Uses of Interface
org.apache.flink.types.Value

Packages that use Value

Package	Description
org.apache.flink.api.common.aggregators
org.apache.flink.api.common.functions
org.apache.flink.api.common.typeinfo
org.apache.flink.api.java.operators
org.apache.flink.api.java.summarize.aggregation
org.apache.flink.api.java.typeutils
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.graph.drivers.transform
org.apache.flink.graph.gsa
org.apache.flink.graph.pregel
org.apache.flink.graph.spargel
org.apache.flink.graph.types.valuearray
org.apache.flink.runtime.iterative.concurrent
org.apache.flink.runtime.iterative.event
org.apache.flink.runtime.iterative.task
org.apache.flink.runtime.operators.util
org.apache.flink.types

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

Classes in org.apache.flink.api.common.aggregators with type parameters of type Value

Modifier and Type	Interface and Description
interface	Aggregator<T extends Value> Aggregators are a means of aggregating values across parallel instances of a function.
class	AggregatorWithName<T extends Value> Simple utility class holding an Aggregator with the name it is registered under.
interface	ConvergenceCriterion<T extends Value> Used to check for convergence.

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

Modifier and Type	Method and Description
<T extends Value> void	AggregatorRegistry.registerAggregationConvergenceCriterion(String name, Aggregator<T> aggregator, ConvergenceCriterion<T> convergenceCheck)

Uses of Value in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions with type parameters of type Value

Modifier and Type	Method and Description
<T extends Value> T	IterationRuntimeContext.getPreviousIterationAggregate(String name)

Uses of Value in org.apache.flink.api.common.typeinfo

Methods in org.apache.flink.api.common.typeinfo with type parameters of type Value

Modifier and Type	Method and Description
static <V extends Value> TypeInformation<V>	Types.VALUE(Class<V> valueType) Returns type information for Flink value types (classes that implement Value).

Uses of Value in org.apache.flink.api.java.operators

Methods in org.apache.flink.api.java.operators with type parameters of type Value

Modifier and Type	Method and Description
<X extends Value> DeltaIteration<ST,WT>	DeltaIteration.registerAggregationConvergenceCriterion(String name, Aggregator<X> aggregator, ConvergenceCriterion<X> convergenceCheck) Registers an Aggregator for the iteration together with a ConvergenceCriterion.
<X extends Value> IterativeDataSet<T>	IterativeDataSet.registerAggregationConvergenceCriterion(String name, Aggregator<X> aggregator, ConvergenceCriterion<X> convergenceCheck) Registers an Aggregator for the iteration together with a ConvergenceCriterion.

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

Classes in org.apache.flink.api.java.summarize.aggregation with type parameters of type Value

Modifier and Type	Class and Description
class	ValueSummaryAggregator<VT extends Value,PT,R,A extends Aggregator<PT,R>> This is a generic Aggregator for Value types like StringValue, DoubleValue, etc.

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

Classes in org.apache.flink.api.java.typeutils with type parameters of type Value

Modifier and Type	Class and Description
class	ValueTypeInfo<T extends Value> Type information for data types that extend the Value interface.

Uses of Value in org.apache.flink.api.java.typeutils.runtime

Classes in org.apache.flink.api.java.typeutils.runtime with type parameters of type Value

Modifier and Type	Class and Description
class	ValueComparator<T extends Value & Comparable<T>> Comparator for all Value types that extend Key
class	ValueSerializer<T extends Value> Serializer for Value types.
static class	ValueSerializer.ValueSerializerConfigSnapshot<T extends Value> Deprecated.
static class	ValueSerializer.ValueSerializerSnapshot<T extends Value> ValueSerializer snapshot class.

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

Classes in org.apache.flink.graph.drivers.transform that implement Value

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

Uses of Value in org.apache.flink.graph.gsa

Methods in org.apache.flink.graph.gsa with type parameters of type Value

Modifier and Type	Method and Description
<T extends Value> T	SumFunction.getPreviousIterationAggregate(String name) Get the aggregated value that an aggregator computed in the previous iteration.
<T extends Value> T	ApplyFunction.getPreviousIterationAggregate(String name) Get the aggregated value that an aggregator computed in the previous iteration.
<T extends Value> T	GatherFunction.getPreviousIterationAggregate(String name) Get the aggregated value that an aggregator computed in the previous iteration.

Uses of Value in org.apache.flink.graph.pregel

Methods in org.apache.flink.graph.pregel with type parameters of type Value

Modifier and Type	Method and Description
<T extends Value> T	ComputeFunction.getPreviousIterationAggregate(String name) Get the aggregated value that an aggregator computed in the previous iteration.

Uses of Value in org.apache.flink.graph.spargel

Methods in org.apache.flink.graph.spargel with type parameters of type Value

Modifier and Type	Method and Description
<T extends Value> T	ScatterFunction.getPreviousIterationAggregate(String name) Get the aggregated value that an aggregator computed in the previous iteration.
<T extends Value> T	GatherFunction.getPreviousIterationAggregate(String name) Get the aggregated value that an aggregator computed in the previous iteration.

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

Subinterfaces of Value in org.apache.flink.graph.types.valuearray

Modifier and Type	Interface and Description
interface	ValueArray<T> Basic interface for array types which reuse objects during serialization.

Classes in org.apache.flink.graph.types.valuearray that implement Value

Modifier and Type	Class and Description
class	ByteValueArray An array of ByteValue.
class	CharValueArray An array of CharValue.
class	DoubleValueArray An array of DoubleValue.
class	FloatValueArray An array of FloatValue.
class	IntValueArray An array of IntValue.
class	LongValueArray An array of LongValue.
class	NullValueArray An array of NullValue.
class	ShortValueArray An array of ShortValue.
class	StringValueArray An array of StringValue.

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

Modifier and Type	Method and Description
static <T> ValueArray<T>	ValueArrayFactory.createValueArray(Class<? extends Value> cls) Produce a ValueArray for the given Value type.
static <T> ValueArray<T>	ValueArrayFactory.createValueArray(Class<? extends Value> cls, int bytes) Produce a ValueArray for the given Value type with the given bounded size.

Uses of Value in org.apache.flink.runtime.iterative.concurrent

Methods in org.apache.flink.runtime.iterative.concurrent that return Value

Modifier and Type	Method and Description
Value[]	SuperstepBarrier.getAggregates()

Uses of Value in org.apache.flink.runtime.iterative.event

Fields in org.apache.flink.runtime.iterative.event declared as Value

Modifier and Type	Field and Description
protected static Value[]	IterationEventWithAggregators.NO_VALUES

Methods in org.apache.flink.runtime.iterative.event that return Value

Modifier and Type	Method and Description
Value[]	IterationEventWithAggregators.getAggregates(ClassLoader classResolver)

Constructors in org.apache.flink.runtime.iterative.event with parameters of type Value

Constructor and Description
IterationEventWithAggregators(String aggregatorName, Value aggregate)
WorkerDoneEvent(int workerIndex, String aggregatorName, Value aggregate)

Uses of Value in org.apache.flink.runtime.iterative.task

Methods in org.apache.flink.runtime.iterative.task that return Value

Modifier and Type	Method and Description
Value	RuntimeAggregatorRegistry.getPreviousGlobalAggregate(String name)

Methods in org.apache.flink.runtime.iterative.task with parameters of type Value

Modifier and Type	Method and Description
void	RuntimeAggregatorRegistry.updateGlobalAggregatesAndReset(String[] names, Value[] aggregates)

Uses of Value in org.apache.flink.runtime.operators.util

Methods in org.apache.flink.runtime.operators.util with type parameters of type Value

Modifier and Type	Method and Description
<T extends Value> ConvergenceCriterion<T>	TaskConfig.getConvergenceCriterion(ClassLoader cl)
<T extends Value> ConvergenceCriterion<T>	TaskConfig.getImplicitConvergenceCriterion(ClassLoader cl)

Uses of Value in org.apache.flink.types

Classes in org.apache.flink.types with type parameters of type Value

Modifier and Type	Class and Description
class	ListValue<V extends Value> Generic list base type for PACT programs that implements the Value and List interfaces.
class	MapValue<K extends Value,V extends Value> Generic map base type for PACT programs that implements the Value and Map interfaces.
class	MapValue<K extends Value,V extends Value> Generic map base type for PACT programs that implements the Value and Map interfaces.
interface	ResettableValue<T extends Value>

Subinterfaces of Value in org.apache.flink.types

Modifier and Type	Interface and Description
interface	CopyableValue<T> Interface to be implemented by basic types that support to be copied efficiently.
interface	Key<T> Deprecated. The Key type is a relict of a deprecated and removed API and will be removed in future (2.0) versions as well.
interface	NormalizableKey<T> The base interface for normalizable keys.
interface	ResettableValue<T extends Value>

Classes in org.apache.flink.types that implement Value

Modifier and Type	Class and Description
class	BooleanValue Boxed serializable and comparable boolean type, representing the primitive type boolean.
class	ByteValue Boxed serializable and comparable byte type, representing the primitive type byte (signed 8 bit integer).
class	CharValue Boxed serializable and comparable character type, representing the primitive type char.
class	DoubleValue Boxed serializable and comparable double precision floating point type, representing the primitive type double.
class	FloatValue Boxed serializable and comparable single precision floating point type, representing the primitive type float.
class	IntValue Boxed serializable and comparable integer type, representing the primitive type int.
class	ListValue<V extends Value> Generic list base type for PACT programs that implements the Value and List interfaces.
class	LongValue Boxed serializable and comparable long integer type, representing the primitive type long.
class	MapValue<K extends Value,V extends Value> Generic map base type for PACT programs that implements the Value and Map interfaces.
class	NullValue Null base type for programs that implements the Key interface.
class	Record The Record represents a multi-valued data record.
class	ShortValue Boxed serializable and comparable short integer type, representing the primitive type short.
class	StringValue Mutable string data type that implements the Key interface.

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

Modifier and Type	Method and Description
<T extends Value> T	Record.getField(int fieldNum, Class<T> type) Gets the field at the given position from the record.
<T extends Value> T	Record.getField(int fieldNum, T target) Gets the field at the given position.

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

Modifier and Type	Method and Description
static Value	JavaToValueConverter.convertBoxedJavaType(Object boxed)

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

Modifier and Type	Method and Description
void	Record.addField(Value value)
static Object	JavaToValueConverter.convertValueType(Value value)
boolean	Record.equalsFields(int[] positions, Value[] searchValues, Value[] deserializationHolders) Checks the values of this record and a given list of values at specified positions for equality.
boolean	Record.equalsFields(int[] positions, Value[] searchValues, Value[] deserializationHolders) Checks the values of this record and a given list of values at specified positions for equality.
boolean	Record.getFieldInto(int fieldNum, Value target) Gets the field at the given position.
boolean	Record.getFieldsInto(int[] positions, Value[] targets) Gets the fields at the given positions into an array.
void	Record.getFieldsIntoCheckingNull(int[] positions, Value[] targets) Gets the fields at the given positions into an array.
void	Record.setField(int fieldNum, Value value) Sets the field at the given position to the given value.

Constructors in org.apache.flink.types with parameters of type Value

Constructor and Description
Record(Value value) Creates a new record containing only a single field, which is the given value.
Record(Value val1, Value val2) Creates a new record containing exactly two fields, which are the given values.