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.
|