| 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.setupGraphMapperJob(org.plasma.query.Query query,
Class<? extends GraphMapper> mapper,
Class<? extends org.apache.hadoop.io.WritableComparable> outputKeyClass,
Class<? extends org.apache.hadoop.io.Writable> outputValueClass,
org.apache.hadoop.mapreduce.Job job)
Use this before submitting a graph map job.
|
static void |
GraphMapReduceSetup.setupGraphMapperJob(org.plasma.query.Query query,
Class<? extends GraphMapper> mapper,
Class<? extends org.apache.hadoop.io.WritableComparable> outputKeyClass,
Class<? extends org.apache.hadoop.io.Writable> outputValueClass,
org.apache.hadoop.mapreduce.Job job,
boolean addDependencyJars)
Use this before submitting a graph map job.
|
static void |
GraphMapReduceSetup.setupGraphMapperJob(org.plasma.query.Query query,
Class<? extends GraphMapper> mapper,
Class<? extends org.apache.hadoop.io.WritableComparable> outputKeyClass,
Class<? extends org.apache.hadoop.io.Writable> outputValueClass,
org.apache.hadoop.mapreduce.Job job,
boolean addDependencyJars,
Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)
Use this before submitting a graph map job.
|
Copyright © 2021. All Rights Reserved.