GiraphConfiguration (Apache Giraph Parent 1.4.0-SNAPSHOT API)

java.lang.Object
- org.apache.hadoop.conf.Configuration
- - org.apache.giraph.conf.GiraphConfiguration

All Implemented Interfaces:

Iterable<Map.Entry<String,String>>, GiraphConstants, org.apache.hadoop.io.Writable

Direct Known Subclasses:

ImmutableClassesGiraphConfiguration
```
public class GiraphConfiguration
extends org.apache.hadoop.conf.Configuration
implements GiraphConstants
```
Adds user methods specific to Giraph. This will be put into an ImmutableClassesGiraphConfiguration that provides the configuration plus the immutable classes. Keeps track of parameters which were set so it easily set them in another copy of configuration.

Nested Class Summary
- Nested classes/interfaces inherited from class org.apache.hadoop.conf.Configuration
  org.apache.hadoop.conf.Configuration.DeprecationDelta, org.apache.hadoop.conf.Configuration.IntegerRanges

Field Summary
- 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

GiraphConfiguration()
Constructor that creates the configuration

GiraphConfiguration(org.apache.hadoop.conf.Configuration conf)
Constructor.

Constructors
Constructor and Description
`GiraphConfiguration()` Constructor that creates the configuration
`GiraphConfiguration(org.apache.hadoop.conf.Configuration conf)` Constructor.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addGcObserverClass(Class<? extends GcObserver> gcObserverClass)` Add a GcObserver class (optional)
`void`	`addMapperObserverClass(Class<? extends MapperObserver> mapperObserverClass)` Add a MapperObserver class (optional)
`void`	`addMasterObserverClass(Class<? extends MasterObserver> masterObserverClass)` Add a MasterObserver class (optional)
`void`	`addWorkerObserverClass(Class<? extends WorkerObserver> workerObserverClass)` Add a WorkerObserver class (optional)
`boolean`	`authenticate()` Use authentication? (if supported)
`void`	`configureHadoopSecurity()` Check environment for Hadoop security token location in case we are executing the Giraph job on a MRv1 Hadoop cluster.
`boolean`	`doOutputDuringComputation()` Check if output should be done during computation
`int`	`getCheckpointFrequency()` Get the checkpoint frequeuncy of how many supersteps to wait before checkpointing
`Class<? extends Computation>`	`getComputationClass()` Get the user's subclassed `Computation`
`Class<? extends ComputationFactory>`	`getComputationFactoryClass()` Get the user's subclassed `ComputationFactory`
`String`	`getComputationName()` Get name of computation being run.
`boolean`	`getCreateSourceVertex()` Get option whether to create a source vertex present only in edge input
`int`	`getEventWaitMsecs()` Get the number of milliseconds to wait for an event before continuing on
`Class<? extends GcObserver>[]`	`getGcObserverClasses()` Get array of GcObserver classes set in configuration.
`int`	`getHdfsFileCreationRetries()`
`int`	`getHdfsFileCreationRetryWaitMs()`
`long`	`getInputSplitMaxEdges()`
`long`	`getInputSplitMaxVertices()`
`Class<? extends GiraphJobObserver>`	`getJobObserverClass()` Get job observer class
`Class<? extends GiraphJobRetryChecker>`	`getJobRetryCheckerClass()` Get job retry checker class
`String`	`getLocalHostname()` Get the local hostname on the given interface.
`String`	`getLocalHostOrIp()` Return local host name by default.
`String`	`getLocalLevel()`
`boolean`	`getLocalTestMode()` is this job run a local test?
`Class<? extends MapperObserver>[]`	`getMapperObserverClasses()` Get array of MapperObserver classes set in configuration.
`int`	`getMapTasks()` Get the number of map tasks in this job
`Class<? extends MasterObserver>[]`	`getMasterObserverClasses()` Get array of MasterObserver classes set in the configuration.
`int`	`getMaxCounterWaitMsecs()`
`int`	`getMaxMappers()` How many mappers is job asking for, taking into account whether master is running on the same mapper as worker or not
`int`	`getMaxMasterSuperstepWaitMsecs()` Get the maximum milliseconds to wait before giving up trying to get the minimum number of workers before a superstep.
`int`	`getMaxNumberOfSupersteps()` Get the maximum number of supersteps of this application.
`int`	`getMaxTaskAttempts()` Get the max task attempts
`int`	`getMaxWorkers()`
`float`	`getMinPercentResponded()`
`int`	`getMinWorkers()`
`io.netty.buffer.ByteBufAllocator`	`getNettyAllocator()` Used by netty client and server to create ByteBufAllocator
`int`	`getNettyServerExecutionConcurrency()` Get the netty server execution concurrency.
`int`	`getNettyServerExecutionThreads()`
`int`	`getNettyServerThreads()`
`boolean`	`getNettyServerUseExecutionHandler()`
`int`	`getNumComputeThreads()`
`int`	`getNumInputSplitsThreads()`
`int`	`getNumOutputThreads()` Get the number of threads to use for writing output in the end of the application.
`Class<? extends OutEdges>`	`getOutEdgesClass()` Get the vertex edges class
`Class<? extends Partition>`	`getPartitionClass()` Get Partition class used
`boolean`	`getResolverCreateVertexOnMessages()` Whether to create a vertex that doesn't exist when it receives messages.
`boolean`	`getSplitMasterWorker()` Getter for SPLIT_MASTER_WORKER flag.
`String`	`getStringVars(String key, org.apache.hadoop.mapreduce.Mapper.Context context)` Get string, replacing variables in the output.
`String`	`getStringVars(String key, String defaultValue, org.apache.hadoop.mapreduce.Mapper.Context context)` Get string, replacing variables in the output.
`int`	`getTaskPartition()` Get the task partition
`int`	`getWaitTaskDoneTimeoutMs()` Get the maximum timeout (in milliseconds) for waiting for all tasks to complete after the job is done.
`Class<? extends WorkerObserver>[]`	`getWorkerObserverClasses()` Get array of WorkerObserver classes set in configuration.
`String`	`getYarnLibJars()` Jars required in "Pure YARN" jobs (names only, no paths) should be listed here in full, including Giraph framework jar(s).
`int`	`getYarnTaskHeapMb()` Get heap size (in MB) for each task in our Giraph job run, assuming this job will run on the "pure YARN" profile.
`String`	`getYourKitOutputDir(org.apache.hadoop.mapreduce.Mapper.Context context)` Get the output directory to write YourKit snapshots to
`int`	`getZookeeperConnectionAttempts()`
`String`	`getZookeeperList()` Get the ZooKeeper list.
`int`	`getZooKeeperMaxSessionTimeout()`
`int`	`getZooKeeperMinSessionTimeout()`
`int`	`getZookeeperOpsMaxAttempts()`
`int`	`getZookeeperOpsRetryWaitMsecs()`
`int`	`getZooKeeperSessionTimeout()`
`boolean`	`hasEdgeInputFormat()` Does the job have a `EdgeInputFormat`?
`boolean`	`hasEdgeOutputFormat()` Does the job have a `EdgeOutputFormat`?
`boolean`	`hasEdgeOutputFormatSubdir()` Does the job have a `EdgeOutputFormat` subdir?
`boolean`	`hasVertexInputFormat()` Does the job have a `VertexInputFormat`?
`boolean`	`hasVertexOutputFormat()` Does the job have a `VertexOutputFormat`?
`boolean`	`hasVertexOutputFormatSubdir()` Does the job have a `EdgeOutputFormat` subdir?
`boolean`	`isJMapHistogramDumpEnabled()` Check whether to enable jmap dumping thread.
`boolean`	`isPureYarnJob()` Is this a "pure YARN" Giraph job, or is a MapReduce layer (v1 or v2) actually managing our cluster nodes, i.e.
`boolean`	`isReactiveJmapHistogramDumpEnabled()` Check whether to enable heap memory supervisor thread
`boolean`	`isZookeeperExternal()` Was ZooKeeper provided externally?
`boolean`	`metricsEnabled()` Whether to track, print, and aggregate metrics.
`boolean`	`reuseEdgeObjects()` True if the `OutEdges` implementation copies the passed edges to its own data structure, i.e.
`boolean`	`reuseVertexObjects()` True if the `Partition` implementation copies the passed vertices to its own data structure, i.e.
`void`	`setAggregatorWriterClass(Class<? extends AggregatorWriter> aggregatorWriterClass)` Set the aggregator writer class (optional)
`void`	`setCheckpointFrequency(int checkpointFrequency)` Set the checkpoint frequeuncy of how many supersteps to wait before checkpointing
`void`	`setCheckpointSupportedChecker(Class<? extends CheckpointSupportedChecker> clazz)` Set runtime checkpoint support checker.
`void`	`setClasses(String name, Class<?> xface, Class<?>... klasses)` Set mapping from a key name to a list of classes.
`void`	`setComputationClass(Class<? extends Computation> computationClass)` Set the computation class (required)
`void`	`setCreateSourceVertex(boolean createVertex)` set option whether to create a source vertex present only in edge input
`void`	`setDoOutputDuringComputation(boolean doOutputDuringComputation)` Set whether or not we should do output during computation
`void`	`setEdgeInputFilterClass(Class<? extends EdgeInputFilter> edgeFilterClass)` Set the edge input filter class
`void`	`setEdgeInputFormatClass(Class<? extends EdgeInputFormat> edgeInputFormatClass)` Set the edge input format class (required)
`void`	`setEdgeOutputFormatClass(Class<? extends EdgeOutputFormat> edgeOutputFormatClass)` Set the edge output format class (optional)
`void`	`setEdgeOutputFormatSubdir(String path)` Set the edge output format path
`void`	`setEventWaitMsecs(int eventWaitMsecs)` Set the number of milliseconds to wait for an event before continuing on
`void`	`setGraphPartitionerFactoryClass(Class<? extends GraphPartitionerFactory> graphPartitionerFactoryClass)` Set the graph partitioner class (optional)
`void`	`setInputOutEdgesClass(Class<? extends OutEdges> inputOutEdgesClass)` Set the vertex edges class used during edge-based input (if different from the one used during computation)
`void`	`setJobObserverClass(Class<? extends GiraphJobObserver> klass)` Set job observer class
`void`	`setJobRetryCheckerClass(Class<? extends GiraphJobRetryChecker> klass)` Set job retry checker class
`void`	`setLocalTestMode(boolean flag)` Flag this job as a local test run.
`void`	`setMappingInputFormatClass(Class<? extends MappingInputFormat> mappingInputFormatClass)` Set the mapping input format class (optional)
`void`	`setMasterComputeClass(Class<? extends MasterCompute> masterComputeClass)` Set the master class (optional)
`void`	`setMaxMasterSuperstepWaitMsecs(int maxMasterSuperstepWaitMsecs)` Set the maximum milliseconds to wait before giving up trying to get the minimum number of workers before a superstep.
`void`	`setMaxNumberOfSupersteps(int maxNumberOfSupersteps)` Set the maximum number of supersteps of this application.
`void`	`setMaxTaskAttempts(int maxTaskAttempts)` Set the max task attempts
`void`	`setMessageCombinerClass(Class<? extends MessageCombiner> messageCombinerClass)` Set the message combiner class (optional)
`void`	`setNumComputeThreads(int numComputeThreads)` Set the number of compute threads
`void`	`setNumInputSplitsThreads(int numInputSplitsThreads)` Set the number of input split threads
`void`	`setNumOutputThreads(int numOutputThreads)` Set the number of threads to use for writing output in the end of the application.
`void`	`setOutEdgesClass(Class<? extends OutEdges> outEdgesClass)` Set the vertex edges class
`void`	`setPartitionClass(Class<? extends Partition> partitionClass)` Set the partition class (optional)
`void`	`setResolverCreateVertexOnMessages(boolean v)` Set whether to create non existent vertices when they receive messages.
`void`	`setVertexClass(Class<? extends Vertex> vertexClass)` Set the vertex implementation class
`void`	`setVertexInputFilterClass(Class<? extends VertexInputFilter> vertexFilterClass)` Set the vertex input filter class
`void`	`setVertexInputFormatClass(Class<? extends VertexInputFormat> vertexInputFormatClass)` Set the vertex input format class (required)
`void`	`setVertexOutputFormatClass(Class<? extends VertexOutputFormat> vertexOutputFormatClass)` Set the vertex output format class (optional)
`void`	`setVertexOutputFormatSubdir(String path)` Set the vertex output format path
`void`	`setVertexOutputFormatThreadSafe(boolean vertexOutputFormatThreadSafe)` Set whether or not selected VertexOutputFormat is thread-safe
`void`	`setVertexResolverClass(Class<? extends VertexResolver> vertexResolverClass)` Set the vertex resolver class (optional)
`void`	`setVertexValueCombinerClass(Class<? extends VertexValueCombiner> vertexValueCombinerClass)` Set the vertex value combiner class (optional)
`void`	`setVertexValueFactoryClass(Class<? extends VertexValueFactory> vertexValueFactoryClass)` Set the vertex value factory class
`void`	`setWaitTaskDoneTimeoutMs(int ms)` Set the maximum timeout (in milliseconds) for waiting for all tasks to complete after the job is done.
`void`	`setWorkerConfiguration(int minWorkers, int maxWorkers, float minPercentResponded)` Set worker configuration for determining what is required for a superstep.
`void`	`setWorkerContextClass(Class<? extends WorkerContext> workerContextClass)` Set the worker context class (optional)
`void`	`setYarnLibJars(String jarList)` Populate jar list for Pure YARN jobs.
`void`	`setYarnTaskHeapMb(int heapMb)` Set heap size for Giraph tasks in our job run, assuming the job will run on the "pure YARN" profile.
`void`	`setZooKeeperConfiguration(String serverList)` Utilize an existing ZooKeeper service.
`void`	`setZookeeperList(String zkList)` Set the ZooKeeper list to the provided list.
`boolean`	`trackJobProgressOnClient()` Check whether to track job progress on client or not
`boolean`	`useCheckpointing()` Check if checkpointing is used
`boolean`	`useInputSplitLocality()` Check if we want to prioritize input splits which reside on the host.
`boolean`	`useLogThreadLayout()` Use the log thread layout option?
`void`	`useUnsafeSerialization(boolean useUnsafeSerialization)` Set whether to use unsafe serialization
`boolean`	`vertexOutputFormatThreadSafe()` Check if VertexOutputFormat is thread-safe

Methods inherited from class org.apache.hadoop.conf.Configuration
addDefaultResource, addDeprecation, addDeprecation, addDeprecation, addDeprecation, addDeprecations, addResource, addResource, addResource, addResource, addResource, addResource, clear, dumpConfiguration, dumpDeprecatedKeys, get, get, getBoolean, getClass, getClass, getClassByName, getClassByNameOrNull, getClasses, getClassLoader, getConfResourceAsInputStream, getConfResourceAsReader, getDouble, getEnum, getFile, getFinalParameters, getFloat, getInstances, getInt, getInts, getLocalPath, getLong, getLongBytes, getPattern, getPropertySources, getProps, getRange, getRaw, getResource, getSocketAddr, getStringCollection, getStrings, getStrings, getTimeDuration, getTrimmed, getTrimmed, getTrimmedStringCollection, getTrimmedStrings, getTrimmedStrings, getValByRegex, hasWarnedDeprecation, isDeprecated, iterator, main, readFields, reloadConfiguration, set, set, setBoolean, setBooleanIfUnset, setClass, setClassLoader, setDouble, setEnum, setFloat, setIfUnset, setInt, setLong, setPattern, setQuietMode, setSocketAddr, setStrings, setTimeDuration, size, toString, unset, updateConnectAddr, write, writeXml, writeXml

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable
forEach, spliterator

- Constructor Detail
  - GiraphConfiguration
```
public GiraphConfiguration()
```
    Constructor that creates the configuration
  - GiraphConfiguration
```
public GiraphConfiguration(org.apache.hadoop.conf.Configuration conf)
```
    Constructor.
    
    Parameters:
    
    conf - Configuration
- Method Detail
  - getComputationName
```
public String getComputationName()
```
    Get name of computation being run. We leave this up to the ComputationFactory to decide what to return.
    
    Returns:
    
    Name of computation being run
  - getComputationFactoryClass
```
public Class<? extends ComputationFactory> getComputationFactoryClass()
```
    Get the user's subclassed ComputationFactory
    
    Returns:
    
    User's computation factory class
  - getComputationClass
```
public Class<? extends Computation> getComputationClass()
```
    Get the user's subclassed Computation
    
    Returns:
    
    User's computation class
  - setComputationClass
```
public void setComputationClass(Class<? extends Computation> computationClass)
```
    Set the computation class (required)
    
    Parameters:
    
    computationClass - Runs vertex computation
  - setVertexValueFactoryClass
```
public final void setVertexValueFactoryClass(Class<? extends VertexValueFactory> vertexValueFactoryClass)
```
    Set the vertex value factory class
    
    Parameters:
    
    vertexValueFactoryClass - Creates default vertex values
  - setEdgeInputFilterClass
```
public void setEdgeInputFilterClass(Class<? extends EdgeInputFilter> edgeFilterClass)
```
    Set the edge input filter class
    
    Parameters:
    
    edgeFilterClass - class to use
  - setVertexInputFilterClass
```
public void setVertexInputFilterClass(Class<? extends VertexInputFilter> vertexFilterClass)
```
    Set the vertex input filter class
    
    Parameters:
    
    vertexFilterClass - class to use
  - getOutEdgesClass
```
public Class<? extends OutEdges> getOutEdgesClass()
```
    Get the vertex edges class
    
    Returns:
    
    vertex edges class
  - setOutEdgesClass
```
public final void setOutEdgesClass(Class<? extends OutEdges> outEdgesClass)
```
    Set the vertex edges class
    
    Parameters:
    
    outEdgesClass - Determines the way edges are stored
  - setVertexClass
```
public final void setVertexClass(Class<? extends Vertex> vertexClass)
```
    Set the vertex implementation class
    
    Parameters:
    
    vertexClass - class of the vertex implementation
  - setInputOutEdgesClass
```
public final void setInputOutEdgesClass(Class<? extends OutEdges> inputOutEdgesClass)
```
    Set the vertex edges class used during edge-based input (if different from the one used during computation)
    
    Parameters:
    
    inputOutEdgesClass - Determines the way edges are stored
  - reuseEdgeObjects
```
public boolean reuseEdgeObjects()
```
    True if the OutEdges implementation copies the passed edges to its own data structure, i.e. it doesn't keep references to Edge objects, target vertex ids or edge values passed to add() or initialize(). This makes it possible to reuse edge objects passed to the data structure, to minimize object instantiation (see for example EdgeStore#addPartitionEdges()).
    
    Returns:
    
    True iff we can reuse the edge objects
  - reuseVertexObjects
```
public boolean reuseVertexObjects()
```
    True if the Partition implementation copies the passed vertices to its own data structure, i.e. it doesn't keep references to Vertex objects passed to it. This makes it possible to reuse vertex objects passed to the data structure, to minimize object instantiation.
    
    Returns:
    
    True iff we can reuse the vertex objects
  - getPartitionClass
```
public Class<? extends Partition> getPartitionClass()
```
    Get Partition class used
    
    Returns:
    
    Partition class
  - hasVertexInputFormat
```
public boolean hasVertexInputFormat()
```
    Does the job have a VertexInputFormat?
    
    Returns:
    
    True iff a VertexInputFormat has been specified.
  - setVertexInputFormatClass
```
public void setVertexInputFormatClass(Class<? extends VertexInputFormat> vertexInputFormatClass)
```
    Set the vertex input format class (required)
    
    Parameters:
    
    vertexInputFormatClass - Determines how graph is input
  - hasEdgeInputFormat
```
public boolean hasEdgeInputFormat()
```
    Does the job have a EdgeInputFormat?
    
    Returns:
    
    True iff a EdgeInputFormat has been specified.
  - setEdgeInputFormatClass
```
public void setEdgeInputFormatClass(Class<? extends EdgeInputFormat> edgeInputFormatClass)
```
    Set the edge input format class (required)
    
    Parameters:
    
    edgeInputFormatClass - Determines how graph is input
  - setMappingInputFormatClass
```
public void setMappingInputFormatClass(Class<? extends MappingInputFormat> mappingInputFormatClass)
```
    Set the mapping input format class (optional)
    
    Parameters:
    
    mappingInputFormatClass - Determines how mappings are input
  - setMasterComputeClass
```
public final void setMasterComputeClass(Class<? extends MasterCompute> masterComputeClass)
```
    Set the master class (optional)
    
    Parameters:
    
    masterComputeClass - Runs master computation
  - addMasterObserverClass
```
public final void addMasterObserverClass(Class<? extends MasterObserver> masterObserverClass)
```
    Add a MasterObserver class (optional)
    
    Parameters:
    
    masterObserverClass - MasterObserver class to add.
  - addWorkerObserverClass
```
public final void addWorkerObserverClass(Class<? extends WorkerObserver> workerObserverClass)
```
    Add a WorkerObserver class (optional)
    
    Parameters:
    
    workerObserverClass - WorkerObserver class to add.
  - addMapperObserverClass
```
public final void addMapperObserverClass(Class<? extends MapperObserver> mapperObserverClass)
```
    Add a MapperObserver class (optional)
    
    Parameters:
    
    mapperObserverClass - MapperObserver class to add.
  - addGcObserverClass
```
public final void addGcObserverClass(Class<? extends GcObserver> gcObserverClass)
```
    Add a GcObserver class (optional)
    
    Parameters:
    
    gcObserverClass - GcObserver class to add.
  - getJobObserverClass
```
public Class<? extends GiraphJobObserver> getJobObserverClass()
```
    Get job observer class
    
    Returns:
    
    GiraphJobObserver class set.
  - setJobObserverClass
```
public void setJobObserverClass(Class<? extends GiraphJobObserver> klass)
```
    Set job observer class
    
    Parameters:
    
    klass - GiraphJobObserver class to set.
  - getJobRetryCheckerClass
```
public Class<? extends GiraphJobRetryChecker> getJobRetryCheckerClass()
```
    Get job retry checker class
    
    Returns:
    
    GiraphJobRetryChecker class set.
  - setJobRetryCheckerClass
```
public void setJobRetryCheckerClass(Class<? extends GiraphJobRetryChecker> klass)
```
    Set job retry checker class
    
    Parameters:
    
    klass - GiraphJobRetryChecker class to set.
  - isJMapHistogramDumpEnabled
```
public boolean isJMapHistogramDumpEnabled()
```
    Check whether to enable jmap dumping thread.
    
    Returns:
    
    true if jmap dumper is enabled.
  - isReactiveJmapHistogramDumpEnabled
```
public boolean isReactiveJmapHistogramDumpEnabled()
```
    Check whether to enable heap memory supervisor thread
    
    Returns:
    
    true if jmap dumper is reactively enabled
  - setClasses
```
public final void setClasses(String name,
                             Class<?> xface,
                             Class<?>... klasses)
```
    Set mapping from a key name to a list of classes.
    
    Parameters:
    
    name - String key name to use.
    
    xface - interface of the classes being set.
    
    klasses - Classes to set.
  - hasVertexOutputFormat
```
public boolean hasVertexOutputFormat()
```
    Does the job have a VertexOutputFormat?
    
    Returns:
    
    True iff a VertexOutputFormat has been specified.
  - setVertexOutputFormatClass
```
public final void setVertexOutputFormatClass(Class<? extends VertexOutputFormat> vertexOutputFormatClass)
```
    Set the vertex output format class (optional)
    
    Parameters:
    
    vertexOutputFormatClass - Determines how graph is output
  - hasVertexOutputFormatSubdir
```
public boolean hasVertexOutputFormatSubdir()
```
    Does the job have a EdgeOutputFormat subdir?
    
    Returns:
    
    True iff a EdgeOutputFormat subdir has been specified.
  - setVertexOutputFormatSubdir
```
public final void setVertexOutputFormatSubdir(String path)
```
    Set the vertex output format path
    
    Parameters:
    
    path - path where the verteces will be written
  - doOutputDuringComputation
```
public final boolean doOutputDuringComputation()
```
    Check if output should be done during computation
    
    Returns:
    
    True iff output should be done during computation
  - setDoOutputDuringComputation
```
public final void setDoOutputDuringComputation(boolean doOutputDuringComputation)
```
    Set whether or not we should do output during computation
    
    Parameters:
    
    doOutputDuringComputation - True iff we want output to happen during computation
  - vertexOutputFormatThreadSafe
```
public final boolean vertexOutputFormatThreadSafe()
```
    Check if VertexOutputFormat is thread-safe
    
    Returns:
    
    True iff VertexOutputFormat is thread-safe
  - setVertexOutputFormatThreadSafe
```
public final void setVertexOutputFormatThreadSafe(boolean vertexOutputFormatThreadSafe)
```
    Set whether or not selected VertexOutputFormat is thread-safe
    
    Parameters:
    
    vertexOutputFormatThreadSafe - True iff selected VertexOutputFormat is thread-safe
  - hasEdgeOutputFormat
```
public boolean hasEdgeOutputFormat()
```
    Does the job have a EdgeOutputFormat?
    
    Returns:
    
    True iff a EdgeOutputFormat has been specified.
  - setEdgeOutputFormatClass
```
public final void setEdgeOutputFormatClass(Class<? extends EdgeOutputFormat> edgeOutputFormatClass)
```
    Set the edge output format class (optional)
    
    Parameters:
    
    edgeOutputFormatClass - Determines how graph is output
  - hasEdgeOutputFormatSubdir
```
public boolean hasEdgeOutputFormatSubdir()
```
    Does the job have a EdgeOutputFormat subdir?
    
    Returns:
    
    True iff a EdgeOutputFormat subdir has been specified.
  - setEdgeOutputFormatSubdir
```
public final void setEdgeOutputFormatSubdir(String path)
```
    Set the edge output format path
    
    Parameters:
    
    path - path where the edges will be written
  - getNumOutputThreads
```
public final int getNumOutputThreads()
```
    Get the number of threads to use for writing output in the end of the application. If output format is not thread safe, returns 1.
    
    Returns:
    
    Number of output threads
  - setNumOutputThreads
```
public void setNumOutputThreads(int numOutputThreads)
```
    Set the number of threads to use for writing output in the end of the application. Will be used only if {#vertexOutputFormatThreadSafe} is true.
    
    Parameters:
    
    numOutputThreads - Number of output threads
  - setMessageCombinerClass
```
public void setMessageCombinerClass(Class<? extends MessageCombiner> messageCombinerClass)
```
    Set the message combiner class (optional)
    
    Parameters:
    
    messageCombinerClass - Determines how vertex messages are combined
  - setGraphPartitionerFactoryClass
```
public final void setGraphPartitionerFactoryClass(Class<? extends GraphPartitionerFactory> graphPartitionerFactoryClass)
```
    Set the graph partitioner class (optional)
    
    Parameters:
    
    graphPartitionerFactoryClass - Determines how the graph is partitioned
  - setVertexResolverClass
```
public final void setVertexResolverClass(Class<? extends VertexResolver> vertexResolverClass)
```
    Set the vertex resolver class (optional)
    
    Parameters:
    
    vertexResolverClass - Determines how vertex mutations are resolved
  - getResolverCreateVertexOnMessages
```
public final boolean getResolverCreateVertexOnMessages()
```
    Whether to create a vertex that doesn't exist when it receives messages. This only affects DefaultVertexResolver.
    
    Returns:
    
    true if we should create non existent vertices that get messages.
  - setResolverCreateVertexOnMessages
```
public final void setResolverCreateVertexOnMessages(boolean v)
```
    Set whether to create non existent vertices when they receive messages.
    
    Parameters:
    
    v - true if we should create vertices when they get messages.
  - setVertexValueCombinerClass
```
public final void setVertexValueCombinerClass(Class<? extends VertexValueCombiner> vertexValueCombinerClass)
```
    Set the vertex value combiner class (optional)
    
    Parameters:
    
    vertexValueCombinerClass - Determines how vertices are combined
  - setWorkerContextClass
```
public final void setWorkerContextClass(Class<? extends WorkerContext> workerContextClass)
```
    Set the worker context class (optional)
    
    Parameters:
    
    workerContextClass - Determines what code is executed on a each worker before and after each superstep and computation
  - setAggregatorWriterClass
```
public final void setAggregatorWriterClass(Class<? extends AggregatorWriter> aggregatorWriterClass)
```
    Set the aggregator writer class (optional)
    
    Parameters:
    
    aggregatorWriterClass - Determines how the aggregators are written to file at the end of the job
  - setPartitionClass
```
public final void setPartitionClass(Class<? extends Partition> partitionClass)
```
    Set the partition class (optional)
    
    Parameters:
    
    partitionClass - Determines the why partitions are stored
  - setWorkerConfiguration
```
public final void setWorkerConfiguration(int minWorkers,
                                         int maxWorkers,
                                         float minPercentResponded)
```
    Set worker configuration for determining what is required for a superstep.
    
    Parameters:
    
    minWorkers - Minimum workers to do a superstep
    
    maxWorkers - Maximum workers to do a superstep (max map tasks in job)
    
    minPercentResponded - 0 - 100 % of the workers required to have responded before continuing the superstep
  - getMinWorkers
```
public final int getMinWorkers()
```
  - getMaxWorkers
```
public final int getMaxWorkers()
```
  - getMinPercentResponded
```
public final float getMinPercentResponded()
```
  - getMaxMappers
```
public final int getMaxMappers()
```
    How many mappers is job asking for, taking into account whether master is running on the same mapper as worker or not
    
    Returns:
    
    How many mappers is job asking for
  - setZooKeeperConfiguration
```
public final void setZooKeeperConfiguration(String serverList)
```
    Utilize an existing ZooKeeper service. If this is not set, ZooKeeper will be dynamically started by Giraph for this job.
    
    Parameters:
    
    serverList - Comma separated list of servers and ports (i.e. zk1:2221,zk2:2221)
  - getSplitMasterWorker
```
public final boolean getSplitMasterWorker()
```
    Getter for SPLIT_MASTER_WORKER flag.
    
    Returns:
    
    boolean flag value.
  - getMasterObserverClasses
```
public Class<? extends MasterObserver>[] getMasterObserverClasses()
```
    Get array of MasterObserver classes set in the configuration.
    
    Returns:
    
    array of MasterObserver classes.
  - getWorkerObserverClasses
```
public Class<? extends WorkerObserver>[] getWorkerObserverClasses()
```
    Get array of WorkerObserver classes set in configuration.
    
    Returns:
    
    array of WorkerObserver classes.
  - getMapperObserverClasses
```
public Class<? extends MapperObserver>[] getMapperObserverClasses()
```
    Get array of MapperObserver classes set in configuration.
    
    Returns:
    
    array of MapperObserver classes.
  - getGcObserverClasses
```
public Class<? extends GcObserver>[] getGcObserverClasses()
```
    Get array of GcObserver classes set in configuration.
    
    Returns:
    
    array of GcObserver classes.
  - metricsEnabled
```
public boolean metricsEnabled()
```
    Whether to track, print, and aggregate metrics.
    
    Returns:
    
    true if metrics are enabled, false otherwise (default)
  - getTaskPartition
```
public int getTaskPartition()
```
    Get the task partition
    
    Returns:
    
    The task partition or -1 if not set
  - isPureYarnJob
```
public boolean isPureYarnJob()
```
    Is this a "pure YARN" Giraph job, or is a MapReduce layer (v1 or v2) actually managing our cluster nodes, i.e. each task is a Mapper.
    
    Returns:
    
    TRUE if this is a pure YARN job.
  - getYarnLibJars
```
public String getYarnLibJars()
```
    Jars required in "Pure YARN" jobs (names only, no paths) should be listed here in full, including Giraph framework jar(s).
    
    Returns:
    
    the comma-separated list of jar names for export to cluster.
  - setYarnLibJars
```
public void setYarnLibJars(String jarList)
```
    Populate jar list for Pure YARN jobs.
    
    Parameters:
    
    jarList - a comma-separated list of jar names
  - getYarnTaskHeapMb
```
public int getYarnTaskHeapMb()
```
    Get heap size (in MB) for each task in our Giraph job run, assuming this job will run on the "pure YARN" profile.
    
    Returns:
    
    the heap size for all tasks, in MB
  - setYarnTaskHeapMb
```
public void setYarnTaskHeapMb(int heapMb)
```
    Set heap size for Giraph tasks in our job run, assuming the job will run on the "pure YARN" profile.
    
    Parameters:
    
    heapMb - the heap size for all tasks
  - getZookeeperList
```
public String getZookeeperList()
```
    Get the ZooKeeper list.
    
    Returns:
    
    ZooKeeper list of strings, comma separated or null if none set.
  - setZookeeperList
```
public void setZookeeperList(String zkList)
```
    Set the ZooKeeper list to the provided list. This method is used when the ZooKeeper is started internally and will set the zkIsExternal option to false as well.
    
    Parameters:
    
    zkList - list of strings, comma separated of zookeeper servers
  - isZookeeperExternal
```
public boolean isZookeeperExternal()
```
    Was ZooKeeper provided externally?
    
    Returns:
    
    true iff was zookeeper is external
  - getLocalLevel
```
public String getLocalLevel()
```
  - useLogThreadLayout
```
public boolean useLogThreadLayout()
```
    Use the log thread layout option?
    
    Returns:
    
    True if use the log thread layout option, false otherwise
  - getLocalTestMode
```
public boolean getLocalTestMode()
```
    is this job run a local test?
    
    Returns:
    
    the test status as recorded in the Configuration
  - setLocalTestMode
```
public void setLocalTestMode(boolean flag)
```
    Flag this job as a local test run.
    
    Parameters:
    
    flag - the test status for this job
  - getZooKeeperSessionTimeout
```
public int getZooKeeperSessionTimeout()
```
  - getZookeeperOpsMaxAttempts
```
public int getZookeeperOpsMaxAttempts()
```
  - getZookeeperOpsRetryWaitMsecs
```
public int getZookeeperOpsRetryWaitMsecs()
```
  - getNettyServerUseExecutionHandler
```
public boolean getNettyServerUseExecutionHandler()
```
  - getNettyServerThreads
```
public int getNettyServerThreads()
```
  - getNettyServerExecutionThreads
```
public int getNettyServerExecutionThreads()
```
  - getNettyServerExecutionConcurrency
```
public int getNettyServerExecutionConcurrency()
```
    Get the netty server execution concurrency. This depends on whether the netty server execution handler exists.
    
    Returns:
    
    Server concurrency
  - getNettyAllocator
```
public io.netty.buffer.ByteBufAllocator getNettyAllocator()
```
    Used by netty client and server to create ByteBufAllocator
    
    Returns:
    
    ByteBufAllocator
  - getZookeeperConnectionAttempts
```
public int getZookeeperConnectionAttempts()
```
  - getZooKeeperMinSessionTimeout
```
public int getZooKeeperMinSessionTimeout()
```
  - getZooKeeperMaxSessionTimeout
```
public int getZooKeeperMaxSessionTimeout()
```
  - getMapTasks
```
public int getMapTasks()
```
    Get the number of map tasks in this job
    
    Returns:
    
    Number of map tasks in this job
  - authenticate
```
public boolean authenticate()
```
    Use authentication? (if supported)
    
    Returns:
    
    True if should authenticate, false otherwise
  - setNumComputeThreads
```
public void setNumComputeThreads(int numComputeThreads)
```
    Set the number of compute threads
    
    Parameters:
    
    numComputeThreads - Number of compute threads to use
  - getNumComputeThreads
```
public int getNumComputeThreads()
```
  - setNumInputSplitsThreads
```
public void setNumInputSplitsThreads(int numInputSplitsThreads)
```
    Set the number of input split threads
    
    Parameters:
    
    numInputSplitsThreads - Number of input split threads to use
  - getNumInputSplitsThreads
```
public int getNumInputSplitsThreads()
```
  - getInputSplitMaxVertices
```
public long getInputSplitMaxVertices()
```
  - getInputSplitMaxEdges
```
public long getInputSplitMaxEdges()
```
  - useUnsafeSerialization
```
public void useUnsafeSerialization(boolean useUnsafeSerialization)
```
    Set whether to use unsafe serialization
    
    Parameters:
    
    useUnsafeSerialization - If true, use unsafe serialization
  - setCheckpointFrequency
```
public void setCheckpointFrequency(int checkpointFrequency)
```
    Set the checkpoint frequeuncy of how many supersteps to wait before checkpointing
    
    Parameters:
    
    checkpointFrequency - How often to checkpoint (0 means never)
  - getCheckpointFrequency
```
public int getCheckpointFrequency()
```
    Get the checkpoint frequeuncy of how many supersteps to wait before checkpointing
    
    Returns:
    
    Checkpoint frequency (0 means never)
  - useCheckpointing
```
public boolean useCheckpointing()
```
    Check if checkpointing is used
    
    Returns:
    
    True iff checkpointing is used
  - setCheckpointSupportedChecker
```
public void setCheckpointSupportedChecker(Class<? extends CheckpointSupportedChecker> clazz)
```
    Set runtime checkpoint support checker. The instance of this class will have to decide whether checkpointing is allowed on current superstep.
    
    Parameters:
    
    clazz - checkpoint supported checker class
  - setMaxTaskAttempts
```
public void setMaxTaskAttempts(int maxTaskAttempts)
```
    Set the max task attempts
    
    Parameters:
    
    maxTaskAttempts - Max task attempts to use
  - getMaxTaskAttempts
```
public int getMaxTaskAttempts()
```
    Get the max task attempts
    
    Returns:
    
    Max task attempts or -1, if not set
  - getEventWaitMsecs
```
public int getEventWaitMsecs()
```
    Get the number of milliseconds to wait for an event before continuing on
    
    Returns:
    
    Number of milliseconds to wait for an event before continuing on
  - setEventWaitMsecs
```
public void setEventWaitMsecs(int eventWaitMsecs)
```
    Set the number of milliseconds to wait for an event before continuing on
    
    Parameters:
    
    eventWaitMsecs - Number of milliseconds to wait for an event before continuing on
  - getMaxMasterSuperstepWaitMsecs
```
public int getMaxMasterSuperstepWaitMsecs()
```
    Get the maximum milliseconds to wait before giving up trying to get the minimum number of workers before a superstep.
    
    Returns:
    
    Maximum milliseconds to wait before giving up trying to get the minimum number of workers before a superstep
  - getMaxCounterWaitMsecs
```
public int getMaxCounterWaitMsecs()
```
  - setMaxMasterSuperstepWaitMsecs
```
public void setMaxMasterSuperstepWaitMsecs(int maxMasterSuperstepWaitMsecs)
```
    Set the maximum milliseconds to wait before giving up trying to get the minimum number of workers before a superstep.
    
    Parameters:
    
    maxMasterSuperstepWaitMsecs - Maximum milliseconds to wait before giving up trying to get the minimum number of workers before a superstep
  - configureHadoopSecurity
```
public void configureHadoopSecurity()
```
    Check environment for Hadoop security token location in case we are executing the Giraph job on a MRv1 Hadoop cluster.
  - useInputSplitLocality
```
public boolean useInputSplitLocality()
```
    Check if we want to prioritize input splits which reside on the host.
    
    Returns:
    
    True iff we want to use input split locality
  - getLocalHostname
```
public String getLocalHostname()
                        throws UnknownHostException
```
    Get the local hostname on the given interface.
    
    Returns:
    
    The local hostname
    
    Throws:
    
    UnknownHostException - IP address of a host could not be determined
  - getLocalHostOrIp
```
public String getLocalHostOrIp()
                        throws UnknownHostException
```
    Return local host name by default. Or local host IP if preferIP option is set.
    
    Returns:
    
    local host name or IP
    
    Throws:
    
    UnknownHostException - IP address of a host could not be determined
  - setMaxNumberOfSupersteps
```
public void setMaxNumberOfSupersteps(int maxNumberOfSupersteps)
```
    Set the maximum number of supersteps of this application. After this many supersteps are executed, the application will shutdown.
    
    Parameters:
    
    maxNumberOfSupersteps - Maximum number of supersteps
  - getMaxNumberOfSupersteps
```
public int getMaxNumberOfSupersteps()
```
    Get the maximum number of supersteps of this application. After this many supersteps are executed, the application will shutdown.
    
    Returns:
    
    Maximum number of supersteps
  - getYourKitOutputDir
```
public String getYourKitOutputDir(org.apache.hadoop.mapreduce.Mapper.Context context)
```
    Get the output directory to write YourKit snapshots to
    
    Parameters:
    
    context - Map context
    
    Returns:
    
    output directory
  - getStringVars
```
public String getStringVars(String key,
                            org.apache.hadoop.mapreduce.Mapper.Context context)
```
    Get string, replacing variables in the output. %JOB_ID% => job id %TASK_ID% => task id %USER% => owning user name
    
    Parameters:
    
    key - name of key to lookup
    
    context - mapper context
    
    Returns:
    
    value for key, with variables expanded
  - getStringVars
```
public String getStringVars(String key,
                            String defaultValue,
                            org.apache.hadoop.mapreduce.Mapper.Context context)
```
    Get string, replacing variables in the output. %JOB_ID% => job id %TASK_ID% => task id %USER% => owning user name
    
    Parameters:
    
    key - name of key to lookup
    
    defaultValue - value to return if no mapping exists. This can also have variables, which will be substituted.
    
    context - mapper context
    
    Returns:
    
    value for key, with variables expanded
  - getCreateSourceVertex
```
public boolean getCreateSourceVertex()
```
    Get option whether to create a source vertex present only in edge input
    
    Returns:
    
    CREATE_EDGE_SOURCE_VERTICES option
  - setCreateSourceVertex
```
public void setCreateSourceVertex(boolean createVertex)
```
    set option whether to create a source vertex present only in edge input
    
    Parameters:
    
    createVertex - create source vertex option
  - getWaitTaskDoneTimeoutMs
```
public int getWaitTaskDoneTimeoutMs()
```
    Get the maximum timeout (in milliseconds) for waiting for all tasks to complete after the job is done.
    
    Returns:
    
    Wait task done timeout in milliseconds.
  - setWaitTaskDoneTimeoutMs
```
public void setWaitTaskDoneTimeoutMs(int ms)
```
    Set the maximum timeout (in milliseconds) for waiting for all tasks to complete after the job is done.
    
    Parameters:
    
    ms - Milliseconds to set
  - trackJobProgressOnClient
```
public boolean trackJobProgressOnClient()
```
    Check whether to track job progress on client or not
    
    Returns:
    
    True if job progress should be tracked on client
  - getHdfsFileCreationRetries
```
public int getHdfsFileCreationRetries()
```
    Returns:
    
    Number of retries when creating an HDFS file before failing.
  - getHdfsFileCreationRetryWaitMs
```
public int getHdfsFileCreationRetryWaitMs()
```
    Returns:
    
    Milliseconds to wait before retrying an HDFS file creation operation.

Class GiraphConfiguration

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.conf.Configuration

Field Summary

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

Constructor Summary

Method Summary

Methods inherited from class org.apache.hadoop.conf.Configuration

Methods inherited from class java.lang.Object

Methods inherited from interface java.lang.Iterable

Constructor Detail

GiraphConfiguration

GiraphConfiguration

Method Detail

getComputationName

getComputationFactoryClass

getComputationClass

setComputationClass

setVertexValueFactoryClass

setEdgeInputFilterClass

setVertexInputFilterClass

getOutEdgesClass

setOutEdgesClass

setVertexClass

setInputOutEdgesClass

reuseEdgeObjects

reuseVertexObjects

getPartitionClass

hasVertexInputFormat

setVertexInputFormatClass

hasEdgeInputFormat

setEdgeInputFormatClass

setMappingInputFormatClass

setMasterComputeClass

addMasterObserverClass

addWorkerObserverClass

addMapperObserverClass

addGcObserverClass

getJobObserverClass

setJobObserverClass

getJobRetryCheckerClass

setJobRetryCheckerClass

isJMapHistogramDumpEnabled

isReactiveJmapHistogramDumpEnabled

setClasses

hasVertexOutputFormat

setVertexOutputFormatClass

hasVertexOutputFormatSubdir

setVertexOutputFormatSubdir

doOutputDuringComputation

setDoOutputDuringComputation

vertexOutputFormatThreadSafe

setVertexOutputFormatThreadSafe

hasEdgeOutputFormat

setEdgeOutputFormatClass

hasEdgeOutputFormatSubdir

setEdgeOutputFormatSubdir

getNumOutputThreads

setNumOutputThreads

setMessageCombinerClass

setGraphPartitionerFactoryClass

setVertexResolverClass

getResolverCreateVertexOnMessages

setResolverCreateVertexOnMessages

setVertexValueCombinerClass

setWorkerContextClass

setAggregatorWriterClass

setPartitionClass

setWorkerConfiguration

getMinWorkers

getMaxWorkers

getMinPercentResponded

getMaxMappers

setZooKeeperConfiguration

getSplitMasterWorker

getMasterObserverClasses

getWorkerObserverClasses

getMapperObserverClasses

getGcObserverClasses

metricsEnabled