Modifier and Type | Method and Description |
---|---|
void |
SerializedListAccumulator.add(T value,
TypeSerializer<T> serializer) |
static <T> List<T> |
SerializedListAccumulator.deserializeList(ArrayList<byte[]> data,
TypeSerializer<T> serializer) |
Constructor and Description |
---|
CopyingIterator(Iterator<E> source,
TypeSerializer<E> serializer) |
CopyingListCollector(List<T> list,
TypeSerializer<T> serializer) |
Constructor and Description |
---|
SimpleListIterable(List<IN> values,
TypeComparator<IN> comparator,
TypeSerializer<IN> serializer) |
SimpleListIterator(List<IN> values,
TypeSerializer<IN> serializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<BT> |
JoinHashMap.getBuildSerializer() |
Constructor and Description |
---|
JoinHashMap(TypeSerializer<BT> buildSerializer,
TypeComparator<BT> buildComparator) |
ListKeyGroupedIterator(List<E> input,
TypeSerializer<E> serializer,
TypeComparator<E> comparator)
Initializes the ListKeyGroupedIterator..
|
Constructor and Description |
---|
TypeInformationSerializationSchema(TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Creates a new de-/serialization schema for the given type.
|
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<T> |
StateDescriptor.serializer
The serializer for the type.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
ListStateDescriptor.getElementSerializer()
Gets the serializer for the elements contained in the list.
|
TypeSerializer<UK> |
MapStateDescriptor.getKeySerializer()
Gets the serializer for the keys in the state.
|
TypeSerializer<T> |
StateDescriptor.getSerializer()
Returns the
TypeSerializer that can be used to serialize the value in the state. |
TypeSerializer<UV> |
MapStateDescriptor.getValueSerializer()
Gets the serializer for the values in the state.
|
Constructor and Description |
---|
AggregatingStateDescriptor(String name,
AggregateFunction<IN,ACC,OUT> aggFunction,
TypeSerializer<ACC> typeSerializer)
Creates a new
ValueStateDescriptor with the given name and default value. |
FoldingStateDescriptor(String name,
ACC initialValue,
FoldFunction<T,ACC> foldFunction,
TypeSerializer<ACC> typeSerializer)
Deprecated.
Creates a new
ValueStateDescriptor with the given name and default value. |
ListStateDescriptor(String name,
TypeSerializer<T> typeSerializer)
Creates a new
ListStateDescriptor with the given name and list element type. |
MapStateDescriptor(String name,
TypeSerializer<UK> keySerializer,
TypeSerializer<UV> valueSerializer)
Create a new
MapStateDescriptor with the given name and the given type serializers. |
MapStateDescriptor(String name,
TypeSerializer<UK> keySerializer,
TypeSerializer<UV> valueSerializer)
Create a new
MapStateDescriptor with the given name and the given type serializers. |
ReducingStateDescriptor(String name,
ReduceFunction<T> reduceFunction,
TypeSerializer<T> typeSerializer)
Creates a new
ValueStateDescriptor with the given name and default value. |
StateDescriptor(String name,
TypeSerializer<T> serializer,
T defaultValue)
Create a new
StateDescriptor with the given name and the given type serializer. |
ValueStateDescriptor(String name,
TypeSerializer<T> typeSerializer)
Creates a new
ValueStateDescriptor with the given name and the specific serializer. |
ValueStateDescriptor(String name,
TypeSerializer<T> typeSerializer,
T defaultValue)
Deprecated.
Use
ValueStateDescriptor.ValueStateDescriptor(String, TypeSerializer) instead and manually
manage the default value by checking whether the contents of the state is null . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
BasicArrayTypeInfo.createSerializer(ExecutionConfig executionConfig) |
abstract TypeSerializer<T> |
TypeInformation.createSerializer(ExecutionConfig config)
Creates a serializer for the type.
|
TypeSerializer<Nothing> |
NothingTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
SqlTimeTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
BasicTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
PrimitiveArrayTypeInfo.createSerializer(ExecutionConfig executionConfig) |
Constructor and Description |
---|
BasicTypeInfo(Class<T> clazz,
Class<?>[] possibleCastTargetTypes,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
FractionalTypeInfo(Class<T> clazz,
Class<?>[] possibleCastTargetTypes,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
IntegerTypeInfo(Class<T> clazz,
Class<?>[] possibleCastTargetTypes,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
NumericTypeInfo(Class<T> clazz,
Class<?>[] possibleCastTargetTypes,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
SqlTimeTypeInfo(Class<T> clazz,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
Modifier and Type | Class and Description |
---|---|
class |
TypeDeserializerAdapter<T>
A utility class that is used to bridge a
TypeSerializer and TypeDeserializer . |
class |
UnloadableDummyTypeSerializer<T>
Dummy TypeSerializer to avoid that data is lost when checkpointing again a serializer for which we encountered
a
ClassNotFoundException or InvalidClassException . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
TypeDeserializer.duplicate()
Creates a deep copy of this deserializer if it is necessary, i.e.
|
TypeSerializer<T> |
TypeDeserializerAdapter.duplicate() |
TypeSerializer<T> |
UnloadableDummyTypeSerializer.duplicate() |
abstract TypeSerializer<T> |
TypeSerializer.duplicate()
Creates a deep copy of this serializer if it is necessary, i.e.
|
TypeSerializer<T> |
TypeSerializerFactory.getSerializer() |
TypeSerializer<T> |
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy.getTypeSerializer() |
static <T> TypeSerializer<T> |
TypeSerializerSerializationUtil.tryReadSerializer(DataInputView in,
ClassLoader userCodeClassLoader)
Reads from a data input view a
TypeSerializer that was previously
written using TypeSerializerSerializationUtil.writeSerializer(DataOutputView, TypeSerializer) . |
static <T> TypeSerializer<T> |
TypeSerializerSerializationUtil.tryReadSerializer(DataInputView in,
ClassLoader userCodeClassLoader,
boolean useDummyPlaceholder)
Reads from a data input view a
TypeSerializer that was previously
written using TypeSerializerSerializationUtil.writeSerializer(DataOutputView, TypeSerializer) . |
Modifier and Type | Method and Description |
---|---|
List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> |
CompositeTypeSerializerConfigSnapshot.getNestedSerializersAndConfigs() |
Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot> |
CompositeTypeSerializerConfigSnapshot.getSingleNestedSerializerAndConfig() |
static List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> |
TypeSerializerSerializationUtil.readSerializersAndConfigsWithResilience(DataInputView in,
ClassLoader userCodeClassLoader)
Reads from a data input view a list of serializers and their corresponding config snapshots
written using
TypeSerializerSerializationUtil.writeSerializersAndConfigsWithResilience(DataOutputView, List) . |
Modifier and Type | Method and Description |
---|---|
static <T> CompatibilityResult<T> |
CompatibilityResult.requiresMigration(TypeSerializer<T> convertSerializer)
Returns a result that signals migration to be performed, and in the case that the preceding serializer
cannot be found or restored to read the previous data during migration, a provided convert serializer
can be used.
|
static <T> CompatibilityResult<T> |
CompatibilityUtil.resolveCompatibilityResult(TypeSerializer<?> precedingSerializer,
Class<?> dummySerializerClassTag,
TypeSerializerConfigSnapshot precedingSerializerConfigSnapshot,
TypeSerializer<T> newSerializer)
Resolves the final compatibility result of two serializers by taking into account compound information,
including the preceding serializer, the preceding serializer's configuration snapshot, and the new serializer.
|
static <T> CompatibilityResult<T> |
CompatibilityUtil.resolveCompatibilityResult(TypeSerializer<?> precedingSerializer,
Class<?> dummySerializerClassTag,
TypeSerializerConfigSnapshot precedingSerializerConfigSnapshot,
TypeSerializer<T> newSerializer)
Resolves the final compatibility result of two serializers by taking into account compound information,
including the preceding serializer, the preceding serializer's configuration snapshot, and the new serializer.
|
static <T> void |
TypeSerializerSerializationUtil.writeSerializer(DataOutputView out,
TypeSerializer<T> serializer)
Writes a
TypeSerializer to the provided data output view. |
Modifier and Type | Method and Description |
---|---|
static void |
TypeSerializerSerializationUtil.writeSerializersAndConfigsWithResilience(DataOutputView out,
List<Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> serializersAndConfigs)
Write a list of serializers and their corresponding config snapshots to the provided
data output view.
|
Constructor and Description |
---|
CompositeTypeSerializerConfigSnapshot(TypeSerializer<?>... nestedSerializers) |
TypeDeserializerAdapter(TypeSerializer<T> serializer)
Creates a
TypeDeserializerAdapter that wraps a TypeSerializer . |
TypeSerializerSerializationProxy(TypeSerializer<T> typeSerializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<Map<K,V>> |
MapSerializer.duplicate() |
TypeSerializer<List<T>> |
ListSerializer.duplicate() |
TypeSerializer<T> |
ListSerializer.getElementSerializer()
Gets the serializer for the elements of the list.
|
TypeSerializer<K> |
MapSerializer.getKeySerializer() |
TypeSerializer<V> |
MapSerializer.getValueSerializer() |
Constructor and Description |
---|
CollectionSerializerConfigSnapshot(TypeSerializer<T> elementSerializer) |
GenericArraySerializer(Class<C> componentClass,
TypeSerializer<C> componentSerializer) |
GenericArraySerializerConfigSnapshot(Class<C> componentClass,
TypeSerializer<C> componentSerializer) |
ListSerializer(TypeSerializer<T> elementSerializer)
Creates a list serializer that uses the given serializer to serialize the list's elements.
|
MapSerializer(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Creates a map serializer that uses the given serializers to serialize the key-value pairs in the map.
|
MapSerializer(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Creates a map serializer that uses the given serializers to serialize the key-value pairs in the map.
|
MapSerializerConfigSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer) |
MapSerializerConfigSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer) |
Modifier and Type | Class and Description |
---|---|
class |
BooleanPrimitiveArraySerializer
A serializer for boolean arrays.
|
class |
BytePrimitiveArraySerializer
A serializer for byte arrays.
|
class |
CharPrimitiveArraySerializer
A serializer for char arrays.
|
class |
DoublePrimitiveArraySerializer
A serializer for double arrays.
|
class |
FloatPrimitiveArraySerializer
A serializer for float arrays.
|
class |
IntPrimitiveArraySerializer
A serializer for int arrays.
|
class |
LongPrimitiveArraySerializer
A serializer for long arrays.
|
class |
ShortPrimitiveArraySerializer
A serializer for short arrays.
|
class |
StringArraySerializer
A serializer for String arrays.
|
Constructor and Description |
---|
CollectHelper(String id,
TypeSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
void |
TypeSerializerOutputFormat.setSerializer(TypeSerializer<T> serializer) |
Constructor and Description |
---|
CollectionInputFormat(Collection<T> dataSet,
TypeSerializer<T> serializer) |
Modifier and Type | Class and Description |
---|---|
class |
AvroSerializer<T>
Deprecated.
|
class |
CopyableValueSerializer<T extends CopyableValue<T>> |
class |
EitherSerializer<L,R>
A
TypeSerializer for the Either type of the Java class. |
class |
PojoSerializer<T> |
class |
RowSerializer
Serializer for
Row . |
class |
Tuple0Serializer |
class |
TupleSerializer<T extends Tuple> |
class |
TupleSerializerBase<T> |
class |
ValueSerializer<T extends Value>
Serializer for
Value types. |
class |
WritableSerializer<T extends org.apache.hadoop.io.Writable>
A
TypeSerializer for Writable . |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<Object>[] |
TupleSerializerBase.fieldSerializers |
protected TypeSerializer[] |
TupleComparatorBase.serializers
serializers to deserialize the first n fields for comparison
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<Either<L,R>> |
EitherSerializer.duplicate() |
TypeSerializer<Row> |
RowSerializer.duplicate() |
TypeSerializer<Object>[] |
TupleSerializerBase.getFieldSerializers() |
TypeSerializer<T> |
RuntimeSerializerFactory.getSerializer() |
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> |
PojoSerializer.PojoSerializerConfigSnapshot.getFieldToSerializerConfigSnapshot() |
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> |
PojoSerializer.PojoSerializerConfigSnapshot.getNonRegisteredSubclassesToSerializerConfigSnapshots() |
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerConfigSnapshot>> |
PojoSerializer.PojoSerializerConfigSnapshot.getRegisteredSubclassesToSerializerConfigSnapshots() |
Modifier and Type | Method and Description |
---|---|
static <T> T |
KryoUtils.copy(T from,
com.esotericsoftware.kryo.Kryo kryo,
TypeSerializer<T> serializer)
Tries to copy the given record from using the provided Kryo instance.
|
static <T> T |
KryoUtils.copy(T from,
T reuse,
com.esotericsoftware.kryo.Kryo kryo,
TypeSerializer<T> serializer)
Tries to copy the given record from using the provided Kryo instance.
|
protected abstract TupleSerializerBase<T> |
TupleSerializerBase.createSerializerInstance(Class<T> tupleClass,
TypeSerializer<?>[] fieldSerializers) |
protected TupleSerializerBase<T> |
TupleSerializer.createSerializerInstance(Class<T> tupleClass,
TypeSerializer<?>[] fieldSerializers) |
Constructor and Description |
---|
EitherSerializer(TypeSerializer<L> leftSerializer,
TypeSerializer<R> rightSerializer) |
EitherSerializer(TypeSerializer<L> leftSerializer,
TypeSerializer<R> rightSerializer) |
EitherSerializerConfigSnapshot(TypeSerializer<L> leftSerializer,
TypeSerializer<R> rightSerializer) |
EitherSerializerConfigSnapshot(TypeSerializer<L> leftSerializer,
TypeSerializer<R> rightSerializer) |
GenericTypeComparator(boolean ascending,
TypeSerializer<T> serializer,
Class<T> type) |
PojoComparator(Field[] keyFields,
TypeComparator<?>[] comparators,
TypeSerializer<T> serializer,
Class<T> type) |
PojoSerializer(Class<T> clazz,
Field[] fields,
TypeSerializer<Object>[] fieldSerializers,
LinkedHashMap<Class<?>,Integer> registeredClasses,
TypeSerializer<?>[] registeredSerializers,
HashMap<Class<?>,TypeSerializer<?>> subclassSerializerCache) |
PojoSerializer(Class<T> clazz,
Field[] fields,
TypeSerializer<Object>[] fieldSerializers,
LinkedHashMap<Class<?>,Integer> registeredClasses,
TypeSerializer<?>[] registeredSerializers,
HashMap<Class<?>,TypeSerializer<?>> subclassSerializerCache) |
PojoSerializer(Class<T> clazz,
TypeSerializer<?>[] fieldSerializers,
Field[] fields,
ExecutionConfig executionConfig) |
RowComparator(int arity,
int[] keyPositions,
TypeComparator<Object>[] comparators,
TypeSerializer<Object>[] serializers,
boolean[] orders)
General constructor for RowComparator.
|
RowSerializer(TypeSerializer<?>[] fieldSerializers) |
RowSerializerConfigSnapshot(TypeSerializer[] fieldSerializers) |
RuntimeSerializerFactory(TypeSerializer<T> serializer,
Class<T> clazz) |
TupleComparator(int[] keyPositions,
TypeComparator<?>[] comparators,
TypeSerializer<?>[] serializers) |
TupleComparatorBase(int[] keyPositions,
TypeComparator<?>[] comparators,
TypeSerializer<?>[] serializers) |
TupleSerializer(Class<T> tupleClass,
TypeSerializer<?>[] fieldSerializers) |
TupleSerializerBase(Class<T> tupleClass,
TypeSerializer<?>[] fieldSerializers) |
TupleSerializerConfigSnapshot(Class<T> tupleClass,
TypeSerializer<?>[] fieldSerializers) |
Modifier and Type | Class and Description |
---|---|
class |
KryoSerializer<T>
A type serializer that serializes its type using the Kryo serialization
framework (https://github.com/EsotericSoftware/kryo).
|
Constructor and Description |
---|
ScalaOptionSerializerConfigSnapshot(TypeSerializer<E> elementSerializer) |
ScalaTrySerializerConfigSnapshot(TypeSerializer<E> elementSerializer,
TypeSerializer<Throwable> throwableSerializer) |
ScalaTrySerializerConfigSnapshot(TypeSerializer<E> elementSerializer,
TypeSerializer<Throwable> throwableSerializer) |
TraversableSerializerConfigSnapshot(TypeSerializer<E> elementSerializer) |
Modifier and Type | Class and Description |
---|---|
static class |
DeweyNumber.DeweyNumberSerializer
A
TypeSerializer for the DeweyNumber which serves as a version number. |
static class |
NFA.NFASerializer<T>
A
TypeSerializer for NFA that uses Java Serialization. |
static class |
SharedBuffer.SharedBufferSerializer<K extends Serializable,V>
A
TypeSerializer for the SharedBuffer . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
SharedBuffer.SharedBufferSerializer.getKeySerializer() |
TypeSerializer<V> |
SharedBuffer.SharedBufferSerializer.getValueSerializer() |
TypeSerializer<DeweyNumber> |
SharedBuffer.SharedBufferSerializer.getVersionSerializer() |
Modifier and Type | Method and Description |
---|---|
static <T> NFA<T> |
NFACompiler.compile(Pattern<T,?> pattern,
TypeSerializer<T> inputTypeSerializer,
boolean timeoutHandling)
Compiles the given pattern into a
NFA . |
static <T> NFACompiler.NFAFactory<T> |
NFACompiler.compileFactory(Pattern<T,?> pattern,
TypeSerializer<T> inputTypeSerializer,
boolean timeoutHandling)
Compiles the given pattern into a
NFACompiler.NFAFactory . |
Modifier and Type | Method and Description |
---|---|
protected <N,T,ACC,R> |
RocksDBKeyedStateBackend.createAggregatingState(TypeSerializer<N> namespaceSerializer,
AggregatingStateDescriptor<T,ACC,R> stateDesc) |
protected <N,T,ACC> InternalFoldingState<K,N,T,ACC> |
RocksDBKeyedStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
<K> AbstractKeyedStateBackend<K> |
RocksDBStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry) |
protected <N,T> InternalListState<K,N,T> |
RocksDBKeyedStateBackend.createListState(TypeSerializer<N> namespaceSerializer,
ListStateDescriptor<T> stateDesc) |
protected <N,UK,UV> InternalMapState<K,N,UK,UV> |
RocksDBKeyedStateBackend.createMapState(TypeSerializer<N> namespaceSerializer,
MapStateDescriptor<UK,UV> stateDesc) |
protected <N,T> InternalReducingState<K,N,T> |
RocksDBKeyedStateBackend.createReducingState(TypeSerializer<N> namespaceSerializer,
ReducingStateDescriptor<T> stateDesc) |
protected <N,T> InternalValueState<K,N,T> |
RocksDBKeyedStateBackend.createValueState(TypeSerializer<N> namespaceSerializer,
ValueStateDescriptor<T> stateDesc) |
byte[] |
RocksDBMapState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<Map<UK,UV>> safeValueSerializer) |
byte[] |
RocksDBMapState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<Map<UK,UV>> safeValueSerializer) |
byte[] |
RocksDBMapState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<Map<UK,UV>> safeValueSerializer) |
byte[] |
AbstractRocksDBState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<V> safeValueSerializer) |
byte[] |
AbstractRocksDBState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<V> safeValueSerializer) |
byte[] |
AbstractRocksDBState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<V> safeValueSerializer) |
static boolean |
RocksDBKeySerializationUtils.isAmbiguousKeyPossible(TypeSerializer keySerializer,
TypeSerializer namespaceSerializer) |
static boolean |
RocksDBKeySerializationUtils.isAmbiguousKeyPossible(TypeSerializer keySerializer,
TypeSerializer namespaceSerializer) |
static <K> K |
RocksDBKeySerializationUtils.readKey(TypeSerializer<K> keySerializer,
ByteArrayInputStreamWithPos inputStream,
DataInputView inputView,
boolean ambiguousKeyPossible) |
static <N> N |
RocksDBKeySerializationUtils.readNamespace(TypeSerializer<N> namespaceSerializer,
ByteArrayInputStreamWithPos inputStream,
DataInputView inputView,
boolean ambiguousKeyPossible) |
static <K> void |
RocksDBKeySerializationUtils.writeKey(K key,
TypeSerializer<K> keySerializer,
ByteArrayOutputStreamWithPos keySerializationStream,
DataOutputView keySerializationDataOutputView,
boolean ambiguousKeyPossible) |
protected void |
AbstractRocksDBState.writeKeyWithGroupAndNamespace(int keyGroup,
K key,
TypeSerializer<K> keySerializer,
N namespace,
TypeSerializer<N> namespaceSerializer,
ByteArrayOutputStreamWithPos keySerializationStream,
DataOutputView keySerializationDataOutputView) |
protected void |
AbstractRocksDBState.writeKeyWithGroupAndNamespace(int keyGroup,
K key,
TypeSerializer<K> keySerializer,
N namespace,
TypeSerializer<N> namespaceSerializer,
ByteArrayOutputStreamWithPos keySerializationStream,
DataOutputView keySerializationDataOutputView) |
static <N> void |
RocksDBKeySerializationUtils.writeNameSpace(N namespace,
TypeSerializer<N> namespaceSerializer,
ByteArrayOutputStreamWithPos keySerializationStream,
DataOutputView keySerializationDataOutputView,
boolean ambiguousKeyPossible) |
Constructor and Description |
---|
AbstractRocksDBState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> valueSerializer,
V defaultValue,
RocksDBKeyedStateBackend<K> backend)
Creates a new RocksDB backed state.
|
AbstractRocksDBState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> valueSerializer,
V defaultValue,
RocksDBKeyedStateBackend<K> backend)
Creates a new RocksDB backed state.
|
RocksDBAggregatingState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<ACC> valueSerializer,
ACC defaultValue,
AggregateFunction<T,ACC,R> aggFunction,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBAggregatingState . |
RocksDBAggregatingState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<ACC> valueSerializer,
ACC defaultValue,
AggregateFunction<T,ACC,R> aggFunction,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBAggregatingState . |
RocksDBFoldingState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<ACC> valueSerializer,
ACC defaultValue,
FoldFunction<T,ACC> foldFunction,
RocksDBKeyedStateBackend<K> backend)
Deprecated.
Creates a new
RocksDBFoldingState . |
RocksDBFoldingState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<ACC> valueSerializer,
ACC defaultValue,
FoldFunction<T,ACC> foldFunction,
RocksDBKeyedStateBackend<K> backend)
Deprecated.
Creates a new
RocksDBFoldingState . |
RocksDBKeyedStateBackend(String operatorIdentifier,
ClassLoader userCodeClassLoader,
File instanceBasePath,
org.rocksdb.DBOptions dbOptions,
org.rocksdb.ColumnFamilyOptions columnFamilyOptions,
TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
ExecutionConfig executionConfig,
boolean enableIncrementalCheckpointing,
LocalRecoveryConfig localRecoveryConfig) |
RocksDBListState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<List<V>> valueSerializer,
List<V> defaultValue,
TypeSerializer<V> elementSerializer,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBListState . |
RocksDBListState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<List<V>> valueSerializer,
List<V> defaultValue,
TypeSerializer<V> elementSerializer,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBListState . |
RocksDBListState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<List<V>> valueSerializer,
List<V> defaultValue,
TypeSerializer<V> elementSerializer,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBListState . |
RocksDBMapState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<Map<UK,UV>> valueSerializer,
Map<UK,UV> defaultValue,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBMapState . |
RocksDBMapState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<Map<UK,UV>> valueSerializer,
Map<UK,UV> defaultValue,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBMapState . |
RocksDBReducingState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> valueSerializer,
V defaultValue,
ReduceFunction<V> reduceFunction,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBReducingState . |
RocksDBReducingState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> valueSerializer,
V defaultValue,
ReduceFunction<V> reduceFunction,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBReducingState . |
RocksDBValueState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> valueSerializer,
V defaultValue,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBValueState . |
RocksDBValueState(org.rocksdb.ColumnFamilyHandle columnFamily,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> valueSerializer,
V defaultValue,
RocksDBKeyedStateBackend<K> backend)
Creates a new
RocksDBValueState . |
Modifier and Type | Class and Description |
---|---|
class |
BackwardsCompatibleAvroSerializer<T>
An Avro serializer that can switch back to a KryoSerializer or a Pojo Serializer, if
it has to ensure compatibility with one of those.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
AvroTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
BackwardsCompatibleAvroSerializer.duplicate() |
TypeSerializer<T> |
AvroSerializer.duplicate() |
Modifier and Type | Method and Description |
---|---|
<T> TypeSerializer<T> |
AvroKryoSerializerUtils.createAvroSerializer(Class<T> type) |
Modifier and Type | Class and Description |
---|---|
static class |
LongValueWithProperHashCode.LongValueWithProperHashCodeSerializer
Serializer for
LongValueWithProperHashCode . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<LongValueWithProperHashCode> |
LongValueWithProperHashCode.LongValueWithProperHashCodeTypeInfo.createSerializer(ExecutionConfig executionConfig) |
Modifier and Type | Class and Description |
---|---|
class |
ByteValueArraySerializer
Specialized serializer for
ByteValueArray . |
class |
CharValueArraySerializer
Specialized serializer for
CharValueArray . |
class |
DoubleValueArraySerializer
Specialized serializer for
DoubleValueArray . |
class |
FloatValueArraySerializer
Specialized serializer for
FloatValueArray . |
class |
IntValueArraySerializer
Specialized serializer for
IntValueArray . |
class |
LongValueArraySerializer
Specialized serializer for
LongValueArray . |
class |
NullValueArraySerializer
Specialized serializer for
NullValueArray . |
class |
ShortValueArraySerializer
Specialized serializer for
ShortValueArray . |
class |
StringValueArraySerializer
Specialized serializer for
StringValueArray . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<ValueArray<T>> |
ValueArrayTypeInfo.createSerializer(ExecutionConfig executionConfig) |
Constructor and Description |
---|
HadoopTupleUnwrappingIterator(TypeSerializer<KEY> keySerializer) |
Modifier and Type | Class and Description |
---|---|
class |
VoidNamespaceSerializer
Serializer for
VoidNamespace . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<VoidNamespace> |
VoidNamespaceTypeInfo.createSerializer(ExecutionConfig config) |
Modifier and Type | Method and Description |
---|---|
static <K,N> Tuple2<K,N> |
KvStateSerializer.deserializeKeyAndNamespace(byte[] serializedKeyAndNamespace,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Deserializes the key and namespace into a
Tuple2 . |
static <K,N> Tuple2<K,N> |
KvStateSerializer.deserializeKeyAndNamespace(byte[] serializedKeyAndNamespace,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Deserializes the key and namespace into a
Tuple2 . |
static <T> List<T> |
KvStateSerializer.deserializeList(byte[] serializedValue,
TypeSerializer<T> serializer)
Deserializes all values with the given serializer.
|
static <UK,UV> Map<UK,UV> |
KvStateSerializer.deserializeMap(byte[] serializedValue,
TypeSerializer<UK> keySerializer,
TypeSerializer<UV> valueSerializer)
Deserializes all kv pairs with the given serializer.
|
static <UK,UV> Map<UK,UV> |
KvStateSerializer.deserializeMap(byte[] serializedValue,
TypeSerializer<UK> keySerializer,
TypeSerializer<UV> valueSerializer)
Deserializes all kv pairs with the given serializer.
|
static <T> T |
KvStateSerializer.deserializeValue(byte[] serializedValue,
TypeSerializer<T> serializer)
Deserializes the value with the given serializer.
|
static <K,N> byte[] |
KvStateSerializer.serializeKeyAndNamespace(K key,
TypeSerializer<K> keySerializer,
N namespace,
TypeSerializer<N> namespaceSerializer)
Serializes the key and namespace into a
ByteBuffer . |
static <K,N> byte[] |
KvStateSerializer.serializeKeyAndNamespace(K key,
TypeSerializer<K> keySerializer,
N namespace,
TypeSerializer<N> namespaceSerializer)
Serializes the key and namespace into a
ByteBuffer . |
static <UK,UV> byte[] |
KvStateSerializer.serializeMap(Iterable<Map.Entry<UK,UV>> entries,
TypeSerializer<UK> keySerializer,
TypeSerializer<UV> valueSerializer)
Serializes all values of the Iterable with the given serializer.
|
static <UK,UV> byte[] |
KvStateSerializer.serializeMap(Iterable<Map.Entry<UK,UV>> entries,
TypeSerializer<UK> keySerializer,
TypeSerializer<UV> valueSerializer)
Serializes all values of the Iterable with the given serializer.
|
static <T> byte[] |
KvStateSerializer.serializeValue(T value,
TypeSerializer<T> serializer)
Serializes the value with the given serializer.
|
Constructor and Description |
---|
ChannelReaderInputViewIterator(BlockChannelReader<MemorySegment> reader,
LinkedBlockingQueue<MemorySegment> returnQueue,
List<MemorySegment> segments,
List<MemorySegment> freeMemTarget,
TypeSerializer<E> accessors,
int numBlocks) |
ChannelReaderInputViewIterator(ChannelReaderInputView inView,
List<MemorySegment> freeMemTarget,
TypeSerializer<E> accessors) |
ChannelReaderInputViewIterator(IOManager ioAccess,
FileIOChannel.ID channel,
LinkedBlockingQueue<MemorySegment> returnQueue,
List<MemorySegment> segments,
List<MemorySegment> freeMemTarget,
TypeSerializer<E> accessors,
int numBlocks) |
ChannelReaderInputViewIterator(IOManager ioAccess,
FileIOChannel.ID channel,
List<MemorySegment> segments,
List<MemorySegment> freeMemTarget,
TypeSerializer<E> accessors,
int numBlocks) |
InputViewIterator(DataInputView inputView,
TypeSerializer<E> serializer) |
Constructor and Description |
---|
HashPartitionIterator(Iterator<HashPartition<BT,PT>> partitions,
TypeSerializer<BT> serializer) |
WorksetUpdateOutputCollector(DataOutputView outputView,
TypeSerializer<T> serializer) |
WorksetUpdateOutputCollector(DataOutputView outputView,
TypeSerializer<T> serializer,
Collector<T> delegate) |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<BT> |
MutableHashTable.buildSideSerializer
The utilities to serialize the build side data types.
|
protected TypeSerializer<T> |
AbstractMutableHashTable.buildSideSerializer
The utilities to serialize the build side data types.
|
protected TypeSerializer<V2> |
NonReusingBuildFirstHashJoinIterator.probeSideSerializer |
protected TypeSerializer<V1> |
ReusingBuildSecondHashJoinIterator.probeSideSerializer |
protected TypeSerializer<V2> |
ReusingBuildFirstHashJoinIterator.probeSideSerializer |
protected TypeSerializer<V1> |
NonReusingBuildSecondHashJoinIterator.probeSideSerializer |
protected TypeSerializer<PT> |
MutableHashTable.probeSideSerializer
The utilities to serialize the probe side data types.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
AbstractMutableHashTable.getBuildSideSerializer() |
Modifier and Type | Method and Description |
---|---|
<BT,PT> MutableHashTable<BT,PT> |
NonReusingBuildSecondReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
NonReusingBuildSecondReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
HashJoinIteratorBase.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBloomFilters) |
<BT,PT> MutableHashTable<BT,PT> |
HashJoinIteratorBase.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBloomFilters) |
<BT,PT> MutableHashTable<BT,PT> |
NonReusingBuildFirstReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
NonReusingBuildFirstReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
ReusingBuildSecondReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
ReusingBuildSecondReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
ReusingBuildFirstReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
ReusingBuildFirstReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
Constructor and Description |
---|
AbstractMutableHashTable(TypeSerializer<T> buildSideSerializer,
TypeComparator<T> buildSideComparator) |
CompactingHashTable(TypeSerializer<T> buildSideSerializer,
TypeComparator<T> buildSideComparator,
List<MemorySegment> memorySegments) |
CompactingHashTable(TypeSerializer<T> buildSideSerializer,
TypeComparator<T> buildSideComparator,
List<MemorySegment> memorySegments,
int avgRecordLen) |
InMemoryPartition(TypeSerializer<T> serializer,
int partitionNumber,
ListMemorySegmentSource memSource,
int pageSize,
int pageSizeInBits)
Creates a new partition, in memory, with one buffer.
|
InPlaceMutableHashTable(TypeSerializer<T> serializer,
TypeComparator<T> comparator,
List<MemorySegment> memory) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
boolean useBloomFilters) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
boolean useBloomFilters) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
int avgRecordLen,
boolean useBloomFilters) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
int avgRecordLen,
boolean useBloomFilters) |
NonReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReOpenableMutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
boolean useBitmapFilters) |
ReOpenableMutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
boolean useBitmapFilters) |
ReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<T> |
SpillingResettableMutableObjectIterator.serializer |
protected TypeSerializer<T> |
SpillingResettableIterator.serializer |
Constructor and Description |
---|
OutputCollector(List<RecordWriter<SerializationDelegate<T>>> writers,
TypeSerializer<T> serializer)
Initializes the output collector with a set of writers.
|
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<E> |
UnilateralSortMerger.SpillingThread.serializer |
protected TypeSerializer<T1> |
AbstractMergeIterator.serializer1 |
protected TypeSerializer<T2> |
AbstractMergeIterator.serializer2 |
Modifier and Type | Method and Description |
---|---|
protected <T> T |
NonReusingMergeInnerJoinIterator.createCopy(TypeSerializer<T> serializer,
T value,
T reuse) |
protected abstract <T> T |
AbstractMergeIterator.createCopy(TypeSerializer<T> serializer,
T value,
T reuse)
Copies an instance of the given type, potentially reusing the object passed as the reuse parameter, which may be null.
|
protected <T> T |
NonReusingMergeOuterJoinIterator.createCopy(TypeSerializer<T> serializer,
T value,
T reuse) |
protected <T> T |
ReusingMergeInnerJoinIterator.createCopy(TypeSerializer<T> serializer,
T value,
T reuse) |
protected <T> T |
ReusingMergeOuterJoinIterator.createCopy(TypeSerializer<T> serializer,
T value,
T reuse) |
protected <T> KeyGroupedIterator<T> |
NonReusingMergeInnerJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
protected abstract <T> KeyGroupedIterator<T> |
AbstractMergeIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
protected <T> KeyGroupedIterator<T> |
NonReusingMergeOuterJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
protected <T> KeyGroupedIterator<T> |
ReusingMergeInnerJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
protected <T> KeyGroupedIterator<T> |
ReusingMergeOuterJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
protected UnilateralSortMerger.ThreadBase<E> |
UnilateralSortMerger.getReadingThread(ExceptionHandler<IOException> exceptionHandler,
MutableObjectIterator<E> reader,
UnilateralSortMerger.CircularQueues<E> queues,
LargeRecordHandler<E> largeRecordHandler,
AbstractInvokable parentTask,
TypeSerializer<E> serializer,
long startSpillingBytes)
Creates the reading thread.
|
Constructor and Description |
---|
ReaderIterator(MutableReader<DeserializationDelegate<T>> reader,
TypeSerializer<T> serializer)
Creates a new iterator, wrapping the given reader.
|
Constructor and Description |
---|
NonReusingDeserializationDelegate(TypeSerializer<T> serializer) |
ReusingDeserializationDelegate(TypeSerializer<T> serializer) |
SerializationDelegate(TypeSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
KvStateInfo.getKeySerializer() |
TypeSerializer<N> |
KvStateInfo.getNamespaceSerializer() |
TypeSerializer<V> |
KvStateInfo.getStateValueSerializer() |
Constructor and Description |
---|
KvStateInfo(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> stateValueSerializer) |
KvStateInfo(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> stateValueSerializer) |
KvStateInfo(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<V> stateValueSerializer) |
Modifier and Type | Class and Description |
---|---|
class |
ArrayListSerializer<T> |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<K> |
AbstractKeyedStateBackend.keySerializer
TypeSerializer for our key. |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<VoidNamespace> |
VoidNamespaceTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<ArrayList<T>> |
ArrayListSerializer.duplicate() |
TypeSerializer<T> |
ArrayListSerializer.getElementSerializer() |
TypeSerializer<K> |
KeyedBackendSerializationProxy.getKeySerializer() |
TypeSerializer<K> |
AbstractKeyedStateBackend.getKeySerializer() |
TypeSerializer<K> |
RegisteredBroadcastBackendStateMetaInfo.getKeySerializer() |
TypeSerializer<K> |
RegisteredBroadcastBackendStateMetaInfo.Snapshot.getKeySerializer() |
TypeSerializer<N> |
RegisteredKeyedBackendStateMetaInfo.getNamespaceSerializer() |
TypeSerializer<N> |
RegisteredKeyedBackendStateMetaInfo.Snapshot.getNamespaceSerializer() |
TypeSerializer<S> |
RegisteredOperatorBackendStateMetaInfo.getPartitionStateSerializer() |
TypeSerializer<S> |
RegisteredOperatorBackendStateMetaInfo.Snapshot.getPartitionStateSerializer() |
TypeSerializer<S> |
RegisteredKeyedBackendStateMetaInfo.getStateSerializer() |
TypeSerializer<S> |
RegisteredKeyedBackendStateMetaInfo.Snapshot.getStateSerializer() |
TypeSerializer<V> |
RegisteredBroadcastBackendStateMetaInfo.getValueSerializer() |
TypeSerializer<V> |
RegisteredBroadcastBackendStateMetaInfo.Snapshot.getValueSerializer() |
Modifier and Type | Method and Description |
---|---|
<N,S extends State,T> |
KeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function)
Applies the provided
KeyedStateFunction to the state with the provided
StateDescriptor of all the currently active keys. |
<N,S extends State,T> |
AbstractKeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function) |
protected abstract <N,T,ACC,R> |
AbstractKeyedStateBackend.createAggregatingState(TypeSerializer<N> namespaceSerializer,
AggregatingStateDescriptor<T,ACC,R> stateDesc)
Creates and returns a new
AggregatingState . |
protected abstract <N,T,ACC> InternalFoldingState<K,N,T,ACC> |
AbstractKeyedStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc)
Deprecated.
will be removed in a future version
|
<K> AbstractKeyedStateBackend<K> |
StateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry)
Creates a new
AbstractKeyedStateBackend that is responsible for holding keyed state
and checkpointing it. |
abstract <K> AbstractKeyedStateBackend<K> |
AbstractStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry) |
protected abstract <N,T> InternalListState<K,N,T> |
AbstractKeyedStateBackend.createListState(TypeSerializer<N> namespaceSerializer,
ListStateDescriptor<T> stateDesc)
Creates and returns a new
ListState . |
protected abstract <N,UK,UV> InternalMapState<K,N,UK,UV> |
AbstractKeyedStateBackend.createMapState(TypeSerializer<N> namespaceSerializer,
MapStateDescriptor<UK,UV> stateDesc)
Creates and returns a new
MapState . |
protected abstract <N,T> InternalReducingState<K,N,T> |
AbstractKeyedStateBackend.createReducingState(TypeSerializer<N> namespaceSerializer,
ReducingStateDescriptor<T> stateDesc)
Creates and returns a new
ReducingState . |
protected abstract <N,T> InternalValueState<K,N,T> |
AbstractKeyedStateBackend.createValueState(TypeSerializer<N> namespaceSerializer,
ValueStateDescriptor<T> stateDesc)
Creates and returns a new
ValueState . |
<N,S extends State,T> |
KeyedStateBackend.getOrCreateKeyedState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor)
Creates or retrieves a keyed state backed by this state backend.
|
<N,S extends State,V> |
AbstractKeyedStateBackend.getOrCreateKeyedState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,V> stateDescriptor) |
<N,S extends State> |
KeyedStateBackend.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor)
Creates or retrieves a partitioned state backed by this state backend.
|
<N,S extends State> |
AbstractKeyedStateBackend.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor)
TODO: NOTE: This method does a lot of work caching / retrieving states just to update the namespace.
|
static <N,S> RegisteredKeyedBackendStateMetaInfo<N,S> |
RegisteredKeyedBackendStateMetaInfo.resolveKvStateCompatibility(RegisteredKeyedBackendStateMetaInfo.Snapshot<N,S> restoredStateMetaInfoSnapshot,
TypeSerializer<N> newNamespaceSerializer,
StateDescriptor<?,S> newStateDescriptor)
Checks compatibility of a restored k/v state, with the new
StateDescriptor provided to it. |
Modifier and Type | Method and Description |
---|---|
<K> AbstractKeyedStateBackend<K> |
FsStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry) |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<K> |
AbstractHeapState.keySerializer |
protected TypeSerializer<N> |
AbstractHeapState.namespaceSerializer |
protected TypeSerializer<SV> |
AbstractHeapState.valueSerializer |
Modifier and Type | Method and Description |
---|---|
<N,S extends State,T> |
HeapKeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function) |
<N,T,ACC,R> |
HeapKeyedStateBackend.createAggregatingState(TypeSerializer<N> namespaceSerializer,
AggregatingStateDescriptor<T,ACC,R> stateDesc) |
<N,T,ACC> InternalFoldingState<K,N,T,ACC> |
HeapKeyedStateBackend.createFoldingState(TypeSerializer<N> namespaceSerializer,
FoldingStateDescriptor<T,ACC> stateDesc) |
<N,T> InternalListState<K,N,T> |
HeapKeyedStateBackend.createListState(TypeSerializer<N> namespaceSerializer,
ListStateDescriptor<T> stateDesc) |
protected <N,UK,UV> InternalMapState<K,N,UK,UV> |
HeapKeyedStateBackend.createMapState(TypeSerializer<N> namespaceSerializer,
MapStateDescriptor<UK,UV> stateDesc) |
<N,T> InternalReducingState<K,N,T> |
HeapKeyedStateBackend.createReducingState(TypeSerializer<N> namespaceSerializer,
ReducingStateDescriptor<T> stateDesc) |
<N,V> InternalValueState<K,N,V> |
HeapKeyedStateBackend.createValueState(TypeSerializer<N> namespaceSerializer,
ValueStateDescriptor<V> stateDesc) |
byte[] |
HeapListState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<List<V>> safeValueSerializer) |
byte[] |
HeapListState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<List<V>> safeValueSerializer) |
byte[] |
HeapListState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<List<V>> safeValueSerializer) |
byte[] |
HeapMapState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<Map<UK,UV>> safeValueSerializer) |
byte[] |
HeapMapState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<Map<UK,UV>> safeValueSerializer) |
byte[] |
HeapMapState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<Map<UK,UV>> safeValueSerializer) |
byte[] |
AbstractHeapState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<SV> safeValueSerializer) |
byte[] |
AbstractHeapState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<SV> safeValueSerializer) |
byte[] |
AbstractHeapState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<SV> safeValueSerializer) |
Constructor and Description |
---|
AbstractHeapMergingState(StateTable<K,N,SV> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<SV> valueSerializer,
TypeSerializer<N> namespaceSerializer,
SV defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
AbstractHeapMergingState(StateTable<K,N,SV> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<SV> valueSerializer,
TypeSerializer<N> namespaceSerializer,
SV defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
AbstractHeapMergingState(StateTable<K,N,SV> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<SV> valueSerializer,
TypeSerializer<N> namespaceSerializer,
SV defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
AbstractHeapState(StateTable<K,N,SV> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<SV> valueSerializer,
TypeSerializer<N> namespaceSerializer,
SV defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
AbstractHeapState(StateTable<K,N,SV> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<SV> valueSerializer,
TypeSerializer<N> namespaceSerializer,
SV defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
AbstractHeapState(StateTable<K,N,SV> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<SV> valueSerializer,
TypeSerializer<N> namespaceSerializer,
SV defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapAggregatingState(StateTable<K,N,ACC> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<ACC> valueSerializer,
TypeSerializer<N> namespaceSerializer,
ACC defaultValue,
AggregateFunction<IN,ACC,OUT> aggregateFunction)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapAggregatingState(StateTable<K,N,ACC> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<ACC> valueSerializer,
TypeSerializer<N> namespaceSerializer,
ACC defaultValue,
AggregateFunction<IN,ACC,OUT> aggregateFunction)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapAggregatingState(StateTable<K,N,ACC> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<ACC> valueSerializer,
TypeSerializer<N> namespaceSerializer,
ACC defaultValue,
AggregateFunction<IN,ACC,OUT> aggregateFunction)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapFoldingState(StateTable<K,N,ACC> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<ACC> valueSerializer,
TypeSerializer<N> namespaceSerializer,
ACC defaultValue,
FoldFunction<T,ACC> foldFunction)
Deprecated.
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapFoldingState(StateTable<K,N,ACC> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<ACC> valueSerializer,
TypeSerializer<N> namespaceSerializer,
ACC defaultValue,
FoldFunction<T,ACC> foldFunction)
Deprecated.
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapFoldingState(StateTable<K,N,ACC> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<ACC> valueSerializer,
TypeSerializer<N> namespaceSerializer,
ACC defaultValue,
FoldFunction<T,ACC> foldFunction)
Deprecated.
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapKeyedStateBackend(TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
ClassLoader userCodeClassLoader,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
boolean asynchronousSnapshots,
ExecutionConfig executionConfig,
LocalRecoveryConfig localRecoveryConfig) |
HeapListState(StateTable<K,N,List<V>> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<List<V>> valueSerializer,
TypeSerializer<N> namespaceSerializer,
List<V> defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapListState(StateTable<K,N,List<V>> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<List<V>> valueSerializer,
TypeSerializer<N> namespaceSerializer,
List<V> defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapListState(StateTable<K,N,List<V>> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<List<V>> valueSerializer,
TypeSerializer<N> namespaceSerializer,
List<V> defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapMapState(StateTable<K,N,Map<UK,UV>> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<Map<UK,UV>> valueSerializer,
TypeSerializer<N> namespaceSerializer,
Map<UK,UV> defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapMapState(StateTable<K,N,Map<UK,UV>> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<Map<UK,UV>> valueSerializer,
TypeSerializer<N> namespaceSerializer,
Map<UK,UV> defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapMapState(StateTable<K,N,Map<UK,UV>> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<Map<UK,UV>> valueSerializer,
TypeSerializer<N> namespaceSerializer,
Map<UK,UV> defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapReducingState(StateTable<K,N,V> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<N> namespaceSerializer,
V defaultValue,
ReduceFunction<V> reduceFunction)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapReducingState(StateTable<K,N,V> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<N> namespaceSerializer,
V defaultValue,
ReduceFunction<V> reduceFunction)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapReducingState(StateTable<K,N,V> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<N> namespaceSerializer,
V defaultValue,
ReduceFunction<V> reduceFunction)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapValueState(StateTable<K,N,V> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<N> namespaceSerializer,
V defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapValueState(StateTable<K,N,V> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<N> namespaceSerializer,
V defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
HeapValueState(StateTable<K,N,V> stateTable,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer,
TypeSerializer<N> namespaceSerializer,
V defaultValue)
Creates a new key/value state for the given hash map of key/value pairs.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
InternalKvState.getKeySerializer()
Returns the
TypeSerializer for the type of key this state is associated to. |
TypeSerializer<N> |
InternalKvState.getNamespaceSerializer()
Returns the
TypeSerializer for the type of namespace this state is associated to. |
TypeSerializer<V> |
InternalKvState.getValueSerializer()
Returns the
TypeSerializer for the type of value this state holds. |
Modifier and Type | Method and Description |
---|---|
byte[] |
InternalKvState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<V> safeValueSerializer)
Returns the serialized value for the given key and namespace.
|
byte[] |
InternalKvState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<V> safeValueSerializer)
Returns the serialized value for the given key and namespace.
|
byte[] |
InternalKvState.getSerializedValue(byte[] serializedKeyAndNamespace,
TypeSerializer<K> safeKeySerializer,
TypeSerializer<N> safeNamespaceSerializer,
TypeSerializer<V> safeValueSerializer)
Returns the serialized value for the given key and namespace.
|
Modifier and Type | Method and Description |
---|---|
<K> AbstractKeyedStateBackend<K> |
MemoryStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry) |
Constructor and Description |
---|
NonReusingMutableToRegularIteratorWrapper(MutableObjectIterator<T> source,
TypeSerializer<T> serializer) |
RegularToMutableObjectIterator(Iterator<T> iterator,
TypeSerializer<T> serializer) |
ReusingKeyGroupedIterator(MutableObjectIterator<E> iterator,
TypeSerializer<E> serializer,
TypeComparator<E> comparator)
Initializes the KeyGroupedIterator.
|
ReusingMutableToRegularIteratorWrapper(MutableObjectIterator<T> source,
TypeSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
QueryableStateStream.getKeySerializer()
Returns the key serializer for the queryable state instance.
|
Constructor and Description |
---|
QueryableStateStream(String queryableStateName,
StateDescriptor<?,V> stateDescriptor,
TypeSerializer<K> keySerializer)
Creates a queryable state stream.
|
UnionSerializerConfigSnapshot(TypeSerializer<T1> oneSerializer,
TypeSerializer<T2> twoSerializer) |
UnionSerializerConfigSnapshot(TypeSerializer<T1> oneSerializer,
TypeSerializer<T2> twoSerializer) |
Modifier and Type | Class and Description |
---|---|
static class |
TwoPhaseCommitSinkFunction.StateSerializer<TXN,CONTEXT>
Custom
TypeSerializer for the sink state. |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> |
TwoPhaseCommitSinkFunction.StateSerializer.duplicate() |
Constructor and Description |
---|
StateSerializer(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer) |
StateSerializer(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer) |
StateSerializerConfigSnapshot(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer) |
StateSerializerConfigSnapshot(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer) |
TwoPhaseCommitSinkFunction(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer)
Use default
ListStateDescriptor for internal state serialization. |
TwoPhaseCommitSinkFunction(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer)
Use default
ListStateDescriptor for internal state serialization. |
Constructor and Description |
---|
FromElementsFunction(TypeSerializer<T> serializer,
Iterable<T> elements) |
FromElementsFunction(TypeSerializer<T> serializer,
T... elements) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<?> |
StreamNode.getStateKeySerializer() |
<K> TypeSerializer<K> |
StreamConfig.getStateKeySerializer(ClassLoader cl) |
TypeSerializer<?> |
StreamNode.getTypeSerializerIn1() |
<T> TypeSerializer<T> |
StreamConfig.getTypeSerializerIn1(ClassLoader cl) |
TypeSerializer<?> |
StreamNode.getTypeSerializerIn2() |
<T> TypeSerializer<T> |
StreamConfig.getTypeSerializerIn2(ClassLoader cl) |
TypeSerializer<?> |
StreamNode.getTypeSerializerOut() |
<T> TypeSerializer<T> |
StreamConfig.getTypeSerializerOut(ClassLoader cl) |
<T> TypeSerializer<T> |
StreamConfig.getTypeSerializerSideOut(OutputTag<?> outputTag,
ClassLoader cl) |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.setOneInputStateKey(Integer vertexID,
KeySelector<?,?> keySelector,
TypeSerializer<?> keySerializer) |
void |
StreamNode.setSerializerIn1(TypeSerializer<?> typeSerializerIn1) |
void |
StreamNode.setSerializerIn2(TypeSerializer<?> typeSerializerIn2) |
void |
StreamNode.setSerializerOut(TypeSerializer<?> typeSerializerOut) |
void |
StreamGraph.setSerializers(Integer vertexID,
TypeSerializer<?> in1,
TypeSerializer<?> in2,
TypeSerializer<?> out) |
void |
StreamGraph.setSerializers(Integer vertexID,
TypeSerializer<?> in1,
TypeSerializer<?> in2,
TypeSerializer<?> out) |
void |
StreamGraph.setSerializers(Integer vertexID,
TypeSerializer<?> in1,
TypeSerializer<?> in2,
TypeSerializer<?> out) |
void |
StreamNode.setStateKeySerializer(TypeSerializer<?> stateKeySerializer) |
void |
StreamConfig.setStateKeySerializer(TypeSerializer<?> serializer) |
void |
StreamGraph.setTwoInputStateKey(Integer vertexID,
KeySelector<?,?> keySelector1,
KeySelector<?,?> keySelector2,
TypeSerializer<?> keySerializer) |
void |
StreamConfig.setTypeSerializerIn1(TypeSerializer<?> serializer) |
void |
StreamConfig.setTypeSerializerIn2(TypeSerializer<?> serializer) |
void |
StreamConfig.setTypeSerializerOut(TypeSerializer<?> serializer) |
void |
StreamConfig.setTypeSerializerSideOut(OutputTag<?> outputTag,
TypeSerializer<?> serializer) |
Modifier and Type | Class and Description |
---|---|
static class |
InternalTimer.TimerSerializer<K,N>
A
TypeSerializer used to serialize/deserialize a InternalTimer . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<InternalTimer<K,N>> |
InternalTimer.TimerSerializer.duplicate() |
TypeSerializer<K> |
InternalTimersSnapshot.getKeySerializer() |
TypeSerializer<N> |
InternalTimersSnapshot.getNamespaceSerializer() |
Modifier and Type | Method and Description |
---|---|
InternalTimerService<N> |
InternalTimeServiceManager.getInternalTimerService(String name,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable)
Returns a
InternalTimerService that can be used to query current processing time
and event time and to set timers. |
InternalTimerService<N> |
InternalTimeServiceManager.getInternalTimerService(String name,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable)
Returns a
InternalTimerService that can be used to query current processing time
and event time and to set timers. |
<K,N> InternalTimerService<N> |
AbstractStreamOperator.getInternalTimerService(String name,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable)
Returns a
InternalTimerService that can be used to query current processing time
and event time and to set timers. |
protected <N,S extends State,T> |
AbstractStreamOperator.getOrCreateKeyedState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor) |
protected <S extends State,N> |
AbstractStreamOperator.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor)
Creates a partitioned state handle, using the state backend configured for this task.
|
protected <K> AbstractKeyedStateBackend<K> |
StreamTaskStateInitializerImpl.keyedStatedBackend(TypeSerializer<K> keySerializer,
String operatorIdentifierText,
PrioritizedOperatorSubtaskState prioritizedOperatorSubtaskStates,
CloseableRegistry backendCloseableRegistry) |
void |
InternalTimersSnapshot.setKeySerializer(TypeSerializer<K> keySerializer) |
void |
InternalTimersSnapshot.setNamespaceSerializer(TypeSerializer<N> namespaceSerializer) |
void |
HeapInternalTimerService.startTimerService(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerTarget)
Starts the local
HeapInternalTimerService by:
Setting the keySerialized and namespaceSerializer for the timers it will contain.
Setting the triggerTarget which contains the action to be performed when a timer fires.
Re-registering timers that were retrieved after recovering from a node failure, if any.
This method can be called multiple times, as long as it is called with the same serializers. |
void |
HeapInternalTimerService.startTimerService(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerTarget)
Starts the local
HeapInternalTimerService by:
Setting the keySerialized and namespaceSerializer for the timers it will contain.
Setting the triggerTarget which contains the action to be performed when a timer fires.
Re-registering timers that were retrieved after recovering from a node failure, if any.
This method can be called multiple times, as long as it is called with the same serializers. |
StreamOperatorStateContext |
StreamTaskStateInitializerImpl.streamOperatorStateContext(OperatorID operatorID,
String operatorClassName,
KeyContext keyContext,
TypeSerializer<?> keySerializer,
CloseableRegistry streamTaskCloseableRegistry) |
StreamOperatorStateContext |
StreamTaskStateInitializer.streamOperatorStateContext(OperatorID operatorID,
String operatorClassName,
KeyContext keyContext,
TypeSerializer<?> keySerializer,
CloseableRegistry streamTaskCloseableRegistry)
Returns the
StreamOperatorStateContext for an AbstractStreamOperator that runs in the stream
task that owns this manager. |
Constructor and Description |
---|
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializerConfigSnapshot keySerializerConfigSnapshot,
TypeSerializer<N> namespaceSerializer,
TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot,
Set<InternalTimer<K,N>> eventTimeTimers,
Set<InternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializerConfigSnapshot keySerializerConfigSnapshot,
TypeSerializer<N> namespaceSerializer,
TypeSerializerConfigSnapshot namespaceSerializerConfigSnapshot,
Set<InternalTimer<K,N>> eventTimeTimers,
Set<InternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
StreamGroupedReduce(ReduceFunction<IN> reducer,
TypeSerializer<IN> serializer) |
StreamProject(int[] fields,
TypeSerializer<OUT> outSerializer) |
Modifier and Type | Method and Description |
---|---|
static <T,W extends Window> |
DeltaTrigger.of(double threshold,
DeltaFunction<T> deltaFunction,
TypeSerializer<T> stateSerializer)
Creates a delta trigger from the given threshold and
DeltaFunction . |
Modifier and Type | Class and Description |
---|---|
static class |
GlobalWindow.Serializer
A
TypeSerializer for GlobalWindow . |
static class |
TimeWindow.Serializer
The serializer used to write the TimeWindow type.
|
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<IN> |
CassandraSink.CassandraSinkBuilder.serializer |
Constructor and Description |
---|
CassandraPojoSinkBuilder(DataStream<IN> input,
TypeInformation<IN> typeInfo,
TypeSerializer<IN> serializer) |
CassandraRowSinkBuilder(DataStream<Row> input,
TypeInformation<Row> typeInfo,
TypeSerializer<Row> serializer) |
CassandraRowWriteAheadSink(String insertQuery,
TypeSerializer<Row> serializer,
ClusterBuilder builder,
CheckpointCommitter committer) |
CassandraScalaProductSinkBuilder(DataStream<IN> input,
TypeInformation<IN> typeInfo,
TypeSerializer<IN> serializer) |
CassandraSinkBuilder(DataStream<IN> input,
TypeInformation<IN> typeInfo,
TypeSerializer<IN> serializer) |
CassandraTupleSinkBuilder(DataStream<IN> input,
TypeInformation<IN> typeInfo,
TypeSerializer<IN> serializer) |
CassandraTupleWriteAheadSink(String insertQuery,
TypeSerializer<IN> serializer,
ClusterBuilder builder,
CheckpointCommitter committer) |
Modifier and Type | Class and Description |
---|---|
static class |
FlinkKafkaProducer011.ContextStateSerializer
|
static class |
FlinkKafkaProducer011.TransactionStateSerializer
TypeSerializer for
KafkaTransactionState . |
Constructor and Description |
---|
CollectSink(InetAddress hostIp,
int port,
TypeSerializer<IN> serializer)
Creates a CollectSink that will send the data to the specified host.
|
SocketStreamIterator(int port,
InetAddress address,
TypeSerializer<T> serializer)
Creates an iterator that returns the data from a socket stream with custom port and bind address.
|
SocketStreamIterator(TypeSerializer<T> serializer)
Creates an iterator that returns the data from a socket stream with automatic port and bind address.
|
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<IN> |
GenericWriteAheadSink.serializer |
Constructor and Description |
---|
GenericWriteAheadSink(CheckpointCommitter committer,
TypeSerializer<IN> serializer,
String jobID) |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<K> |
WindowOperator.keySerializer
For serializing the key in checkpoints.
|
protected TypeSerializer<W> |
WindowOperator.windowSerializer
For serializing the window in checkpoints.
|
Constructor and Description |
---|
EvictingWindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
KeySelector<IN,K> keySelector,
TypeSerializer<K> keySerializer,
StateDescriptor<? extends ListState<StreamRecord<IN>>,?> windowStateDescriptor,
InternalWindowFunction<Iterable<IN>,OUT,K,W> windowFunction,
Trigger<? super IN,? super W> trigger,
Evictor<? super IN,? super W> evictor,
long allowedLateness,
OutputTag<IN> lateDataOutputTag) |
EvictingWindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
KeySelector<IN,K> keySelector,
TypeSerializer<K> keySerializer,
StateDescriptor<? extends ListState<StreamRecord<IN>>,?> windowStateDescriptor,
InternalWindowFunction<Iterable<IN>,OUT,K,W> windowFunction,
Trigger<? super IN,? super W> trigger,
Evictor<? super IN,? super W> evictor,
long allowedLateness,
OutputTag<IN> lateDataOutputTag) |
WindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
KeySelector<IN,K> keySelector,
TypeSerializer<K> keySerializer,
StateDescriptor<? extends AppendingState<IN,ACC>,?> windowStateDescriptor,
InternalWindowFunction<ACC,OUT,K,W> windowFunction,
Trigger<? super IN,? super W> trigger,
long allowedLateness,
OutputTag<IN> lateDataOutputTag)
Creates a new
WindowOperator based on the given policies and user functions. |
WindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
KeySelector<IN,K> keySelector,
TypeSerializer<K> keySerializer,
StateDescriptor<? extends AppendingState<IN,ACC>,?> windowStateDescriptor,
InternalWindowFunction<ACC,OUT,K,W> windowFunction,
Trigger<? super IN,? super W> trigger,
long allowedLateness,
OutputTag<IN> lateDataOutputTag)
Creates a new
WindowOperator based on the given policies and user functions. |
Modifier and Type | Class and Description |
---|---|
class |
StreamElementSerializer<T>
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
StreamElementSerializer.getContainedTypeSerializer() |
Constructor and Description |
---|
StreamElementSerializer(TypeSerializer<T> serializer) |
StreamElementSerializerConfigSnapshot(TypeSerializer<T> typeSerializer) |
Constructor and Description |
---|
ArtificialListStateBuilder(String stateName,
JoinFunction<IN,Iterable<STATE>,List<STATE>> keyedStateGenerator,
JoinFunction<IN,Iterable<STATE>,List<STATE>> operatorStateGenerator,
TypeSerializer<STATE> typeSerializer) |
ArtificialMapStateBuilder(String stateName,
JoinFunction<IN,Iterator<Map.Entry<K,V>>,Iterator<Map.Entry<K,V>>> stateValueGenerator,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer) |
ArtificialMapStateBuilder(String stateName,
JoinFunction<IN,Iterator<Map.Entry<K,V>>,Iterator<Map.Entry<K,V>>> stateValueGenerator,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer) |
ArtificialValueStateBuilder(String stateName,
JoinFunction<IN,STATE,STATE> stateValueGenerator,
TypeSerializer<STATE> typeSerializer) |
Constructor and Description |
---|
CollectStreamTableSink(InetAddress targetAddress,
int targetPort,
TypeSerializer<Tuple2<Boolean,Row>> serializer) |
Modifier and Type | Method and Description |
---|---|
static <L,R> Either.Left<L,R> |
Either.obtainLeft(Either<L,R> input,
TypeSerializer<L> leftSerializer)
Utility function for
EitherSerializer to support object reuse. |
static <L,R> Either.Right<L,R> |
Either.obtainRight(Either<L,R> input,
TypeSerializer<R> rightSerializer)
Utility function for
EitherSerializer to support object reuse. |
Modifier and Type | Method and Description |
---|---|
static <T> T |
InstantiationUtil.deserializeFromByteArray(TypeSerializer<T> serializer,
byte[] buf) |
static <T> T |
InstantiationUtil.deserializeFromByteArray(TypeSerializer<T> serializer,
T reuse,
byte[] buf) |
static <T> byte[] |
InstantiationUtil.serializeToByteArray(TypeSerializer<T> serializer,
T record) |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.