| Class | Description |
|---|---|
| IntegrationTestSparkBulkLoad |
Test Bulk Load and Spark on a distributed cluster.
|
| IntegrationTestSparkBulkLoad.createCombinerFunc | |
| IntegrationTestSparkBulkLoad.LinkedListCheckingFlatMapFunc |
PairFlatMapFunction used to transfer
|
| IntegrationTestSparkBulkLoad.LinkedListCheckingForeachFunc |
Sort all LinkChain for one LinkKey, and test List
|
| IntegrationTestSparkBulkLoad.LinkedListCreationMapper | |
| IntegrationTestSparkBulkLoad.ListToKeyValueFunc | |
| IntegrationTestSparkBulkLoad.mergeCombinersFunc | |
| IntegrationTestSparkBulkLoad.mergeValueFunc | |
| IntegrationTestSparkBulkLoad.NaturalKeyPartitioner |
Class to figure out what partition to send a link in the chain to.
|
| IntegrationTestSparkBulkLoad.SparkLinkChain |
Writable used as the value emitted from a pass over the hbase table.
|
| IntegrationTestSparkBulkLoad.SparkLinkKey |
Writable class used as the key to group links in the linked list.
|