Index (flink-gelly 1.7.0-mrs-1.8.0 API)

A B C D E F G H I J K L M N O P R S T U V W

A

AdamicAdar<K extends org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.similarity: http://social.cs.uiuc.edu/class/cs591kgk/friendsadamic.pdf
AdamicAdar() - Constructor for class org.apache.flink.graph.library.similarity.AdamicAdar
AdamicAdar.Result<T> - Class in org.apache.flink.graph.library.similarity: A result for the Adamic-Adar algorithm.
add(ChecksumHashCode.Checksum) - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum
add(ByteValue) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
add(CharValue) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
add(DoubleValue) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
add(FloatValue) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
add(IntValue) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
add(LongValue) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
add(NullValue) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
add(ShortValue) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
add(StringValue) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
add(T) - Method in interface org.apache.flink.graph.types.valuearray.ValueArray: Appends the value to this array if and only if the array capacity would not be exceeded.
addAccumulator(String, Accumulator<V, A>) - Method in class org.apache.flink.graph.AnalyticHelper: Adds an accumulator by prepending the given name with a random string.
addAll(ValueArray<ByteValue>) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
addAll(ValueArray<CharValue>) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
addAll(ValueArray<DoubleValue>) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
addAll(ValueArray<FloatValue>) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
addAll(ValueArray<IntValue>) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
addAll(ValueArray<LongValue>) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
addAll(ValueArray<NullValue>) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
addAll(ValueArray<ShortValue>) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
addAll(ValueArray<StringValue>) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
addAll(ValueArray<T>) - Method in interface org.apache.flink.graph.types.valuearray.ValueArray: Appends all of the values in the specified array to the end of this array.
addBroadcastSet(String, DataSet<?>) - Method in class org.apache.flink.graph.pregel.VertexCentricConfiguration: Adds a data set as a broadcast set to the compute function.
addBroadcastSetForApplyFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.gsa.GSAConfiguration: Adds a data set as a broadcast set to the apply function.
addBroadcastSetForGatherFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.gsa.GSAConfiguration: Adds a data set as a broadcast set to the gather function.
addBroadcastSetForGatherFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration: Adds a data set as a broadcast set to the gather function.
addBroadcastSetForScatterFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration: Adds a data set as a broadcast set to the scatter function.
addBroadcastSetForSumFunction(String, DataSet<?>) - Method in class org.apache.flink.graph.gsa.GSAConfiguration: Adds a data set as a broadcast set to the sum function.
addDimension(long, boolean) - Method in class org.apache.flink.graph.generator.GridGraph: Required configuration for each dimension of the graph.
addEdge(Vertex<K, VV>, Vertex<K, VV>, EV) - Method in class org.apache.flink.graph.Graph: Adds the given edge to the graph.
addEdges(List<Edge<K, EV>>) - Method in class org.apache.flink.graph.Graph: Adds the given list edges to the graph.
AddLongValue() - Constructor for class org.apache.flink.graph.utils.GraphUtils.AddLongValue
addRange(long, long) - Method in class org.apache.flink.graph.generator.CirculantGraph: Required configuration for each range of offsets in the graph.
addVertex(Vertex<K, VV>) - Method in class org.apache.flink.graph.Graph: Adds the input vertex to the graph.
addVertices(List<Vertex<K, VV>>) - Method in class org.apache.flink.graph.Graph: Adds the list of vertices, passed as input, to the graph.
AnalyticHelper<T> - Class in org.apache.flink.graph: A GraphAnalytic computes over a DataSet and returns the results via Flink accumulators.
AnalyticHelper() - Constructor for class org.apache.flink.graph.AnalyticHelper
apply(M, VV) - Method in class org.apache.flink.graph.gsa.ApplyFunction: This method is invoked once per superstep, after the SumFunction in a GatherSumApplyIteration.
ApplyFunction<K,VV,M> - Class in org.apache.flink.graph.gsa: The base class for the third and last step of a GatherSumApplyIteration.
ApplyFunction() - Constructor for class org.apache.flink.graph.gsa.ApplyFunction
AverageClusteringCoefficient<K extends Comparable<K> & org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.directed: The average clustering coefficient measures the mean connectedness of a graph.
AverageClusteringCoefficient() - Constructor for class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient
AverageClusteringCoefficient<K extends Comparable<K> & org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.undirected: The average clustering coefficient measures the mean connectedness of a graph.
AverageClusteringCoefficient() - Constructor for class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient
AverageClusteringCoefficient.Result - Class in org.apache.flink.graph.library.clustering.directed: Wraps global clustering coefficient metrics.
AverageClusteringCoefficient.Result - Class in org.apache.flink.graph.library.clustering.undirected: Wraps global clustering coefficient metrics.

B

BinaryResult<K> - Interface in org.apache.flink.graph.asm.result: A GraphAlgorithm result for a pair vertices.
BinaryResult.MirrorResult<T,RT extends BinaryResult<T>> - Class in org.apache.flink.graph.asm.result: Output each input and a second result with the vertex order flipped.
BinaryResultBase<K> - Class in org.apache.flink.graph.asm.result: Base class for algorithm results for a pair of vertices.
BinaryResultBase() - Constructor for class org.apache.flink.graph.asm.result.BinaryResultBase
BipartiteEdge<KT,KB,EV> - Class in org.apache.flink.graph.bipartite: A BipartiteEdge represents a link between top and bottom vertices in a BipartiteGraph.
BipartiteEdge() - Constructor for class org.apache.flink.graph.bipartite.BipartiteEdge
BipartiteEdge(KT, KB, EV) - Constructor for class org.apache.flink.graph.bipartite.BipartiteEdge
BipartiteGraph<KT,KB,VVT,VVB,EV> - Class in org.apache.flink.graph.bipartite: The vertices of a bipartite graph are divided into two disjoint sets, referenced by the names "top" and "bottom".
BlockInfo<T extends org.apache.commons.math3.random.RandomGenerator> - Class in org.apache.flink.graph.generator.random: Defines a source of randomness and a unit of work.
BlockInfo(RandomGenerable<T>, int, int, long, long) - Constructor for class org.apache.flink.graph.generator.random.BlockInfo
BYTE_VALUE_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
ByteValueArray - Class in org.apache.flink.graph.types.valuearray: An array of ByteValue.
ByteValueArray() - Constructor for class org.apache.flink.graph.types.valuearray.ByteValueArray: Initializes an expandable array with default capacity.
ByteValueArray(int) - Constructor for class org.apache.flink.graph.types.valuearray.ByteValueArray: Initializes a fixed-size array with the provided number of bytes.
ByteValueArrayComparator - Class in org.apache.flink.graph.types.valuearray: Specialized comparator for ByteValueArray based on CopyableValueComparator.
ByteValueArrayComparator(boolean) - Constructor for class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
ByteValueArraySerializer - Class in org.apache.flink.graph.types.valuearray: Specialized serializer for ByteValueArray.
ByteValueArraySerializer() - Constructor for class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer

C

canEqual(Object) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
canEqual(Object) - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
canEqual(Object) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
canEqual(Object) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
canEqual(Object) - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
canEqual(Object) - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
canEqual(Object) - Method in class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
canEqual(Object) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
canEqual(Object) - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
canEqual(Object) - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexInDegree
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexOutDegree
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.VertexDegree
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.filter.undirected.MaximumDegree
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.simple.undirected.Simplify
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.translate.TranslateEdgeValues
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.translate.TranslateGraphIds
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.translate.TranslateVertexValues
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.clustering.TriangleListingBase
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.linkanalysis.PageRank
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.similarity.AdamicAdar
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.similarity.JaccardIndex
canMergeConfigurationWith(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase: First test whether the algorithm configurations can be merged before the call to GraphAlgorithmWrappingBase.mergeConfiguration(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase).
CCMessenger(TypeInformation<VV>) - Constructor for class org.apache.flink.graph.library.ConnectedComponents.CCMessenger
CCUpdater() - Constructor for class org.apache.flink.graph.library.ConnectedComponents.CCUpdater
CharValueArray - Class in org.apache.flink.graph.types.valuearray: An array of CharValue.
CharValueArray() - Constructor for class org.apache.flink.graph.types.valuearray.CharValueArray: Initializes an expandable array with default capacity.
CharValueArray(int) - Constructor for class org.apache.flink.graph.types.valuearray.CharValueArray: Initializes a fixed-size array with the provided number of chars.
CharValueArrayComparator - Class in org.apache.flink.graph.types.valuearray: Specialized comparator for CharValueArray based on CopyableValueComparator.
CharValueArrayComparator(boolean) - Constructor for class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
CharValueArraySerializer - Class in org.apache.flink.graph.types.valuearray: Specialized serializer for CharValueArray.
CharValueArraySerializer() - Constructor for class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
Checksum(long, long) - Constructor for class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum: Instantiate an immutable result.
ChecksumHashCode<T> - Class in org.apache.flink.graph.asm.dataset: Convenience method to get the count (number of elements) of a DataSet as well as the checksum (sum over element hashes).
ChecksumHashCode() - Constructor for class org.apache.flink.graph.asm.dataset.ChecksumHashCode
ChecksumHashCode<K,VV,EV> - Class in org.apache.flink.graph.library.metric: Convenience method to get the count (number of elements) of a Graph as well as the checksum (sum over element hashes).
ChecksumHashCode() - Constructor for class org.apache.flink.graph.library.metric.ChecksumHashCode
ChecksumHashCode.Checksum - Class in org.apache.flink.graph.asm.dataset: Wraps checksum and count.
CirculantGraph - Class in org.apache.flink.graph.generator
CirculantGraph(ExecutionEnvironment, long) - Constructor for class org.apache.flink.graph.generator.CirculantGraph: An oriented Graph with n vertices where each vertex v_i is connected to vertex v_(i+j)%n for each configured offset j.
CirculantGraph.OffsetRange - Class in org.apache.flink.graph.generator: Stores the start offset and length configuration for an offset range.
clear() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
clear() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
clear() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
clear() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
clear() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
clear() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
clear() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
clear() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
clear() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
clear() - Method in interface org.apache.flink.graph.types.valuearray.ValueArray: Resets the array to the empty state.
clone() - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum
Collect<T> - Class in org.apache.flink.graph.asm.dataset: Collect the elements of a DataSet into a List.
Collect() - Constructor for class org.apache.flink.graph.asm.dataset.Collect
combineMessages(MessageIterator<Message>) - Method in class org.apache.flink.graph.pregel.MessageCombiner: Combines messages sent from different vertices to a target vertex.
CommunityDetection<K> - Class in org.apache.flink.graph.library: Community Detection Algorithm.
CommunityDetection(int, double) - Constructor for class org.apache.flink.graph.library.CommunityDetection: Creates a new Community Detection algorithm instance.
compare(ByteValueArray, ByteValueArray) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
compare(CharValueArray, CharValueArray) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
compare(DoubleValueArray, DoubleValueArray) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
compare(FloatValueArray, FloatValueArray) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
compare(IntValueArray, IntValueArray) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
compare(LongValueArray, LongValueArray) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
compare(NullValueArray, NullValueArray) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
compare(ShortValueArray, ShortValueArray) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
compare(StringValueArray, StringValueArray) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
compareSerialized(DataInputView, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
compareSerialized(DataInputView, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
compareSerialized(DataInputView, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
compareSerialized(DataInputView, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
compareSerialized(DataInputView, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
compareSerialized(DataInputView, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
compareSerialized(DataInputView, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
compareSerialized(DataInputView, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
compareSerialized(DataInputView, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
compareTo(CirculantGraph.OffsetRange) - Method in class org.apache.flink.graph.generator.CirculantGraph.OffsetRange
compareTo(AdamicAdar.Result<T>) - Method in class org.apache.flink.graph.library.similarity.AdamicAdar.Result
compareTo(JaccardIndex.Result<T>) - Method in class org.apache.flink.graph.library.similarity.JaccardIndex.Result
compareTo(ValueArray<ByteValue>) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
compareTo(ValueArray<CharValue>) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
compareTo(ValueArray<DoubleValue>) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
compareTo(ValueArray<FloatValue>) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
compareTo(ValueArray<IntValue>) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
compareTo(ValueArray<LongValue>) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
compareTo(ValueArray<NullValue>) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
compareTo(ValueArray<ShortValue>) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
compareTo(ValueArray<StringValue>) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
compareToReference(TypeComparator<ByteValueArray>) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
compareToReference(TypeComparator<CharValueArray>) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
compareToReference(TypeComparator<DoubleValueArray>) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
compareToReference(TypeComparator<FloatValueArray>) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
compareToReference(TypeComparator<IntValueArray>) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
compareToReference(TypeComparator<LongValueArray>) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
compareToReference(TypeComparator<NullValueArray>) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
compareToReference(TypeComparator<ShortValueArray>) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
compareToReference(TypeComparator<StringValueArray>) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
CompleteGraph - Class in org.apache.flink.graph.generator
CompleteGraph(ExecutionEnvironment, long) - Constructor for class org.apache.flink.graph.generator.CompleteGraph: An undirected Graph connecting every distinct pair of vertices.
compute(Vertex<K, VV>, MessageIterator<Message>) - Method in class org.apache.flink.graph.pregel.ComputeFunction: This method is invoked once per superstep, for each active vertex.
ComputeFunction<K,VV,EV,Message> - Class in org.apache.flink.graph.pregel: The base class for the message-passing functions between vertices as a part of a VertexCentricIteration.
ComputeFunction() - Constructor for class org.apache.flink.graph.pregel.ComputeFunction
configure(Configuration) - Method in class org.apache.flink.graph.AnalyticHelper
configure(GSAConfiguration) - Method in class org.apache.flink.graph.gsa.GatherSumApplyIteration: Configures this gather-sum-apply iteration with the provided parameters.
configure(VertexCentricConfiguration) - Method in class org.apache.flink.graph.pregel.VertexCentricIteration: Configures this vertex-centric iteration with the provided parameters.
configure(ScatterGatherConfiguration) - Method in class org.apache.flink.graph.spargel.ScatterGatherIteration: Configures this scatter-gather iteration with the provided parameters.
conflictsWith(OptionalBoolean) - Method in class org.apache.flink.graph.utils.proxy.OptionalBoolean: The conflicting states are true with false and false with true.
ConnectedComponents<K,VV extends Comparable<VV>,EV> - Class in org.apache.flink.graph.library: A scatter-gather implementation of the Weakly Connected Components algorithm.
ConnectedComponents(Integer) - Constructor for class org.apache.flink.graph.library.ConnectedComponents: Creates an instance of the Connected Components algorithm.
ConnectedComponents.CCMessenger<K,VV extends Comparable<VV>> - Class in org.apache.flink.graph.library: Sends the current vertex value to all adjacent vertices.
ConnectedComponents.CCUpdater<K,VV extends Comparable<VV>> - Class in org.apache.flink.graph.library: Updates the value of a vertex by picking the minimum neighbor value out of all the incoming messages.
copy() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
copy(ByteValueArray) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
copy(ByteValueArray, ByteValueArray) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
copy() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
copy(CharValueArray) - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
copy(CharValueArray, CharValueArray) - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
copy() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
copy(DoubleValueArray) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
copy(DoubleValueArray, DoubleValueArray) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
copy() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
copy(FloatValueArray) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
copy(FloatValueArray, FloatValueArray) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
copy() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
copy(IntValueArray) - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
copy(IntValueArray, IntValueArray) - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
copy() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
copy(LongValueArray) - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
copy(LongValueArray, LongValueArray) - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
copy() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
copy(NullValueArray) - Method in class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
copy(NullValueArray, NullValueArray) - Method in class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
copy() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
copy(ShortValueArray) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
copy(ShortValueArray, ShortValueArray) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
copy() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
copy(StringValueArray) - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
copy(StringValueArray, StringValueArray) - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
copyFrom(TriangleEnumerator.EdgeWithDegrees<K>) - Method in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
copyInternal(DataInputView, DataOutputView) - Static method in class org.apache.flink.graph.types.valuearray.ByteValueArray
copyInternal(DataInputView, DataOutputView) - Static method in class org.apache.flink.graph.types.valuearray.CharValueArray
copyInternal(DataInputView, DataOutputView) - Static method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
copyInternal(DataInputView, DataOutputView) - Static method in class org.apache.flink.graph.types.valuearray.FloatValueArray
copyInternal(DataInputView, DataOutputView) - Static method in class org.apache.flink.graph.types.valuearray.IntValueArray
copyInternal(DataInputView, DataOutputView) - Static method in class org.apache.flink.graph.types.valuearray.LongValueArray
copyInternal(DataInputView, DataOutputView) - Static method in class org.apache.flink.graph.types.valuearray.ShortValueArray
copyInternal(DataInputView, DataOutputView) - Static method in class org.apache.flink.graph.types.valuearray.StringValueArray
copyNormalizedKey(MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
copyNormalizedKey(MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
copyNormalizedKey(MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
copyNormalizedKey(MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
copyNormalizedKey(MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
copyNormalizedKey(MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
copyNormalizedKey(MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
copyNormalizedKey(MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
copyNormalizedKey(MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
copyTo(ValueArray<ByteValue>) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
copyTo(ValueArray<CharValue>) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
copyTo(ValueArray<DoubleValue>) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
copyTo(ValueArray<FloatValue>) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
copyTo(ValueArray<IntValue>) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
copyTo(ValueArray<LongValue>) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
copyTo(ValueArray<NullValue>) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
copyTo(ValueArray<ShortValue>) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
copyTo(ValueArray<StringValue>) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
Count<T> - Class in org.apache.flink.graph.asm.dataset: Count the number of elements in a DataSet.
Count() - Constructor for class org.apache.flink.graph.asm.dataset.Count
count(DataSet<T>) - Static method in class org.apache.flink.graph.utils.GraphUtils: Count the number of elements in a DataSet.
createComparator(boolean, ExecutionConfig) - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
createInstance() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
createInstance() - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
createInstance() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
createInstance() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
createInstance() - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
createInstance() - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
createInstance() - Method in class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
createInstance() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
createInstance() - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
createResult() - Method in class org.apache.flink.graph.gsa.GatherSumApplyIteration: Computes the results of the gather-sum-apply iteration.
createResult() - Method in class org.apache.flink.graph.pregel.VertexCentricIteration: Creates the operator that represents this vertex-centric graph computation.
createResult() - Method in class org.apache.flink.graph.spargel.ScatterGatherIteration: Creates the operator that represents this scatter-gather graph computation.
createSerializer(ExecutionConfig) - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
createTypeInfo(Type, Map<String, TypeInformation<?>>) - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfoFactory
createValueArray(Class<? extends Value>) - Static method in class org.apache.flink.graph.types.valuearray.ValueArrayFactory: Produce a ValueArray for the given Value type.
createValueArray(Class<? extends Value>, int) - Static method in class org.apache.flink.graph.types.valuearray.ValueArrayFactory: Produce a ValueArray for the given Value type with the given bounded size.
CycleGraph - Class in org.apache.flink.graph.generator
CycleGraph(ExecutionEnvironment, long) - Constructor for class org.apache.flink.graph.generator.CycleGraph: An undirected Graph with n vertices where each vertex v_i is connected to adjacent vertices v_(i+1)%n and v_(i-1)%n.

D

D1 - Static variable in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
D2 - Static variable in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
DataSetAnalytic<T,R> - Interface in org.apache.flink.graph.asm.dataset: A DataSetAnalytic is similar to a CustomUnaryOperation but is terminal and results are retrieved via accumulators.
DataSetAnalyticBase<T,R> - Class in org.apache.flink.graph.asm.dataset: Base class for DataSetAnalytic.
DataSetAnalyticBase() - Constructor for class org.apache.flink.graph.asm.dataset.DataSetAnalyticBase
DEFAULT_A - Static variable in class org.apache.flink.graph.generator.RMatGraph
DEFAULT_B - Static variable in class org.apache.flink.graph.generator.RMatGraph
DEFAULT_C - Static variable in class org.apache.flink.graph.generator.RMatGraph
DEFAULT_CAPACITY_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.ByteValueArray
DEFAULT_CAPACITY_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.CharValueArray
DEFAULT_CAPACITY_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.DoubleValueArray
DEFAULT_CAPACITY_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.FloatValueArray
DEFAULT_CAPACITY_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.IntValueArray
DEFAULT_CAPACITY_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.LongValueArray
DEFAULT_CAPACITY_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.ShortValueArray
DEFAULT_CAPACITY_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.StringValueArray
DEFAULT_GROUP_SIZE - Static variable in class org.apache.flink.graph.library.similarity.JaccardIndex
DEFAULT_NOISE - Static variable in class org.apache.flink.graph.generator.RMatGraph
DEFAULT_SEED - Static variable in class org.apache.flink.graph.generator.random.JDKRandomGeneratorFactory
DEFAULT_SEED - Static variable in class org.apache.flink.graph.generator.random.MersenneTwisterFactory
DegreeAnnotationFunctions - Class in org.apache.flink.graph.asm.degree.annotate: Common user-defined-functions.
DegreeAnnotationFunctions.DegreeCount<K> - Class in org.apache.flink.graph.asm.degree.annotate: Combines the vertex degree count.
DegreeAnnotationFunctions.JoinEdgeDegreeWithVertexDegree<K,EV,D> - Class in org.apache.flink.graph.asm.degree.annotate: Composes the vertex degree with this edge value.
DegreeAnnotationFunctions.JoinEdgeWithVertexDegree<K,EV,D> - Class in org.apache.flink.graph.asm.degree.annotate: Assigns the vertex degree to this edge value.
DegreeAnnotationFunctions.JoinVertexWithVertexDegree<K,VV> - Class in org.apache.flink.graph.asm.degree.annotate: Performs a left outer join to apply a zero count for vertices with out- or in-degree of zero.
DegreeAnnotationFunctions.MapEdgeToSourceId<K,EV> - Class in org.apache.flink.graph.asm.degree.annotate: Emits the source vertex ID along with an initial count.
DegreeAnnotationFunctions.MapEdgeToTargetId<K,EV> - Class in org.apache.flink.graph.asm.degree.annotate: Emits the target vertex ID along with an initial count.
DegreeCount() - Constructor for class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.DegreeCount
Degrees() - Constructor for class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees.Degrees
Degrees(LongValue, LongValue, LongValue) - Constructor for class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees.Degrees
deserialize(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
deserialize(ByteValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
deserialize(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
deserialize(CharValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
deserialize(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
deserialize(DoubleValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
deserialize(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
deserialize(FloatValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
deserialize(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
deserialize(IntValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
deserialize(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
deserialize(LongValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
deserialize(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
deserialize(NullValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
deserialize(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
deserialize(ShortValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
deserialize(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
deserialize(StringValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
difference(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.Graph: Performs Difference on the vertex and edge sets of the input graphs removes common vertices and edges.
DoubleValueArray - Class in org.apache.flink.graph.types.valuearray: An array of DoubleValue.
DoubleValueArray() - Constructor for class org.apache.flink.graph.types.valuearray.DoubleValueArray: Initializes an expandable array with default capacity.
DoubleValueArray(int) - Constructor for class org.apache.flink.graph.types.valuearray.DoubleValueArray: Initializes a fixed-size array with the provided number of doubles.
DoubleValueArrayComparator - Class in org.apache.flink.graph.types.valuearray: Specialized comparator for DoubleValueArray based on CopyableValueComparator.
DoubleValueArrayComparator(boolean) - Constructor for class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
DoubleValueArraySerializer - Class in org.apache.flink.graph.types.valuearray: Specialized serializer for DoubleValueArray.
DoubleValueArraySerializer() - Constructor for class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
duplicate() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
duplicate() - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
duplicate() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
duplicate() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
duplicate() - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
duplicate() - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
duplicate() - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
duplicate() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
duplicate() - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator

E

EchoGraph - Class in org.apache.flink.graph.generator: A CirculantGraph with n vertices defined by the width of a single range of offsets centered at n/2.
EchoGraph(ExecutionEnvironment, long, long) - Constructor for class org.apache.flink.graph.generator.EchoGraph: An undirected Graph whose vertices have the same degree.
Edge<K,V> - Class in org.apache.flink.graph: An Edge represents a link between two vertices, the source and the target and can carry an attached value.
Edge() - Constructor for class org.apache.flink.graph.Edge
Edge(K, K, V) - Constructor for class org.apache.flink.graph.Edge
EdgeDegreePair<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.annotate.undirected: Annotates edges of an undirected graph with the degree of both the source and target degree vertices.
EdgeDegreePair() - Constructor for class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeDegreePair
EdgeDegreesPair<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.annotate.directed: Annotates edges of a directed graph with the degree, out-degree, and in-degree of both the source and target vertices.
EdgeDegreesPair() - Constructor for class org.apache.flink.graph.asm.degree.annotate.directed.EdgeDegreesPair
EdgeDirection - Enum in org.apache.flink.graph: The EdgeDirection is used to select a node's neighborhood by the Graph.groupReduceOnEdges(EdgesFunction, EdgeDirection), Graph.groupReduceOnEdges(EdgesFunctionWithVertexValue, EdgeDirection), Graph.groupReduceOnNeighbors(NeighborsFunction, EdgeDirection), Graph.groupReduceOnNeighbors(NeighborsFunctionWithVertexValue, EdgeDirection), Graph.reduceOnEdges(ReduceEdgesFunction, EdgeDirection) and Graph.reduceOnNeighbors(ReduceNeighborsFunction, EdgeDirection) methods.
edgeJoin(EV, T) - Method in interface org.apache.flink.graph.EdgeJoinFunction: Applies a transformation on the current edge value and the value of the matched tuple of the input DataSet.
EdgeJoinFunction<EV,T> - Interface in org.apache.flink.graph: Interface to be implemented by the transformation function applied in Graph.joinWithEdges(DataSet, EdgeJoinFunction), Graph.joinWithEdgesOnSource(DataSet, EdgeJoinFunction), and Graph.joinWithEdgesOnTarget(DataSet, EdgeJoinFunction) methods.
EdgeMetrics<K extends Comparable<K>,VV,EV> - Class in org.apache.flink.graph.library.metric.directed: Compute the following edge metrics in a directed graph.
EdgeMetrics() - Constructor for class org.apache.flink.graph.library.metric.directed.EdgeMetrics
EdgeMetrics<K extends Comparable<K>,VV,EV> - Class in org.apache.flink.graph.library.metric.undirected: Compute the following edge metrics in an undirected graph.
EdgeMetrics() - Constructor for class org.apache.flink.graph.library.metric.undirected.EdgeMetrics
EdgeMetrics.Result - Class in org.apache.flink.graph.library.metric.directed: Wraps edge metrics.
EdgeMetrics.Result - Class in org.apache.flink.graph.library.metric.undirected: Wraps edge metrics.
EdgeOrder - Enum in org.apache.flink.graph: These bitmasks are used by edge-flipping algorithms to mark the edge order relative to the original edge direction.
edgeReader - Variable in class org.apache.flink.graph.GraphCsvReader
EdgesFunction<K,EV,O> - Interface in org.apache.flink.graph: Interface to be implemented by the function applied to a vertex neighborhood in the Graph.groupReduceOnEdges(EdgesFunction, EdgeDirection) method.
EdgesFunctionWithVertexValue<K,VV,EV,O> - Interface in org.apache.flink.graph: Interface to be implemented by the function applied to a vertex neighborhood in the Graph.groupReduceOnEdges(EdgesFunctionWithVertexValue, EdgeDirection) method.
EdgeSourceDegree<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.annotate.undirected: Annotates edges of an undirected graph with degree of the source vertex.
EdgeSourceDegree() - Constructor for class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeSourceDegree
EdgeSourceDegrees<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.annotate.directed: Annotates edges of a directed graph with the degree, out-degree, and in-degree of the source vertex.
EdgeSourceDegrees() - Constructor for class org.apache.flink.graph.asm.degree.annotate.directed.EdgeSourceDegrees
EdgeTargetDegree<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.annotate.undirected: Annotates edges of an undirected graph with degree of the target vertex.
EdgeTargetDegree() - Constructor for class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeTargetDegree
EdgeTargetDegrees<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.annotate.directed: Annotates edges of a directed graph with the degree, out-degree, and in-degree of the target vertex.
EdgeTargetDegrees() - Constructor for class org.apache.flink.graph.asm.degree.annotate.directed.EdgeTargetDegrees
EdgeToTuple2Map<K,EV> - Class in org.apache.flink.graph.utils: Create a Tuple2 DataSet from the vertices of an Edge DataSet.
EdgeToTuple2Map() - Constructor for class org.apache.flink.graph.utils.EdgeToTuple2Map
EdgeToTuple3Map<K,EV> - Class in org.apache.flink.graph.utils: Create a Tuple3 DataSet from an Edge DataSet.
EdgeToTuple3Map() - Constructor for class org.apache.flink.graph.utils.EdgeToTuple3Map
edgeTypes(Class<K>, Class<EV>) - Method in class org.apache.flink.graph.GraphCsvReader: Creates a Graph from CSV input with edge values, but without vertex values.
EdgeValue() - Constructor for class org.apache.flink.graph.library.Summarization.EdgeValue
EdgeWithDegrees() - Constructor for class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
ELEMENT_LENGTH_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.ByteValueArray
ELEMENT_LENGTH_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.CharValueArray
ELEMENT_LENGTH_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.DoubleValueArray
ELEMENT_LENGTH_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.FloatValueArray
ELEMENT_LENGTH_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.IntValueArray
ELEMENT_LENGTH_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.LongValueArray
ELEMENT_LENGTH_IN_BYTES - Static variable in class org.apache.flink.graph.types.valuearray.ShortValueArray
EmptyGraph - Class in org.apache.flink.graph.generator
EmptyGraph(ExecutionEnvironment, long) - Constructor for class org.apache.flink.graph.generator.EmptyGraph: The Graph containing no edges.
env - Variable in class org.apache.flink.graph.asm.dataset.DataSetAnalyticBase
env - Variable in class org.apache.flink.graph.GraphAnalyticBase
equals(Object) - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum
equals(Object) - Method in class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient.Result
equals(Object) - Method in class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient.Result
equals(Object) - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result
equals(Object) - Method in class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient.Result
equals(Object) - Method in class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient.Result
equals(Object) - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result
equals(Object) - Method in class org.apache.flink.graph.library.metric.directed.EdgeMetrics.Result
equals(Object) - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result
equals(Object) - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics.Result
equals(Object) - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result
equals(Object) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
equals(Object) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
equals(Object) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
equals(Object) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
equals(Object) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
equals(Object) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
equals(Object) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
equals(Object) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
equals(Object) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
equals(Object) - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
equals(Object) - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingDataSet
equals(Object) - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingGraph
equalToReference(ByteValueArray) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
equalToReference(CharValueArray) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
equalToReference(DoubleValueArray) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
equalToReference(FloatValueArray) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
equalToReference(IntValueArray) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
equalToReference(LongValueArray) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
equalToReference(NullValueArray) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
equalToReference(ShortValueArray) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
equalToReference(StringValueArray) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
execute() - Method in interface org.apache.flink.graph.asm.dataset.DataSetAnalytic: Execute the program and return the result.
execute(String) - Method in interface org.apache.flink.graph.asm.dataset.DataSetAnalytic: Execute the program and return the result.
execute() - Method in class org.apache.flink.graph.asm.dataset.DataSetAnalyticBase
execute(String) - Method in class org.apache.flink.graph.asm.dataset.DataSetAnalyticBase
execute() - Method in interface org.apache.flink.graph.GraphAnalytic: Execute the program and return the result.
execute(String) - Method in interface org.apache.flink.graph.GraphAnalytic: Execute the program and return the result.
execute() - Method in class org.apache.flink.graph.GraphAnalyticBase
execute(String) - Method in class org.apache.flink.graph.GraphAnalyticBase
extractKeys(Object, Object[], int) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
extractKeys(Object, Object[], int) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
extractKeys(Object, Object[], int) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
extractKeys(Object, Object[], int) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
extractKeys(Object, Object[], int) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
extractKeys(Object, Object[], int) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
extractKeys(Object, Object[], int) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
extractKeys(Object, Object[], int) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
extractKeys(Object, Object[], int) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator

F

fieldDelimiterEdges(String) - Method in class org.apache.flink.graph.GraphCsvReader: Configures the Delimiter that separates fields in a row for the CSV reader used to read the edges (',') is used by default.
fieldDelimiterVertices(String) - Method in class org.apache.flink.graph.GraphCsvReader: Configures the Delimiter that separates fields in a row for the CSV reader used to read the vertices (',') is used by default.
filterOnEdges(FilterFunction<Edge<K, EV>>) - Method in class org.apache.flink.graph.Graph: Apply a filtering function to the graph and return a sub-graph that satisfies the predicates only for the edges.
filterOnVertices(FilterFunction<Vertex<K, VV>>) - Method in class org.apache.flink.graph.Graph: Apply a filtering function to the graph and return a sub-graph that satisfies the predicates only for the vertices.
flatMap(RT, Collector<RT>) - Method in class org.apache.flink.graph.asm.result.BinaryResult.MirrorResult
FloatValueArray - Class in org.apache.flink.graph.types.valuearray: An array of FloatValue.
FloatValueArray() - Constructor for class org.apache.flink.graph.types.valuearray.FloatValueArray: Initializes an expandable array with default capacity.
FloatValueArray(int) - Constructor for class org.apache.flink.graph.types.valuearray.FloatValueArray: Initializes a fixed-size array with the provided number of floats.
FloatValueArrayComparator - Class in org.apache.flink.graph.types.valuearray: Specialized comparator for FloatValueArray based on CopyableValueComparator.
FloatValueArrayComparator(boolean) - Constructor for class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
FloatValueArraySerializer - Class in org.apache.flink.graph.types.valuearray: Specialized serializer for FloatValueArray.
FloatValueArraySerializer() - Constructor for class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
fromCollection(Collection<Vertex<K, VV>>, Collection<Edge<K, EV>>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a Collection of vertices and a Collection of edges.
fromCollection(Collection<Edge<K, EV>>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a Collection of edges.
fromCollection(Collection<Edge<K, EV>>, MapFunction<K, VV>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a Collection of edges.
fromCsvReader(String, String, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a Graph from a CSV file of vertices and a CSV file of edges.
fromCsvReader(String, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a CSV file of edges.
fromCsvReader(String, MapFunction<K, VV>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a CSV file of edges.
fromDataSet(DataSet<Vertex<KT, VVT>>, DataSet<Vertex<KB, VVB>>, DataSet<BipartiteEdge<KT, KB, EV>>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.bipartite.BipartiteGraph: Create bipartite graph from datasets.
fromDataSet(DataSet<Vertex<K, VV>>, DataSet<Edge<K, EV>>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a DataSet of vertices and a DataSet of edges.
fromDataSet(DataSet<Edge<K, EV>>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a DataSet of edges.
fromDataSet(DataSet<Edge<K, EV>>, MapFunction<K, VV>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a DataSet of edges.
fromTuple2DataSet(DataSet<Tuple2<K, K>>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a DataSet of Tuple2 objects for edges.
fromTuple2DataSet(DataSet<Tuple2<K, K>>, MapFunction<K, VV>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a DataSet of Tuple2 objects for edges.
fromTupleDataSet(DataSet<Tuple2<K, VV>>, DataSet<Tuple3<K, K, EV>>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a DataSet of Tuple2 objects for vertices and Tuple3 objects for edges.
fromTupleDataSet(DataSet<Tuple3<K, K, EV>>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a DataSet of Tuple3 objects for edges.
fromTupleDataSet(DataSet<Tuple3<K, K, EV>>, MapFunction<K, VV>, ExecutionEnvironment) - Static method in class org.apache.flink.graph.Graph: Creates a graph from a DataSet of Tuple3 objects for edges.

G

gather(Neighbor<VV, EV>) - Method in class org.apache.flink.graph.gsa.GatherFunction: This method is invoked once per superstep, for each Neighbor of each Vertex in the beginning of each superstep in a GatherSumApplyIteration.
GatherFunction<VV,EV,M> - Class in org.apache.flink.graph.gsa: The base class for the first step of a GatherSumApplyIteration.
GatherFunction() - Constructor for class org.apache.flink.graph.gsa.GatherFunction
GatherFunction<K,VV,Message> - Class in org.apache.flink.graph.spargel: This class must be extended by functions that compute the state of the vertex depending on the old state and the incoming messages.
GatherFunction() - Constructor for class org.apache.flink.graph.spargel.GatherFunction
GatherSumApplyIteration<K,VV,EV,M> - Class in org.apache.flink.graph.gsa: This class represents iterative graph computations, programmed in a gather-sum-apply perspective.
generate() - Method in class org.apache.flink.graph.generator.CirculantGraph
generate() - Method in class org.apache.flink.graph.generator.CompleteGraph
generate() - Method in class org.apache.flink.graph.generator.CycleGraph
generate() - Method in class org.apache.flink.graph.generator.EchoGraph
generate() - Method in class org.apache.flink.graph.generator.EmptyGraph
generate() - Method in interface org.apache.flink.graph.generator.GraphGenerator: Generates the configured graph.
generate() - Method in class org.apache.flink.graph.generator.GridGraph
generate() - Method in class org.apache.flink.graph.generator.HypercubeGraph
generate() - Method in class org.apache.flink.graph.generator.PathGraph
generate() - Method in class org.apache.flink.graph.generator.RMatGraph
generate() - Method in class org.apache.flink.graph.generator.SingletonEdgeGraph
generate() - Method in class org.apache.flink.graph.generator.StarGraph
generator() - Method in interface org.apache.flink.graph.generator.random.RandomGenerable: Returns an initialized RandomGenerator.
GeneratorFactoryBase<T extends org.apache.commons.math3.random.RandomGenerator> - Class in org.apache.flink.graph.generator.random: This base class handles the task of dividing the requested work into the appropriate number of blocks of near-equal size.
GeneratorFactoryBase() - Constructor for class org.apache.flink.graph.generator.random.GeneratorFactoryBase
get() - Method in class org.apache.flink.graph.utils.proxy.OptionalBoolean: Get the boolean state.
getAccumulator(ExecutionEnvironment, String) - Method in class org.apache.flink.graph.AnalyticHelper: Gets the accumulator with the given name.
getAdamicAdarScore() - Method in class org.apache.flink.graph.library.similarity.AdamicAdar.Result: Get the Adamic-Adar score, equal to the sum over common neighbors of the inverse logarithm of degree.
getAggregators() - Method in class org.apache.flink.graph.IterationConfiguration: Gets the set of aggregators that are registered for this vertex-centric iteration.
getAlgorithmName() - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase: Algorithms are identified by name rather than by class to allow subclassing.
getApplyBcastVars() - Method in class org.apache.flink.graph.gsa.GSAConfiguration: Get the broadcast variables of the ApplyFunction.
getArity() - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
getAuthorityScore() - Method in class org.apache.flink.graph.library.linkanalysis.HITS.Result: Get the authority score.
getAverageClusteringCoefficient() - Method in class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient.Result: Get the average clustering coefficient.
getAverageClusteringCoefficient() - Method in class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient.Result: Get the average clustering coefficient.
getAverageDegree() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the average degree, the average number of in- plus out-edges per vertex.
getAverageDegree() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result: Get the average degree, the average number of edges per vertex.
getBcastVars() - Method in class org.apache.flink.graph.pregel.VertexCentricConfiguration: Get the broadcast variables of the compute function.
getBinaryLength() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
getBinaryLength() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
getBinaryLength() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
getBinaryLength() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
getBinaryLength() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
getBinaryLength() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
getBinaryLength() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
getBinaryLength() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
getBinaryLength() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
getBitmask() - Method in enum org.apache.flink.graph.EdgeOrder: Returns a bitmask used for marking whether an edge is in the same direction as in the original edge set (FORWARD), is flipped relative to the original edge set (REVERSE), or both (MUTUAL).
getBitmask() - Method in class org.apache.flink.graph.library.clustering.directed.TriangleListing.Result: Get the bitmask indicating the presence of the six potential connecting edges.
getBlockCount() - Method in class org.apache.flink.graph.generator.random.BlockInfo
getBlockIndex() - Method in class org.apache.flink.graph.generator.random.BlockInfo
getBottomId() - Method in class org.apache.flink.graph.bipartite.BipartiteEdge
getBottomVertices() - Method in class org.apache.flink.graph.bipartite.BipartiteGraph: Get dataset with bottom vertices.
getBroadcastSet(String) - Method in class org.apache.flink.graph.gsa.ApplyFunction: Gets the broadcast data set registered under the given name.
getBroadcastSet(String) - Method in class org.apache.flink.graph.gsa.GatherFunction: Gets the broadcast data set registered under the given name.
getBroadcastSet(String) - Method in class org.apache.flink.graph.gsa.SumFunction: Gets the broadcast data set registered under the given name.
getBroadcastSet(String) - Method in class org.apache.flink.graph.pregel.ComputeFunction: Gets the broadcast data set registered under the given name.
getBroadcastSet(String) - Method in class org.apache.flink.graph.spargel.GatherFunction: Gets the broadcast data set registered under the given name.
getBroadcastSet(String) - Method in class org.apache.flink.graph.spargel.ScatterFunction: Gets the broadcast data set registered under the given name.
getChecksum() - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum: Get the checksum over the hash() of elements.
getContext() - Method in class org.apache.flink.graph.Graph
getCount() - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum: Get the number of elements.
getCount003() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "003" triads which have zero connecting vertices.
getCount012() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "012" triads which have one unidirectional edge among the vertices.
getCount021c() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "021c" triads which have two unidirectional edges among the vertices, forming an open triplet; one edge sources and one edge targets the center vertex.
getCount021d() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "021d" triads which have two unidirectional edges among the vertices, forming an open triplet; both edges source the center vertex.
getCount021u() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "021u" triads which have two unidirectional edges among the vertices, forming an open triplet; both edges target the center vertex.
getCount03() - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result: Get the count of "03" triads which have zero connecting vertices.
getCount030c() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "030c" triads which have three unidirectional edges among the vertices, forming a closed triplet, a triangle; the three unidirectional edges both source and target different vertices.
getCount030t() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "030t" triads which have three unidirectional edges among the vertices, forming a closed triplet, a triangle; two of the unidirectional edges source/target the same vertex.
getCount102() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "102" triads which have one bidirectional edge among the vertices.
getCount111d() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "111d" triads which have one unidirectional and one bidirectional edge among the vertices, forming an open triplet; the unidirectional edge targets the center vertex.
getCount111u() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "111u" triads which have one unidirectional and one bidirectional edge among the vertices, forming an open triplet; the unidirectional edge sources the center vertex.
getCount12() - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result: Get the count of "12" triads which have one edge among the vertices.
getCount120c() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "120c" triads which have two unidirectional edges and one bidirectional edge among the vertices, forming a closed triplet, a triangle; one vertex is sourced by and targeted by the unidirectional edges.
getCount120d() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "120d" triads which have two unidirectional edges and one bidirectional edge among the vertices, forming a closed triplet, a triangle; both unidirectional edges source the same vertex.
getCount120u() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "120u" triads which have two unidirectional and one bidirectional edges among the vertices, forming a closed triplet, a triangle; both unidirectional edges target the same vertex.
getCount201() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "201" triads which have two unidirectional edges among the vertices, forming an open triplet.
getCount21() - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result: Get the count of "21" triads which have two edges among the vertices and form a open triplet.
getCount210() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "210" triads which have one unidirectional edge and two bidirectional edges among the vertices, forming a closed triplet, a triangle.
getCount30() - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result: Get the count of "30" triads which have three edges among the vertices and form a closed triplet, a triangle.
getCount300() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the count of "300" triads which have three bidirectional edges among the vertices, forming a closed triplet, a triangle.
getCounts() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result: Get the array of counts.
getCounts() - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result: Get the array of counts.
getDegree() - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees.Degrees
getDegree() - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result: Get the vertex degree.
getDegree() - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result: Get the vertex degree.
getDegrees() - Method in class org.apache.flink.graph.Graph: Return the degree of all vertices in the graph.
getDensity() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the density, the ratio of actual to potential edges between vertices.
getDensity() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result: Get the density, the ratio of actual to potential edges between vertices.
getDirection() - Method in class org.apache.flink.graph.gsa.GSAConfiguration: Gets the direction from which the neighbors are to be selected By default the neighbors who are target of the edges are selected.
getDirection() - Method in class org.apache.flink.graph.spargel.ScatterFunction: Retrieves the edge direction in which messages are propagated in the scatter-gather iteration.
getDirection() - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration: Gets the direction in which messages are sent in the ScatterFunction.
getDistinctNeighborCount() - Method in class org.apache.flink.graph.library.similarity.JaccardIndex.Result: Get the distinct neighbor count.
getEdge() - Method in class org.apache.flink.graph.Triplet
getEdgeGroupCount() - Method in class org.apache.flink.graph.library.Summarization.EdgeValue
getEdgeGroupValue() - Method in class org.apache.flink.graph.library.Summarization.EdgeValue
getEdgeIds() - Method in class org.apache.flink.graph.Graph
getEdges() - Method in class org.apache.flink.graph.bipartite.BipartiteGraph: Get dataset with graph edges.
getEdges() - Method in class org.apache.flink.graph.Graph
getEdges() - Method in class org.apache.flink.graph.pregel.ComputeFunction: Gets an Iterable with all out-going edges.
getEdges() - Method in class org.apache.flink.graph.spargel.ScatterFunction: Gets an Iterable with all edges.
getEdgesAsTuple3() - Method in class org.apache.flink.graph.Graph
getEdgeValue() - Method in class org.apache.flink.graph.gsa.Neighbor
getElementCount() - Method in class org.apache.flink.graph.generator.random.BlockInfo
getFirstDegree() - Method in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
getFirstElement() - Method in class org.apache.flink.graph.generator.random.BlockInfo
getFirstVertex() - Method in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
getFirstVertex() - Method in class org.apache.flink.graph.library.TriangleEnumerator.Triad
getFlatComparators() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
getFlatComparators() - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
getFlatComparators() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
getFlatComparators() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
getFlatComparators() - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
getFlatComparators() - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
getFlatComparators() - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
getFlatComparators() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
getFlatComparators() - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
getGatherBcastVars() - Method in class org.apache.flink.graph.gsa.GSAConfiguration: Get the broadcast variables of the GatherFunction.
getGatherBcastVars() - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration: Get the broadcast variables of the GatherFunction.
getGenericParameters() - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
getGlobalClusteringCoefficientScore() - Method in class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient.Result: Get the global clustering coefficient score.
getGlobalClusteringCoefficientScore() - Method in class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient.Result: Get the global clustering coefficient score.
getGroupRepresentativeId() - Method in class org.apache.flink.graph.library.Summarization.VertexGroupItem
getGroupRepresentativeId() - Method in class org.apache.flink.graph.library.Summarization.VertexWithRepresentative
getHubScore() - Method in class org.apache.flink.graph.library.linkanalysis.HITS.Result: Get the hub score.
getId() - Method in class org.apache.flink.graph.Vertex
getInDegree() - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees.Degrees
getInDegree() - Method in class org.apache.flink.graph.spargel.GatherFunction: Retrieves the vertex in-degree (number of in-coming edges).
getInDegree() - Method in class org.apache.flink.graph.spargel.ScatterFunction: Retrieves the vertex in-degree (number of in-coming edges).
getIntermediateVertexId() - Method in class org.apache.flink.graph.bipartite.Projection
getIntermediateVertexValue() - Method in class org.apache.flink.graph.bipartite.Projection
getIterationAggregator(String) - Method in class org.apache.flink.graph.gsa.ApplyFunction: Gets the iteration aggregator registered under the given name.
getIterationAggregator(String) - Method in class org.apache.flink.graph.gsa.GatherFunction: Gets the iteration aggregator registered under the given name.
getIterationAggregator(String) - Method in class org.apache.flink.graph.gsa.SumFunction: Gets the iteration aggregator registered under the given name.
getIterationAggregator(String) - Method in class org.apache.flink.graph.pregel.ComputeFunction: Gets the iteration aggregator registered under the given name.
getIterationAggregator(String) - Method in class org.apache.flink.graph.spargel.GatherFunction: Gets the iteration aggregator registered under the given name.
getIterationAggregator(String) - Method in class org.apache.flink.graph.spargel.ScatterFunction: Gets the iteration aggregator registered under the given name.
getIterationConfiguration() - Method in class org.apache.flink.graph.gsa.GatherSumApplyIteration
getIterationConfiguration() - Method in class org.apache.flink.graph.pregel.VertexCentricIteration
getIterationConfiguration() - Method in class org.apache.flink.graph.spargel.ScatterGatherIteration
getJaccardIndexScore() - Method in class org.apache.flink.graph.library.similarity.JaccardIndex.Result: Get the Jaccard Index score, equal to the number of shared neighbors of the source and target vertices divided by the number of distinct neighbors.
getLastOffset() - Method in class org.apache.flink.graph.generator.CirculantGraph.OffsetRange: Get the offset of the last index in the range.
getLength() - Method in class org.apache.flink.graph.generator.CirculantGraph.OffsetRange: Get the range length.
getLength() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
getLength() - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
getLength() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
getLength() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
getLength() - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
getLength() - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
getLength() - Method in class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
getLength() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
getLength() - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
getLocalClusteringCoefficientScore() - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result: Get the local clustering coefficient score.
getLocalClusteringCoefficientScore() - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result: Get the local clustering coefficient score.
getLocalValue() - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum
getMaximumDegree() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the maximum degree.
getMaximumDegree() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result: Get the maximum degree.
getMaximumInDegree() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the maximum in degree.
getMaximumOutDegree() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the maximum out degree.
getMaximumRectangleTriplets() - Method in class org.apache.flink.graph.library.metric.directed.EdgeMetrics.Result: Get the maximum rectangle triplets.
getMaximumRectangleTriplets() - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics.Result: Get the maximum rectangle triplets.
getMaximumTriangleTriplets() - Method in class org.apache.flink.graph.library.metric.directed.EdgeMetrics.Result: Get the maximum triangle triplets.
getMaximumTriangleTriplets() - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics.Result: Get the maximum triangle triplets.
getMaximumTriplets() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the maximum triplets.
getMaximumTriplets() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result: Get the maximum triplets.
getMaxNormalizedKeyLen() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
getMaxNormalizedKeyLen() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
getMaxNormalizedKeyLen() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
getMaxNormalizedKeyLen() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
getMaxNormalizedKeyLen() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
getMaxNormalizedKeyLen() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
getMaxNormalizedKeyLen() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
getMaxNormalizedKeyLen() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
getMaxNormalizedKeyLen() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
getMinimumCyclesPerBlock() - Method in class org.apache.flink.graph.generator.random.GeneratorFactoryBase
getMinimumCyclesPerBlock() - Method in class org.apache.flink.graph.generator.random.JDKRandomGeneratorFactory
getMinimumCyclesPerBlock() - Method in class org.apache.flink.graph.generator.random.MersenneTwisterFactory
getName(String) - Method in class org.apache.flink.graph.IterationConfiguration: Gets the name of the iteration.
getNeighborValue() - Method in class org.apache.flink.graph.gsa.Neighbor
getNormalizeKeyLen() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
getNormalizeKeyLen() - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
getNormalizeKeyLen() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
getNormalizeKeyLen() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
getNormalizeKeyLen() - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
getNormalizeKeyLen() - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
getNormalizeKeyLen() - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
getNormalizeKeyLen() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
getNormalizeKeyLen() - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
getNumberOfDirectedEdges() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the number of unidirectional edges.
getNumberOfEdges() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the number of edges.
getNumberOfEdges() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result: Get the number of edges.
getNumberOfRectangleTriplets() - Method in class org.apache.flink.graph.library.metric.directed.EdgeMetrics.Result: Get the number of rectangle triplets.
getNumberOfRectangleTriplets() - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics.Result: Get the number of rectangle triplets.
getNumberOfTriangles() - Method in class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient.Result: Get the number of triangles.
getNumberOfTriangles() - Method in class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient.Result: Get the number of triangles.
getNumberOfTriangleTriplets() - Method in class org.apache.flink.graph.library.metric.directed.EdgeMetrics.Result: Get the number of triangle triplets.
getNumberOfTriangleTriplets() - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics.Result: Get the number of triangle triplets.
getNumberOfTriplets() - Method in class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient.Result: Get the number of triplets.
getNumberOfTriplets() - Method in class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient.Result: Get the number of triplets.
getNumberOfTriplets() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the number of triplets.
getNumberOfTriplets() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result: Get the number of triplets.
getNumberOfUndirectedEdges() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the number of bidirectional edges.
getNumberOfVertices() - Method in class org.apache.flink.graph.gsa.ApplyFunction: Retrieves the number of vertices in the graph.
getNumberOfVertices() - Method in class org.apache.flink.graph.gsa.GatherFunction: Retrieves the number of vertices in the graph.
getNumberOfVertices() - Method in class org.apache.flink.graph.gsa.SumFunction: Retrieves the number of vertices in the graph.
getNumberOfVertices() - Method in class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient.Result: Get the number of vertices.
getNumberOfVertices() - Method in class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient.Result: Get the number of vertices.
getNumberOfVertices() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result: Get the number of vertices.
getNumberOfVertices() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result: Get the number of vertices.
getNumberOfVertices() - Method in class org.apache.flink.graph.spargel.GatherFunction: Retrieves the number of vertices in the graph.
getNumberOfVertices() - Method in class org.apache.flink.graph.spargel.ScatterFunction: Retrieves the number of vertices in the graph.
getOffset() - Method in class org.apache.flink.graph.generator.CirculantGraph.OffsetRange: Get the range offset.
getOutDegree() - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees.Degrees
getOutDegree() - Method in class org.apache.flink.graph.spargel.GatherFunction: Retrieve the vertex out-degree (number of out-going edges).
getOutDegree() - Method in class org.apache.flink.graph.spargel.ScatterFunction: Retrieve the vertex out-degree (number of out-going edges).
getPageRankScore() - Method in class org.apache.flink.graph.library.linkanalysis.PageRank.Result: Get the PageRank score.
getParallelism() - Method in class org.apache.flink.graph.IterationConfiguration: Gets the iteration's parallelism.
getPreviousIterationAggregate(String) - Method in class org.apache.flink.graph.gsa.ApplyFunction: Get the aggregated value that an aggregator computed in the previous iteration.
getPreviousIterationAggregate(String) - Method in class org.apache.flink.graph.gsa.GatherFunction: Get the aggregated value that an aggregator computed in the previous iteration.
getPreviousIterationAggregate(String) - Method in class org.apache.flink.graph.gsa.SumFunction: Get the aggregated value that an aggregator computed in the previous iteration.
getPreviousIterationAggregate(String) - Method in class org.apache.flink.graph.pregel.ComputeFunction: Get the aggregated value that an aggregator computed in the previous iteration.
getPreviousIterationAggregate(String) - Method in class org.apache.flink.graph.spargel.GatherFunction: Get the aggregated value that an aggregator computed in the previous iteration.
getPreviousIterationAggregate(String) - Method in class org.apache.flink.graph.spargel.ScatterFunction: Get the aggregated value that an aggregator computed in the previous iteration.
getProducedType() - Method in class org.apache.flink.graph.library.ConnectedComponents.CCMessenger
getProducedType() - Method in class org.apache.flink.graph.library.LabelPropagation.SendNewLabelToNeighbors
getProducedType() - Method in class org.apache.flink.graph.utils.GraphUtils.MapTo
getRandomGenerable() - Method in class org.apache.flink.graph.generator.random.BlockInfo
getRandomGenerables(long, int) - Method in class org.apache.flink.graph.generator.random.GeneratorFactoryBase
getRandomGenerables(long, int) - Method in interface org.apache.flink.graph.generator.random.RandomGenerableFactory: The amount of work (elementCount * cyclesPerElement) is used to generate a list of blocks of work of near-equal size.
getResult() - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode
getResult() - Method in class org.apache.flink.graph.asm.dataset.Collect
getResult() - Method in class org.apache.flink.graph.asm.dataset.Count
getResult() - Method in interface org.apache.flink.graph.asm.dataset.DataSetAnalytic: This method must be called after the program has executed.
getResult() - Method in interface org.apache.flink.graph.GraphAnalytic: This method must be called after the program has executed.
getResult() - Method in class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient
getResult() - Method in class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient
getResult() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus
getResult() - Method in class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient
getResult() - Method in class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient
getResult() - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus
getResult() - Method in class org.apache.flink.graph.library.metric.ChecksumHashCode
getResult() - Method in class org.apache.flink.graph.library.metric.directed.EdgeMetrics
getResult() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics
getResult() - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics
getResult() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics
getScatterBcastVars() - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration: Get the broadcast variables of the ScatterFunction.
getSecondDegree() - Method in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
getSecondVertex() - Method in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
getSecondVertex() - Method in class org.apache.flink.graph.library.TriangleEnumerator.Triad
getSharedNeighborCount() - Method in class org.apache.flink.graph.library.similarity.JaccardIndex.Result: Get the shared neighbor count.
getSource() - Method in class org.apache.flink.graph.Edge
getSourceEdgeValue() - Method in class org.apache.flink.graph.bipartite.Projection
getSrcVertex() - Method in class org.apache.flink.graph.Triplet
getsSourceVertexValue() - Method in class org.apache.flink.graph.bipartite.Projection
getState() - Method in class org.apache.flink.graph.utils.proxy.OptionalBoolean: Get the actual state.
getSumBcastVars() - Method in class org.apache.flink.graph.gsa.GSAConfiguration: Get the broadcast variables of the SumFunction.
getSuperstepNumber() - Method in class org.apache.flink.graph.gsa.ApplyFunction: Gets the number of the superstep, starting at 1.
getSuperstepNumber() - Method in class org.apache.flink.graph.gsa.GatherFunction: Gets the number of the superstep, starting at 1.
getSuperstepNumber() - Method in class org.apache.flink.graph.gsa.SumFunction: Gets the number of the superstep, starting at 1.
getSuperstepNumber() - Method in class org.apache.flink.graph.pregel.ComputeFunction: Gets the number of the superstep, starting at 1.
getSuperstepNumber() - Method in class org.apache.flink.graph.spargel.GatherFunction: Gets the number of the superstep, starting at 1.
getSuperstepNumber() - Method in class org.apache.flink.graph.spargel.ScatterFunction: Gets the number of the superstep, starting at 1.
getTarget() - Method in class org.apache.flink.graph.Edge
getTargetEdgeValue() - Method in class org.apache.flink.graph.bipartite.Projection
getTargetVertexValue() - Method in class org.apache.flink.graph.bipartite.Projection
getThirdVertex() - Method in class org.apache.flink.graph.library.TriangleEnumerator.Triad
getTopId() - Method in class org.apache.flink.graph.bipartite.BipartiteEdge
getTopVertices() - Method in class org.apache.flink.graph.bipartite.BipartiteGraph: Get dataset with top vertices.
getTotalFields() - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
getTrgVertex() - Method in class org.apache.flink.graph.Triplet
getTriangleCount() - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result: Get the number of triangles containing this vertex; equivalently, this is the number of edges between neighbors of this vertex.
getTriangleCount() - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result: Get the number of triangles containing this vertex; equivalently, this is the number of edges between neighbors of this vertex.
getTriplets() - Method in class org.apache.flink.graph.Graph: This method allows access to the graph's edge values along with its source and target vertex values.
getTypeClass() - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
getUndirected() - Method in class org.apache.flink.graph.Graph: This operation adds all inverse-direction edges to the graph.
getValue() - Method in class org.apache.flink.graph.bipartite.BipartiteEdge
getValue() - Method in class org.apache.flink.graph.Edge
getValue() - Method in class org.apache.flink.graph.Vertex
getVertexGroupCount() - Method in class org.apache.flink.graph.library.Summarization.VertexGroupItem
getVertexGroupCount() - Method in class org.apache.flink.graph.library.Summarization.VertexValue
getVertexGroupValue() - Method in class org.apache.flink.graph.library.Summarization.VertexGroupItem
getVertexGroupValue() - Method in class org.apache.flink.graph.library.Summarization.VertexValue
getVertexId() - Method in class org.apache.flink.graph.library.Summarization.VertexGroupItem
getVertexId0() - Method in interface org.apache.flink.graph.asm.result.BinaryResult: Get the first vertex ID.
getVertexId0() - Method in class org.apache.flink.graph.asm.result.BinaryResultBase
getVertexId0() - Method in interface org.apache.flink.graph.asm.result.TertiaryResult: Get the first vertex ID.
getVertexId0() - Method in class org.apache.flink.graph.asm.result.TertiaryResultBase
getVertexId0() - Method in interface org.apache.flink.graph.asm.result.UnaryResult: Get the first vertex ID.
getVertexId0() - Method in class org.apache.flink.graph.asm.result.UnaryResultBase
getVertexId1() - Method in interface org.apache.flink.graph.asm.result.BinaryResult: Get the second vertex ID.
getVertexId1() - Method in class org.apache.flink.graph.asm.result.BinaryResultBase
getVertexId1() - Method in interface org.apache.flink.graph.asm.result.TertiaryResult: Get the second vertex ID.
getVertexId1() - Method in class org.apache.flink.graph.asm.result.TertiaryResultBase
getVertexId2() - Method in interface org.apache.flink.graph.asm.result.TertiaryResult: Get the third vertex ID.
getVertexId2() - Method in class org.apache.flink.graph.asm.result.TertiaryResultBase
getVertexIds() - Method in class org.apache.flink.graph.Graph
getVertices() - Method in class org.apache.flink.graph.Graph
getVerticesAsTuple2() - Method in class org.apache.flink.graph.Graph
GlobalClusteringCoefficient<K extends Comparable<K> & org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.directed: The global clustering coefficient measures the connectedness of a graph.
GlobalClusteringCoefficient() - Constructor for class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient
GlobalClusteringCoefficient<K extends Comparable<K> & org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.undirected: The global clustering coefficient measures the connectedness of a graph.
GlobalClusteringCoefficient() - Constructor for class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient
GlobalClusteringCoefficient.Result - Class in org.apache.flink.graph.library.clustering.directed: Wraps global clustering coefficient metrics.
GlobalClusteringCoefficient.Result - Class in org.apache.flink.graph.library.clustering.undirected: Wraps global clustering coefficient metrics.
Graph<K,VV,EV> - Class in org.apache.flink.graph: Represents a Graph consisting of edges and vertices.
Graph(DataSet<Vertex<K, VV>>, DataSet<Edge<K, EV>>, ExecutionEnvironment) - Constructor for class org.apache.flink.graph.Graph: Creates a graph from two DataSets: vertices and edges.
GraphAlgorithm<K,VV,EV,T> - Interface in org.apache.flink.graph
GraphAlgorithmWrappingBase<K,VV,EV,R> - Class in org.apache.flink.graph.utils.proxy: A GraphAlgorithm transforms an input Graph into an output of type T.
GraphAlgorithmWrappingBase() - Constructor for class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase
GraphAlgorithmWrappingDataSet<K,VV,EV,T> - Class in org.apache.flink.graph.utils.proxy: Base class for a mergeable GraphAlgorithm which wraps and returns a result DataSet.
GraphAlgorithmWrappingDataSet() - Constructor for class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingDataSet
GraphAlgorithmWrappingGraph<IN_K,IN_VV,IN_EV,OUT_K,OUT_VV,OUT_EV> - Class in org.apache.flink.graph.utils.proxy: Base class for a mergeable GraphAlgorithm which wraps and returns a result Graph.
GraphAlgorithmWrappingGraph() - Constructor for class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingGraph
GraphAnalytic<K,VV,EV,T> - Interface in org.apache.flink.graph: A GraphAnalytic is similar to a GraphAlgorithm but is terminal and results are retrieved via accumulators.
GraphAnalyticBase<K,VV,EV,T> - Class in org.apache.flink.graph: Base class for GraphAnalytic.
GraphAnalyticBase() - Constructor for class org.apache.flink.graph.GraphAnalyticBase
GraphCsvReader - Class in org.apache.flink.graph: A class to build a Graph using path(s) provided to CSV file(s) with optional vertex and edge data.
GraphCsvReader(Path, Path, ExecutionEnvironment) - Constructor for class org.apache.flink.graph.GraphCsvReader
GraphCsvReader(Path, ExecutionEnvironment) - Constructor for class org.apache.flink.graph.GraphCsvReader
GraphCsvReader(Path, MapFunction<K, VV>, ExecutionEnvironment) - Constructor for class org.apache.flink.graph.GraphCsvReader
GraphCsvReader(String, ExecutionEnvironment) - Constructor for class org.apache.flink.graph.GraphCsvReader
GraphCsvReader(String, String, ExecutionEnvironment) - Constructor for class org.apache.flink.graph.GraphCsvReader
GraphCsvReader(String, MapFunction<K, VV>, ExecutionEnvironment) - Constructor for class org.apache.flink.graph.GraphCsvReader
GraphGenerator<K,VV,EV> - Interface in org.apache.flink.graph.generator: Graph generators shall be - parallelizable, in order to create large datasets - scale-free, generating the same graph regardless of parallelism - thrifty, using as few operators as possible
GraphGeneratorBase<K,VV,EV> - Class in org.apache.flink.graph.generator: Base class for graph generators.
GraphGeneratorBase() - Constructor for class org.apache.flink.graph.generator.GraphGeneratorBase
GraphGeneratorUtils - Class in org.apache.flink.graph.generator: Utilities for graph generators.
GraphUtils - Class in org.apache.flink.graph.utils: Graph utilities.
GraphUtils.AddLongValue - Class in org.apache.flink.graph.utils: Add LongValue elements.
GraphUtils.IdentityMapper<T> - Class in org.apache.flink.graph.utils: The identity mapper returns the input as output.
GraphUtils.MapTo<I,O> - Class in org.apache.flink.graph.utils: Map each element to a value.
GraphUtils.NonForwardingIdentityMapper<T> - Class in org.apache.flink.graph.utils: The identity mapper returns the input as output.
GraphValidator<K,VV,EV> - Class in org.apache.flink.graph.validation: A utility for defining validation criteria for different types of Graphs.
GraphValidator() - Constructor for class org.apache.flink.graph.validation.GraphValidator
GridGraph - Class in org.apache.flink.graph.generator
GridGraph(ExecutionEnvironment) - Constructor for class org.apache.flink.graph.generator.GridGraph: An undirected Graph connecting vertices in a regular tiling in one or more dimensions and where the endpoints are optionally connected.
groupReduceOnEdges(EdgesFunctionWithVertexValue<K, VV, EV, T>, EdgeDirection) - Method in class org.apache.flink.graph.Graph: Groups by vertex and computes a GroupReduce transformation over the edge values of each vertex.
groupReduceOnEdges(EdgesFunctionWithVertexValue<K, VV, EV, T>, EdgeDirection, TypeInformation<T>) - Method in class org.apache.flink.graph.Graph: Groups by vertex and computes a GroupReduce transformation over the edge values of each vertex.
groupReduceOnEdges(EdgesFunction<K, EV, T>, EdgeDirection) - Method in class org.apache.flink.graph.Graph: Groups by vertex and computes a GroupReduce transformation over the edge values of each vertex.
groupReduceOnEdges(EdgesFunction<K, EV, T>, EdgeDirection, TypeInformation<T>) - Method in class org.apache.flink.graph.Graph: Groups by vertex and computes a GroupReduce transformation over the edge values of each vertex.
groupReduceOnNeighbors(NeighborsFunctionWithVertexValue<K, VV, EV, T>, EdgeDirection) - Method in class org.apache.flink.graph.Graph: Groups by vertex and computes a GroupReduce transformation over the neighbors (both edges and vertices) of each vertex.
groupReduceOnNeighbors(NeighborsFunctionWithVertexValue<K, VV, EV, T>, EdgeDirection, TypeInformation<T>) - Method in class org.apache.flink.graph.Graph: Groups by vertex and computes a GroupReduce transformation over the neighbors (both edges and vertices) of each vertex.
groupReduceOnNeighbors(NeighborsFunction<K, VV, EV, T>, EdgeDirection) - Method in class org.apache.flink.graph.Graph: Groups by vertex and computes a GroupReduce transformation over the neighbors (both edges and vertices) of each vertex.
groupReduceOnNeighbors(NeighborsFunction<K, VV, EV, T>, EdgeDirection, TypeInformation<T>) - Method in class org.apache.flink.graph.Graph: Groups by vertex and computes a GroupReduce transformation over the neighbors (both edges and vertices) of each vertex.
GSAConfiguration - Class in org.apache.flink.graph.gsa: A GSAConfiguration object can be used to set the iteration name and degree of parallelism, to register aggregators and use broadcast sets in the GatherFunction, SumFunction as well as ApplyFunction.
GSAConfiguration() - Constructor for class org.apache.flink.graph.gsa.GSAConfiguration
GSAConnectedComponents<K,VV extends Comparable<VV>,EV> - Class in org.apache.flink.graph.library: A gather-sum-apply implementation of the Weakly Connected Components algorithm.
GSAConnectedComponents(Integer) - Constructor for class org.apache.flink.graph.library.GSAConnectedComponents: Creates an instance of the GSA Connected Components algorithm.
GSASingleSourceShortestPaths<K,VV> - Class in org.apache.flink.graph.library: This is an implementation of the Single Source Shortest Paths algorithm, using a gather-sum-apply iteration.
GSASingleSourceShortestPaths(K, Integer) - Constructor for class org.apache.flink.graph.library.GSASingleSourceShortestPaths: Creates an instance of the GSA SingleSourceShortestPaths algorithm.

H

hash(ByteValueArray) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
hash(CharValueArray) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
hash(DoubleValueArray) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
hash(FloatValueArray) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
hash(IntValueArray) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
hash(LongValueArray) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
hash(NullValueArray) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
hash(ShortValueArray) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
hash(StringValueArray) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
hash(double) - Method in class org.apache.flink.graph.utils.MurmurHash: Process a double value.
hash(float) - Method in class org.apache.flink.graph.utils.MurmurHash: Process a float value.
hash(int) - Method in class org.apache.flink.graph.utils.MurmurHash: Process an integer value.
hash(long) - Method in class org.apache.flink.graph.utils.MurmurHash: Process a long value.
hash() - Method in class org.apache.flink.graph.utils.MurmurHash: Finalize and return the MurmurHash output.
HASH_SEED - Static variable in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result
HASH_SEED - Static variable in class org.apache.flink.graph.library.clustering.directed.TriangleListing.Result
HASH_SEED - Static variable in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result
HASH_SEED - Static variable in class org.apache.flink.graph.library.clustering.undirected.TriangleListing.Result
HASH_SEED - Static variable in class org.apache.flink.graph.library.linkanalysis.HITS.Result
HASH_SEED - Static variable in class org.apache.flink.graph.library.linkanalysis.PageRank.Result
HASH_SEED - Static variable in class org.apache.flink.graph.library.similarity.AdamicAdar.Result
HASH_SEED - Static variable in class org.apache.flink.graph.library.similarity.JaccardIndex.Result
hashCode() - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum
hashCode() - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees.Degrees
hashCode() - Method in class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient.Result
hashCode() - Method in class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient.Result
hashCode() - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result
hashCode() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result
hashCode() - Method in class org.apache.flink.graph.library.clustering.directed.TriangleListing.Result
hashCode() - Method in class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient.Result
hashCode() - Method in class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient.Result
hashCode() - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result
hashCode() - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result
hashCode() - Method in class org.apache.flink.graph.library.clustering.undirected.TriangleListing.Result
hashCode() - Method in class org.apache.flink.graph.library.linkanalysis.HITS.Result
hashCode() - Method in class org.apache.flink.graph.library.linkanalysis.PageRank.Result
hashCode() - Method in class org.apache.flink.graph.library.metric.directed.EdgeMetrics.Result
hashCode() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result
hashCode() - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics.Result
hashCode() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result
hashCode() - Method in class org.apache.flink.graph.library.similarity.AdamicAdar.Result
hashCode() - Method in class org.apache.flink.graph.library.similarity.JaccardIndex.Result
hashCode() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
hashCode() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
hashCode() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
hashCode() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
hashCode() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
hashCode() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
hashCode() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
hashCode() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
hashCode() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
hashCode() - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
hashCode() - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingDataSet
hashCode() - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingGraph
hasNext() - Method in class org.apache.flink.graph.pregel.MessageIterator
hasNext() - Method in class org.apache.flink.graph.spargel.MessageIterator
HIGH_BIT - Static variable in class org.apache.flink.graph.types.valuearray.StringValueArray
HITS<K,VV,EV> - Class in org.apache.flink.graph.library.linkanalysis: Hyperlink-Induced Topic Search computes two interdependent scores for every vertex in a directed graph.
HITS(int) - Constructor for class org.apache.flink.graph.library.linkanalysis.HITS: Hyperlink-Induced Topic Search with a fixed number of iterations.
HITS(double) - Constructor for class org.apache.flink.graph.library.linkanalysis.HITS: Hyperlink-Induced Topic Search with a convergence threshold.
HITS(int, double) - Constructor for class org.apache.flink.graph.library.linkanalysis.HITS: Hyperlink-Induced Topic Search with a convergence threshold and a maximum iteration count.
HITS.Result<T> - Class in org.apache.flink.graph.library.linkanalysis: A result for the HITS algorithm.
HypercubeGraph - Class in org.apache.flink.graph.generator
HypercubeGraph(ExecutionEnvironment, long) - Constructor for class org.apache.flink.graph.generator.HypercubeGraph: An undirected Graph where edges form an n-dimensional hypercube.

I

IdentityMapper() - Constructor for class org.apache.flink.graph.utils.GraphUtils.IdentityMapper
ignoreCommentsEdges(String) - Method in class org.apache.flink.graph.GraphCsvReader: Configures the string that starts comments for the Edge Csv Reader.
ignoreCommentsVertices(String) - Method in class org.apache.flink.graph.GraphCsvReader: Configures the string that starts comments for the Vertex Csv Reader.
ignoreFirstLineEdges() - Method in class org.apache.flink.graph.GraphCsvReader: Sets the CSV reader for the Edges file to ignore the first line.
ignoreFirstLineVertices() - Method in class org.apache.flink.graph.GraphCsvReader: Sets the CSV reader for the Vertices file to ignore the first line.
ignoreInvalidLinesEdges() - Method in class org.apache.flink.graph.GraphCsvReader: Sets the CSV reader for the Edges file to ignore any invalid lines.
ignoreInvalidLinesVertices() - Method in class org.apache.flink.graph.GraphCsvReader: Sets the CSV reader Vertices file to ignore any invalid lines.
includeFieldsEdges(boolean...) - Method in class org.apache.flink.graph.GraphCsvReader: Configures which fields of the CSV file containing edges data should be included and which should be skipped.
includeFieldsEdges(String) - Method in class org.apache.flink.graph.GraphCsvReader: Configures which fields of the CSV file containing edges data should be included and which should be skipped.
includeFieldsEdges(long) - Method in class org.apache.flink.graph.GraphCsvReader: Configures which fields of the CSV file containing edges data should be included and which should be skipped.
includeFieldsVertices(boolean...) - Method in class org.apache.flink.graph.GraphCsvReader: Configures which fields of the CSV file containing vertices data should be included and which should be skipped.
includeFieldsVertices(String) - Method in class org.apache.flink.graph.GraphCsvReader: Configures which fields of the CSV file containing vertices data should be included and which should be skipped.
includeFieldsVertices(long) - Method in class org.apache.flink.graph.GraphCsvReader: Configures which fields of the CSV file containing vertices data should be included and which should be skipped.
inDegrees() - Method in class org.apache.flink.graph.Graph: Return the in-degree of all vertices in the graph.
init(IterationRuntimeContext) - Method in class org.apache.flink.graph.gsa.ApplyFunction
init(IterationRuntimeContext) - Method in class org.apache.flink.graph.gsa.GatherFunction
init(IterationRuntimeContext) - Method in class org.apache.flink.graph.gsa.SumFunction
INT_VALUE_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
intersect(Graph<K, VV, EV>, boolean) - Method in class org.apache.flink.graph.Graph: Performs intersect on the edge sets of the input graphs.
IntValueArray - Class in org.apache.flink.graph.types.valuearray: An array of IntValue.
IntValueArray() - Constructor for class org.apache.flink.graph.types.valuearray.IntValueArray: Initializes an expandable array with default capacity.
IntValueArray(int) - Constructor for class org.apache.flink.graph.types.valuearray.IntValueArray: Initializes a fixed-size array with the provided number of bytes.
IntValueArrayComparator - Class in org.apache.flink.graph.types.valuearray: Specialized comparator for IntValueArray based on CopyableValueComparator.
IntValueArrayComparator(boolean) - Constructor for class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
IntValueArraySerializer - Class in org.apache.flink.graph.types.valuearray: Specialized serializer for IntValueArray.
IntValueArraySerializer() - Constructor for class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
InvalidVertexIdsValidator<K,VV,EV> - Class in org.apache.flink.graph.validation: Validate that the edge set vertex IDs exist in the vertex set.
InvalidVertexIdsValidator() - Constructor for class org.apache.flink.graph.validation.InvalidVertexIdsValidator
invertNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
invertNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
invertNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
invertNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
invertNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
invertNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
invertNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
invertNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
invertNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
isBasicType() - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
isCompatibleSerializationFormatIdentifier(String) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
isCompatibleSerializationFormatIdentifier(String) - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
isCompatibleSerializationFormatIdentifier(String) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
isCompatibleSerializationFormatIdentifier(String) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
isCompatibleSerializationFormatIdentifier(String) - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
isCompatibleSerializationFormatIdentifier(String) - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
isCompatibleSerializationFormatIdentifier(String) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
isCompatibleSerializationFormatIdentifier(String) - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
isFull() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
isFull() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
isFull() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
isFull() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
isFull() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
isFull() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
isFull() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
isFull() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
isFull() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
isFull() - Method in interface org.apache.flink.graph.types.valuearray.ValueArray: An bounded array fills when the allocated capacity has been fully used.
isImmutableType() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
isImmutableType() - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
isImmutableType() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
isImmutableType() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
isImmutableType() - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
isImmutableType() - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
isImmutableType() - Method in class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
isImmutableType() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
isImmutableType() - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
isKeyType() - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
isNormalizedKeyPrefixOnly(int) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
isNormalizedKeyPrefixOnly(int) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
isNormalizedKeyPrefixOnly(int) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
isNormalizedKeyPrefixOnly(int) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
isNormalizedKeyPrefixOnly(int) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
isNormalizedKeyPrefixOnly(int) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
isNormalizedKeyPrefixOnly(int) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
isNormalizedKeyPrefixOnly(int) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
isNormalizedKeyPrefixOnly(int) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
isOptDegrees() - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration: Gets whether the degrees option is set.
isOptNumVertices() - Method in class org.apache.flink.graph.IterationConfiguration: Gets whether the number of vertices option is set.
isSolutionSetUnmanagedMemory() - Method in class org.apache.flink.graph.IterationConfiguration: Gets whether the solution set is kept in managed memory (Flink's internal way of keeping object in serialized form) or as a simple object map.
isTupleType() - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
iterateEdges(Iterable<Tuple2<K, Edge<K, EV>>>, Collector<O>) - Method in interface org.apache.flink.graph.EdgesFunction: This method is called per vertex and can iterate over all of its neighboring edges with the specified direction.
iterateEdges(Vertex<K, VV>, Iterable<Edge<K, EV>>, Collector<O>) - Method in interface org.apache.flink.graph.EdgesFunctionWithVertexValue: This method is called per vertex and can iterate over all of its neighboring edges with the specified direction.
iterateNeighbors(Iterable<Tuple3<K, Edge<K, EV>, Vertex<K, VV>>>, Collector<O>) - Method in interface org.apache.flink.graph.NeighborsFunction: This method is called per vertex and can iterate over all of its neighbors with the specified direction.
iterateNeighbors(Vertex<K, VV>, Iterable<Tuple2<Edge<K, EV>, Vertex<K, VV>>>, Collector<O>) - Method in interface org.apache.flink.graph.NeighborsFunctionWithVertexValue: This method is called per vertex and can iterate over all of its neighbors with the specified direction.
IterationConfiguration - Class in org.apache.flink.graph: This is used as a base class for vertex-centric iteration or gather-sum-apply iteration configuration.
IterationConfiguration() - Constructor for class org.apache.flink.graph.IterationConfiguration
iterator() - Method in class org.apache.flink.graph.pregel.MessageIterator
iterator() - Method in class org.apache.flink.graph.spargel.MessageIterator
iterator() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
iterator() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
iterator() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
iterator() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
iterator() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
iterator() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
iterator() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
iterator() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
iterator() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray

J

JaccardIndex<K extends org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.similarity: The Jaccard Index measures the similarity between vertex neighborhoods and is computed as the number of shared neighbors divided by the number of distinct neighbors.
JaccardIndex() - Constructor for class org.apache.flink.graph.library.similarity.JaccardIndex
JaccardIndex.Result<T> - Class in org.apache.flink.graph.library.similarity: A result for the Jaccard Index algorithm.
JDKRandomGeneratorFactory - Class in org.apache.flink.graph.generator.random: Uses a seeded JDKRandomGenerator to generate seeds for the distributed collection of JDKRandomGenerator.
JDKRandomGeneratorFactory() - Constructor for class org.apache.flink.graph.generator.random.JDKRandomGeneratorFactory
JDKRandomGeneratorFactory(long) - Constructor for class org.apache.flink.graph.generator.random.JDKRandomGeneratorFactory
join(Edge<K, Tuple2<EV, D>>, Vertex<K, D>) - Method in class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinEdgeDegreeWithVertexDegree
join(Edge<K, EV>, Vertex<K, D>) - Method in class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinEdgeWithVertexDegree
join(Vertex<K, VV>, Vertex<K, LongValue>) - Method in class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinVertexWithVertexDegree
JoinEdgeDegreeWithVertexDegree() - Constructor for class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinEdgeDegreeWithVertexDegree
JoinEdgeWithVertexDegree() - Constructor for class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinEdgeWithVertexDegree
JoinVertexWithVertexDegree() - Constructor for class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.JoinVertexWithVertexDegree
joinWithEdges(DataSet<Tuple3<K, K, T>>, EdgeJoinFunction<EV, T>) - Method in class org.apache.flink.graph.Graph: Joins the edge DataSet with an input DataSet on the composite key of both source and target IDs and applies a user-defined transformation on the values of the matched records.
joinWithEdgesOnSource(DataSet<Tuple2<K, T>>, EdgeJoinFunction<EV, T>) - Method in class org.apache.flink.graph.Graph: Joins the edge DataSet with an input Tuple2 DataSet and applies a user-defined transformation on the values of the matched records.
joinWithEdgesOnTarget(DataSet<Tuple2<K, T>>, EdgeJoinFunction<EV, T>) - Method in class org.apache.flink.graph.Graph: Joins the edge DataSet with an input Tuple2 DataSet and applies a user-defined transformation on the values of the matched records.
joinWithVertices(DataSet<Tuple2<K, T>>, VertexJoinFunction<VV, T>) - Method in class org.apache.flink.graph.Graph: Joins the vertex DataSet of this graph with an input Tuple2 DataSet and applies a user-defined transformation on the values of the matched records.

K

keyType(Class<K>) - Method in class org.apache.flink.graph.GraphCsvReader: Creates a Graph from CSV input without vertex values or edge values.

L

LabelPropagation<K,VV extends Comparable<VV>,EV> - Class in org.apache.flink.graph.library: An implementation of the label propagation algorithm.
LabelPropagation(int) - Constructor for class org.apache.flink.graph.library.LabelPropagation: Creates a new Label Propagation algorithm instance.
LabelPropagation.SendNewLabelToNeighbors<K,VV extends Comparable<VV>> - Class in org.apache.flink.graph.library: Sends the vertex label to all out-neighbors.
LabelPropagation.UpdateVertexLabel<K,VV extends Comparable<VV>> - Class in org.apache.flink.graph.library: Function that updates the value of a vertex by adopting the most frequent label among its in-neighbors.
lineDelimiterEdges(String) - Method in class org.apache.flink.graph.GraphCsvReader: Configures the Delimiter that separates rows for the CSV reader used to read the edges ('\n') is used by default.
lineDelimiterVertices(String) - Method in class org.apache.flink.graph.GraphCsvReader: Configures the Delimiter that separates rows for the CSV reader used to read the vertices ('\n') is used by default.
LocalClusteringCoefficient<K extends Comparable<K> & org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.directed: The local clustering coefficient measures the connectedness of each vertex's neighborhood.
LocalClusteringCoefficient() - Constructor for class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient
LocalClusteringCoefficient<K extends Comparable<K> & org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.undirected: The local clustering coefficient measures the connectedness of each vertex's neighborhood.
LocalClusteringCoefficient() - Constructor for class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient
LocalClusteringCoefficient.Result<T> - Class in org.apache.flink.graph.library.clustering.directed: A result for the directed Local Clustering Coefficient algorithm.
LocalClusteringCoefficient.Result<T> - Class in org.apache.flink.graph.library.clustering.undirected: A result for the undirected Local Clustering Coefficient algorithm.
LONG_VALUE_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
LongToLongValue - Class in org.apache.flink.graph.asm.translate.translators: Translate Long to LongValue.
LongToLongValue() - Constructor for class org.apache.flink.graph.asm.translate.translators.LongToLongValue
LongValueAddOffset - Class in org.apache.flink.graph.asm.translate.translators: Translate LongValue by adding a constant offset value.
LongValueAddOffset(long) - Constructor for class org.apache.flink.graph.asm.translate.translators.LongValueAddOffset: Translate LongValue by adding a constant offset value.
LongValueArray - Class in org.apache.flink.graph.types.valuearray: An array of LongValue.
LongValueArray() - Constructor for class org.apache.flink.graph.types.valuearray.LongValueArray: Initializes an expandable array with default capacity.
LongValueArray(int) - Constructor for class org.apache.flink.graph.types.valuearray.LongValueArray: Initializes a fixed-size array with the provided number of bytes.
LongValueArrayComparator - Class in org.apache.flink.graph.types.valuearray: Specialized comparator for LongValueArray based on CopyableValueComparator.
LongValueArrayComparator(boolean) - Constructor for class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
LongValueArraySerializer - Class in org.apache.flink.graph.types.valuearray: Specialized serializer for LongValueArray.
LongValueArraySerializer() - Constructor for class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
LongValueToSignedIntValue - Class in org.apache.flink.graph.asm.translate.translators: Translate LongValue to IntValue.
LongValueToSignedIntValue() - Constructor for class org.apache.flink.graph.asm.translate.translators.LongValueToSignedIntValue
LongValueToStringValue - Class in org.apache.flink.graph.asm.translate.translators: Translate LongValue to StringValue.
LongValueToStringValue() - Constructor for class org.apache.flink.graph.asm.translate.translators.LongValueToStringValue
LongValueToUnsignedIntValue - Class in org.apache.flink.graph.asm.translate.translators: Translate LongValue to IntValue.
LongValueToUnsignedIntValue() - Constructor for class org.apache.flink.graph.asm.translate.translators.LongValueToUnsignedIntValue

M

map(Edge<K, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.MapEdgeToSourceId
map(Edge<K, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.MapEdgeToTargetId
map(Edge<K, EV>) - Method in class org.apache.flink.graph.utils.EdgeToTuple2Map
map(Edge<K, EV>) - Method in class org.apache.flink.graph.utils.EdgeToTuple3Map
map(T) - Method in class org.apache.flink.graph.utils.GraphUtils.IdentityMapper
map(I) - Method in class org.apache.flink.graph.utils.GraphUtils.MapTo
map(T) - Method in class org.apache.flink.graph.utils.GraphUtils.NonForwardingIdentityMapper
map(Tuple2<K, K>) - Method in class org.apache.flink.graph.utils.Tuple2ToEdgeMap
map(Tuple2<K, VV>) - Method in class org.apache.flink.graph.utils.Tuple2ToVertexMap
map(Tuple3<K, K, EV>) - Method in class org.apache.flink.graph.utils.Tuple3ToEdgeMap
map(Vertex<K, VV>) - Method in class org.apache.flink.graph.utils.VertexToTuple2Map
mapEdges(MapFunction<Edge<K, EV>, NV>) - Method in class org.apache.flink.graph.Graph: Apply a function to the attribute of each edge in the graph.
mapEdges(MapFunction<Edge<K, EV>, NV>, TypeInformation<Edge<K, NV>>) - Method in class org.apache.flink.graph.Graph: Apply a function to the attribute of each edge in the graph.
MapEdgeToSourceId() - Constructor for class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.MapEdgeToSourceId
MapEdgeToTargetId() - Constructor for class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.MapEdgeToTargetId
mapper - Variable in class org.apache.flink.graph.GraphCsvReader
MapTo(O) - Constructor for class org.apache.flink.graph.utils.GraphUtils.MapTo: Map each element to the given object.
mapVertices(MapFunction<Vertex<K, VV>, NV>) - Method in class org.apache.flink.graph.Graph: Apply a function to the attribute of each vertex in the graph.
mapVertices(MapFunction<Vertex<K, VV>, NV>, TypeInformation<Vertex<K, NV>>) - Method in class org.apache.flink.graph.Graph: Apply a function to the attribute of each vertex in the graph.
mark() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
mark() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
mark() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
mark() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
mark() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
mark() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
mark() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
mark() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
mark() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
mark() - Method in interface org.apache.flink.graph.types.valuearray.ValueArray: Saves the array index, which can be restored by calling reset().
MAX_VERTEX_COUNT - Static variable in class org.apache.flink.graph.asm.translate.translators.LongValueToSignedIntValue
MAX_VERTEX_COUNT - Static variable in class org.apache.flink.graph.asm.translate.translators.LongValueToUnsignedIntValue
MAXIMUM_BLOCK_COUNT - Static variable in class org.apache.flink.graph.generator.random.GeneratorFactoryBase
MaximumDegree<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.filter.undirected: Removes vertices from a graph with degree greater than the given maximum.
MaximumDegree(long) - Constructor for class org.apache.flink.graph.asm.degree.filter.undirected.MaximumDegree: Filter out vertices with degree greater than the given maximum.
merge(Accumulator<ChecksumHashCode.Checksum, ChecksumHashCode.Checksum>) - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexInDegree
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexOutDegree
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeDegreePair
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeSourceDegree
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeTargetDegree
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.VertexDegree
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.asm.degree.filter.undirected.MaximumDegree
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.clustering.TriangleListingBase
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.linkanalysis.HITS
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.linkanalysis.PageRank
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.library.similarity.JaccardIndex
mergeConfiguration(GraphAlgorithmWrappingBase) - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase: Merge the other configuration into this algorithm's after the call to GraphAlgorithmWrappingBase.canMergeConfigurationWith(org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase) has checked that the configurations can be merged.
mergeWith(OptionalBoolean) - Method in class org.apache.flink.graph.utils.proxy.OptionalBoolean: State transitions.
MersenneTwisterFactory - Class in org.apache.flink.graph.generator.random: Uses a seeded MersenneTwister to generate seeds for the distributed collection of MersenneTwister.
MersenneTwisterFactory() - Constructor for class org.apache.flink.graph.generator.random.MersenneTwisterFactory
MersenneTwisterFactory(long) - Constructor for class org.apache.flink.graph.generator.random.MersenneTwisterFactory
MessageCombiner<K,Message> - Class in org.apache.flink.graph.pregel: The base class for combining messages sent during a VertexCentricIteration.
MessageCombiner() - Constructor for class org.apache.flink.graph.pregel.MessageCombiner
MessageIterator<Message> - Class in org.apache.flink.graph.pregel: An iterator that returns messages.
MessageIterator() - Constructor for class org.apache.flink.graph.pregel.MessageIterator
MessageIterator<Message> - Class in org.apache.flink.graph.spargel: An iterator that returns messages.
MessageIterator() - Constructor for class org.apache.flink.graph.spargel.MessageIterator
MinDistanceMessenger() - Constructor for class org.apache.flink.graph.library.SingleSourceShortestPaths.MinDistanceMessenger
MINIMUM_CYCLES_PER_BLOCK - Static variable in class org.apache.flink.graph.generator.random.JDKRandomGeneratorFactory
MINIMUM_CYCLES_PER_BLOCK - Static variable in class org.apache.flink.graph.generator.random.MersenneTwisterFactory
MINIMUM_DIMENSIONS - Static variable in class org.apache.flink.graph.generator.HypercubeGraph
MINIMUM_EDGE_COUNT - Static variable in class org.apache.flink.graph.generator.RMatGraph
MINIMUM_OFFSET - Static variable in class org.apache.flink.graph.generator.CirculantGraph
MINIMUM_VERTEX_COUNT - Static variable in class org.apache.flink.graph.generator.CirculantGraph
MINIMUM_VERTEX_COUNT - Static variable in class org.apache.flink.graph.generator.CompleteGraph
MINIMUM_VERTEX_COUNT - Static variable in class org.apache.flink.graph.generator.CycleGraph
MINIMUM_VERTEX_COUNT - Static variable in class org.apache.flink.graph.generator.EchoGraph
MINIMUM_VERTEX_COUNT - Static variable in class org.apache.flink.graph.generator.EmptyGraph
MINIMUM_VERTEX_COUNT - Static variable in class org.apache.flink.graph.generator.PathGraph
MINIMUM_VERTEX_COUNT - Static variable in class org.apache.flink.graph.generator.RMatGraph
MINIMUM_VERTEX_COUNT - Static variable in class org.apache.flink.graph.generator.StarGraph
MINIMUM_VERTEX_DEGREE - Static variable in class org.apache.flink.graph.generator.EchoGraph
MINIMUM_VERTEX_PAIR_COUNT - Static variable in class org.apache.flink.graph.generator.SingletonEdgeGraph
MirrorResult() - Constructor for class org.apache.flink.graph.asm.result.BinaryResult.MirrorResult
MurmurHash - Class in org.apache.flink.graph.utils: A resettable implementation of the 32-bit MurmurHash algorithm.
MurmurHash(int) - Constructor for class org.apache.flink.graph.utils.MurmurHash: A resettable implementation of the 32-bit MurmurHash algorithm.

N

Neighbor<VV,EV> - Class in org.apache.flink.graph.gsa: This class represents a <sourceVertex, edge> pair.
Neighbor() - Constructor for class org.apache.flink.graph.gsa.Neighbor
Neighbor(VV, EV) - Constructor for class org.apache.flink.graph.gsa.Neighbor
NeighborsFunction<K,VV,EV,O> - Interface in org.apache.flink.graph: Interface to be implemented by the function applied to a vertex neighborhood in the Graph.groupReduceOnNeighbors(NeighborsFunction, EdgeDirection) method.
NeighborsFunctionWithVertexValue<K,VV,EV,O> - Interface in org.apache.flink.graph: Interface to be implemented by the function applied to a vertex neighborhood in the Graph.groupReduceOnNeighbors(NeighborsFunctionWithVertexValue, EdgeDirection) method.
next() - Method in class org.apache.flink.graph.generator.random.GeneratorFactoryBase
next() - Method in class org.apache.flink.graph.generator.random.JDKRandomGeneratorFactory
next() - Method in class org.apache.flink.graph.generator.random.MersenneTwisterFactory
next() - Method in class org.apache.flink.graph.pregel.MessageIterator
next() - Method in class org.apache.flink.graph.spargel.MessageIterator
NonForwardingIdentityMapper() - Constructor for class org.apache.flink.graph.utils.GraphUtils.NonForwardingIdentityMapper
NULL_VALUE_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
NullValueArray - Class in org.apache.flink.graph.types.valuearray: An array of NullValue.
NullValueArray() - Constructor for class org.apache.flink.graph.types.valuearray.NullValueArray: Initializes an expandable array with default capacity.
NullValueArray(int) - Constructor for class org.apache.flink.graph.types.valuearray.NullValueArray: Initializes a fixed-size array with the provided number of bytes.
NullValueArrayComparator - Class in org.apache.flink.graph.types.valuearray: Specialized comparator for NullValueArray based on CopyableValueComparator.
NullValueArrayComparator(boolean) - Constructor for class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
NullValueArraySerializer - Class in org.apache.flink.graph.types.valuearray: Specialized serializer for NullValueArray.
NullValueArraySerializer() - Constructor for class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
numberOfEdges() - Method in class org.apache.flink.graph.Graph
numberOfVertices() - Method in class org.apache.flink.graph.Graph

O

OffsetRange(long, long) - Constructor for class org.apache.flink.graph.generator.CirculantGraph.OffsetRange: Construct a range with the given offset and length.
open(int, int) - Method in class org.apache.flink.graph.AnalyticHelper
OptionalBoolean - Class in org.apache.flink.graph.utils.proxy: A multi-state boolean.
OptionalBoolean(boolean, boolean) - Constructor for class org.apache.flink.graph.utils.proxy.OptionalBoolean: An OptionalBoolean has three possible states: true, false, and "unset".
OptionalBoolean.State - Enum in org.apache.flink.graph.utils.proxy: States for OptionalBoolean.
org.apache.flink.graph - package org.apache.flink.graph
org.apache.flink.graph.asm.dataset - package org.apache.flink.graph.asm.dataset
org.apache.flink.graph.asm.degree.annotate - package org.apache.flink.graph.asm.degree.annotate: The degree annotation package provides a collection of edge-centric graph algorithms for counting the vertex degree of directed and undirected graphs.
org.apache.flink.graph.asm.degree.annotate.directed - package org.apache.flink.graph.asm.degree.annotate.directed
org.apache.flink.graph.asm.degree.annotate.undirected - package org.apache.flink.graph.asm.degree.annotate.undirected
org.apache.flink.graph.asm.degree.filter.undirected - package org.apache.flink.graph.asm.degree.filter.undirected
org.apache.flink.graph.asm.result - package org.apache.flink.graph.asm.result
org.apache.flink.graph.asm.simple.directed - package org.apache.flink.graph.asm.simple.directed
org.apache.flink.graph.asm.simple.undirected - package org.apache.flink.graph.asm.simple.undirected
org.apache.flink.graph.asm.translate - package org.apache.flink.graph.asm.translate
org.apache.flink.graph.asm.translate.translators - package org.apache.flink.graph.asm.translate.translators
org.apache.flink.graph.bipartite - package org.apache.flink.graph.bipartite
org.apache.flink.graph.generator - package org.apache.flink.graph.generator
org.apache.flink.graph.generator.random - package org.apache.flink.graph.generator.random
org.apache.flink.graph.gsa - package org.apache.flink.graph.gsa
org.apache.flink.graph.library - package org.apache.flink.graph.library
org.apache.flink.graph.library.clustering - package org.apache.flink.graph.library.clustering
org.apache.flink.graph.library.clustering.directed - package org.apache.flink.graph.library.clustering.directed
org.apache.flink.graph.library.clustering.undirected - package org.apache.flink.graph.library.clustering.undirected
org.apache.flink.graph.library.linkanalysis - package org.apache.flink.graph.library.linkanalysis
org.apache.flink.graph.library.metric - package org.apache.flink.graph.library.metric
org.apache.flink.graph.library.metric.directed - package org.apache.flink.graph.library.metric.directed
org.apache.flink.graph.library.metric.undirected - package org.apache.flink.graph.library.metric.undirected
org.apache.flink.graph.library.similarity - package org.apache.flink.graph.library.similarity
org.apache.flink.graph.pregel - package org.apache.flink.graph.pregel
org.apache.flink.graph.spargel - package org.apache.flink.graph.spargel
org.apache.flink.graph.types.valuearray - package org.apache.flink.graph.types.valuearray
org.apache.flink.graph.utils - package org.apache.flink.graph.utils
org.apache.flink.graph.utils.proxy - package org.apache.flink.graph.utils.proxy
org.apache.flink.graph.validation - package org.apache.flink.graph.validation
outDegrees() - Method in class org.apache.flink.graph.Graph: Return the out-degree of all vertices in the graph.
overlaps(CirculantGraph.OffsetRange) - Method in class org.apache.flink.graph.generator.CirculantGraph.OffsetRange: Return true if and only if the other range and this range share a common offset ID.

P

PageRank<K,VV,EV> - Class in org.apache.flink.graph.library.linkanalysis: PageRank computes a per-vertex score which is the sum of PageRank scores transmitted over in-edges.
PageRank(double, int) - Constructor for class org.apache.flink.graph.library.linkanalysis.PageRank: PageRank with a fixed number of iterations.
PageRank(double, double) - Constructor for class org.apache.flink.graph.library.linkanalysis.PageRank: PageRank with a convergence threshold.
PageRank(double, int, double) - Constructor for class org.apache.flink.graph.library.linkanalysis.PageRank: PageRank with a convergence threshold and a maximum iteration count.
PageRank.Result<T> - Class in org.apache.flink.graph.library.linkanalysis: A result for the PageRank algorithm.
parallelism - Variable in class org.apache.flink.graph.generator.GraphGeneratorBase
parallelism - Variable in class org.apache.flink.graph.GraphAnalyticBase
parallelism - Variable in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase
parseQuotedStringsEdges(char) - Method in class org.apache.flink.graph.GraphCsvReader: Enables quoted String parsing for Edge Csv Reader.
parseQuotedStringsVertices(char) - Method in class org.apache.flink.graph.GraphCsvReader: Enables quoted String parsing for Vertex Csv Reader.
PathGraph - Class in org.apache.flink.graph.generator
PathGraph(ExecutionEnvironment, long) - Constructor for class org.apache.flink.graph.generator.PathGraph: An undirected Graph with n vertices where each vertex v_i connects to adjacent vertices v_i+1 when i < n-1 and v_i-1 when i > 0.
permuteResults - Variable in class org.apache.flink.graph.library.clustering.TriangleListingBase
postSuperstep() - Method in class org.apache.flink.graph.gsa.ApplyFunction: This method is executed once per superstep after the vertex update function has been invoked for each vertex.
postSuperstep() - Method in class org.apache.flink.graph.gsa.GatherFunction: This method is executed once per superstep after the vertex update function has been invoked for each vertex.
postSuperstep() - Method in class org.apache.flink.graph.gsa.SumFunction: This method is executed once per superstep after the vertex update function has been invoked for each vertex.
postSuperstep() - Method in class org.apache.flink.graph.pregel.ComputeFunction: This method is executed once per superstep after the vertex update function has been invoked for each vertex.
postSuperstep() - Method in class org.apache.flink.graph.spargel.GatherFunction: This method is executed once per superstep after the gather function has been invoked for each vertex.
postSuperstep() - Method in class org.apache.flink.graph.spargel.ScatterFunction: This method is executed once per superstep after the scatter function has been invoked for each vertex.
preSuperstep() - Method in class org.apache.flink.graph.gsa.ApplyFunction: This method is executed once per superstep before the vertex update function is invoked for each vertex.
preSuperstep() - Method in class org.apache.flink.graph.gsa.GatherFunction: This method is executed once per superstep before the vertex update function is invoked for each vertex.
preSuperstep() - Method in class org.apache.flink.graph.gsa.SumFunction: This method is executed once per superstep before the vertex update function is invoked for each vertex.
preSuperstep() - Method in class org.apache.flink.graph.pregel.ComputeFunction: This method is executed once per superstep before the vertex update function is invoked for each vertex.
preSuperstep() - Method in class org.apache.flink.graph.spargel.GatherFunction: This method is executed once per superstep before the gather function is invoked for each vertex.
preSuperstep() - Method in class org.apache.flink.graph.spargel.ScatterFunction: This method is executed once per superstep before the scatter function is invoked for each vertex.
PrintableResult - Interface in org.apache.flink.graph.asm.result: Base interface for GraphAlgorithm results.
Projection<KC,VVC,VV,EV> - Class in org.apache.flink.graph.bipartite: The edge value of a full bipartite projection.
Projection() - Constructor for class org.apache.flink.graph.bipartite.Projection
Projection(Vertex<KC, VVC>, VV, VV, EV, EV) - Constructor for class org.apache.flink.graph.bipartite.Projection
projectionBottomFull() - Method in class org.apache.flink.graph.bipartite.BipartiteGraph: Convert a bipartite graph into a graph that contains only bottom vertices.
projectionBottomSimple() - Method in class org.apache.flink.graph.bipartite.BipartiteGraph: Convert a bipartite graph into an undirected graph that contains only bottom vertices.
projectionTopFull() - Method in class org.apache.flink.graph.bipartite.BipartiteGraph: Convert a bipartite graph into a graph that contains only top vertices.
projectionTopSimple() - Method in class org.apache.flink.graph.bipartite.BipartiteGraph: Convert a bipartite graph into an undirected graph that contains only top vertices.
putNormalizedKey(ByteValueArray, MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
putNormalizedKey(CharValueArray, MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
putNormalizedKey(DoubleValueArray, MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
putNormalizedKey(FloatValueArray, MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
putNormalizedKey(IntValueArray, MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
putNormalizedKey(LongValueArray, MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
putNormalizedKey(NullValueArray, MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
putNormalizedKey(ShortValueArray, MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
putNormalizedKey(StringValueArray, MemorySegment, int, int) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator

R

RandomGenerable<T extends org.apache.commons.math3.random.RandomGenerator> - Interface in org.apache.flink.graph.generator.random: A RandomGenerable provides deferred instantiation and initialization of a RandomGenerator.
RandomGenerableFactory<T extends org.apache.commons.math3.random.RandomGenerator> - Interface in org.apache.flink.graph.generator.random: A RandomGenerableFactory returns a scale-free collection of sources of pseudorandomness which can be used to perform repeatable parallel computation regardless of parallelism.
read(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
read(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
read(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
read(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
read(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
read(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
read(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
read(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
read(DataInputView) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
readWithKeyDenormalization(ByteValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
readWithKeyDenormalization(CharValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
readWithKeyDenormalization(DoubleValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
readWithKeyDenormalization(FloatValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
readWithKeyDenormalization(IntValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
readWithKeyDenormalization(LongValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
readWithKeyDenormalization(NullValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
readWithKeyDenormalization(ShortValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
readWithKeyDenormalization(StringValueArray, DataInputView) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
reduce(Vertex<K, LongValue>, Vertex<K, LongValue>) - Method in class org.apache.flink.graph.asm.degree.annotate.DegreeAnnotationFunctions.DegreeCount
reduce(LongValue, LongValue) - Method in class org.apache.flink.graph.utils.GraphUtils.AddLongValue
reduceEdges(EV, EV) - Method in interface org.apache.flink.graph.ReduceEdgesFunction: It combines two neighboring edge values into one new value of the same type.
ReduceEdgesFunction<EV> - Interface in org.apache.flink.graph: Interface to be implemented by the function applied to a vertex neighborhood in the Graph.reduceOnEdges(org.apache.flink.graph.ReduceEdgesFunction, EdgeDirection) method.
reduceNeighbors(VV, VV) - Method in interface org.apache.flink.graph.ReduceNeighborsFunction: It combines two neighboring vertex values into one new value of the same type.
ReduceNeighborsFunction<VV> - Interface in org.apache.flink.graph: Interface to be implemented by the function applied to a vertex neighborhood in the Graph.reduceOnNeighbors(ReduceNeighborsFunction, EdgeDirection) method.
reduceOnEdges(ReduceEdgesFunction<EV>, EdgeDirection) - Method in class org.apache.flink.graph.Graph: Compute a reduce transformation over the edge values of each vertex.
reduceOnNeighbors(ReduceNeighborsFunction<VV>, EdgeDirection) - Method in class org.apache.flink.graph.Graph: Compute a reduce transformation over the neighbors' vertex values of each vertex.
registerAggregator(String, Aggregator<?>) - Method in class org.apache.flink.graph.IterationConfiguration: Registers a new aggregator.
remove() - Method in class org.apache.flink.graph.pregel.MessageIterator
remove() - Method in class org.apache.flink.graph.spargel.MessageIterator
removeEdge(Edge<K, EV>) - Method in class org.apache.flink.graph.Graph: Removes all edges that match the given edge from the graph.
removeEdges(List<Edge<K, EV>>) - Method in class org.apache.flink.graph.Graph: Removes all the edges that match the edges in the given data set from the graph.
removeVertex(Vertex<K, VV>) - Method in class org.apache.flink.graph.Graph: Removes the given vertex and its edges from the graph.
removeVertices(List<Vertex<K, VV>>) - Method in class org.apache.flink.graph.Graph: Removes the given list of vertices and its edges from the graph.
reset() - Method in class org.apache.flink.graph.library.Summarization.VertexGroupItem: Resets the fields to initial values.
reset() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
reset() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
reset() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
reset() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
reset() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
reset() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
reset() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
reset() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
reset() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
reset() - Method in interface org.apache.flink.graph.types.valuearray.ValueArray: Restores the array index to when mark() was last called.
reset() - Method in class org.apache.flink.graph.utils.MurmurHash: Re-initialize the MurmurHash state.
resetLocal() - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum
Result(long, double) - Constructor for class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient.Result: Instantiate an immutable result.
Result(long, long) - Constructor for class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient.Result: Instantiate an immutable result.
Result() - Constructor for class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result
Result(BigInteger...) - Constructor for class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result
Result(long...) - Constructor for class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result
Result() - Constructor for class org.apache.flink.graph.library.clustering.directed.TriangleListing.Result
Result(long, double) - Constructor for class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient.Result: Instantiate an immutable result.
Result(long, long) - Constructor for class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient.Result: Instantiate an immutable result.
Result() - Constructor for class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result
Result(BigInteger...) - Constructor for class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result
Result(long...) - Constructor for class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result
Result() - Constructor for class org.apache.flink.graph.library.clustering.undirected.TriangleListing.Result
Result() - Constructor for class org.apache.flink.graph.library.linkanalysis.HITS.Result
Result() - Constructor for class org.apache.flink.graph.library.linkanalysis.PageRank.Result
Result(long, long, long, long) - Constructor for class org.apache.flink.graph.library.metric.directed.EdgeMetrics.Result
Result(long, long, long, long, long, long, long, long) - Constructor for class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result
Result(long, long, long, long) - Constructor for class org.apache.flink.graph.library.metric.undirected.EdgeMetrics.Result
Result(long, long, long, long, long) - Constructor for class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result
Result() - Constructor for class org.apache.flink.graph.library.similarity.AdamicAdar.Result
Result() - Constructor for class org.apache.flink.graph.library.similarity.JaccardIndex.Result
ResultBase - Class in org.apache.flink.graph.asm.result: Base class for algorithm results.
ResultBase() - Constructor for class org.apache.flink.graph.asm.result.ResultBase
reverse() - Method in class org.apache.flink.graph.Edge: Reverses the direction of this Edge.
reverse() - Method in class org.apache.flink.graph.Graph: Reverse the direction of the edges in the graph.
RichTranslateFunction<IN,OUT> - Class in org.apache.flink.graph.asm.translate: Rich variant of the TranslateFunction.
RichTranslateFunction() - Constructor for class org.apache.flink.graph.asm.translate.RichTranslateFunction
RMatGraph<T extends org.apache.commons.math3.random.RandomGenerator> - Class in org.apache.flink.graph.generator
RMatGraph(ExecutionEnvironment, RandomGenerableFactory<T>, long, long) - Constructor for class org.apache.flink.graph.generator.RMatGraph: A directed power-law multigraph generated using the stochastic Recursive Matrix (R-Mat) model.
run(DataSet<T>) - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode
run(DataSet<T>) - Method in class org.apache.flink.graph.asm.dataset.Collect
run(DataSet<T>) - Method in class org.apache.flink.graph.asm.dataset.Count
run(DataSet<T>) - Method in interface org.apache.flink.graph.asm.dataset.DataSetAnalytic: All DataSetAnalytic processing must be terminated by an OutputFormat and obtained via accumulators rather than returned by a DataSet.
run(DataSet<T>) - Method in class org.apache.flink.graph.asm.dataset.DataSetAnalyticBase
run(GraphAlgorithm<K, VV, EV, T>) - Method in class org.apache.flink.graph.Graph
run(GraphAnalytic<K, VV, EV, T>) - Method in class org.apache.flink.graph.Graph: A GraphAnalytic is similar to a GraphAlgorithm but is terminal and results are retrieved via accumulators.
run(Graph<K, VV, EV>) - Method in interface org.apache.flink.graph.GraphAlgorithm
run(Graph<K, VV, EV>) - Method in interface org.apache.flink.graph.GraphAnalytic: All GraphAnalytic processing must be terminated by an OutputFormat.
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.GraphAnalyticBase
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus
run(Graph<K, Long, Double>) - Method in class org.apache.flink.graph.library.CommunityDetection
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.ConnectedComponents
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.GSAConnectedComponents
run(Graph<K, VV, Double>) - Method in class org.apache.flink.graph.library.GSASingleSourceShortestPaths
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.LabelPropagation
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.metric.ChecksumHashCode
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.metric.directed.EdgeMetrics
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics
run(Graph<K, VV, Double>) - Method in class org.apache.flink.graph.library.SingleSourceShortestPaths
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.Summarization
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.TriangleEnumerator
run(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingDataSet
run(Graph<IN_K, IN_VV, IN_EV>) - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingGraph
runGatherSumApplyIteration(GatherFunction<VV, EV, M>, SumFunction<VV, EV, M>, ApplyFunction<K, VV, M>, int) - Method in class org.apache.flink.graph.Graph: Runs a Gather-Sum-Apply iteration on the graph.
runGatherSumApplyIteration(GatherFunction<VV, EV, M>, SumFunction<VV, EV, M>, ApplyFunction<K, VV, M>, int, GSAConfiguration) - Method in class org.apache.flink.graph.Graph: Runs a Gather-Sum-Apply iteration on the graph with configuration options.
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.EdgeDegreesPair
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.EdgeSourceDegrees
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.EdgeTargetDegrees
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexInDegree
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexOutDegree
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeDegreePair
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeSourceDegree
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeTargetDegree
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.VertexDegree
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.degree.filter.undirected.MaximumDegree
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.simple.directed.Simplify
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.asm.simple.undirected.Simplify
runInternal(Graph<K, VV, OLD>) - Method in class org.apache.flink.graph.asm.translate.TranslateEdgeValues
runInternal(Graph<OLD, VV, EV>) - Method in class org.apache.flink.graph.asm.translate.TranslateGraphIds
runInternal(Graph<K, OLD, EV>) - Method in class org.apache.flink.graph.asm.translate.TranslateVertexValues
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.clustering.directed.TriangleListing
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.clustering.undirected.TriangleListing
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.linkanalysis.HITS
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.linkanalysis.PageRank
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.similarity.AdamicAdar
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.library.similarity.JaccardIndex
runInternal(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingDataSet: The implementation of the algorithm, renamed from GraphAlgorithm.run(Graph).
runInternal(Graph<IN_K, IN_VV, IN_EV>) - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingGraph: The implementation of the algorithm, renamed from GraphAlgorithm.run(Graph).
runScatterGatherIteration(ScatterFunction<K, VV, M, EV>, GatherFunction<K, VV, M>, int) - Method in class org.apache.flink.graph.Graph: Runs a ScatterGather iteration on the graph.
runScatterGatherIteration(ScatterFunction<K, VV, M, EV>, GatherFunction<K, VV, M>, int, ScatterGatherConfiguration) - Method in class org.apache.flink.graph.Graph: Runs a ScatterGather iteration on the graph with configuration options.
runVertexCentricIteration(ComputeFunction<K, VV, EV, M>, MessageCombiner<K, M>, int) - Method in class org.apache.flink.graph.Graph: Runs a VertexCentricIteration on the graph.
runVertexCentricIteration(ComputeFunction<K, VV, EV, M>, MessageCombiner<K, M>, int, VertexCentricConfiguration) - Method in class org.apache.flink.graph.Graph: Runs a VertexCentricIteration on the graph with configuration options.

S

ScatterFunction<K,VV,Message,EV> - Class in org.apache.flink.graph.spargel: The base class for functions that produce messages between vertices as a part of a ScatterGatherIteration.
ScatterFunction() - Constructor for class org.apache.flink.graph.spargel.ScatterFunction
ScatterGatherConfiguration - Class in org.apache.flink.graph.spargel: A ScatterGatherConfiguration object can be used to set the iteration name and degree of parallelism, to register aggregators and use broadcast sets in the GatherFunction and ScatterFunction
ScatterGatherConfiguration() - Constructor for class org.apache.flink.graph.spargel.ScatterGatherConfiguration
ScatterGatherIteration<K,VV,Message,EV> - Class in org.apache.flink.graph.spargel: This class represents iterative graph computations, programmed in a scatter-gather perspective.
sendCombinedMessage(Message) - Method in class org.apache.flink.graph.pregel.MessageCombiner: Sends the combined message to the target vertex.
sendMessages(Vertex<K, VV>) - Method in class org.apache.flink.graph.library.ConnectedComponents.CCMessenger
sendMessages(Vertex<K, VV>) - Method in class org.apache.flink.graph.library.LabelPropagation.SendNewLabelToNeighbors
sendMessages(Vertex<K, Double>) - Method in class org.apache.flink.graph.library.SingleSourceShortestPaths.MinDistanceMessenger
sendMessages(Vertex<K, VV>) - Method in class org.apache.flink.graph.spargel.ScatterFunction: This method is invoked once per superstep for each vertex that was changed in that superstep.
sendMessageTo(K, Message) - Method in class org.apache.flink.graph.pregel.ComputeFunction: Sends the given message to the vertex identified by the given key.
sendMessageTo(K, Message) - Method in class org.apache.flink.graph.spargel.ScatterFunction: Sends the given message to the vertex identified by the given key.
sendMessageToAllNeighbors(Message) - Method in class org.apache.flink.graph.pregel.ComputeFunction: Sends the given message to all vertices that adjacent to the changed vertex.
sendMessageToAllNeighbors(Message) - Method in class org.apache.flink.graph.spargel.ScatterFunction: Sends the given message to all vertices that are targets of an edge of the changed vertex.
SendNewLabelToNeighbors(TypeInformation<VV>) - Constructor for class org.apache.flink.graph.library.LabelPropagation.SendNewLabelToNeighbors
serialize(ByteValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArraySerializer
serialize(CharValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.CharValueArraySerializer
serialize(DoubleValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArraySerializer
serialize(FloatValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArraySerializer
serialize(IntValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.IntValueArraySerializer
serialize(LongValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.LongValueArraySerializer
serialize(NullValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.NullValueArraySerializer
serialize(ShortValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
serialize(StringValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
set(boolean) - Method in class org.apache.flink.graph.utils.proxy.OptionalBoolean: Set the boolean state.
setAdamicAdarScore(FloatValue) - Method in class org.apache.flink.graph.library.similarity.AdamicAdar.Result: Set the Adamic-Adar score, equal to the sum over common neighbors of the inverse logarithm of degree.
setAuthorityScore(DoubleValue) - Method in class org.apache.flink.graph.library.linkanalysis.HITS.Result: Set the authority score.
setBitmask(ByteValue) - Method in class org.apache.flink.graph.library.clustering.directed.TriangleListing.Result: Set the bitmask indicating the presence of the six potential connecting edges.
setBitmask(byte) - Method in class org.apache.flink.graph.library.clustering.directed.TriangleListing.Result
setBottomId(KB) - Method in class org.apache.flink.graph.bipartite.BipartiteEdge
setBroadcastHighDegreeVertices(boolean) - Method in class org.apache.flink.graph.asm.degree.filter.undirected.MaximumDegree: After filtering high-degree vertices this algorithm must perform joins on the original graph's vertex set and on both the source and target IDs of the edge set.
setConstants(float, float, float) - Method in class org.apache.flink.graph.generator.RMatGraph: The parameters for recursively subdividing the adjacency matrix.
setDegree(LongValue) - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result: Set the vertex degree.
setDegree(LongValue) - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result: Set the vertex degree.
setDirection(EdgeDirection) - Method in class org.apache.flink.graph.gsa.GSAConfiguration: Sets the direction in which neighbors are to be selected By default the neighbors who are target of the edges are selected.
setDirection(EdgeDirection) - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration: Sets the direction in which messages are sent in the ScatterFunction.
setDistinctNeighborCount(IntValue) - Method in class org.apache.flink.graph.library.similarity.JaccardIndex.Result: Set the distinct neighbor count.
setEdgeGroupCount(Long) - Method in class org.apache.flink.graph.library.Summarization.EdgeValue
setEdgeGroupValue(EV) - Method in class org.apache.flink.graph.library.Summarization.EdgeValue
setFirstDegree(Integer) - Method in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
setFirstVertex(K) - Method in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
setFirstVertex(K) - Method in class org.apache.flink.graph.library.TriangleEnumerator.Triad
setGroupRepresentativeId(K) - Method in class org.apache.flink.graph.library.Summarization.VertexGroupItem
setGroupRepresentativeId(K) - Method in class org.apache.flink.graph.library.Summarization.VertexWithRepresentative
setGroupSize(int) - Method in class org.apache.flink.graph.library.similarity.JaccardIndex: Override the default group size for the quadratic expansion of neighbor pairs.
setHubScore(DoubleValue) - Method in class org.apache.flink.graph.library.linkanalysis.HITS.Result: Set the hub score.
setId(K) - Method in class org.apache.flink.graph.Vertex
setIncludeZeroDegreeVertices(boolean) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees: By default only the edge set is processed for the computation of degree.
setIncludeZeroDegreeVertices(boolean) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexInDegree: By default only the edge set is processed for the computation of degree.
setIncludeZeroDegreeVertices(boolean) - Method in class org.apache.flink.graph.asm.degree.annotate.directed.VertexOutDegree: By default only the edge set is processed for the computation of degree.
setIncludeZeroDegreeVertices(boolean) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.VertexDegree: By default only the edge set is processed for the computation of degree.
setIncludeZeroDegreeVertices(boolean) - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient: By default the vertex set is checked for zero degree vertices.
setIncludeZeroDegreeVertices(boolean) - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient: By default the vertex set is checked for zero degree vertices.
setIncludeZeroDegreeVertices(boolean) - Method in class org.apache.flink.graph.library.linkanalysis.PageRank: This PageRank implementation properly handles both source and sink vertices which have, respectively, only outgoing and incoming edges.
setIncludeZeroDegreeVertices(boolean) - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics: By default only the edge set is processed for the computation of degree.
setIncludeZeroDegreeVertices(boolean) - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics: By default only the edge set is processed for the computation of degree.
setInput(DataSet<Vertex<K, VV>>) - Method in class org.apache.flink.graph.gsa.GatherSumApplyIteration: Sets the input data set for this operator.
setInput(DataSet<Vertex<K, VV>>) - Method in class org.apache.flink.graph.pregel.VertexCentricIteration: Sets the input data set for this operator.
setInput(DataSet<Vertex<K, VV>>) - Method in class org.apache.flink.graph.spargel.ScatterGatherIteration: Sets the input data set for this operator.
setMaximumScore(int, int) - Method in class org.apache.flink.graph.library.similarity.JaccardIndex: Filter out Jaccard Index scores greater than the given maximum fraction.
setMinimumRatio(float) - Method in class org.apache.flink.graph.library.similarity.AdamicAdar: Filter out Adamic-Adar scores less than the given ratio times the average score.
setMinimumScore(float) - Method in class org.apache.flink.graph.library.similarity.AdamicAdar: Filter out Adamic-Adar scores less than the given minimum.
setMinimumScore(int, int) - Method in class org.apache.flink.graph.library.similarity.JaccardIndex: Filter out Jaccard Index scores less than the given minimum fraction.
setMirrorResults(boolean) - Method in class org.apache.flink.graph.library.similarity.AdamicAdar: By default only one result is output for each pair of vertices.
setMirrorResults(boolean) - Method in class org.apache.flink.graph.library.similarity.JaccardIndex: By default only one result is output for each pair of vertices.
setName(String) - Method in class org.apache.flink.graph.IterationConfiguration: Sets the name for the iteration.
setNewVertexValue(VV) - Method in class org.apache.flink.graph.pregel.ComputeFunction: Sets the new value of this vertex.
setNewVertexValue(VV) - Method in class org.apache.flink.graph.spargel.GatherFunction: Sets the new value of this vertex.
setNoise(boolean, float) - Method in class org.apache.flink.graph.generator.RMatGraph: Enable and configure noise.
setOptDegrees(boolean) - Method in class org.apache.flink.graph.spargel.ScatterGatherConfiguration: Sets the degree option.
setOptNumVertices(boolean) - Method in class org.apache.flink.graph.IterationConfiguration: Sets the number of vertices option.
setOutput(Vertex<K, VV>, Collector<Vertex<K, VV>>) - Method in class org.apache.flink.graph.gsa.ApplyFunction
setPageRankScore(DoubleValue) - Method in class org.apache.flink.graph.library.linkanalysis.PageRank.Result: Set the PageRank score.
setParallelism(int) - Method in interface org.apache.flink.graph.generator.GraphGenerator: Override the operator parallelism.
setParallelism(int) - Method in class org.apache.flink.graph.generator.GraphGeneratorBase
setParallelism(int) - Method in class org.apache.flink.graph.GraphAnalyticBase: Set the parallelism for this analytic's operators.
setParallelism(int) - Method in class org.apache.flink.graph.IterationConfiguration: Sets the parallelism for the iteration.
setParallelism(int) - Method in class org.apache.flink.graph.utils.proxy.GraphAlgorithmWrappingBase: Set the parallelism for this algorithm's operators.
setPermuteResults(boolean) - Method in class org.apache.flink.graph.library.clustering.TriangleListingBase: By default only one result is output for each triangle, whether vertices are sorted or unsorted.
setReduceOnSourceId(boolean) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeTargetDegree: The degree can be counted from either the edge source or target IDs.
setReduceOnTargetId(boolean) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeDegreePair: The degree can be counted from either the edge source or target IDs.
setReduceOnTargetId(boolean) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.EdgeSourceDegree: The degree can be counted from either the edge source or target IDs.
setReduceOnTargetId(boolean) - Method in class org.apache.flink.graph.asm.degree.annotate.undirected.VertexDegree: The degree can be counted from either the edge source or target IDs.
setReduceOnTargetId(boolean) - Method in class org.apache.flink.graph.asm.degree.filter.undirected.MaximumDegree: The degree can be counted from either the edge source or target IDs.
setReduceOnTargetId(boolean) - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics: The degree can be counted from either the edge source or target IDs.
setReduceOnTargetId(boolean) - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics: The degree can be counted from either the edge source or target IDs.
setReference(ByteValueArray) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
setReference(CharValueArray) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
setReference(DoubleValueArray) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
setReference(FloatValueArray) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
setReference(IntValueArray) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
setReference(LongValueArray) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
setReference(NullValueArray) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
setReference(ShortValueArray) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
setReference(StringValueArray) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
setResult(VV) - Method in class org.apache.flink.graph.gsa.ApplyFunction: Sets the result for the apply function.
setSecondDegree(Integer) - Method in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
setSecondVertex(K) - Method in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
setSecondVertex(K) - Method in class org.apache.flink.graph.library.TriangleEnumerator.Triad
setSharedNeighborCount(IntValue) - Method in class org.apache.flink.graph.library.similarity.JaccardIndex.Result: Set the shared neighbor count.
setSolutionSetUnmanagedMemory(boolean) - Method in class org.apache.flink.graph.IterationConfiguration: Defines whether the solution set is kept in managed memory (Flink's internal way of keeping object in serialized form) or as a simple object map.
setSortTriangleVertices(boolean) - Method in class org.apache.flink.graph.library.clustering.TriangleListingBase: Normalize the triangle listing such that for each result (K0, K1, K2) the vertex IDs are sorted K0 < K1 < K2.
setSource(K) - Method in class org.apache.flink.graph.Edge
setTarget(K) - Method in class org.apache.flink.graph.Edge
setThirdVertex(K) - Method in class org.apache.flink.graph.library.TriangleEnumerator.Triad
setTopId(KT) - Method in class org.apache.flink.graph.bipartite.BipartiteEdge
setTriangleCount(LongValue) - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result: Set the number of triangles containing this vertex; equivalently, this is the number of edges between neighbors of this vertex.
setTriangleCount(LongValue) - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result: Set the number of triangles containing this vertex; equivalently, this is the number of edges between neighbors of this vertex.
setValue(EV) - Method in class org.apache.flink.graph.bipartite.BipartiteEdge
setValue(V) - Method in class org.apache.flink.graph.Edge
setValue(ValueArray<ByteValue>) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
setValue(ValueArray<CharValue>) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
setValue(ValueArray<DoubleValue>) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
setValue(ValueArray<FloatValue>) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
setValue(ValueArray<IntValue>) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
setValue(ValueArray<LongValue>) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
setValue(ValueArray<NullValue>) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
setValue(ValueArray<ShortValue>) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
setValue(ValueArray<StringValue>) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
setValue(V) - Method in class org.apache.flink.graph.Vertex
setVertexGroupCount(Long) - Method in class org.apache.flink.graph.library.Summarization.VertexGroupItem
setVertexGroupCount(Long) - Method in class org.apache.flink.graph.library.Summarization.VertexValue
setVertexGroupValue(VGV) - Method in class org.apache.flink.graph.library.Summarization.VertexGroupItem
setVertexGroupValue(VV) - Method in class org.apache.flink.graph.library.Summarization.VertexValue
setVertexId(K) - Method in class org.apache.flink.graph.library.Summarization.VertexGroupItem
setVertexId(K) - Method in class org.apache.flink.graph.library.Summarization.VertexWithRepresentative
setVertexId0(K) - Method in interface org.apache.flink.graph.asm.result.BinaryResult: Set the first vertex ID.
setVertexId0(K) - Method in class org.apache.flink.graph.asm.result.BinaryResultBase
setVertexId0(K) - Method in interface org.apache.flink.graph.asm.result.TertiaryResult: Set the first vertex ID.
setVertexId0(K) - Method in class org.apache.flink.graph.asm.result.TertiaryResultBase
setVertexId0(K) - Method in interface org.apache.flink.graph.asm.result.UnaryResult: Set the first vertex ID.
setVertexId0(K) - Method in class org.apache.flink.graph.asm.result.UnaryResultBase
setVertexId1(K) - Method in interface org.apache.flink.graph.asm.result.BinaryResult: Set the second vertex ID.
setVertexId1(K) - Method in class org.apache.flink.graph.asm.result.BinaryResultBase
setVertexId1(K) - Method in interface org.apache.flink.graph.asm.result.TertiaryResult: Set the second vertex ID.
setVertexId1(K) - Method in class org.apache.flink.graph.asm.result.TertiaryResultBase
setVertexId2(K) - Method in interface org.apache.flink.graph.asm.result.TertiaryResult: Set the third vertex ID.
setVertexId2(K) - Method in class org.apache.flink.graph.asm.result.TertiaryResultBase
ShortValueArray - Class in org.apache.flink.graph.types.valuearray: An array of ShortValue.
ShortValueArray() - Constructor for class org.apache.flink.graph.types.valuearray.ShortValueArray: Initializes an expandable array with default capacity.
ShortValueArray(int) - Constructor for class org.apache.flink.graph.types.valuearray.ShortValueArray: Initializes a fixed-size array with the provided number of shorts.
ShortValueArrayComparator - Class in org.apache.flink.graph.types.valuearray: Specialized comparator for ShortValueArray based on CopyableValueComparator.
ShortValueArrayComparator(boolean) - Constructor for class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
ShortValueArraySerializer - Class in org.apache.flink.graph.types.valuearray: Specialized serializer for ShortValueArray.
ShortValueArraySerializer() - Constructor for class org.apache.flink.graph.types.valuearray.ShortValueArraySerializer
Simplify<K extends Comparable<K>,VV,EV> - Class in org.apache.flink.graph.asm.simple.directed: Remove self-loops and duplicate edges from a directed graph.
Simplify() - Constructor for class org.apache.flink.graph.asm.simple.directed.Simplify
Simplify<K extends Comparable<K>,VV,EV> - Class in org.apache.flink.graph.asm.simple.undirected: Add symmetric edges and remove self-loops and duplicate edges from an undirected graph.
Simplify(boolean) - Constructor for class org.apache.flink.graph.asm.simple.undirected.Simplify: Simplifies an undirected graph by adding reverse edges and removing self-loops and duplicate edges.
SingleSourceShortestPaths<K,VV> - Class in org.apache.flink.graph.library: This is an implementation of the Single-Source-Shortest Paths algorithm, using a scatter-gather iteration.
SingleSourceShortestPaths(K, Integer) - Constructor for class org.apache.flink.graph.library.SingleSourceShortestPaths: Creates an instance of the SingleSourceShortestPaths algorithm.
SingleSourceShortestPaths.MinDistanceMessenger<K> - Class in org.apache.flink.graph.library: Distributes the minimum distance associated with a given vertex among all the target vertices summed up with the edge's value.
SingleSourceShortestPaths.VertexDistanceUpdater<K> - Class in org.apache.flink.graph.library: Function that updates the value of a vertex by picking the minimum distance from all incoming messages.
SingletonEdgeGraph - Class in org.apache.flink.graph.generator: A singleton-edge Graph contains one or more isolated two-paths.
SingletonEdgeGraph(ExecutionEnvironment, long) - Constructor for class org.apache.flink.graph.generator.SingletonEdgeGraph: An undirected Graph containing one or more isolated two-paths.
size() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
size() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
size() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
size() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
size() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
size() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
size() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
size() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
size() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
size() - Method in interface org.apache.flink.graph.types.valuearray.ValueArray: Returns the number of elements stored in the array.
sortTriangleVertices - Variable in class org.apache.flink.graph.library.clustering.TriangleListingBase
StarGraph - Class in org.apache.flink.graph.generator
StarGraph(ExecutionEnvironment, long) - Constructor for class org.apache.flink.graph.generator.StarGraph: An undirected Graph with n vertices where the single central node has degree n-1, connecting to the other n-1 vertices which have degree 1.
STRING_VALUE_ARRAY_TYPE_INFO - Static variable in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
StringValueArray - Class in org.apache.flink.graph.types.valuearray: An array of StringValue.
StringValueArray() - Constructor for class org.apache.flink.graph.types.valuearray.StringValueArray: Initializes an expandable array with default capacity.
StringValueArray(int) - Constructor for class org.apache.flink.graph.types.valuearray.StringValueArray: Initializes a fixed-size array with the provided number of bytes.
StringValueArrayComparator - Class in org.apache.flink.graph.types.valuearray: Specialized comparator for StringValueArray based on CopyableValueComparator.
StringValueArrayComparator(boolean) - Constructor for class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
StringValueArraySerializer - Class in org.apache.flink.graph.types.valuearray: Specialized serializer for StringValueArray.
StringValueArraySerializer() - Constructor for class org.apache.flink.graph.types.valuearray.StringValueArraySerializer
subgraph(FilterFunction<Vertex<K, VV>>, FilterFunction<Edge<K, EV>>) - Method in class org.apache.flink.graph.Graph: Apply filtering functions to the graph and return a sub-graph that satisfies the predicates for both vertices and edges.
sum(M, M) - Method in class org.apache.flink.graph.gsa.SumFunction: This method is invoked once per superstep, after the GatherFunction in a GatherSumApplyIteration.
SumFunction<VV,EV,M> - Class in org.apache.flink.graph.gsa: The base class for the second step of a GatherSumApplyIteration.
SumFunction() - Constructor for class org.apache.flink.graph.gsa.SumFunction
Summarization<K,VV,EV> - Class in org.apache.flink.graph.library: The summarization algorithm computes a condensed version of the input graph by grouping vertices and edges based on their values.
Summarization() - Constructor for class org.apache.flink.graph.library.Summarization
Summarization.EdgeValue<EV> - Class in org.apache.flink.graph.library: Value that is stored at a summarized edge.
Summarization.VertexGroupItem<K,VGV> - Class in org.apache.flink.graph.library: Represents a single vertex in a vertex group.
Summarization.VertexValue<VV> - Class in org.apache.flink.graph.library: Value that is stored at a summarized vertex.
Summarization.VertexWithRepresentative<K> - Class in org.apache.flink.graph.library: Represents a vertex identifier and its corresponding vertex group identifier.
supportsNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
supportsNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
supportsNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
supportsNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
supportsNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
supportsNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
supportsNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
supportsNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
supportsNormalizedKey() - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator
supportsSerializationWithKeyNormalization() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
supportsSerializationWithKeyNormalization() - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
supportsSerializationWithKeyNormalization() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
supportsSerializationWithKeyNormalization() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
supportsSerializationWithKeyNormalization() - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
supportsSerializationWithKeyNormalization() - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
supportsSerializationWithKeyNormalization() - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
supportsSerializationWithKeyNormalization() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
supportsSerializationWithKeyNormalization() - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator

T

TertiaryResult<K> - Interface in org.apache.flink.graph.asm.result: A GraphAlgorithm result for three vertices.
TertiaryResultBase<K> - Class in org.apache.flink.graph.asm.result: Base class for algorithm results for three vertices.
TertiaryResultBase() - Constructor for class org.apache.flink.graph.asm.result.TertiaryResultBase
ToNullValue<T> - Class in org.apache.flink.graph.asm.translate.translators: Replace any type with NullValue.
ToNullValue() - Constructor for class org.apache.flink.graph.asm.translate.translators.ToNullValue
toPrintableString() - Method in interface org.apache.flink.graph.asm.result.PrintableResult: A human-readable representation of this value.
toPrintableString() - Method in class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient.Result
toPrintableString() - Method in class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient.Result
toPrintableString() - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result: Format values into a human-readable string.
toPrintableString() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result
toPrintableString() - Method in class org.apache.flink.graph.library.clustering.directed.TriangleListing.Result
toPrintableString() - Method in class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient.Result
toPrintableString() - Method in class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient.Result
toPrintableString() - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result: Format values into a human-readable string.
toPrintableString() - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result
toPrintableString() - Method in class org.apache.flink.graph.library.clustering.undirected.TriangleListing.Result
toPrintableString() - Method in class org.apache.flink.graph.library.linkanalysis.HITS.Result
toPrintableString() - Method in class org.apache.flink.graph.library.linkanalysis.PageRank.Result
toPrintableString() - Method in class org.apache.flink.graph.library.metric.directed.EdgeMetrics.Result
toPrintableString() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result
toPrintableString() - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics.Result
toPrintableString() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result
toPrintableString() - Method in class org.apache.flink.graph.library.similarity.AdamicAdar.Result
toPrintableString() - Method in class org.apache.flink.graph.library.similarity.JaccardIndex.Result
toString() - Method in class org.apache.flink.graph.asm.dataset.ChecksumHashCode.Checksum
toString() - Method in class org.apache.flink.graph.asm.result.ResultBase: Object.toString() must be overridden to write POJO values in the same form as Tuple.
toString() - Method in class org.apache.flink.graph.generator.CirculantGraph.OffsetRange
toString() - Method in class org.apache.flink.graph.library.clustering.directed.AverageClusteringCoefficient.Result
toString() - Method in class org.apache.flink.graph.library.clustering.directed.GlobalClusteringCoefficient.Result
toString() - Method in class org.apache.flink.graph.library.clustering.directed.LocalClusteringCoefficient.Result
toString() - Method in class org.apache.flink.graph.library.clustering.directed.TriadicCensus.Result
toString() - Method in class org.apache.flink.graph.library.clustering.directed.TriangleListing.Result
toString() - Method in class org.apache.flink.graph.library.clustering.undirected.AverageClusteringCoefficient.Result
toString() - Method in class org.apache.flink.graph.library.clustering.undirected.GlobalClusteringCoefficient.Result
toString() - Method in class org.apache.flink.graph.library.clustering.undirected.LocalClusteringCoefficient.Result
toString() - Method in class org.apache.flink.graph.library.clustering.undirected.TriadicCensus.Result
toString() - Method in class org.apache.flink.graph.library.clustering.undirected.TriangleListing.Result
toString() - Method in class org.apache.flink.graph.library.linkanalysis.HITS.Result
toString() - Method in class org.apache.flink.graph.library.linkanalysis.PageRank.Result
toString() - Method in class org.apache.flink.graph.library.metric.directed.EdgeMetrics.Result
toString() - Method in class org.apache.flink.graph.library.metric.directed.VertexMetrics.Result
toString() - Method in class org.apache.flink.graph.library.metric.undirected.EdgeMetrics.Result
toString() - Method in class org.apache.flink.graph.library.metric.undirected.VertexMetrics.Result
toString() - Method in class org.apache.flink.graph.library.similarity.AdamicAdar.Result
toString() - Method in class org.apache.flink.graph.library.similarity.JaccardIndex.Result
toString() - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
toString() - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
toString() - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
toString() - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
toString() - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
toString() - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
toString() - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
toString() - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
toString() - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
toString() - Method in class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
TranslatableResult<K> - Interface in org.apache.flink.graph.asm.result: A transformable result can transform its ID type.
translate(TranslateFunction<K, T>, TranslatableResult<T>, Collector<TranslatableResult<T>>) - Method in class org.apache.flink.graph.asm.result.BinaryResultBase
translate(TranslateFunction<K, T>, TranslatableResult<T>, Collector<TranslatableResult<T>>) - Method in class org.apache.flink.graph.asm.result.TertiaryResultBase
translate(TranslateFunction<K, T>, TranslatableResult<T>, Collector<TranslatableResult<T>>) - Method in interface org.apache.flink.graph.asm.result.TranslatableResult: Output the result after transforming the vertex ID type.
translate(TranslateFunction<K, T>, TranslatableResult<T>, Collector<TranslatableResult<T>>) - Method in class org.apache.flink.graph.asm.result.UnaryResultBase
translate(IN, OUT) - Method in class org.apache.flink.graph.asm.translate.RichTranslateFunction
Translate - Class in org.apache.flink.graph.asm.translate: Methods for translation of the type or modification of the data of graph IDs, vertex values, and edge values.
Translate() - Constructor for class org.apache.flink.graph.asm.translate.Translate
translate(T, O) - Method in interface org.apache.flink.graph.asm.translate.TranslateFunction: The translating method.
translate(Long, LongValue) - Method in class org.apache.flink.graph.asm.translate.translators.LongToLongValue
translate(LongValue, LongValue) - Method in class org.apache.flink.graph.asm.translate.translators.LongValueAddOffset
translate(LongValue, IntValue) - Method in class org.apache.flink.graph.asm.translate.translators.LongValueToSignedIntValue
translate(LongValue, StringValue) - Method in class org.apache.flink.graph.asm.translate.translators.LongValueToStringValue
translate(LongValue, IntValue) - Method in class org.apache.flink.graph.asm.translate.translators.LongValueToUnsignedIntValue
translate(T, NullValue) - Method in class org.apache.flink.graph.asm.translate.translators.ToNullValue
translate(I, O) - Method in class org.apache.flink.graph.utils.GraphUtils.MapTo
translateEdgeIds(DataSet<Edge<OLD, EV>>, TranslateFunction<OLD, NEW>) - Static method in class org.apache.flink.graph.asm.translate.Translate: Translate Edge IDs using the given TranslateFunction.
translateEdgeIds(DataSet<Edge<OLD, EV>>, TranslateFunction<OLD, NEW>, int) - Static method in class org.apache.flink.graph.asm.translate.Translate: Translate Edge IDs using the given TranslateFunction.
translateEdgeValues(DataSet<Edge<K, OLD>>, TranslateFunction<OLD, NEW>) - Static method in class org.apache.flink.graph.asm.translate.Translate: Translate Edge values using the given TranslateFunction.
translateEdgeValues(DataSet<Edge<K, OLD>>, TranslateFunction<OLD, NEW>, int) - Static method in class org.apache.flink.graph.asm.translate.Translate: Translate Edge values using the given TranslateFunction.
TranslateEdgeValues<K,VV,OLD,NEW> - Class in org.apache.flink.graph.asm.translate: Translate Edge values using the given TranslateFunction.
TranslateEdgeValues(TranslateFunction<OLD, NEW>) - Constructor for class org.apache.flink.graph.asm.translate.TranslateEdgeValues: Translate Edge values using the given TranslateFunction.
translateEdgeValues(TranslateFunction<EV, NEW>) - Method in class org.apache.flink.graph.Graph: Translate Edge values using the given MapFunction.
TranslateFunction<T,O> - Interface in org.apache.flink.graph.asm.translate: Base interface for Translate functions.
TranslateGraphIds<OLD,NEW,VV,EV> - Class in org.apache.flink.graph.asm.translate: Translate Vertex and Edge IDs of a Graph using the given TranslateFunction.
TranslateGraphIds(TranslateFunction<OLD, NEW>) - Constructor for class org.apache.flink.graph.asm.translate.TranslateGraphIds: Translate Vertex and Edge IDs of a Graph using the given TranslateFunction.
translateGraphIds(TranslateFunction<K, NEW>) - Method in class org.apache.flink.graph.Graph: Translate Vertex and Edge IDs using the given MapFunction.
translateVertexIds(DataSet<Vertex<OLD, VV>>, TranslateFunction<OLD, NEW>) - Static method in class org.apache.flink.graph.asm.translate.Translate: Translate Vertex IDs using the given TranslateFunction.
translateVertexIds(DataSet<Vertex<OLD, VV>>, TranslateFunction<OLD, NEW>, int) - Static method in class org.apache.flink.graph.asm.translate.Translate: Translate Vertex IDs using the given TranslateFunction.
translateVertexValues(DataSet<Vertex<K, OLD>>, TranslateFunction<OLD, NEW>) - Static method in class org.apache.flink.graph.asm.translate.Translate: Translate Vertex values using the given TranslateFunction.
translateVertexValues(DataSet<Vertex<K, OLD>>, TranslateFunction<OLD, NEW>, int) - Static method in class org.apache.flink.graph.asm.translate.Translate: Translate Vertex values using the given TranslateFunction.
TranslateVertexValues<K,OLD,NEW,EV> - Class in org.apache.flink.graph.asm.translate: Translate Vertex values using the given TranslateFunction.
TranslateVertexValues(TranslateFunction<OLD, NEW>) - Constructor for class org.apache.flink.graph.asm.translate.TranslateVertexValues: Translate Vertex values using the given TranslateFunction.
translateVertexValues(TranslateFunction<VV, NEW>) - Method in class org.apache.flink.graph.Graph: Translate Vertex values using the given MapFunction.
Triad() - Constructor for class org.apache.flink.graph.library.TriangleEnumerator.Triad
TriadicCensus<K extends Comparable<K> & org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.directed: A triad is formed by three connected or unconnected vertices in a graph.
TriadicCensus() - Constructor for class org.apache.flink.graph.library.clustering.directed.TriadicCensus
TriadicCensus<K extends Comparable<K> & org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.undirected: A triad is formed by three connected or unconnected vertices in a graph.
TriadicCensus() - Constructor for class org.apache.flink.graph.library.clustering.undirected.TriadicCensus
TriadicCensus.Result - Class in org.apache.flink.graph.library.clustering.directed: Wraps triadic census metrics.
TriadicCensus.Result - Class in org.apache.flink.graph.library.clustering.undirected: Wraps triadic census metrics.
TriangleEnumerator<K extends Comparable<K>,VV,EV> - Class in org.apache.flink.graph.library: This library method enumerates unique triangles present in the input graph.
TriangleEnumerator() - Constructor for class org.apache.flink.graph.library.TriangleEnumerator
TriangleEnumerator.EdgeWithDegrees<K> - Class in org.apache.flink.graph.library: POJO storing two vertex IDs with degree.
TriangleEnumerator.Triad<K> - Class in org.apache.flink.graph.library: Tuple storing three vertex IDs.
TriangleListing<K extends Comparable<K> & org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.directed: Generates a listing of distinct triangles from the input graph.
TriangleListing() - Constructor for class org.apache.flink.graph.library.clustering.directed.TriangleListing
TriangleListing<K extends Comparable<K> & org.apache.flink.types.CopyableValue<K>,VV,EV> - Class in org.apache.flink.graph.library.clustering.undirected: Generates a listing of distinct triangles from the input graph.
TriangleListing() - Constructor for class org.apache.flink.graph.library.clustering.undirected.TriangleListing
TriangleListing.Result<T> - Class in org.apache.flink.graph.library.clustering.directed: A result for the directed Triangle Listing algorithm.
TriangleListing.Result<T> - Class in org.apache.flink.graph.library.clustering.undirected: A result for the undirected Triangle Listing algorithm.
TriangleListingBase<K,VV,EV,R> - Class in org.apache.flink.graph.library.clustering: Common configuration for directed and undirected Triangle Listing algorithms.
TriangleListingBase() - Constructor for class org.apache.flink.graph.library.clustering.TriangleListingBase
Triplet<K,VV,EV> - Class in org.apache.flink.graph: A Triplet stores and retrieves the edges along with their corresponding source and target vertices.
Triplet() - Constructor for class org.apache.flink.graph.Triplet
Triplet(Vertex<K, VV>, Vertex<K, VV>, Edge<K, EV>) - Constructor for class org.apache.flink.graph.Triplet: Constructs a Triplet from a given source vertex, target vertex, and edge.
Triplet(K, K, VV, VV, EV) - Constructor for class org.apache.flink.graph.Triplet: Constructs a Triplet from its src vertex id, src target id, src vertex value, src target value and edge value respectively.
Tuple2ToEdgeMap<K> - Class in org.apache.flink.graph.utils: Create an Edge from a Tuple2.
Tuple2ToEdgeMap() - Constructor for class org.apache.flink.graph.utils.Tuple2ToEdgeMap
Tuple2ToVertexMap<K,VV> - Class in org.apache.flink.graph.utils: Create a Vertex DataSet from a Tuple2 DataSet.
Tuple2ToVertexMap() - Constructor for class org.apache.flink.graph.utils.Tuple2ToVertexMap
Tuple3ToEdgeMap<K,EV> - Class in org.apache.flink.graph.utils: Create an Edge DataSet from a Tuple3 DataSet.
Tuple3ToEdgeMap() - Constructor for class org.apache.flink.graph.utils.Tuple3ToEdgeMap
types(Class<K>, Class<VV>, Class<EV>) - Method in class org.apache.flink.graph.GraphCsvReader: Creates a Graph from CSV input with vertex values and edge values.

U

UnaryResult<K> - Interface in org.apache.flink.graph.asm.result: A GraphAlgorithm result for a single vertex.
UnaryResultBase<K> - Class in org.apache.flink.graph.asm.result: Base class for algorithm results for a single vertex.
UnaryResultBase() - Constructor for class org.apache.flink.graph.asm.result.UnaryResultBase
union(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.Graph: Performs union on the vertices and edges sets of the input graphs removing duplicate vertices but maintaining duplicate edges.
unset() - Method in class org.apache.flink.graph.utils.proxy.OptionalBoolean: Reset to the unset state.
updateVertex(Vertex<K, VV>, MessageIterator<VV>) - Method in class org.apache.flink.graph.library.ConnectedComponents.CCUpdater
updateVertex(Vertex<K, VV>, MessageIterator<VV>) - Method in class org.apache.flink.graph.library.LabelPropagation.UpdateVertexLabel
updateVertex(Vertex<K, Double>, MessageIterator<Double>) - Method in class org.apache.flink.graph.library.SingleSourceShortestPaths.VertexDistanceUpdater
updateVertex(Vertex<K, VV>, MessageIterator<Message>) - Method in class org.apache.flink.graph.spargel.GatherFunction: This method is invoked once per vertex per superstep.
UpdateVertexLabel() - Constructor for class org.apache.flink.graph.library.LabelPropagation.UpdateVertexLabel

V

V1 - Static variable in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
V1 - Static variable in class org.apache.flink.graph.library.TriangleEnumerator.Triad
V2 - Static variable in class org.apache.flink.graph.library.TriangleEnumerator.EdgeWithDegrees
V2 - Static variable in class org.apache.flink.graph.library.TriangleEnumerator.Triad
V3 - Static variable in class org.apache.flink.graph.library.TriangleEnumerator.Triad
validate(GraphValidator<K, VV, EV>) - Method in class org.apache.flink.graph.Graph: Function that checks whether a Graph is a valid Graph, as defined by the given GraphValidator.
validate(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.validation.GraphValidator
validate(Graph<K, VV, EV>) - Method in class org.apache.flink.graph.validation.InvalidVertexIdsValidator: Checks that the edge set input contains valid vertex Ids, i.e.
ValueArray<T> - Interface in org.apache.flink.graph.types.valuearray: Basic interface for array types which reuse objects during serialization.
ValueArrayFactory - Class in org.apache.flink.graph.types.valuearray: A factory generator for ValueArray types is necessary because the contained Value types do not currently implement a common interface for creating a ValueArray.
ValueArrayFactory() - Constructor for class org.apache.flink.graph.types.valuearray.ValueArrayFactory
ValueArrayTypeInfo<T> - Class in org.apache.flink.graph.types.valuearray: A TypeInformation for the ValueArray type.
ValueArrayTypeInfo(TypeInformation<T>) - Constructor for class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfo
ValueArrayTypeInfoFactory<T> - Class in org.apache.flink.graph.types.valuearray: Used by TypeExtractor to create a TypeInformation for implementations of ValueArray.
ValueArrayTypeInfoFactory() - Constructor for class org.apache.flink.graph.types.valuearray.ValueArrayTypeInfoFactory
valueOf(String) - Static method in enum org.apache.flink.graph.EdgeDirection: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.graph.EdgeOrder: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.graph.utils.proxy.OptionalBoolean.State: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.flink.graph.EdgeDirection: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.graph.EdgeOrder: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.graph.utils.proxy.OptionalBoolean.State: Returns an array containing the constants of this enum type, in the order they are declared.
Vertex<K,V> - Class in org.apache.flink.graph: Represents the graph's nodes.
Vertex() - Constructor for class org.apache.flink.graph.Vertex
Vertex(K, V) - Constructor for class org.apache.flink.graph.Vertex
VertexCentricConfiguration - Class in org.apache.flink.graph.pregel: A VertexCentricConfiguration object can be used to set the iteration name and degree of parallelism, to register aggregators and use broadcast sets in the ComputeFunction.
VertexCentricConfiguration() - Constructor for class org.apache.flink.graph.pregel.VertexCentricConfiguration
VertexCentricIteration<K,VV,EV,Message> - Class in org.apache.flink.graph.pregel: This class represents iterative graph computations, programmed in a vertex-centric perspective.
VertexDegree<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.annotate.undirected: Annotates vertices of an undirected graph with the degree.
VertexDegree() - Constructor for class org.apache.flink.graph.asm.degree.annotate.undirected.VertexDegree
VertexDegrees<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.annotate.directed: Annotates vertices of a directed graph with the degree, out-, and in-degree.
VertexDegrees() - Constructor for class org.apache.flink.graph.asm.degree.annotate.directed.VertexDegrees
VertexDegrees.Degrees - Class in org.apache.flink.graph.asm.degree.annotate.directed: Wraps the vertex degree, out-degree, and in-degree.
VertexDistanceUpdater() - Constructor for class org.apache.flink.graph.library.SingleSourceShortestPaths.VertexDistanceUpdater
VertexGroupItem() - Constructor for class org.apache.flink.graph.library.Summarization.VertexGroupItem
VertexInDegree<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.annotate.directed: Annotates vertices of a directed graph with the in-degree.
VertexInDegree() - Constructor for class org.apache.flink.graph.asm.degree.annotate.directed.VertexInDegree
vertexJoin(VV, T) - Method in interface org.apache.flink.graph.VertexJoinFunction: Applies a transformation on the current vertex value and the value of the matched tuple of the input DataSet.
VertexJoinFunction<VV,T> - Interface in org.apache.flink.graph: Interface to be implemented by the transformation function applied in Graph.joinWithVertices(DataSet, VertexJoinFunction) method.
VertexMetrics<K extends Comparable<K>,VV,EV> - Class in org.apache.flink.graph.library.metric.directed: Compute the following vertex metrics in a directed graph.
VertexMetrics() - Constructor for class org.apache.flink.graph.library.metric.directed.VertexMetrics
VertexMetrics<K extends Comparable<K>,VV,EV> - Class in org.apache.flink.graph.library.metric.undirected: Compute the following vertex metrics in an undirected graph.
VertexMetrics() - Constructor for class org.apache.flink.graph.library.metric.undirected.VertexMetrics
VertexMetrics.Result - Class in org.apache.flink.graph.library.metric.directed: Wraps vertex metrics.
VertexMetrics.Result - Class in org.apache.flink.graph.library.metric.undirected: Wraps vertex metrics.
VertexOutDegree<K,VV,EV> - Class in org.apache.flink.graph.asm.degree.annotate.directed: Annotates vertices of a directed graph with the out-degree.
VertexOutDegree() - Constructor for class org.apache.flink.graph.asm.degree.annotate.directed.VertexOutDegree
vertexReader - Variable in class org.apache.flink.graph.GraphCsvReader
vertexSequence(ExecutionEnvironment, int, long) - Static method in class org.apache.flink.graph.generator.GraphGeneratorUtils: Generates Vertices with sequential, numerical labels.
vertexSet(DataSet<Edge<K, EV>>, int) - Static method in class org.apache.flink.graph.generator.GraphGeneratorUtils: Generates vertices present in the given set of Edges.
VertexToTuple2Map<K,VV> - Class in org.apache.flink.graph.utils: Create a Tuple2 DataSet from a Vertex DataSet.
VertexToTuple2Map() - Constructor for class org.apache.flink.graph.utils.VertexToTuple2Map
vertexTypes(Class<K>, Class<VV>) - Method in class org.apache.flink.graph.GraphCsvReader: Creates a Graph from CSV input without edge values.
VertexValue() - Constructor for class org.apache.flink.graph.library.Summarization.VertexValue
VertexWithRepresentative() - Constructor for class org.apache.flink.graph.library.Summarization.VertexWithRepresentative

W

withEdges(DataSet<Edge<K, EV>>, GatherFunction<VV, EV, M>, SumFunction<VV, EV, M>, ApplyFunction<K, VV, M>, int) - Static method in class org.apache.flink.graph.gsa.GatherSumApplyIteration: Creates a new gather-sum-apply iteration operator for graphs.
withEdges(DataSet<Edge<K, EV>>, ComputeFunction<K, VV, EV, Message>, int) - Static method in class org.apache.flink.graph.pregel.VertexCentricIteration: Creates a new vertex-centric iteration operator.
withEdges(DataSet<Edge<K, EV>>, ComputeFunction<K, VV, EV, Message>, MessageCombiner<K, Message>, int) - Static method in class org.apache.flink.graph.pregel.VertexCentricIteration: Creates a new vertex-centric iteration operator for graphs where the edges are associated with a value (such as a weight or distance).
withEdges(DataSet<Edge<K, EV>>, ScatterFunction<K, VV, Message, EV>, GatherFunction<K, VV, Message>, int) - Static method in class org.apache.flink.graph.spargel.ScatterGatherIteration: Creates a new scatter-gather iteration operator for graphs where the edges are associated with a value (such as a weight or distance).
write(DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArray
write(DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.CharValueArray
write(DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArray
write(DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArray
write(DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.IntValueArray
write(DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.LongValueArray
write(DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.NullValueArray
write(DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArray
write(DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.StringValueArray
writeWithKeyNormalization(ByteValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.ByteValueArrayComparator
writeWithKeyNormalization(CharValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.CharValueArrayComparator
writeWithKeyNormalization(DoubleValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.DoubleValueArrayComparator
writeWithKeyNormalization(FloatValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.FloatValueArrayComparator
writeWithKeyNormalization(IntValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.IntValueArrayComparator
writeWithKeyNormalization(LongValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.LongValueArrayComparator
writeWithKeyNormalization(NullValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.NullValueArrayComparator
writeWithKeyNormalization(ShortValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.ShortValueArrayComparator
writeWithKeyNormalization(StringValueArray, DataOutputView) - Method in class org.apache.flink.graph.types.valuearray.StringValueArrayComparator

A B C D E F G H I J K L M N O P R S T U V W