Package | Description |
---|---|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
org.apache.giraph.master |
Package of all the master related things.
|
Modifier and Type | Method and Description |
---|---|
GiraphClasses |
GiraphClasses.setAggregatorWriterClass(Class<? extends AggregatorWriter> aggregatorWriterClass)
Set AggregatorWriter class used
|
GiraphClasses |
GiraphClasses.setComputationClass(Class<? extends Computation<I,V,E,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable>> computationClass)
Set Computation class held, and update message types
|
GiraphClasses |
GiraphClasses.setEdgeInputFormatClass(Class<? extends EdgeInputFormat<I,E>> edgeInputFormatClass)
Set EdgeInputFormat class held
|
GiraphClasses |
GiraphClasses.setEdgeValueClass(Class<E> edgeValueClass)
Set Edge Value class held
|
GiraphClasses |
GiraphClasses.setGraphPartitionerFactoryClass(Class<? extends GraphPartitionerFactory<I,V,E>> klass)
Set GraphPartitionerFactory class held
|
GiraphClasses |
GiraphClasses.setIncomingMessageClasses(MessageClasses<I,? extends org.apache.hadoop.io.Writable> incomingMessageClasses)
Set incoming Message Value class held - messages which have been sent in
the previous superstep and are processed in the current one
|
GiraphClasses |
GiraphClasses.setInputOutEdgesClass(Class<? extends OutEdges> inputOutEdgesClass)
Set OutEdges class used during edge-input (if different from the one
used for computation)
|
GiraphClasses |
GiraphClasses.setMappingInputFormatClass(Class<? extends MappingInputFormat<I,V,E,org.apache.hadoop.io.Writable>> mappingInputFormatClass)
Set MappingInputFormat held
|
GiraphClasses |
GiraphClasses.setMasterComputeClass(Class<? extends MasterCompute> masterComputeClass)
Set MasterCompute class used
|
GiraphClasses |
GiraphClasses.setOutEdgesClass(Class<? extends OutEdges> outEdgesClass)
Set OutEdges class held
|
GiraphClasses |
GiraphClasses.setOutgoingMessageClasses(MessageClasses<I,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses)
Set outgoing Message Value class held - messages which are going to be sent
during current superstep
|
GiraphClasses |
GiraphClasses.setPartitionClass(Class<? extends Partition<I,V,E>> partitionClass)
Set Partition class to use
|
GiraphClasses |
GiraphClasses.setVertexIdClass(Class<I> vertexIdClass)
Set Vertex ID class held
|
GiraphClasses |
GiraphClasses.setVertexInputFormatClass(Class<? extends VertexInputFormat<I,V,E>> vertexInputFormatClass)
Set VertexInputFormat held
|
GiraphClasses |
GiraphClasses.setVertexOutputFormatClass(Class<? extends VertexOutputFormat<I,V,E>> vertexOutputFormatClass)
Set VertexOutputFormat held
|
GiraphClasses |
GiraphClasses.setVertexResolverClass(Class<? extends VertexResolver<I,V,E>> vertexResolverClass)
Set VertexResolver used
|
GiraphClasses |
GiraphClasses.setVertexValueClass(Class<V> vertexValueClass)
Set Vertex Value class held
|
GiraphClasses |
GiraphClasses.setWorkerContextClass(Class<? extends WorkerContext> workerContextClass)
Set WorkerContext used
|
Modifier and Type | Method and Description |
---|---|
void |
SuperstepClasses.updateGiraphClasses(GiraphClasses classes)
Update GiraphClasses with updated types
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.