Uses of Class
org.apache.hadoop.hbase.io.ImmutableBytesWritable
Package
Description
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
-
Uses of org.apache.hadoop.hbase.io.ImmutableBytesWritable in org.apache.hadoop.hbase.io
Modifier and TypeMethodDescriptionint
ImmutableBytesWritable.compareTo
(org.apache.hadoop.hbase.io.ImmutableBytesWritable that) Define the sort order of the BytesWritable.ModifierConstructorDescriptionImmutableBytesWritable
(org.apache.hadoop.hbase.io.ImmutableBytesWritable ibw) Set the new ImmutableBytesWritable to the contents of the passedibw
. -
Uses of org.apache.hadoop.hbase.io.ImmutableBytesWritable in org.apache.hadoop.hbase.mapred
Modifier and TypeMethodDescriptionprotected org.apache.hadoop.hbase.io.ImmutableBytesWritable
GroupingTableMap.createGroupKey
(byte[][] vals) Create a key by concatenating multiple column values.org.apache.hadoop.hbase.io.ImmutableBytesWritable
TableRecordReader.createKey()
org.apache.hadoop.hbase.io.ImmutableBytesWritable
TableRecordReaderImpl.createKey()
Modifier and TypeMethodDescriptionorg.apache.hadoop.mapred.RecordReader<org.apache.hadoop.hbase.io.ImmutableBytesWritable,
org.apache.hadoop.hbase.client.Result> MultiTableSnapshotInputFormat.getRecordReader
(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.hbase.io.ImmutableBytesWritable,
org.apache.hadoop.hbase.client.Result> TableInputFormatBase.getRecordReader
(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) Builds a TableRecordReader.org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.hbase.io.ImmutableBytesWritable,
org.apache.hadoop.hbase.client.Result> TableSnapshotInputFormat.getRecordReader
(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) Modifier and TypeMethodDescriptionint
HRegionPartitioner.getPartition
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, V2 value, int numPartitions) void
GroupingTableMap.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result> output, org.apache.hadoop.mapred.Reporter reporter) Extract the grouping columns from value to construct a new key.void
IdentityTableMap.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result> output, org.apache.hadoop.mapred.Reporter reporter) Pass the key, value to reduceboolean
TableRecordReader.next
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value) boolean
TableRecordReaderImpl.next
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value) void
IdentityTableReduce.reduce
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, Iterator<org.apache.hadoop.hbase.client.Put> values, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Put> output, org.apache.hadoop.mapred.Reporter reporter) No aggregation, output pairs of (key, record)void
TableOutputFormat.TableRecordWriter.write
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Put value) Modifier and TypeMethodDescriptionvoid
GroupingTableMap.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result> output, org.apache.hadoop.mapred.Reporter reporter) Extract the grouping columns from value to construct a new key.void
IdentityTableMap.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result> output, org.apache.hadoop.mapred.Reporter reporter) Pass the key, value to reducevoid
IdentityTableReduce.reduce
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, Iterator<org.apache.hadoop.hbase.client.Put> values, org.apache.hadoop.mapred.OutputCollector<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Put> output, org.apache.hadoop.mapred.Reporter reporter) No aggregation, output pairs of (key, record) -
Uses of org.apache.hadoop.hbase.io.ImmutableBytesWritable in org.apache.hadoop.hbase.mapreduce
Modifier and TypeMethodDescriptionprotected org.apache.hadoop.hbase.io.ImmutableBytesWritable
GroupingTableMapper.createGroupKey
(byte[][] vals) Create a key by concatenating multiple column values.org.apache.hadoop.hbase.io.ImmutableBytesWritable
HashTable.TableHash.Reader.getCurrentHash()
Get the current hashorg.apache.hadoop.hbase.io.ImmutableBytesWritable
HashTable.TableHash.Reader.getCurrentKey()
Get the current keyorg.apache.hadoop.hbase.io.ImmutableBytesWritable
TableRecordReader.getCurrentKey()
Returns the current key.org.apache.hadoop.hbase.io.ImmutableBytesWritable
TableRecordReaderImpl.getCurrentKey()
Returns the current key.org.apache.hadoop.hbase.io.ImmutableBytesWritable
TableSnapshotInputFormatImpl.RecordReader.getCurrentKey()
Modifier and TypeMethodDescriptionorg.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.hbase.io.ImmutableBytesWritable,
org.apache.hadoop.hbase.client.Result> MultiTableInputFormatBase.createRecordReader
(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) Builds a TableRecordReader.org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.hbase.io.ImmutableBytesWritable,
org.apache.hadoop.hbase.client.Result> TableInputFormatBase.createRecordReader
(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) Builds aTableRecordReader
.org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.hbase.io.ImmutableBytesWritable,
org.apache.hadoop.hbase.client.Result> TableSnapshotInputFormat.createRecordReader
(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) static <K2,
V2> Class<org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, K2, V2>> MultithreadedTableMapper.getMapperClass
(org.apache.hadoop.mapreduce.JobContext job) Get the application's mapper class.org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.hbase.io.ImmutableBytesWritable,
org.apache.hadoop.hbase.Cell> HFileOutputFormat2.getRecordWriter
(org.apache.hadoop.mapreduce.TaskAttemptContext context) org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.hbase.io.ImmutableBytesWritable,
org.apache.hadoop.hbase.client.Mutation> MultiTableOutputFormat.getRecordWriter
(org.apache.hadoop.mapreduce.TaskAttemptContext context) Modifier and TypeMethodDescriptionstatic byte[]
MultiTableHFileOutputFormat.createCompositeKey
(byte[] tableName, org.apache.hadoop.hbase.io.ImmutableBytesWritable suffix) Alternate api which accepts an ImmutableBytesWritable for the suffixstatic byte[]
MultiTableHFileOutputFormat.createCompositeKey
(String tableName, org.apache.hadoop.hbase.io.ImmutableBytesWritable suffix) Alternate api which accepts a String for the tableName and ImmutableBytesWritable for the suffixint
HRegionPartitioner.getPartition
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, VALUE value, int numPartitions) Gets the partition number for a given key (hence record) given the total number of partitions i.e.int
SimpleTotalOrderPartitioner.getPartition
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, VALUE value, int reduces) void
GroupingTableMapper.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result>.org.apache.hadoop.mapreduce.Mapper.Context context) Extract the grouping columns from value to construct a new key.protected void
HashTable.HashMapper.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.io.ImmutableBytesWritable>.org.apache.hadoop.mapreduce.Mapper.Context context) void
IdentityTableMapper.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result>.org.apache.hadoop.mapreduce.Mapper.Context context) Pass the key, value to reduce.void
Import.CellImporter.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable row, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.Cell>.org.apache.hadoop.mapreduce.Mapper.Context context) void
Import.CellSortImporter.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable row, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.mapreduce.Import.CellWritableComparable, org.apache.hadoop.hbase.Cell>.org.apache.hadoop.mapreduce.Mapper.Context context) void
Import.Importer.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable row, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context) void
Import.KeyValueImporter.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable row, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.KeyValue>.org.apache.hadoop.mapreduce.Mapper.Context context) Deprecated.void
Import.KeyValueSortImporter.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable row, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.mapreduce.Import.KeyValueWritableComparable, org.apache.hadoop.hbase.KeyValue>.org.apache.hadoop.mapreduce.Mapper.Context context) Deprecated.protected void
IndexBuilder.Map.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable rowKey, org.apache.hadoop.hbase.client.Result result, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Put>.org.apache.hadoop.mapreduce.Mapper.Context context) protected void
SyncTable.SyncMapper.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result value, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context) org.apache.hadoop.hbase.mapreduce.HashTable.TableHash.Reader
HashTable.TableHash.newReader
(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.io.ImmutableBytesWritable startKey) Open a TableHash.Reader starting at the first hash at or after the given key.protected void
Import.Importer.processKV
(org.apache.hadoop.hbase.io.ImmutableBytesWritable key, org.apache.hadoop.hbase.client.Result result, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Mutation>.org.apache.hadoop.mapreduce.Mapper.Context context, org.apache.hadoop.hbase.client.Put put, org.apache.hadoop.hbase.client.Delete delete) protected void
CellSortReducer.reduce
(org.apache.hadoop.hbase.io.ImmutableBytesWritable row, Iterable<org.apache.hadoop.hbase.Cell> kvs, org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.Cell, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.Cell>.org.apache.hadoop.mapreduce.Reducer.Context context) protected void
KeyValueSortReducer.reduce
(org.apache.hadoop.hbase.io.ImmutableBytesWritable row, Iterable<org.apache.hadoop.hbase.KeyValue> kvs, org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.KeyValue, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.KeyValue>.org.apache.hadoop.mapreduce.Reducer.Context context) Deprecated.protected void
PutSortReducer.reduce
(org.apache.hadoop.hbase.io.ImmutableBytesWritable row, Iterable<org.apache.hadoop.hbase.client.Put> puts, org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Put, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.KeyValue>.org.apache.hadoop.mapreduce.Reducer.Context context) protected void
TextSortReducer.reduce
(org.apache.hadoop.hbase.io.ImmutableBytesWritable rowKey, Iterable<org.apache.hadoop.io.Text> lines, org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.io.Text, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.KeyValue>.org.apache.hadoop.mapreduce.Reducer.Context context) void
MultiTableOutputFormat.MultiTableRecordWriter.write
(org.apache.hadoop.hbase.io.ImmutableBytesWritable tableName, org.apache.hadoop.hbase.client.Mutation action) Writes an action (Put or Delete) to the specified table.Modifier and TypeMethodDescriptionstatic <K2,
V2> void MultithreadedTableMapper.setMapperClass
(org.apache.hadoop.mapreduce.Job job, Class<? extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, K2, V2>> cls) Set the application's mapper class. -
Uses of org.apache.hadoop.hbase.io.ImmutableBytesWritable in org.apache.hadoop.hbase.mob.mapreduce
Modifier and TypeMethodDescriptionvoid
MobRefReporter.MobRefMapper.map
(org.apache.hadoop.hbase.io.ImmutableBytesWritable r, org.apache.hadoop.hbase.client.Result columns, org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.hbase.client.Result, org.apache.hadoop.io.Text, org.apache.hadoop.hbase.io.ImmutableBytesWritable>.org.apache.hadoop.mapreduce.Mapper.Context context) Modifier and TypeMethodDescriptionvoid
MobRefReporter.MobRefReducer.reduce
(org.apache.hadoop.io.Text key, Iterable<org.apache.hadoop.hbase.io.ImmutableBytesWritable> rows, org.apache.hadoop.mapreduce.Reducer<org.apache.hadoop.io.Text, org.apache.hadoop.hbase.io.ImmutableBytesWritable, org.apache.hadoop.io.Text, org.apache.hadoop.io.Text>.org.apache.hadoop.mapreduce.Reducer.Context context)