Serialized Form
-
Package org.apache.flink.api.common.functions
-
Package org.apache.flink.api.common.state
-
Class org.apache.flink.api.common.state.IllegalRedistributionModeException extends IllegalStateException implements Serializable
- serialVersionUID:
- 1L
-
Class org.apache.flink.api.common.state.StateDeclarations.AggregatingStateDeclarationBuilder extends Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
aggregateFunction
AggregateFunction<IN,ACC,OUT> aggregateFunction
-
name
String name
-
stateTypeDescriptor
TypeDescriptor<ACC> stateTypeDescriptor
-
-
Class org.apache.flink.api.common.state.StateDeclarations.ListStateDeclarationBuilder extends Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
elementTypeInformation
TypeDescriptor<T> elementTypeInformation
-
name
String name
-
redistributionMode
StateDeclaration.RedistributionMode redistributionMode
-
redistributionStrategy
ListStateDeclaration.RedistributionStrategy redistributionStrategy
-
-
Class org.apache.flink.api.common.state.StateDeclarations.MapStateDeclarationBuilder extends Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
keyTypeInformation
TypeDescriptor<K> keyTypeInformation
-
name
String name
-
redistributionMode
StateDeclaration.RedistributionMode redistributionMode
-
valueTypeInformation
TypeDescriptor<V> valueTypeInformation
-
-
Class org.apache.flink.api.common.state.StateDeclarations.ReducingStateDeclarationBuilder extends Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
name
String name
-
reduceFunction
ReduceFunction<T> reduceFunction
-
typeInformation
TypeDescriptor<T> typeInformation
-
-
Class org.apache.flink.api.common.state.StateDeclarations.ValueStateDeclarationBuilder extends Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
name
String name
-
valueType
TypeDescriptor<T> valueType
-
-
-
Package org.apache.flink.api.common.typeinfo
-
Class org.apache.flink.api.common.typeinfo.TypeDescriptors extends Object implements Serializable
-
-
Package org.apache.flink.api.common.typeinfo.utils
-
Class org.apache.flink.api.common.typeinfo.utils.TypeUtils extends Object implements Serializable
-
-
Package org.apache.flink.api.java.functions
-
Package org.apache.flink.configuration
-
Class org.apache.flink.configuration.MemorySize extends Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
bytes
long bytes
The memory size, in bytes.
-
-
-
Package org.apache.flink.util.function