| IntegrationTestBulkLoad |
Test Bulk Load and MR on a distributed cluster.
|
| IntegrationTestBulkLoad.CompositeKeyComparator |
Comparator used to order linkKeys so that they are passed to a reducer in order.
|
| IntegrationTestBulkLoad.EmptySplit |
|
| IntegrationTestBulkLoad.FixedRecordReader<K,V> |
|
| IntegrationTestBulkLoad.ITBulkLoadInputFormat |
|
| IntegrationTestBulkLoad.LinkChain |
Writable used as the value emitted from a pass over the hbase table.
|
| IntegrationTestBulkLoad.LinkedListCheckingMapper |
Mapper to pass over the table.
|
| IntegrationTestBulkLoad.LinkedListCheckingReducer |
Class that does the actual checking of the links.
|
| IntegrationTestBulkLoad.LinkedListCreationMapper |
Mapper that creates a linked list of KeyValues.
|
| IntegrationTestBulkLoad.LinkKey |
Writable class used as the key to group links in the linked list.
|
| IntegrationTestBulkLoad.NaturalKeyGroupingComparator |
Comparator used to figure out if a linkKey should be grouped together.
|
| IntegrationTestBulkLoad.NaturalKeyPartitioner |
Class to figure out what partition to send a link in the chain to.
|
| IntegrationTestBulkLoad.SlowMeCoproScanOperations |
|
| IntegrationTestImportTsv |
Validate ImportTsv + LoadIncrementalHFiles on a distributed cluster.
|
| IntegrationTestTableMapReduceUtil |
Test that we add tmpjars correctly including the named dependencies.
|
| IntegrationTestTableSnapshotInputFormat |
An integration test to test TableSnapshotInputFormat which enables
reading directly from snapshot files without going through hbase servers.
|
| MapreduceTestingShim |
This class provides shims for HBase to interact with the Hadoop 1.0.x and the
Hadoop 0.23.x series.
|
| MapreduceTestingShim.MapreduceV1Shim |
|
| MapreduceTestingShim.MapreduceV2Shim |
|
| MultiTableInputFormatTestBase |
Base set of tests and setup for input formats touching multiple tables.
|
| MultiTableInputFormatTestBase.ScanMapper |
Pass the key and value to reducer.
|
| MultiTableInputFormatTestBase.ScanReducer |
Checks the last and first keys seen against the scanner boundaries.
|
| NMapInputFormat |
Input format that creates a configurable number of map tasks
each provided with a single row of NullWritables.
|
| NMapInputFormat.NullInputSplit |
|
| NMapInputFormat.SingleRecordReader<K,V> |
|
| TableSnapshotInputFormatTestBase |
|
| TestCellBasedHFileOutputFormat2 |
Simple test for HFileOutputFormat2.
|
| TestCellBasedHFileOutputFormat2.RandomKVGeneratingMapper |
Simple mapper that makes KeyValue output.
|
| TestCellBasedHFileOutputFormat2.RandomPutGeneratingMapper |
Simple mapper that makes Put output.
|
| TestCellBasedImportExport2 |
Tests the table import and table export MR job functionality
|
| TestCellBasedImportExport2.TableWALActionListener |
This listens to the WALActionsListener.visitLogEntryBeforeWrite(RegionInfo, WALKey, WALEdit) to
identify that an entry is written to the Write Ahead Log for the given table.
|
| TestCellBasedWALPlayer2 |
Basic test for the WALPlayer M/R tool
|
| TestCellCounter |
|
| TestCopyTable |
Basic test for the CopyTable M/R tool
|
| TestGroupingTableMapper |
|
| TestHashTable |
Basic test for the HashTable M/R tool
|
| TestHBaseMRTestingUtility |
|
| TestHFileOutputFormat2 |
Simple test for HFileOutputFormat2.
|
| TestHFileOutputFormat2.RandomKVGeneratingMapper |
Simple mapper that makes KeyValue output.
|
| TestHFileOutputFormat2.RandomPutGeneratingMapper |
Simple mapper that makes Put output.
|
| TestHRegionPartitioner |
|
| TestImportExport |
Tests the table import and table export MR job functionality
|
| TestImportExport.TableWALActionListener |
This listens to the WALActionsListener.visitLogEntryBeforeWrite(RegionInfo, WALKey, WALEdit) to
identify that an entry is written to the Write Ahead Log for the given table.
|
| TestImportTsv |
|
| TestImportTsvParser |
Tests for ImportTsv.TsvParser.
|
| TestImportTSVWithOperationAttributes |
|
| TestImportTSVWithOperationAttributes.OperationAttributesTestController |
|
| TestImportTSVWithTTLs |
|
| TestImportTSVWithTTLs.TTLCheckingObserver |
|
| TestImportTSVWithVisibilityLabels |
|
| TestJarFinder |
This file was forked from hadoop/common/branches/branch-2@1350012.
|
| TestMapReduceExamples |
|
| TestMultiTableInputFormat |
Tests various scan start and stop row scenarios.
|
| TestMultiTableInputFormatBase |
Tests of MultiTableInputFormatBase.
|
| TestMultiTableInputFormatBase.MRSplitsConnection |
Connection to use above in Test.
|
| TestMultiTableSnapshotInputFormat |
|
| TestMultiTableSnapshotInputFormatImpl |
|
| TestMultiTableSnapshotInputFormatImpl.ScanWithEquals |
|
| TestMultithreadedTableMapper |
Test Map/Reduce job over HBase tables.
|
| TestMultithreadedTableMapper.ProcessContentsMapper |
Pass the given key and processed record reduce
|
| TestRegionSizeCalculator |
|
| TestRowCounter |
Test the rowcounter map reduce job.
|
| TestSimpleTotalOrderPartitioner |
Test of simple partitioner.
|
| TestSyncTable |
Basic test for the SyncTable M/R tool
|
| TestTableInputFormat |
This tests the TableInputFormat and its recovery semantics
|
| TestTableInputFormat.ExampleDeprecatedTIF |
|
| TestTableInputFormat.ExampleJobConfigurableTIF |
|
| TestTableInputFormat.ExampleTIF |
|
| TestTableInputFormat.ExampleVerifier |
|
| TestTableInputFormatBase |
|
| TestTableInputFormatBase.ConnectionForMergeTesting |
|
| TestTableInputFormatBase.TableInputFormatForMergeTesting |
|
| TestTableInputFormatScan |
|
| TestTableInputFormatScanBase |
Tests various scan start and stop row scenarios.
|
| TestTableInputFormatScanBase.ScanMapper |
Pass the key and value to reduce.
|
| TestTableInputFormatScanBase.ScanReducer |
Checks the last and first key seen against the scanner boundaries.
|
| TestTableInputFormatScanEmptyToAPP |
|
| TestTableInputFormatScanEmptyToBBA |
|
| TestTableInputFormatScanEmptyToBBB |
|
| TestTableInputFormatScanEmptyToEmpty |
|
| TestTableInputFormatScanEmptyToOPP |
|
| TestTableInputFormatScanOBBToOPP |
|
| TestTableInputFormatScanOBBToQPP |
|
| TestTableInputFormatScanOPPToEmpty |
|
| TestTableInputFormatScanYYXToEmpty |
|
| TestTableInputFormatScanYYYToEmpty |
|
| TestTableInputFormatScanYZYToEmpty |
|
| TestTableMapReduce |
Test Map/Reduce job over HBase tables.
|
| TestTableMapReduce.ProcessContentsMapper |
Pass the given key and processed record reduce
|
| TestTableMapReduceBase |
A base class for a test Map/Reduce job over HBase tables.
|
| TestTableMapReduceUtil |
Test different variants of initTableMapperJob method
|
| TestTableRecordReader |
|
| TestTableSnapshotInputFormat |
|
| TestTableSnapshotInputFormat.TestTableSnapshotMapper |
|
| TestTableSnapshotInputFormat.TestTableSnapshotReducer |
|
| TestTableSplit |
|
| TestTimeRangeMapRed |
|
| TestTimeRangeMapRed.ProcessTimeRangeMapper |
|
| TestWALPlayer |
Basic test for the WALPlayer M/R tool
|
| TestWALRecordReader |
JUnit tests for the WALRecordReader
|
| TsvImporterCustomTestMapper |
Dummy mapper used for unit tests to verify that the mapper can be injected.
|
| TsvImporterCustomTestMapperForOprAttr |
Just shows a simple example of how the attributes can be extracted and added
to the puts
|