Uses of Interface
org.apache.flink.api.common.typeinfo.TypeDescriptor

Packages that use TypeDescriptor

Package	Description
org.apache.flink.api.common.state
org.apache.flink.api.common.typeinfo

Uses of TypeDescriptor in org.apache.flink.api.common.state

Methods in org.apache.flink.api.common.state that return TypeDescriptor

Modifier and Type	Method	Description
TypeDescriptor<K>	BroadcastStateDeclaration.getKeyTypeDescriptor()	Get type descriptor of this broadcast state's key.
TypeDescriptor<K>	MapStateDeclaration.getKeyTypeDescriptor()	Get type descriptor of this map state's key.
TypeDescriptor<ACC>	AggregatingStateDeclaration.getTypeDescriptor()	Get type descriptor of this state.
TypeDescriptor<T>	ListStateDeclaration.getTypeDescriptor()	Get type descriptor of this list state's element.
TypeDescriptor<T>	ReducingStateDeclaration.getTypeDescriptor()	Get type descriptor of this reducing state.
TypeDescriptor<T>	ValueStateDeclaration.getTypeDescriptor()	Get type descriptor of this value state.
TypeDescriptor<V>	BroadcastStateDeclaration.getValueTypeDescriptor()	Get type descriptor of this broadcast state's value.
TypeDescriptor<V>	MapStateDeclaration.getValueTypeDescriptor()	Get type descriptor of this map state's value.

Methods in org.apache.flink.api.common.state with parameters of type TypeDescriptor

Modifier and Type	Method	Description
static <IN,ACC,OUT> AggregatingStateDeclaration<IN,ACC,OUT>	StateDeclarations.aggregatingState(String name, TypeDescriptor<ACC> aggTypeDescriptor, AggregateFunction<IN,ACC,OUT> aggregateFunction)	Get the AggregatingStateDeclaration of aggregating state.
static <IN,OUT,ACC> StateDeclarations.AggregatingStateDeclarationBuilder<IN,OUT,ACC>	StateDeclarations.aggregatingStateBuilder(String name, TypeDescriptor<ACC> aggTypeDescriptor, AggregateFunction<IN,ACC,OUT> aggregateFunction)	Get the builder of AggregatingStateDeclaration.
static <T> ListStateDeclaration<T>	StateDeclarations.listState(String name, TypeDescriptor<T> elementTypeInformation)	Get the ListStateDeclaration of list state with StateDeclaration.RedistributionMode.NONE.
static <T> StateDeclarations.ListStateDeclarationBuilder<T>	StateDeclarations.listStateBuilder(String name, TypeDescriptor<T> elementTypeInformation)	Get the builder of ListStateDeclaration.
static <K,V> MapStateDeclaration<K,V>	StateDeclarations.mapState(String name, TypeDescriptor<K> keyTypeInformation, TypeDescriptor<V> valueTypeInformation)	Get the MapStateDeclaration of map state with StateDeclaration.RedistributionMode.NONE.
static <K,V> StateDeclarations.MapStateDeclarationBuilder<K,V>	StateDeclarations.mapStateBuilder(String name, TypeDescriptor<K> keyTypeInformation, TypeDescriptor<V> valueTypeInformation)	Get the builder of MapStateDeclaration.
static <T> ReducingStateDeclaration<T>	StateDeclarations.reducingState(String name, TypeDescriptor<T> typeInformation, ReduceFunction<T> reduceFunction)	Get the ReducingStateDeclaration of list state.
static <T> StateDeclarations.ReducingStateDeclarationBuilder<T>	StateDeclarations.reducingStateBuilder(String name, TypeDescriptor<T> typeInformation, ReduceFunction<T> reduceFunction)	Get the builder of ReducingStateDeclaration.
static <T> ValueStateDeclaration<T>	StateDeclarations.valueState(String name, TypeDescriptor<T> valueType)	Get the ValueStateDeclaration of value state.
<T> StateDeclarations.ValueStateDeclarationBuilder<T>	StateDeclarations.valueStateBuilder(String name, TypeDescriptor<T> valueType)	Get the builder of ValueStateDeclaration.

Constructors in org.apache.flink.api.common.state with parameters of type TypeDescriptor

Constructor	Description
AggregatingStateDeclarationBuilder(String name, TypeDescriptor<ACC> stateTypeDescriptor, AggregateFunction<IN,ACC,OUT> aggregateFunction)
ListStateDeclarationBuilder(String name, TypeDescriptor<T> elementTypeInformation)
MapStateDeclarationBuilder(String name, TypeDescriptor<K> keyTypeInformation, TypeDescriptor<V> valueTypeInformation)
MapStateDeclarationBuilder(String name, TypeDescriptor<K> keyTypeInformation, TypeDescriptor<V> valueTypeInformation, StateDeclaration.RedistributionMode redistributionMode)
ReducingStateDeclarationBuilder(String name, TypeDescriptor<T> typeInformation, ReduceFunction<T> reduceFunction)
ValueStateDeclarationBuilder(String name, TypeDescriptor<T> valueType)

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

Fields in org.apache.flink.api.common.typeinfo declared as TypeDescriptor

Modifier and Type	Field	Description
static TypeDescriptor<Boolean>	TypeDescriptors.BOOLEAN
static TypeDescriptor<Byte>	TypeDescriptors.BYTE
static TypeDescriptor<Character>	TypeDescriptors.CHAR
static TypeDescriptor<Double>	TypeDescriptors.DOUBLE
static TypeDescriptor<Float>	TypeDescriptors.FLOAT
static TypeDescriptor<Integer>	TypeDescriptors.INT
static TypeDescriptor<Long>	TypeDescriptors.LONG
static TypeDescriptor<Short>	TypeDescriptors.SHORT
static TypeDescriptor<String>	TypeDescriptors.STRING

Methods in org.apache.flink.api.common.typeinfo that return TypeDescriptor

Modifier and Type	Method	Description
static <T> TypeDescriptor<List<T>>	TypeDescriptors.list(TypeDescriptor<T> elementTypeDescriptor)
static <K,V> TypeDescriptor<Map<K,V>>	TypeDescriptors.map(TypeDescriptor<K> keyTypeDescriptor, TypeDescriptor<V> valueTypeDescriptor)
static <T> TypeDescriptor<T>	TypeDescriptors.value(TypeDescriptor<T> typeDescriptor)

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

Modifier and Type	Method	Description
static <T> TypeDescriptor<List<T>>	TypeDescriptors.list(TypeDescriptor<T> elementTypeDescriptor)
static <K,V> TypeDescriptor<Map<K,V>>	TypeDescriptors.map(TypeDescriptor<K> keyTypeDescriptor, TypeDescriptor<V> valueTypeDescriptor)
static <T> TypeDescriptor<T>	TypeDescriptors.value(TypeDescriptor<T> typeDescriptor)