Package org.apache.hadoop.hbase.mapreduce
package org.apache.hadoop.hbase.mapreduce
-
ClassDescriptionBase class for testing CopyTable MR tool.Test CopyTable between clustersTest Bulk Load and MR on a distributed cluster.Comparator used to order linkKeys so that they are passed to a reducer in order.Writable used as the value emitted from a pass over the hbase table.Mapper to pass over the table.Class that does the actual checking of the links.Mapper that creates a linked list of KeyValues.Writable class used as the key to group links in the linked list.Comparator used to figure out if a linkKey should be grouped together.Class to figure out what partition to send a link in the chain to.Test Bulk Load and MR on a distributed cluster.Validate ImportTsv + BulkLoadFiles on a distributed cluster.Test that we add tmpjars correctly including the named dependencies.An integration test to test
TableSnapshotInputFormatwhich enables reading directly from snapshot files without going through hbase servers.This class provides shims for HBase to interact with the Hadoop 1.0.x and the Hadoop 0.23.x series.Base set of tests and setup for input formats touching multiple tables.Pass the key and value to reducer.Checks the last and first keys seen against the scanner boundaries.Input format that creates a configurable number of map tasks each provided with a single row of NullWritables.Basic test for the CopyTable M/R toolBasic test for the HashTable M/R toolSimple test forHFileOutputFormat2.Simple mapper that makes KeyValue output.Simple mapper that makes Put output.Tests the table import and table export MR job functionalityThis listens to theTestImportExport.TableWALActionListener.visitLogEntryBeforeWrite(RegionInfo, WALKey, WALEdit)to identify that an entry is written to the Write Ahead Log for the given table.Tests forImportTsv.TsvParser.This file was forked from hadoop/common/branches/branch-2@1350012.Tests various scan start and stop row scenarios.Tests of MultiTableInputFormatBase.Connection to use above in Test.Test Map/Reduce job over HBase tables.Pass the given key and processed record reduceBasic test ofRoundRobinTableInputFormat; i.e.Private comparator copied from private JobSubmmiter Hadoop class...Test the rowcounter map reduce job.Test of simple partitioner.Basic test for the SyncTable M/R toolThis tests the TableInputFormat and its recovery semanticsConnection class to use inTestTableInputFormatBase.testNonSuccessiveSplitsAreNotMerged().Subclass ofTableInputFormatto use inTestTableInputFormatBase.testNonSuccessiveSplitsAreNotMerged().Tests various scan start and stop row scenarios.Pass the key and value to reduce.Checks the last and first key seen against the scanner boundaries.Test Map/Reduce job over HBase tables.Pass the given key and processed record reduceA base class for a test Map/Reduce job over HBase tables.Test different variants of initTableMapperJob methodSimple Tests to check whether the durability of the Mutation is changed or not, forTableOutputFormatifTableOutputFormat.WAL_PROPERTYis set to false.Basic test for the WALPlayer M/R toolJUnit tests for the WALRecordReaderDummy mapper used for unit tests to verify that the mapper can be injected.Just shows a simple example of how the attributes can be extracted and added to the puts