This project has retired. For details please refer to its Attic page.
Index (Apache Giraph Core 1.3.0-SNAPSHOT API)
Skip navigation links
A B C D E F G H I J K L M N O P R S T U V W Y Z _ 

A

abortTask(TaskAttemptContext) - Method in class org.apache.giraph.bsp.ImmutableOutputCommitter
 
abortTask(TaskAttemptContext) - Method in class org.apache.giraph.utils.DefaultOutputCommitter
 
AbstractComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.graph
See Computation for explanation of the interface.
AbstractComputation() - Constructor for class org.apache.giraph.graph.AbstractComputation
 
AbstractConfOption - Class in org.apache.giraph.conf
Abstract base class of configuration options
AbstractConfOption(String, String) - Constructor for class org.apache.giraph.conf.AbstractConfOption
Constructor
AbstractEdgeStore<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,K,Et> - Class in org.apache.giraph.edge
Basic implementation of edges store, extended this to easily define simple and primitive edge stores
AbstractEdgeStore(CentralizedServiceWorker<I, V, E>, ImmutableClassesGiraphConfiguration<I, V, E>, Progressable) - Constructor for class org.apache.giraph.edge.AbstractEdgeStore
Constructor.
AbstractListPerVertexStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,L extends List> - Class in org.apache.giraph.comm.messages
Abstract Implementation of SimpleMessageStore where multiple messages are stored per vertex as a list Used when there is no combiner provided.
AbstractListPerVertexStore(MessageValueFactory<M>, PartitionSplitInfo<I>, ImmutableClassesGiraphConfiguration<I, ?, ?>) - Constructor for class org.apache.giraph.comm.messages.AbstractListPerVertexStore
Constructor
AbstractLongByteOps - Class in org.apache.giraph.mapping
Implementation of basic methods in MappingStoreOps
AbstractLongByteOps() - Constructor for class org.apache.giraph.mapping.AbstractLongByteOps
 
AbstractVertexIdData<I extends org.apache.hadoop.io.WritableComparable,T> - Class in org.apache.giraph.utils
Partial implementation of vertexIdData
AbstractVertexIdData() - Constructor for class org.apache.giraph.utils.AbstractVertexIdData
 
acceptReducedValues(DataInput) - Method in class org.apache.giraph.master.MasterAggregatorHandler
Accept reduced values sent by worker.
AckSignalFlag - Enum in org.apache.giraph.comm.netty.handler
Flag used to differentiate acknowledgement flags.
activeThreadCheckIn() - Method in class org.apache.giraph.ooc.OutOfCoreEngine
A processing thread would check in with out-of-core engine every once in a while to make sure that it can still remain active.
add(DoubleDenseVector) - Method in class org.apache.giraph.aggregators.matrix.dense.DoubleDenseVector
Add the vector specified.
add(FloatDenseVector) - Method in class org.apache.giraph.aggregators.matrix.dense.FloatDenseVector
Add the vector specified.
add(IntDenseVector) - Method in class org.apache.giraph.aggregators.matrix.dense.IntDenseVector
Add the vector specified.
add(LongDenseVector) - Method in class org.apache.giraph.aggregators.matrix.dense.LongDenseVector
Add the vector specified.
add(int, double) - Method in class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseVector
Increment value for a given key
add(DoubleSparseVector) - Method in class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseVector
Add the vector specified.
add(FloatSparseVector) - Method in class org.apache.giraph.aggregators.matrix.sparse.FloatSparseVector
Add the vector specified.
add(IntSparseVector) - Method in class org.apache.giraph.aggregators.matrix.sparse.IntSparseVector
Add the vector specified.
add(int, long) - Method in class org.apache.giraph.aggregators.matrix.sparse.LongSparseVector
Increment value for a given key
add(LongSparseVector) - Method in class org.apache.giraph.aggregators.matrix.sparse.LongSparseVector
Add the vector specified.
add(Configuration, Class<? extends C>) - Method in class org.apache.giraph.conf.ClassConfOption
Add class to list for key
add(Edge<I, E>) - Method in class org.apache.giraph.edge.ArrayListEdges
 
add(Edge<I, E>) - Method in class org.apache.giraph.edge.ByteArrayEdges
 
add(Edge<I, E>) - Method in class org.apache.giraph.edge.HashMapEdges
 
add(Edge<I, E>) - Method in class org.apache.giraph.edge.HashMultimapEdges
 
add(Edge<I, NullWritable>) - Method in class org.apache.giraph.edge.IdAndNullArrayEdges
 
add(Edge<I, E>) - Method in class org.apache.giraph.edge.IdAndValueArrayEdges
 
add(Edge<IntWritable, NullWritable>) - Method in class org.apache.giraph.edge.IntNullArrayEdges
 
add(Edge<LongWritable, ByteWritable>) - Method in class org.apache.giraph.edge.LongByteHashMapEdges
 
add(long) - Method in class org.apache.giraph.edge.LongDiffArray
Add a value
add(Edge<LongWritable, NullWritable>) - Method in class org.apache.giraph.edge.LongDiffNullArrayEdges
 
add(Edge<LongWritable, DoubleWritable>) - Method in class org.apache.giraph.edge.LongDoubleArrayEdges
 
add(Edge<LongWritable, DoubleWritable>) - Method in class org.apache.giraph.edge.LongDoubleHashMapEdges
 
add(Edge<LongWritable, NullWritable>) - Method in class org.apache.giraph.edge.LongNullArrayEdges
 
add(Edge<LongWritable, NullWritable>) - Method in class org.apache.giraph.edge.LongNullHashSetEdges
 
add(Edge<I, E>) - Method in class org.apache.giraph.edge.MutableEdgesWrapper
 
add(Edge<I, E>) - Method in interface org.apache.giraph.edge.OutEdges
Add an edge.
add(String, long, String) - Method in class org.apache.giraph.metrics.AggregatedMetrics
Add value from hostname for a metric.
add(String, double, String) - Method in class org.apache.giraph.metrics.AggregatedMetrics
Add value from hostname for a metric.
add(WorkerSuperstepMetrics, String) - Method in class org.apache.giraph.metrics.AggregatedMetrics
Add metrics from worker.
add(int, byte) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntByteMinHeap
Add a key value pair
add(int, double) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntDoubleMinHeap
Add a key value pair
add(int, float) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntFloatMinHeap
Add a key value pair
add(int, int) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntIntMinHeap
Add a key value pair
add(int, long) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntLongMinHeap
Add a key value pair
add(long, byte) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongByteMinHeap
Add a key value pair
add(long, double) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongDoubleMinHeap
Add a key value pair
add(long, float) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongFloatMinHeap
Add a key value pair
add(long, int) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongIntMinHeap
Add a key value pair
add(long, long) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongLongMinHeap
Add a key value pair
add(T) - Method in interface org.apache.giraph.types.ops.collections.BasicSet
Adds value to the set.
add(IntWritable) - Method in class org.apache.giraph.types.ops.collections.BasicSet.BasicIntOpenHashSet
 
add(LongWritable) - Method in class org.apache.giraph.types.ops.collections.BasicSet.BasicLongOpenHashSet
 
add(I, T) - Method in class org.apache.giraph.utils.AbstractVertexIdData
 
add(byte[], int, T) - Method in class org.apache.giraph.utils.AbstractVertexIdData
 
add(byte[], int, int, M) - Method in class org.apache.giraph.utils.ByteArrayOneMessageToManyIds
Add a message.
add(I, M) - Method in class org.apache.giraph.utils.ByteArrayOneMessageToManyIds
 
add(byte[], int, M) - Method in class org.apache.giraph.utils.ByteArrayOneMessageToManyIds
 
add(I, M) - Method in class org.apache.giraph.utils.ByteArrayVertexIdMessages
 
add(byte[], int, M) - Method in class org.apache.giraph.utils.ByteArrayVertexIdMessages
 
add(long) - Method in class org.apache.giraph.utils.IncreasingBitSet
Add a key if it is possible.
add(U, V) - Method in class org.apache.giraph.utils.PairList
Add a pair to the collection.
add(I, T) - Method in interface org.apache.giraph.utils.VertexIdData
Add a vertex id and data pair to the collection.
add(byte[], int, T) - Method in interface org.apache.giraph.utils.VertexIdData
Add a serialized vertex id and data.
addChannel(Channel) - Method in class org.apache.giraph.comm.netty.ChannelRotater
Add a channel to the rotation
addConcurrent(K, C, ConcurrentMap<K, C>) - Static method in class org.apache.giraph.utils.CollectionUtils
If map already has a value associated with the key it adds values to that value, otherwise it will put values to the map.
addCustomCounter(String, String, CustomCounter.Aggregation) - Static method in class org.apache.giraph.counters.CustomCounters
Add a counter group and name to the custom counters If it already exists, then it will not be added This will be called from the application to add the app-specific counters
addData(WorkerInfo, int, I, T) - Method in class org.apache.giraph.comm.SendVertexIdDataCache
Add data to the cache.
addData(WorkerInfo, int, byte[], int, T) - Method in class org.apache.giraph.comm.SendVertexIdDataCache
This method is similar to the method above, but use a serialized id to replace original I type destVertexId.
addEdge(WorkerInfo, int, I, Edge<I, E>) - Method in class org.apache.giraph.comm.SendEdgeCache
Add an edge to the cache.
addEdge(Edge<I, E>) - Method in class org.apache.giraph.graph.DefaultVertex
 
addEdge(Edge<I, Writable>) - Method in class org.apache.giraph.graph.OnlyIdVertex
 
addEdge(Edge<I, E>) - Method in interface org.apache.giraph.graph.Vertex
Add an edge for this vertex (happens immediately)
addEdge(Edge<I, E>) - Method in class org.apache.giraph.graph.VertexMutations
Add an edge to this vertex
addEdge(I, Map.Entry<I, E>) - Method in class org.apache.giraph.utils.TestGraph
Add an edge to an existing vertex `
addEdge(I, I, E) - Method in class org.apache.giraph.utils.TestGraph
Add an edge to an existing vertex
addEdgeCount(long) - Method in class org.apache.giraph.partition.PartitionStats
Add edges to the edge count.
addEdgeInputPath(Configuration, Path) - Static method in class org.apache.giraph.io.formats.GiraphFileInputFormat
Add a Path to the list of edge inputs.
addEdgeMutation(Integer, I, Edge<I, E>) - Method in class org.apache.giraph.comm.SendMutationsCache
Add an add edge mutation to the cache.
addEdgeRequest(I, Edge<I, E>) - Method in class org.apache.giraph.comm.netty.NettyWorkerClientRequestProcessor
 
addEdgeRequest(I, Edge<I, E>) - Method in interface org.apache.giraph.comm.WorkerClientRequestProcessor
Sends a request to the appropriate vertex range owner to add an edge
addEdgeRequest(I, Edge<I, E>) - Method in class org.apache.giraph.graph.AbstractComputation
Request to add an edge of a vertex in the graph (processed just prior to the next superstep)
addEdgeRequest(I, Edge<I, E>) - Method in interface org.apache.giraph.graph.Computation
Request to add an edge of a vertex in the graph (processed just prior to the next superstep)
addEdgeRequest(Object, Edge) - Method in class org.apache.giraph.jython.JythonComputation
Request to add an edge of a vertex in the graph (processed just prior to the next superstep)
addEdges(Vertex<I, V, E>, VertexChanges<I, V, E>) - Method in class org.apache.giraph.graph.DefaultVertexResolver
Add edges to the Vertex.
addEdgesLoaded(long) - Method in class org.apache.giraph.worker.WorkerProgress
Add number of edges loaded
addEntry(LongWritable, ByteWritable) - Method in class org.apache.giraph.mapping.LongByteMappingStore
 
addEntry(I, B) - Method in interface org.apache.giraph.mapping.MappingStore
Add an entry to the mapping store
addEntry(int, T) - Method in class org.apache.giraph.ooc.data.DiskBackedDataStore
Adds a data entry for a given partition to the current data store.
addEntryToInMemoryPartitionData(int, T) - Method in class org.apache.giraph.ooc.data.DiskBackedDataStore
Adds a single entry for a given partition to the in-memory data store.
addEntryToInMemoryPartitionData(int, VertexIdEdges<I, E>) - Method in class org.apache.giraph.ooc.data.DiskBackedEdgeStore
 
addEntryToInMemoryPartitionData(int, VertexIdMessages<I, M>) - Method in class org.apache.giraph.ooc.data.DiskBackedMessageStore
 
addEntryToInMemoryPartitionData(int, ExtendedDataOutput) - Method in class org.apache.giraph.ooc.data.DiskBackedPartitionStore
 
addFileToResourceMap(Map<String, LocalResource>, FileSystem, Path) - Static method in class org.apache.giraph.yarn.YarnUtils
Boilerplate to add a file to the local resources..
addFsResourcesToMap(Map<String, LocalResource>, GiraphConfiguration, ApplicationId) - Static method in class org.apache.giraph.yarn.YarnUtils
Populates the LocalResources list with the HDFS paths listed in the conf under GiraphConstants.GIRAPH_YARN_LIBJARS, and the GiraphConfiguration for this job.
addGcObserverClass(Class<? extends GcObserver>) - Method in class org.apache.giraph.conf.GiraphConfiguration
Add a GcObserver class (optional)
addGiraphConfToLocalResourceMap(GiraphConfiguration, ApplicationId, Map<String, LocalResource>) - Static method in class org.apache.giraph.yarn.YarnUtils
Populate the LocalResources list with the GiraphConf XML file's HDFS path.
addGiraphTimersAndSendCounters(long) - Method in interface org.apache.giraph.bsp.CentralizedServiceMaster
Add the Giraph Timers to thirft counter struct, and send to the job client Counters include the Giraph Timers for setup, initialise, shutdown, total, and time for the given superstep
addGiraphTimersAndSendCounters(long) - Method in class org.apache.giraph.master.BspServiceMaster
We add the Giraph Timers separately, because we need to include the time required for shutdown and cleanup This will fetch the final Giraph Timers, and send all the counters to the job client
addIncomingWorkerToWorkerMessage(Writable) - Method in class org.apache.giraph.comm.ServerData
Add incoming message to this worker for next superstep.
addIndex(DataIndex.DataIndexEntry) - Method in class org.apache.giraph.ooc.persistence.DataIndex
Add an index to the index chain
addIOCommand(IOCommand) - Method in class org.apache.giraph.ooc.OutOfCoreIOScheduler
Add an IO command to the scheduling queue of the IO scheduler
addItem(T, String) - Method in class org.apache.giraph.metrics.AggregatedMetric
Add another item to the aggregation.
addItem(Double, String) - Method in class org.apache.giraph.metrics.AggregatedMetricDouble
 
addItem(Long, String) - Method in class org.apache.giraph.metrics.AggregatedMetricLong
 
ADDITIONAL_EDGE_REQUEST_SIZE - Static variable in interface org.apache.giraph.conf.GiraphConstants
Additional size (expressed as a ratio) of each per-partition buffer on top of the average size for edges.
ADDITIONAL_MSG_REQUEST_SIZE - Static variable in interface org.apache.giraph.conf.GiraphConstants
How much bigger than the average per partition size to make initial per partition buffers.
ADDITIONAL_VERTEX_REQUEST_SIZE - Static variable in interface org.apache.giraph.conf.GiraphConstants
Additional size (expressed as a ratio) of each per-partition buffer on top of the average size for vertices.
addLastWithExecutorCheck(String, ChannelHandler, String, EventExecutorGroup, Channel) - Static method in class org.apache.giraph.utils.PipelineUtils
Add a handler to pipeline if it is not already added and configure the handler to use an executor group based on equality of compareTo and handlerName
addListener(MetricsRegistryListener) - Method in class org.apache.giraph.metrics.NoOpMetricsRegistry
 
addLocalClasspathToEnv(Map<String, String>, GiraphConfiguration) - Static method in class org.apache.giraph.yarn.YarnUtils
Popuate the environment string map to be added to the environment vars in a remote execution container.
addMapperObserverClass(Class<? extends MapperObserver>) - Method in class org.apache.giraph.conf.GiraphConfiguration
Add a MapperObserver class (optional)
addMasterObserverClass(Class<? extends MasterObserver>) - Method in class org.apache.giraph.conf.GiraphConfiguration
Add a MasterObserver class (optional)
addMessage(I, M) - Method in class org.apache.giraph.comm.messages.ByteArrayMessagesPerVertexStore
 
addMessage(I, M) - Method in interface org.apache.giraph.comm.messages.MessageStore
Adds a message for a particular vertex The method is used by InternalMessageStore to send local messages; for the general case, use a more efficient addPartitionMessages
addMessage(I, M) - Method in class org.apache.giraph.comm.messages.OneMessagePerVertexStore
 
addMessage(I, M) - Method in class org.apache.giraph.comm.messages.PointerListPerVertexStore
 
addMessage(I, M) - Method in class org.apache.giraph.comm.messages.primitives.IdByteArrayMessageStore
Adds a message for a particular vertex
addMessage(I, M) - Method in class org.apache.giraph.comm.messages.primitives.IdOneMessagePerVertexStore
Adds a message for a particular vertex
addMessage(IntWritable, FloatWritable) - Method in class org.apache.giraph.comm.messages.primitives.IntFloatMessageStore
 
addMessage(LongWritable, M) - Method in class org.apache.giraph.comm.messages.primitives.long_id.LongPointerListPerVertexStore
 
addMessage(LongWritable, DoubleWritable) - Method in class org.apache.giraph.comm.messages.primitives.LongDoubleMessageStore
 
addMessage(I, M) - Method in class org.apache.giraph.comm.messages.queue.AsyncMessageStoreWrapper
 
addMessage(WorkerInfo, int, I, M) - Method in class org.apache.giraph.comm.SendMessageCache
Add a message to the cache.
addMessage(WorkerInfo, int, byte[], int, M) - Method in class org.apache.giraph.comm.SendMessageCache
Add a message to the cache with serialized ids.
addMessage(I, M) - Method in class org.apache.giraph.ooc.data.DiskBackedMessageStore
 
addMessageBytesCount(long) - Method in class org.apache.giraph.graph.GlobalStats
Add messages to the global stats.
addMessageBytesSentCount(long) - Method in class org.apache.giraph.partition.PartitionStats
Add message bytes to messageBytesSentCount.
addMessageCount(long) - Method in class org.apache.giraph.graph.GlobalStats
Add messages to the global stats.
addMessagesSentCount(long) - Method in class org.apache.giraph.partition.PartitionStats
Add messages to the messages sent count.
addOocLoadBytesCount(long) - Method in class org.apache.giraph.graph.GlobalStats
Add bytes loaded to the global stats.
addOocStoreBytesCount(long) - Method in class org.apache.giraph.graph.GlobalStats
Add bytes stored to the global stats.
addOption(String, String, boolean, String) - Static method in class org.apache.giraph.utils.ConfigurationUtils
Callers can place additional options to be parsed and stored in our job's GiraphConfiguration via this utility call.
addParameter(String, String) - Method in class org.apache.giraph.io.formats.multi.InputFormatDescription
Add parameter to this input format description
addParameters(JSONObject) - Method in class org.apache.giraph.io.formats.multi.InputFormatDescription
Add all parameters from json object
addPartition(Partition<I, V, E>) - Method in class org.apache.giraph.ooc.data.DiskBackedPartitionStore
 
addPartition(int) - Method in class org.apache.giraph.ooc.data.MetaPartitionManager
Add a partition
addPartition(Partition<I, V, E>) - Method in class org.apache.giraph.partition.ByteArrayPartition
 
addPartition(Partition<I, V, E>) - Method in interface org.apache.giraph.partition.Partition
Add a partition's vertices.
addPartition(Partition<I, V, E>) - Method in interface org.apache.giraph.partition.PartitionStore
Add a *new* partition to the store.
addPartition(Partition<I, V, E>) - Method in class org.apache.giraph.partition.SimplePartition
 
addPartition(Partition<I, V, E>) - Method in class org.apache.giraph.partition.SimplePartitionStore
 
addPartitionEdges(int, VertexIdEdges<I, E>) - Method in class org.apache.giraph.edge.AbstractEdgeStore
 
addPartitionEdges(int, VertexIdEdges<I, E>) - Method in interface org.apache.giraph.edge.EdgeStore
Add edges belonging to a given partition on this worker.
addPartitionEdges(int, VertexIdEdges<I, E>) - Method in class org.apache.giraph.ooc.data.DiskBackedEdgeStore
 
addPartitionMessages(int, VertexIdMessages<I, M>) - Method in class org.apache.giraph.comm.messages.ByteArrayMessagesPerVertexStore
 
addPartitionMessages(int, VertexIdMessages<I, M>) - Method in interface org.apache.giraph.comm.messages.MessageStore
Adds messages for partition
addPartitionMessages(int, VertexIdMessages<I, M>) - Method in class org.apache.giraph.comm.messages.OneMessagePerVertexStore
 
addPartitionMessages(int, VertexIdMessages<I, M>) - Method in class org.apache.giraph.comm.messages.PointerListPerVertexStore
 
addPartitionMessages(int, VertexIdMessages<I, M>) - Method in class org.apache.giraph.comm.messages.primitives.IdByteArrayMessageStore
 
addPartitionMessages(int, VertexIdMessages<I, M>) - Method in class org.apache.giraph.comm.messages.primitives.IdOneMessagePerVertexStore
 
addPartitionMessages(int, VertexIdMessages<IntWritable, FloatWritable>) - Method in class org.apache.giraph.comm.messages.primitives.IntFloatMessageStore
 
addPartitionMessages(int, VertexIdMessages<LongWritable, M>) - Method in class org.apache.giraph.comm.messages.primitives.long_id.LongPointerListPerVertexStore
 
addPartitionMessages(int, VertexIdMessages<LongWritable, DoubleWritable>) - Method in class org.apache.giraph.comm.messages.primitives.LongDoubleMessageStore
 
addPartitionMessages(int, VertexIdMessages<I, M>) - Method in class org.apache.giraph.comm.messages.queue.AsyncMessageStoreWrapper
 
addPartitionMessages(int, VertexIdMessages<I, M>) - Method in class org.apache.giraph.ooc.data.DiskBackedMessageStore
 
addPartitionStats(PartitionStats) - Method in class org.apache.giraph.graph.GlobalStats
Add the stats of a partition to the global stats.
addPartitionVertices(Integer, ExtendedDataOutput) - Method in class org.apache.giraph.ooc.data.DiskBackedPartitionStore
 
addPartitionVertices(VertexIterator<I, V, E>) - Method in class org.apache.giraph.partition.BasicPartition
 
addPartitionVertices(VertexIterator<I, V, E>) - Method in interface org.apache.giraph.partition.Partition
Add vertices to a partition.
addPartitionVertices(Integer, ExtendedDataOutput) - Method in interface org.apache.giraph.partition.PartitionStore
Add vertices to a given partition from a given DataOutput instance.
addPartitionVertices(Integer, ExtendedDataOutput) - Method in class org.apache.giraph.partition.SimplePartitionStore
 
addressesAndPartitionsReceived(AddressesAndPartitionsWritable) - Method in interface org.apache.giraph.bsp.CentralizedServiceWorker
Received addresses and partitions assignments from master.
addressesAndPartitionsReceived(AddressesAndPartitionsWritable) - Method in class org.apache.giraph.worker.BspServiceWorker
 
AddressesAndPartitionsRequest - Class in org.apache.giraph.comm.requests
Request for master sending addresses and partitions to workers
AddressesAndPartitionsRequest() - Constructor for class org.apache.giraph.comm.requests.AddressesAndPartitionsRequest
Constructor for reflection
AddressesAndPartitionsRequest(AddressesAndPartitionsWritable) - Constructor for class org.apache.giraph.comm.requests.AddressesAndPartitionsRequest
Constructor
AddressesAndPartitionsWritable - Class in org.apache.giraph.graph
Helper class to write descriptions of master, workers and partition owners
AddressesAndPartitionsWritable(MasterInfo, List<WorkerInfo>, Collection<PartitionOwner>) - Constructor for class org.apache.giraph.graph.AddressesAndPartitionsWritable
Constructor when we want to serialize object
AddressesAndPartitionsWritable() - Constructor for class org.apache.giraph.graph.AddressesAndPartitionsWritable
Constructor for reflection
addRow(FloatDenseVector) - Method in class org.apache.giraph.aggregators.matrix.dense.FloatDenseMatrix
Add the float vector as a row in the matrix.
addRow(IntDenseVector) - Method in class org.apache.giraph.aggregators.matrix.dense.IntDenseMatrix
Add the int vector as a row in the matrix.
addScriptToLoad(Configuration, String, DeployType, Language) - Static method in class org.apache.giraph.scripting.ScriptLoader
Add a script to load on workers
addScriptToLoad(Configuration, DeployedScript) - Static method in class org.apache.giraph.scripting.ScriptLoader
Add a script to load on workers
addSpecialCount(Integer) - Method in class org.apache.giraph.comm.aggregators.SendGlobalCommCache
Creates special value which will hold the total number of global communication requests for worker with selected task id.
addSplits(InputType, List<InputSplit>, GiraphInputFormat) - Method in class org.apache.giraph.master.input.MasterInputSplitsHandler
Add splits
addSuperstepResetObserver(ResetSuperstepMetricsObserver) - Method in class org.apache.giraph.metrics.GiraphMetrics
Anyone using per-superstep counters needs to re-initialize their Metrics object on each new superstep.
addToClasses(Configuration, String, Class<? extends T>, Class<T>) - Static method in class org.apache.giraph.conf.ClassConfOption
Add a class to a property that is a list of classes.
addToOptions(Options) - Method in class org.apache.giraph.benchmark.BenchmarkOption
Add option to cli Options
addValue(String, GlobalCommType, Writable) - Method in class org.apache.giraph.comm.aggregators.GlobalCommValueOutputStream
Write global communication object to the stream and increment internal counter
addValue(Integer, String, GlobalCommType, Writable) - Method in class org.apache.giraph.comm.aggregators.SendGlobalCommCache
Add global communication value to the cache
addVertex(PartitionOwner, Vertex<I, V, E>) - Method in class org.apache.giraph.comm.SendPartitionCache
Add a vertex to the cache.
addVertex(Vertex<I, V, E>) - Method in class org.apache.giraph.graph.VertexMutations
Add a vertex mutation
addVertex(Vertex<I, V, E>) - Method in class org.apache.giraph.utils.TestGraph
Add vertex
addVertex(I, V, Map.Entry<I, E>...) - Method in class org.apache.giraph.utils.TestGraph
Add vertex with given ID
addVertexIfDesired(I, Vertex<I, V, E>, VertexChanges<I, V, E>, boolean) - Method in class org.apache.giraph.graph.DefaultVertexResolver
Add the Vertex if desired.
addVertexInputPath(Configuration, Path) - Static method in class org.apache.giraph.io.formats.GiraphFileInputFormat
Add a Path to the list of vertex inputs.
addVertexMutation(Integer, Vertex<I, V, E>) - Method in class org.apache.giraph.comm.SendMutationsCache
Add a add vertex mutation to the cache.
addVertexMutations(VertexMutations<I, V, E>) - Method in class org.apache.giraph.graph.VertexMutations
Add one vertex mutations to another
addVertexRequest(Vertex<I, V, E>) - Method in class org.apache.giraph.comm.netty.NettyWorkerClientRequestProcessor
 
addVertexRequest(Vertex<I, V, E>) - Method in interface org.apache.giraph.comm.WorkerClientRequestProcessor
Sends a request to the appropriate vertex range owner to add a vertex
addVertexRequest(I, V, OutEdges<I, E>) - Method in class org.apache.giraph.graph.AbstractComputation
Sends a request to create a vertex that will be available during the next superstep.
addVertexRequest(I, V) - Method in class org.apache.giraph.graph.AbstractComputation
Sends a request to create a vertex that will be available during the next superstep.
addVertexRequest(I, V, OutEdges<I, E>) - Method in interface org.apache.giraph.graph.Computation
Sends a request to create a vertex that will be available during the next superstep.
addVertexRequest(I, V) - Method in interface org.apache.giraph.graph.Computation
Sends a request to create a vertex that will be available during the next superstep.
addVertexRequest(Object, Object, OutEdges) - Method in class org.apache.giraph.jython.JythonComputation
Sends a request to create a vertex that will be available during the next superstep.
addVertexRequest(Object, Object) - Method in class org.apache.giraph.jython.JythonComputation
Sends a request to create a vertex that will be available during the next superstep.
addVerticesComputed(long) - Method in class org.apache.giraph.worker.WorkerProgress
Add number of vertices computed
addVerticesLoaded(long) - Method in class org.apache.giraph.worker.WorkerProgress
Add number of vertices loaded
addVerticesStored(long) - Method in class org.apache.giraph.worker.WorkerProgress
Add number of vertices stored
addW(BooleanWritable) - Method in class org.apache.giraph.types.ops.collections.array.WBooleanArrayList
 
addW(ByteWritable) - Method in class org.apache.giraph.types.ops.collections.array.WByteArrayList
 
addW(DoubleWritable) - Method in class org.apache.giraph.types.ops.collections.array.WDoubleArrayList
 
addW(FloatWritable) - Method in class org.apache.giraph.types.ops.collections.array.WFloatArrayList
 
addW(IntWritable) - Method in class org.apache.giraph.types.ops.collections.array.WIntArrayList
 
addW(LongWritable) - Method in class org.apache.giraph.types.ops.collections.array.WLongArrayList
 
addW(T) - Method in interface org.apache.giraph.types.ops.collections.WCollection
Add value to the collection
addWorkerObserverClass(Class<? extends WorkerObserver>) - Method in class org.apache.giraph.conf.GiraphConfiguration
Add a WorkerObserver class (optional)
AdjacencyListTextVertexInputFormat<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.formats
VertexReader that readers lines of text with vertices encoded as adjacency lists and converts each token to the correct type.
AdjacencyListTextVertexInputFormat() - Constructor for class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat
 
AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader - Class in org.apache.giraph.io.formats
Vertex reader associated with AdjacencyListTextVertexInputFormat.
AdjacencyListTextVertexInputFormat.LineSanitizer - Interface in org.apache.giraph.io.formats
Utility for doing any cleaning of each line before it is tokenized.
AdjacencyListTextVertexOutputFormat<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.formats
OutputFormat to write out the graph nodes as text, value-separated (by tabs, by default).
AdjacencyListTextVertexOutputFormat() - Constructor for class org.apache.giraph.io.formats.AdjacencyListTextVertexOutputFormat
 
AdjacencyListTextVertexOutputFormat.AdjacencyListTextVertexWriter - Class in org.apache.giraph.io.formats
Vertex writer associated with AdjacencyListTextVertexOutputFormat.
AdjacencyListTextVertexReader() - Constructor for class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader
Constructor without line sanitizer.
AdjacencyListTextVertexReader(AdjacencyListTextVertexInputFormat.LineSanitizer) - Constructor for class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader
Constructor with line sanitizer.
AdjacencyListTextVertexWriter() - Constructor for class org.apache.giraph.io.formats.AdjacencyListTextVertexOutputFormat.AdjacencyListTextVertexWriter
 
AdjustableSemaphore - Class in org.apache.giraph.utils
Implementation of a semaphore where number of available permits can change
AdjustableSemaphore(int) - Constructor for class org.apache.giraph.utils.AdjustableSemaphore
Constructor
AGG_SUPERSTEP_TOTAL_BYTES - Static variable in class org.apache.giraph.benchmark.RandomMessageBenchmark
All bytes sent during this superstep
AGG_SUPERSTEP_TOTAL_MESSAGES - Static variable in class org.apache.giraph.benchmark.RandomMessageBenchmark
All messages during this superstep
AGG_SUPERSTEP_TOTAL_MILLIS - Static variable in class org.apache.giraph.benchmark.RandomMessageBenchmark
All millis during this superstep
AGG_TOTAL_BYTES - Static variable in class org.apache.giraph.benchmark.RandomMessageBenchmark
All bytes sent during this application
AGG_TOTAL_MESSAGES - Static variable in class org.apache.giraph.benchmark.RandomMessageBenchmark
All messages during this application
AGG_TOTAL_MILLIS - Static variable in class org.apache.giraph.benchmark.RandomMessageBenchmark
All millis during this application
aggregate(A) - Method in interface org.apache.giraph.aggregators.Aggregator
Add a new value.
aggregate(BooleanWritable) - Method in class org.apache.giraph.aggregators.BooleanAndAggregator
 
aggregate(BooleanWritable) - Method in class org.apache.giraph.aggregators.BooleanOrAggregator
 
aggregate(BooleanWritable) - Method in class org.apache.giraph.aggregators.BooleanOverwriteAggregator
 
aggregate(DoubleWritable) - Method in class org.apache.giraph.aggregators.DoubleMaxAggregator
 
aggregate(DoubleWritable) - Method in class org.apache.giraph.aggregators.DoubleMinAggregator
 
aggregate(DoubleWritable) - Method in class org.apache.giraph.aggregators.DoubleOverwriteAggregator
 
aggregate(DoubleWritable) - Method in class org.apache.giraph.aggregators.DoubleProductAggregator
 
aggregate(DoubleWritable) - Method in class org.apache.giraph.aggregators.DoubleSumAggregator
 
aggregate(FloatWritable) - Method in class org.apache.giraph.aggregators.FloatMaxAggregator
 
aggregate(FloatWritable) - Method in class org.apache.giraph.aggregators.FloatMinAggregator
 
aggregate(FloatWritable) - Method in class org.apache.giraph.aggregators.FloatOverwriteAggregator
 
aggregate(FloatWritable) - Method in class org.apache.giraph.aggregators.FloatProductAggregator
 
aggregate(FloatWritable) - Method in class org.apache.giraph.aggregators.FloatSumAggregator
 
aggregate(IntWritable) - Method in class org.apache.giraph.aggregators.IntMaxAggregator
 
aggregate(IntWritable) - Method in class org.apache.giraph.aggregators.IntMinAggregator
 
aggregate(IntWritable) - Method in class org.apache.giraph.aggregators.IntOverwriteAggregator
 
aggregate(IntWritable) - Method in class org.apache.giraph.aggregators.IntProductAggregator
 
aggregate(IntWritable) - Method in class org.apache.giraph.aggregators.IntSumAggregator
 
aggregate(LongWritable) - Method in class org.apache.giraph.aggregators.LongMaxAggregator
 
aggregate(LongWritable) - Method in class org.apache.giraph.aggregators.LongMinAggregator
 
aggregate(LongWritable) - Method in class org.apache.giraph.aggregators.LongOverwriteAggregator
 
aggregate(LongWritable) - Method in class org.apache.giraph.aggregators.LongProductAggregator
 
aggregate(LongWritable) - Method in class org.apache.giraph.aggregators.LongSumAggregator
 
aggregate(int, int, double, WorkerAggregatorUsage) - Method in class org.apache.giraph.aggregators.matrix.dense.DoubleDenseMatrixSumAggregator
Add the given value to the entry specified.
aggregate(DoubleDenseVector) - Method in class org.apache.giraph.aggregators.matrix.dense.DoubleDenseVectorSumAggregator
 
aggregate(int, int, float, WorkerAggregatorUsage) - Method in class org.apache.giraph.aggregators.matrix.dense.FloatDenseMatrixSumAggregator
Add the given value to the entry specified.
aggregate(FloatDenseVector) - Method in class org.apache.giraph.aggregators.matrix.dense.FloatDenseVectorSumAggregator
 
aggregate(int, int, int, WorkerAggregatorUsage) - Method in class org.apache.giraph.aggregators.matrix.dense.IntDenseMatrixSumAggregator
Add the given value to the entry specified.
aggregate(IntDenseVector) - Method in class org.apache.giraph.aggregators.matrix.dense.IntDenseVectorSumAggregator
 
aggregate(int, int, long, WorkerAggregatorUsage) - Method in class org.apache.giraph.aggregators.matrix.dense.LongDenseMatrixSumAggregator
Add the given value to the entry specified.
aggregate(LongDenseVector) - Method in class org.apache.giraph.aggregators.matrix.dense.LongDenseVectorSumAggregator
 
aggregate(int, int, double, WorkerAggregatorUsage) - Method in class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseMatrixSumAggregator
Add the given value to the entry specified.
aggregate(DoubleSparseVector) - Method in class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseVectorSumAggregator
 
aggregate(int, int, float, WorkerAggregatorUsage) - Method in class org.apache.giraph.aggregators.matrix.sparse.FloatSparseMatrixSumAggregator
Add the given value to the entry specified.
aggregate(FloatSparseVector) - Method in class org.apache.giraph.aggregators.matrix.sparse.FloatSparseVectorSumAggregator
 
aggregate(int, int, int, WorkerAggregatorUsage) - Method in class org.apache.giraph.aggregators.matrix.sparse.IntSparseMatrixSumAggregator
Add the given value to the entry specified.
aggregate(IntSparseVector) - Method in class org.apache.giraph.aggregators.matrix.sparse.IntSparseVectorSumAggregator
 
aggregate(int, int, long, WorkerAggregatorUsage) - Method in class org.apache.giraph.aggregators.matrix.sparse.LongSparseMatrixSumAggregator
Add the given value to the entry specified.
aggregate(LongSparseVector) - Method in class org.apache.giraph.aggregators.matrix.sparse.LongSparseVectorSumAggregator
 
aggregate(Text) - Method in class org.apache.giraph.aggregators.TextAppendAggregator
 
aggregate(String, WorkerAggregatorUsage, Configuration) - Static method in class org.apache.giraph.utils.MasterLoggingAggregator
Aggregate some message to master logging aggregator, if the option for using it is set in the configuration.
aggregate(String, A) - Method in class org.apache.giraph.worker.WorkerAggregatorDelegator
 
aggregate(String, A) - Method in interface org.apache.giraph.worker.WorkerAggregatorUsage
Add a new value
AGGREGATE_SENT_MESSAGE_BYTES_NAME - Static variable in class org.apache.giraph.counters.GiraphStats
aggregate sent messages bytes counter name
AGGREGATE_SENT_MESSAGES_NAME - Static variable in class org.apache.giraph.counters.GiraphStats
aggregate sent messages counter name
AGGREGATE_VERTICES - Static variable in class org.apache.giraph.io.formats.PseudoRandomInputFormatConstants
Set the number of aggregate vertices.
AggregatedMetric<T extends Number> - Class in org.apache.giraph.metrics
An aggregator over metrics from multiple hosts.
AggregatedMetric() - Constructor for class org.apache.giraph.metrics.AggregatedMetric
 
AggregatedMetricDouble - Class in org.apache.giraph.metrics
Aggregator over metrics with double values
AggregatedMetricDouble() - Constructor for class org.apache.giraph.metrics.AggregatedMetricDouble
Constructor
AggregatedMetricLong - Class in org.apache.giraph.metrics
Aggregator over metrics with long values
AggregatedMetricLong() - Constructor for class org.apache.giraph.metrics.AggregatedMetricLong
Constructor
AggregatedMetrics - Class in org.apache.giraph.metrics
Map of a bunch of aggregated metrics
AggregatedMetrics() - Constructor for class org.apache.giraph.metrics.AggregatedMetrics
 
Aggregator<A extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.aggregators
Interface for Aggregator.
AGGREGATOR_WRITER_CLASS - Static variable in interface org.apache.giraph.conf.GiraphConstants
AggregatorWriter class - optional
AggregatorBroadcast<A extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.master
Writable representation of aggregated value
AggregatorBroadcast() - Constructor for class org.apache.giraph.master.AggregatorBroadcast
Constructor
AggregatorBroadcast(Class<? extends Aggregator<A>>, A) - Constructor for class org.apache.giraph.master.AggregatorBroadcast
Constructor
AggregatorReduceOperation<A extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.master
Translates aggregation operation to reduce operations.
AggregatorReduceOperation() - Constructor for class org.apache.giraph.master.AggregatorReduceOperation
Constructor
AggregatorReduceOperation(Class<? extends Aggregator<A>>, ImmutableClassesGiraphConfiguration<?, ?, ?>) - Constructor for class org.apache.giraph.master.AggregatorReduceOperation
Constructor
AggregatorsBenchmark - Class in org.apache.giraph.benchmark
Benchmark for aggregators.
AggregatorsBenchmark() - Constructor for class org.apache.giraph.benchmark.AggregatorsBenchmark
 
AggregatorsBenchmark.AggregatorsBenchmarkComputation - Class in org.apache.giraph.benchmark
Vertex class for AggregatorsBenchmark
AggregatorsBenchmark.AggregatorsBenchmarkMasterCompute - Class in org.apache.giraph.benchmark
MasterCompute class for AggregatorsBenchmark
AggregatorsBenchmark.AggregatorsBenchmarkWorkerContext - Class in org.apache.giraph.benchmark
WorkerContext class for AggregatorsBenchmark
AggregatorsBenchmarkComputation() - Constructor for class org.apache.giraph.benchmark.AggregatorsBenchmark.AggregatorsBenchmarkComputation
 
AggregatorsBenchmarkMasterCompute() - Constructor for class org.apache.giraph.benchmark.AggregatorsBenchmark.AggregatorsBenchmarkMasterCompute
 
AggregatorsBenchmarkWorkerContext() - Constructor for class org.apache.giraph.benchmark.AggregatorsBenchmark.AggregatorsBenchmarkWorkerContext
 
AggregatorToGlobalCommTranslation - Class in org.apache.giraph.master
Class that translates aggregator handling on the master to reduce and broadcast operations supported by the MasterAggregatorHandler.
AggregatorToGlobalCommTranslation(ImmutableClassesGiraphConfiguration<?, ?, ?>, MasterGlobalCommUsage) - Constructor for class org.apache.giraph.master.AggregatorToGlobalCommTranslation
Constructor
aggregatorToString(String, Writable, long) - Method in class org.apache.giraph.aggregators.TextAggregatorWriter
Implements the way an aggregator is converted into a String.
AggregatorUsage - Interface in org.apache.giraph.aggregators
Master and workers can access aggregators through this interface.
AggregatorUtils - Class in org.apache.giraph.comm.aggregators
Class for aggregator constants and utility methods
AggregatorWriter - Interface in org.apache.giraph.aggregators
An AggregatorWriter is used to export Aggregators during or at the end of each computation.
aggregatorWriterClass - Variable in class org.apache.giraph.conf.GiraphClasses
Aggregator writer class - cached for fast access
Algorithm - Annotation Type in org.apache.giraph
This annotation should be used to annotate built-in algorithms.
AllAggregatorServerData - Class in org.apache.giraph.comm.aggregators
Accepts aggregators and their values from previous superstep from master and workers which own aggregators.
AllAggregatorServerData(Progressable, ImmutableClassesGiraphConfiguration) - Constructor for class org.apache.giraph.comm.aggregators.AllAggregatorServerData
Constructor
allMetrics() - Method in class org.apache.giraph.metrics.NoOpMetricsRegistry
 
AllOptions - Class in org.apache.giraph.conf
Tracks all of the Giraph options
allVerticesHalted() - Method in class org.apache.giraph.graph.FinishedSuperstepStats
Are all the vertices halted?
AllWorkersInfo - Class in org.apache.giraph.worker
Information about all workers, their WorkerInfo values, and indices.
AllWorkersInfo(List<WorkerInfo>, WorkerInfo) - Constructor for class org.apache.giraph.worker.AllWorkersInfo
Constructor
ALWAYS - Static variable in class org.apache.giraph.aggregators.TextAggregatorWriter
Signal for "write values in every superstep" frequency
AM_HIGH_THRESHOLD - Static variable in class org.apache.giraph.ooc.policy.MemoryEstimatorOracle
If mem-usage is above this threshold, active threads are set to 0
AM_LOW_THRESHOLD - Static variable in class org.apache.giraph.ooc.policy.MemoryEstimatorOracle
If mem-usage is below this threshold, active threads are set to max
analyzePartitionStats(Collection<PartitionOwner>, List<PartitionStats>) - Static method in class org.apache.giraph.partition.PartitionUtils
Check for imbalances on a per worker basis, by calculating the mean, high and low workers by edges and vertices.
AndReduce - Class in org.apache.giraph.reducers.impl
ReduceOperation for calculating the AND function over boolean values.
AndReduce() - Constructor for class org.apache.giraph.reducers.impl.AndReduce
 
AnnotationUtils - Class in org.apache.giraph.utils
Helper class to deal with annotations in runtime.
APPLICATION_ATTEMPTS_DIR - Static variable in class org.apache.giraph.bsp.BspService
Directory of attempts of this application
applicationAttemptsPath - Variable in class org.apache.giraph.bsp.BspService
Path to the application attempts)
applicationFailed(Exception) - Method in class org.apache.giraph.master.DefaultMasterObserver
 
applicationFailed(Exception) - Method in interface org.apache.giraph.master.MasterObserver
If there is an error during the application.
applicationFailed(Exception) - Method in class org.apache.giraph.utils.JMapHistoDumper
 
applicationFailed(Exception) - Method in class org.apache.giraph.utils.LogVersions
 
applicationFailed(Exception) - Method in class org.apache.giraph.utils.ReactiveJMapHistoDumper
 
ApplicationState - Enum in org.apache.giraph.bsp
State of the BSP application
apply(T) - Method in interface org.apache.giraph.function.Consumer
Applies this function to input
apply(F) - Method in interface org.apache.giraph.function.Function
Returns the result of applying this function to given input.
apply(T) - Method in class org.apache.giraph.function.ObjectHolder
 
apply(T) - Method in class org.apache.giraph.function.ObjectNotifier
 
apply(T) - Method in class org.apache.giraph.function.ObjectTransfer
 
apply(T1, T2) - Method in interface org.apache.giraph.function.PairConsumer
Applies this function to input1 and input2
apply(F1, F2) - Method in interface org.apache.giraph.function.PairFunction
Returns the result of applying this function to given input1 and input2.
apply(T1, T2) - Method in interface org.apache.giraph.function.PairPredicate
Returns the result of applying this predicate to input1 and input2.
apply(T) - Method in interface org.apache.giraph.function.Predicate
Returns the result of applying this predicate to input.
apply(boolean) - Method in interface org.apache.giraph.function.primitive.Boolean2BooleanFunction
Returns the result of applying this function to given input.
apply(boolean) - Method in interface org.apache.giraph.function.primitive.Boolean2ObjFunction
Returns the result of applying this function to given input.
apply(boolean) - Method in interface org.apache.giraph.function.primitive.BooleanConsumer
Applies this function to input
apply(boolean) - Method in interface org.apache.giraph.function.primitive.BooleanPredicate
Returns the result of applying this predicate to input.
apply(byte) - Method in interface org.apache.giraph.function.primitive.Byte2ByteFunction
Returns the result of applying this function to given input.
apply(byte) - Method in interface org.apache.giraph.function.primitive.Byte2ObjFunction
Returns the result of applying this function to given input.
apply(byte) - Method in interface org.apache.giraph.function.primitive.ByteConsumer
Applies this function to input
apply(byte) - Method in interface org.apache.giraph.function.primitive.BytePredicate
Returns the result of applying this predicate to input.
apply(double) - Method in interface org.apache.giraph.function.primitive.Double2DoubleFunction
Returns the result of applying this function to given input.
apply(double) - Method in interface org.apache.giraph.function.primitive.Double2ObjFunction
Returns the result of applying this function to given input.
apply(double) - Method in interface org.apache.giraph.function.primitive.DoubleConsumer
Applies this function to input
apply(double) - Method in interface org.apache.giraph.function.primitive.DoublePredicate
Returns the result of applying this predicate to input.
apply(float) - Method in interface org.apache.giraph.function.primitive.Float2FloatFunction
Returns the result of applying this function to given input.
apply(float) - Method in interface org.apache.giraph.function.primitive.Float2ObjFunction
Returns the result of applying this function to given input.
apply(float) - Method in interface org.apache.giraph.function.primitive.FloatConsumer
Applies this function to input
apply(float) - Method in interface org.apache.giraph.function.primitive.FloatPredicate
Returns the result of applying this predicate to input.
apply(int) - Method in interface org.apache.giraph.function.primitive.Int2IntFunction
Returns the result of applying this function to given input.
apply(int) - Method in interface org.apache.giraph.function.primitive.Int2ObjFunction
Returns the result of applying this function to given input.
apply(int) - Method in interface org.apache.giraph.function.primitive.IntConsumer
Applies this function to input
apply(int) - Method in interface org.apache.giraph.function.primitive.IntPredicate
Returns the result of applying this predicate to input.
apply(long) - Method in interface org.apache.giraph.function.primitive.Long2LongFunction
Returns the result of applying this function to given input.
apply(long) - Method in interface org.apache.giraph.function.primitive.Long2ObjFunction
Returns the result of applying this function to given input.
apply(long) - Method in interface org.apache.giraph.function.primitive.LongConsumer
Applies this function to input
apply(long) - Method in interface org.apache.giraph.function.primitive.LongPredicate
Returns the result of applying this predicate to input.
apply(T) - Method in interface org.apache.giraph.function.primitive.Obj2BooleanFunction
Returns the result of applying this function to given input.
apply(T) - Method in interface org.apache.giraph.function.primitive.Obj2ByteFunction
Returns the result of applying this function to given input.
apply(T) - Method in interface org.apache.giraph.function.primitive.Obj2DoubleFunction
Returns the result of applying this function to given input.
apply(T) - Method in interface org.apache.giraph.function.primitive.Obj2FloatFunction
Returns the result of applying this function to given input.
apply(T) - Method in interface org.apache.giraph.function.primitive.Obj2IntFunction
Returns the result of applying this function to given input.
apply(T) - Method in interface org.apache.giraph.function.primitive.Obj2LongFunction
Returns the result of applying this function to given input.
apply(T) - Method in interface org.apache.giraph.function.primitive.Obj2ShortFunction
Returns the result of applying this function to given input.
apply(boolean, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanBooleanConsumer
Applies this function to input1 and input2
apply(boolean, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanBooleanPredicate
Returns the result of applying this predicate to input.
apply(boolean, byte) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanByteConsumer
Applies this function to input1 and input2
apply(boolean, byte) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanBytePredicate
Returns the result of applying this predicate to input.
apply(boolean, double) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanDoubleConsumer
Applies this function to input1 and input2
apply(boolean, double) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanDoublePredicate
Returns the result of applying this predicate to input.
apply(boolean, float) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanFloatConsumer
Applies this function to input1 and input2
apply(boolean, float) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanFloatPredicate
Returns the result of applying this predicate to input.
apply(boolean, int) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanIntConsumer
Applies this function to input1 and input2
apply(boolean, int) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanIntPredicate
Returns the result of applying this predicate to input.
apply(boolean, long) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanLongConsumer
Applies this function to input1 and input2
apply(boolean, long) - Method in interface org.apache.giraph.function.primitive.pairs.BooleanLongPredicate
Returns the result of applying this predicate to input.
apply(byte, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.ByteBooleanConsumer
Applies this function to input1 and input2
apply(byte, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.ByteBooleanPredicate
Returns the result of applying this predicate to input.
apply(byte, byte) - Method in interface org.apache.giraph.function.primitive.pairs.ByteByteConsumer
Applies this function to input1 and input2
apply(byte, byte) - Method in interface org.apache.giraph.function.primitive.pairs.ByteBytePredicate
Returns the result of applying this predicate to input.
apply(byte, double) - Method in interface org.apache.giraph.function.primitive.pairs.ByteDoubleConsumer
Applies this function to input1 and input2
apply(byte, double) - Method in interface org.apache.giraph.function.primitive.pairs.ByteDoublePredicate
Returns the result of applying this predicate to input.
apply(byte, float) - Method in interface org.apache.giraph.function.primitive.pairs.ByteFloatConsumer
Applies this function to input1 and input2
apply(byte, float) - Method in interface org.apache.giraph.function.primitive.pairs.ByteFloatPredicate
Returns the result of applying this predicate to input.
apply(byte, int) - Method in interface org.apache.giraph.function.primitive.pairs.ByteIntConsumer
Applies this function to input1 and input2
apply(byte, int) - Method in interface org.apache.giraph.function.primitive.pairs.ByteIntPredicate
Returns the result of applying this predicate to input.
apply(byte, long) - Method in interface org.apache.giraph.function.primitive.pairs.ByteLongConsumer
Applies this function to input1 and input2
apply(byte, long) - Method in interface org.apache.giraph.function.primitive.pairs.ByteLongPredicate
Returns the result of applying this predicate to input.
apply(double, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleBooleanConsumer
Applies this function to input1 and input2
apply(double, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleBooleanPredicate
Returns the result of applying this predicate to input.
apply(double, byte) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleByteConsumer
Applies this function to input1 and input2
apply(double, byte) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleBytePredicate
Returns the result of applying this predicate to input.
apply(double, double) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleDoubleConsumer
Applies this function to input1 and input2
apply(double, double) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleDoublePredicate
Returns the result of applying this predicate to input.
apply(double, float) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleFloatConsumer
Applies this function to input1 and input2
apply(double, float) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleFloatPredicate
Returns the result of applying this predicate to input.
apply(double, int) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleIntConsumer
Applies this function to input1 and input2
apply(double, int) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleIntPredicate
Returns the result of applying this predicate to input.
apply(double, long) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleLongConsumer
Applies this function to input1 and input2
apply(double, long) - Method in interface org.apache.giraph.function.primitive.pairs.DoubleLongPredicate
Returns the result of applying this predicate to input.
apply(float, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.FloatBooleanConsumer
Applies this function to input1 and input2
apply(float, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.FloatBooleanPredicate
Returns the result of applying this predicate to input.
apply(float, byte) - Method in interface org.apache.giraph.function.primitive.pairs.FloatByteConsumer
Applies this function to input1 and input2
apply(float, byte) - Method in interface org.apache.giraph.function.primitive.pairs.FloatBytePredicate
Returns the result of applying this predicate to input.
apply(float, double) - Method in interface org.apache.giraph.function.primitive.pairs.FloatDoubleConsumer
Applies this function to input1 and input2
apply(float, double) - Method in interface org.apache.giraph.function.primitive.pairs.FloatDoublePredicate
Returns the result of applying this predicate to input.
apply(float, float) - Method in interface org.apache.giraph.function.primitive.pairs.FloatFloatConsumer
Applies this function to input1 and input2
apply(float, float) - Method in interface org.apache.giraph.function.primitive.pairs.FloatFloatPredicate
Returns the result of applying this predicate to input.
apply(float, int) - Method in interface org.apache.giraph.function.primitive.pairs.FloatIntConsumer
Applies this function to input1 and input2
apply(float, int) - Method in interface org.apache.giraph.function.primitive.pairs.FloatIntPredicate
Returns the result of applying this predicate to input.
apply(float, long) - Method in interface org.apache.giraph.function.primitive.pairs.FloatLongConsumer
Applies this function to input1 and input2
apply(float, long) - Method in interface org.apache.giraph.function.primitive.pairs.FloatLongPredicate
Returns the result of applying this predicate to input.
apply(int, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.IntBooleanConsumer
Applies this function to input1 and input2
apply(int, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.IntBooleanPredicate
Returns the result of applying this predicate to input.
apply(int, byte) - Method in interface org.apache.giraph.function.primitive.pairs.IntByteConsumer
Applies this function to input1 and input2
apply(int, byte) - Method in interface org.apache.giraph.function.primitive.pairs.IntBytePredicate
Returns the result of applying this predicate to input.
apply(int, double) - Method in interface org.apache.giraph.function.primitive.pairs.IntDoubleConsumer
Applies this function to input1 and input2
apply(int, double) - Method in interface org.apache.giraph.function.primitive.pairs.IntDoublePredicate
Returns the result of applying this predicate to input.
apply(int, float) - Method in interface org.apache.giraph.function.primitive.pairs.IntFloatConsumer
Applies this function to input1 and input2
apply(int, float) - Method in interface org.apache.giraph.function.primitive.pairs.IntFloatPredicate
Returns the result of applying this predicate to input.
apply(int, int) - Method in interface org.apache.giraph.function.primitive.pairs.IntIntConsumer
Applies this function to input1 and input2
apply(int, int) - Method in interface org.apache.giraph.function.primitive.pairs.IntIntPredicate
Returns the result of applying this predicate to input.
apply(int, long) - Method in interface org.apache.giraph.function.primitive.pairs.IntLongConsumer
Applies this function to input1 and input2
apply(int, long) - Method in interface org.apache.giraph.function.primitive.pairs.IntLongPredicate
Returns the result of applying this predicate to input.
apply(long, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.LongBooleanConsumer
Applies this function to input1 and input2
apply(long, boolean) - Method in interface org.apache.giraph.function.primitive.pairs.LongBooleanPredicate
Returns the result of applying this predicate to input.
apply(long, byte) - Method in interface org.apache.giraph.function.primitive.pairs.LongByteConsumer
Applies this function to input1 and input2
apply(long, byte) - Method in interface org.apache.giraph.function.primitive.pairs.LongBytePredicate
Returns the result of applying this predicate to input.
apply(long, double) - Method in interface org.apache.giraph.function.primitive.pairs.LongDoubleConsumer
Applies this function to input1 and input2
apply(long, double) - Method in interface org.apache.giraph.function.primitive.pairs.LongDoublePredicate
Returns the result of applying this predicate to input.
apply(long, float) - Method in interface org.apache.giraph.function.primitive.pairs.LongFloatConsumer
Applies this function to input1 and input2
apply(long, float) - Method in interface org.apache.giraph.function.primitive.pairs.LongFloatPredicate
Returns the result of applying this predicate to input.
apply(long, int) - Method in interface org.apache.giraph.function.primitive.pairs.LongIntConsumer
Applies this function to input1 and input2
apply(long, int) - Method in interface org.apache.giraph.function.primitive.pairs.LongIntPredicate
Returns the result of applying this predicate to input.
apply(long, long) - Method in interface org.apache.giraph.function.primitive.pairs.LongLongConsumer
Applies this function to input1 and input2
apply(long, long) - Method in interface org.apache.giraph.function.primitive.pairs.LongLongPredicate
Returns the result of applying this predicate to input.
apply(short) - Method in interface org.apache.giraph.function.primitive.Short2ObjFunction
Returns the result of applying this function to given input.
apply(short) - Method in interface org.apache.giraph.function.primitive.Short2ShortFunction
Returns the result of applying this function to given input.
apply(short) - Method in interface org.apache.giraph.function.primitive.ShortConsumer
Applies this function to input
apply(short) - Method in interface org.apache.giraph.function.primitive.ShortPredicate
Returns the result of applying this predicate to input.
apply(F1, F2, F3) - Method in interface org.apache.giraph.function.TripleFunction
Returns the result of applying this function to given input1, input2 and input3.
apply(Vertex<I, V, E>, T) - Method in interface org.apache.giraph.function.vertex.ConsumerWithVertex
Applies this function to vertex and input
apply(Vertex<I, V, E>, F) - Method in interface org.apache.giraph.function.vertex.FunctionWithVertex
Returns the result of applying this function to given vertex and input.
approve(IOCommand) - Method in class org.apache.giraph.ooc.policy.FixedPartitionsOracle
 
approve(IOCommand) - Method in class org.apache.giraph.ooc.policy.MemoryEstimatorOracle
 
approve(IOCommand) - Method in interface org.apache.giraph.ooc.policy.OutOfCoreOracle
Whether a command is appropriate to bring the memory to a more desired state.
approve(IOCommand) - Method in class org.apache.giraph.ooc.policy.SimpleGCMonitoringOracle
 
approve(IOCommand) - Method in class org.apache.giraph.ooc.policy.ThresholdBasedOracle
 
ARGS - Static variable in class org.apache.giraph.utils.JMap
Arguments to pass in to command
ArrayListEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.edge
OutEdges implementation backed by an ArrayList.
ArrayListEdges() - Constructor for class org.apache.giraph.edge.ArrayListEdges
 
ArrayListWritable<M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.utils
A Writable for ListArray containing instances of a class.
ArrayListWritable() - Constructor for class org.apache.giraph.utils.ArrayListWritable
Using the default constructor requires that the user implement setClass(), guaranteed to be invoked prior to instantiation in readFields()
ArrayListWritable(ArrayListWritable<M>) - Constructor for class org.apache.giraph.utils.ArrayListWritable
Constructor with another ArrayListWritable.
ArrayListWritable(Class<M>) - Constructor for class org.apache.giraph.utils.ArrayListWritable
This constructor allows setting the refClass during construction.
ArraysAsListSerializer - Class in org.apache.giraph.writable.kryo.serializers
Special serializer for Arrays.asList() as they can not be deserialized in a standard way.
ArraysAsListSerializer() - Constructor for class org.apache.giraph.writable.kryo.serializers.ArraysAsListSerializer
 
ArrayWritable<T extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.utils
A Writable for arrays containing instances of a class.
ArrayWritable() - Constructor for class org.apache.giraph.utils.ArrayWritable
Constructor
ArrayWritable(Class<T>, T[]) - Constructor for class org.apache.giraph.utils.ArrayWritable
Constructor
AskForInputSplitRequest - Class in org.apache.giraph.comm.requests
A request which workers will send to master to ask it to give them splits
AskForInputSplitRequest(InputType, int, boolean) - Constructor for class org.apache.giraph.comm.requests.AskForInputSplitRequest
Constructor
AskForInputSplitRequest() - Constructor for class org.apache.giraph.comm.requests.AskForInputSplitRequest
Constructor used for reflection only
ASYNC_MESSAGE_STORE_THREADS_COUNT - Static variable in interface org.apache.giraph.conf.GiraphConstants
Number of threads to use in async message store, 0 means we should not use async message processing
AsyncMessageStoreWrapper<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.comm.messages.queue
This class decouples message receiving and processing into separate threads thus reducing contention.
AsyncMessageStoreWrapper(MessageStore<I, M>, Iterable<Integer>, int) - Constructor for class org.apache.giraph.comm.messages.queue.AsyncMessageStoreWrapper
Constructs async wrapper around existing message store object.
AT_THE_END - Static variable in class org.apache.giraph.aggregators.TextAggregatorWriter
Signal for "write only the final values" frequency
authenticate() - Method in class org.apache.giraph.comm.netty.NettyClient
Authenticate all servers in addressChannelMap.
authenticate() - Method in class org.apache.giraph.comm.netty.NettyWorkerClient
 
authenticate() - Method in interface org.apache.giraph.comm.WorkerClient
Authenticates, as client, with another BSP worker, as server.
authenticate() - Method in class org.apache.giraph.conf.GiraphConfiguration
Use authentication? (if supported)
AUTHENTICATE - Static variable in interface org.apache.giraph.conf.GiraphConstants
Whether to use SASL with DIGEST and Hadoop Job Tokens to authenticate and authorize Netty BSP Clients to Servers.
AuthorizeServerHandler - Class in org.apache.giraph.comm.netty.handler
Authorize or deny client requests based on existence and completeness of client's SASL authentication.
AuthorizeServerHandler() - Constructor for class org.apache.giraph.comm.netty.handler.AuthorizeServerHandler
Constructor.
available() - Method in interface org.apache.giraph.utils.ExtendedDataInput
How many bytes are available?
available() - Method in class org.apache.giraph.utils.io.BigDataInput
 
available() - Method in class org.apache.giraph.utils.UnsafeArrayReads
 
available() - Method in class org.apache.giraph.utils.UnsafeReads
How many bytes are still available?
awaitChannelFuture(ChannelFuture, Progressable) - Static method in class org.apache.giraph.utils.ProgressableUtils
Wait for ChannelFuture to finish, while periodically reporting progress.
awaitChannelGroupFuture(ChannelGroupFuture, Progressable) - Static method in class org.apache.giraph.utils.ProgressableUtils
Wait for ChannelGroupFuture to finish, while periodically reporting progress.
awaitExecutorTermination(ExecutorService, Progressable, int) - Static method in class org.apache.giraph.utils.ProgressableUtils
Wait for executor tasks to terminate, while periodically reporting progress.
awaitExecutorTermination(ExecutorService, Progressable) - Static method in class org.apache.giraph.utils.ProgressableUtils
Wait for executor tasks to terminate, while periodically reporting progress.
awaitSemaphorePermits(Semaphore, int, Progressable) - Static method in class org.apache.giraph.utils.ProgressableUtils
Wait to acquire enough permits from Semaphore, while periodically reporting progress.
awaitTermination(long, TimeUnit) - Method in class com.yammer.metrics.core.NoOpExecutorService
 
awaitTerminationFuture(EventExecutorGroup, Progressable) - Static method in class org.apache.giraph.utils.ProgressableUtils
Wait for executorgroup to terminate, while periodically reporting progress

B

balancePartitionsAcrossWorkers(Configuration, Collection<PartitionOwner>, Collection<PartitionStats>, Collection<WorkerInfo>) - Static method in class org.apache.giraph.partition.PartitionBalancer
Balance the partitions with an algorithm based on a value.
BASE_DIR - Static variable in class org.apache.giraph.bsp.BspService
Base ZooKeeper directory
BASE_ZNODE_KEY - Static variable in interface org.apache.giraph.conf.GiraphConstants
Base ZNode for Giraph's state in the ZooKeeper cluster.
basePath - Variable in class org.apache.giraph.bsp.BspService
Path to the job's root
Basic2ObjectMap<K,V> - Class in org.apache.giraph.types.ops.collections
Basic2ObjectMap with only basic set of operations.
Basic2ObjectMap() - Constructor for class org.apache.giraph.types.ops.collections.Basic2ObjectMap
 
Basic2ObjectMap.BasicInt2ObjectOpenHashMap<V> - Class in org.apache.giraph.types.ops.collections
IntWritable implementation of Basic2ObjectMap
Basic2ObjectMap.BasicLong2ObjectOpenHashMap<V> - Class in org.apache.giraph.types.ops.collections
LongWritable implementation of Basic2ObjectMap
Basic2ObjectMap.BasicObject2ObjectOpenHashMap<K extends org.apache.hadoop.io.Writable,V> - Class in org.apache.giraph.types.ops.collections
Writable implementation of Basic2ObjectMap
Basic2ObjectMap.ReusableIterator<Iter extends Iterator<?>> - Class in org.apache.giraph.types.ops.collections
Iterator that reuses key object.
BasicAggregator<A extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.aggregators
Abstract class for Aggregator.
BasicAggregator() - Constructor for class org.apache.giraph.aggregators.BasicAggregator
Default constructor.
BasicAggregator(A) - Constructor for class org.apache.giraph.aggregators.BasicAggregator
Constructor
BasicCollectionsUtils - Class in org.apache.giraph.types.ops.collections
Utility functions for constructing basic collections
BasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.graph
Computation in which both incoming and outgoing message types are the same.
BasicComputation() - Constructor for class org.apache.giraph.graph.BasicComputation
 
BasicInputSplitsMasterOrganizer - Class in org.apache.giraph.master.input
Input splits organizer for vertex and edge input splits on master, which doesn't use locality information
BasicInputSplitsMasterOrganizer(List<byte[]>) - Constructor for class org.apache.giraph.master.input.BasicInputSplitsMasterOrganizer
Constructor
BasicInt2ObjectOpenHashMap(WritableWriter<V>) - Constructor for class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicInt2ObjectOpenHashMap
Constructor
BasicInt2ObjectOpenHashMap(int, WritableWriter<V>) - Constructor for class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicInt2ObjectOpenHashMap
Constructor
BasicIntOpenHashSet() - Constructor for class org.apache.giraph.types.ops.collections.BasicSet.BasicIntOpenHashSet
Constructor
BasicIntOpenHashSet(long) - Constructor for class org.apache.giraph.types.ops.collections.BasicSet.BasicIntOpenHashSet
Constructor
BasicLong2ObjectOpenHashMap(WritableWriter<V>) - Constructor for class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicLong2ObjectOpenHashMap
Constructor
BasicLong2ObjectOpenHashMap(int, WritableWriter<V>) - Constructor for class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicLong2ObjectOpenHashMap
Constructor
BasicLongOpenHashSet() - Constructor for class org.apache.giraph.types.ops.collections.BasicSet.BasicLongOpenHashSet
Constructor
BasicLongOpenHashSet(long) - Constructor for class org.apache.giraph.types.ops.collections.BasicSet.BasicLongOpenHashSet
Constructor
BasicObject2ObjectOpenHashMap(WritableWriter<K>, WritableWriter<V>) - Constructor for class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicObject2ObjectOpenHashMap
Constructor
BasicObject2ObjectOpenHashMap(int, WritableWriter<K>, WritableWriter<V>) - Constructor for class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicObject2ObjectOpenHashMap
Constructor
BasicPartition<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.partition
Basic partition class for other partitions to extend.
BasicPartition() - Constructor for class org.apache.giraph.partition.BasicPartition
 
BasicPartitionOwner - Class in org.apache.giraph.partition
Basic partition owner, can be subclassed for more complicated partition owner implementations.
BasicPartitionOwner() - Constructor for class org.apache.giraph.partition.BasicPartitionOwner
Default constructor.
BasicPartitionOwner(int, WorkerInfo) - Constructor for class org.apache.giraph.partition.BasicPartitionOwner
Constructor with partition id and worker info.
BasicPartitionOwner(int, WorkerInfo, WorkerInfo, String) - Constructor for class org.apache.giraph.partition.BasicPartitionOwner
Constructor with partition id and worker info.
BasicSet<T> - Interface in org.apache.giraph.types.ops.collections
BasicSet with only basic set of operations.
BasicSet.BasicIntOpenHashSet - Class in org.apache.giraph.types.ops.collections
IntWritable implementation of BasicSet
BasicSet.BasicLongOpenHashSet - Class in org.apache.giraph.types.ops.collections
LongWritable implementation of BasicSet
BasicVertexValueReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io
Abstract base class for VertexValueReader.
BasicVertexValueReader() - Constructor for class org.apache.giraph.io.BasicVertexValueReader
 
becomeMaster() - Method in interface org.apache.giraph.bsp.CentralizedServiceMaster
Become the master.
becomeMaster() - Method in class org.apache.giraph.master.BspServiceMaster
 
BenchmarkOption - Class in org.apache.giraph.benchmark
Command line options for benchmarks
BenchmarkOption(String, String, boolean, String) - Constructor for class org.apache.giraph.benchmark.BenchmarkOption
Constructor for option which is not required
BenchmarkOption(String, String, boolean, String, String) - Constructor for class org.apache.giraph.benchmark.BenchmarkOption
Constructor for option which is not required
BigDataInput - Class in org.apache.giraph.utils.io
Implementations of ExtendedDataInput are limited because they can only handle up to 1GB of data.
BigDataInput(BigDataOutput) - Constructor for class org.apache.giraph.utils.io.BigDataInput
Constructor
BigDataInputOutput - Class in org.apache.giraph.utils.io
DataInputOutput which uses BigDataInput and BigDataOutput to support larger than allowed array size streams.
BigDataInputOutput(ImmutableClassesGiraphConfiguration) - Constructor for class org.apache.giraph.utils.io.BigDataInputOutput
Constructor
BigDataOutput - Class in org.apache.giraph.utils.io
Implementations of ExtendedDataOutput are limited because they can only handle up to 1GB of data.
BigDataOutput(ImmutableClassesGiraphConfiguration) - Constructor for class org.apache.giraph.utils.io.BigDataOutput
Constructor
BigDataOutput(int, ImmutableClassesGiraphConfiguration) - Constructor for class org.apache.giraph.utils.io.BigDataOutput
Constructor
BlockingElementsSet<T> - Class in org.apache.giraph.utils
Keeps a set of elements, and allows for waiting on certain number of elements to become available.
BlockingElementsSet() - Constructor for class org.apache.giraph.utils.BlockingElementsSet
 
Boolean2BooleanFunction - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (boolean) -> boolean
Boolean2ObjFunction<T> - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (boolean) -> T
BOOLEAN_BOOLEAN_WRITABLE - Static variable in class org.apache.giraph.types.JavaWritablePair
Boolean,BooleanWritable
BooleanAndAggregator - Class in org.apache.giraph.aggregators
Aggregator for calculating the AND function over boolean values.
BooleanAndAggregator() - Constructor for class org.apache.giraph.aggregators.BooleanAndAggregator
 
BooleanBooleanConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, boolean) -> void
BooleanBooleanPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, boolean) -> boolean
BooleanByteConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, byte) -> void
BooleanBytePredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, byte) -> boolean
BooleanConfOption - Class in org.apache.giraph.conf
Boolean configuration option
BooleanConfOption(String, boolean, String) - Constructor for class org.apache.giraph.conf.BooleanConfOption
Constructor
BooleanConsumer - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (boolean) -> void
BooleanDoubleConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, double) -> void
BooleanDoublePredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, double) -> boolean
BooleanFloatConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, float) -> void
BooleanFloatPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, float) -> boolean
BooleanIntConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, int) -> void
BooleanIntPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, int) -> boolean
BooleanLongConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, long) -> void
BooleanLongPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (boolean, long) -> boolean
BooleanOrAggregator - Class in org.apache.giraph.aggregators
Aggregator for calculating the OR function over boolean values.
BooleanOrAggregator() - Constructor for class org.apache.giraph.aggregators.BooleanOrAggregator
 
BooleanOverwriteAggregator - Class in org.apache.giraph.aggregators
Aggregator that stores a value that is overwritten once another value is aggregated.
BooleanOverwriteAggregator() - Constructor for class org.apache.giraph.aggregators.BooleanOverwriteAggregator
 
BooleanPredicate - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (boolean) -> boolean
BooleanToBooleanWritableWrapper - Class in org.apache.giraph.types
Converts Booleans to BooleanWritables
BooleanToBooleanWritableWrapper() - Constructor for class org.apache.giraph.types.BooleanToBooleanWritableWrapper
 
BooleanTypeOps - Enum in org.apache.giraph.types.ops
TypeOps implementation for working with BooleanWritable type
BooleanWritableToBooleanUnwrapper - Class in org.apache.giraph.types
Converts BooleanWritables to Booleans.
BooleanWritableToBooleanUnwrapper() - Constructor for class org.apache.giraph.types.BooleanWritableToBooleanUnwrapper
 
Boxed<T> - Interface in org.apache.giraph.writable.kryo
Boxed interface
broadcast(String, Writable) - Method in class org.apache.giraph.master.MasterAggregatorHandler
 
broadcast(String, Writable) - Method in class org.apache.giraph.master.MasterCompute
 
broadcast(String, Writable) - Method in class org.apache.giraph.master.MasterGlobalCommHandler
 
broadcast(String, Writable) - Method in interface org.apache.giraph.master.MasterGlobalCommUsageAggregators
Broadcast given value to all workers for next computation.
BspEvent - Interface in org.apache.giraph.zk
Synchronize on waiting for an event to have happened.
BspInputFormat - Class in org.apache.giraph.bsp
This InputFormat supports the BSP model by ensuring that the user specifies how many splits (number of mappers) should be started simultaneously.
BspInputFormat() - Constructor for class org.apache.giraph.bsp.BspInputFormat
 
BspInputSplit - Class in org.apache.giraph.bsp
This InputSplit will not give any ordering or location data.
BspInputSplit() - Constructor for class org.apache.giraph.bsp.BspInputSplit
Reflection constructor.
BspInputSplit(int, int) - Constructor for class org.apache.giraph.bsp.BspInputSplit
Constructor used by BspInputFormat.
BspOutputFormat - Class in org.apache.giraph.bsp
This is for internal use only.
BspOutputFormat() - Constructor for class org.apache.giraph.bsp.BspOutputFormat
 
BspRecordWriter - Class in org.apache.giraph.bsp
Used by BspOutputFormat since some versions of Hadoop require that a RecordWriter is returned from getRecordWriter.
BspRecordWriter() - Constructor for class org.apache.giraph.bsp.BspRecordWriter
 
BspService<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.bsp
Zookeeper-based implementation of CentralizedService.
BspService(Mapper<?, ?, ?, ?>.Context, GraphTaskManager<I, V, E>) - Constructor for class org.apache.giraph.bsp.BspService
Constructor.
BspServiceMaster<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.master
ZooKeeper-based implementation of CentralizedServiceMaster.
BspServiceMaster(Mapper<?, ?, ?, ?>.Context, GraphTaskManager<I, V, E>) - Constructor for class org.apache.giraph.master.BspServiceMaster
Constructor for setting up the master.
BspServiceWorker<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.worker
ZooKeeper-based implementation of CentralizedServiceWorker.
BspServiceWorker(Mapper<?, ?, ?, ?>.Context, GraphTaskManager<I, V, E>) - Constructor for class org.apache.giraph.worker.BspServiceWorker
Constructor for setting up the worker.
BulkConfigurator - Interface in org.apache.giraph.conf
Function that modifies configuration.
Byte2ByteFunction - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (byte) -> byte
Byte2ObjFunction<T> - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (byte) -> T
BYTE_BYTE_WRITABLE - Static variable in class org.apache.giraph.types.JavaWritablePair
Byte,ByteWritable
BYTE_INT_WRITABLE - Static variable in class org.apache.giraph.types.JavaWritablePair
Byte,IntWritable
BYTE_LONG_WRITABLE - Static variable in class org.apache.giraph.types.JavaWritablePair
Byte,LongWritable
ByteArrayEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.edge
OutEdges implementation backed by a byte array.
ByteArrayEdges() - Constructor for class org.apache.giraph.edge.ByteArrayEdges
 
ByteArrayMessagesPerVertexStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.comm.messages
Implementation of SimpleMessageStore where multiple messages are stored per vertex as byte backed datastructures.
ByteArrayMessagesPerVertexStore(MessageValueFactory<M>, PartitionSplitInfo<I>, ImmutableClassesGiraphConfiguration<I, ?, ?>) - Constructor for class org.apache.giraph.comm.messages.ByteArrayMessagesPerVertexStore
Constructor
ByteArrayMessagesPerVertexStore.Factory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.comm.messages
ByteArrayOneMessageToManyIds<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.utils
Stores a message and a list of target vertex ids.
ByteArrayOneMessageToManyIds(MessageValueFactory<M>) - Constructor for class org.apache.giraph.utils.ByteArrayOneMessageToManyIds
Constructor.
ByteArrayPartition<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.partition
Byte array based partition.
ByteArrayPartition() - Constructor for class org.apache.giraph.partition.ByteArrayPartition
Constructor for reflection.
ByteArrayRequest - Class in org.apache.giraph.comm.requests
Abstract request which has a byte array as its data
ByteArrayVertexIdData<I extends org.apache.hadoop.io.WritableComparable,T> - Class in org.apache.giraph.utils
Stores pairs of vertex id and generic data in a single byte array
ByteArrayVertexIdData() - Constructor for class org.apache.giraph.utils.ByteArrayVertexIdData
 
ByteArrayVertexIdEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.utils
Stores vertex id and edge pairs in a single byte array.
ByteArrayVertexIdEdges() - Constructor for class org.apache.giraph.utils.ByteArrayVertexIdEdges
 
ByteArrayVertexIdMessages<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.utils
Stores vertex id and message pairs in a single byte array.
ByteArrayVertexIdMessages(MessageValueFactory<M>) - Constructor for class org.apache.giraph.utils.ByteArrayVertexIdMessages
Constructor
ByteArrayWithSenderTaskIdRequest - Class in org.apache.giraph.comm.requests
Abstract request which has a byte array and task id of the sender as its data
ByteArrayWithSenderTaskIdRequest(byte[], int) - Constructor for class org.apache.giraph.comm.requests.ByteArrayWithSenderTaskIdRequest
Constructor
ByteArrayWithSenderTaskIdRequest() - Constructor for class org.apache.giraph.comm.requests.ByteArrayWithSenderTaskIdRequest
Default constructor
byteBookkeeper(ByteBuf) - Method in class org.apache.giraph.comm.netty.ByteCounterDelegate
Updates properties based on bytes sent / received
ByteBooleanConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, boolean) -> void
ByteBooleanPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, boolean) -> boolean
ByteByteConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, byte) -> void
ByteBytePredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, byte) -> boolean
ByteConsumer - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (byte) -> void
ByteCounter - Interface in org.apache.giraph.comm.netty
ByteCounter interface
ByteCounterDelegate - Class in org.apache.giraph.comm.netty
Delegate Object to help keep track of the bytes processed and provide some metrics when desired as part of the Netty Channel stack.
ByteCounterDelegate(boolean) - Constructor for class org.apache.giraph.comm.netty.ByteCounterDelegate
Constructor to specify if delegate is created by InBound/ Outbound counter
ByteDoubleConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, double) -> void
ByteDoublePredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, double) -> boolean
ByteFloatConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, float) -> void
ByteFloatPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, float) -> boolean
ByteIntConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, int) -> void
ByteIntPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, int) -> boolean
ByteLongConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, long) -> void
ByteLongPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (byte, long) -> boolean
BytePredicate - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (byte) -> boolean
BYTES_LOAD_FROM_DISK - Static variable in class org.apache.giraph.ooc.OutOfCoreIOCallable
Name of Metric for number of bytes read from disk
BYTES_STORE_TO_DISK - Static variable in class org.apache.giraph.ooc.OutOfCoreIOCallable
Name of Metric for number of bytes written to disk
bytesTransferred() - Method in class org.apache.giraph.ooc.command.IOCommand
Get the number of bytes transferred (loaded/stored from/to disk).
ByteStructIterable<T extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.utils
This iterable is designed to deserialize a byte array on the fly to provide new copies of writable objects when desired.
ByteStructIterable(Factory<? extends ExtendedDataInput>) - Constructor for class org.apache.giraph.utils.ByteStructIterable
Constructor
ByteStructIterator<T extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.utils
This iterator is designed to deserialize a byte array on the fly to provide new copies of writable objects when desired.
ByteStructIterator(ExtendedDataInput) - Constructor for class org.apache.giraph.utils.ByteStructIterator
Wrap ExtendedDataInput in ByteArrayIterator
ByteStructVertexIdDataIterator<I extends org.apache.hadoop.io.WritableComparable,T> - Class in org.apache.giraph.utils
Special iterator that reuses vertex ids and data objects so that the lifetime of the object is only until next() is called.
ByteStructVertexIdDataIterator(AbstractVertexIdData<I, T>) - Constructor for class org.apache.giraph.utils.ByteStructVertexIdDataIterator
Constructor
ByteStructVertexIdEdgeIterator<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.utils
Special iterator that reuses vertex ids and edge objects so that the lifetime of the object is only until next() is called.
ByteStructVertexIdEdgeIterator(AbstractVertexIdData<I, Edge<I, E>>) - Constructor for class org.apache.giraph.utils.ByteStructVertexIdEdgeIterator
Constructor
ByteStructVertexIdIterator<I extends org.apache.hadoop.io.WritableComparable> - Class in org.apache.giraph.utils
Common implementation for VertexIdEdgeIterator, VertexIdMessageIterator and VertexIdMessageBytesIterator.
ByteStructVertexIdIterator(ExtendedDataOutput, ImmutableClassesGiraphConfiguration<I, ?, ?>) - Constructor for class org.apache.giraph.utils.ByteStructVertexIdIterator
Constructor.
ByteStructVertexIdMessageBytesIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.utils
Special iterator that reuses vertex ids and messages bytes so that the lifetime of the object is only until next() is called.
ByteStructVertexIdMessageBytesIterator(AbstractVertexIdData<I, M>) - Constructor for class org.apache.giraph.utils.ByteStructVertexIdMessageBytesIterator
Constructor with vertexIdData
ByteStructVertexIdMessageIterator<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.utils
Special iterator that reuses vertex ids and message objects so that the lifetime of the object is only until next() is called.
ByteStructVertexIdMessageIterator(AbstractVertexIdData<I, M>) - Constructor for class org.apache.giraph.utils.ByteStructVertexIdMessageIterator
Constructor with vertexIdData
ByteToByteWritableWrapper - Class in org.apache.giraph.types
Converts Bytes to ByteWritables
ByteToByteWritableWrapper() - Constructor for class org.apache.giraph.types.ByteToByteWritableWrapper
 
ByteToIntWritableWrapper - Class in org.apache.giraph.types
Converts Bytes to IntWritables
ByteToIntWritableWrapper() - Constructor for class org.apache.giraph.types.ByteToIntWritableWrapper
 
ByteToLongWritableWrapper - Class in org.apache.giraph.types
Converts Bytes to LongWritables
ByteToLongWritableWrapper() - Constructor for class org.apache.giraph.types.ByteToLongWritableWrapper
 
ByteTypeOps - Enum in org.apache.giraph.types.ops
TypeOps implementation for working with ByteWritable type
ByteUtils - Class in org.apache.giraph.utils
Utilities class for byte operations and constants
ByteValueVertex<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.graph
Special version of vertex that holds the value in raw byte form to save memory.
ByteValueVertex() - Constructor for class org.apache.giraph.graph.ByteValueVertex
 
ByteWritableToByteUnwrapper - Class in org.apache.giraph.types
Converts ByteWritables to Bytes
ByteWritableToByteUnwrapper() - Constructor for class org.apache.giraph.types.ByteWritableToByteUnwrapper
 
ByteWritableToIntUnwrapper - Class in org.apache.giraph.types
Converts Integers to ByteWritables
ByteWritableToIntUnwrapper() - Constructor for class org.apache.giraph.types.ByteWritableToIntUnwrapper
 
ByteWritableToLongUnwrapper - Class in org.apache.giraph.types
Converts ByteWritables to Longs
ByteWritableToLongUnwrapper() - Constructor for class org.apache.giraph.types.ByteWritableToLongUnwrapper
 
ByteWritableToShortUnwrapper - Class in org.apache.giraph.types
Converts ByteWritables to Shorts
ByteWritableToShortUnwrapper() - Constructor for class org.apache.giraph.types.ByteWritableToShortUnwrapper
 

C

calculateResponse(AckSignalFlag, int) - Method in class org.apache.giraph.comm.flow_control.CreditBasedFlowControl
 
calculateResponse(AckSignalFlag, int) - Method in interface org.apache.giraph.comm.flow_control.FlowControl
Calculate/Build the response to piggyback with acknowledgement
calculateResponse(AckSignalFlag, int) - Method in class org.apache.giraph.comm.flow_control.NoOpFlowControl
 
calculateResponse(AckSignalFlag, int) - Method in class org.apache.giraph.comm.flow_control.StaticFlowControl
 
call() - Method in class org.apache.giraph.graph.ComputeCallable
 
call() - Method in class org.apache.giraph.ooc.OutOfCoreIOCallable
 
call() - Method in class org.apache.giraph.utils.LogStacktraceCallable
 
call() - Method in class org.apache.giraph.worker.InputSplitsCallable
 
CallableFactory<R> - Interface in org.apache.giraph.utils
Factory for creating Callables
callGc() - Method in class org.apache.giraph.worker.MemoryObserver
Manually call gc, if enough time from last call has passed
canFinishInTime(GiraphConfiguration, Job, CombinedWorkerProgress) - Method in class org.apache.giraph.job.DefaultJobProgressTrackerService
Determine if the job will finish in allotted time
capacity() - Method in class org.apache.giraph.types.ops.collections.array.WBooleanArrayList
 
capacity() - Method in class org.apache.giraph.types.ops.collections.array.WByteArrayList
 
capacity() - Method in class org.apache.giraph.types.ops.collections.array.WDoubleArrayList
 
capacity() - Method in class org.apache.giraph.types.ops.collections.array.WFloatArrayList
 
capacity() - Method in class org.apache.giraph.types.ops.collections.array.WIntArrayList
 
capacity() - Method in class org.apache.giraph.types.ops.collections.array.WLongArrayList
 
capacity() - Method in interface org.apache.giraph.types.ops.collections.WCollection
Capacity of currently allocated memory
CAPACITY_OF_DATAOUT_IN_BUFFER - Static variable in class org.apache.giraph.utils.ExtendedByteArrayOutputBuffer
This option sets the capacity of an ExtendedDataOutput instance created in ExtendedByteArrayOutputBuffer
cardinality() - Method in class org.apache.giraph.utils.IncreasingBitSet
Get the number of set bits
castToConsumer() - Method in class org.apache.giraph.function.ObjectTransfer
To be called when needing to pass it as a Consumer - making it obvious that K, V and E on consumer side can be any types, and to make code work without compile errors/warnings.
castToSupplier() - Method in class org.apache.giraph.function.ObjectTransfer
To be called when needing to pass it as a Supplier - making it obvious that K, V and E on supplier side can be any types, and to make code work without compile errors/warnings.
CentralizedService<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.bsp
Basic service interface shared by both CentralizedServiceMaster and CentralizedServiceWorker.
CentralizedServiceMaster<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.bsp
At most, there will be one active master at a time, but many threads can be trying to be the active master.
CentralizedServiceWorker<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.bsp
All workers should have access to this centralized service to execute the following methods.
CHANNEL_SASL_NETTY_SERVERS - Static variable in class org.apache.giraph.comm.netty.NettyServer
Used to authenticate with netty clients
channelActive(ChannelHandlerContext) - Method in class org.apache.giraph.comm.netty.handler.RequestServerHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.apache.giraph.comm.netty.handler.RequestServerHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.apache.giraph.comm.netty.handler.ResponseClientHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.giraph.comm.netty.handler.AuthorizeServerHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.giraph.comm.netty.handler.RequestDecoder
 
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.giraph.comm.netty.handler.RequestServerHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.giraph.comm.netty.handler.ResponseClientHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.giraph.comm.netty.handler.SaslClientHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.giraph.comm.netty.handler.SaslServerHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.apache.giraph.comm.netty.InboundByteCounter
 
ChannelRotater - Class in org.apache.giraph.comm.netty
Maintains multiple channels and rotates between them.
ChannelRotater(Integer, InetSocketAddress) - Constructor for class org.apache.giraph.comm.netty.ChannelRotater
Constructor
CHANNELS_PER_SERVER - Static variable in interface org.apache.giraph.conf.GiraphConstants
Number of channels used per server
CHECK_IN_INTERVAL - Static variable in class org.apache.giraph.ooc.OutOfCoreEngine
Number of 'units of processing' after which an active thread should check-in with the out-of-core engine in order to re-claim its permission to stay active.
CHECK_MEMORY_INTERVAL - Static variable in class org.apache.giraph.ooc.policy.MemoryEstimatorOracle
Memory check interval in msec
CHECK_MEMORY_INTERVAL - Static variable in class org.apache.giraph.ooc.policy.ThresholdBasedOracle
The interval at which memory observer thread wakes up.
checkConfiguration(ImmutableClassesGiraphConfiguration<I, V, E>) - Method in interface org.apache.giraph.factories.ComputationFactory
Check that the Configuration passed in is setup correctly to run a job.
checkConfiguration(ImmutableClassesGiraphConfiguration<I, V, E>) - Method in class org.apache.giraph.factories.DefaultComputationFactory
 
checkConfiguration(ImmutableClassesGiraphConfiguration) - Method in class org.apache.giraph.jython.factories.JythonComputationFactory
 
CHECKER_IF_WORKER_SHOULD_FAIL_AFTER_EXCEPTION_CLASS - Static variable in class org.apache.giraph.graph.GraphTaskManager
Class which checks if an exception on some thread should cause worker to fail
checkIfWorkerShouldFail(Thread, Throwable) - Method in interface org.apache.giraph.graph.GraphTaskManager.CheckerIfWorkerShouldFailAfterException
Check if worker should fail after a thread gets an exception
checkIfWorkerShouldFail(Thread, Throwable) - Method in class org.apache.giraph.graph.GraphTaskManager.FailWithEveryExceptionOccurred
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.GeneratedVertexInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.multi.MultiEdgeInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.multi.MultiMappingInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.multi.MultiVertexInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.PseudoRandomEdgeInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.PseudoRandomIntNullVertexInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.PseudoRandomVertexInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.SequenceFileVertexInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.TextEdgeInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.TextVertexInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.TextVertexValueInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.formats.WattsStrogatzVertexInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.GiraphInputFormat
Check that input is valid.
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.internal.WrappedEdgeInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.internal.WrappedMappingInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.internal.WrappedVertexInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.utils.InMemoryVertexInputFormat
 
checkOption(CommandLine, Logger) - Method in class org.apache.giraph.benchmark.BenchmarkOption
If option is not required just return true.
checkOutputSpecs(JobContext) - Method in class org.apache.giraph.bsp.BspOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.giraph.io.formats.InMemoryVertexOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.giraph.io.formats.SequenceFileVertexOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.giraph.io.formats.TextEdgeOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.giraph.io.formats.TextVertexOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.giraph.io.internal.WrappedEdgeOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.giraph.io.internal.WrappedVertexOutputFormat
 
checkOutputSpecs(JobContext) - Method in class org.apache.giraph.io.OutputFormat
Check for validity of the output-specification for the job.
CHECKPOINT_COMPRESSION_CODEC - Static variable in interface org.apache.giraph.conf.GiraphConstants
Compression algorithm to be used for checkpointing.
CHECKPOINT_DATA_POSTFIX - Static variable in class org.apache.giraph.utils.CheckpointingUtils
If at the end of a checkpoint file, indicates that we store WorkerContext and aggregator handler data.
CHECKPOINT_DIRECTORY - Static variable in interface org.apache.giraph.conf.GiraphConstants
This directory has/stores the available checkpoint files in HDFS.
CHECKPOINT_FINALIZED_POSTFIX - Static variable in class org.apache.giraph.utils.CheckpointingUtils
If at the end of a checkpoint file, indicates the stitched checkpoint file prefixes.
CHECKPOINT_FREQUENCY - Static variable in interface org.apache.giraph.conf.GiraphConstants
How often to checkpoint (i.e.
CHECKPOINT_METADATA_POSTFIX - Static variable in class org.apache.giraph.utils.CheckpointingUtils
If at the end of a checkpoint file, indicates metadata
CHECKPOINT_SUPPORTED_CHECKER - Static variable in interface org.apache.giraph.conf.GiraphConstants
Defines if and when checkpointing is supported by this job.
CHECKPOINT_VALID_POSTFIX - Static variable in class org.apache.giraph.utils.CheckpointingUtils
If at the end of a checkpoint file, indicates metadata and data is valid for the same filenames without .valid
CHECKPOINT_VERTICES_POSTFIX - Static variable in class org.apache.giraph.utils.CheckpointingUtils
If at the end of a checkpoint file, indicates vertices, edges, messages, etc.
checkpointBasePath - Variable in class org.apache.giraph.bsp.BspService
Path to the checkpoint's root (including job id)
CheckpointingUtils - Class in org.apache.giraph.utils
Holds useful functions to get checkpoint paths in hdfs.
CheckpointStatus - Enum in org.apache.giraph.bsp.checkpoints
Enum represents possible checkpoint state.
CheckpointSupportedChecker - Interface in org.apache.giraph.bsp.checkpoints
To prevent accidental checkpointing of non-checkpointable app you may provide implementation of this interface.
checkWorkers() - Method in interface org.apache.giraph.bsp.CentralizedServiceMaster
Check all the WorkerInfo objects to ensure that a minimum number of good workers exists out of the total that have reported.
checkWorkers() - Method in class org.apache.giraph.master.BspServiceMaster
 
ClassConfOption<C> - Class in org.apache.giraph.conf
Class configuration option
CLEANED_UP_DIR - Static variable in class org.apache.giraph.bsp.BspService
Denotes which workers have been cleaned up
cleanedUpPath - Variable in class org.apache.giraph.bsp.BspService
Path to the cleaned up notifications
cleanup(SuperstepState) - Method in interface org.apache.giraph.bsp.CentralizedServiceMaster
Clean up the service (no calls may be issued after this)
cleanup(FinishedSuperstepStats) - Method in interface org.apache.giraph.bsp.CentralizedServiceWorker
Clean up the service (no calls may be issued after this)
cleanup(Mapper<Object, Object, Object, Object>.Context) - Method in class org.apache.giraph.graph.GraphMapper
 
cleanup() - Method in class org.apache.giraph.graph.GraphTaskManager
Called by owner of this GraphTaskManager object on each compute node
cleanup() - Method in interface org.apache.giraph.graph.JobProgressTrackerClient
Close the connections if any
cleanup() - Method in class org.apache.giraph.graph.JobProgressTrackerClientNoOp
 
cleanup() - Method in class org.apache.giraph.graph.RetryableJobProgressTrackerClient
 
cleanup(SuperstepState) - Method in class org.apache.giraph.master.BspServiceMaster
 
cleanup(FinishedSuperstepStats) - Method in class org.apache.giraph.worker.BspServiceWorker
 
cleanup() - Method in class org.apache.giraph.zk.InProcessZooKeeperRunner
 
cleanup() - Method in class org.apache.giraph.zk.ZooKeeperManager
Do necessary cleanup in zookeeper wrapper.
cleanup() - Method in interface org.apache.giraph.zk.ZooKeeperRunner
Does necessary cleanup after zookeeper job is complete.
CLEANUP_CHECKPOINTS_AFTER_SUCCESS - Static variable in interface org.apache.giraph.conf.GiraphConstants
Delete checkpoints after a successful job run?
cleanupOnExit() - Method in class org.apache.giraph.zk.ZooKeeperManager
Mark files zookeeper creates in hdfs to be deleted on exit.
clear() - Method in class com.yammer.metrics.core.NoOpCounter
 
clear() - Method in class com.yammer.metrics.core.NoOpHistogram
 
clear() - Method in class com.yammer.metrics.core.NoOpTimer
 
clear() - Method in class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseVector
Clear the contents of the vector.
clear() - Method in class org.apache.giraph.aggregators.matrix.sparse.FloatSparseVector
Clear the contents of the vector.
clear() - Method in class org.apache.giraph.aggregators.matrix.sparse.IntSparseVector
Clear the contents of the vector.
clear() - Method in class org.apache.giraph.aggregators.matrix.sparse.LongSparseVector
Clear the contents of the vector.
clear() - Method in class org.apache.giraph.types.heaps.FixedCapacityIntByteMinHeap
Clear the heap
clear() - Method in class org.apache.giraph.types.heaps.FixedCapacityIntDoubleMinHeap
Clear the heap
clear() - Method in class org.apache.giraph.types.heaps.FixedCapacityIntFloatMinHeap
Clear the heap
clear() - Method in class org.apache.giraph.types.heaps.FixedCapacityIntIntMinHeap
Clear the heap
clear() - Method in class org.apache.giraph.types.heaps.FixedCapacityIntLongMinHeap
Clear the heap
clear() - Method in class org.apache.giraph.types.heaps.FixedCapacityLongByteMinHeap
Clear the heap
clear() - Method in class org.apache.giraph.types.heaps.FixedCapacityLongDoubleMinHeap
Clear the heap
clear() - Method in class org.apache.giraph.types.heaps.FixedCapacityLongFloatMinHeap
Clear the heap
clear() - Method in class org.apache.giraph.types.heaps.FixedCapacityLongIntMinHeap
Clear the heap
clear() - Method in class org.apache.giraph.types.heaps.FixedCapacityLongLongMinHeap
Clear the heap
clear() - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicInt2ObjectOpenHashMap
 
clear() - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicLong2ObjectOpenHashMap
 
clear() - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicObject2ObjectOpenHashMap
 
clear() - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap
Removes all of the elements from this list.
clear() - Method in class org.apache.giraph.types.ops.collections.BasicSet.BasicIntOpenHashSet
 
clear() - Method in class org.apache.giraph.types.ops.collections.BasicSet.BasicLongOpenHashSet
 
clear() - Method in interface org.apache.giraph.types.ops.collections.BasicSet
Removes all of the elements from this list.
clear() - Method in interface org.apache.giraph.types.ops.collections.WCollection
Removes all of the elements from this
clear() - Method in class org.apache.giraph.utils.AbstractVertexIdData
 
clear() - Method in class org.apache.giraph.utils.TestGraph
Clear all data
clear() - Method in interface org.apache.giraph.utils.VertexIdData
Clear the list.
clearAll() - Method in interface org.apache.giraph.comm.messages.MessageStore
Clears all resources used by this store.
clearAll() - Method in class org.apache.giraph.comm.messages.primitives.IdByteArrayMessageStore
 
clearAll() - Method in class org.apache.giraph.comm.messages.primitives.IdOneMessagePerVertexStore
 
clearAll() - Method in class org.apache.giraph.comm.messages.primitives.IntFloatMessageStore
 
clearAll() - Method in class org.apache.giraph.comm.messages.primitives.long_id.LongAbstractStore
 
clearAll() - Method in class org.apache.giraph.comm.messages.primitives.LongDoubleMessageStore
 
clearAll() - Method in class org.apache.giraph.comm.messages.queue.AsyncMessageStoreWrapper
 
clearAll() - Method in class org.apache.giraph.comm.messages.SimpleMessageStore
 
clearAll() - Method in class org.apache.giraph.ooc.data.DiskBackedMessageStore
 
clearCounters() - Method in class org.apache.giraph.graph.GiraphTransferRegulator
Clear storage to reset for reading new InputSplit
clearPartition(int) - Method in interface org.apache.giraph.comm.messages.MessageStore
Clears messages for a partition.
clearPartition(int) - Method in class org.apache.giraph.comm.messages.primitives.IdByteArrayMessageStore
 
clearPartition(int) - Method in class org.apache.giraph.comm.messages.primitives.IdOneMessagePerVertexStore
 
clearPartition(int) - Method in class org.apache.giraph.comm.messages.primitives.IntFloatMessageStore
 
clearPartition(int) - Method in class org.apache.giraph.comm.messages.primitives.long_id.LongAbstractStore
 
clearPartition(int) - Method in class org.apache.giraph.comm.messages.primitives.LongDoubleMessageStore
 
clearPartition(int) - Method in class org.apache.giraph.comm.messages.queue.AsyncMessageStoreWrapper
 
clearPartition(int) - Method in class org.apache.giraph.comm.messages.SimpleMessageStore
 
clearPartition(int) - Method in class org.apache.giraph.ooc.data.DiskBackedMessageStore
 
clearVertexMessages(I) - Method in interface org.apache.giraph.comm.messages.MessageStore
Clears messages for a vertex.
clearVertexMessages(I) - Method in class org.apache.giraph.comm.messages.primitives.IdByteArrayMessageStore
 
clearVertexMessages(I) - Method in class org.apache.giraph.comm.messages.primitives.IdOneMessagePerVertexStore
 
clearVertexMessages(IntWritable) - Method in class org.apache.giraph.comm.messages.primitives.IntFloatMessageStore
 
clearVertexMessages(LongWritable) - Method in class org.apache.giraph.comm.messages.primitives.long_id.LongAbstractStore
 
clearVertexMessages(LongWritable) - Method in class org.apache.giraph.comm.messages.primitives.LongDoubleMessageStore
 
clearVertexMessages(I) - Method in class org.apache.giraph.comm.messages.queue.AsyncMessageStoreWrapper
 
clearVertexMessages(I) - Method in class org.apache.giraph.comm.messages.SimpleMessageStore
 
clearVertexMessages(I) - Method in class org.apache.giraph.ooc.data.DiskBackedMessageStore
 
CLIENT_RECEIVE_BUFFER_SIZE - Static variable in interface org.apache.giraph.conf.GiraphConstants
Client receive buffer size
CLIENT_SEND_BUFFER_SIZE - Static variable in interface org.apache.giraph.conf.GiraphConstants
Client send buffer size
CLIENT_THRIFT_SERVER_HOST - Static variable in class org.apache.giraph.job.ClientThriftServer
The client can run a Thrift server (e.g.
CLIENT_THRIFT_SERVER_PORT - Static variable in class org.apache.giraph.job.ClientThriftServer
The client can run a Thrift server (e.g.
clientProcessor - Variable in class org.apache.giraph.comm.SendMessageCache
NettyWorkerClientRequestProcessor for message sending
ClientRequestId - Class in org.apache.giraph.comm.netty.handler
Simple immutable object to use for tracking requests uniquely.
ClientRequestId(int, long) - Constructor for class org.apache.giraph.comm.netty.handler.ClientRequestId
Constructor.
ClientThriftServer - Class in org.apache.giraph.job
Manages the life cycle of the Thrift server started on the client.
ClientThriftServer(GiraphConfiguration, List<?>) - Constructor for class org.apache.giraph.job.ClientThriftServer
Create and start the Thrift server.
cloneValue(E) - Method in class org.apache.giraph.mapping.translate.LongByteTranslateEdge
 
cloneValue(DoubleWritable) - Method in class org.apache.giraph.mapping.translate.LongByteTranslateEdge.DoubleEdgeValue
 
cloneValue(FloatWritable) - Method in class org.apache.giraph.mapping.translate.LongByteTranslateEdge.FloatEdgeValue
 
cloneValue(IntWritable) - Method in class org.apache.giraph.mapping.translate.LongByteTranslateEdge.IntEdgeValue
 
cloneValue(LongWritable) - Method in class org.apache.giraph.mapping.translate.LongByteTranslateEdge.LongEdgeValue
 
cloneValue(NullWritable) - Method in class org.apache.giraph.mapping.translate.LongByteTranslateEdge.NoEdgeValue
 
cloneValue(E) - Method in interface org.apache.giraph.mapping.translate.TranslateEdge
Clone edge value
close() - Method in interface org.apache.giraph.aggregators.AggregatorWriter
The method is called at the end of a successful computation.
close() - Method in class org.apache.giraph.aggregators.TextAggregatorWriter
 
close(TaskAttemptContext) - Method in class org.apache.giraph.bsp.BspRecordWriter
 
close() - Method in interface org.apache.giraph.comm.MasterServer
Shuts down.
close() - Method in class org.apache.giraph.comm.netty.NettyMasterServer
 
close() - Method in class org.apache.giraph.comm.netty.NettyWorkerServer
 
close() - Method in interface org.apache.giraph.comm.WorkerServer
Shuts down.
close() - Method in class org.apache.giraph.io.EdgeReader
Close this EdgeReader to future operations.
close(TaskAttemptContext) - Method in class org.apache.giraph.io.EdgeWriter
Close this EdgeWriter to future operations.
close() - Method in class org.apache.giraph.io.formats.SequenceFileVertexInputFormat.SequenceFileVertexReader
 
close() - Method in class org.apache.giraph.io.formats.TextEdgeInputFormat.TextEdgeReader
 
close(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextEdgeOutputFormat.TextEdgeWriter
 
close() - Method in class org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReader
 
close(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextVertexOutputFormat.TextVertexWriter
 
close() - Method in class org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReader
 
close() - Method in class org.apache.giraph.io.internal.WrappedEdgeReader
 
close() - Method in class org.apache.giraph.io.internal.WrappedMappingReader
 
close() - Method in class org.apache.giraph.io.internal.WrappedVertexReader
 
close() - Method in class org.apache.giraph.io.iterables.EdgeReaderWrapper
 
close() - Method in interface org.apache.giraph.io.iterables.GiraphReader
Close this GiraphReader to future operations.
close() - Method in class org.apache.giraph.io.iterables.MappingReaderWrapper
 
close() - Method in class org.apache.giraph.io.iterables.VertexReaderWrapper
 
close() - Method in class org.apache.giraph.io.MappingReader
Close this MappingReader to future operations.
close() - Method in class org.apache.giraph.io.ReverseEdgeDuplicator
 
close() - Method in class org.apache.giraph.io.VertexReader
Close this VertexReader to future operations.
close(TaskAttemptContext) - Method in class org.apache.giraph.io.VertexWriter
Close this VertexWriter to future operations.
close() - Method in class org.apache.giraph.master.MasterAggregatorHandler
close() - Method in class org.apache.giraph.zk.ZooKeeperExt
Close this client object.
closeChannels(ChannelFutureListener) - Method in class org.apache.giraph.comm.netty.ChannelRotater
Close the channels
closeConnections() - Method in interface org.apache.giraph.comm.MasterClient
Closes all connections.
closeConnections() - Method in class org.apache.giraph.comm.netty.NettyMasterClient
 
closeConnections() - Method in class org.apache.giraph.comm.netty.NettyWorkerClient
 
closeConnections() - Method in interface org.apache.giraph.comm.WorkerClient
Closes all connections.
closeZooKeeper() - Method in interface org.apache.giraph.bsp.CentralizedServiceWorker
Close zookeeper
closeZooKeeper() - Method in class org.apache.giraph.worker.BspServiceWorker
Method to close the zookeeper connection, after the worker has sent the counters to the master
CollectionsNCopiesSerializer<T> - Class in org.apache.giraph.writable.kryo.serializers
Special serializer for Collections.nCopies
CollectionsNCopiesSerializer() - Constructor for class org.apache.giraph.writable.kryo.serializers.CollectionsNCopiesSerializer
 
CollectionUtils - Class in org.apache.giraph.utils
Helper methods for Collections
com.yammer.metrics.core - package com.yammer.metrics.core
Package of communication related objects, IPC service.
combine(WritableComparable, DoubleWritable, DoubleWritable) - Method in class org.apache.giraph.combiner.DoubleSumMessageCombiner
Deprecated.
 
combine(WritableComparable, FloatWritable, FloatWritable) - Method in class org.apache.giraph.combiner.FloatSumMessageCombiner
Deprecated.
 
combine(WritableComparable, M, M) - Method in class org.apache.giraph.combiner.MaxMessageCombiner
 
combine(I, M, M) - Method in interface org.apache.giraph.combiner.MessageCombiner
Combine messageToCombine with originalMessage, by modifying originalMessage.
combine(WritableComparable, DoubleWritable, DoubleWritable) - Method in class org.apache.giraph.combiner.MinimumDoubleMessageCombiner
 
combine(WritableComparable, IntWritable, IntWritable) - Method in class org.apache.giraph.combiner.MinimumIntMessageCombiner
 
combine(I, M, M) - Method in class org.apache.giraph.combiner.MinMessageCombiner
 
combine(WritableComparable, NullWritable, NullWritable) - Method in class org.apache.giraph.combiner.NullMessageCombiner
 
combine(WritableComparable, IntWritable, IntWritable) - Method in class org.apache.giraph.combiner.SimpleSumMessageCombiner
Deprecated.
 
combine(WritableComparable, M, M) - Method in class org.apache.giraph.combiner.SumMessageCombiner
 
combine(V, V) - Method in class org.apache.giraph.graph.DefaultVertexValueCombiner
 
combine(V, V) - Method in interface org.apache.giraph.graph.VertexValueCombiner
Combine a vertex with the original vertex by modifying originalVertex.
CombinedWorkerProgress - Class in org.apache.giraph.job
Class which combines multiple workers' progresses to get overall application progress
CombinedWorkerProgress(Iterable<WorkerProgress>, MasterProgress, Configuration) - Constructor for class org.apache.giraph.job.CombinedWorkerProgress
Constructor
commandCompleted(IOCommand) - Method in class org.apache.giraph.ooc.policy.FixedPartitionsOracle
 
commandCompleted(IOCommand) - Method in class org.apache.giraph.ooc.policy.MemoryEstimatorOracle
 
commandCompleted(IOCommand) - Method in interface org.apache.giraph.ooc.policy.OutOfCoreOracle
Notification of command completion.
commandCompleted(IOCommand) - Method in class org.apache.giraph.ooc.policy.SimpleGCMonitoringOracle
 
commandCompleted(IOCommand) - Method in class org.apache.giraph.ooc.policy.ThresholdBasedOracle
 
commit(JobContext) - Method in class org.apache.giraph.utils.DefaultOutputCommitter
For cleaning up the job's output after job completion.
commitJob(JobContext) - Method in class org.apache.giraph.bsp.ImmutableOutputCommitter
 
commitJob(JobContext) - Method in class org.apache.giraph.utils.DefaultOutputCommitter
 
commitTask(TaskAttemptContext) - Method in class org.apache.giraph.bsp.ImmutableOutputCommitter
 
commitTask(TaskAttemptContext) - Method in class org.apache.giraph.utils.DefaultOutputCommitter
 
compare(int, byte, int, byte) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntByteMinHeap
Comapre two (key, value) entries
compare(int, double, int, double) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntDoubleMinHeap
Comapre two (key, value) entries
compare(int, float, int, float) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntFloatMinHeap
Comapre two (key, value) entries
compare(int, int, int, int) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntIntMinHeap
Comapre two (key, value) entries
compare(int, long, int, long) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntLongMinHeap
Comapre two (key, value) entries
compare(long, byte, long, byte) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongByteMinHeap
Comapre two (key, value) entries
compare(long, double, long, double) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongDoubleMinHeap
Comapre two (key, value) entries
compare(long, float, long, float) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongFloatMinHeap
Comapre two (key, value) entries
compare(long, int, long, int) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongIntMinHeap
Comapre two (key, value) entries
compare(long, long, long, long) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongLongMinHeap
Comapre two (key, value) entries
compare(ByteWritable, ByteWritable) - Method in enum org.apache.giraph.types.ops.ByteTypeOps
 
compare(DoubleWritable, DoubleWritable) - Method in enum org.apache.giraph.types.ops.DoubleTypeOps
 
compare(FloatWritable, FloatWritable) - Method in enum org.apache.giraph.types.ops.FloatTypeOps
 
compare(IntWritable, IntWritable) - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
compare(LongWritable, LongWritable) - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
compare(T, T) - Method in interface org.apache.giraph.types.ops.NumericTypeOps
Compare two values
compare(Edge<I, E>, Edge<I, E>) - Method in class org.apache.giraph.utils.EdgeComparator
 
compareEdges(Edge<I, E>, Edge<I, E>) - Static method in class org.apache.giraph.utils.EdgeComparator
Compares two edges.
compareTo(AbstractConfOption) - Method in class org.apache.giraph.conf.AbstractConfOption
 
compareTo(Object) - Method in class org.apache.giraph.counters.CustomCounter
 
compareTo(Object) - Method in class org.apache.giraph.jython.wrappers.JythonWritableWrapper
 
Computation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.graph
Interface for an application for computation.
COMPUTATION_CLASS - Static variable in interface org.apache.giraph.conf.GiraphConstants
Computation class - required
COMPUTATION_FACTORY_CLASS - Static variable in interface org.apache.giraph.conf.GiraphConstants
Computation factory class - optional
COMPUTATION_LANGUAGE - Static variable in interface org.apache.giraph.conf.GiraphConstants
Which language computation is implemented in
computationClass - Variable in class org.apache.giraph.conf.GiraphClasses
Computation class - cached for fast access
computationDone - Variable in class org.apache.giraph.worker.WorkerProgressStats
Whether all compute supersteps are done
computationDone() - Method in class org.apache.giraph.zk.ZooKeeperManager
Check if all the computation is done.
ComputationDoneName - Class in org.apache.giraph.zk
This name is used by each worker as a file to let the ZooKeeper servers know that they can shutdown.
ComputationDoneName(int) - Constructor for class org.apache.giraph.zk.ComputationDoneName
Constructor.
ComputationFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.factories
Factory for creating Computations
computationFactoryClass - Variable in class org.apache.giraph.conf.GiraphClasses
ComputationFactory class - cached for fast access
computationName(GiraphConfiguration) - Method in interface org.apache.giraph.factories.ComputationFactory
Get name of this particular computation
computationName(GiraphConfiguration) - Method in class org.apache.giraph.factories.DefaultComputationFactory
 
computationName(GiraphConfiguration) - Method in class org.apache.giraph.jython.factories.JythonComputationFactory
 
compute(Vertex<LongWritable, DoubleWritable, DoubleWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.benchmark.AggregatorsBenchmark.AggregatorsBenchmarkComputation
 
compute() - Method in class org.apache.giraph.benchmark.AggregatorsBenchmark.AggregatorsBenchmarkMasterCompute
 
compute(Vertex<IntWritable, FloatWritable, NullWritable>, Iterable<FloatWritable>) - Method in class org.apache.giraph.benchmark.PageRankComputation
 
compute(Vertex<LongWritable, DoubleWritable, DoubleWritable>, Iterable<BytesWritable>) - Method in class org.apache.giraph.benchmark.RandomMessageBenchmark.RandomMessageComputation
 
compute(Vertex<LongWritable, DoubleWritable, DoubleWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.benchmark.ReducersBenchmark.ReducersBenchmarkComputation
 
compute() - Method in class org.apache.giraph.benchmark.ReducersBenchmark.ReducersBenchmarkMasterCompute
 
compute(Vertex<LongWritable, DoubleWritable, DoubleWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.benchmark.ShortestPathsComputation
 
compute(Vertex<LongWritable, DoubleWritable, DoubleWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.benchmark.WeightedPageRankComputation
 
compute(Vertex<I, V, E>, Iterable<M1>) - Method in class org.apache.giraph.graph.AbstractComputation
Must be defined by user to do computation on a single Vertex.
compute(Vertex<I, V, E>, Iterable<M1>) - Method in interface org.apache.giraph.graph.Computation
Must be defined by user to do computation on a single Vertex.
compute(Object, Iterable) - Method in class org.apache.giraph.jython.JythonComputation
User's computation function
compute(Vertex<I, V, E>, Iterable<M1>) - Method in class org.apache.giraph.jython.JythonGiraphComputation
 
compute() - Method in class org.apache.giraph.master.DefaultMasterCompute
 
compute() - Method in class org.apache.giraph.master.MasterCompute
Must be defined by user to specify what the master has to do.
ComputeCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.graph
Compute as many vertex partitions as possible.
ComputeCallable(Mapper<?, ?, ?, ?>.Context, GraphState, MessageStore<I, M1>, ImmutableClassesGiraphConfiguration<I, V, E>, CentralizedServiceWorker<I, V, E>) - Constructor for class org.apache.giraph.graph.ComputeCallable
Constructor
computePartition(LongWritable, int, int, byte) - Method in class org.apache.giraph.mapping.AbstractLongByteOps
Compute partition given id, partitionCount, workerCount & target
computePartitionCount(int, ImmutableClassesGiraphConfiguration) - Static method in class org.apache.giraph.partition.PartitionUtils
Compute the number of partitions, based on the configuration.
conditionalSetStatusAndLog(boolean, TaskAttemptContext, Logger, Level, String) - Static method in class org.apache.giraph.utils.LoggerUtils
Helper method to set the status and log message together if condition has been been met.
conf - Variable in class org.apache.giraph.comm.messages.InMemoryMessageStoreFactory
Hadoop configuration
conf - Variable in class org.apache.giraph.comm.requests.WritableRequest
Configuration
conf - Variable in class org.apache.giraph.edge.InMemoryEdgeStoreFactory
Giraph configuration.
conf - Variable in class org.apache.giraph.utils.io.BigDataOutput
Configuration
conf - Variable in class org.apache.giraph.utils.TestGraph
The configuration
config - Variable in class org.apache.giraph.comm.messages.primitives.long_id.LongAbstractStore
Giraph configuration
config - Variable in class org.apache.giraph.comm.messages.SimpleMessageStore
Giraph configuration
ConfigurableOutEdges<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.edge
Common base class for OutEdges implementations that require a configuration.
ConfigurableOutEdges() - Constructor for class org.apache.giraph.edge.ConfigurableOutEdges
 
configuration - Variable in class org.apache.giraph.edge.AbstractEdgeStore
Giraph configuration.
configuration - Variable in class org.apache.giraph.worker.InputSplitsCallable
Configuration
ConfigurationObjectUtils - Class in org.apache.giraph.utils
Utility methods for dealing with Hadoop configuration
ConfigurationUtils - Class in org.apache.giraph.utils
Translate command line args into Configuration Key-Value pairs.
configure(GiraphConfiguration) - Method in interface org.apache.giraph.conf.BulkConfigurator
Modify given configuration.
configure(GiraphConfiguration) - Method in class org.apache.giraph.conf.FacebookConfiguration
Expand GiraphConfiguration with default Facebook settings.
CONFIGURE_JAVA_OPTS - Static variable in class org.apache.giraph.conf.FacebookConfiguration
Whether to configure java opts.
configureHadoopSecurity() - Method in class org.apache.giraph.conf.GiraphConfiguration
Check environment for Hadoop security token location in case we are executing the Giraph job on a MRv1 Hadoop cluster.
configureIfPossible(Object) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Configure an object with this instance if the object is configurable.
configureIfPossible(Object, ImmutableClassesGiraphConfiguration) - Static method in class org.apache.giraph.utils.ConfigurationUtils
Configure an object with an ImmutableClassesGiraphConfiguration if that objects supports it.
ConfOptionType - Enum in org.apache.giraph.conf
Type of value for a Configuration option
connectAllAddresses(Collection<? extends TaskInfo>) - Method in class org.apache.giraph.comm.netty.NettyClient
Connect to a collection of tasks servers
Consumer<T> - Interface in org.apache.giraph.function
Function: (T) -> void
ConsumerWithVertex<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,T> - Interface in org.apache.giraph.function.vertex
Function: (vertex, T) -> void A class that can consume objects of a single type, when given a vertex.
contains(Configuration) - Method in class org.apache.giraph.conf.AbstractConfOption
Check if option is set in configuration
contains(IntWritable) - Method in class org.apache.giraph.types.ops.collections.BasicSet.BasicIntOpenHashSet
 
contains(LongWritable) - Method in class org.apache.giraph.types.ops.collections.BasicSet.BasicLongOpenHashSet
 
contains(T) - Method in interface org.apache.giraph.types.ops.collections.BasicSet
Checks whether set contains given value
containsKey(IntWritable) - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicInt2ObjectOpenHashMap
 
containsKey(LongWritable) - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicLong2ObjectOpenHashMap
 
containsKey(K) - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicObject2ObjectOpenHashMap
 
containsKey(K) - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap
Checks whether key is present in the map
context - Variable in class org.apache.giraph.worker.InputSplitsCallable
Context
ContextSettable - Interface in org.apache.giraph.conf
Worker/Master/Mapper observer can implement this to get context set, to allow them to access job counters
convertEdgeToLine(I, V, Edge<I, E>) - Method in class org.apache.giraph.io.formats.SrcIdDstIdEdgeValueTextOutputFormat.SrcIdDstIdEdgeValueEdgeWriter
 
convertEdgeToLine(I, V, Edge<I, E>) - Method in class org.apache.giraph.io.formats.TextEdgeOutputFormat.TextEdgeWriterToEachLine
Writes a line for the given edge.
convertFromByteArray(byte[]) - Static method in class org.apache.giraph.writable.kryo.KryoWritableWrapper
Converting from byte array
convertToByteArray(T) - Static method in class org.apache.giraph.writable.kryo.KryoWritableWrapper
Converting the object to byte array.
convertToSequenceFileKey(I) - Method in class org.apache.giraph.io.formats.SequenceFileVertexOutputFormat
Converts a vertex identifier into a sequence file key.
convertToSequenceFileValue(V) - Method in class org.apache.giraph.io.formats.SequenceFileVertexOutputFormat
Converts a vertex value into a sequence file value.
convertVertexToLine(Vertex<I, V, E>) - Method in class org.apache.giraph.io.formats.AdjacencyListTextVertexOutputFormat.AdjacencyListTextVertexWriter
 
convertVertexToLine(Vertex<I, V, E>) - Method in class org.apache.giraph.io.formats.IdWithValueTextOutputFormat.IdWithValueVertexWriter
 
convertVertexToLine(Vertex<I, V, E>) - Method in class org.apache.giraph.io.formats.JsonBase64VertexOutputFormat.JsonBase64VertexWriter
 
convertVertexToLine(Vertex<I, V, E>) - Method in class org.apache.giraph.io.formats.TextVertexOutputFormat.TextVertexWriterToEachLine
Writes a line for the given vertex.
coordinateSuperstep() - Method in interface org.apache.giraph.bsp.CentralizedServiceMaster
Master coordinates the superstep
coordinateSuperstep() - Method in class org.apache.giraph.master.BspServiceMaster
 
copy() - Method in class org.apache.giraph.graph.VertexMutations
Copy the vertex mutations.
copy() - Method in class org.apache.giraph.ooc.persistence.DataIndex
Create a copy of the existing DataIndex
copy(Iterable<Edge<I, E>>) - Static method in class org.apache.giraph.utils.EdgeIterables
Make a deep copy of an edge iterable and return it as an ArrayList.
copy(Kryo, T) - Method in class org.apache.giraph.writable.kryo.serializers.DirectWritableSerializer
 
copyAndAdd(Path, Configuration) - Static method in class org.apache.giraph.utils.DistributedCacheUtils
Copy a file to HDFS if it is local, and adds it to the distributed cache.
copyInto(T, T) - Static method in class org.apache.giraph.utils.WritableUtils
Copy from into to, by serializing and deserializing it.
copyInto(T, T, boolean) - Static method in class org.apache.giraph.utils.WritableUtils
Copy from into to, by serializing and deserializing it.
copyToHdfs(Path, Configuration) - Static method in class org.apache.giraph.utils.DistributedCacheUtils
Copy a file to HDFS if it is local.
CORES_FRACTION_DURING_COMMUNICATION - Static variable in class org.apache.giraph.conf.FacebookConfiguration
Which fraction of cores to use for threads when computation and communication overlap
count() - Method in class com.yammer.metrics.core.NoOpCounter
 
count() - Method in class com.yammer.metrics.core.NoOpHistogram
 
count() - Method in class com.yammer.metrics.core.NoOpMeter
 
count() - Method in class com.yammer.metrics.core.NoOpTimer
 
count - Variable in class org.apache.giraph.metrics.AggregatedMetric
Number of values seen
count() - Method in class org.apache.giraph.metrics.AggregatedMetric
Get number of values seen
COUNTERS_DIR - Static variable in class org.apache.giraph.bsp.BspService
Counter sub directory
CounterUtils - Class in org.apache.giraph.utils
Utility methods for dealing with counters
CountingCache - Class in org.apache.giraph.comm.aggregators
Cache which counts the number of flushes per task id (destination worker id), so we know how many requests were sent to the worker
CountingCache() - Constructor for class org.apache.giraph.comm.aggregators.CountingCache
 
CountingOutputStream - Class in org.apache.giraph.comm.aggregators
Wrapper for output stream which keeps the place in the beginning for the count of objects which were written to it
CountingOutputStream() - Constructor for class org.apache.giraph.comm.aggregators.CountingOutputStream
Default constructor
create(String, Class<? extends T>, Class<T>, String) - Static method in class org.apache.giraph.conf.ClassConfOption
Static create method
create(String, Class<X>, X, String) - Static method in class org.apache.giraph.conf.EnumConfOption
Create new EnumConfOption
create(String, Class<X>, X, String) - Static method in class org.apache.giraph.conf.PerGraphTypeEnumConfOption
Create new EnumGraphTypeConfOption
create(I, E) - Static method in class org.apache.giraph.edge.EdgeFactory
Create an edge pointing to a given ID with a value
create(I) - Static method in class org.apache.giraph.edge.EdgeFactory
Create an edge pointing to a given ID without a value
create(GiraphConfiguration, String, String) - Static method in class org.apache.giraph.metrics.GiraphMetricsRegistry
Create registry with Hadoop Configuration and group to use for metrics.
create(GiraphConfiguration, long) - Static method in class org.apache.giraph.metrics.SuperstepMetricsRegistry
Create with Hadoop Configuration and superstep number.
create(Class<W>, Class<J>) - Static method in class org.apache.giraph.types.JavaWritablePair
Create holder for classes
create() - Method in enum org.apache.giraph.types.ops.BooleanTypeOps
 
create() - Method in enum org.apache.giraph.types.ops.ByteTypeOps
 
create() - Method in enum org.apache.giraph.types.ops.DoubleTypeOps
 
create() - Method in enum org.apache.giraph.types.ops.FloatTypeOps
 
create() - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
create() - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
create() - Method in enum org.apache.giraph.types.ops.MapTypeOps
 
create() - Method in enum org.apache.giraph.types.ops.TextTypeOps
 
create() - Method in interface org.apache.giraph.types.ops.TypeOps
Create new instance of type T.
create() - Method in interface org.apache.giraph.utils.Factory
Create new object
create() - Method in class org.apache.giraph.utils.io.DataInputOutput
 
create(Kryo, Input, Class<T>) - Method in class org.apache.giraph.writable.kryo.serializers.DirectWritableSerializer
Used by DirectWritableSerializer.read(Kryo, Input, Class) to create the new object.
create(Kryo, Input, Class<T>) - Method in class org.apache.giraph.writable.kryo.serializers.ReusableFieldSerializer
 
create2ObjectMap(Class<I>) - Static method in class org.apache.giraph.types.ops.collections.BasicCollectionsUtils
Construct OpenHashMap with primitive keys.
create2ObjectMap(Class<I>, WritableWriter<I>, WritableWriter<V>) - Static method in class org.apache.giraph.types.ops.collections.BasicCollectionsUtils
Construct OpenHashMap with primitive keys.
create2ObjectOpenHashMap(WritableWriter<V>) - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
create2ObjectOpenHashMap(int, WritableWriter<V>) - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
create2ObjectOpenHashMap(WritableWriter<V>) - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
create2ObjectOpenHashMap(int, WritableWriter<V>) - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
create2ObjectOpenHashMap(WritableWriter<V>) - Method in interface org.apache.giraph.types.ops.PrimitiveIdTypeOps
Create Basic2ObjectMap with key type T.
create2ObjectOpenHashMap(int, WritableWriter<V>) - Method in interface org.apache.giraph.types.ops.PrimitiveIdTypeOps
Create Basic2ObjectMap with key type T, given capacity.
CREATE_EDGE_SOURCE_VERTICES - Static variable in interface org.apache.giraph.conf.GiraphConstants
This option can be used to specify if a source vertex present in edge input but not in vertex input can be created
CREATE_EDGE_SOURCE_VERTICES_CALLBACK - Static variable in interface org.apache.giraph.conf.GiraphConstants
Defines a call back that can be used to make decisions on whether the vertex should be created or not in the runtime.
createAggregatorWriter() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user aggregator output format class
createAndExtractTypes(ImmutableClassesGiraphConfiguration) - Static method in class org.apache.giraph.master.SuperstepClasses
Create superstep classes by initiazling from current state in configuration
createAndInitializeInputOutEdges() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create an input OutEdges instance and initialize it with the default capacity.
createAndInitializeOutEdges() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a OutEdges instance and initialize it with the default capacity.
createAndInitializeOutEdges(int) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a OutEdges instance and initialize it with the given capacity (the number of edges that will be added).
createAndInitializeOutEdges(Iterable<Edge<I, E>>) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a OutEdges instance and initialize it with the given iterable of edges.
createArrayList() - Method in enum org.apache.giraph.types.ops.BooleanTypeOps
 
createArrayList(int) - Method in enum org.apache.giraph.types.ops.BooleanTypeOps
 
createArrayList() - Method in enum org.apache.giraph.types.ops.ByteTypeOps
 
createArrayList(int) - Method in enum org.apache.giraph.types.ops.ByteTypeOps
 
createArrayList() - Method in enum org.apache.giraph.types.ops.DoubleTypeOps
 
createArrayList(int) - Method in enum org.apache.giraph.types.ops.DoubleTypeOps
 
createArrayList() - Method in enum org.apache.giraph.types.ops.FloatTypeOps
 
createArrayList(int) - Method in enum org.apache.giraph.types.ops.FloatTypeOps
 
createArrayList() - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
createArrayList(int) - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
createArrayList() - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
createArrayList(int) - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
createArrayList() - Method in interface org.apache.giraph.types.ops.PrimitiveTypeOps
Create WArrayList of type T.
createArrayList(int) - Method in interface org.apache.giraph.types.ops.PrimitiveTypeOps
Create WArrayList of type T, given capacity.
createCallable() - Method in class org.apache.giraph.ooc.OutOfCoreIOCallableFactory
Creates/Launches IO threads
createCandidateStamp() - Method in class org.apache.giraph.zk.ZooKeeperManager
Create a HDFS stamp for this task.
createClassName(String) - Static method in class org.apache.giraph.writable.kryo.GiraphClassResolver
Creates a new node for the given class name.
createComputation() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user computation
createComputation(ImmutableClassesGiraphConfiguration<I, V, E>) - Method in interface org.apache.giraph.factories.ComputationFactory
Get Computation object
createComputation(ImmutableClassesGiraphConfiguration<I, V, E>) - Method in class org.apache.giraph.factories.DefaultComputationFactory
 
createComputation(ImmutableClassesGiraphConfiguration) - Method in class org.apache.giraph.jython.factories.JythonComputationFactory
 
createComputationFactory() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Get computation factory
createCopy() - Method in class org.apache.giraph.master.AggregatorReduceOperation
Creates copy of this object
createCopy(BooleanWritable) - Method in enum org.apache.giraph.types.ops.BooleanTypeOps
 
createCopy(ByteWritable) - Method in enum org.apache.giraph.types.ops.ByteTypeOps
 
createCopy(DoubleWritable) - Method in enum org.apache.giraph.types.ops.DoubleTypeOps
 
createCopy(FloatWritable) - Method in enum org.apache.giraph.types.ops.FloatTypeOps
 
createCopy(IntWritable) - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
createCopy(LongWritable) - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
createCopy(MapWritable) - Method in enum org.apache.giraph.types.ops.MapTypeOps
 
createCopy(Text) - Method in enum org.apache.giraph.types.ops.TextTypeOps
 
createCopy(T) - Method in interface org.apache.giraph.types.ops.TypeOps
Create a copy of passed object
createCopy(UnsafeByteArrayOutputStream, UnsafeReusableByteArrayInput, T, ImmutableClassesGiraphConfiguration) - Static method in class org.apache.giraph.utils.WritableUtils
Create a copy of Writable object, by serializing and deserializing it.
createCopy(T) - Static method in class org.apache.giraph.utils.WritableUtils
Create a copy of Writable object, by serializing and deserializing it.
createCopy(T, Class<? extends T>, ImmutableClassesGiraphConfiguration) - Static method in class org.apache.giraph.utils.WritableUtils
Create a copy of Writable object, by serializing and deserializing it.
createCopy(T, ValueFactory<T>, ImmutableClassesGiraphConfiguration) - Static method in class org.apache.giraph.utils.WritableUtils
Create a copy of Writable object, by serializing and deserializing it.
createCopy(T) - Static method in class org.apache.giraph.writable.kryo.HadoopKryo
Create copy of the object, by magically recursively copying all of its fields, keeping reference structures (like cycles)
createCopyForNewSuperstep() - Method in class org.apache.giraph.conf.DefaultMessageClasses
 
createCopyForNewSuperstep() - Method in interface org.apache.giraph.conf.MessageClasses
Creates a fresh copy of this object, to be used and changed for new superstep.
createData() - Method in class org.apache.giraph.utils.ByteArrayOneMessageToManyIds
 
createData() - Method in class org.apache.giraph.utils.ByteArrayVertexIdEdges
 
createData() - Method in class org.apache.giraph.utils.ByteArrayVertexIdMessages
 
createData() - Method in interface org.apache.giraph.utils.VertexIdData
Create a new data object.
createDataInput() - Method in class org.apache.giraph.utils.io.BigDataInputOutput
 
createDataInput() - Method in class org.apache.giraph.utils.io.DataInputOutput
Create DataInput which reads data from underlying DataOutput
createDataInput() - Method in class org.apache.giraph.utils.io.ExtendedDataInputOutput
 
createEdge() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user edge.
createEdge(TranslateEdge<I, E>, Edge<I, E>) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create edge based on #createEdge definition
createEdgeInputFormats(ImmutableClassesGiraphConfiguration<I, Writable, E>) - Static method in class org.apache.giraph.io.formats.multi.EdgeInputFormatDescription
Create all edge input formats
createEdgeInputSplits() - Method in interface org.apache.giraph.bsp.CentralizedServiceMaster
Create the BspInputSplit objects from the index range based on the user-defined EdgeInputFormat.
createEdgeInputSplits() - Method in class org.apache.giraph.master.BspServiceMaster
 
createEdgeReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.EdgeInputFormat
Create an edge reader for a given split.
createEdgeReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.IntNullReverseTextEdgeInputFormat
 
createEdgeReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.IntNullTextEdgeInputFormat
 
createEdgeReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.multi.MultiEdgeInputFormat
 
createEdgeReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.PseudoRandomEdgeInputFormat
 
createEdgeReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.internal.WrappedEdgeInputFormat
 
createEdges(Map.Entry<I, E>...) - Method in class org.apache.giraph.utils.TestGraph
Create edges for given ids
createEdgeStoreFactory() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create edge store factory
createEdgeValue() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user edge value
createEdgeWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.EdgeOutputFormat
Create an edge writer for a given split.
createEdgeWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.SrcIdDstIdEdgeValueTextOutputFormat
 
createEdgeWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextEdgeOutputFormat
The factory method which produces the TextEdgeOutputFormat.TextEdgeWriter used by this output format.
createEdgeWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.internal.WrappedEdgeOutputFormat
 
createExt(String, byte[], List<ACL>, CreateMode, boolean) - Method in class org.apache.giraph.zk.ZooKeeperExt
Provides a possibility of a creating a path consisting of more than one znode (not atomic).
createExtendedDataInput(byte[], int, int) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create an extended data input (can be subclassed)
createExtendedDataInput(byte[]) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create an extended data input (can be subclassed)
createExtendedDataInput(ExtendedDataOutput) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create extendedDataInput based on extendedDataOutput
createExtendedDataOutput() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create an extended data output (can be subclassed)
createExtendedDataOutput(int) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create an extended data output (can be subclassed)
createExtendedDataOutput(byte[], int) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create an extended data output (can be subclassed)
createFake() - Static method in class org.apache.giraph.metrics.GiraphMetricsRegistry
Create no-op empty registry that makes no-op metrics.
createFake() - Static method in class org.apache.giraph.metrics.SuperstepMetricsRegistry
Create an empty registry
createGcObservers(Mapper<?, ?, ?, ?>.Context) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create array of GcObservers.
createGraphPartitioner() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user graph partitioner class
createIncomingMessageValueFactory() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create new incoming message value factory
createInitialMessage() - Method in class org.apache.giraph.combiner.DoubleSumMessageCombiner
Deprecated.
 
createInitialMessage() - Method in class org.apache.giraph.combiner.FloatSumMessageCombiner
Deprecated.
 
createInitialMessage() - Method in class org.apache.giraph.combiner.MaxMessageCombiner
 
createInitialMessage() - Method in interface org.apache.giraph.combiner.MessageCombiner
Get the initial message.
createInitialMessage() - Method in class org.apache.giraph.combiner.MinimumDoubleMessageCombiner
 
createInitialMessage() - Method in class org.apache.giraph.combiner.MinimumIntMessageCombiner
 
createInitialMessage() - Method in class org.apache.giraph.combiner.MinMessageCombiner
 
createInitialMessage() - Method in class org.apache.giraph.combiner.NullMessageCombiner
 
createInitialMessage() - Method in class org.apache.giraph.combiner.SimpleSumMessageCombiner
Deprecated.
 
createInitialMessage() - Method in class org.apache.giraph.combiner.SumMessageCombiner
 
createInitialPartitionOwners(Collection<WorkerInfo>, int) - Method in interface org.apache.giraph.partition.MasterGraphPartitioner
Set some initial partition owners for the graph.
createInitialPartitionOwners(Collection<WorkerInfo>, int) - Method in class org.apache.giraph.partition.MasterGraphPartitionerImpl
 
createInitialValue() - Method in interface org.apache.giraph.aggregators.Aggregator
Return new aggregated value which is neutral to aggregate operation.
createInitialValue() - Method in class org.apache.giraph.aggregators.BooleanAndAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.BooleanOrAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.BooleanOverwriteAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.DoubleMaxAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.DoubleMinAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.DoubleOverwriteAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.DoubleProductAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.DoubleSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.FloatMaxAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.FloatMinAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.FloatOverwriteAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.FloatProductAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.FloatSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.IntMaxAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.IntMinAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.IntOverwriteAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.IntProductAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.IntSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.LongMaxAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.LongMinAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.LongOverwriteAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.LongProductAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.LongSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.matrix.dense.DoubleDenseVectorSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.matrix.dense.FloatDenseVectorSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.matrix.dense.IntDenseVectorSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.matrix.dense.LongDenseVectorSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseVectorSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.matrix.sparse.FloatSparseVectorSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.matrix.sparse.IntSparseVectorSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.matrix.sparse.LongSparseVectorSumAggregator
 
createInitialValue() - Method in class org.apache.giraph.aggregators.TextAppendAggregator
 
createInitialValue() - Method in class org.apache.giraph.benchmark.ReducersBenchmark.TestLongSumReducer
 
createInitialValue(String) - Method in class org.apache.giraph.comm.aggregators.OwnerAggregatorServerData
Create initial value for a reducer.
createInitialValue() - Method in class org.apache.giraph.master.AggregatorReduceOperation
 
createInitialValue() - Method in class org.apache.giraph.reducers.impl.AndReduce
 
createInitialValue() - Method in class org.apache.giraph.reducers.impl.KryoWrappedReduceOperation
 
createInitialValue() - Method in class org.apache.giraph.reducers.impl.LongXorReduce
 
createInitialValue() - Method in class org.apache.giraph.reducers.impl.MaxPairReducer
 
createInitialValue() - Method in class org.apache.giraph.reducers.impl.MaxReduce
 
createInitialValue() - Method in class org.apache.giraph.reducers.impl.MinReduce
 
createInitialValue() - Method in class org.apache.giraph.reducers.impl.OrReduce
 
createInitialValue() - Method in class org.apache.giraph.reducers.impl.PairReduce
 
createInitialValue() - Method in class org.apache.giraph.reducers.impl.SumReduce
 
createInitialValue() - Method in interface org.apache.giraph.reducers.ReduceOperation
Return new reduced value which is neutral to reduce operation.
createInitialValue() - Method in class org.apache.giraph.reducers.Reducer
Return new initial reduced value.
createInputOutEdges() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user OutEdges used during edge-based input
createJobProgressTrackerService(GiraphConfiguration, GiraphJobObserver) - Static method in class org.apache.giraph.job.DefaultJobProgressTrackerService
Create job progress server on job client if enabled in configuration.
createLineRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextEdgeInputFormat.TextEdgeReader
Create the line record reader.
createLineRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReader
Create the line record reader.
createLineRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReader
Create the line record reader.
createLineRecordWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextEdgeOutputFormat.TextEdgeWriter
Create the line record writer.
createLineRecordWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextVertexOutputFormat.TextVertexWriter
Create the line record writer.
createList() - Method in class org.apache.giraph.comm.messages.AbstractListPerVertexStore
Create an instance of L
createList() - Method in class org.apache.giraph.comm.messages.PointerListPerVertexStore
 
createList() - Method in class org.apache.giraph.comm.messages.primitives.long_id.LongAbstractListStore
Create an instance of L
createList() - Method in class org.apache.giraph.comm.messages.primitives.long_id.LongPointerListPerVertexStore
 
createMapperObservers(Mapper<?, ?, ?, ?>.Context) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create array of MapperObservers.
createMappingInputFormats(ImmutableClassesGiraphConfiguration<I, V, E>) - Static method in class org.apache.giraph.io.formats.multi.MappingInputFormatDescription
Create all mapping input formats
createMappingInputSplits() - Method in interface org.apache.giraph.bsp.CentralizedServiceMaster
Create the BspInputSplit objects from the index range based on the user-defined MappingInputFormat.
createMappingInputSplits() - Method in class org.apache.giraph.master.BspServiceMaster
 
createMappingReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.multi.MultiMappingInputFormat
 
createMappingReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.internal.WrappedMappingInputFormat
 
createMappingReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.MappingInputFormat
Create a vertex reader for a given split.
createMappingStore() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a MappingStore instance
createMappingStoreOps() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a MappingStoreOps instance
createMappingTarget() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create and return mappingTarget instance
createMasterCompute() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user master
createMasterGraphPartitioner() - Method in class org.apache.giraph.partition.GraphPartitionerFactory
 
createMasterGraphPartitioner() - Method in interface org.apache.giraph.partition.GraphPartitionerFactoryInterface
Create the MasterGraphPartitioner used by the master.
createMasterObservers(Mapper<?, ?, ?, ?>.Context) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create array of MasterObservers.
createMaxPositiveValue() - Method in enum org.apache.giraph.types.ops.ByteTypeOps
 
createMaxPositiveValue() - Method in enum org.apache.giraph.types.ops.DoubleTypeOps
 
createMaxPositiveValue() - Method in enum org.apache.giraph.types.ops.FloatTypeOps
 
createMaxPositiveValue() - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
createMaxPositiveValue() - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
createMaxPositiveValue() - Method in interface org.apache.giraph.types.ops.NumericTypeOps
Maximal positive value representable via current type.
createMessage() - Method in class org.apache.giraph.comm.messages.PointerListMessagesIterable
Create message from factory
createMessageCombiner(ImmutableClassesGiraphConfiguration) - Method in class org.apache.giraph.conf.DefaultMessageClasses
 
createMessageCombiner(ImmutableClassesGiraphConfiguration<I, ? extends Writable, ? extends Writable>) - Method in interface org.apache.giraph.conf.MessageClasses
Create new instance of MessageCombiner
createMessagesInputOutput() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create DataInputOutput to store messages
createMessageValueFactory(ImmutableClassesGiraphConfiguration) - Method in class org.apache.giraph.conf.DefaultMessageClasses
 
createMessageValueFactory(ImmutableClassesGiraphConfiguration) - Method in interface org.apache.giraph.conf.MessageClasses
Create new instance of MessageValueFactory
createMinNegativeValue() - Method in enum org.apache.giraph.types.ops.ByteTypeOps
 
createMinNegativeValue() - Method in enum org.apache.giraph.types.ops.DoubleTypeOps
 
createMinNegativeValue() - Method in enum org.apache.giraph.types.ops.FloatTypeOps
 
createMinNegativeValue() - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
createMinNegativeValue() - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
createMinNegativeValue() - Method in interface org.apache.giraph.types.ops.NumericTypeOps
Minimal negative value representable via current type.
createOnceExt(String, byte[], List<ACL>, CreateMode, boolean) - Method in class org.apache.giraph.zk.ZooKeeperExt
Create a znode if there is no other znode there
createOne() - Method in enum org.apache.giraph.types.ops.ByteTypeOps
 
createOne() - Method in enum org.apache.giraph.types.ops.DoubleTypeOps
 
createOne() - Method in enum org.apache.giraph.types.ops.FloatTypeOps
 
createOne() - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
createOne() - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
createOne() - Method in interface org.apache.giraph.types.ops.NumericTypeOps
Value of one
createOpenHashSet() - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
createOpenHashSet(long) - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
createOpenHashSet() - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
createOpenHashSet(long) - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
createOpenHashSet() - Method in interface org.apache.giraph.types.ops.PrimitiveIdTypeOps
Create BasicSet of type T.
createOpenHashSet(long) - Method in interface org.apache.giraph.types.ops.PrimitiveIdTypeOps
Create BasicSet of type T, given capacity.
createOrSetExt(String, byte[], List<ACL>, CreateMode, boolean, int) - Method in class org.apache.giraph.zk.ZooKeeperExt
Create a znode.
createOutEdges() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user OutEdges
createOutgoingMessageCombiner() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user combiner class
createOutgoingMessageValueFactory() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create new outgoing message value factory
createOutput(int) - Method in class org.apache.giraph.utils.io.BigDataOutput
Create next data output
createPartition(int, Progressable) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a partition
createPartitionEntry(int) - Static method in class org.apache.giraph.ooc.persistence.DataIndex.NumericIndexEntry
Create a data index entry for a given partition
createPartitionOwner() - Method in interface org.apache.giraph.partition.WorkerGraphPartitioner
Instantiate the PartitionOwner implementation used to read the master assignments.
createPartitionOwner() - Method in class org.apache.giraph.partition.WorkerGraphPartitionerImpl
 
createPartitionStats() - Method in interface org.apache.giraph.partition.MasterGraphPartitioner
Instantiate the PartitionStats implementation used to read the worker stats
createPartitionStats() - Method in class org.apache.giraph.partition.MasterGraphPartitionerImpl
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.bsp.BspInputFormat
 
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.GiraphTextInputFormat
 
createReusable(I, E) - Static method in class org.apache.giraph.edge.EdgeFactory
Create a reusable edge pointing to a given ID with a value
createReusable(I) - Static method in class org.apache.giraph.edge.EdgeFactory
Create a reusable edge pointing to a given ID with a value
createReusableEdge() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a reusable edge.
CreateSourceVertexCallback<I extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.edge
Implementations of this interface can decide whether we should create a vertex when it is not present in vertex input but exists in edge input.
createSuperstepEntry(long) - Static method in class org.apache.giraph.ooc.persistence.DataIndex.NumericIndexEntry
Create a data index entry for a given superstep
createSuperstepOutput(Mapper<?, ?, ?, ?>.Context) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create the proper superstep output, based on the configuration settings.
createTempDir(File, String) - Static method in class org.apache.giraph.utils.FileUtils
Make a temporary directory.
createTempFile(File, String) - Static method in class org.apache.giraph.utils.FileUtils
Make a temporary file.
createTestDir(String) - Static method in class org.apache.giraph.utils.FileUtils
Create a temporary folder that will be removed after the test.
createTestTempFileOrDir(File, String, boolean) - Static method in class org.apache.giraph.utils.FileUtils
Create a test temp file or directory.
createThreadFactory(String, Thread.UncaughtExceptionHandler) - Static method in class org.apache.giraph.utils.ThreadUtils
Creates new thread factory with specified thread name format.
createThreadFactory(String) - Static method in class org.apache.giraph.utils.ThreadUtils
Creates new thread factory with specified thread name format.
createToRead(ImmutableClassesGiraphConfiguration) - Static method in class org.apache.giraph.master.SuperstepClasses
Create empty superstep classes, readFields needs to be called afterwards
createUncaughtExceptionHandler() - Method in class org.apache.giraph.graph.GraphTaskManager
Creates exception handler that will terminate process gracefully in case of any uncaught exception.
createUncaughtExceptionHandler(GraphTaskManager.CheckerIfWorkerShouldFailAfterException) - Method in class org.apache.giraph.graph.GraphTaskManager
Creates exception handler with the passed implementation of GraphTaskManager.CheckerIfWorkerShouldFailAfterException.
createValue() - Method in class org.apache.giraph.reducers.impl.KryoWrappedReduceOperation
Look at ReduceOperation.createValue.
createVertex() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a vertex
createVertexId() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user vertex index
createVertexId(Et) - Method in class org.apache.giraph.edge.AbstractEdgeStore
Create vertexId from a given key
createVertexId(Int2ObjectMap.Entry<OutEdges<IntWritable, E>>) - Method in class org.apache.giraph.edge.primitives.IntEdgeStore
 
createVertexId(Long2ObjectMap.Entry<OutEdges<LongWritable, E>>) - Method in class org.apache.giraph.edge.primitives.LongEdgeStore
 
createVertexId(Map.Entry<I, OutEdges<I, E>>) - Method in class org.apache.giraph.edge.SimpleEdgeStore
 
createVertexIdData() - Method in class org.apache.giraph.comm.requests.SendWorkerDataRequest
Create a new VertexIdData specialized for the use case.
createVertexIdData() - Method in class org.apache.giraph.comm.requests.SendWorkerEdgesRequest
 
createVertexIdData() - Method in class org.apache.giraph.comm.requests.SendWorkerMessagesRequest
 
createVertexIdData() - Method in class org.apache.giraph.comm.SendEdgeCache
 
createVertexIdData() - Method in class org.apache.giraph.comm.SendMessageCache
 
createVertexIdData() - Method in class org.apache.giraph.comm.SendVertexIdDataCache
Create a new VertexIdData specialized for the use case.
createVertexInputFormats(ImmutableClassesGiraphConfiguration<I, V, E>) - Static method in class org.apache.giraph.io.formats.multi.VertexInputFormatDescription
Create all vertex input formats
createVertexInputSplits() - Method in interface org.apache.giraph.bsp.CentralizedServiceMaster
Create the BspInputSplit objects from the index range based on the user-defined VertexInputFormat.
createVertexInputSplits() - Method in class org.apache.giraph.master.BspServiceMaster
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.IntIntNullTextInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.IntIntNullTextVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.IntNullNullTextInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.JsonBase64VertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.JsonLongDoubleFloatDoubleVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.LongDoubleDoubleAdjacencyListVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.LongLongNullTextInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.multi.MultiVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.PseudoRandomIntNullVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.PseudoRandomVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.SequenceFileVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextDoubleDoubleAdjacencyListVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextVertexInputFormat
The factory method which produces the TextVertexInputFormat.TextVertexReader used by this input format.
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.WattsStrogatzVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.internal.WrappedVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.VertexInputFormat
Create a vertex reader for a given split.
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.VertexValueInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.utils.InMemoryVertexInputFormat
 
createVertexResolver() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user vertex revolver
createVertexValue() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user vertex value
createVertexValueCombiner() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user vertex value combiner class
createVertexValueReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.IntIntTextVertexValueInputFormat
 
createVertexValueReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextVertexValueInputFormat
 
createVertexValueReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.VertexValueInputFormat
Create a VertexValueReader for a given split.
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.AdjacencyListTextVertexOutputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.GraphvizOutputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.IdWithValueTextOutputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.InMemoryVertexOutputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.JsonBase64VertexOutputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.JsonLongDoubleFloatDoubleVertexOutputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.SequenceFileVertexOutputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.formats.TextVertexOutputFormat
The factory method which produces the TextVertexOutputFormat.TextVertexWriter used by this output format.
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.internal.WrappedVertexOutputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.VertexOutputFormat
Create a vertex writer for a given split.
createWithOptional(String, String) - Static method in class org.apache.giraph.metrics.GiraphMetricsRegistry
Create registry with group to use for metrics.
createWorkerContext() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a user worker context
createWorkerGraphPartitioner() - Method in class org.apache.giraph.partition.GraphPartitionerFactory
 
createWorkerGraphPartitioner() - Method in interface org.apache.giraph.partition.GraphPartitionerFactoryInterface
Create the WorkerGraphPartitioner used by the worker.
createWorkerObservers(Mapper<?, ?, ?, ?>.Context) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create array of WorkerObservers.
createWrappedEdgeInputFormat() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a wrapper for user edge input format, which makes sure that Configuration parameters are set properly in all methods related to this format.
createWrappedEdgeOutputFormat() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a wrapper for user edge output format, which makes sure that Configuration parameters are set properly in all methods related to this format.
createWrappedMappingInputFormat() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a wrapper for user mapping input format, which makes sure that Configuration parameters are set properly in all methods related to this format.
createWrappedVertexInputFormat() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a wrapper for user vertex input format, which makes sure that Configuration parameters are set properly in all methods related to this format.
createWrappedVertexOutputFormat() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Create a wrapper for user vertex output format, which makes sure that Configuration parameters are set properly in all methods related to this format.
createWritable() - Method in class org.apache.giraph.comm.messages.MessagesIterable
 
createWritable() - Method in class org.apache.giraph.utils.ByteStructIterable
Must be able to create the writable object
createWritable() - Method in class org.apache.giraph.utils.ByteStructIterator
Must be able to create the writable object
createWritable(Class<W>) - Static method in class org.apache.giraph.utils.WritableUtils
Instantiate a new Writable, checking for NullWritable along the way.
createWritable(Class<W>, ImmutableClassesGiraphConfiguration) - Static method in class org.apache.giraph.utils.WritableUtils
Instantiate a new Writable, checking for NullWritable along the way.
createZero() - Method in enum org.apache.giraph.types.ops.ByteTypeOps
 
createZero() - Method in enum org.apache.giraph.types.ops.DoubleTypeOps
 
createZero() - Method in enum org.apache.giraph.types.ops.FloatTypeOps
 
createZero() - Method in enum org.apache.giraph.types.ops.IntTypeOps
 
createZero() - Method in enum org.apache.giraph.types.ops.LongTypeOps
 
createZero() - Method in interface org.apache.giraph.types.ops.NumericTypeOps
Value of zero
CREDIT_HIGH_THRESHOLD - Static variable in class org.apache.giraph.ooc.policy.MemoryEstimatorOracle
If mem-usage is above this threshold, credit is set to 0
CREDIT_LOW_THRESHOLD - Static variable in class org.apache.giraph.ooc.policy.MemoryEstimatorOracle
If mem-usage is below this threshold, credit is set to max
CreditBasedFlowControl - Class in org.apache.giraph.comm.flow_control
Representation of credit-based flow control policy.
CreditBasedFlowControl(ImmutableClassesGiraphConfiguration, NettyClient, Thread.UncaughtExceptionHandler) - Constructor for class org.apache.giraph.comm.flow_control.CreditBasedFlowControl
Constructor
CURRENT_MASTER_PARTITION_TASK_NAME - Static variable in class org.apache.giraph.counters.GiraphStats
current master partition task counter name
CURRENT_WORKERS_NAME - Static variable in class org.apache.giraph.counters.GiraphStats
workers counter name
currentDataOutput - Variable in class org.apache.giraph.utils.io.BigDataOutput
Data output which we are currently writing to
currentSuperstep - Variable in class org.apache.giraph.worker.WorkerProgressStats
Superstep which worker is executing, Long.MAX_VALUE if it's output
CustomCounter - Class in org.apache.giraph.counters
An object of this class represents a counter with a group name, counter name, value, and type of aggregation to be performed
CustomCounter() - Constructor for class org.apache.giraph.counters.CustomCounter
Create a default custom counter
CustomCounter(String, String, CustomCounter.Aggregation) - Constructor for class org.apache.giraph.counters.CustomCounter
Create a counter with a given group, name, and aggregation type The default value is 0
CustomCounter(String, String, CustomCounter.Aggregation, long) - Constructor for class org.apache.giraph.counters.CustomCounter
Create a counter with a group, name, aggregation type, and value
CustomCounter.Aggregation - Enum in org.apache.giraph.counters
To store the type of aggregation to be done on the counters
CustomCounters - Class in org.apache.giraph.counters
Custom counters created by the client or app Stores the names of the counters, and the final aggregated values Since there is no way to get the list of available counters from the context, we need to call addCustomCounter to store the information about the list of available counters.
CustomCounters() - Constructor for class org.apache.giraph.counters.CustomCounters
Create custom counters

D

dataExist(int, DataIndex) - Method in class org.apache.giraph.ooc.persistence.InMemoryDataAccessor
 
dataExist(int, DataIndex) - Method in class org.apache.giraph.ooc.persistence.LocalDiskDataAccessor
 
dataExist(int, DataIndex) - Method in interface org.apache.giraph.ooc.persistence.OutOfCoreDataAccessor
Whether the data for the given thread and index chain exists?
DataIndex - Class in org.apache.giraph.ooc.persistence
Index chain used in out-of-core data accessor object (DAO) to access serialized data.
DataIndex() - Constructor for class org.apache.giraph.ooc.persistence.DataIndex
 
DataIndex.DataIndexEntry - Interface in org.apache.giraph.ooc.persistence
Interface to unify different types of entries used as index chain
DataIndex.NumericIndexEntry - Class in org.apache.giraph.ooc.persistence
Class representing any index chain that depends on something with id.
DataIndex.TypeIndexEntry - Enum in org.apache.giraph.ooc.persistence
Different static types of index chain entry
dataInputFactory - Variable in class org.apache.giraph.utils.ByteStructIterable
Factory for data input
DataInputOutput - Class in org.apache.giraph.utils.io
Provides both DataOutput which we can write to and DataInputs which are going to read data which was written to DataOutput.
DataInputOutput() - Constructor for class org.apache.giraph.utils.io.DataInputOutput
 
DataInputWrapperStream - Class in org.apache.giraph.writable.kryo
Thin wrapper around DataInput so it can be used as an InputStream For use with Input
DataInputWrapperStream() - Constructor for class org.apache.giraph.writable.kryo.DataInputWrapperStream
 
dataOutput - Variable in class org.apache.giraph.comm.aggregators.CountingOutputStream
DataOutput to which subclasses will be writing data
dataOutputs - Variable in class org.apache.giraph.utils.io.BigDataOutput
List of filled outputs, will be null until we get a lot of data
DataOutputWrapperStream - Class in org.apache.giraph.writable.kryo
Thin wrapper around a DataOutput so it can be used as an OutputStream For use with Output)
DataOutputWrapperStream() - Constructor for class org.apache.giraph.writable.kryo.DataOutputWrapperStream
 
dataSize - Variable in class org.apache.giraph.utils.ByteStructVertexIdDataIterator
Serialized size of the message object in bytestore
dec() - Method in class com.yammer.metrics.core.NoOpCounter
 
dec(long) - Method in class com.yammer.metrics.core.NoOpCounter
 
DECIMAL_FORMAT - Static variable in class org.apache.giraph.job.CombinedWorkerProgress
Decimal format which rounds numbers to two decimal places
decode(ChannelHandlerContext, Object) - Method in class org.apache.giraph.comm.netty.handler.SaslClientHandler
Decode the message read by handler
decodeBytes(String) - Static method in class org.apache.giraph.utils.ConfigurationObjectUtils
Decode bytes from a hex String
decodeEdge(String, String) - Method in class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader
Decode an edge from the line into an instance of a correctly typed Edge
decodeEdge(String, String) - Method in class org.apache.giraph.io.formats.LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader
 
decodeEdge(String, String) - Method in class org.apache.giraph.io.formats.TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader
 
decodeId(String) - Method in class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader
Decode the id for this line into an instance of its correct type.
decodeId(String) - Method in class org.apache.giraph.io.formats.LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader
 
decodeId(String) - Method in class org.apache.giraph.io.formats.TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader
 
decodeValue(String) - Method in class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader
Decode the value for this line into an instance of its correct type.
decodeValue(String) - Method in class org.apache.giraph.io.formats.LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader
 
decodeValue(String) - Method in class org.apache.giraph.io.formats.TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader
 
decodeWritableRequest(ByteBuf, WritableRequest) - Static method in class org.apache.giraph.utils.RequestUtils
decodeWritableRequest based on predicate
decrementEdges() - Method in class org.apache.giraph.edge.MutableEdgesWrapper
Decrement the number of edges (to account for a deletion from the mutable iterator).
DEFAULT_INPUT_SPLIT_THREAD_COUNT - Static variable in class org.apache.giraph.master.BspServiceMaster
Default number of threads to use when writing input splits to zookeeper
DEFAULT_NUM_BYTES_PER_MESSAGE - Static variable in class org.apache.giraph.benchmark.RandomMessageBenchmark
Default bytes per message
DEFAULT_NUM_MESSAGES_PER_EDGE - Static variable in class org.apache.giraph.benchmark.RandomMessageBenchmark
Default messages per edge
DEFAULT_ZOOKEEPER_MAX_CLIENT_CNXNS - Static variable in interface org.apache.giraph.conf.GiraphConstants
Default ZooKeeper maximum client connections.
DEFAULT_ZOOKEEPER_SNAP_COUNT - Static variable in interface org.apache.giraph.conf.GiraphConstants
Default ZooKeeper snap count.
DEFAULT_ZOOKEEPER_TICK_TIME - Static variable in interface org.apache.giraph.conf.GiraphConstants
Default ZooKeeper tick time.
DefaultCheckpointSupportedChecker - Class in org.apache.giraph.bsp.checkpoints
Default checkpoint supported checker.
DefaultCheckpointSupportedChecker() - Constructor for class org.apache.giraph.bsp.checkpoints.DefaultCheckpointSupportedChecker
 
DefaultComputationFactory<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.factories
Default computation factory that simply creates java computation object
DefaultComputationFactory() - Constructor for class org.apache.giraph.factories.DefaultComputationFactory
 
DefaultCreateSourceVertexCallback<I extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.edge
Default implementation of vertex creation decision maker.
DefaultCreateSourceVertexCallback() - Constructor for class org.apache.giraph.edge.DefaultCreateSourceVertexCallback
 
DefaultEdge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.edge
A complete edge, the target vertex and the edge value.
DefaultEdge() - Constructor for class org.apache.giraph.edge.DefaultEdge
Constructor for reflection
DefaultEdge(I, E) - Constructor for class org.apache.giraph.edge.DefaultEdge
Create the edge with final values.
DefaultEdgeInputFilter<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io.filters
Default edge filter that lets in all edges.
DefaultEdgeInputFilter() - Constructor for class org.apache.giraph.io.filters.DefaultEdgeInputFilter
 
DefaultEdgeValueFactory<E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.factories
Factory class to create default edge values.
DefaultEdgeValueFactory() - Constructor for class org.apache.giraph.factories.DefaultEdgeValueFactory
 
DefaultEmbeddedLongByteOps - Class in org.apache.giraph.mapping
MappingStoreOps implementation used to embed target information into vertex id.
DefaultEmbeddedLongByteOps() - Constructor for class org.apache.giraph.mapping.DefaultEmbeddedLongByteOps
Default constructor (do not use)
DefaultGiraphJobRetryChecker - Class in org.apache.giraph.job
Default implementation of GiraphJobRetryChecker, which never retries the job.
DefaultGiraphJobRetryChecker() - Constructor for class org.apache.giraph.job.DefaultGiraphJobRetryChecker
 
DefaultHaltInstructionsWriter() - Constructor for class org.apache.giraph.job.HaltApplicationUtils.DefaultHaltInstructionsWriter
 
DefaultImmutableClassesGiraphConfigurable<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.conf
Default implementation of ImmutableClassesGiraphConfigurable
DefaultImmutableClassesGiraphConfigurable() - Constructor for class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable
 
DefaultInputOutEdgesFactory<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.factories
Default factory class for creating OutEdges instances to be used during input.
DefaultInputOutEdgesFactory() - Constructor for class org.apache.giraph.factories.DefaultInputOutEdgesFactory
 
DefaultJobObserver - Class in org.apache.giraph.job
Default implementation of job observer that does nothing.
DefaultJobObserver() - Constructor for class org.apache.giraph.job.DefaultJobObserver
 
DefaultJobProgressTrackerService - Class in org.apache.giraph.job
Default implementation of JobProgressTrackerService
DefaultJobProgressTrackerService() - Constructor for class org.apache.giraph.job.DefaultJobProgressTrackerService
 
DefaultLongByteOps - Class in org.apache.giraph.mapping
MappingStoreOps implementation which reads partition information from map
DefaultLongByteOps() - Constructor for class org.apache.giraph.mapping.DefaultLongByteOps
Default constructor (do not use)
DefaultMasterCompute - Class in org.apache.giraph.master
A dumb implementation of MasterCompute.
DefaultMasterCompute() - Constructor for class org.apache.giraph.master.DefaultMasterCompute
 
DefaultMasterObserver - Class in org.apache.giraph.master
A no-op implementation of MasterObserver to make it easier for users.
DefaultMasterObserver() - Constructor for class org.apache.giraph.master.DefaultMasterObserver
 
DefaultMessageClasses<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.conf
Default implementation of MessageClasses
DefaultMessageClasses() - Constructor for class org.apache.giraph.conf.DefaultMessageClasses
Constructor
DefaultMessageClasses(Class<M>, Class<? extends MessageValueFactory<M>>, Class<? extends MessageCombiner<? super I, M>>, MessageEncodeAndStoreType) - Constructor for class org.apache.giraph.conf.DefaultMessageClasses
Constructor
DefaultMessageValueFactory<M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.factories
Factory class to create default message values.
DefaultMessageValueFactory(Class<M>, ImmutableClassesGiraphConfiguration) - Constructor for class org.apache.giraph.factories.DefaultMessageValueFactory
Constructor
DefaultOutEdgesFactory<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.factories
Default factory class for creating OutEdges instances to be used during computation.
DefaultOutEdgesFactory() - Constructor for class org.apache.giraph.factories.DefaultOutEdgesFactory
 
DefaultOutputCommitter - Class in org.apache.giraph.utils
Output committer which has abstract commit method
DefaultOutputCommitter() - Constructor for class org.apache.giraph.utils.DefaultOutputCommitter
 
DefaultVertex<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.graph
Class which holds vertex id, data and edges.
DefaultVertex() - Constructor for class org.apache.giraph.graph.DefaultVertex
 
DefaultVertexIdFactory<I extends org.apache.hadoop.io.WritableComparable> - Class in org.apache.giraph.factories
Default VertexIdFactory that simply uses the default constructor for the vertex ID class.
DefaultVertexIdFactory() - Constructor for class org.apache.giraph.factories.DefaultVertexIdFactory
 
DefaultVertexInputFilter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io.filters
Default vertex filter that lets in all vertices.
DefaultVertexInputFilter() - Constructor for class org.apache.giraph.io.filters.DefaultVertexInputFilter
 
DefaultVertexResolver<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.graph
Default implementation of how to resolve vertex creation/removal, messages to nonexistent vertices, etc.
DefaultVertexResolver() - Constructor for class org.apache.giraph.graph.DefaultVertexResolver
 
DefaultVertexValueCombiner<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.graph
The default vertex value combining approach is to simply keep the original value.
DefaultVertexValueCombiner() - Constructor for class org.apache.giraph.graph.DefaultVertexValueCombiner
 
DefaultVertexValueFactory<V extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.factories
Default VertexValueFactory that simply uses the default constructor for the vertex value class.
DefaultVertexValueFactory() - Constructor for class org.apache.giraph.factories.DefaultVertexValueFactory
 
DefaultWorkerContext - Class in org.apache.giraph.worker
A dummy implementation of WorkerContext.
DefaultWorkerContext() - Constructor for class org.apache.giraph.worker.DefaultWorkerContext
 
DefaultWorkerObserver - Class in org.apache.giraph.worker
Default Observer for Worker that does nothing.
DefaultWorkerObserver() - Constructor for class org.apache.giraph.worker.DefaultWorkerObserver
 
delete(File) - Static method in class org.apache.giraph.utils.FileUtils
Recursively delete a directory
deleteExt(String, int, boolean) - Method in class org.apache.giraph.zk.ZooKeeperExt
Delete a path recursively.
deletePath(Configuration, String) - Static method in class org.apache.giraph.utils.FileUtils
Helper method to remove a path if it exists.
deletePath(Configuration, Path) - Static method in class org.apache.giraph.utils.FileUtils
Helper method to remove a path if it exists.
DeployedScript - Class in org.apache.giraph.scripting
A script that was deployed to the cluster.
DeployedScript(String, DeployType, Language) - Constructor for class org.apache.giraph.scripting.DeployedScript
Constructor
DeployType - Enum in org.apache.giraph.scripting
Type of deployment for a file
DirectWritableSerializer<T extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.writable.kryo.serializers
A custom Serializer that will call the Writable methods defined by the object itself to serialize the object, instead of Kryo auto-magically serializing
DirectWritableSerializer() - Constructor for class org.apache.giraph.writable.kryo.serializers.DirectWritableSerializer
 
DISABLE_GIRAPH_CLASS_RESOLVER - Static variable in interface org.apache.giraph.conf.GiraphConstants
Whether to disable GiraphClassResolver which is an efficient implementation of kryo class resolver.
DisabledCheckpointSupportedChecker - Class in org.apache.giraph.bsp.checkpoints
Disable all checkpoints.
DisabledCheckpointSupportedChecker() - Constructor for class org.apache.giraph.bsp.checkpoints.DisabledCheckpointSupportedChecker
 
DISK_BANDWIDTH_ESTIMATE - Static variable in class org.apache.giraph.ooc.OutOfCoreIOStatistics
An estimate of disk bandwidth.
DiskBackedDataStore<T> - Class in org.apache.giraph.ooc.data
This class provides basic operations for data structures that have to participate in out-of-core mechanism.
DiskBackedEdgeStore<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.ooc.data
Implementation of an edge-store used for out-of-core mechanism.
DiskBackedEdgeStore(EdgeStore<I, V, E>, ImmutableClassesGiraphConfiguration<I, V, E>, OutOfCoreEngine) - Constructor for class org.apache.giraph.ooc.data.DiskBackedEdgeStore
Constructor
DiskBackedMessageStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.ooc.data
Implementation of a message store used for out-of-core mechanism.
DiskBackedMessageStore(ImmutableClassesGiraphConfiguration<I, ?, ?>, OutOfCoreEngine, MessageStore<I, M>, boolean, long) - Constructor for class org.apache.giraph.ooc.data.DiskBackedMessageStore
Constructor
DiskBackedPartitionStore<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.ooc.data
Implementation of a partition-store used for out-of-core mechanism.
DiskBackedPartitionStore(PartitionStore<I, V, E>, ImmutableClassesGiraphConfiguration<I, V, E>, Mapper<?, ?, ?, ?>.Context, OutOfCoreEngine) - Constructor for class org.apache.giraph.ooc.data.DiskBackedPartitionStore
Constructor.
DistributedCacheUtils - Class in org.apache.giraph.utils
Helpers for dealing with DistributedCache
distributeReducedValues(Iterable<byte[]>) - Method in interface org.apache.giraph.comm.aggregators.WorkerAggregatorRequestProcessor
Sends reduced values to all other workers
distributeReducedValues(Iterable<byte[]>) - Method in class org.apache.giraph.comm.netty.NettyWorkerAggregatorRequestProcessor
 
DNS_INTERFACE - Static variable in interface org.apache.giraph.conf.GiraphConstants
Interface to use for hostname resolution
DNS_NAMESERVER - Static variable in interface org.apache.giraph.conf.GiraphConstants
Server for hostname resolution
DO_OUTPUT_DURING_COMPUTATION - Static variable in interface org.apache.giraph.conf.GiraphConstants
If you use this option, instead of having saving vertices in the end of application, saveVertex will be called right after each vertex.compute() is called.
doCompression() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Has the user enabled compression in netty client & server
doExchange() - Method in class org.apache.giraph.partition.PartitionExchange
Is this worker involved in a partition exchange? Receiving or sending?
DONE_FRACTIONS_TO_STORE_IN_COUNTERS - Static variable in class org.apache.giraph.master.input.MasterInputSplitsHandler
Store in counters timestamps when we finished reading these fractions of input
doneLoadingPartition(int, long) - Method in class org.apache.giraph.ooc.data.MetaPartitionManager
Notify this meta store that load of a partition for a specific superstep is completed
doneOffloadingBuffer(int) - Method in class org.apache.giraph.ooc.data.MetaPartitionManager
Notify this meta store that offload of raw data buffers (vertex/edges/ messages) of a particular partition is completed.
doneOffloadingMessages(int) - Method in class org.apache.giraph.ooc.data.MetaPartitionManager
Notify this meta store that offload of messages for a particular partition is complete.
doneOffloadingPartition(int) - Method in class org.apache.giraph.ooc.data.MetaPartitionManager
Notify this meta store that offload of a partition (partition data and its current messages) is completed.
doneProcessingPartition(int) - Method in class org.apache.giraph.ooc.OutOfCoreEngine
Notify out-of-core engine that processing of a particular partition is done
doOutputDuringComputation() - Method in class org.apache.giraph.conf.GiraphConfiguration
Check if output should be done during computation
doRequest(WorkerInfo, WritableRequest) - Method in class org.apache.giraph.comm.netty.NettyWorkerClientRequestProcessor
When doing the request, short circuit if it is local
doRequest(ServerData) - Method in class org.apache.giraph.comm.requests.AddressesAndPartitionsRequest
 
doRequest(MasterGlobalCommHandler) - Method in class org.apache.giraph.comm.requests.AskForInputSplitRequest
 
doRequest(MasterGlobalCommHandler) - Method in interface org.apache.giraph.comm.requests.MasterRequest
Execute the request
doRequest(MasterGlobalCommHandler) - Method in class org.apache.giraph.comm.requests.PartitionStatsRequest
 
doRequest(ServerData) - Method in class org.apache.giraph.comm.requests.ReplyWithInputSplitRequest
 
doRequest(ServerData) - Method in class org.apache.giraph.comm.requests.SendAggregatorsToOwnerRequest
 
doRequest(ServerData) - Method in class org.apache.giraph.comm.requests.SendAggregatorsToWorkerRequest
 
doRequest(ServerData<I, V, E>) - Method in class org.apache.giraph.comm.requests.SendPartitionCurrentMessagesRequest
 
doRequest(ServerData<I, V, E>) - Method in class org.apache.giraph.comm.requests.SendPartitionMutationsRequest
 
doRequest(MasterGlobalCommHandler) - Method in class org.apache.giraph.comm.requests.SendReducedToMasterRequest
 
doRequest(ServerData) - Method in class org.apache.giraph.comm.requests.SendResumeRequest
 
doRequest(ServerData<I, V, E>) - Method in class org.apache.giraph.comm.requests.SendVertexRequest
 
doRequest(ServerData) - Method in class org.apache.giraph.comm.requests.SendWorkerAggregatorsRequest
 
doRequest(ServerData) - Method in class org.apache.giraph.comm.requests.SendWorkerEdgesRequest
 
doRequest(ServerData) - Method in class org.apache.giraph.comm.requests.SendWorkerMessagesRequest
 
doRequest(ServerData) - Method in class org.apache.giraph.comm.requests.SendWorkerOneMessageToManyRequest
 
doRequest(ServerData<WritableComparable, Writable, Writable>) - Method in class org.apache.giraph.comm.requests.SendWorkerToWorkerMessageRequest
 
doRequest(ServerData<I, V, E>) - Method in class org.apache.giraph.comm.requests.SendWorkerVerticesRequest
 
doRequest(ServerData<I, V, E>) - Method in interface org.apache.giraph.comm.requests.WorkerRequest
Execute the request
doSend(int, WritableRequest) - Method in class org.apache.giraph.comm.netty.NettyClient
Actual send of a request.
dotString() - Method in enum org.apache.giraph.graph.GraphType
Name of graph type with dots, like vertex.id or vertex.value
DOUBLE - Static variable in class org.apache.giraph.combiner.MaxMessageCombiner
DoubleWritable specialization
DOUBLE - Static variable in class org.apache.giraph.combiner.SumMessageCombiner
DoubleWritable specialization
DOUBLE - Static variable in class org.apache.giraph.reducers.impl.MaxReduce
DoubleWritable specialization
DOUBLE - Static variable in class org.apache.giraph.reducers.impl.MinReduce
DoubleWritable specialization
DOUBLE - Static variable in class org.apache.giraph.reducers.impl.SumReduce
DoubleWritable specialization
Double2DoubleFunction - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (double) -> double
Double2ObjFunction<T> - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (double) -> T
DOUBLE_DOUBLE_WRITABLE - Static variable in class org.apache.giraph.types.JavaWritablePair
Double,DoubleWritable
DOUBLE_FLOAT_WRITABLE - Static variable in class org.apache.giraph.types.JavaWritablePair
Double,FloatWritable
DoubleBooleanConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, boolean) -> void
DoubleBooleanPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, boolean) -> boolean
DoubleByteConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, byte) -> void
DoubleBytePredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, byte) -> boolean
DoubleConsumer - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (double) -> void
DoubleDenseMatrix - Class in org.apache.giraph.aggregators.matrix.dense
A double matrix holds the values of the entries in double vectors.
DoubleDenseMatrix(int) - Constructor for class org.apache.giraph.aggregators.matrix.dense.DoubleDenseMatrix
Create a new matrix with the same number of rows and columns.
DoubleDenseMatrix(int, int) - Constructor for class org.apache.giraph.aggregators.matrix.dense.DoubleDenseMatrix
Create a new matrix with the given number of rows and columns.
DoubleDenseMatrixSumAggregator - Class in org.apache.giraph.aggregators.matrix.dense
The double dense matrix aggregator is used to register and aggregate double dense matrices.
DoubleDenseMatrixSumAggregator(String) - Constructor for class org.apache.giraph.aggregators.matrix.dense.DoubleDenseMatrixSumAggregator
Create a new matrix aggregator with the given prefix name for the vector aggregators.
DoubleDenseVector - Class in org.apache.giraph.aggregators.matrix.dense
The double dense vector holds the values of a particular row.
DoubleDenseVector() - Constructor for class org.apache.giraph.aggregators.matrix.dense.DoubleDenseVector
Create a new vector with default size.
DoubleDenseVector(int) - Constructor for class org.apache.giraph.aggregators.matrix.dense.DoubleDenseVector
Create a new vector with given size.
DoubleDenseVectorSumAggregator - Class in org.apache.giraph.aggregators.matrix.dense
The double dense vector aggregator is used to aggregate double dense vectors.
DoubleDenseVectorSumAggregator() - Constructor for class org.apache.giraph.aggregators.matrix.dense.DoubleDenseVectorSumAggregator
 
DoubleDoubleConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, double) -> void
DoubleDoublePredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, double) -> boolean
DoubleDoubleWritable - Class in org.apache.giraph.writable.tuple
Double-double Pair Writable
DoubleDoubleWritable() - Constructor for class org.apache.giraph.writable.tuple.DoubleDoubleWritable
Constructor
DoubleDoubleWritable(double, double) - Constructor for class org.apache.giraph.writable.tuple.DoubleDoubleWritable
Constructor
DoubleEdgeValue() - Constructor for class org.apache.giraph.mapping.translate.LongByteTranslateEdge.DoubleEdgeValue
 
DoubleFloatConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, float) -> void
DoubleFloatPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, float) -> boolean
DoubleIntConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, int) -> void
DoubleIntPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, int) -> boolean
DoubleLongConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, long) -> void
DoubleLongPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (double, long) -> boolean
DoubleMaxAggregator - Class in org.apache.giraph.aggregators
Aggregator for getting max double value.
DoubleMaxAggregator() - Constructor for class org.apache.giraph.aggregators.DoubleMaxAggregator
 
DoubleMinAggregator - Class in org.apache.giraph.aggregators
Aggregator for getting min double value.
DoubleMinAggregator() - Constructor for class org.apache.giraph.aggregators.DoubleMinAggregator
 
DoubleOverwriteAggregator - Class in org.apache.giraph.aggregators
Aggregator that stores a value that is overwritten once another value is aggregated.
DoubleOverwriteAggregator() - Constructor for class org.apache.giraph.aggregators.DoubleOverwriteAggregator
 
DoublePredicate - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (double) -> boolean
DoubleProductAggregator - Class in org.apache.giraph.aggregators
Aggregator for calculating products of double values.
DoubleProductAggregator() - Constructor for class org.apache.giraph.aggregators.DoubleProductAggregator
 
DoubleRef(double) - Constructor for class org.apache.giraph.function.primitive.PrimitiveRefs.DoubleRef
Constructor
DoubleSparseMatrix - Class in org.apache.giraph.aggregators.matrix.sparse
A double matrix holds the values of the entries in double vectors.
DoubleSparseMatrix(int) - Constructor for class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseMatrix
Create a new matrix with the given number of rows.
DoubleSparseMatrixSumAggregator - Class in org.apache.giraph.aggregators.matrix.sparse
The double matrix aggregator is used to register and aggregate double matrices.
DoubleSparseMatrixSumAggregator(String) - Constructor for class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseMatrixSumAggregator
Create a new matrix aggregator with the given prefix name for the vector aggregators.
DoubleSparseVector - Class in org.apache.giraph.aggregators.matrix.sparse
The double vector holds the values of a particular row.
DoubleSparseVector() - Constructor for class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseVector
Create a new vector with default size.
DoubleSparseVector(int) - Constructor for class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseVector
Create a new vector with given size.
DoubleSparseVectorSumAggregator - Class in org.apache.giraph.aggregators.matrix.sparse
The double vector aggregator is used to aggregate double vectors.
DoubleSparseVectorSumAggregator() - Constructor for class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseVectorSumAggregator
 
DoubleSumAggregator - Class in org.apache.giraph.aggregators
Aggregator for summing up double values.
DoubleSumAggregator() - Constructor for class org.apache.giraph.aggregators.DoubleSumAggregator
 
DoubleSumMessageCombiner - Class in org.apache.giraph.combiner
Deprecated.
DoubleSumMessageCombiner() - Constructor for class org.apache.giraph.combiner.DoubleSumMessageCombiner
Deprecated.
 
DoubleToDoubleWritableWrapper - Class in org.apache.giraph.types
Converts Doubles to DoubleWritables
DoubleToDoubleWritableWrapper() - Constructor for class org.apache.giraph.types.DoubleToDoubleWritableWrapper
 
DoubleTypeOps - Enum in org.apache.giraph.types.ops
TypeOps implementation for working with DoubleWritable type
DoubleWritableToDoubleUnwrapper - Class in org.apache.giraph.types
Converts DoubleWritables to Doubles
DoubleWritableToDoubleUnwrapper() - Constructor for class org.apache.giraph.types.DoubleWritableToDoubleUnwrapper
 
doZooKeeperCleanup(ZooKeeperExt, String) - Method in class org.apache.giraph.zk.GiraphZooKeeperAdmin
Cleans the ZooKeeper quorum of in-memory failed/killed job fragments.
dropEdge(I, Edge<I, E>) - Method in class org.apache.giraph.io.filters.DefaultEdgeInputFilter
 
dropEdge(I, Edge<I, E>) - Method in interface org.apache.giraph.io.filters.EdgeInputFilter
Whether to drop this edge
dropVertex(Vertex<I, V, E>) - Method in class org.apache.giraph.io.filters.DefaultVertexInputFilter
 
dropVertex(Vertex<I, V, E>) - Method in interface org.apache.giraph.io.filters.VertexInputFilter
Whether to drop a vertex on input.
dumpToStream(PrintStream) - Method in class org.apache.giraph.metrics.GiraphMetrics
Dump all metrics to output stream provided.
DynamicChannelBufferInputStream - Class in org.apache.giraph.utils
Special input that reads from a DynamicChannelBuffer.
DynamicChannelBufferInputStream(ByteBuf) - Constructor for class org.apache.giraph.utils.DynamicChannelBufferInputStream
Constructor.
DynamicChannelBufferOutputStream - Class in org.apache.giraph.utils
Special output stream that can grow as needed and dumps to a DynamicChannelBuffer.
DynamicChannelBufferOutputStream(int) - Constructor for class org.apache.giraph.utils.DynamicChannelBufferOutputStream
Constructor
DynamicChannelBufferOutputStream(ByteBuf) - Constructor for class org.apache.giraph.utils.DynamicChannelBufferOutputStream
Constructor with the buffer to use

E

Edge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.edge
A complete edge, the target vertex and the edge value.
EDGE_ARRAY_KEY - Static variable in class org.apache.giraph.io.formats.JsonBase64VertexFormat
Edge value array key (all the edges are stored here)
EDGE_INPUT_DIR - Static variable in class org.apache.giraph.io.formats.GiraphFileInputFormat
Edge input file paths.
EDGE_INPUT_FILTER_CLASS - Static variable in interface org.apache.giraph.conf.GiraphConstants
EdgeInputFilter class
EDGE_INPUT_FORMAT_CLASS - Static variable in interface org.apache.giraph.conf.GiraphConstants
EdgeInputFormat class
EDGE_INPUT_FORMAT_DESCRIPTIONS - Static variable in class org.apache.giraph.io.formats.multi.EdgeInputFormatDescription
EdgeInputFormats description - JSON array containing a JSON array for each edge input.
EDGE_OUTPUT_FORMAT_CLASS - Static variable in interface org.apache.giraph.conf.GiraphConstants
EdgeOutputFormat class
EDGE_OUTPUT_FORMAT_SUBDIR - Static variable in interface org.apache.giraph.conf.GiraphConstants
EdgeOutputFormat sub-directory
EDGE_STORE_FACTORY_CLASS - Static variable in interface org.apache.giraph.conf.GiraphConstants
Edge Store Factory
EDGE_TRANSLATION_CLASS - Static variable in interface org.apache.giraph.conf.GiraphConstants
Class used to conduct expensive edge translation during vertex input
EDGE_VALUE_CLASS - Static variable in interface org.apache.giraph.conf.GiraphConstants
Edge value class
EDGE_VALUE_FACTORY_CLASS - Static variable in interface org.apache.giraph.conf.GiraphConstants
Edge value factory class - optional
EdgeComparator<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> - Class in org.apache.giraph.utils
Comparator for edges.
EdgeComparator() - Constructor for class org.apache.giraph.utils.EdgeComparator
 
EdgeFactory - Class in org.apache.giraph.edge
Factory for creating Edges
EdgeInput() - Constructor for class org.apache.giraph.jython.JythonJob.EdgeInput
 
EdgeInputFilter<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.io.filters
Filters edges on input.
edgeInputFilterClass - Variable in class org.apache.giraph.conf.GiraphClasses
Edge Input Filter class
EdgeInputFormat<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io
Input format for reading single edges.
EdgeInputFormat() - Constructor for class org.apache.giraph.io.EdgeInputFormat
 
edgeInputFormatClass - Variable in class org.apache.giraph.conf.GiraphClasses
Edge input format class - cached for fast access
EdgeInputFormatDescription<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io.formats.multi
Description of the edge input format - holds edge input format class and all parameters specifically set for that edge input format.
EdgeInputFormatDescription(Class<? extends EdgeInputFormat<I, E>>) - Constructor for class org.apache.giraph.io.formats.multi.EdgeInputFormatDescription
Constructor with edge input format class
EdgeInputFormatDescription(String) - Constructor for class org.apache.giraph.io.formats.multi.EdgeInputFormatDescription
Constructor with json string describing this input format
EdgeInputSplitsCallable<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.worker
Load as many edge input splits as possible.
EdgeInputSplitsCallable(EdgeInputFormat<I, E>, Mapper<?, ?, ?, ?>.Context, ImmutableClassesGiraphConfiguration<I, V, E>, BspServiceWorker<I, V, E>, WorkerInputSplitsHandler) - Constructor for class org.apache.giraph.worker.EdgeInputSplitsCallable
Constructor.
EdgeInputSplitsCallableFactory<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.worker
EdgeInputSplitsCallableFactory(EdgeInputFormat<I, E>, Mapper<?, ?, ?, ?>.Context, ImmutableClassesGiraphConfiguration<I, V, E>, BspServiceWorker<I, V, E>, WorkerInputSplitsHandler) - Constructor for class org.apache.giraph.worker.EdgeInputSplitsCallableFactory
Constructor.
edgeInputSplitsLoaded - Variable in class org.apache.giraph.worker.WorkerProgressStats
How many edge input splits were loaded until now
edgeInputSplitsSet() - Method in class org.apache.giraph.master.MasterProgress
Whether or not number of edge input splits was set yet
EdgeIterables - Class in org.apache.giraph.utils
Utility methods for iterables of edges.
EdgeNoValue<I extends org.apache.hadoop.io.WritableComparable> - Class in org.apache.giraph.edge
An edge that has no value.
EdgeOutputFormat<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
abstract class which can only write edges
EdgeOutputFormat() - Constructor for class org.apache.giraph.io.EdgeOutputFormat
 
edgeOutputFormatClass - Variable in class org.apache.giraph.conf.GiraphClasses
Edge output format class - cached for fast access
EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io
Analogous to org.apache.giraph.bsp.BspRecordReader for edges.
EdgeReader() - Constructor for class org.apache.giraph.io.EdgeReader
 
EdgeReaderWrapper<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io.iterables
Wraps GiraphReader for edges into EdgeReader
EdgeReaderWrapper(GiraphReader<EdgeWithSource<I, E>>) - Constructor for class org.apache.giraph.io.iterables.EdgeReaderWrapper
Constructor
EDGES_FILTERED - Static variable in interface org.apache.giraph.metrics.MetricNames
Total edges loaded
EDGES_FILTERED_PCT - Static variable in interface org.apache.giraph.metrics.MetricNames
Percent of edges filtered out
EDGES_FILTERED_UPDATE_PERIOD - Static variable in class org.apache.giraph.worker.EdgeInputSplitsCallable
How often to update filtered metrics
EDGES_NAME - Static variable in class org.apache.giraph.counters.GiraphStats
aggregate edges counter name
EDGES_PER_VERTEX - Static variable in class org.apache.giraph.benchmark.BenchmarkOption
Option for number of edges per vertex
EDGES_PER_VERTEX - Static variable in class org.apache.giraph.io.formats.PseudoRandomInputFormatConstants
Set the number of edges per vertex (pseudo-random destination).
EDGES_UPDATE_PERIOD - Static variable in class org.apache.giraph.worker.EdgeInputSplitsCallable
How often to update metrics and print info
edgesLoaded - Variable in class org.apache.giraph.worker.WorkerProgressStats
How many edges were loaded
EdgeStore<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.edge
Collects incoming edges for vertices owned by this worker.
EdgeStoreFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.edge
Factory to create a new Edge Store
edgeTranslationClass() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Get the class used for edge translation during vertex input
edgeTranslationInstance() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Instance of TranslateEdge that contains helper method for edge translation
EdgeValueFactory<E extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.factories
Factory class to create default edge values.
EdgeWithSource<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.io.iterables
Wrapper for edge and its source id
EdgeWithSource() - Constructor for class org.apache.giraph.io.iterables.EdgeWithSource
Constructor
EdgeWithSource(I, ReusableEdge<I, E>) - Constructor for class org.apache.giraph.io.iterables.EdgeWithSource
Constructor with source id and edge
EdgeWriter<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
 
EdgeWriter() - Constructor for class org.apache.giraph.io.EdgeWriter
 
EGDE_BALANCE_ALGORITHM - Static variable in class org.apache.giraph.partition.PartitionBalancer
Rebalance across supersteps by edges
embedTargetInfo(LongWritable) - Method in class org.apache.giraph.mapping.DefaultEmbeddedLongByteOps
 
embedTargetInfo(LongWritable) - Method in class org.apache.giraph.mapping.DefaultLongByteOps
 
embedTargetInfo(I) - Method in interface org.apache.giraph.mapping.MappingStoreOps
Embed target information into vertexId
EMERGENCY_MEMORY_PRESSURE - Static variable in class org.apache.giraph.ooc.policy.ThresholdBasedOracle
The memory pressure at which the job is cloe to fail, even though we were using maximal disk bandwidth and minimal network rate.
EmptyIterable<T> - Class in org.apache.giraph.utils
Singleton class for empty iterables.
EmptyIterable() - Constructor for class org.apache.giraph.utils.EmptyIterable
 
encodeBytes(byte[]) - Static method in class org.apache.giraph.utils.ConfigurationObjectUtils
Encode bytes to a hex String
endOfInput() - Method in class org.apache.giraph.utils.ExtendedByteArrayDataInput
 
endOfInput() - Method in interface org.apache.giraph.utils.ExtendedDataInput
Check if we read everything from the input
endOfInput() - Method in class org.apache.giraph.utils.io.BigDataInput
 
endOfInput() - Method in class org.apache.giraph.utils.UnsafeArrayReads
 
ensureWritable(int) - Method in class org.apache.giraph.utils.ExtendedByteArrayDataOutput
 
ensureWritable(int) - Method in interface org.apache.giraph.utils.ExtendedDataOutput
Ensure that backing byte structure has at least minSize additional bytes
ensureWritable(int) - Method in class org.apache.giraph.utils.UnsafeByteArrayOutputStream
 
entrySerializedSize(T) - Method in class org.apache.giraph.ooc.data.DiskBackedDataStore
Gets the size of a given entry in bytes.
entrySerializedSize(VertexIdEdges<I, E>) - Method in class org.apache.giraph.ooc.data.DiskBackedEdgeStore
 
entrySerializedSize(VertexIdMessages<I, M>) - Method in class org.apache.giraph.ooc.data.DiskBackedMessageStore
 
entrySerializedSize(ExtendedDataOutput) - Method in class org.apache.giraph.ooc.data.DiskBackedPartitionStore
 
EnumConfOption<T extends Enum<T>> - Class in org.apache.giraph.conf
Enum Configuration option
EnumConfOption(String, Class<T>, T, String) - Constructor for class org.apache.giraph.conf.EnumConfOption
Constructor
equal(Edge<I, E>, Edge<I, E>) - Static method in class org.apache.giraph.utils.EdgeComparator
Indicates whether two edges are equal.
equals(Object) - Method in class org.apache.giraph.comm.netty.handler.ClientRequestId
 
equals(Object) - Method in class org.apache.giraph.conf.AbstractConfOption
 
equals(Object) - Method in class org.apache.giraph.counters.CustomCounter
 
equals(Object) - Method in class org.apache.giraph.counters.GiraphHadoopCounter
 
equals(Object) - Method in class org.apache.giraph.graph.TaskInfo
 
equals(Object) - Method in class org.apache.giraph.jython.wrappers.JythonWrapperBase
 
equals(Object) - Method in class org.apache.giraph.jython.wrappers.JythonWritableWrapper
 
equals(Object) - Method in class org.apache.giraph.ooc.persistence.DataIndex
 
equals(Object) - Method in class org.apache.giraph.ooc.persistence.DataIndex.NumericIndexEntry
 
equals(Object) - Method in class org.apache.giraph.scripting.DeployedScript
 
equals(Object) - Method in class org.apache.giraph.types.JavaWritablePair
 
equals(Iterable<Edge<I, E>>, Iterable<Edge<I, E>>) - Static method in class org.apache.giraph.utils.EdgeIterables
Compare two edge iterables element-wise.
EVENT_WAIT_MSECS - Static variable in interface org.apache.giraph.conf.GiraphConstants
Millseconds to wait for an event before continuing
eventType() - Method in class com.yammer.metrics.core.NoOpTimer
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.apache.giraph.comm.netty.handler.RequestServerHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.apache.giraph.comm.netty.handler.ResponseClientHandler
 
exchangeVertexPartitions(Collection<? extends PartitionOwner>) - Method in interface org.apache.giraph.bsp.CentralizedServiceWorker
If desired by the user, vertex partitions are redistributed among workers according to the chosen WorkerGraphPartitioner.
exchangeVertexPartitions(Collection<? extends PartitionOwner>) - Method in class org.apache.giraph.worker.BspServiceWorker
 
execute(Runnable) - Method in class com.yammer.metrics.core.NoOpExecutorService
 
execute() - Method in class org.apache.giraph.graph.GraphTaskManager
Perform the work assigned to this compute node for this job run.
execute() - Method in class org.apache.giraph.ooc.command.IOCommand
Execute (load/store of data) the IO command, and change the data stores appropriately based on the data loaded/stored.
execute() - Method in class org.apache.giraph.ooc.command.LoadPartitionIOCommand
 
execute() - Method in class org.apache.giraph.ooc.command.StoreDataBufferIOCommand
 
execute() - Method in class org.apache.giraph.ooc.command.StoreIncomingMessageIOCommand
 
execute() - Method in class org.apache.giraph.ooc.command.StorePartitionIOCommand
 
execute() - Method in class org.apache.giraph.ooc.command.WaitIOCommand
 
exists(String, boolean) - Method in class org.apache.giraph.zk.ZooKeeperExt
Return the stat of the node of the given path.
exists(String, Watcher) - Method in class org.apache.giraph.zk.ZooKeeperExt
Return the stat of the node of the given path.
exportGiraphConfiguration(GiraphConfiguration, ApplicationId) - Static method in class org.apache.giraph.yarn.YarnUtils
Export our populated GiraphConfiguration as an XML file to be used by the ApplicationMaster's exec container, and register it with LocalResources.
ExtendedByteArrayDataInput - Class in org.apache.giraph.utils
Provides access to a internals of ByteArrayInputStream
ExtendedByteArrayDataInput(byte[]) - Constructor for class org.apache.giraph.utils.ExtendedByteArrayDataInput
Constructor
ExtendedByteArrayDataInput(byte[], int, int) - Constructor for class org.apache.giraph.utils.ExtendedByteArrayDataInput
Get access to portion of a byte array
ExtendedByteArrayDataOutput - Class in org.apache.giraph.utils
Adds some functionality to ByteArrayOutputStream, such as an option to write int value over previously written data and directly get the byte array.
ExtendedByteArrayDataOutput(byte[]) - Constructor for class org.apache.giraph.utils.ExtendedByteArrayDataOutput
Uses the byte array provided or if null, use a default size
ExtendedByteArrayDataOutput(byte[], int) - Constructor for class org.apache.giraph.utils.ExtendedByteArrayDataOutput
Uses the byte array provided at the given pos
ExtendedByteArrayDataOutput() - Constructor for class org.apache.giraph.utils.ExtendedByteArrayDataOutput
Creates a new byte array output stream.
ExtendedByteArrayDataOutput(int) - Constructor for class org.apache.giraph.utils.ExtendedByteArrayDataOutput
Creates a new byte array output stream, with a buffer capacity of the specified size, in bytes.
ExtendedByteArrayOutputBuffer - Class in org.apache.giraph.utils
Wraps a list of byte array outputs and provides convenient utilities on top of it
ExtendedByteArrayOutputBuffer(ImmutableClassesGiraphConfiguration<?, ?, ?>) - Constructor for class org.apache.giraph.utils.ExtendedByteArrayOutputBuffer
Constructor
ExtendedByteArrayOutputBuffer.IndexAndDataOut - Class in org.apache.giraph.utils
Holder for index & DataOutput objects
extendedDataInput - Variable in class org.apache.giraph.utils.ByteStructIterator
Data input
extendedDataInput - Variable in class org.apache.giraph.utils.ByteStructVertexIdIterator
Reader of the serialized edges
ExtendedDataInput - Interface in org.apache.giraph.utils
Add some functionality to data input
ExtendedDataInputOutput - Class in org.apache.giraph.utils.io
Wraps ExtendedDataOutput and ExtendedDataOutput to be able to write data and later read data from the same place
ExtendedDataInputOutput(ImmutableClassesGiraphConfiguration) - Constructor for class org.apache.giraph.utils.io.ExtendedDataInputOutput
Constructor
extendedDataOutput - Variable in class org.apache.giraph.utils.AbstractVertexIdData
Extended data output
ExtendedDataOutput - Interface in org.apache.giraph.utils
Add a few features to data output
extractAvailableWorkers() - Method in class org.apache.giraph.partition.WorkerGraphPartitionerImpl
Update availableWorkers

F

FacebookConfiguration - Class in org.apache.giraph.conf
Default configuration used in Facebook
FacebookConfiguration() - Constructor for class org.apache.giraph.conf.FacebookConfiguration
 
Factory() - Constructor for class org.apache.giraph.comm.messages.ByteArrayMessagesPerVertexStore.Factory
Constructor for reflection
Factory(PartitionSplitInfo<I>, ImmutableClassesGiraphConfiguration<I, ?, ?>) - Constructor for class org.apache.giraph.comm.messages.ByteArrayMessagesPerVertexStore.Factory
 
Factory(MasterGlobalCommHandler) - Constructor for class org.apache.giraph.comm.netty.handler.MasterRequestServerHandler.Factory
Constructor
Factory() - Constructor for class org.apache.giraph.comm.netty.handler.SaslServerHandler.Factory
Constructor
Factory(ServerData<I, V, E>) - Constructor for class org.apache.giraph.comm.netty.handler.WorkerRequestServerHandler.Factory
Constructor
factory(ImmutableClassesGiraphConfiguration) - Method in enum org.apache.giraph.graph.GraphType
Get factory for creating this graph type
Factory<T> - Interface in org.apache.giraph.utils
Factory for any kind of objects
factoryClassOption() - Method in enum org.apache.giraph.graph.GraphType
Get the option for the factory that creates this graph type
FAIL_FIRST_IPC_PORT_BIND_ATTEMPT - Static variable in interface org.apache.giraph.conf.GiraphConstants
Fail first IPC port binding attempt, simulate binding failure on real grid testing
FAIL_MEMORY_PRESSURE - Static variable in class org.apache.giraph.ooc.policy.ThresholdBasedOracle
The memory pressure at/above which the job would fail
FAIL_ON_EMPTY_INPUT - Static variable in interface org.apache.giraph.conf.GiraphConstants
Whether to fail the job or just warn when input is empty
failureCleanup(Exception) - Method in interface org.apache.giraph.bsp.CentralizedServiceMaster
Called when the job fails in order to let the Master do any cleanup.
failureCleanup() - Method in interface org.apache.giraph.bsp.CentralizedServiceWorker
Operations that will be called if there is a failure by a worker.
failureCleanup(Exception) - Method in class org.apache.giraph.master.BspServiceMaster
 
failureCleanup() - Method in class org.apache.giraph.worker.BspServiceWorker
 
FailWithEveryExceptionOccurred() - Constructor for class org.apache.giraph.graph.GraphTaskManager.FailWithEveryExceptionOccurred
 
FakeTime - Class in org.apache.giraph.time
Thread-safe implementation of Time for testing that can help get time based ordering of events when desired.
FakeTime() - Constructor for class org.apache.giraph.time.FakeTime
 
fastForEachW(Consumer<BooleanWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WBooleanArrayList
 
fastForEachW(Consumer<ByteWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WByteArrayList
 
fastForEachW(Consumer<DoubleWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WDoubleArrayList
 
fastForEachW(Consumer<FloatWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WFloatArrayList
 
fastForEachW(Consumer<IntWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WIntArrayList
 
fastForEachW(Consumer<LongWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WLongArrayList
 
fastForEachW(Consumer<T>) - Method in interface org.apache.giraph.types.ops.collections.WCollection
Traverse all elements of the collection, calling given function on each element.
fastForEachWhileW(Predicate<BooleanWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WBooleanArrayList
 
fastForEachWhileW(Predicate<ByteWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WByteArrayList
 
fastForEachWhileW(Predicate<DoubleWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WDoubleArrayList
 
fastForEachWhileW(Predicate<FloatWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WFloatArrayList
 
fastForEachWhileW(Predicate<IntWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WIntArrayList
 
fastForEachWhileW(Predicate<LongWritable>) - Method in class org.apache.giraph.types.ops.collections.array.WLongArrayList
 
fastForEachWhileW(Predicate<T>) - Method in interface org.apache.giraph.types.ops.collections.WCollection
Traverse all elements of the collection, calling given function on each element, or until predicate returns false.
fastIteratorW() - Method in class org.apache.giraph.types.ops.collections.array.WBooleanArrayList
 
fastIteratorW(BooleanWritable) - Method in class org.apache.giraph.types.ops.collections.array.WBooleanArrayList
 
fastIteratorW() - Method in class org.apache.giraph.types.ops.collections.array.WByteArrayList
 
fastIteratorW(ByteWritable) - Method in class org.apache.giraph.types.ops.collections.array.WByteArrayList
 
fastIteratorW() - Method in class org.apache.giraph.types.ops.collections.array.WDoubleArrayList
 
fastIteratorW(DoubleWritable) - Method in class org.apache.giraph.types.ops.collections.array.WDoubleArrayList
 
fastIteratorW() - Method in class org.apache.giraph.types.ops.collections.array.WFloatArrayList
 
fastIteratorW(FloatWritable) - Method in class org.apache.giraph.types.ops.collections.array.WFloatArrayList
 
fastIteratorW() - Method in class org.apache.giraph.types.ops.collections.array.WIntArrayList
 
fastIteratorW(IntWritable) - Method in class org.apache.giraph.types.ops.collections.array.WIntArrayList
 
fastIteratorW() - Method in class org.apache.giraph.types.ops.collections.array.WLongArrayList
 
fastIteratorW(LongWritable) - Method in class org.apache.giraph.types.ops.collections.array.WLongArrayList
 
fastIteratorW() - Method in interface org.apache.giraph.types.ops.collections.WCollection
Fast iterator over collection objects, which doesn't allocate new element for each returned element, and can be iterated multiple times using reset().
fastIteratorW(T) - Method in interface org.apache.giraph.types.ops.collections.WCollection
Fast iterator over collection objects, which doesn't allocate new element for each returned element, and can be iterated multiple times using reset().
fastKeyIterator() - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicInt2ObjectOpenHashMap
 
fastKeyIterator() - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicLong2ObjectOpenHashMap
 
fastKeyIterator() - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicObject2ObjectOpenHashMap
 
fastKeyIterator() - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap
Fast iterator over keys within this map, which doesn't allocate new element for each returned element.
FastUtilSerializer<T> - Class in org.apache.giraph.writable.kryo.serializers
Kryo Serializer for Fastutil collection class.
FastUtilSerializer(Kryo, Class<T>) - Constructor for class org.apache.giraph.writable.kryo.serializers.FastUtilSerializer
Creates and initializes new serializer for a given fastutil class.
fifteenMinuteRate() - Method in class com.yammer.metrics.core.NoOpMeter
 
fifteenMinuteRate() - Method in class com.yammer.metrics.core.NoOpTimer
 
FILENAME - Static variable in class org.apache.giraph.aggregators.TextAggregatorWriter
The filename of the outputfile
FileOutputFormatUtil - Class in org.apache.giraph.io.formats
Utility to access file output format in a way independent of current hadoop implementation.
FileUtils - Class in org.apache.giraph.utils
Helper class for filesystem operations during testing
FILLING_THRESHOLD_OF_DATAOUT_IN_BUFFER - Static variable in class org.apache.giraph.utils.ExtendedByteArrayOutputBuffer
This option sets the maximum fraction of a ExtendedDataOutput instance (stored in ExtendedByteArrayOutputBuffer) that can be filled
fillNextSuperstepMapsWhenReady(Set<Integer>, Map<String, Writable>, Map<String, Reducer<Object, Writable>>) - Method in class org.apache.giraph.comm.aggregators.AllAggregatorServerData
This function will wait until all aggregator requests from workers have arrived, and fill the maps for next superstep when ready.
fillW(int, int, T) - Method in interface org.apache.giraph.types.ops.collections.array.WArrayList
Sets given range of elements to a specified value.
fillW(int, int, BooleanWritable) - Method in class org.apache.giraph.types.ops.collections.array.WBooleanArrayList
 
fillW(int, int, ByteWritable) - Method in class org.apache.giraph.types.ops.collections.array.WByteArrayList
 
fillW(int, int, DoubleWritable) - Method in class org.apache.giraph.types.ops.collections.array.WDoubleArrayList
 
fillW(int, int, FloatWritable) - Method in class org.apache.giraph.types.ops.collections.array.WFloatArrayList
 
fillW(int, int, IntWritable) - Method in class org.apache.giraph.types.ops.collections.array.WIntArrayList
 
fillW(int, int, LongWritable) - Method in class org.apache.giraph.types.ops.collections.array.WLongArrayList
 
finalizeInput(boolean) - Method in class org.apache.giraph.ooc.persistence.InMemoryDataAccessor.InMemoryDataInputWrapper
 
finalizeInput(boolean) - Method in interface org.apache.giraph.ooc.persistence.OutOfCoreDataAccessor.DataInputWrapper
Finalize and close the DataInput used for persistence.
finalizeOutput() - Method in class org.apache.giraph.ooc.persistence.InMemoryDataAccessor.InMemoryDataOutputWrapper
 
finalizeOutput() - Method in interface org.apache.giraph.ooc.persistence.OutOfCoreDataAccessor.DataOutputWrapper
Finalize and close the DataOutput used for persistence.
finalizePartitionStats(Collection<PartitionStats>, PartitionStore<I, V, E>) - Method in interface org.apache.giraph.partition.WorkerGraphPartitioner
At the end of a superstep, workers have PartitionStats generated for each of their partitions.
finalizePartitionStats(Collection<PartitionStats>, PartitionStore<I, V, E>) - Method in class org.apache.giraph.partition.WorkerGraphPartitionerImpl
 
finalizeStore() - Method in interface org.apache.giraph.comm.messages.MessageStore
Called before start of computation in bspworker Since it is run from a single thread while the store is not being accessed by any other thread - this is ensured to be thread-safe
finalizeStore() - Method in class org.apache.giraph.comm.messages.primitives.IdByteArrayMessageStore
 
finalizeStore() - Method in class org.apache.giraph.comm.messages.primitives.IdOneMessagePerVertexStore
 
finalizeStore() - Method in class org.apache.giraph.comm.messages.primitives.IntFloatMessageStore
 
finalizeStore() - Method in class org.apache.giraph.comm.messages.primitives.long_id.LongAbstractListStore
 
finalizeStore() - Method in class org.apache.giraph.comm.messages.primitives.LongDoubleMessageStore
 
finalizeStore() - Method in class org.apache.giraph.comm.messages.queue.AsyncMessageStoreWrapper
 
finalizeStore() - Method in class org.apache.giraph.comm.messages.SimpleMessageStore
 
finalizeStore() - Method in class org.apache.giraph.ooc.data.DiskBackedMessageStore
 
FINISHED_VERTICES_NAME - Static variable in class org.apache.giraph.counters.GiraphStats
aggregate finished vertices counter name
FinishedSuperstepStats - Class in org.apache.giraph.graph
Immutable graph stats after the completion of a superstep
FinishedSuperstepStats(long, boolean, long, long, boolean, CheckpointStatus) - Constructor for class org.apache.giraph.graph.FinishedSuperstepStats
Constructor.
finishLoadingEdges() - Method in class org.apache.giraph.worker.WorkerProgress
Notify this class that worker finished loading edges
finishLoadingVertices() - Method in class org.apache.giraph.worker.WorkerProgress
Notify this class that worker finished loading vertices
finishSendingValues() - Method in interface org.apache.giraph.comm.MasterClient
Flush aggregated values cache.
finishSendingValues() - Method in class org.apache.giraph.comm.netty.NettyMasterClient
 
finishStoring() - Method in class org.apache.giraph.worker.WorkerProgress
Notify this class that storing data is done
finishSuperstep(List<PartitionStats>, GiraphTimerContext) - Method in interface org.apache.giraph.bsp.CentralizedServiceWorker
Worker is done with its portion of the superstep.
finishSuperstep() - Method in class org.apache.giraph.master.MasterAggregatorHandler
Finalize aggregators for current superstep
finishSuperstep(List<PartitionStats>, GiraphTimerContext) - Method in class org.apache.giraph.worker.BspServiceWorker
 
finishSuperstep(WorkerAggregatorRequestProcessor) - Method in class org.apache.giraph.worker.WorkerAggregatorHandler
Send aggregators to their owners and in the end to the master
finishThreadComputation() - Method in class org.apache.giraph.worker.WorkerAggregatorHandler
 
finishThreadComputation() - Method in class org.apache.giraph.worker.WorkerAggregatorHandler.ThreadLocalWorkerGlobalCommUsage
 
finishThreadComputation() - Method in interface org.apache.giraph.worker.WorkerThreadGlobalCommUsage
Call this after thread's computation is finished, i.e.
firstList - Variable in class org.apache.giraph.utils.PairList
List to keep first elements of pairs in
firstToken() - Method in class org.apache.giraph.comm.netty.SaslNettyClient
Used by authenticateOnChannel() to initiate SASL handshake with server.
fiveMinuteRate() - Method in class com.yammer.metrics.core.NoOpMeter
 
fiveMinuteRate() - Method in class com.yammer.metrics.core.NoOpTimer
 
FixedCapacityIntByteMinHeap - Class in org.apache.giraph.types.heaps
Min heap which holds (int key, byte value) pairs with the largest values as its elements, up to the given maximum number of elements.
FixedCapacityIntByteMinHeap(int) - Constructor for class org.apache.giraph.types.heaps.FixedCapacityIntByteMinHeap
Initialize the heap with desired capacity
FixedCapacityIntDoubleMinHeap - Class in org.apache.giraph.types.heaps
Min heap which holds (int key, double value) pairs with the largest values as its elements, up to the given maximum number of elements.
FixedCapacityIntDoubleMinHeap(int) - Constructor for class org.apache.giraph.types.heaps.FixedCapacityIntDoubleMinHeap
Initialize the heap with desired capacity
FixedCapacityIntFloatMinHeap - Class in org.apache.giraph.types.heaps
Min heap which holds (int key, float value) pairs with the largest values as its elements, up to the given maximum number of elements.
FixedCapacityIntFloatMinHeap(int) - Constructor for class org.apache.giraph.types.heaps.FixedCapacityIntFloatMinHeap
Initialize the heap with desired capacity
FixedCapacityIntIntMinHeap - Class in org.apache.giraph.types.heaps
Min heap which holds (int key, int value) pairs with the largest values as its elements, up to the given maximum number of elements.
FixedCapacityIntIntMinHeap(int) - Constructor for class org.apache.giraph.types.heaps.FixedCapacityIntIntMinHeap
Initialize the heap with desired capacity
FixedCapacityIntLongMinHeap - Class in org.apache.giraph.types.heaps
Min heap which holds (int key, long value) pairs with the largest values as its elements, up to the given maximum number of elements.
FixedCapacityIntLongMinHeap(int) - Constructor for class org.apache.giraph.types.heaps.FixedCapacityIntLongMinHeap
Initialize the heap with desired capacity
FixedCapacityLongByteMinHeap - Class in org.apache.giraph.types.heaps
Min heap which holds (long key, byte value) pairs with the largest values as its elements, up to the given maximum number of elements.
FixedCapacityLongByteMinHeap(int) - Constructor for class org.apache.giraph.types.heaps.FixedCapacityLongByteMinHeap
Initialize the heap with desired capacity
FixedCapacityLongDoubleMinHeap - Class in org.apache.giraph.types.heaps
Min heap which holds (long key, double value) pairs with the largest values as its elements, up to the given maximum number of elements.
FixedCapacityLongDoubleMinHeap(int) - Constructor for class org.apache.giraph.types.heaps.FixedCapacityLongDoubleMinHeap
Initialize the heap with desired capacity
FixedCapacityLongFloatMinHeap - Class in org.apache.giraph.types.heaps
Min heap which holds (long key, float value) pairs with the largest values as its elements, up to the given maximum number of elements.
FixedCapacityLongFloatMinHeap(int) - Constructor for class org.apache.giraph.types.heaps.FixedCapacityLongFloatMinHeap
Initialize the heap with desired capacity
FixedCapacityLongIntMinHeap - Class in org.apache.giraph.types.heaps
Min heap which holds (long key, int value) pairs with the largest values as its elements, up to the given maximum number of elements.
FixedCapacityLongIntMinHeap(int) - Constructor for class org.apache.giraph.types.heaps.FixedCapacityLongIntMinHeap
Initialize the heap with desired capacity
FixedCapacityLongLongMinHeap - Class in org.apache.giraph.types.heaps
Min heap which holds (long key, long value) pairs with the largest values as its elements, up to the given maximum number of elements.
FixedCapacityLongLongMinHeap(int) - Constructor for class org.apache.giraph.types.heaps.FixedCapacityLongLongMinHeap
Initialize the heap with desired capacity
FixedPartitionsOracle - Class in org.apache.giraph.ooc.policy
Oracle for fixed out-of-core mechanism
FixedPartitionsOracle(ImmutableClassesGiraphConfiguration, OutOfCoreEngine) - Constructor for class org.apache.giraph.ooc.policy.FixedPartitionsOracle
Constructor
FLOAT - Static variable in class org.apache.giraph.combiner.MaxMessageCombiner
DoubleWritable specialization
FLOAT - Static variable in class org.apache.giraph.combiner.SumMessageCombiner
DoubleWritable specialization
Float2FloatFunction - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (float) -> float
Float2ObjFunction<T> - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (float) -> T
FLOAT_DOUBLE_WRITABLE - Static variable in class org.apache.giraph.types.JavaWritablePair
Float,DoubleWritable
FLOAT_FLOAT_WRITABLE - Static variable in class org.apache.giraph.types.JavaWritablePair
Float,FloatWritable
FloatBooleanConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, boolean) -> void
FloatBooleanPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, boolean) -> boolean
FloatByteConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, byte) -> void
FloatBytePredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, byte) -> boolean
FloatConfOption - Class in org.apache.giraph.conf
Float Configuration option
FloatConfOption(String, float, String) - Constructor for class org.apache.giraph.conf.FloatConfOption
Constructor
FloatConsumer - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (float) -> void
FloatDenseMatrix - Class in org.apache.giraph.aggregators.matrix.dense
A float matrix holds the values of the entries in float vectors.
FloatDenseMatrix(int) - Constructor for class org.apache.giraph.aggregators.matrix.dense.FloatDenseMatrix
Create a new matrix with the same number of rows and columns.
FloatDenseMatrix(int, int) - Constructor for class org.apache.giraph.aggregators.matrix.dense.FloatDenseMatrix
Create a new matrix with the given number of rows and columns.
FloatDenseMatrixSumAggregator - Class in org.apache.giraph.aggregators.matrix.dense
The float dense matrix aggregator is used to register and aggregate float dense matrices.
FloatDenseMatrixSumAggregator(String) - Constructor for class org.apache.giraph.aggregators.matrix.dense.FloatDenseMatrixSumAggregator
Create a new matrix aggregator with the given prefix name for the vector aggregators.
FloatDenseVector - Class in org.apache.giraph.aggregators.matrix.dense
The float dense vector holds the values of a particular row.
FloatDenseVector() - Constructor for class org.apache.giraph.aggregators.matrix.dense.FloatDenseVector
Create a new vector with default size.
FloatDenseVector(int) - Constructor for class org.apache.giraph.aggregators.matrix.dense.FloatDenseVector
Create a new vector with given size.
FloatDenseVectorSumAggregator - Class in org.apache.giraph.aggregators.matrix.dense
The float dense vector aggregator is used to aggregate float dense vectors.
FloatDenseVectorSumAggregator() - Constructor for class org.apache.giraph.aggregators.matrix.dense.FloatDenseVectorSumAggregator
 
FloatDoubleConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, double) -> void
FloatDoublePredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, double) -> boolean
FloatEdgeValue() - Constructor for class org.apache.giraph.mapping.translate.LongByteTranslateEdge.FloatEdgeValue
 
FloatFloatConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, float) -> void
FloatFloatPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, float) -> boolean
FloatIntConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, int) -> void
FloatIntPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, int) -> boolean
FloatLongConsumer - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, long) -> void
FloatLongPredicate - Interface in org.apache.giraph.function.primitive.pairs
Primitive specialization of Function: (float, long) -> boolean
FloatMaxAggregator - Class in org.apache.giraph.aggregators
Aggregator for getting max float value.
FloatMaxAggregator() - Constructor for class org.apache.giraph.aggregators.FloatMaxAggregator
 
FloatMinAggregator - Class in org.apache.giraph.aggregators
Aggregator for getting min float value.
FloatMinAggregator() - Constructor for class org.apache.giraph.aggregators.FloatMinAggregator
 
FloatOverwriteAggregator - Class in org.apache.giraph.aggregators
Aggregator that stores a value that is overwritten once another value is aggregated.
FloatOverwriteAggregator() - Constructor for class org.apache.giraph.aggregators.FloatOverwriteAggregator
 
FloatPredicate - Interface in org.apache.giraph.function.primitive
Primitive specialization of Function: (float) -> boolean
FloatProductAggregator - Class in org.apache.giraph.aggregators
Aggregator for calculating products of float values.
FloatProductAggregator() - Constructor for class org.apache.giraph.aggregators.FloatProductAggregator
 
FloatRef(float) - Constructor for class org.apache.giraph.function.primitive.PrimitiveRefs.FloatRef
Constructor
FloatSparseMatrix - Class in org.apache.giraph.aggregators.matrix.sparse
A float matrix holds the values of the entries in float vectors.
FloatSparseMatrix(int) - Constructor for class org.apache.giraph.aggregators.matrix.sparse.FloatSparseMatrix
Create a new matrix with the given number of rows.
FloatSparseMatrixSumAggregator - Class in org.apache.giraph.aggregators.matrix.sparse
The float matrix aggregator is used to register and aggregate float matrices.
FloatSparseMatrixSumAggregator(String) - Constructor for class org.apache.giraph.aggregators.matrix.sparse.FloatSparseMatrixSumAggregator
Create a new matrix aggregator with the given prefix name for the vector aggregators.
FloatSparseVector - Class in org.apache.giraph.aggregators.matrix.sparse
The float vector holds the values of a particular row.
FloatSparseVector() - Constructor for class org.apache.giraph.aggregators.matrix.sparse.FloatSparseVector
Create a new vector with default size.
FloatSparseVector(int) - Constructor for class org.apache.giraph.aggregators.matrix.sparse.FloatSparseVector
Create a new vector with given size.
FloatSparseVectorSumAggregator - Class in org.apache.giraph.aggregators.matrix.sparse
The float vector aggregator is used to aggregate float vectors.
FloatSparseVectorSumAggregator() - Constructor for class org.apache.giraph.aggregators.matrix.sparse.FloatSparseVectorSumAggregator
 
FloatSumAggregator - Class in org.apache.giraph.aggregators
Aggregator for summing up float values.
FloatSumAggregator() - Constructor for class org.apache.giraph.aggregators.FloatSumAggregator
 
FloatSumMessageCombiner - Class in org.apache.giraph.combiner
Deprecated.
FloatSumMessageCombiner() - Constructor for class org.apache.giraph.combiner.FloatSumMessageCombiner
Deprecated.
 
FloatToDoubleWritableWrapper - Class in org.apache.giraph.types
Converts Floats to DoubleWritables
FloatToDoubleWritableWrapper() - Constructor for class org.apache.giraph.types.FloatToDoubleWritableWrapper
 
FloatToFloatWritableWrapper - Class in org.apache.giraph.types
Converts Floats to FloatWritables
FloatToFloatWritableWrapper() - Constructor for class org.apache.giraph.types.FloatToFloatWritableWrapper
 
FloatTypeOps - Enum in org.apache.giraph.types.ops
TypeOps implementation for working with FloatWritable type
FloatWritableToDoubleUnwrapper - Class in org.apache.giraph.types
Converts FloatWritables to Doubles
FloatWritableToDoubleUnwrapper() - Constructor for class org.apache.giraph.types.FloatWritableToDoubleUnwrapper
 
FloatWritableToFloatUnwrapper - Class in org.apache.giraph.types
Converts FloatWritables to Floats
FloatWritableToFloatUnwrapper() - Constructor for class org.apache.giraph.types.FloatWritableToFloatUnwrapper
 
FlowControl - Interface in org.apache.giraph.comm.flow_control
Interface representing flow control policy in sending requests
flowControl - Variable in class org.apache.giraph.comm.netty.handler.RequestServerHandler
Flow control used in sending requests
flush() - Method in class org.apache.giraph.comm.aggregators.CountingOutputStream
Returns all the data from the stream and clears it.
flush() - Method in interface org.apache.giraph.comm.aggregators.WorkerAggregatorRequestProcessor
Flush aggregated values cache.
flush() - Method in interface org.apache.giraph.comm.MasterClient
Flush all outgoing messages.
flush() - Method in class org.apache.giraph.comm.netty.NettyMasterClient
 
flush() - Method in class org.apache.giraph.comm.netty.NettyWorkerAggregatorRequestProcessor
 
flush() - Method in class org.apache.giraph.comm.netty.NettyWorkerClientRequestProcessor
 
flush() - Method in class org.apache.giraph.comm.SendMessageCache
Flush the rest of the messages to the workers.
flush() - Method in class org.apache.giraph.comm.SendOneMessageToManyCache
 
flush() - Method in interface org.apache.giraph.comm.WorkerClientRequestProcessor
Flush all outgoing messages.
FORCE_CHECKPOINT_USER_FLAG - Static variable in class org.apache.giraph.bsp.BspService
User sets this flag to checkpoint and stop the job
forEachBoolean(BooleanConsumer) - Method in class org.apache.giraph.types.ops.collections.array.WBooleanArrayList
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachBoolean(BooleanConsumer) - Method in interface org.apache.giraph.types.ops.collections.WBooleanCollection
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachByte(ByteConsumer) - Method in class org.apache.giraph.types.ops.collections.array.WByteArrayList
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachByte(ByteConsumer) - Method in interface org.apache.giraph.types.ops.collections.WByteCollection
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachDouble(DoubleConsumer) - Method in class org.apache.giraph.types.ops.collections.array.WDoubleArrayList
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachDouble(DoubleConsumer) - Method in interface org.apache.giraph.types.ops.collections.WDoubleCollection
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachFloat(FloatConsumer) - Method in class org.apache.giraph.types.ops.collections.array.WFloatArrayList
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachFloat(FloatConsumer) - Method in interface org.apache.giraph.types.ops.collections.WFloatCollection
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachInt(IntConsumer) - Method in class org.apache.giraph.types.ops.collections.array.WIntArrayList
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachInt(IntConsumer) - Method in interface org.apache.giraph.types.ops.collections.WIntCollection
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachIntByte(IntByteConsumer) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntByteMinHeap
Traverse all elements of the heap, calling given function on each element.
forEachIntDouble(IntDoubleConsumer) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntDoubleMinHeap
Traverse all elements of the heap, calling given function on each element.
forEachIntFloat(IntFloatConsumer) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntFloatMinHeap
Traverse all elements of the heap, calling given function on each element.
forEachIntInt(IntIntConsumer) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntIntMinHeap
Traverse all elements of the heap, calling given function on each element.
forEachIntLong(IntLongConsumer) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntLongMinHeap
Traverse all elements of the heap, calling given function on each element.
forEachLong(LongConsumer) - Method in class org.apache.giraph.types.ops.collections.array.WLongArrayList
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachLong(LongConsumer) - Method in interface org.apache.giraph.types.ops.collections.WLongCollection
Traverse all elements of the array list, calling given function on each element, or until predicate returns false.
forEachLongByte(LongByteConsumer) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongByteMinHeap
Traverse all elements of the heap, calling given function on each element.
forEachLongDouble(LongDoubleConsumer) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongDoubleMinHeap
Traverse all elements of the heap, calling given function on each element.
forEachLongFloat(LongFloatConsumer) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongFloatMinHeap
Traverse all elements of the heap, calling given function on each element.
forEachLongInt(LongIntConsumer) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongIntMinHeap
Traverse all elements of the heap, calling given function on each element.
forEachLongLong(LongLongConsumer) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongLongMinHeap
Traverse all elements of the heap, calling given function on each element.
forEachWhileBoolean(BooleanPredicate) - Method in class org.apache.giraph.types.ops.collections.array.WBooleanArrayList
Traverse all elements of the array list, calling given function on each element.
forEachWhileBoolean(BooleanPredicate) - Method in interface org.apache.giraph.types.ops.collections.WBooleanCollection
Traverse all elements of the array list, calling given function on each element.
forEachWhileByte(BytePredicate) - Method in class org.apache.giraph.types.ops.collections.array.WByteArrayList
Traverse all elements of the array list, calling given function on each element.
forEachWhileByte(BytePredicate) - Method in interface org.apache.giraph.types.ops.collections.WByteCollection
Traverse all elements of the array list, calling given function on each element.
forEachWhileDouble(DoublePredicate) - Method in class org.apache.giraph.types.ops.collections.array.WDoubleArrayList
Traverse all elements of the array list, calling given function on each element.
forEachWhileDouble(DoublePredicate) - Method in interface org.apache.giraph.types.ops.collections.WDoubleCollection
Traverse all elements of the array list, calling given function on each element.
forEachWhileFloat(FloatPredicate) - Method in class org.apache.giraph.types.ops.collections.array.WFloatArrayList
Traverse all elements of the array list, calling given function on each element.
forEachWhileFloat(FloatPredicate) - Method in interface org.apache.giraph.types.ops.collections.WFloatCollection
Traverse all elements of the array list, calling given function on each element.
forEachWhileInt(IntPredicate) - Method in class org.apache.giraph.types.ops.collections.array.WIntArrayList
Traverse all elements of the array list, calling given function on each element.
forEachWhileInt(IntPredicate) - Method in interface org.apache.giraph.types.ops.collections.WIntCollection
Traverse all elements of the array list, calling given function on each element.
forEachWhileIntByte(IntBytePredicate) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntByteMinHeap
Traverse all elements of the heap, calling given function on each element, or until predicate returns false.
forEachWhileIntDouble(IntDoublePredicate) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntDoubleMinHeap
Traverse all elements of the heap, calling given function on each element, or until predicate returns false.
forEachWhileIntFloat(IntFloatPredicate) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntFloatMinHeap
Traverse all elements of the heap, calling given function on each element, or until predicate returns false.
forEachWhileIntInt(IntIntPredicate) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntIntMinHeap
Traverse all elements of the heap, calling given function on each element, or until predicate returns false.
forEachWhileIntLong(IntLongPredicate) - Method in class org.apache.giraph.types.heaps.FixedCapacityIntLongMinHeap
Traverse all elements of the heap, calling given function on each element, or until predicate returns false.
forEachWhileLong(LongPredicate) - Method in class org.apache.giraph.types.ops.collections.array.WLongArrayList
Traverse all elements of the array list, calling given function on each element.
forEachWhileLong(LongPredicate) - Method in interface org.apache.giraph.types.ops.collections.WLongCollection
Traverse all elements of the array list, calling given function on each element.
forEachWhileLongByte(LongBytePredicate) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongByteMinHeap
Traverse all elements of the heap, calling given function on each element, or until predicate returns false.
forEachWhileLongDouble(LongDoublePredicate) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongDoubleMinHeap
Traverse all elements of the heap, calling given function on each element, or until predicate returns false.
forEachWhileLongFloat(LongFloatPredicate) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongFloatMinHeap
Traverse all elements of the heap, calling given function on each element, or until predicate returns false.
forEachWhileLongInt(LongIntPredicate) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongIntMinHeap
Traverse all elements of the heap, calling given function on each element, or until predicate returns false.
forEachWhileLongLong(LongLongPredicate) - Method in class org.apache.giraph.types.heaps.FixedCapacityLongLongMinHeap
Traverse all elements of the heap, calling given function on each element, or until predicate returns false.
FRACTION_OF_REQUESTS_TO_CLOSE_BEFORE_PROCEEDING - Static variable in class org.apache.giraph.comm.flow_control.StaticFlowControl
After pausing a thread due to too large number of open requests, which fraction of these requests need to be closed before we continue
FREE_MEMORY_FRACTION_FOR_GC - Static variable in class org.apache.giraph.worker.MemoryObserver
For which fraction of free memory will we issue manual gc calls
freeMemoryFraction() - Static method in class org.apache.giraph.utils.MemoryUtils
Get fraction of memory that's free
freeMemoryFraction - Variable in class org.apache.giraph.worker.WorkerProgressStats
Fraction of memory that's free
freeMemoryMB() - Static method in class org.apache.giraph.utils.MemoryUtils
Get free memory in megabytes
freeMemoryMB - Variable in class org.apache.giraph.worker.WorkerProgressStats
Free memory
freePlusUnallocatedMemoryMB() - Static method in class org.apache.giraph.utils.MemoryUtils
Get free plus unallocated memory in megabytes
FREQUENCY - Static variable in class org.apache.giraph.aggregators.TextAggregatorWriter
The frequency of writing: - NEVER: never write, files aren't created at all - AT_THE_END: aggregators are written only when the computation is over - int: i.e.
fromByteArray(byte[], T) - Static method in class org.apache.giraph.utils.WritableUtils
Deserialize from given byte array into given writable, using new instance of ExtendedByteArrayDataInput.
fromByteArrayUnsafe(byte[], T, UnsafeReusableByteArrayInput) - Static method in class org.apache.giraph.utils.WritableUtils
Deserialize from given byte array into given writable, using given reusable UnsafeReusableByteArrayInput.
fromName(String) - Static method in class org.apache.giraph.zk.ComputationDoneName
Create this object from a name (if possible).
Function<F,T> - Interface in org.apache.giraph.function
Function: (F) -> T
FunctionWithVertex<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,F,T> - Interface in org.apache.giraph.function.vertex
Function: (vertex, F) -> T Determines an output value based on a vertex and an input value.
funnel(LongWritable, PrimitiveSink) - Method in enum org.apache.giraph.utils.hashing.LongWritableFunnel
 

G

GC_MINIMUM_RECLAIM_FRACTION - Static variable in class org.apache.giraph.ooc.policy.MemoryEstimatorOracle
Used to detect a high memory pressure situation
GC_OBSERVER_CLASSES - Static variable in interface org.apache.giraph.conf.GiraphConstants
Classes for GC Observer - optional
gcCompleted(GarbageCollectionNotificationInfo) - Method in class org.apache.giraph.ooc.OutOfCoreEngine
Notify the out-of-core engine that a GC has just been completed
gcCompleted(GarbageCollectionNotificationInfo) - Method in class org.apache.giraph.ooc.policy.FixedPartitionsOracle
 
gcCompleted(GarbageCollectionNotificationInfo) - Method in class org.apache.giraph.ooc.policy.MemoryEstimatorOracle
When a new GC has completed, we can get an accurate measurement of the memory usage.
gcCompleted(GarbageCollectionNotificationInfo) - Method in interface org.apache.giraph.ooc.policy.OutOfCoreOracle
Notification of GC completion.
gcCompleted(GarbageCollectionNotificationInfo) - Method in class org.apache.giraph.ooc.policy.SimpleGCMonitoringOracle
 
gcCompleted(GarbageCollectionNotificationInfo) - Method in class org.apache.giraph.ooc.policy.ThresholdBasedOracle
 
GcObserver - Interface in org.apache.giraph.utils
Observer for when GCs occur
gcOccurred(GarbageCollectionNotificationInfo) - Method in interface org.apache.giraph.utils.GcObserver
Called to notify that GC occurred
gcOccurred(GcInfo) - Method in class org.apache.giraph.utils.GcTracker
Called to notify gc tracker that gc occurred
gcTimeSpentSince(long) - Method in class org.apache.giraph.utils.GcTracker
Check how much time was spent doing gc since some timestamp
GcTracker - Class in org.apache.giraph.utils
Tracks last k GC pauses and is able to tell how much time was spent doing GC since some point in time.
GcTracker() - Constructor for class org.apache.giraph.utils.GcTracker
Constructor with default number of last gcs to keep
GcTracker(Configuration) - Constructor for class org.apache.giraph.utils.GcTracker
Constructor with configuration
generateChangedPartitionOwners(Collection<PartitionStats>, Collection<WorkerInfo>, int, long) - Method in interface org.apache.giraph.partition.MasterGraphPartitioner
After the worker stats have been merged to a single list, the master can use this information to send commands to the workers for any Partition changes.
generateChangedPartitionOwners(Collection<PartitionStats>, Collection<WorkerInfo>, int, long) - Method in class org.apache.giraph.partition.MasterGraphPartitionerImpl
 
generateDestVertex(int, Random) - Method in class org.apache.giraph.io.formats.PseudoRandomIntNullLocalEdgesHelper
Generate a destination vertex id for the given source vertex, using the desired configuration for edge locality and the provided pseudo-random generator.
generateDestVertex(long, Random) - Method in class org.apache.giraph.io.formats.PseudoRandomLocalEdgesHelper
Generate a destination vertex id for the given source vertex, using the desired configuration for edge locality and the provided pseudo-random generator.
GeneratedVertexInputFormat<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.formats
This VertexInputFormat is meant for testing/debugging.
GeneratedVertexInputFormat() - Constructor for class org.apache.giraph.io.formats.GeneratedVertexInputFormat
 
get(int, int) - Method in class org.apache.giraph.aggregators.matrix.dense.DoubleDenseMatrix
Get a specific entry of the matrix.
get(int) - Method in class org.apache.giraph.aggregators.matrix.dense.DoubleDenseVector
Get a particular entry of the vector.
get(int, int) - Method in class org.apache.giraph.aggregators.matrix.dense.FloatDenseMatrix
Get a specific entry of the matrix.
get(int) - Method in class org.apache.giraph.aggregators.matrix.dense.FloatDenseVector
Get a particular entry of the vector.
get(int, int) - Method in class org.apache.giraph.aggregators.matrix.dense.IntDenseMatrix
Get a specific entry of the matrix.
get(int) - Method in class org.apache.giraph.aggregators.matrix.dense.IntDenseVector
Get a particular entry of the vector.
get(int, int) - Method in class org.apache.giraph.aggregators.matrix.dense.LongDenseMatrix
Get a specific entry of the matrix.
get(int) - Method in class org.apache.giraph.aggregators.matrix.dense.LongDenseVector
Get a particular entry of the vector.
get(int, int) - Method in class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseMatrix
Get a specific entry of the matrix.
get(int) - Method in class org.apache.giraph.aggregators.matrix.sparse.DoubleSparseVector
Get a particular entry of the vector.
get(int, int) - Method in class org.apache.giraph.aggregators.matrix.sparse.FloatSparseMatrix
Get a specific entry of the matrix.
get(int) - Method in class org.apache.giraph.aggregators.matrix.sparse.FloatSparseVector
Get a particular entry of the vector.
get(int, int) - Method in class org.apache.giraph.aggregators.matrix.sparse.IntSparseMatrix
Get a specific entry of the matrix.
get(int) - Method in class org.apache.giraph.aggregators.matrix.sparse.IntSparseVector
Get a particular entry of the vector.
get(int, int) - Method in class org.apache.giraph.aggregators.matrix.sparse.LongSparseMatrix
Get a specific entry of the matrix.
get(int) - Method in class org.apache.giraph.aggregators.matrix.sparse.LongSparseVector
Get a particular entry of the vector.
get(Configuration) - Method in class org.apache.giraph.conf.BooleanConfOption
Lookup value in Configuration
get(Configuration) - Method in class org.apache.giraph.conf.ClassConfOption
Lookup value
get(Configuration) - Method in class org.apache.giraph.conf.EnumConfOption
Lookup value
get(Configuration) - Method in class org.apache.giraph.conf.FloatConfOption
Lookup value
get(Configuration) - Method in class org.apache.giraph.conf.IntConfOption
Lookup value
get(Configuration, Class<T>) - Method in class org.apache.giraph.conf.JsonStringConfOption
Get JSON value
get(Configuration, TypeReference<T>) - Method in class org.apache.giraph.conf.JsonStringConfOption
Get JSON value
get(Configuration) - Method in class org.apache.giraph.conf.LongConfOption
Lookup value
get(GraphType) - Method in class org.apache.giraph.conf.PerGraphTypeBoolean
Get data for given GraphType
get(GraphType) - Method in class org.apache.giraph.conf.PerGraphTypeBooleanConfOption
Get option for given GraphType
get(GraphType) - Method in class org.apache.giraph.conf.PerGraphTypeEnum
Get data for given GraphType
get(GraphType) - Method in class org.apache.giraph.conf.PerGraphTypeEnumConfOption
Get option for given GraphType
get(Configuration) - Method in class org.apache.giraph.conf.StrConfOption
Lookup value
get() - Method in class org.apache.giraph.function.ObjectHolder
 
get() - Method in class org.apache.giraph.function.ObjectTransfer
 
get() - Method in interface org.apache.giraph.function.primitive.IntSupplier
Retrieves an int value.
get() - Method in interface org.apache.giraph.function.Supplier
Retrieves an instance of the appropriate type.
get(Vertex<I, V, E>) - Method in interface org.apache.giraph.function.vertex.SupplierFromVertex
Retrieves an instance of the appropriate type, given a vertex.
get(ImmutableClassesGiraphConfiguration) - Method in enum org.apache.giraph.graph.GraphType
Get class set by user for this option
get(Configuration) - Method in enum org.apache.giraph.graph.GraphType
Get class set by user for this option
get() - Static method in class org.apache.giraph.master.MasterProgress
Get singleton instance of MasterProgress.
get(String) - Method in class org.apache.giraph.metrics.AggregatedMetrics
Get AggregatedMetric with given name.
get() - Static method in class org.apache.giraph.metrics.GiraphMetrics
Get singleton instance of GiraphMetrics.
get() - Static method in class org.apache.giraph.metrics.MetricsRegistryDebugger
Get singleton static instance of this class.
get() - Static method in class org.apache.giraph.time.SystemTime
Get an instance (shared) of this object
get(Time, TimeUnit) - Static method in class org.apache.giraph.time.Times
Convenience method to measure time in a given TimeUnit.
get(IntWritable) - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicInt2ObjectOpenHashMap
 
get(LongWritable) - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicLong2ObjectOpenHashMap
 
get(K) - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap.BasicObject2ObjectOpenHashMap
 
get(K) - Method in class org.apache.giraph.types.ops.collections.Basic2ObjectMap
Get value for a given key
get() - Method in class org.apache.giraph.utils.ArrayWritable
Ger array
get() - Static method in class org.apache.giraph.utils.EmptyIterable
Get the singleton empty iterable
get() - Static method in class org.apache.giraph.utils.GiraphDepVersions
Get singleton instance
get() - Static method in class org.apache.giraph.worker.WorkerProgress
Get singleton instance of WorkerProgress.
get() - Method in interface org.apache.giraph.writable.kryo.Boxed
Gets the boxed value.
get() - Method in class org.apache.giraph.writable.kryo.KryoSimpleWrapper
Unwrap the object value
get() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapper
Unwrap the object value
get() - Method in class org.apache.giraph.writable.kryo.TransientRandom
Get instance of Random
getAckSignalFlag(int) - Method in class org.apache.giraph.comm.flow_control.CreditBasedFlowControl
Get the response flag from a response
getAckSignalFlag(int) - Method in interface org.apache.giraph.comm.flow_control.FlowControl
Decode the acknowledgement signal from the response after an open request is completed
getAckSignalFlag(int) - Method in class org.apache.giraph.comm.flow_control.NoOpFlowControl
 
getAckSignalFlag(int) - Method in class org.apache.giraph.comm.flow_control.StaticFlowControl
 
getAddedEdgeList() - Method in interface org.apache.giraph.graph.VertexChanges
Get the added edges for this particular vertex index from the previous superstep
getAddedEdgeList() - Method in class org.apache.giraph.graph.VertexMutations
 
getAddedVertexList() - Method in interface org.apache.giraph.graph.VertexChanges
Get the added vertices for this particular vertex index from the previous superstep.
getAddedVertexList() - Method in class org.apache.giraph.graph.VertexMutations
 
getAggregatedValue() - Method in interface org.apache.giraph.aggregators.Aggregator
Return current aggregated value.
getAggregatedValue(String) - Method in interface org.apache.giraph.aggregators.AggregatorUsage
Get value of an aggregator.
getAggregatedValue() - Method in class org.apache.giraph.aggregators.BasicAggregator
 
getAggregatedValue(String) - Method in class org.apache.giraph.master.AggregatorToGlobalCommTranslation
 
getAggregatedValue(String) - Method in class org.apache.giraph.master.MasterCompute
 
getAggregatedValue(String) - Method in class org.apache.giraph.worker.WorkerAggregatorDelegator
 
getAggregateOOCBytesLoaded() - Method in class org.apache.giraph.counters.GiraphStats
Get OOCBytesLoaded counter
getAggregateOOCBytesStored() - Method in class org.apache.giraph.counters.GiraphStats
Get OOCBytesStored counter
getAggregateSentMessageBytes() - Method in class org.apache.giraph.counters.GiraphStats
Get AggregateSentMessageBytes counter
getAggregateSentMessages() - Method in class org.apache.giraph.counters.GiraphStats
Get AggregateSentMessages counter
getAggregation() - Method in class org.apache.giraph.counters.CustomCounter
 
getAggregatorClass() - Method in class org.apache.giraph.master.AggregatorReduceOperation
 
getAggregatorHandler() - Method in interface org.apache.giraph.bsp.CentralizedServiceWorker
Get worker aggregator handler
getAggregatorHandler() - Method in class org.apache.giraph.master.MasterGlobalCommHandler
 
getAggregatorHandler() - Method in class org.apache.giraph.worker.BspServiceWorker
 
getAggregatorTranslationHandler() - Method in interface org.apache.giraph.bsp.CentralizedServiceMaster
Handler for aggregators to reduce/broadcast translation
getAggregatorTranslationHandler() - Method in class org.apache.giraph.master.BspServiceMaster
 
getAggregatorWriterClass() - Method in class org.apache.giraph.conf.GiraphClasses
Get AggregatorWriter used
getAggregatorWriterClass() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Get the user's subclassed AggregatorWriter.
getAll() - Method in class org.apache.giraph.metrics.AggregatedMetrics
Get map of all aggregated metrics.
getAll() - Method in class org.apache.giraph.metrics.GiraphMetricsRegistry
Get map of all metrics.
getAllAggregatorData() - Method in class org.apache.giraph.comm.ServerData
Get holder for aggregators from previous superstep
getAllEdgeValues(I) - Method in class org.apache.giraph.edge.HashMultimapEdges
 
getAllEdgeValues(I) - Method in interface org.apache.giraph.edge.MultiRandomAccessOutEdges
Return an iterable over the edge values for a given target vertex id.
getAllEdgeValues(I) - Method in class org.apache.giraph.graph.DefaultVertex
 
getAllEdgeValues(I) - Method in class org.apache.giraph.graph.OnlyIdVertex
 
getAllEdgeValues(I) - Method in interface org.apache.giraph.graph.Vertex
Get an iterable over the values of all edges with the given target vertex id.
getAllPartitionStats(int, Progressable) - Method in class org.apache.giraph.master.MasterGlobalCommHandler
Get all partition stats.
getAndClearCurrentWorkerToWorkerMessages() - Method in class org.apache.giraph.comm.ServerData
Get and clear worker to worker messages for this superstep.
getAndClearCustomCounters() - Static method in class org.apache.giraph.counters.CustomCounters
Get the unique counter group and names This will also clear the counters list, to avoid duplicate counters from the previous superstep from being sent to the zookeeper again
getAndClearMessagesFromOtherWorkers() - Method in class org.apache.giraph.worker.WorkerContext
Get messages which other workers sent to this worker and clear them (can be called once per superstep)
getAnnotatedClasses(Class<T>, String) - Static method in class org.apache.giraph.utils.AnnotationUtils
Finds all classes within a package which are annotated with certain annotation.
getApplicationAttempt() - Method in class org.apache.giraph.bsp.BspService
Get the latest application attempt and cache it.
getApplicationAttemptChangedEvent() - Method in class org.apache.giraph.bsp.BspService
 
getArray(Configuration) - Method in class org.apache.giraph.conf.ClassConfOption
Lookup array of classes for key
getArray(Configuration) - Method in class org.apache.giraph.conf.StrConfOption
Get array of values for key
getAuthenticated() - Method in class org.apache.giraph.comm.netty.SaslNettyClient
 
getBasePath(Configuration) - Static method in class org.apache.giraph.zk.ZooKeeperManager
Return the base ZooKeeper ZNode from which all other ZNodes Giraph creates should be sited, for instance in a multi-tenant ZooKeeper, the znode reserved for Giraph
getBaseReader() - Method in class org.apache.giraph.io.ReverseEdgeDuplicator
Get wrapped EdgeReader
getBenchmarkOptions() - Method in class org.apache.giraph.benchmark.AggregatorsBenchmark
 
getBenchmarkOptions() - Method in class org.apache.giraph.benchmark.GiraphBenchmark
Get the options to use in this benchmark.
getBenchmarkOptions() - Method in class org.apache.giraph.benchmark.PageRankBenchmark
 
getBenchmarkOptions() - Method in class org.apache.giraph.benchmark.RandomMessageBenchmark
 
getBenchmarkOptions() - Method in class org.apache.giraph.benchmark.ReducersBenchmark
 
getBenchmarkOptions() - Method in class org.apache.giraph.benchmark.ShortestPathsBenchmark
 
getBenchmarkOptions() - Method in class org.apache.giraph.benchmark.WeightedPageRankBenchmark
 
getBiasedHistogram(String) - Method in class org.apache.giraph.metrics.GiraphMetricsRegistry
Creates a new biased Histogram and registers it under the given group and name
getBroadcast(String) - Method in class org.apache.giraph.worker.WorkerAggregatorDelegator
 
getBroadcast(String) - Method in class org.apache.giraph.worker.WorkerAggregatorHandler
 
getBroadcast(String) - Method in class org.apache.giraph.worker.WorkerAggregatorHandler.ThreadLocalWorkerGlobalCommUsage
 
getBroadcast(String) - Method in interface org.apache.giraph.worker.WorkerBroadcastUsage
Get value broadcasted from master
getByteArray() - Method in class org.apache.giraph.utils.ByteArrayVertexIdData
Get the underlying byte-array.
getByteArray(String, Configuration) - Static method in class org.apache.giraph.utils.ConfigurationObjectUtils
Get byte array from a conf option
getByteArray() - Method in class org.apache.giraph.utils.ExtendedByteArrayDataOutput
 
getByteArray() - Method in interface org.apache.giraph.utils.ExtendedDataOutput
Get the internal byte array (if possible), read-only
getByteArray() - Method in class org.apache.giraph.utils.UnsafeByteArrayOutputStream
 
getBytes() - Method in class org.apache.giraph.ooc.OutOfCoreIOStatistics.BytesDuration
 
getBytesLoadedFromDisk() - Method in class org.apache.giraph.metrics.WorkerSuperstepMetrics
 
getBytesProcessed() - Method in class org.apache.giraph.comm.netty.ByteCounterDelegate
 
getBytesProcessedPerSuperstep() - Method in class org.apache.giraph.comm.netty.ByteCounterDelegate
Returns bytes processed per superstep.
getBytesReceived() - Method in class org.apache.giraph.comm.netty.InboundByteCounter
 
getBytesReceived() - Method in class org.apache.giraph.comm.netty.NettyWorkerServer
 
getBytesReceived() - Method in interface org.apache.giraph.comm.NetworkMetrics
Returns aggregate bytes received.
getBytesReceivedPerSuperstep() - Method in class org.apache.giraph.comm.netty.InboundByteCounter
Returns bytes received per superstep.
getBytesReceivedPerSuperstep() - Method in class org.apache.giraph.comm.netty.NettyWorkerServer
 
getBytesReceivedPerSuperstep() - Method in interface org.apache.giraph.comm.NetworkMetrics
Returns bytes received in current superstep
getBytesSent() - Method in class org.apache.giraph.comm.netty.OutboundByteCounter
 
getBytesStoredOnDisk() - Method in class org.apache.giraph.metrics.WorkerSuperstepMetrics
 
getByteTarget(LongWritable) - Method in class org.apache.giraph.mapping.LongByteMappingStore
Auxiliary method to be used by getTarget
getCandidateBuffersToOffload(int) - Method in class org.apache.giraph.ooc.data.DiskBackedDataStore
Looks through all partitions that their data is not in the data store (is offloaded to disk), and sees if any of them has enough raw data buffer in memory.
getCapacity() - Method in class org.apache.giraph.types.heaps.FixedCapacityIntByteMinHeap
Get capacity of the heap
getCapacity() - Method in class org.apache.giraph.types.heaps.FixedCapacityIntDoubleMinHeap
Get capacity of the heap
getCapacity() - Method in class org.apache.giraph.types.heaps.FixedCapacityIntFloatMinHeap
Get capacity of the heap
getCapacity() - Method in class org.apache.giraph.types.heaps.FixedCapacityIntIntMinHeap
Get capacity of the heap
getCapacity() - Method in class org.apache.giraph.types.heaps.FixedCapacityIntLongMinHeap
Get capacity of the heap
getCapacity() - Method in class org.apache.giraph.types.heaps.FixedCapacityLongByteMinHeap
Get capacity of the heap
getCapacity() - Method in class org.apache.giraph.types.heaps.FixedCapacityLongDoubleMinHeap
Get capacity of the heap
getCapacity() - Method in class org.apache.giraph.types.heaps.FixedCapacityLongFloatMinHeap
Get capacity of the heap
getCapacity() - Method in class org.apache.giraph.types.heaps.FixedCapacityLongIntMinHeap
Get capacity of the heap
getCapacity() - Method in class org.apache.giraph.types.heaps.FixedCapacityLongLongMinHeap
Get capacity of the heap
getChannels() - Method in class org.apache.giraph.comm.netty.ChannelRotater
Get a copy of the channels
getCheckpointBasePath(long) - Method in class org.apache.giraph.bsp.BspService
Generate the base superstep directory path for a given application attempt
getCheckpointBasePath(Configuration, String) - Static method in class org.apache.giraph.utils.CheckpointingUtils
Path to the checkpoint's root (including job id)
getCheckpointFrequency() - Method in class org.apache.giraph.conf.GiraphConfiguration
Get the checkpoint frequeuncy of how many supersteps to wait before checkpointing
getCheckpointMarkPath(Configuration, String) - Static method in class org.apache.giraph.utils.CheckpointingUtils
Path to checkpoint&halt node in hdfs.
getCheckpointStatus() - Method in class org.apache.giraph.graph.FinishedSuperstepStats
What master thinks about checkpointing after this superstep.
getCheckpointStatus() - Method in class org.apache.giraph.graph.GlobalStats
 
getChildrenExt(String, boolean, boolean, boolean) - Method in class org.apache.giraph.zk.ZooKeeperExt
Get the children of the path with extensions.
getClassesIterator(String) - Static method in class org.apache.giraph.utils.AnnotationUtils
 
getClassesOfType(Configuration, String, Class<T>, Class<? extends T>...) - Static method in class org.apache.giraph.conf.ClassConfOption
Get classes from a property that all implement a given interface.
getClassId(String) - Static method in class org.apache.giraph.writable.kryo.GiraphClassResolver
Gets ID for the given class name.
getClassName(int) - Static method in class org.apache.giraph.writable.kryo.GiraphClassResolver
Get class name for given ID.
getCleanedUpChildrenChangedEvent() - Method in class org.apache.giraph.bsp.BspService
 
getClientId() - Method in class org.apache.giraph.comm.requests.WritableRequest
 
getClientPortAddress() - Method in class org.apache.giraph.zk.ZookeeperConfig
Get zookeeper server address
getCommandTypeStats(IOCommand.IOCommandType) - Method in class org.apache.giraph.ooc.OutOfCoreIOStatistics
Get aggregate statistics of a given command type in the command history
getCommTimer() - Method in class org.apache.giraph.metrics.WorkerSuperstepMetrics
 
getComputation() - Method in class org.apache.giraph.master.MasterCompute
Get Computation class to be used
getComputation_name() - Method in class org.apache.giraph.jython.JythonJob
 
getComputationClass() - Method in class org.apache.giraph.conf.GiraphClasses
Get Computation class
getComputationClass() - Method in class org.apache.giraph.conf.GiraphConfiguration
Get the user's subclassed Computation
getComputationClass() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
 
getComputationClass() - Method in class org.apache.giraph.master.SuperstepClasses
 
getComputationFactoryClass() - Method in class org.apache.giraph.conf.GiraphClasses
 
getComputationFactoryClass() - Method in class org.apache.giraph.conf.GiraphConfiguration
Get the user's subclassed ComputationFactory
getComputationFactoryClass() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Get computation factory class
getComputationName() - Method in class org.apache.giraph.conf.GiraphConfiguration
Get name of computation being run.
getComputeAllTimer() - Method in class org.apache.giraph.metrics.WorkerSuperstepMetrics
 
getComputeMs() - Method in class org.apache.giraph.partition.PartitionStats
 
getConf() - Method in class org.apache.giraph.benchmark.GiraphBenchmark
 
getConf() - Method in class org.apache.giraph.comm.requests.WritableRequest
 
getConf() - Method in class org.apache.giraph.comm.SendDataCache
 
getConf() - Method in class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable
 
getConf() - Method in interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable
Return the configuration used by this object.
getConf() - Method in class org.apache.giraph.edge.IdAndNullArrayEdges
 
getConf() - Method in class org.apache.giraph.edge.IdAndValueArrayEdges
 
getConf() - Method in class org.apache.giraph.GiraphRunner
 
getConf() - Method in class org.apache.giraph.graph.GraphTaskManager
 
getConf() - Method in class org.apache.giraph.graph.VertexMutations
 
getConf() - Method in class org.apache.giraph.job.DefaultJobObserver
 
getConf() - Method in class org.apache.giraph.master.DefaultMasterObserver
 
getConf() - Method in class org.apache.giraph.partition.BasicPartition
 
getConf() - Method in class org.apache.giraph.partition.BasicPartitionOwner
 
getConf() - Method in class org.apache.giraph.utils.AbstractVertexIdData
 
getConf() - Method in class org.apache.giraph.utils.ArrayListWritable
 
getConf() - Method in class org.apache.giraph.utils.ByteArrayVertexIdEdges
Cast the ImmutableClassesGiraphConfiguration so it can be used to generate edge objects.
getConf() - Method in class org.apache.giraph.utils.io.BigDataOutput
 
getConf() - Method in class org.apache.giraph.utils.JMapHistoDumper
 
getConf() - Method in class org.apache.giraph.utils.LogVersions
 
getConf() - Method in class org.apache.giraph.utils.TestGraph
 
getConf() - Method in class org.apache.giraph.worker.DefaultWorkerObserver
 
getConf() - Method in class org.apache.giraph.zk.GiraphZooKeeperAdmin
 
getConf() - Method in class org.apache.giraph.zk.ZooKeeperNodeCreator
 
getConfiguration() - Method in class org.apache.giraph.bsp.BspService
 
getConfiguration() - Method in interface org.apache.giraph.bsp.CentralizedService
Get configuration
getConfiguration() - Method in class org.apache.giraph.job.GiraphJob
Get the configuration from the internal job.
getContext() - Method in class org.apache.giraph.bsp.BspService
 
getContext() - Method in class org.apache.giraph.counters.HadoopCountersBase
Get Hadoop Context
getContext() - Method in class org.apache.giraph.graph.AbstractComputation
Get the mapper context
getContext() - Method in interface org.apache.giraph.graph.Computation
Get the mapper context
getContext() - Method in class org.apache.giraph.graph.GraphState
 
getContext() - Method in class org.apache.giraph.io.formats.TextEdgeInputFormat.TextEdgeReader
Get the context.
getContext() - Method in class org.apache.giraph.io.formats.TextEdgeOutputFormat.TextEdgeWriter
Get the context.
getContext() - Method in class org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReader
Get the context.
getContext() - Method in class org.apache.giraph.io.formats.TextVertexOutputFormat.TextVertexWriter
Get the context.
getContext() - Method in class org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReader
Get the context.
getContext() - Method in class org.apache.giraph.jython.JythonComputation
Get the mapper context
getContext() - Method in class org.apache.giraph.master.MasterCompute
Get the mapper context
getContext() - Method in class org.apache.giraph.worker.WorkerContext
Get the mapper context
getCount(Integer) - Method in class org.apache.giraph.comm.aggregators.CountingCache
Get number of flushes for worker with desired task id
getCounter(String) - Method in class org.apache.giraph.counters.HadoopCountersBase
Get or create counter with given name and class's group name.
getCounter(String) - Method in class org.apache.giraph.metrics.GiraphMetricsRegistry
Creates a new Counter and registers it under the given group and name.
getCounterGroupAndNames() - Static method in class org.apache.giraph.master.input.MasterInputSplitsHandler
 
getCounterGroupsAndNames() - Static method in class org.apache.giraph.comm.netty.NettyClient
 
getCounterList() - Method in class org.apache.giraph.counters.CustomCounters
Get the counter list
getCounterList() - Method in class org.apache.giraph.counters.GiraphStats
Get a map of counter names, and values To be used by the master to send to the job client
getCounterList(long) - Method in class org.apache.giraph.counters.GiraphTimers
Get a map of counter names and values for the given superstep Counters include Setup, Initialise, Shutdown, Total, and time for the given superstep
getCounterName() - Method in class org.apache.giraph.counters.CustomCounter
 
getCounters() - Method in class org.apache.giraph.counters.GiraphCountersThriftStruct
 
getCreateSourceVertex() - Method in class org.apache.giraph.conf.GiraphConfiguration
Get option whether to create a source vertex present only in edge input
getCurrentData() - Method in class org.apache.giraph.utils.ByteStructVertexIdDataIterator
 
getCurrentData() - Method in class org.apache.giraph.utils.OneMessageToManyIdsIterator
 
getCurrentData() - Method in interface org.apache.giraph.utils.VertexIdDataIterator
Get the current data.
getCurrentDataSize() - Method in class org.apache.giraph.utils.ByteStructVertexIdDataIterator
 
getCurrentDataSize() - Method in class org.apache.giraph.utils.OneMessageToManyIdsIterator
 
getCurrentDataSize() - Method in interface org.apache.giraph.utils.VertexIdDataIterator
Get serialized size of current data
getCurrentDate() - Method in class org.apache.giraph.time.FakeTime
 
getCurrentDate() - Method in class org.apache.giraph.time.SystemTime
 
getCurrentDate() - Method in interface org.apache.giraph.time.Time
Get the current date
getCurrentEdge() - Method in class org.apache.giraph.edge.MutableEdgesWrapper
Get the last edge returned by the mutable iterator.
getCurrentEdge() - Method in class org.apache.giraph.io.EdgeReader
Get the current edge.
getCurrentEdge() - Method in class org.apache.giraph.io.formats.TextEdgeInputFormat.TextEdgeReaderFromEachLine
 
getCurrentEdge() - Method in class org.apache.giraph.io.formats.TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed
 
getCurrentEdge() - Method in class org.apache.giraph.io.internal.WrappedEdgeReader
 
getCurrentEdge() - Method in class org.apache.giraph.io.iterables.EdgeReaderWrapper
 
getCurrentEdge() - Method in class org.apache.giraph.io.ReverseEdgeDuplicator
 
getCurrentEdge() - Method in class org.apache.giraph.utils.ByteStructVertexIdEdgeIterator
 
getCurrentEdge() - Method in interface org.apache.giraph.utils.VertexIdEdgeIterator
Get the current edge.
getCurrentEntry() - Method in class org.apache.giraph.io.internal.WrappedMappingReader
 
getCurrentEntry() - Method in class org.apache.giraph.io.iterables.MappingReaderWrapper
 
getCurrentEntry() - Method in class org.apache.giraph.io.MappingReader
Get the current entry.
getCurrentFirst() - Method in class org.apache.giraph.utils.PairList.Iterator
Get first element of the current pair of the iteration.
getCurrentMasterTaskPartition() - Method in class org.apache.giraph.counters.GiraphStats
Get CurrentMasterTaskPartition counter
getCurrentMessage() - Method in class org.apache.giraph.utils.ByteStructVertexIdMessageIterator
 
getCurrentMessage() - Method in class org.apache.giraph.utils.OneMessageToManyIdsIterator
 
getCurrentMessage() - Method in interface org.apache.giraph.utils.VertexIdMessageIterator
Get the current message.
getCurrentMessageSize() - Method in class org.apache.giraph.utils.ByteStructVertexIdMessageIterator
 
getCurrentMessageSize() - Method in class org.apache.giraph.utils.OneMessageToManyIdsIterator
 
getCurrentMessageSize() - Method in interface org.apache.giraph.utils.VertexIdMessageIterator
Get the serialized size of current message
getCurrentMessageStore() - Method in class org.apache.giraph.comm.ServerData
Get message store for current messages (messages which we received in previous super step and which will be consumed in current super step)
getCurrentObject() - Method in class org.apache.giraph.io.iterables.IteratorToReaderWrapper
Get the current object
getCurrentPartitionOwners() - Method in interface org.apache.giraph.partition.MasterGraphPartitioner
Get current partition owners at this time.
getCurrentPartitionOwners() - Method in class org.apache.giraph.partition.MasterGraphPartitionerImpl
 
getCurrentSecond() - Method in class org.apache.giraph.utils.PairList.Iterator
Get second element of the current pair of the iteration.
getCurrentSourceId() - Method in class org.apache.giraph.io.EdgeReader
Get the current edge source id.
getCurrentSourceId() - Method in class org.apache.giraph.io.formats.TextEdgeInputFormat.TextEdgeReaderFromEachLine
 
getCurrentSourceId() - Method in class org.apache.giraph.io.formats.TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed
 
getCurrentSourceId() - Method in class org.apache.giraph.io.internal.WrappedEdgeReader
 
getCurrentSourceId() - Method in class org.apache.giraph.io.iterables.EdgeReaderWrapper
 
getCurrentSourceId() - Method in class org.apache.giraph.io.ReverseEdgeDuplicator
 
getCurrentSuperstep() - Method in class org.apache.giraph.job.CombinedWorkerProgress
Get Current superstep
getCurrentSuperstep() - Method in class org.apache.giraph.worker.WorkerProgress
 
getCurrentValue() - Method in class org.apache.giraph.reducers.Reducer
 
getCurrentVertex() - Method in class org.apache.giraph.io.formats.SequenceFileVertexInputFormat.SequenceFileVertexReader
 
getCurrentVertex() - Method in class org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReaderFromEachLine
 
getCurrentVertex() - Method in class org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReaderFromEachLineProcessed
 
getCurrentVertex() - Method in class org.apache.giraph.io.formats.TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions
 
getCurrentVertex() - Method in class org.apache.giraph.io.internal.WrappedVertexReader
 
getCurrentVertex() - Method in class org.apache.giraph.io.iterables.VertexReaderWrapper
 
getCurrentVertex() - Method in class org.apache.giraph.io.VertexReader
Get the current vertex.
getCurrentVertex() - Method in class org.apache.giraph.io.VertexValueReader
 
getCurrentVertexId() - Method in class org.apache.giraph.io.BasicVertexValueReader
User-defined method to extract the vertex id.
getCurrentVertexId() - Method in class org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReaderFromEachLine
 
getCurrentVertexId() - Method in class org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed
 
getCurrentVertexId() - Method in class org.apache.giraph.utils.ByteStructVertexIdIterator
 
getCurrentVertexId() - Method in class org.apache.giraph.utils.OneMessageToManyIdsIterator
 
getCurrentVertexId() - Method in interface org.apache.giraph.utils.VertexIdIterator
Get the current vertex id.
getCurrentVertexId() - Method in class org.apache.giraph.utils.VertexIterator
Get the current vertex id.
getCurrentVertexValue() - Method in class org.apache.giraph.io.BasicVertexValueReader
User-defined method to extract the vertex value.
getCurrentVertexValue() - Method in class org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReaderFromEachLine
 
getCurrentVertexValue() - Method in class org.apache.giraph.io.formats.TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed
 
getCurrentWorkers() - Method in class org.apache.giraph.counters.GiraphStats
Get CurrentWorkers counter
getCurrentWorkerToWorkerMessages() - Method in class org.apache.giraph.comm.ServerData
Get worker to worker messages received in previous superstep.
getData() - Method in class org.apache.giraph.comm.requests.ByteArrayRequest
Get request data
getData(int) - Method in class org.apache.giraph.comm.SendDataCache
Get the data cache for a partition id
getData(String, Watcher, Stat) - Method in class org.apache.giraph.zk.ZooKeeperExt
Return the data and the stat of the node of the given path.
getData(String, boolean, Stat) - Method in class org.apache.giraph.zk.ZooKeeperExt
Return the data and the stat of the node of the given path.
getDataAccessor() - Method in class org.apache.giraph.ooc.OutOfCoreEngine
 
getDataDir() - Method in class org.apache.giraph.zk.ZookeeperConfig
Snapshot dir
getDataFromMasterWhenReady(MasterInfo) - Method in class org.apache.giraph.comm.aggregators.AllAggregatorServerData
This function will wait until all aggregator requests from master have arrived, and return that data afterwards.
getDataInput() - Method in class org.apache.giraph.comm.requests.ByteArrayRequest
Get request data in the form of DataInput
getDataInput() - Method in class org.apache.giraph.ooc.persistence.InMemoryDataAccessor.InMemoryDataInputWrapper
 
getDataInput() - Method in interface org.apache.giraph.ooc.persistence.OutOfCoreDataAccessor.DataInputWrapper
 
getDataLogDir() - Method in class org.apache.giraph.zk.ZookeeperConfig
Transaction dir
getDataOutput() - Method in class org.apache.giraph.ooc.persistence.InMemoryDataAccessor.InMemoryDataOutputWrapper
 
getDataOutput() - Method in interface org.apache.giraph.ooc.persistence.OutOfCoreDataAccessor.DataOutputWrapper
 
getDataOutput(int) - Method in class org.apache.giraph.utils.ExtendedByteArrayOutputBuffer
Get dataoutput from bytearrayOutputs
getDataOutput() - Method in class org.apache.giraph.utils.ExtendedByteArrayOutputBuffer.IndexAndDataOut
 
getDataOutput() - Method in class org.apache.giraph.utils.io.BigDataInputOutput
 
getDataOutput() - Method in class org.apache.giraph.utils.io.DataInputOutput
Get DataOutput to write to
getDataOutput() - Method in class org.apache.giraph.utils.io.ExtendedDataInputOutput
 
getDataOutputs() - Method in class org.apache.giraph.utils.io.BigDataOutput
Get DataOutputs which contain written data.
getDefaultClass() - Method in class org.apache.giraph.conf.ClassConfOption
 
getDefaultValue() - Method in class org.apache.giraph.conf.BooleanConfOption
Get the default value of this option
getDefaultValue() - Method in class org.apache.giraph.conf.FloatConfOption
 
getDefaultValue() - Method in class org.apache.giraph.conf.IntConfOption
 
getDefaultValue() - Method in class org.apache.giraph.conf.LongConfOption
 
getDefaultValue() - Method in class org.apache.giraph.conf.StrConfOption
 
getDefaultValueStr() - Method in class org.apache.giraph.conf.AbstractConfOption
Get string representation of default value
getDefaultValueStr() - Method in class org.apache.giraph.conf.BooleanConfOption
 
getDefaultValueStr() - Method in class org.apache.giraph.conf.ClassConfOption
 
getDefaultValueStr() - Method in class org.apache.giraph.conf.EnumConfOption
 
getDefaultValueStr() - Method in class org.apache.giraph.conf.FloatConfOption
 
getDefaultValueStr() - Method in class org.apache.giraph.conf.IntConfOption
 
getDefaultValueStr() - Method in class org.apache.giraph.conf.JsonStringConfOption
 
getDefaultValueStr() - Method in class org.apache.giraph.conf.LongConfOption
 
getDefaultValueStr() - Method in class org.apache.giraph.conf.StrConfOption
 
getDeployType() - Method in class org.apache.giraph.scripting.DeployedScript
 
getDescription() - Method in class org.apache.giraph.conf.AbstractConfOption
 
getDestinationAddress() - Method in class org.apache.giraph.comm.netty.handler.RequestInfo
 
getDestinationTaskId() - Method in class org.apache.giraph.comm.netty.handler.ClientRequestId
 
getDiff(Time, TimeUnit, long) - Static method in class org.apache.giraph.time.Times
Convenience method to get time since the beginning of an event in a given TimeUnit.
getDiskBandwidth() - Method in class org.apache.giraph.ooc.OutOfCoreIOStatistics
 
getDisplayName() - Method in class org.apache.giraph.counters.GiraphHadoopCounter
Get counter display name.
getDouble() - Method in class org.apache.giraph.metrics.ValueGauge
Get double representation of value held.
getDuration() - Method in class org.apache.giraph.ooc.OutOfCoreIOStatistics.BytesDuration
 
getDynamicChannelBuffer() - Method in class org.apache.giraph.utils.DynamicChannelBufferOutputStream
Get the dynamic channel buffer
getEdge() - Method in class org.apache.giraph.io.iterables.EdgeWithSource
 
getEdge_inputs() - Method in class org.apache.giraph.jython.JythonJob
 
getEdge_value() - Method in class org.apache.giraph.jython.JythonJob
 
getEdgeCount() - Method in class org.apache.giraph.graph.GlobalStats
 
getEdgeCount() - Method in class org.apache.giraph.graph.VertexEdgeCount
 
getEdgeCount() - Method in class org.apache.giraph.partition.ByteArrayPartition
 
getEdgeCount() - Method in interface org.apache.giraph.partition.Partition
Get the number of edges in this partition.
getEdgeCount() - Method in class org.apache.giraph.partition.PartitionStats
Get the edge count.
getEdgeCount() - Method in class org.apache.giraph.partition.SimplePartition
 
getEdgeInputFilter() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Get the edge input filter to use
getEdgeInputFilterClass() - Method in class org.apache.giraph.conf.GiraphClasses
 
getEdgeInputFilterClass() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Get the vertex input filter class
getEdgeInputFormatClass() - Method in class org.apache.giraph.conf.GiraphClasses
Get EdgeInputFormat used
getEdgeInputFormatClass() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Get the user's subclassed EdgeInputFormat.
getEdgeInputFormatDescriptions(Configuration) - Static method in class org.apache.giraph.io.formats.multi.EdgeInputFormatDescription
Get descriptions of edge input formats from configuration.
getEdgeInputPaths(JobContext) - Static method in class org.apache.giraph.io.formats.GiraphFileInputFormat
Get the list of edge input Paths.
getEdgeInputSplitsCount() - Method in class org.apache.giraph.master.MasterProgress
 
getEdgeInputSplitsLoaded() - Method in class org.apache.giraph.worker.WorkerProgress
 
getEdgeOutputFormatClass() - Method in class org.apache.giraph.conf.GiraphClasses
Get VertexOutputFormat set
getEdgeOutputFormatClass() - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration
Get the user's subclassed EdgeOutputFormat.
getEdges() - Method in class org.apache.giraph.counters.GiraphStats
Get Edges counter
getEdges() - Method in class org.apache.giraph.graph.DefaultVertex
 
getEdges() - Method in class org.apache.giraph.graph.OnlyIdVertex
 
getEdges() - Method in interface org.apache.giraph.graph.Vertex
Get a read-only view of the out-edges of this vertex.
getEdges(String[]) - Method in class org.apache.giraph.io.formats.AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader
 
getEdges(String[]) - Method in class org.apache.giraph.io.formats.IntIntNullTextInputFormat.IntIntNullVertexReader
 
getEdges(String[]) - Method in class org.apache.giraph.io.formats.IntIntNullTextVertexInputFormat.IntIntNullVertexReader
 
getEdges(String) - Method in class org.apache.giraph.io.formats.IntNullNullTextInputFormat.IntNullNullNullVertexReader
 
getEdges(JSONObject) - Method in class org.apache.giraph.io.formats.