org.apache.giraph.conf

Class GiraphClasses<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.conf.GiraphClasses<I,V,E>

Type Parameters:

I - Vertex ID class

V - Vertex Value class

E - Edge class

All Implemented Interfaces:

GiraphConstants

public class GiraphClasses<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
extends Object
implements GiraphConstants

Holder for classes used by Giraph.

Field Summary

Fields

Modifier and Type	Field and Description
protected Class<? extends AggregatorWriter>	aggregatorWriterClass Aggregator writer class - cached for fast access
protected Class<? extends Computation<I,V,E,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable>>	computationClass Computation class - cached for fast access
protected Class<? extends ComputationFactory<I,V,E,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable>>	computationFactoryClass ComputationFactory class - cached for fast access
protected Class<? extends EdgeInputFilter<I,E>>	edgeInputFilterClass Edge Input Filter class
protected Class<? extends EdgeInputFormat<I,E>>	edgeInputFormatClass Edge input format class - cached for fast access
protected Class<? extends EdgeOutputFormat<I,V,E>>	edgeOutputFormatClass Edge output format class - cached for fast access
protected GiraphTypes<I,V,E>	giraphTypes Generic types used to describe graph
protected Class<? extends GraphPartitionerFactory<I,V,E>>	graphPartitionerFactoryClass Graph partitioner factory class - cached for fast access
protected MessageClasses<I,? extends org.apache.hadoop.io.Writable>	incomingMessageClasses Incoming message classes
protected Class<? extends OutEdges<I,E>>	inputOutEdgesClass Input vertex edges class - cached for fast access
protected Class<? extends MappingInputFormat<I,V,E,? extends org.apache.hadoop.io.Writable>>	mappingInputFormatClass Mapping input format - cached for fast access
protected Class<? extends MasterCompute>	masterComputeClass Master compute class - cached for fast access
protected Class<? extends OutEdges<I,E>>	outEdgesClass Vertex edges class - cached for fast access
protected MessageClasses<I,? extends org.apache.hadoop.io.Writable>	outgoingMessageClasses Outgoing message classes
protected Class<? extends Partition<I,V,E>>	partitionClass Partition class - cached for fast accesss
protected Class<? extends VertexInputFilter<I,V,E>>	vertexInputFilterClass Vertex Input Filter class
protected Class<? extends VertexInputFormat<I,V,E>>	vertexInputFormatClass Vertex input format class - cached for fast access
protected Class<? extends VertexOutputFormat<I,V,E>>	vertexOutputFormatClass Vertex output format class - cached for fast access
protected Class<? extends VertexResolver<I,V,E>>	vertexResolverClass Vertex resolver class - cached for fast access
protected Class<? extends VertexValueCombiner<V>>	vertexValueCombinerClass Vertex value combiner class - cached for fast access
protected Class<? extends WorkerContext>	workerContextClass Worker context class - cached for fast access

Fields inherited from interface org.apache.giraph.conf.GiraphConstants

ADDITIONAL_EDGE_REQUEST_SIZE, ADDITIONAL_MSG_REQUEST_SIZE, ADDITIONAL_VERTEX_REQUEST_SIZE, AGGREGATOR_WRITER_CLASS, ASYNC_MESSAGE_STORE_THREADS_COUNT, AUTHENTICATE, BASE_ZNODE_KEY, CHANNELS_PER_SERVER, CHECKPOINT_COMPRESSION_CODEC, CHECKPOINT_DIRECTORY, CHECKPOINT_FREQUENCY, CHECKPOINT_SUPPORTED_CHECKER, CLEANUP_CHECKPOINTS_AFTER_SUCCESS, CLIENT_RECEIVE_BUFFER_SIZE, CLIENT_SEND_BUFFER_SIZE, COMPUTATION_CLASS, COMPUTATION_FACTORY_CLASS, COMPUTATION_LANGUAGE, CREATE_EDGE_SOURCE_VERTICES, CREATE_EDGE_SOURCE_VERTICES_CALLBACK, DEFAULT_ZOOKEEPER_MAX_CLIENT_CNXNS, DEFAULT_ZOOKEEPER_SNAP_COUNT, DEFAULT_ZOOKEEPER_TICK_TIME, DISABLE_GIRAPH_CLASS_RESOLVER, DNS_INTERFACE, DNS_NAMESERVER, DO_OUTPUT_DURING_COMPUTATION, EDGE_INPUT_FILTER_CLASS, EDGE_INPUT_FORMAT_CLASS, EDGE_OUTPUT_FORMAT_CLASS, EDGE_OUTPUT_FORMAT_SUBDIR, EDGE_STORE_FACTORY_CLASS, EDGE_TRANSLATION_CLASS, EDGE_VALUE_CLASS, EDGE_VALUE_FACTORY_CLASS, EVENT_WAIT_MSECS, FAIL_FIRST_IPC_PORT_BIND_ATTEMPT, FAIL_ON_EMPTY_INPUT, GC_OBSERVER_CLASSES, GIRAPH_TEXT_OUTPUT_FORMAT_REVERSE, GIRAPH_TEXT_OUTPUT_FORMAT_SEPARATOR, GIRAPH_YARN_CONF_FILE, GIRAPH_YARN_LIBJARS, GIRAPH_YARN_PRIORITY, GIRAPH_YARN_TASK_HEAP_MB, GIRAPH_YARN_TASK_HEAP_MB_DEFAULT, GRAPH_PARTITIONER_FACTORY_CLASS, GRAPH_TYPE_LANGUAGES, GRAPH_TYPES_NEEDS_WRAPPERS, HADOOP_OUTPUT_FORMAT_CLASS, HALT_INSTRUCTIONS_WRITER_CLASS, HDFS_FILE_CREATION_RETRIES, HDFS_FILE_CREATION_RETRY_WAIT_MS, INPUT_SPLIT_MAX_EDGES, INPUT_SPLIT_MAX_VERTICES, INPUT_SPLIT_SAMPLE_PERCENT, INPUT_VERTEX_EDGES_CLASS, INPUT_VERTEX_EDGES_FACTORY_CLASS, IPC_INITIAL_PORT, IS_PURE_YARN_JOB, JMAP_ENABLE, JMAP_LIVE_ONLY, JMAP_PATH, JMAP_PRINT_LINES, JMAP_SLEEP_MILLIS, JOB_OBSERVER_CLASS, JOB_PROGRESS_TRACKER_CLIENT_CLASS, JOB_PROGRESS_TRACKER_SERVICE_CLASS, JOB_RETRY_CHECKER_CLASS, KEEP_ZOOKEEPER_DATA, LB_MAPPINGSTORE_LOWER, LB_MAPPINGSTORE_UPPER, LOCAL_TEST_MODE, LOG_LEVEL, LOG_THREAD_LAYOUT, MAPPER_OBSERVER_CLASSES, MAPPING_INPUT_FORMAT_CLASS, MAPPING_STORE_CLASS, MAPPING_STORE_OPS_CLASS, MASTER_COMPUTE_CLASS, MASTER_OBSERVER_CLASSES, MAX_ALLOWED_JOB_TIME_MS, MAX_COUNTER_WAIT_MSECS, MAX_EDGE_REQUEST_SIZE, MAX_IPC_PORT_BIND_ATTEMPTS, MAX_MASTER_SUPERSTEP_WAIT_MSECS, MAX_MSG_REQUEST_SIZE, MAX_MUTATIONS_PER_REQUEST, MAX_NUMBER_OF_SUPERSTEPS, MAX_PARTITIONS_IN_MEMORY, MAX_REQUEST_MILLISECONDS, MAX_RESOLVE_ADDRESS_ATTEMPTS, MAX_TASK_ATTEMPTS, MAX_VERTEX_REQUEST_SIZE, MAX_WORKERS, MESSAGE_COMBINER_CLASS, MESSAGE_ENCODE_AND_STORE_TYPE, MESSAGE_STORE_FACTORY_CLASS, METRICS_DIRECTORY, METRICS_ENABLE, MIN_FREE_MBS_ON_HEAP, MIN_PARTITIONS_PER_COMPUTE_THREAD, MIN_PERCENT_RESPONDED, MIN_WORKERS, MSG_NUM_FLUSH_THREADS, NETTY_CLIENT_EXECUTION_AFTER_HANDLER, NETTY_CLIENT_EXECUTION_THREADS, NETTY_CLIENT_THREADS, NETTY_CLIENT_USE_EXECUTION_HANDLER, NETTY_COMPRESSION_ALGORITHM, NETTY_MAX_CONNECTION_FAILURES, NETTY_REQUEST_ENCODER_BUFFER_SIZE, NETTY_SERVER_EXECUTION_AFTER_HANDLER, NETTY_SERVER_EXECUTION_THREADS, NETTY_SERVER_THREADS, NETTY_SERVER_USE_EXECUTION_HANDLER, NETTY_SIMULATE_FIRST_REQUEST_CLOSED, NETTY_SIMULATE_FIRST_RESPONSE_FAILED, NETTY_USE_DIRECT_MEMORY, NETTY_USE_POOLED_ALLOCATOR, NUM_CHECKPOINT_IO_THREADS, NUM_COMPUTE_THREADS, NUM_INPUT_THREADS, NUM_OUT_OF_CORE_THREADS, NUM_OUTPUT_THREADS, ONE_KB, ONE_MB, OUT_OF_CORE_DATA_ACCESSOR, OUT_OF_CORE_ORACLE, OUTGOING_MESSAGE_VALUE_CLASS, OUTGOING_MESSAGE_VALUE_FACTORY_CLASS, PARTITION_CLASS, PARTITION_COUNT_MULTIPLIER, PARTITION_LONG_TAIL_MIN_PRINT, PARTITION_VERTEX_KEY_SPACE_SIZE, PARTITIONS_DIRECTORY, PREFER_IP_ADDRESSES, REACTIVE_JMAP_ENABLE, REQUEST_SIZE_WARNING_THRESHOLD, RESEND_TIMED_OUT_REQUESTS, RESOLVER_CREATE_VERTEX_ON_MSGS, RESTART_JOB_ID, RESTART_SUPERSTEP, SERVER_RECEIVE_BUFFER_SIZE, SERVER_SEND_BUFFER_SIZE, SPLIT_MASTER_WORKER, STATIC_GRAPH, SUPERSTEP_COUNT, TCP_BACKLOG, TRACK_JOB_PROGRESS_ON_CLIENT, TYPES_HOLDER_CLASS, USE_BIG_DATA_IO_FOR_MESSAGES, USE_INPUT_SPLIT_LOCALITY, USE_MESSAGE_SIZE_ENCODING, USE_OUT_OF_CORE_GRAPH, USE_SUPERSTEP_COUNTERS, USE_UNSAFE_SERIALIZATION, USER_PARTITION_COUNT, VERTEX_CLASS, VERTEX_EDGES_CLASS, VERTEX_EDGES_FACTORY_CLASS, VERTEX_ID_CLASS, VERTEX_ID_FACTORY_CLASS, VERTEX_INPUT_FILTER_CLASS, VERTEX_INPUT_FORMAT_CLASS, VERTEX_OUTPUT_FORMAT_CLASS, VERTEX_OUTPUT_FORMAT_SUBDIR, VERTEX_OUTPUT_FORMAT_THREAD_SAFE, VERTEX_RESOLVER_CLASS, VERTEX_VALUE_CLASS, VERTEX_VALUE_COMBINER_CLASS, VERTEX_VALUE_FACTORY_CLASS, VERTICES_TO_UPDATE_PROGRESS, WAIT_FOR_OTHER_WORKERS_TIMEOUT_MSEC, WAIT_TASK_DONE_TIMEOUT_MS, WAIT_TIME_BETWEEN_CONNECTION_RETRIES_MS, WAIT_ZOOKEEPER_TIMEOUT_MSEC, WAITING_REQUEST_MSECS, WORKER_CONTEXT_CLASS, WORKER_OBSERVER_CLASSES, YOURKIT_OUTPUT_DIR, YOURKIT_OUTPUT_DIR_DEFAULT, ZOOKEEPER_BASE_PATH_COUNTER_GROUP, ZOOKEEPER_CONNECTION_ATTEMPTS, ZOOKEEPER_DIR, ZOOKEEPER_FORCE_SYNC, ZOOKEEPER_HALT_NODE_COUNTER_GROUP, ZOOKEEPER_IS_EXTERNAL, ZOOKEEPER_LIST, ZOOKEEPER_MANAGER_DIRECTORY, ZOOKEEPER_MAX_SESSION_TIMEOUT, ZOOKEEPER_MIN_SESSION_TIMEOUT, ZOOKEEPER_OPS_MAX_ATTEMPTS, ZOOKEEPER_OPS_RETRY_WAIT_MSECS, ZOOKEEPER_PURGE_INTERVAL, ZOOKEEPER_SERVER_PORT, ZOOKEEPER_SERVER_PORT_COUNTER_GROUP, ZOOKEEPER_SERVERLIST_POLL_MSECS, ZOOKEEPER_SESSION_TIMEOUT, ZOOKEEPER_SKIP_ACL, ZOOKEEPER_SNAP_RETAIN_COUNT

Constructor Summary

Constructors

Constructor and Description
GiraphClasses() Empty constructor.
GiraphClasses(org.apache.hadoop.conf.Configuration conf) Constructor that reads classes from a Configuration object.

Method Summary

Modifier and Type	Method and Description
Class<? extends AggregatorWriter>	getAggregatorWriterClass() Get AggregatorWriter used
Class<? extends Computation<I,V,E,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable>>	getComputationClass() Get Computation class
Class<? extends ComputationFactory<I,V,E,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable>>	getComputationFactoryClass()
Class<? extends EdgeInputFilter<I,E>>	getEdgeInputFilterClass()
Class<? extends EdgeInputFormat<I,E>>	getEdgeInputFormatClass() Get EdgeInputFormat used
Class<? extends EdgeOutputFormat<I,V,E>>	getEdgeOutputFormatClass() Get VertexOutputFormat set
Class<E>	getEdgeValueClass() Get Edge Value class
GiraphTypes<I,V,E>	getGiraphTypes()
Class<? extends GraphPartitionerFactory<I,V,E>>	getGraphPartitionerFactoryClass() Get the GraphPartitionerFactory
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable>	getIncomingMessageClasses()
Class<? extends OutEdges<I,E>>	getInputOutEdgesClass() Get Vertex edges class used during edge-based input
Class<? extends MappingInputFormat<I,V,E,? extends org.apache.hadoop.io.Writable>>	getMappingInputFormatClass()
Class<? extends MasterCompute>	getMasterComputeClass() Get MasterCompute used
Class<? extends OutEdges<I,E>>	getOutEdgesClass() Get Vertex edges class
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable>	getOutgoingMessageClasses()
Class<? extends Partition<I,V,E>>	getPartitionClass() Get Partition
Class<? extends Vertex>	getVertexClass() Get Vertex implementation class
Class<I>	getVertexIdClass() Get Vertex ID class
Class<? extends VertexInputFilter<I,V,E>>	getVertexInputFilterClass()
Class<? extends VertexInputFormat<I,V,E>>	getVertexInputFormatClass() Get VertexInputFormat held
Class<? extends VertexOutputFormat<I,V,E>>	getVertexOutputFormatClass() Get VertexOutputFormat set
Class<? extends VertexResolver<I,V,E>>	getVertexResolverClass() Get VertexResolver used
Class<V>	getVertexValueClass() Get Vertex Value class
Class<? extends VertexValueCombiner<V>>	getVertexValueCombinerClass() Get VertexValueCombiner used
Class<? extends WorkerContext>	getWorkerContextClass() Get WorkerContext used
boolean	hasAggregatorWriterClass() Check if AggregatorWriter is set
boolean	hasEdgeInputFormat() Check if EdgeInputFormat is set
boolean	hasEdgeOutputFormat() Check if EdgeOutputFormat is set
boolean	hasMappingInputFormat() Check if MappingInputFormat is set
boolean	hasMasterComputeClass() Check if MasterCompute is set
boolean	hasPartitionClass() Check if Partition is set
boolean	hasVertexInputFormat() Check if VertexInputFormat class is set
boolean	hasVertexOutputFormat() Check if VertexOutputFormat is set
boolean	hasVertexResolverClass() Check if VertexResolver is set
boolean	hasWorkerContextClass() Check if WorkerContext is set
GiraphClasses	setAggregatorWriterClass(Class<? extends AggregatorWriter> aggregatorWriterClass) Set AggregatorWriter class used
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	setEdgeInputFormatClass(Class<? extends EdgeInputFormat<I,E>> edgeInputFormatClass) Set EdgeInputFormat class held
GiraphClasses	setEdgeValueClass(Class<E> edgeValueClass) Set Edge Value class held
GiraphClasses	setGraphPartitionerFactoryClass(Class<? extends GraphPartitionerFactory<I,V,E>> klass) Set GraphPartitionerFactory class held
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	setInputOutEdgesClass(Class<? extends OutEdges> inputOutEdgesClass) Set OutEdges class used during edge-input (if different from the one used for computation)
GiraphClasses	setMappingInputFormatClass(Class<? extends MappingInputFormat<I,V,E,org.apache.hadoop.io.Writable>> mappingInputFormatClass) Set MappingInputFormat held
GiraphClasses	setMasterComputeClass(Class<? extends MasterCompute> masterComputeClass) Set MasterCompute class used
GiraphClasses	setOutEdgesClass(Class<? extends OutEdges> outEdgesClass) Set OutEdges class held
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	setPartitionClass(Class<? extends Partition<I,V,E>> partitionClass) Set Partition class to use
GiraphClasses	setVertexIdClass(Class<I> vertexIdClass) Set Vertex ID class held
GiraphClasses	setVertexInputFormatClass(Class<? extends VertexInputFormat<I,V,E>> vertexInputFormatClass) Set VertexInputFormat held
GiraphClasses	setVertexOutputFormatClass(Class<? extends VertexOutputFormat<I,V,E>> vertexOutputFormatClass) Set VertexOutputFormat held
GiraphClasses	setVertexResolverClass(Class<? extends VertexResolver<I,V,E>> vertexResolverClass) Set VertexResolver used
GiraphClasses	setVertexValueClass(Class<V> vertexValueClass) Set Vertex Value class held
GiraphClasses	setWorkerContextClass(Class<? extends WorkerContext> workerContextClass) Set WorkerContext used

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

computationFactoryClass

protected Class<? extends ComputationFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable>> computationFactoryClass

ComputationFactory class - cached for fast access

computationClass

protected Class<? extends Computation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable>> computationClass

Computation class - cached for fast access

giraphTypes

protected GiraphTypes<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> giraphTypes

Generic types used to describe graph

outEdgesClass

protected Class<? extends OutEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>> outEdgesClass

Vertex edges class - cached for fast access

inputOutEdgesClass

protected Class<? extends OutEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>> inputOutEdgesClass

Input vertex edges class - cached for fast access

graphPartitionerFactoryClass

protected Class<? extends GraphPartitionerFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>> graphPartitionerFactoryClass

Graph partitioner factory class - cached for fast access

vertexInputFormatClass

protected Class<? extends VertexInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>> vertexInputFormatClass

Vertex input format class - cached for fast access

vertexOutputFormatClass

protected Class<? extends VertexOutputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>> vertexOutputFormatClass

Vertex output format class - cached for fast access

mappingInputFormatClass

protected Class<? extends MappingInputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable>> mappingInputFormatClass

Mapping input format - cached for fast access

edgeInputFormatClass

protected Class<? extends EdgeInputFormat<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>> edgeInputFormatClass

Edge input format class - cached for fast access

edgeOutputFormatClass

protected Class<? extends EdgeOutputFormat<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>> edgeOutputFormatClass

Edge output format class - cached for fast access

aggregatorWriterClass

protected Class<? extends AggregatorWriter> aggregatorWriterClass

Aggregator writer class - cached for fast access

incomingMessageClasses

protected MessageClasses<I extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> incomingMessageClasses

Incoming message classes

outgoingMessageClasses

protected MessageClasses<I extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses

Outgoing message classes

vertexResolverClass

protected Class<? extends VertexResolver<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>> vertexResolverClass

Vertex resolver class - cached for fast access

vertexValueCombinerClass

protected Class<? extends VertexValueCombiner<V extends org.apache.hadoop.io.Writable>> vertexValueCombinerClass

Vertex value combiner class - cached for fast access

workerContextClass

protected Class<? extends WorkerContext> workerContextClass

Worker context class - cached for fast access

masterComputeClass

protected Class<? extends MasterCompute> masterComputeClass

Master compute class - cached for fast access

partitionClass

protected Class<? extends Partition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>> partitionClass

Partition class - cached for fast accesss

edgeInputFilterClass

protected Class<? extends EdgeInputFilter<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>> edgeInputFilterClass

Edge Input Filter class

vertexInputFilterClass

protected Class<? extends VertexInputFilter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>> vertexInputFilterClass

Vertex Input Filter class

Constructor Detail

GiraphClasses

public GiraphClasses()

Empty constructor. Initialize with default classes or null.

GiraphClasses

public GiraphClasses(org.apache.hadoop.conf.Configuration conf)

Constructor that reads classes from a Configuration object.

Parameters:

conf - Configuration object to read from.

Method Detail

getComputationFactoryClass

public Class<? extends ComputationFactory<I,V,E,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable>> getComputationFactoryClass()

getComputationClass

public Class<? extends Computation<I,V,E,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable>> getComputationClass()

Get Computation class

Returns:

Computation class.

getGiraphTypes

public GiraphTypes<I,V,E> getGiraphTypes()

getVertexIdClass

public Class<I> getVertexIdClass()

Get Vertex ID class

Returns:

Vertex ID class

getVertexClass

public Class<? extends Vertex> getVertexClass()

Get Vertex implementation class

Returns:

Vertex implementation class

getVertexValueClass

public Class<V> getVertexValueClass()

Get Vertex Value class

Returns:

Vertex Value class

getEdgeValueClass

public Class<E> getEdgeValueClass()

Get Edge Value class

Returns:

Edge Value class

getIncomingMessageClasses

public MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> getIncomingMessageClasses()

getOutgoingMessageClasses

public MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> getOutgoingMessageClasses()

getOutEdgesClass

public Class<? extends OutEdges<I,E>> getOutEdgesClass()

Get Vertex edges class

Returns:

Vertex edges class.

getInputOutEdgesClass

public Class<? extends OutEdges<I,E>> getInputOutEdgesClass()

Get Vertex edges class used during edge-based input

Returns:

Vertex edges class.

getGraphPartitionerFactoryClass

public Class<? extends GraphPartitionerFactory<I,V,E>> getGraphPartitionerFactoryClass()

Get the GraphPartitionerFactory

Returns:

GraphPartitionerFactory

getEdgeInputFilterClass

public Class<? extends EdgeInputFilter<I,E>> getEdgeInputFilterClass()

getVertexInputFilterClass

public Class<? extends VertexInputFilter<I,V,E>> getVertexInputFilterClass()

hasVertexInputFormat

public boolean hasVertexInputFormat()

Check if VertexInputFormat class is set

Returns:

true if VertexInputFormat class is set

getVertexInputFormatClass

public Class<? extends VertexInputFormat<I,V,E>> getVertexInputFormatClass()

Get VertexInputFormat held

Returns:

VertexInputFormat

hasVertexOutputFormat

public boolean hasVertexOutputFormat()

Check if VertexOutputFormat is set

Returns:

true if VertexOutputFormat is set

hasMappingInputFormat

public boolean hasMappingInputFormat()

Check if MappingInputFormat is set

Returns:

true if MappingInputFormat is set

getVertexOutputFormatClass

public Class<? extends VertexOutputFormat<I,V,E>> getVertexOutputFormatClass()

Get VertexOutputFormat set

Returns:

VertexOutputFormat

getMappingInputFormatClass

public Class<? extends MappingInputFormat<I,V,E,? extends org.apache.hadoop.io.Writable>> getMappingInputFormatClass()

hasEdgeInputFormat

public boolean hasEdgeInputFormat()

Check if EdgeInputFormat is set

Returns:

true if EdgeInputFormat is set

getEdgeInputFormatClass

public Class<? extends EdgeInputFormat<I,E>> getEdgeInputFormatClass()

Get EdgeInputFormat used

Returns:

EdgeInputFormat

hasEdgeOutputFormat

public boolean hasEdgeOutputFormat()

Check if EdgeOutputFormat is set

Returns:

true if EdgeOutputFormat is set

getEdgeOutputFormatClass

public Class<? extends EdgeOutputFormat<I,V,E>> getEdgeOutputFormatClass()

Get VertexOutputFormat set

Returns:

VertexOutputFormat

hasAggregatorWriterClass

public boolean hasAggregatorWriterClass()

Check if AggregatorWriter is set

Returns:

true if AggregatorWriter is set

getAggregatorWriterClass

public Class<? extends AggregatorWriter> getAggregatorWriterClass()

Get AggregatorWriter used

Returns:

AggregatorWriter

hasVertexResolverClass

public boolean hasVertexResolverClass()

Check if VertexResolver is set

Returns:

true if VertexResolver is set

getVertexResolverClass

public Class<? extends VertexResolver<I,V,E>> getVertexResolverClass()

Get VertexResolver used

Returns:

VertexResolver

getVertexValueCombinerClass

public Class<? extends VertexValueCombiner<V>> getVertexValueCombinerClass()

Get VertexValueCombiner used

Returns:

VertexValueCombiner

hasWorkerContextClass

public boolean hasWorkerContextClass()

Check if WorkerContext is set

Returns:

true if WorkerContext is set

getWorkerContextClass

public Class<? extends WorkerContext> getWorkerContextClass()

Get WorkerContext used

Returns:

WorkerContext

hasMasterComputeClass

public boolean hasMasterComputeClass()

Check if MasterCompute is set

Returns:

true MasterCompute is set

getMasterComputeClass

public Class<? extends MasterCompute> getMasterComputeClass()

Get MasterCompute used

Returns:

MasterCompute

hasPartitionClass

public boolean hasPartitionClass()

Check if Partition is set

Returns:

true if Partition is set

getPartitionClass

public Class<? extends Partition<I,V,E>> getPartitionClass()

Get Partition

Returns:

Partition

setComputationClass

public 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

Parameters:

computationClass - Computation class to set

Returns:

this

setVertexIdClass

public GiraphClasses setVertexIdClass(Class<I> vertexIdClass)

Set Vertex ID class held

Parameters:

vertexIdClass - Vertex ID to set

Returns:

this

setVertexValueClass

public GiraphClasses setVertexValueClass(Class<V> vertexValueClass)

Set Vertex Value class held

Parameters:

vertexValueClass - Vertex Value class to set

Returns:

this

setEdgeValueClass

public GiraphClasses setEdgeValueClass(Class<E> edgeValueClass)

Set Edge Value class held

Parameters:

edgeValueClass - Edge Value class to set

Returns:

this

setIncomingMessageClasses

public 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

Parameters:

incomingMessageClasses - Message classes value to set

Returns:

this

setOutgoingMessageClasses

public 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

Parameters:

outgoingMessageClasses - Message classes value to set

Returns:

this

setOutEdgesClass

public GiraphClasses setOutEdgesClass(Class<? extends OutEdges> outEdgesClass)

Set OutEdges class held

Parameters:

outEdgesClass - Vertex edges class to set

Returns:

this

setInputOutEdgesClass

public GiraphClasses setInputOutEdgesClass(Class<? extends OutEdges> inputOutEdgesClass)

Set OutEdges class used during edge-input (if different from the one used for computation)

Parameters:

inputOutEdgesClass - Input vertex edges class to set

Returns:

this

setGraphPartitionerFactoryClass

public GiraphClasses setGraphPartitionerFactoryClass(Class<? extends GraphPartitionerFactory<I,V,E>> klass)

Set GraphPartitionerFactory class held

Parameters:

klass - GraphPartitionerFactory to set

Returns:

this

setMappingInputFormatClass

public GiraphClasses setMappingInputFormatClass(Class<? extends MappingInputFormat<I,V,E,org.apache.hadoop.io.Writable>> mappingInputFormatClass)

Set MappingInputFormat held

Parameters:

mappingInputFormatClass - MappingInputFormat to set

Returns:

this

setVertexInputFormatClass

public GiraphClasses setVertexInputFormatClass(Class<? extends VertexInputFormat<I,V,E>> vertexInputFormatClass)

Set VertexInputFormat held

Parameters:

vertexInputFormatClass - VertexInputFormat to set

Returns:

this

setVertexOutputFormatClass

public GiraphClasses setVertexOutputFormatClass(Class<? extends VertexOutputFormat<I,V,E>> vertexOutputFormatClass)

Set VertexOutputFormat held

Parameters:

vertexOutputFormatClass - VertexOutputFormat to set

Returns:

this

setEdgeInputFormatClass

public GiraphClasses setEdgeInputFormatClass(Class<? extends EdgeInputFormat<I,E>> edgeInputFormatClass)

Set EdgeInputFormat class held

Parameters:

edgeInputFormatClass - EdgeInputFormat to set

Returns:

this

setAggregatorWriterClass

public GiraphClasses setAggregatorWriterClass(Class<? extends AggregatorWriter> aggregatorWriterClass)

Set AggregatorWriter class used

Parameters:

aggregatorWriterClass - AggregatorWriter to set

Returns:

this

setVertexResolverClass

public GiraphClasses setVertexResolverClass(Class<? extends VertexResolver<I,V,E>> vertexResolverClass)

Set VertexResolver used

Parameters:

vertexResolverClass - VertexResolver to set

Returns:

this

setWorkerContextClass

public GiraphClasses setWorkerContextClass(Class<? extends WorkerContext> workerContextClass)

Set WorkerContext used

Parameters:

workerContextClass - WorkerContext class to set

Returns:

this

setMasterComputeClass

public GiraphClasses setMasterComputeClass(Class<? extends MasterCompute> masterComputeClass)

Set MasterCompute class used

Parameters:

masterComputeClass - MasterCompute class to set

Returns:

this

setPartitionClass

public GiraphClasses setPartitionClass(Class<? extends Partition<I,V,E>> partitionClass)

Set Partition class to use

Parameters:

partitionClass - Partition class to set

Returns:

this