Question : You have a MapReduce job, which uses HBase as source and Sink. It reads some stock market data PRICE, DIVIDEND, VOLUME (All there are stored in different column family.) However, data come from various vendor like Bloomberg, Reuters and Markit. Using MapReduce job we filter out most accurate data. And marked them as valid record and save back in same table with updated flag value. Table name is "MARKET_DATA" . You have written following Driver code. And also you want to process data for DIVIDEND column family.