Package org.apache.hadoop.hbase.mapred
package org.apache.hadoop.hbase.mapred
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
See HBase and MapReduce in the HBase Reference Guide for mapreduce over hbase documentation.
-
ClassDescriptionDriver for hbase mapreduce jobs.Extract grouping columns from input recordHRegionPartitioner<K2,
V2> This is used to partition the output keys into groups of keys.Pass the given key and record as-is to reduceWrite to table each key, record pairMultiTableSnapshotInputFormat generalizesTableSnapshotInputFormat
allowing a MapReduce job to run over one or more table snapshots, with one or more scans configured for each.A job with a map to count rows.Mapper that runs the count.Convert HBase tabular data into a format that is consumable by Map/Reduce.A Base forTableInputFormat
s.TableMap<K extends org.apache.hadoop.io.WritableComparable<? super K>,V> Scan an HBase table to sort by a specified sort column.Utility forTableMap
andTableReduce
Convert Map/Reduce output and write it to an HBase tableConvert Reduce output (key, value) to (HStoreKey, KeyedDataArrayWritable) and write to an HBase table.Iterate over an HBase table data, return (Text, RowResult) pairsIterate over an HBase table data, return (Text, RowResult) pairsTableReduce<K extends org.apache.hadoop.io.WritableComparable,V> Write a table, sorting by the input keyTableSnapshotInputFormat allows a MapReduce job to run over a table snapshot.A table split corresponds to a key range [low, high)