Index (Apache Giraph Parent 1.4.0-SNAPSHOT API)

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
AbstractBlockFactory<S> - Class in org.apache.giraph.block_app.framework: Default block factory abstract class, providing default methods that need to be/can be overridden for specifying required/most common parameters, to simplify setting properties.
AbstractBlockFactory() - Constructor for class org.apache.giraph.block_app.framework.AbstractBlockFactory
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 - 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 - 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, 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
AbstractPiece<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,WV,WM extends org.apache.hadoop.io.Writable,S> - Class in org.apache.giraph.block_app.framework.piece: Parent of all Pieces, contains comprehensive list of methods Piece can support.
AbstractPiece() - Constructor for class org.apache.giraph.block_app.framework.piece.AbstractPiece
AbstractPiece.InnerVertexReceiver - Class in org.apache.giraph.block_app.framework.piece: Inner class to provide clean use without specifying types
AbstractPiece.InnerVertexSender - Class in org.apache.giraph.block_app.framework.piece: Inner class to provide clean use without specifying types
AbstractVertexIdData - 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.
ACK - Static variable in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage: Bracha-Toueg ACK message.
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.
ACTUAL_LOCALITY_RATIO - Static variable in class org.apache.giraph.block_app.test_setup.graphs.SyntheticGraphInit
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(PieceCount) - Method in class org.apache.giraph.block_app.framework.block.PieceCount
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(Number, Number) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add Edge to the graph with default Edge Value, by adding it to outEdges of fromVertex, potentially creating fromVertex if it doesn't exist.
addEdge(Number, Number, Number) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add Edge to the graph with provided Edge Value, by adding it to outEdges of fromVertex, potentially creating fromVertex if it doesn't exist.
addEdge(Number, Number, E) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add Edge to the graph with provided Edge Value, by adding it to outEdges of fromVertex, potentially creating fromVertex if it doesn't exist.
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 interface org.apache.giraph.block_app.framework.api.BlockWorkerSendApi: Request to add an edge of a vertex in the graph (processed just prior to the next receive phase)
addEdgeRequest(I, Edge<I, E>) - Method in class org.apache.giraph.block_app.migration.MigrationAbstractComputation
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.
additionalInitConfig(GiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.AbstractBlockFactory: Additional configuration initialization, other then overriding class specification.
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.
addOutputDesc(OD, String, GiraphConfiguration) - Static method in class org.apache.giraph.block_app.framework.output.BlockOutputFormat
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
addParent(long) - Method in class org.apache.giraph.examples.scc.SccVertexValue: Adds a vertex id to the list of parent vertices.
addParent(Long) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue: add a parent id into the list of parents kept at the vertex side
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.
addSymmetricEdge(Number, Number) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add symmetric Edge to the graph with default Edge Value, by adding it to outEdges of vertices on both ends, potentially creating them both, if they don't exist.
addSymmetricEdge(Number, Number, Number) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add symmetric Edge to the graph with provided Edge Value, by adding it to outEdges of vertices on both ends, potentially creating them both, if they don't exist.
addSymmetricEdge(Number, Number, E) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add symmetric Edge to the graph with provided Edge Value, by adding it to outEdges of vertices on both ends, potentially creating them both, if they don't exist.
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(Number) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add Vertex with a given id to the graph, initializing it to default vertex value and no edges.
addVertex(Number, Number) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add Vertex with a given id and a given Vertex Value to the graph, initializing it to have no edges.
addVertex(Number, Number, Number, Number...) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add Vertex with a given id and a given Vertex Value to the graph, with listed outgoing edges, all initialized to same provided edgeValue.
addVertex(Number, V) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add Vertex with a given id and a given Vertex Value to the graph, initializing it to have no edges.
addVertex(Number, V, Supplier<E>, Number...) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph: Add Vertex with a given id and a given Vertex Value to the graph, with listed outgoing edges, all initialized to same provided edgeSupplier.
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(I, V, OutEdges<I, E>) - Method in interface org.apache.giraph.block_app.framework.api.BlockWorkerSendApi: Sends a request to create a vertex that will be available in the receive phase.
addVertexRequest(I, V) - Method in interface org.apache.giraph.block_app.framework.api.BlockWorkerSendApi: Sends a request to create a vertex that will be available in the receive phase.
addVertexRequest(I, V, OutEdges<I, E>) - Method in class org.apache.giraph.block_app.migration.MigrationAbstractComputation
addVertexRequest(I, V) - Method in class org.apache.giraph.block_app.migration.MigrationAbstractComputation
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 - 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 - 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(PageRankWithKryoSimpleWritable.VertexValue) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator
aggregate(PageRankWithKryoSimpleWritable.VertexValue) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator
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
AggregatorsTestComputation - Class in org.apache.giraph.examples: Computation which uses aggrergators.
AggregatorsTestComputation() - Constructor for class org.apache.giraph.examples.AggregatorsTestComputation
AggregatorsTestComputation.AggregatorsTestMasterCompute - Class in org.apache.giraph.examples: Master compute which uses aggregators.
AggregatorsTestComputation.SimpleEdgeInputFormat - Class in org.apache.giraph.examples: Simple VertexInputFormat
AggregatorsTestComputation.SimpleEdgeReader - Class in org.apache.giraph.examples: Simple Edge Reader
AggregatorsTestComputation.SimpleVertexInputFormat - Class in org.apache.giraph.examples: Simple VertexInputFormat
AggregatorsTestComputation.SimpleVertexReader - Class in org.apache.giraph.examples: Simple VertexReader
AggregatorsTestMasterCompute() - Constructor for class org.apache.giraph.examples.AggregatorsTestComputation.AggregatorsTestMasterCompute
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.
Algorithm - Annotation Type in org.apache.giraph.examples: 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
allowOneMessageToManyIdsEncoding() - Method in class org.apache.giraph.block_app.framework.piece.DefaultParentPiece: Override to specify that this Piece allows one to many ids encoding to be used for messages.
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(ImmutableClassesGiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.piece.messages.SupplierFromConf.DefaultMessageFactorySupplierFromConf
apply(ImmutableClassesGiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.piece.messages.SupplierFromConf.SupplierFromConfByCopy
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.
apply(int) - Method in class org.apache.giraph.object.MultiSizedReusable
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
ArrayHandle<T> - Interface in org.apache.giraph.block_app.framework.piece.global_comm.array: Handle to array of handles underneath
ArrayListEdges - 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.
ArrayOfBroadcasts(int, Int2ObjFunction<BroadcastHandle<T>>) - Constructor for class org.apache.giraph.block_app.reducers.array.ArrayOfHandles.ArrayOfBroadcasts
ArrayOfBroadcasts(int, Supplier<BroadcastHandle<T>>) - Constructor for class org.apache.giraph.block_app.reducers.array.ArrayOfHandles.ArrayOfBroadcasts
ArrayOfHandles<H> - Class in org.apache.giraph.block_app.reducers.array: ArrayHandle implemented as an array of individual handles.
ArrayOfHandles(int, Supplier<H>) - Constructor for class org.apache.giraph.block_app.reducers.array.ArrayOfHandles
ArrayOfHandles(int, Int2ObjFunction<H>) - Constructor for class org.apache.giraph.block_app.reducers.array.ArrayOfHandles
ArrayOfHandles.ArrayOfBroadcasts<T> - Class in org.apache.giraph.block_app.reducers.array: BroadcastArrayHandle implemented as an array of separate broadcast handles.
ArrayOfHandles.ArrayOfReducers<S,R> - Class in org.apache.giraph.block_app.reducers.array: ReducerArrayHandle implemented as an array of separate reducer handles.
ArrayOfReducers(int, Supplier<ReducerHandle<S, R>>) - Constructor for class org.apache.giraph.block_app.reducers.array.ArrayOfHandles.ArrayOfReducers
ArrayOfReducers(int, Int2ObjFunction<ReducerHandle<S, R>>) - Constructor for class org.apache.giraph.block_app.reducers.array.ArrayOfHandles.ArrayOfReducers
ArrayReduce<S,R extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.block_app.reducers.array: One reducer representing reduction of array of individual values.
ArrayReduce() - Constructor for class org.apache.giraph.block_app.reducers.array.ArrayReduce
ArrayReduce(int, ReduceOperation<S, R>) - Constructor for class org.apache.giraph.block_app.reducers.array.ArrayReduce: Create ReduceOperation that reduces arrays by reducing individual elements.
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 - 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
BasicArrayReduce<S,R extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.block_app.reducers.array: Efficient generic primitive array reduce operation.
BasicArrayReduce() - Constructor for class org.apache.giraph.block_app.reducers.array.BasicArrayReduce
BasicArrayReduce(int, PrimitiveTypeOps<R>, ReduceOperation<S, R>) - Constructor for class org.apache.giraph.block_app.reducers.array.BasicArrayReduce: Create ReduceOperation that reduces BasicArrays by reducing individual elements, with predefined size.
BasicArrayReduce(PrimitiveTypeOps<R>, ReduceOperation<S, R>) - Constructor for class org.apache.giraph.block_app.reducers.array.BasicArrayReduce: Create ReduceOperation that reduces BasicArrays by reducing individual elements, with unbounded size.
BasicCollectionsUtils - Class in org.apache.giraph.types.ops.collections: Utility functions for constructing basic collections
BasicComputation - 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
BasicMapReduce<K extends org.apache.hadoop.io.WritableComparable,S,R extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.block_app.reducers.map: Efficient generic primitive map of values reduce operation.
BasicMapReduce() - Constructor for class org.apache.giraph.block_app.reducers.map.BasicMapReduce
BasicMapReduce(PrimitiveIdTypeOps<K>, PrimitiveTypeOps<R>, ReduceOperation<S, R>) - Constructor for class org.apache.giraph.block_app.reducers.map.BasicMapReduce: Create ReduceOperation that reduces BasicMaps by reducing individual elements corresponding to the same key.
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 - 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 - 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
Block - Interface in org.apache.giraph.block_app.framework.block: Composable unit of execution.
BLOCK_FACTORY_CLASS - Static variable in class org.apache.giraph.block_app.framework.BlockUtils: Property describing BlockFactory to use for current application run
BLOCK_WORKER_CONTEXT_VALUE_CLASS - Static variable in class org.apache.giraph.block_app.framework.BlockUtils: Property describing block worker context value class to use
BlockApi - Interface in org.apache.giraph.block_app.framework.api: Basic block computation API for accessing items present on both workers and master.
BlockApiHandle - Class in org.apache.giraph.block_app.framework.api: Class that contains references to Block Api objects.
BlockApiHandle() - Constructor for class org.apache.giraph.block_app.framework.api.BlockApiHandle
BlockComputation - Class in org.apache.giraph.block_app.framework.api.giraph: Computation that executes receiver and sender blocks passed into BlockWorkerPieces.
BlockComputation() - Constructor for class org.apache.giraph.block_app.framework.api.giraph.BlockComputation
BlockConfApi - Interface in org.apache.giraph.block_app.framework.api: Block computation API for accessing configuration.
BlockCounters - Class in org.apache.giraph.block_app.framework.internal: Utility class for Blocks Framework related counters
BlockFactory<S> - Interface in org.apache.giraph.block_app.framework: Class describing a particular application.
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
BlockMasterApi - Interface in org.apache.giraph.block_app.framework.api: Block computation API available for the master methods.
BlockMasterCompute<S> - Class in org.apache.giraph.block_app.framework.api.giraph: MasterCompute class which executes block computation.
BlockMasterCompute() - Constructor for class org.apache.giraph.block_app.framework.api.giraph.BlockMasterCompute
BlockMasterLogic<S> - Class in org.apache.giraph.block_app.framework.internal: Block execution logic on master, iterating over Pieces of the application Block, executing master logic, and providing what needs to be executed on the workers.
BlockMasterLogic() - Constructor for class org.apache.giraph.block_app.framework.internal.BlockMasterLogic
BlockMasterLogic.TimeStatsPerEvent - Class in org.apache.giraph.block_app.framework.internal: Class tracking invocation count and elapsed time for a set of events, each event being having a String name.
BlockOutputApi - Interface in org.apache.giraph.block_app.framework.api: Block worker output api
BlockOutputDesc<OW extends BlockOutputWriter> - Interface in org.apache.giraph.block_app.framework.output: Output description
BlockOutputFormat - Class in org.apache.giraph.block_app.framework.output: Hadoop output format to use with block output.
BlockOutputFormat() - Constructor for class org.apache.giraph.block_app.framework.output.BlockOutputFormat
BlockOutputHandle - Class in org.apache.giraph.block_app.framework.output: Handler for blocks output - keeps track of outputs and writers created
BlockOutputHandle() - Constructor for class org.apache.giraph.block_app.framework.output.BlockOutputHandle
BlockOutputHandle(String, Configuration, Progressable) - Constructor for class org.apache.giraph.block_app.framework.output.BlockOutputHandle
BlockOutputHandleAccessor - Interface in org.apache.giraph.block_app.framework.api: Function for accessing BlockOutputHandle.
BlockOutputOption<OD extends BlockOutputDesc<OW>,OW extends BlockOutputWriter> - Class in org.apache.giraph.block_app.framework.output: Block output option, with apis to use from application code
BlockOutputOption(String) - Constructor for class org.apache.giraph.block_app.framework.output.BlockOutputOption
BlockOutputWriter - Interface in org.apache.giraph.block_app.framework.output: Block output writer
BlockUtils - Class in org.apache.giraph.block_app.framework: Utility functions for block applications
BlockWithApiHandle - Interface in org.apache.giraph.block_app.framework.block: Applications that need access to a BlockApiHandle should return a Block of this type.
BlockWorkerApi - Interface in org.apache.giraph.block_app.framework.api: Block computation API available for worker methods.
BlockWorkerContext - Class in org.apache.giraph.block_app.framework.api.giraph: WorkerContext that executes receiver and sender blocks passed into BlockWorkerPieces.
BlockWorkerContext() - Constructor for class org.apache.giraph.block_app.framework.api.giraph.BlockWorkerContext
BlockWorkerContextApi - Interface in org.apache.giraph.block_app.framework.api: Block computation API available for worker context methods.
BlockWorkerContextLogic - Class in org.apache.giraph.block_app.framework.internal: Block execution logic on WorkerContext.
BlockWorkerContextLogic() - Constructor for class org.apache.giraph.block_app.framework.internal.BlockWorkerContextLogic
BlockWorkerContextReceiveApi - Interface in org.apache.giraph.block_app.framework.api: Block computation API available for worker context receive methods.
BlockWorkerContextSendApi - Interface in org.apache.giraph.block_app.framework.api: Block computation API available for worker send methods.
BlockWorkerLogic - Class in org.apache.giraph.block_app.framework.internal: Block execution logic on workers.
BlockWorkerLogic(BlockWorkerPieces) - Constructor for class org.apache.giraph.block_app.framework.internal.BlockWorkerLogic
BlockWorkerPieces<S> - Class in org.apache.giraph.block_app.framework.internal: Pair of pieces to be executed on workers in a superstep
BlockWorkerPieces(PairedPieceAndStage<S>, PairedPieceAndStage<S>, BlockApiHandle) - Constructor for class org.apache.giraph.block_app.framework.internal.BlockWorkerPieces
BlockWorkerReceiveApi - Interface in org.apache.giraph.block_app.framework.api: Block computation API available for worker receive methods.
BlockWorkerSendApi - Interface in org.apache.giraph.block_app.framework.api: Block computation API available for worker send methods.
BlockWorkerValueAccessor - Interface in org.apache.giraph.block_app.framework.api: Function for accessing WorkerValue.
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
BRACHA_TOUEG_DL_INITIATOR_ID - Static variable in class org.apache.giraph.examples.BrachaTouegDeadlockComputation: The deadlock detection initiator id
BrachaTouegDeadlockComputation - Class in org.apache.giraph.examples: This code demonstrates the Bracha Toueg deadlock detection algorithm.
BrachaTouegDeadlockComputation() - Constructor for class org.apache.giraph.examples.BrachaTouegDeadlockComputation
BrachaTouegDeadlockInputFormat - Class in org.apache.giraph.examples.io.formats: VertexInputFormat for the Bracha Toueg Deadlock Detection algorithm specified in JSON format.
BrachaTouegDeadlockInputFormat() - Constructor for class org.apache.giraph.examples.io.formats.BrachaTouegDeadlockInputFormat
BrachaTouegDeadlockMessage - Class in org.apache.giraph.examples.utils: Data sent via a message that includes the source vertex id.
BrachaTouegDeadlockMessage() - Constructor for class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage: Default empty constructor.
BrachaTouegDeadlockMessage(long, long) - Constructor for class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage
BrachaTouegDeadlockVertexValue - Class in org.apache.giraph.examples.utils: Vertex value used for the Bracha-Toueg Dealock algorithm
BrachaTouegDeadlockVertexValue() - Constructor for class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue: Default constructor
BrachaTouegDeadlockVertexValue(HashMap<Long, ArrayList<Long>>) - Constructor for class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue: Parametrized constructor
broadcast(T) - Method in interface org.apache.giraph.block_app.framework.api.BlockMasterApi: Broadcast given value to all workers for next computation.
broadcast(String, Writable) - Method in class org.apache.giraph.block_app.migration.MigrationMasterCompute
broadcast(int, Int2ObjFunction<V>, BlockMasterApi) - Static method in class org.apache.giraph.block_app.reducers.array.HugeArrayUtils: Broadcast a huge array, by splitting into NUM_STRIPES number of parts.
broadcast(int, Int2ObjFunction<V>, PrimitiveTypeOps<V>, BlockMasterApi) - Static method in class org.apache.giraph.block_app.reducers.array.HugeArrayUtils: Broadcast a huge array, by splitting into NUM_STRIPES number of parts.
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.
BroadcastArrayHandle<T> - Interface in org.apache.giraph.block_app.framework.piece.global_comm.array: Handle to array of broadcasts
BroadcastHandle<T> - Interface in org.apache.giraph.block_app.framework.piece.global_comm: Handle to a broadcast.
BroadcastHandleImpl() - Constructor for class org.apache.giraph.block_app.framework.piece.global_comm.internal.ReducersForPieceHandler.BroadcastHandleImpl
BroadcastMapHandle<K,V> - Interface in org.apache.giraph.block_app.framework.piece.global_comm.map: Handle to map of broadcasts
broadcasts - Variable in class org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle.ShardedBroadcastHandle
broadcastValue(BlockMasterApi) - Method in interface org.apache.giraph.block_app.framework.piece.global_comm.array.ReducerArrayHandle: Broadcast whole array of reducers to master
broadcastValue(BlockMasterApi) - Method in class org.apache.giraph.block_app.framework.piece.global_comm.internal.ReducersForPieceHandler.ReduceHandleImpl
broadcastValue(BlockMasterApi) - Method in interface org.apache.giraph.block_app.framework.piece.global_comm.map.ReducerMapHandle: Broadcast whole map of reducers to master
broadcastValue(BlockMasterApi) - Method in class org.apache.giraph.block_app.framework.piece.global_comm.ReducerAndBroadcastWrapperHandle: Broadcast reduced value from master
broadcastValue(BlockMasterApi) - Method in interface org.apache.giraph.block_app.framework.piece.global_comm.ReducerHandle: Broadcast reduced value from master
broadcastValue(BlockMasterApi) - Method in class org.apache.giraph.block_app.reducers.array.ArrayOfHandles.ArrayOfReducers
broadcastValue(BlockMasterApi) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast: Broadcast reduced value from master
broadcastValue(BlockMasterApi) - Method in class org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle
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 - 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 - 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 - 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 - Class in org.apache.giraph.edge: OutEdges implementation backed by a byte array.
ByteArrayEdges() - Constructor for class org.apache.giraph.edge.ByteArrayEdges
ByteArrayMessagesPerVertexStore - 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, ImmutableClassesGiraphConfiguration<I, ?, ?>) - Constructor for class org.apache.giraph.comm.messages.ByteArrayMessagesPerVertexStore: Constructor
ByteArrayMessagesPerVertexStore.Factory - Class in org.apache.giraph.comm.messages: Factory for ByteArrayMessagesPerVertexStore
ByteArrayOneMessageToManyIds - 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 - 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 - 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 - 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 - 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 - 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 - 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 - 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 - 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 - 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 - 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 - Interface in org.apache.giraph.bsp: Basic service interface shared by both CentralizedServiceMaster and CentralizedServiceWorker.
CentralizedServiceMaster - 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 - Interface in org.apache.giraph.bsp: All workers should have access to this centralized service to execute the following methods.
chainConfigurators(BulkConfigurator...) - Static method in class org.apache.giraph.block_app.test_setup.TestGraphUtils: Chain execution of multiple BulkConfigurators into one.
chainModifiers(TestGraphModifier<I, V, E>...) - Static method in class org.apache.giraph.block_app.test_setup.TestGraphUtils: Chain execution of multiple TestGraphModifier into one.
changedIteration(int) - Method in interface org.apache.giraph.block_app.library.iteration.IterationStage
changedIteration(int) - Method in class org.apache.giraph.block_app.library.iteration.IterationStageImpl
changedMigrationSuperstep(int) - Method in interface org.apache.giraph.block_app.migration.MigrationSuperstepStage
changedMigrationSuperstep(int) - Method in class org.apache.giraph.block_app.migration.MigrationSuperstepStageImpl
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.
checkBlockTypes(Block, Object, ImmutableClassesGiraphConfiguration) - Static method in class org.apache.giraph.block_app.framework.BlockUtils
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.examples.AggregatorsTestComputation.SimpleEdgeInputFormat
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.
checkOutput(NumericTestGraph<I, V, E>) - Method in interface org.apache.giraph.block_app.test_setup.TestGraphChecker
checkOutputSpecs(JobContext) - Method in class org.apache.giraph.block_app.framework.output.BlockOutputFormat
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
clearParents() - Method in class org.apache.giraph.examples.scc.SccVertexValue: Clear parents list.
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.examples.GeneratedEdgeReader
close() - Method in class org.apache.giraph.examples.GeneratedVertexReader
close() - Method in class org.apache.giraph.examples.SimpleAggregatorWriter
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 AggregatorWriter
close() - Method in class org.apache.giraph.zk.ZooKeeperExt: Close this client object.
closeAllWriters() - Method in class org.apache.giraph.block_app.framework.output.BlockOutputHandle
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
CollectPrimitiveReduceOperation<S> - Class in org.apache.giraph.block_app.reducers.collect: Collect primitive values reduce operation
CollectPrimitiveReduceOperation() - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectPrimitiveReduceOperation: For reflection only
CollectPrimitiveReduceOperation(PrimitiveTypeOps<S>) - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectPrimitiveReduceOperation
CollectReduceOperation<S> - Class in org.apache.giraph.block_app.reducers.collect: Collect values reduce operation
CollectReduceOperation() - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectReduceOperation
CollectShardedBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<S>>>) - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectShardedReducerHandle.CollectShardedBroadcastHandle
CollectShardedPrimitiveBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>>) - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectShardedPrimitiveReducerHandle.CollectShardedPrimitiveBroadcastHandle
CollectShardedPrimitiveReducerHandle<S> - Class in org.apache.giraph.block_app.reducers.collect: ShardedReducerHandle where we keep a list of reduced values, when primitives are used
CollectShardedPrimitiveReducerHandle(CreateReducersApi, Class<S>) - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectShardedPrimitiveReducerHandle
CollectShardedPrimitiveReducerHandle.CollectShardedPrimitiveBroadcastHandle - Class in org.apache.giraph.block_app.reducers.collect: Broadcast handle for CollectShardedPrimitiveReducerHandle
CollectShardedReducerHandle<S> - Class in org.apache.giraph.block_app.reducers.collect: ShardedReducerHandle where we keep a list of reduced values
CollectShardedReducerHandle(CreateReducersApi) - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectShardedReducerHandle
CollectShardedReducerHandle.CollectShardedBroadcastHandle - Class in org.apache.giraph.block_app.reducers.collect: BroadcastHandle for CollectShardedReducerHandle
CollectShardedTuplesOfPrimitivesBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<WArrayList>>>) - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesBroadcastHandle
CollectShardedTuplesOfPrimitivesReduceBroadcast() - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast
CollectShardedTuplesOfPrimitivesReducerHandle - Class in org.apache.giraph.block_app.reducers.collect: ShardedReducerHandle where we keep a list of reduced values, and values consist of multiple primitives, so we keep one primitive list for each
CollectShardedTuplesOfPrimitivesReducerHandle(CreateReducersApi, Class<?>...) - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle
CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesBroadcastHandle - Class in org.apache.giraph.block_app.reducers.collect: BroadcastHandle for CollectShardedTuplesOfPrimitivesReducerHandle
CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast - Class in org.apache.giraph.block_app.reducers.collect: Reduce broadcast wrapper
CollectTuplesOfPrimitivesReduceOperation - Class in org.apache.giraph.block_app.reducers.collect: Collect tuples of primitive values reduce operation
CollectTuplesOfPrimitivesReduceOperation() - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectTuplesOfPrimitivesReduceOperation: For reflection only
CollectTuplesOfPrimitivesReduceOperation(List<PrimitiveTypeOps>) - Constructor for class org.apache.giraph.block_app.reducers.collect.CollectTuplesOfPrimitivesReduceOperation
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() - Method in interface org.apache.giraph.block_app.framework.output.BlockOutputDesc: Commit everything
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(SimpleTriangleClosingComputation.Pair) - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputation.Pair: Comparator to quickly sort by values
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, Iterable) - Method in class org.apache.giraph.block_app.framework.api.giraph.BlockComputation
compute() - Method in class org.apache.giraph.block_app.framework.api.giraph.BlockMasterCompute
compute(Vertex, Iterable) - Method in class org.apache.giraph.block_app.framework.internal.BlockWorkerLogic
compute(Vertex<I, V, E>, Iterable<M1>) - Method in class org.apache.giraph.block_app.migration.MigrationAbstractComputation
compute() - Method in class org.apache.giraph.block_app.migration.MigrationMasterCompute
compute() - Method in class org.apache.giraph.examples.AggregatorsTestComputation.AggregatorsTestMasterCompute
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.AggregatorsTestComputation
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation
compute() - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterCompute
compute(Vertex<LongWritable, BrachaTouegDeadlockVertexValue, LongWritable>, Iterable<BrachaTouegDeadlockMessage>) - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputation
compute(Vertex<IntWritable, IntWritable, NullWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.ConnectedComponentsComputation: Propagates the smallest vertex id to all neighbors.
compute(Vertex<I, V, E>, Iterable<M>) - Method in class org.apache.giraph.examples.IdentityComputation
compute(Vertex<IntWritable, IntWritable, NullWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.MaxComputation
compute(Vertex<LongWritable, PageRankWithKryoSimpleWritable.VertexValue, PageRankWithKryoSimpleWritable.EdgeValue>, Iterable<PageRankWithKryoSimpleWritable.MessageValue>) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable
compute(Vertex<LongWritable, DoubleWritable, E>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.RandomWalkComputation
compute() - Method in class org.apache.giraph.examples.RandomWalkVertexMasterCompute
compute(Vertex<LongWritable, SccVertexValue, NullWritable>, Iterable<LongWritable>) - Method in class org.apache.giraph.examples.scc.SccComputation
compute() - Method in class org.apache.giraph.examples.scc.SccPhaseMasterCompute
compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<FloatWritable>) - Method in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointComputation
compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.SimpleCombinerComputation
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleFailComputation
compute(Vertex<LongWritable, LongWritable, DoubleWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleInDegreeCountComputation
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleMasterComputeComputation
compute() - Method in class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterCompute
compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.SimpleMsgComputation
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleMutateGraphComputation
compute(Vertex<LongWritable, LongWritable, DoubleWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleOutDegreeCountComputation
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimplePageRankComputation
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleShortestPathsComputation
compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.SimpleSuperstepComputation
compute(Vertex<IntWritable, SimpleTriangleClosingComputation.IntArrayListWritable, NullWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputation
compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext.SimpleComputation
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.TestComputationStateComputation
compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<VerifyMessage.VerifiableMessage>) - Method in class org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation
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
computeNext(long) - Method in class org.apache.giraph.block_app.framework.internal.BlockMasterLogic: Executes operations on master (master compute and registering reducers), and calculates next pieces to be exectued on workers.
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 - 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.
CONFIGURATORS - Static variable in class org.apache.giraph.block_app.framework.AbstractBlockFactory: Comma separated list of BulkConfigurators, that are going to be called to simplify specifying of large number of properties.
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
ConnectedComponentsComputation - Class in org.apache.giraph.examples: Implementation of the HCC algorithm that identifies connected components and assigns each vertex its "component identifier" (the smallest vertex id in the component) The idea behind the algorithm is very simple: propagate the smallest vertex id along the edges to all vertices of a connected component.
ConnectedComponentsComputation() - Constructor for class org.apache.giraph.examples.ConnectedComponentsComputation
Consumer<T> - Interface in org.apache.giraph.function: Function: (T) -> void
ConsumerWithVertex - 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
CONVERGED - Static variable in class org.apache.giraph.examples.scc.SccPhaseMasterCompute: Flags whether a vertex converged in the Backward Traversal phase
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
Counter - Interface in org.apache.giraph.block_app.framework.api: Interface wrapping around org.appache.hadoop.mapreduce.Counter
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) - Static method in class org.apache.giraph.types.ops.collections.BasicCollectionsUtils: Construct OpenHashMap with primitive keys.
create2ObjectMap(Class, WritableWriter, 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.
createArrayHandles(int, ReduceOperation<S, T>, CreateReducersApi.CreateReducerFunctionApi) - Static method in class org.apache.giraph.block_app.reducers.array.ArrayReduce: Registers one new reducer, that will reduce array of objects, by reducing individual elements using elementReduceOp.
createArrayHandles(PrimitiveTypeOps<R>, ReduceOperation<S, R>, CreateReducersApi.CreateReducerFunctionApi) - Static method in class org.apache.giraph.block_app.reducers.array.BasicArrayReduce: Registers one new reducer, that will reduce BasicArray, by reducing individual elements using elementReduceOp, with unbounded size.
createArrayHandles(int, PrimitiveTypeOps<R>, ReduceOperation<S, R>, CreateReducersApi.CreateReducerFunctionApi) - Static method in class org.apache.giraph.block_app.reducers.array.BasicArrayReduce: Registers one new reducer, that will reduce BasicArray, by reducing individual elements using elementReduceOp, with predefined size.
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.
createBlock(GiraphConfiguration) - Method in interface org.apache.giraph.block_app.framework.BlockFactory: Create a block (representing a full Giraph job), based on the given configuration.
createBlock(GiraphConfiguration) - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory
createBlockFactory(Configuration) - Static method in class org.apache.giraph.block_app.framework.BlockUtils: Create new BlockFactory that is specified in the configuration.
createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>>) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedPrimitiveReducerHandle
createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<S>>>) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedReducerHandle
createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<WArrayList>>>) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle
createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<R>>) - Method in class org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle
createBroadcastResult(WorkerBroadcastUsage) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedPrimitiveReducerHandle.CollectShardedPrimitiveBroadcastHandle
createBroadcastResult(WorkerBroadcastUsage) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedReducerHandle.CollectShardedBroadcastHandle
createBroadcastResult(WorkerBroadcastUsage) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesBroadcastHandle
createBroadcastResult(WorkerBroadcastUsage) - Method in class org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle.ShardedBroadcastHandle
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.block_app.framework.piece.messages.ObjectMessageClasses
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.examples.AggregatorsTestComputation.SimpleEdgeInputFormat
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
createExecutionStage(GiraphConfiguration) - Method in interface org.apache.giraph.block_app.framework.BlockFactory: Create an empty instance of execution stage object.
createExecutionStage(GiraphConfiguration) - Method in class org.apache.giraph.block_app.migration.MigrationFullBlockFactory
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
createForBasic2ObjectMap(PrimitiveIdTypeOps<K>) - Static method in class org.apache.giraph.object.MultiSizedReusable
createForBasicSet(PrimitiveIdTypeOps) - Static method in class org.apache.giraph.object.MultiSizedReusable
createGcObservers(Mapper<?, ?, ?, ?>.Context) - Method in class org.apache.giraph.conf.ImmutableClassesGiraphConfiguration: Create array of GcObservers.
createGlobalReducer(ReduceOperation<S, R>) - Method in interface org.apache.giraph.block_app.framework.api.CreateReducersApi: Create global reducer, returning a handle to it.
createGlobalReducer(ReduceOperation<S, R>, R) - Method in interface org.apache.giraph.block_app.framework.api.CreateReducersApi: Create global reducer, returning a handle to it.
createGlobalReducer(ReduceOperation<S, R>) - Method in class org.apache.giraph.block_app.framework.piece.global_comm.internal.CreateReducersApiWrapper
createGlobalReducer(ReduceOperation<S, R>, R) - Method in class org.apache.giraph.block_app.framework.piece.global_comm.internal.CreateReducersApiWrapper
createGlobalReducer(MasterGlobalCommUsage, ReduceOperation<S, R>, R) - Method in class org.apache.giraph.block_app.framework.piece.global_comm.internal.ReducersForPieceHandler
createGlobalReducerArrayHandle(int, ReduceOperation<S, R>, CreateReducersApi) - Static method in class org.apache.giraph.block_app.reducers.array.HugeArrayUtils: Create global array of reducers, by splitting the huge array into NUM_STRIPES number of parts.
createGlobalReducerArrayHandle(int, ReduceOperation<S, R>, CreateReducersApi, int) - Static method in class org.apache.giraph.block_app.reducers.array.HugeArrayUtils: Create global array of reducers, by splitting the huge array into maxNumStripes number of parts.
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
createInitAndCheckOutputDesc(String, Configuration, String) - Static method in class org.apache.giraph.block_app.framework.output.BlockOutputFormat
createInitAndCheckOutputDescsMap(Configuration, String) - Static method in class org.apache.giraph.block_app.framework.output.BlockOutputFormat
createInitAndCheckOutputDescsMap(JobContext) - Static method in class org.apache.giraph.block_app.framework.output.BlockOutputFormat
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() - Method in class org.apache.giraph.block_app.reducers.array.ArrayReduce
createInitialValue() - Method in class org.apache.giraph.block_app.reducers.array.BasicArrayReduce
createInitialValue() - Method in class org.apache.giraph.block_app.reducers.map.BasicMapReduce
createInitialValue(String) - Method in class org.apache.giraph.comm.aggregators.OwnerAggregatorServerData: Create initial value for a reducer.
createInitialValue() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator
createInitialValue() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator
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.block_app.reducers.collect.CollectPrimitiveReduceOperation
createList() - Method in class org.apache.giraph.block_app.reducers.collect.CollectReduceOperation
createList(int) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedPrimitiveReducerHandle
createList(int) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedReducerHandle
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
createLists(int) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle
createLocalArrayHandles(PrimitiveTypeOps<R>, ReduceOperation<S, R>, CreateReducersApi) - Static method in class org.apache.giraph.block_app.reducers.array.BasicArrayReduce: Registers one new local reducer, that will reduce BasicArray, by reducing individual elements using elementReduceOp, with unbounded size.
createLocalArrayHandles(int, PrimitiveTypeOps<R>, ReduceOperation<S, R>, CreateReducersApi) - Static method in class org.apache.giraph.block_app.reducers.array.BasicArrayReduce: Registers one new local reducer, that will reduce BasicArray, by reducing individual elements using elementReduceOp, with predefined size.
createLocalMapHandles(PrimitiveIdTypeOps<K>, PrimitiveTypeOps<R>, ReduceOperation<S, R>, CreateReducersApi) - Static method in class org.apache.giraph.block_app.reducers.map.BasicMapReduce: Registers one new local reducer, that will reduce BasicMap, by reducing individual elements corresponding to the same key using elementReduceOp.
createLocalReducer(ReduceOperation<S, R>) - Method in interface org.apache.giraph.block_app.framework.api.CreateReducersApi: Create local reducer, returning a handle to it.
createLocalReducer(ReduceOperation<S, R>, R) - Method in interface org.apache.giraph.block_app.framework.api.CreateReducersApi: Create local reducer, returning a handle to it.
createLocalReducer(ReduceOperation<S, R>) - Method in class org.apache.giraph.block_app.framework.piece.global_comm.internal.CreateReducersApiWrapper
createLocalReducer(ReduceOperation<S, R>, R) - Method in class org.apache.giraph.block_app.framework.piece.global_comm.internal.CreateReducersApiWrapper
createLocalReducer(MasterGlobalCommUsage, ReduceOperation<S, R>, R) - Method in class org.apache.giraph.block_app.framework.piece.global_comm.internal.ReducersForPieceHandler
createMapHandles(PrimitiveIdTypeOps<K>, PrimitiveTypeOps<R>, ReduceOperation<S, R>, CreateReducersApi.CreateReducerFunctionApi) - Static method in class org.apache.giraph.block_app.reducers.map.BasicMapReduce: Registers one new reducer, that will reduce BasicMap, by reducing individual elements corresponding to the same key using elementReduceOp.
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<I, ? extends Writable, ? extends Writable>) - Method in class org.apache.giraph.block_app.framework.piece.messages.ObjectMessageClasses
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.block_app.framework.piece.messages.ObjectMessageClasses
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
createMigrationAppBlock(Class<? extends MigrationAbstractComputation.MigrationFullAbstractComputation<I, V, E, MR, MS>>, MigrationMasterCompute.MigrationFullMasterCompute, Class<MS>, Class<? extends MessageCombiner<? super I, MS>>, GiraphConfiguration) - Method in class org.apache.giraph.block_app.migration.MigrationFullBlockFactory
createMigrationPiece(Class<? extends MigrationAbstractComputation<I, V, E, MR, MS>>, MigrationMasterCompute, Supplier<Iterable<MR>>, Consumer<Iterable<MS>>, Class<MS>, Class<? extends MessageCombiner<? super I, MS>>) - Static method in class org.apache.giraph.block_app.migration.MigrationPiece
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
createOutputWriter(Configuration, Progressable) - Method in interface org.apache.giraph.block_app.framework.output.BlockOutputDesc: Create writer
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
createReceiveFiltering(SupplierFromVertex<I, V, E, Boolean>, Block) - Static method in class org.apache.giraph.block_app.framework.block.FilteringBlock: Creates filtering block, that filters only vertexReceive function, and always calls vertexSend function.
createReceiveFiltering(SupplierFromVertex<? super I, ? super V, ? super E, Boolean>, AbstractPiece<? super I, ? super V, ? super E, ? super M, ? super WV, ? super WM, ? super S>) - Static method in class org.apache.giraph.block_app.framework.piece.delegate.FilteringPiece: Creates filtering piece, that filters only vertexReceive function, and always calls vertexSend function.
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.bsp.BspInputFormat
createRecordReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.formats.GiraphTextInputFormat
createReduceOperation() - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedPrimitiveReducerHandle
createReduceOperation() - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedReducerHandle
createReduceOperation() - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle
createReduceOperation() - Method in class org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle
createReducer(ReduceOperation<S, R>) - Method in interface org.apache.giraph.block_app.framework.api.CreateReducersApi.CreateReducerFunctionApi
createReduceResult(MasterGlobalCommUsage) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedPrimitiveReducerHandle
createReduceResult(MasterGlobalCommUsage) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedReducerHandle
createReduceResult(MasterGlobalCommUsage) - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle
createReduceResult(MasterGlobalCommUsage) - Method in class org.apache.giraph.block_app.reducers.collect.ShardedReducerHandle
CreateReducersApi - Interface in org.apache.giraph.block_app.framework.api: Api for creating reducer handles.
CreateReducersApi.CreateReducerFunctionApi - Interface in org.apache.giraph.block_app.framework.api: Function that creates a reducer - abstracting away whether it is local or global reducer
CreateReducersApiWrapper - Class in org.apache.giraph.block_app.framework.piece.global_comm.internal: Wrapping masterApi and reducers handler into API for creating reducer handles.
CreateReducersApiWrapper(BlockMasterApi, ReducersForPieceHandler) - Constructor for class org.apache.giraph.block_app.framework.piece.global_comm.internal.CreateReducersApiWrapper
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.
createSendFiltering(SupplierFromVertex<I, V, E, Boolean>, Block) - Static method in class org.apache.giraph.block_app.framework.block.FilteringBlock: Creates filtering block, that filters only vertexSend function, and always calls vertexReceive function.
createSendFiltering(SupplierFromVertex<? super I, ? super V, ? super E, Boolean>, AbstractPiece<? super I, ? super V, ? super E, ? super M, ? super WV, ? super WM, ? super S>) - Static method in class org.apache.giraph.block_app.framework.piece.delegate.FilteringPiece: Creates filtering block, that filters only vertexSend function, and always calls vertexReceive function.
createSingleStripeBySendersFunction(Block) - Static method in class org.apache.giraph.block_app.library.striping.StripingUtils: Given a block, creates a function that will given a predicate filter calls to vertexSend function based on that predicate.
createSingleValue() - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast
createSingleValue() - Method in class org.apache.giraph.block_app.reducers.collect.CollectShardedTuplesOfPrimitivesReducerHandle
CreateSourceVertexCallback - 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.
createUnknownCount() - Static method in class org.apache.giraph.block_app.framework.block.PieceCount
createValue() - Method in class org.apache.giraph.block_app.reducers.collect.CollectPrimitiveReduceOperation
createValue() - Method in class org.apache.giraph.block_app.reducers.collect.CollectReduceOperation
createValue() - Method in class org.apache.giraph.block_app.reducers.collect.CollectTuplesOfPrimitivesReduceOperation
createValue() - Method in class org.apache.giraph.block_app.reducers.TopNReduce
createValue() - Method in class org.apache.giraph.reducers.impl.KryoWrappedReduceOperation: Look at ReduceOperation.createValue.
createVertex() - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph
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.examples.AggregatorsTestComputation.SimpleVertexInputFormat
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.io.formats.BrachaTouegDeadlockInputFormat
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.LongDoubleDoubleTextInputFormat
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.LongDoubleFloatTextInputFormat
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.LongDoubleNullTextInputFormat
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.NormalizingLongDoubleDoubleTextInputFormat
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoVertexInputFormat
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.scc.SccLongLongNullTextInputFormat
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexInputFormat
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexInputFormat
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.examples.SimplePageRankComputation.SimplePageRankVertexOutputFormat
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexOutputFormat
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.examples.SimpleTextVertexOutputFormat
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.examples.VertexWithDoubleValueDoubleEdgeTextOutputFormat
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.examples.VertexWithDoubleValueNullEdgeTextOutputFormat
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
CTRL_IN_EDGE - Static variable in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage: Bracha-Toueg control incoming-edge message
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
deactivate() - Method in class org.apache.giraph.examples.scc.SccVertexValue: Remove this vertex from the computation.
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_READER_EDGES - Static variable in class org.apache.giraph.examples.GeneratedEdgeReader: Default edges produced by this reader
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 - 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 - Class in org.apache.giraph.edge: Default implementation of vertex creation decision maker.
DefaultCreateSourceVertexCallback() - Constructor for class org.apache.giraph.edge.DefaultCreateSourceVertexCallback
DefaultEdge - 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 - 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 - Class in org.apache.giraph.conf: Default implementation of ImmutableClassesGiraphConfigurable
DefaultImmutableClassesGiraphConfigurable() - Constructor for class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable
DefaultInputOutEdgesFactory - 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 - 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
DefaultMessageFactorySupplierFromConf(Class<M>) - Constructor for class org.apache.giraph.block_app.framework.piece.messages.SupplierFromConf.DefaultMessageFactorySupplierFromConf
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 - 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
DefaultParentPiece<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,WV,WM extends org.apache.hadoop.io.Writable,S> - Class in org.apache.giraph.block_app.framework.piece: Additional abstract implementations for all pieces to be used.
DefaultParentPiece() - Constructor for class org.apache.giraph.block_app.framework.piece.DefaultParentPiece
DefaultVertex - Class in org.apache.giraph.graph: Class which holds vertex id, data and edges.
DefaultVertex() - Constructor for class org.apache.giraph.graph.DefaultVertex
DefaultVertexIdFactory - 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 - 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 - 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 - 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
DelegatePiece<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,WV,WM extends org.apache.hadoop.io.Writable,S> - Class in org.apache.giraph.block_app.framework.piece.delegate: Delegate Piece which allows combining multiple pieces in same iteration: new DelegatePiece(new LogicPiece(), new StatsPiece()) You should be careful when doing so, since those pieces must not interact, and only one can send messages.
DelegatePiece(AbstractPiece<? super I, ? super V, ? super E, ? super M, ? super WV, ? super WM, ? super S>...) - Constructor for class org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece
DelegatePiece(AbstractPiece<? super I, ? super V, ? super E, ? super M, ? super WV, ? super WM, ? super S>) - Constructor for class org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece
DelegatePiece.DelegateWorkerReceiveFunctions - Class in org.apache.giraph.block_app.framework.piece.delegate: Delegating WorkerReceivePiece
DelegatePiece.DelegateWorkerSendFunctions - Class in org.apache.giraph.block_app.framework.piece.delegate: Delegating WorkerSendPiece
delegateWorkerReceiveFunctions(ArrayList<VertexReceiver<I, V, E, M>>, BlockWorkerReceiveApi, S) - Method in class org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece
DelegateWorkerReceiveFunctions(ArrayList<VertexReceiver<I, V, E, M>>) - Constructor for class org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece.DelegateWorkerReceiveFunctions
delegateWorkerReceiveFunctions(ArrayList<VertexReceiver<I, V, E, M>>, BlockWorkerReceiveApi, S) - Method in class org.apache.giraph.block_app.framework.piece.delegate.FilteringPiece
delegateWorkerSendFunctions(ArrayList<AbstractPiece<I, V, E, M, WV, WM, S>.InnerVertexSender>, BlockWorkerSendApi<I, V, E, M>, S) - Method in class org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece
DelegateWorkerSendFunctions(ArrayList<AbstractPiece<I, V, E, M, WV, WM, S>.InnerVertexSender>) - Constructor for class org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece.DelegateWorkerSendFunctions
delegateWorkerSendFunctions(ArrayList<AbstractPiece<I, V, E, M, WV, WM, S>.InnerVertexSender>, BlockWorkerSendApi<I, V, E, M>, S) - Method in class org.apache.giraph.block_app.framework.piece.delegate.FilteringPiece
delegationName() - Method in class org.apache.giraph.block_app.framework.piece.delegate.DelegatePiece
delegationName() - Method in class org.apache.giraph.block_app.framework.piece.delegate.FilteringPiece
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 - 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 - 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 - 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 - Static variable in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage: Bracha-Toueg DONE message.
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
DoubleMaxWrapperAggregator() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator
DoubleMinAggregator - Class in org.apache.giraph.aggregators: Aggregator for getting min double value.
DoubleMinAggregator() - Constructor for class org.apache.giraph.aggregators.DoubleMinAggregator
DoubleMinWrapperAggregator() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator
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.
doubleSupplier(double) - Static method in class org.apache.giraph.block_app.test_setup.TestGraphUtils
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

EachVertexInit - Class in org.apache.giraph.block_app.test_setup.graphs: Traverse each Vertex in the graph, and initialize it with a given consumer function.
EachVertexInit(Consumer<Vertex<I, V, E>>) - Constructor for class org.apache.giraph.block_app.test_setup.graphs.EachVertexInit
Edge - 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 - 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 - 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 - 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 - 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 - 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 - Class in org.apache.giraph.worker: Factory for EdgeInputSplitsCallables.
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 - Class in org.apache.giraph.edge: An edge that has no value.
EdgeOutputFormat - 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 - 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 - 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 - Interface in org.apache.giraph.edge: Collects incoming edges for vertices owned by this worker.
EdgeStoreFactory - Interface in org.apache.giraph.edge: Factory to create a new Edge Store
edgeSupplier - Variable in class org.apache.giraph.block_app.test_setup.graphs.SyntheticGraphInit
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
EdgeValue() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.EdgeValue: Constructor
EdgeValue(Float) - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.EdgeValue: Constructor
EdgeValueFactory<E extends org.apache.hadoop.io.Writable> - Interface in org.apache.giraph.factories: Factory class to create default edge values.
edgeValueOrCreate(E) - Method in class org.apache.giraph.block_app.test_setup.NumericTestGraph
EdgeWithSource - 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 - 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.
emit(String) - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext.EmitterWorkerContext: Write this string to the output stream.
EmitterWorkerContext() - Constructor for class org.apache.giraph.examples.SimpleVertexWithWorkerContext.EmitterWorkerContext
EmptyBlock - Class in org.apache.giraph.block_app.framework.block: Block without any pieces
EmptyBlock() - Constructor for class org.apache.giraph.block_app.framework.block.EmptyBlock
EmptyIterable<T> - Class in org.apache.giraph.utils: Singleton class for empty iterables.
EmptyIterable() - Constructor for class org.apache.giraph.utils.EmptyIterable
ENABLE_FAULT - Static variable in class org.apache.giraph.examples.SimpleCheckpoint: Should fault?
encodeBytes(byte[]) - Static method in class org.apache.giraph.utils.ConfigurationObjectUtils: Encode bytes to a hex String
endConsume(ConsumerWithVertex<I, V, E, P>) - Method in class org.apache.giraph.block_app.library.SendMessageChain: End chain by processing messages received within the last link in the chain.
endCustom(Function<SupplierFromVertex<I, V, E, P>, Block>) - Method in class org.apache.giraph.block_app.library.SendMessageChain: End chain by providing a function that will produce Block to be attached to the end of current chain, given a supplier of messages received within the last link in the chain.
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
endReduce(String, ReduceOperation<S, R>, FunctionWithVertex<I, V, E, P, S>, Consumer<R>) - Method in class org.apache.giraph.block_app.library.SendMessageChain: End chain by giving received messages to valueSupplier, to produce value that should be reduced, and consumed on master by reducedValueConsumer.
endReduceWithMaster(String, ReduceOperation<S, R>, FunctionWithVertex<I, V, E, P, S>, PairConsumer<R, BlockMasterApi>) - Method in class org.apache.giraph.block_app.library.SendMessageChain: End chain by giving received messages to valueSupplier, to produce value that should be reduced, and consumed on master by reducedValueConsumer.
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.block_app.framework.block.PieceCount
equals(Object) - Method in class org.apache.giraph.block_app.framework.piece.AbstractPiece
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.examples.SimpleTriangleClosingComputation.Pair
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, 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.
fastHash(long) - Static method in class org.apache.giraph.block_app.library.striping.StripingUtils: Returns 32-bit hash of a given value.
fastHashStriping(int) - Static method in class org.apache.giraph.block_app.library.striping.StripingUtils: Fast hash-based striping for LongWritable IDs, returns a function that for a given ID returns it's stripe index.
fastHashStripingPredicate(int) - Static method in class org.apache.giraph.block_app.library.striping.StripingUtils: Fast hash-based striping for LongWritable IDs, returns a function that for a given stripe index returns a predicate checking whether ID is in that stripe.
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.
fastStripe(long, int) - Static method in class org.apache.giraph.block_app.library.striping.StripingUtils: Returns number in [0, stripes) range, from given input value.
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.
FAULT_FILE - Static variable in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext: Filename to indicate whether a fault was found
FAULTING_SUPERSTEP - Static variable in class org.apache.giraph.examples.SimpleCheckpoint: Which superstep to cause the worker to fail
FAULTING_VERTEX_ID - Static variable in class org.apache.giraph.examples.SimpleCheckpoint: Vertex id to fault on
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
FilteringBlock - Class in org.apache.giraph.block_app.framework.block: Block which filters out calls to vertexSend/vertexReceive functions of all pieces in a given block.
FilteringBlock(SupplierFromVertex<I, V, E, Boolean>, SupplierFromVertex<I, V, E, Boolean>, Block) - Constructor for class org.apache.giraph.block_app.framework.block.FilteringBlock: Creates filtering block which uses passed toCallSend to filter calls to vertexSend, and passed toCallReceive to filter calls to vertexReceive, on all pieces within passed block.
FilteringBlock(SupplierFromVertex<I, V, E, Boolean>, Block) - Constructor for class org.apache.giraph.block_app.framework.block.FilteringBlock: Creates filtering block, where both vertexSend and vertexReceive is filtered based on same supplier.
FilteringPiece<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,WV,WM extends org.apache.hadoop.io.Writable,S> - Class in org.apache.giraph.block_app.framework.piece.delegate: Piece which uses a provided suppliers to decide whether or not to run receive/send piece part on a certain vertex.
FilteringPiece(SupplierFromVertex<? super I, ? super V, ? super E, Boolean>, SupplierFromVertex<? super I, ? super V, ? super E, Boolean>, AbstractPiece<? super I, ? super V, ? super E, ? super M, ? super WV, ? super WM, ? super S>) - Constructor for class org.apache.giraph.block_app.framework.piece.delegate.FilteringPiece: Creates filtering piece which uses passed toCallSend to filter calls to vertexSend, and passed toCallReceive to filter calls to vertexReceive, on passed innerPiece.
FilteringPiece(SupplierFromVertex<? super I, ? super V, ? super E, Boolean>, AbstractPiece<? super I, ? super V, ? super E, ? super M, ? super WV, ? super WM, ? super S>) - Constructor for class org.apache.giraph.block_app.framework.piece.delegate.FilteringPiece: Creates filtering piece, where both vertexSend and vertexReceive is filtered based on same supplier.
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 Funct