| Package | Description |
|---|---|
| org.cloudgraph.hbase.mapreduce |
Contains MapReduce extension, implementation and other infrastructure classes which allow SDO data graphs of any depth or complexity, to be queried, consumed, produced and
modified by Hadoop HBase MapReduce jobs.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
GraphMapReduceSetup.setupGraphReducerJob(org.plasma.query.Query query,
Class<? extends GraphReducer> reducer,
org.apache.hadoop.mapreduce.Job job,
Class partitioner,
StoreMappingContext mappingContext)
Use this before submitting a graph reduce job.
|
static void |
GraphMapReduceSetup.setupGraphReducerJob(org.plasma.query.Query query,
Class<? extends GraphReducer> reducer,
org.apache.hadoop.mapreduce.Job job,
Class partitioner,
String quorumAddress,
String serverClass,
String serverImpl,
boolean addDependencyJars,
StoreMappingContext mappingContext)
Use this before submitting a TableReduce job.
|
static void |
GraphMapReduceSetup.setupGraphReducerJob(org.plasma.query.Query query,
Class<? extends GraphReducer> reducer,
org.apache.hadoop.mapreduce.Job job,
Class partitioner,
String quorumAddress,
String serverClass,
String serverImpl,
StoreMappingContext mappingContext)
Use this before submitting a graph reduce job.
|
static void |
GraphMapReduceSetup.setupGraphReducerJob(org.plasma.query.Query query,
Class<? extends GraphReducer> reducer,
org.apache.hadoop.mapreduce.Job job,
StoreMappingContext mappingContext)
Use this before submitting a graph reduce job.
|
Copyright © 2021. All Rights Reserved.