A C G I O

A

accumuloInputFormat - Variable in class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat

delegate input format for all accumulo operations.

accumuloOutputFormat - Variable in class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat

Accumulo delegate for table output

AccumuloVertexInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io.accumulo

Class which wraps the AccumuloInputFormat.

AccumuloVertexInputFormat() - Constructor for class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat

AccumuloVertexInputFormat.AccumuloVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io.accumulo

Abstract class which provides a template for instantiating vertices from Accumulo Key/Value pairs.

AccumuloVertexOutputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io.accumulo

Class which wraps the AccumuloOutputFormat.

AccumuloVertexOutputFormat() - Constructor for class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat

AccumuloVertexOutputFormat.AccumuloVertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io.accumulo

Main abstraction point for vertex writers to persist back to Accumulo tables.

AccumuloVertexReader(RecordReader<Key, Value>) - Constructor for class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat.AccumuloVertexReader

Constructor used to pass Record Reader instance

AccumuloVertexWriter(RecordWriter<Text, Mutation>) - Constructor for class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat.AccumuloVertexWriter

Constructor for use with subclasses

C

checkOutputSpecs(JobContext) - Method in class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat

checkOutputSpecs

close() - Method in class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat.AccumuloVertexReader

close

close(TaskAttemptContext) - Method in class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat.AccumuloVertexWriter

close

G

getConfiguration() - Method in class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat.AccumuloVertexReader

getContext() - Method in class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat.AccumuloVertexReader

getContext

getContext() - Method in class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat.AccumuloVertexWriter

Get the context.

getOutputCommitter(TaskAttemptContext) - Method in class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat

getOutputCommitter

getProgress() - Method in class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat.AccumuloVertexReader

getProgress

getRecordReader() - Method in class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat.AccumuloVertexReader

Get the result record reader

getRecordWriter() - Method in class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat.AccumuloVertexWriter

Get the table record writer;

getSplits(JobContext, int) - Method in class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat

I

initialize(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.accumulo.AccumuloVertexInputFormat.AccumuloVertexReader

initialize the reader.

initialize(TaskAttemptContext) - Method in class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat.AccumuloVertexWriter

initialize

O

org.apache.giraph.io.accumulo - package org.apache.giraph.io.accumulo

Accumulo Input/Output for Giraph

OUTPUT_TABLE - Static variable in class org.apache.giraph.io.accumulo.AccumuloVertexOutputFormat

Output table parameter

A C G I O