Uses of Class
org.apache.flink.types.LongValue

Packages that use LongValue

Package	Description
org.apache.flink.api.common.aggregators
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.typeutils.base
org.apache.flink.api.java.summarize.aggregation
org.apache.flink.api.java.typeutils
org.apache.flink.graph
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
org.apache.flink.graph.asm.degree.annotate.undirected
org.apache.flink.graph.asm.translate.translators
org.apache.flink.graph.drivers.input
org.apache.flink.graph.drivers.transform
org.apache.flink.graph.generator
org.apache.flink.graph.library.clustering.directed
org.apache.flink.graph.library.clustering.undirected
org.apache.flink.graph.types.valuearray
org.apache.flink.graph.utils
org.apache.flink.runtime.iterative.convergence
org.apache.flink.types
org.apache.flink.types.parser
org.apache.flink.util

Uses of LongValue in org.apache.flink.api.common.aggregators

Methods in org.apache.flink.api.common.aggregators that return LongValue

Modifier and Type	Method and Description
LongValue	LongSumAggregator.getAggregate()

Methods in org.apache.flink.api.common.aggregators with parameters of type LongValue

Modifier and Type	Method and Description
void	LongSumAggregator.aggregate(LongValue element)
boolean	LongZeroConvergence.isConverged(int iteration, LongValue value) Returns true, if the aggregator value is zero, false otherwise.

Uses of LongValue in org.apache.flink.api.common.operators.base

Methods in org.apache.flink.api.common.operators.base that return LongValue

Modifier and Type	Method and Description
LongValue	BulkIterationBase.TerminationCriterionAggregator.getAggregate()

Methods in org.apache.flink.api.common.operators.base with parameters of type LongValue

Modifier and Type	Method and Description
void	BulkIterationBase.TerminationCriterionAggregator.aggregate(LongValue count)
boolean	BulkIterationBase.TerminationCriterionAggregationConvergence.isConverged(int iteration, LongValue countAggregate)

Uses of LongValue in org.apache.flink.api.common.typeutils.base

Methods in org.apache.flink.api.common.typeutils.base that return LongValue

Modifier and Type	Method and Description
LongValue	LongValueSerializer.copy(LongValue from)
LongValue	LongValueSerializer.copy(LongValue from, LongValue reuse)
LongValue	LongValueSerializer.createInstance()
LongValue	LongValueSerializer.deserialize(DataInputView source)
LongValue	LongValueSerializer.deserialize(LongValue reuse, DataInputView source)
LongValue	LongValueComparator.readWithKeyDenormalization(LongValue reuse, DataInputView source)

Methods in org.apache.flink.api.common.typeutils.base that return types with arguments of type LongValue

Modifier and Type	Method and Description
TypeComparator<LongValue>	LongValueComparator.duplicate()
TypeSerializerSnapshot<LongValue>	LongValueSerializer.snapshotConfiguration()

Methods in org.apache.flink.api.common.typeutils.base with parameters of type LongValue

Modifier and Type	Method and Description
int	LongValueComparator.compare(LongValue first, LongValue second)
LongValue	LongValueSerializer.copy(LongValue from)
LongValue	LongValueSerializer.copy(LongValue from, LongValue reuse)
LongValue	LongValueSerializer.deserialize(LongValue reuse, DataInputView source)
boolean	LongValueComparator.equalToReference(LongValue candidate)
int	LongValueComparator.hash(LongValue record)
void	LongValueComparator.putNormalizedKey(LongValue record, MemorySegment target, int offset, int numBytes)
LongValue	LongValueComparator.readWithKeyDenormalization(LongValue reuse, DataInputView source)
void	LongValueSerializer.serialize(LongValue record, DataOutputView target)
void	LongValueComparator.setReference(LongValue toCompare)
void	LongValueComparator.writeWithKeyNormalization(LongValue record, DataOutputView target)

Method parameters in org.apache.flink.api.common.typeutils.base with type arguments of type LongValue

Modifier and Type	Method and Description
int	LongValueComparator.compareToReference(TypeComparator<LongValue> referencedComparator)

Uses of LongValue in org.apache.flink.api.java.summarize.aggregation

Methods in org.apache.flink.api.java.summarize.aggregation with parameters of type LongValue

Modifier and Type	Method and Description
protected Long	ValueSummaryAggregator.LongValueSummaryAggregator.getValue(LongValue value)

Uses of LongValue in org.apache.flink.api.java.typeutils

Fields in org.apache.flink.api.java.typeutils with type parameters of type LongValue

Modifier and Type	Field and Description
static ValueTypeInfo<LongValue>	ValueTypeInfo.LONG_VALUE_TYPE_INFO

Uses of LongValue in org.apache.flink.graph

Methods in org.apache.flink.graph that return types with arguments of type LongValue

Modifier and Type	Method and Description
DataSet<Tuple2<K,LongValue>>	Graph.getDegrees() Return the degree of all vertices in the graph.
DataSet<Tuple2<K,LongValue>>	Graph.inDegrees() Return the in-degree of all vertices in the graph.
DataSet<Tuple2<K,LongValue>>	Graph.outDegrees() Return the out-degree of all vertices in the graph.

Uses of LongValue in org.apache.flink.graph.asm.degree.annotate

Methods in org.apache.flink.graph.asm.degree.annotate that return types with arguments of type LongValue

Modifier and Type	Method and Description
Vertex<K,LongValue>	DegreeAnnotationFunctions.JoinVertexWithVertexDegree.join(Vertex<K,VV> vertex, Vertex<K,LongValue> vertexDegree)
Vertex<K,LongValue>	DegreeAnnotationFunctions.MapEdgeToSourceId.map(Edge<K,EV> value)
Vertex<K,LongValue>	DegreeAnnotationFunctions.MapEdgeToTargetId.map(Edge<K,EV> value)
Vertex<K,LongValue>	DegreeAnnotationFunctions.DegreeCount.reduce(Vertex<K,LongValue> left, Vertex<K,LongValue> right)

Method parameters in org.apache.flink.graph.asm.degree.annotate with type arguments of type LongValue

Modifier and Type	Method and Description
Vertex<K,LongValue>	DegreeAnnotationFunctions.JoinVertexWithVertexDegree.join(Vertex<K,VV> vertex, Vertex<K,LongValue> vertexDegree)
Vertex<K,LongValue>	DegreeAnnotationFunctions.DegreeCount.reduce(Vertex<K,LongValue> left, Vertex<K,LongValue> right)
Vertex<K,LongValue>	DegreeAnnotationFunctions.DegreeCount.reduce(Vertex<K,LongValue> left, Vertex<K,LongValue> right)

Uses of LongValue in org.apache.flink.graph.asm.degree.annotate.directed

Methods in org.apache.flink.graph.asm.degree.annotate.directed that return LongValue

Modifier and Type	Method and Description
LongValue	VertexDegrees.Degrees.getDegree()
LongValue	VertexDegrees.Degrees.getInDegree()
LongValue	VertexDegrees.Degrees.getOutDegree()

Methods in org.apache.flink.graph.asm.degree.annotate.directed that return types with arguments of type LongValue

Modifier and Type	Method and Description
DataSet<Vertex<K,LongValue>>	VertexInDegree.runInternal(Graph<K,VV,EV> input)
DataSet<Vertex<K,LongValue>>	VertexOutDegree.runInternal(Graph<K,VV,EV> input)

Constructors in org.apache.flink.graph.asm.degree.annotate.directed with parameters of type LongValue

Constructor and Description
Degrees(LongValue value0, LongValue value1, LongValue value2)

Uses of LongValue in org.apache.flink.graph.asm.degree.annotate.undirected

Methods in org.apache.flink.graph.asm.degree.annotate.undirected that return types with arguments of type LongValue

Modifier and Type	Method and Description
DataSet<Edge<K,Tuple2<EV,LongValue>>>	EdgeTargetDegree.runInternal(Graph<K,VV,EV> input)
DataSet<Edge<K,Tuple3<EV,LongValue,LongValue>>>	EdgeDegreePair.runInternal(Graph<K,VV,EV> input)
DataSet<Edge<K,Tuple3<EV,LongValue,LongValue>>>	EdgeDegreePair.runInternal(Graph<K,VV,EV> input)
DataSet<Vertex<K,LongValue>>	VertexDegree.runInternal(Graph<K,VV,EV> input)
DataSet<Edge<K,Tuple2<EV,LongValue>>>	EdgeSourceDegree.runInternal(Graph<K,VV,EV> input)

Uses of LongValue in org.apache.flink.graph.asm.translate.translators

Methods in org.apache.flink.graph.asm.translate.translators that return LongValue

Modifier and Type	Method and Description
LongValue	LongToLongValue.translate(Long value, LongValue reuse)
LongValue	LongValueAddOffset.translate(LongValue value, LongValue reuse)

Methods in org.apache.flink.graph.asm.translate.translators with parameters of type LongValue

Modifier and Type	Method and Description
LongValue	LongToLongValue.translate(Long value, LongValue reuse)
IntValue	LongValueToSignedIntValue.translate(LongValue value, IntValue reuse)
IntValue	LongValueToUnsignedIntValue.translate(LongValue value, IntValue reuse)
LongValue	LongValueAddOffset.translate(LongValue value, LongValue reuse)
StringValue	LongValueToStringValue.translate(LongValue value, StringValue reuse)

Uses of LongValue in org.apache.flink.graph.drivers.input

Methods in org.apache.flink.graph.drivers.input that return types with arguments of type LongValue

Modifier and Type	Method and Description
Graph<LongValue,NullValue,NullValue>	EchoGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	StarGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	HypercubeGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	CompleteGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	GeneratedMultiGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	CycleGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	SingletonEdgeGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	EmptyGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	PathGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	GridGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	CirculantGraph.create(ExecutionEnvironment env)
Graph<LongValue,NullValue,NullValue>	RMatGraph.generate(ExecutionEnvironment env)
abstract Graph<LongValue,NullValue,NullValue>	GeneratedMultiGraph.generate(ExecutionEnvironment env)

Uses of LongValue in org.apache.flink.graph.drivers.transform

Subclasses of LongValue in org.apache.flink.graph.drivers.transform

Modifier and Type	Class and Description
class	LongValueWithProperHashCode Fix for hashCode().

Method parameters in org.apache.flink.graph.drivers.transform with type arguments of type LongValue

Modifier and Type	Method and Description
Graph<?,VV,EV>	GraphKeyTypeTransform.transformInput(Graph<LongValue,VV,EV> input)

Uses of LongValue in org.apache.flink.graph.generator

Methods in org.apache.flink.graph.generator that return types with arguments of type LongValue

Modifier and Type	Method and Description
Graph<LongValue,NullValue,NullValue>	EchoGraph.generate()
Graph<LongValue,NullValue,NullValue>	StarGraph.generate()
Graph<LongValue,NullValue,NullValue>	RMatGraph.generate()
Graph<LongValue,NullValue,NullValue>	HypercubeGraph.generate()
Graph<LongValue,NullValue,NullValue>	CompleteGraph.generate()
Graph<LongValue,NullValue,NullValue>	CycleGraph.generate()
Graph<LongValue,NullValue,NullValue>	SingletonEdgeGraph.generate()
Graph<LongValue,NullValue,NullValue>	EmptyGraph.generate()
Graph<LongValue,NullValue,NullValue>	PathGraph.generate()
Graph<LongValue,NullValue,NullValue>	GridGraph.generate()
Graph<LongValue,NullValue,NullValue>	CirculantGraph.generate()
static DataSet<Vertex<LongValue,NullValue>>	GraphGeneratorUtils.vertexSequence(ExecutionEnvironment env, int parallelism, long vertexCount) Generates Vertices with sequential, numerical labels.

Uses of LongValue in org.apache.flink.graph.library.clustering.directed

Methods in org.apache.flink.graph.library.clustering.directed that return LongValue

Modifier and Type	Method and Description
LongValue	LocalClusteringCoefficient.Result.getDegree() Get the vertex degree.
LongValue	LocalClusteringCoefficient.Result.getTriangleCount() Get the number of triangles containing this vertex; equivalently, this is the number of edges between neighbors of this vertex.

Methods in org.apache.flink.graph.library.clustering.directed with parameters of type LongValue

Modifier and Type	Method and Description
void	LocalClusteringCoefficient.Result.setDegree(LongValue degree) Set the vertex degree.
void	LocalClusteringCoefficient.Result.setTriangleCount(LongValue triangleCount) Set the number of triangles containing this vertex; equivalently, this is the number of edges between neighbors of this vertex.

Uses of LongValue in org.apache.flink.graph.library.clustering.undirected

Methods in org.apache.flink.graph.library.clustering.undirected that return LongValue

Modifier and Type	Method and Description
LongValue	LocalClusteringCoefficient.Result.getDegree() Get the vertex degree.
LongValue	LocalClusteringCoefficient.Result.getTriangleCount() Get the number of triangles containing this vertex; equivalently, this is the number of edges between neighbors of this vertex.

Methods in org.apache.flink.graph.library.clustering.undirected with parameters of type LongValue

Modifier and Type	Method and Description
void	LocalClusteringCoefficient.Result.setDegree(LongValue degree) Set the vertex degree.
void	LocalClusteringCoefficient.Result.setTriangleCount(LongValue triangleCount) Set the number of triangles containing this vertex; equivalently, this is the number of edges between neighbors of this vertex.

Uses of LongValue in org.apache.flink.graph.types.valuearray

Fields in org.apache.flink.graph.types.valuearray with type parameters of type LongValue

Modifier and Type	Field and Description
static ValueArrayTypeInfo<LongValue>	ValueArrayTypeInfo.LONG_VALUE_ARRAY_TYPE_INFO

Methods in org.apache.flink.graph.types.valuearray that return types with arguments of type LongValue

Modifier and Type	Method and Description
ValueArray<LongValue>	LongValueArray.copy()
Iterator<LongValue>	LongValueArray.iterator()

Methods in org.apache.flink.graph.types.valuearray with parameters of type LongValue

Modifier and Type	Method and Description
boolean	LongValueArray.add(LongValue value)

Method parameters in org.apache.flink.graph.types.valuearray with type arguments of type LongValue

Modifier and Type	Method and Description
boolean	LongValueArray.addAll(ValueArray<LongValue> other)
int	LongValueArray.compareTo(ValueArray<LongValue> o)
void	LongValueArray.copyTo(ValueArray<LongValue> target)
void	LongValueArray.setValue(ValueArray<LongValue> value)

Uses of LongValue in org.apache.flink.graph.utils

Methods in org.apache.flink.graph.utils that return LongValue

Modifier and Type	Method and Description
LongValue	GraphUtils.AddLongValue.reduce(LongValue value1, LongValue value2)

Methods in org.apache.flink.graph.utils that return types with arguments of type LongValue

Modifier and Type	Method and Description
static <T> DataSet<LongValue>	GraphUtils.count(DataSet<T> input) Count the number of elements in a DataSet.

Methods in org.apache.flink.graph.utils with parameters of type LongValue

Modifier and Type	Method and Description
LongValue	GraphUtils.AddLongValue.reduce(LongValue value1, LongValue value2)

Uses of LongValue in org.apache.flink.runtime.iterative.convergence

Methods in org.apache.flink.runtime.iterative.convergence with parameters of type LongValue

Modifier and Type	Method and Description
boolean	WorksetEmptyConvergenceCriterion.isConverged(int iteration, LongValue value)

Uses of LongValue in org.apache.flink.types

Methods in org.apache.flink.types that return LongValue

Modifier and Type	Method and Description
LongValue	LongValue.copy()

Methods in org.apache.flink.types with parameters of type LongValue

Modifier and Type	Method and Description
int	LongValue.compareTo(LongValue o)
void	LongValue.copyTo(LongValue target)
void	LongValue.setValue(LongValue value)

Uses of LongValue in org.apache.flink.types.parser

Methods in org.apache.flink.types.parser that return LongValue

Modifier and Type	Method and Description
LongValue	LongValueParser.createValue()
LongValue	LongValueParser.getLastResult()

Methods in org.apache.flink.types.parser with parameters of type LongValue

Modifier and Type	Method and Description
int	LongValueParser.parseField(byte[] bytes, int startPos, int limit, byte[] delimiter, LongValue reusable)

Uses of LongValue in org.apache.flink.util

Methods in org.apache.flink.util that return LongValue

Modifier and Type	Method and Description
LongValue	LongValueSequenceIterator.next()