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 | 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. |
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(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> |
SqlTimeTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<Nothing> |
NothingTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
BasicTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
PrimitiveArrayTypeInfo.createSerializer(ExecutionConfig executionConfig) |
abstract TypeSerializer<T> |
TypeInformation.createSerializer(ExecutionConfig config)
Creates a serializer for the type.
|
TypeSerializer<T> |
LocalTimeTypeInfo.createSerializer(ExecutionConfig executionConfig) |
TypeSerializer<T> |
BasicArrayTypeInfo.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) |
LocalTimeTypeInfo(Class<T> clazz,
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 |
CompositeTypeSerializerSnapshot<T,S extends TypeSerializer<T>>
A
CompositeTypeSerializerSnapshot is a convenient serializer snapshot class that can be
used by simple serializers which 1) delegates its serialization to multiple nested serializers,
and 2) may contain some extra static information that needs to be persisted as part of its
snapshot. |
class |
GenericTypeSerializerSnapshot<T,S extends TypeSerializer>
Base
TypeSerializerSnapshot for serializers for generic types. |
Modifier and Type | Class and Description |
---|---|
class |
CompositeSerializer<T>
Base class for composite serializers.
|
class |
SingleThreadAccessCheckingTypeSerializer<T> |
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 | Field and Description |
---|---|
protected TypeSerializer<Object>[] |
CompositeSerializer.fieldSerializers
Serializers for fields which constitute T.
|
Modifier and Type | Method and Description |
---|---|
protected abstract TypeSerializer<T> |
GenericTypeSerializerSnapshot.createSerializer(Class<T> typeClass)
Create a serializer that is able to serialize the generic type
typeClass . |
abstract TypeSerializer<T> |
TypeSerializer.duplicate()
Creates a deep copy of this serializer if it is necessary, i.e.
|
TypeSerializer<T> |
UnloadableDummyTypeSerializer.duplicate() |
TypeSerializer<T> |
SingleThreadAccessCheckingTypeSerializer.duplicate() |
TypeSerializer<?>[] |
CompositeTypeSerializerUtil.IntermediateCompatibilityResult.getNestedSerializers() |
protected abstract TypeSerializer<?>[] |
CompositeTypeSerializerSnapshot.getNestedSerializers(S outerSerializer)
Gets the nested serializers from the outer serializer.
|
protected TypeSerializer<?>[] |
SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessCheckingTypeSerializerSnapshot.getNestedSerializers(SingleThreadAccessCheckingTypeSerializer<T> outerSerializer) |
TypeSerializer<T> |
TypeSerializerSchemaCompatibility.getReconfiguredSerializer()
Gets the reconfigured serializer.
|
<T> TypeSerializer<T> |
NestedSerializersSnapshotDelegate.getRestoredNestedSerializer(int pos)
Creates the restore serializer from the pos-th config snapshot.
|
TypeSerializer<?>[] |
NestedSerializersSnapshotDelegate.getRestoredNestedSerializers()
Produces a restore serializer from each contained serializer configuration snapshot.
|
TypeSerializer<T> |
TypeSerializerFactory.getSerializer() |
TypeSerializer<T> |
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy.getTypeSerializer() |
TypeSerializer<T> |
TypeSerializerConfigSnapshot.restoreSerializer()
Deprecated.
Creates a serializer using this configuration, that is capable of reading data written by the
serializer described by this configuration.
|
TypeSerializer<T> |
TypeSerializerSnapshot.restoreSerializer()
Recreates a serializer instance from this snapshot.
|
TypeSerializer<T> |
CompositeTypeSerializerSnapshot.restoreSerializer() |
TypeSerializer<T> |
SimpleTypeSerializerSnapshot.restoreSerializer() |
TypeSerializer<T> |
GenericTypeSerializerSnapshot.restoreSerializer() |
TypeSerializer<T> |
BackwardsCompatibleSerializerSnapshot.restoreSerializer() |
static <T> TypeSerializer<T> |
TypeSerializerSerializationUtil.tryReadSerializer(DataInputView in,
ClassLoader userCodeClassLoader)
Deprecated.
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)
Deprecated.
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<?>,TypeSerializerSnapshot<?>>> |
CompositeTypeSerializerConfigSnapshot.getNestedSerializersAndConfigs() |
Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>> |
CompositeTypeSerializerConfigSnapshot.getSingleNestedSerializerAndConfig() |
static List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
TypeSerializerSerializationUtil.readSerializersAndConfigsWithResilience(DataInputView in,
ClassLoader userCodeClassLoader)
Deprecated.
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> TypeSerializerSchemaCompatibility<T> |
TypeSerializerSchemaCompatibility.compatibleWithReconfiguredSerializer(TypeSerializer<T> reconfiguredSerializer)
Returns a result that indicates a reconfigured version of the new serializer is compatible,
and should be used instead of the original new serializer.
|
static <T> CompositeTypeSerializerUtil.IntermediateCompatibilityResult<T> |
CompositeTypeSerializerUtil.constructIntermediateCompatibilityResult(TypeSerializer<?>[] newNestedSerializers,
TypeSerializerSnapshot<?>[] nestedSerializerSnapshots)
Constructs an
CompositeTypeSerializerUtil.IntermediateCompatibilityResult with the given array of nested
serializers and their corresponding serializer snapshots. |
protected abstract S |
CompositeTypeSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
Creates an instance of the outer serializer with a given array of its nested serializers.
|
protected SingleThreadAccessCheckingTypeSerializer<T> |
SingleThreadAccessCheckingTypeSerializer.SingleThreadAccessCheckingTypeSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected abstract CompositeSerializer<T> |
CompositeSerializer.createSerializerInstance(CompositeSerializer.PrecomputedParameters precomputed,
TypeSerializer<?>... originalSerializers)
Factory for concrete serializer.
|
static <T> TypeSerializerSchemaCompatibility<T> |
CompositeTypeSerializerUtil.delegateCompatibilityCheckToNewSnapshot(TypeSerializer<T> newSerializer,
CompositeTypeSerializerSnapshot<T,? extends TypeSerializer> newCompositeSnapshot,
TypeSerializerSnapshot<?>... legacyNestedSnapshots)
Delegates compatibility checks to a
CompositeTypeSerializerSnapshot instance. |
static <T> TypeSerializerSnapshot<T> |
TypeSerializerSnapshotSerializationUtil.readSerializerSnapshot(DataInputView in,
ClassLoader userCodeClassLoader,
TypeSerializer<T> existingPriorSerializer)
Reads from a data input view a
TypeSerializerSnapshot that was previously written
using TypeSerializerSnapshotSerializationUtil.writeSerializerSnapshot(DataOutputView,
TypeSerializerSnapshot, TypeSerializer) . |
<T> TypeSerializerSchemaCompatibility<T> |
NestedSerializersSnapshotDelegate.resolveCompatibilityWithNested(TypeSerializerSchemaCompatibility<?> outerCompatibility,
TypeSerializer<?>... newNestedSerializers)
Deprecated.
this no method will be removed in the future. Resolving compatibility for nested
serializers is now handled by
CompositeTypeSerializerSnapshot . |
TypeSerializerSchemaCompatibility<T> |
TypeSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<T> |
TypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Checks a new serializer's compatibility to read data written by the prior serializer.
|
TypeSerializerSchemaCompatibility<T> |
CompositeTypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer) |
TypeSerializerSchemaCompatibility<T> |
SimpleTypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer) |
TypeSerializerSchemaCompatibility<T> |
ParameterlessTypeSerializerConfig.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<T> |
GenericTypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer) |
TypeSerializerSchemaCompatibility<T> |
BackwardsCompatibleSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer) |
void |
TypeSerializerConfigSnapshot.setPriorSerializer(TypeSerializer<T> serializer)
Deprecated.
Set the originating serializer of this configuration snapshot.
|
static TypeSerializerSnapshot<?>[] |
TypeSerializerUtils.snapshotBackwardsCompatible(TypeSerializer<?>... originatingSerializers)
Takes snapshots of the given serializers.
|
static <T> TypeSerializerSnapshot<T> |
TypeSerializerUtils.snapshotBackwardsCompatible(TypeSerializer<T> originatingSerializer)
Takes a snapshot of the given serializer.
|
static <T> void |
TypeSerializerSerializationUtil.writeSerializer(DataOutputView out,
TypeSerializer<T> serializer)
Deprecated.
Writes a
TypeSerializer to the provided data output view. |
static <T> void |
TypeSerializerSnapshotSerializationUtil.writeSerializerSnapshot(DataOutputView out,
TypeSerializerSnapshot<T> serializerSnapshot,
TypeSerializer<T> serializer)
Writes a
TypeSerializerSnapshot to the provided data output view. |
Modifier and Type | Method and Description |
---|---|
static <T> TypeSerializerSchemaCompatibility<T> |
CompositeTypeSerializerUtil.delegateCompatibilityCheckToNewSnapshot(TypeSerializer<T> newSerializer,
CompositeTypeSerializerSnapshot<T,? extends TypeSerializer> newCompositeSnapshot,
TypeSerializerSnapshot<?>... legacyNestedSnapshots)
Delegates compatibility checks to a
CompositeTypeSerializerSnapshot instance. |
static void |
TypeSerializerSerializationUtil.writeSerializersAndConfigsWithResilience(DataOutputView out,
List<Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> serializersAndConfigs)
Deprecated.
Write a list of serializers and their corresponding config snapshots to the provided data
output view.
|
Constructor and Description |
---|
BackwardsCompatibleSerializerSnapshot(TypeSerializer<T> serializerInstance) |
CompositeSerializer(boolean immutableTargetType,
TypeSerializer<?>... fieldSerializers)
Can be used for user facing constructor.
|
CompositeSerializer(CompositeSerializer.PrecomputedParameters precomputed,
TypeSerializer<?>... fieldSerializers)
Can be used in createSerializerInstance for internal operations.
|
CompositeTypeSerializerConfigSnapshot(TypeSerializer<?>... nestedSerializers) |
NestedSerializersSnapshotDelegate(TypeSerializer<?>... serializers)
Constructor to create a snapshot for writing.
|
SingleThreadAccessCheckingTypeSerializer(TypeSerializer<T> originalSerializer) |
TypeSerializerSerializationProxy(TypeSerializer<T> typeSerializer) |
Constructor and Description |
---|
CompositeTypeSerializerSnapshot(Class<? extends TypeSerializer> correspondingSerializerClass)
Constructor to be used for read instantiation.
|
SimpleTypeSerializerSnapshot(java.util.function.Supplier<? extends TypeSerializer<T>> serializerSupplier)
Constructor to create snapshot from serializer (writing the snapshot).
|
Modifier and Type | Class and Description |
---|---|
class |
BigDecSerializer
Serializer for serializing/deserializing BigDecimal values including null values.
|
class |
BigIntSerializer
Serializer for serializing/deserializing BigInteger values including null values.
|
class |
BooleanSerializer
Type serializer for
Boolean . |
class |
BooleanValueSerializer |
class |
ByteSerializer
Type serializer for
Byte . |
class |
ByteValueSerializer |
class |
CharSerializer
Type serializer for
Character . |
class |
CharValueSerializer |
class |
DateSerializer |
class |
DoubleSerializer
Type serializer for
Double . |
class |
DoubleValueSerializer |
class |
EnumSerializer<T extends Enum<T>>
TypeSerializer for Java enums. |
class |
FloatSerializer
Type serializer for
Float . |
class |
FloatValueSerializer |
class |
GenericArraySerializer<C>
A serializer for arrays of objects.
|
class |
InstantSerializer
Serializer for serializing/deserializing Instant values including null values.
|
class |
IntSerializer
Type serializer for
Integer (and int , via auto-boxing). |
class |
IntValueSerializer |
class |
ListSerializer<T>
A serializer for
Lists . |
class |
LocalDateSerializer |
class |
LocalDateTimeSerializer |
class |
LocalTimeSerializer |
class |
LongSerializer
Type serializer for
Long . |
class |
LongValueSerializer |
class |
MapSerializer<K,V>
A serializer for
Map . |
class |
NullValueSerializer |
class |
ShortSerializer
Type serializer for
Byte . |
class |
ShortValueSerializer |
class |
SqlDateSerializer |
class |
SqlTimeSerializer |
class |
SqlTimestampSerializer |
class |
StringSerializer
Type serializer for
String . |
class |
StringValueSerializer |
class |
TypeSerializerSingleton<T> |
class |
VoidSerializer
Serializer for
Void . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<Map<K,V>> |
MapSerializer.duplicate() |
TypeSerializer<List<T>> |
ListSerializer.duplicate() |
TypeSerializer<C> |
GenericArraySerializer.getComponentSerializer() |
TypeSerializer<T> |
ListSerializer.getElementSerializer()
Gets the serializer for the elements of the list.
|
TypeSerializer<K> |
MapSerializer.getKeySerializer() |
protected TypeSerializer<?>[] |
GenericArraySerializerSnapshot.getNestedSerializers(GenericArraySerializer<C> outerSerializer) |
protected TypeSerializer<?>[] |
ListSerializerSnapshot.getNestedSerializers(ListSerializer<T> outerSerializer) |
protected TypeSerializer<?>[] |
MapSerializerSnapshot.getNestedSerializers(MapSerializer<K,V> outerSerializer) |
TypeSerializer<V> |
MapSerializer.getValueSerializer() |
TypeSerializer<T> |
EnumSerializer.EnumSerializerSnapshot.restoreSerializer() |
Constructor and Description |
---|
CollectionSerializerConfigSnapshot(TypeSerializer<T> elementSerializer)
Deprecated.
|
GenericArraySerializer(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)
Deprecated.
|
MapSerializerConfigSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Deprecated.
|
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 |
CopyableValueSerializer<T extends CopyableValue<T>> |
class |
EitherSerializer<L,R>
A
TypeSerializer for the Either type of the Java class. |
class |
NullableSerializer<T>
Serializer wrapper to add support of
null value serialization. |
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 |
---|---|
protected TypeSerializer<T> |
WritableSerializer.WritableSerializerSnapshot.createSerializer(Class<T> typeClass) |
protected TypeSerializer<T> |
CopyableValueSerializer.CopyableValueSerializerSnapshot.createSerializer(Class<T> typeClass) |
protected TypeSerializer<T> |
ValueSerializer.ValueSerializerSnapshot.createSerializer(Class<T> typeClass) |
TypeSerializer<T> |
NullableSerializer.duplicate() |
TypeSerializer<Row> |
RowSerializer.duplicate() |
TypeSerializer<Either<L,R>> |
EitherSerializer.duplicate() |
TypeSerializer<Object>[] |
TupleSerializerBase.getFieldSerializers() |
TypeSerializer<L> |
EitherSerializer.getLeftSerializer() |
protected TypeSerializer<?>[] |
JavaEitherSerializerSnapshot.getNestedSerializers(EitherSerializer<L,R> outerSerializer) |
protected TypeSerializer<?>[] |
NullableSerializer.NullableSerializerSnapshot.getNestedSerializers(NullableSerializer<T> outerSerializer) |
protected TypeSerializer<?>[] |
RowSerializer.RowSerializerSnapshot.getNestedSerializers(RowSerializer outerSerializer) |
protected TypeSerializer<?>[] |
TupleSerializerSnapshot.getNestedSerializers(TupleSerializer<T> outerSerializer) |
TypeSerializer<R> |
EitherSerializer.getRightSerializer() |
TypeSerializer<T> |
RuntimeSerializerFactory.getSerializer() |
TypeSerializer<T> |
PojoSerializerSnapshot.restoreSerializer() |
static <T> TypeSerializer<T> |
NullableSerializer.wrap(TypeSerializer<T> originalSerializer,
boolean padNullValueIfFixedLen)
This method wraps the
originalSerializer with the NullableSerializer if not
already wrapped. |
static <T> TypeSerializer<T> |
NullableSerializer.wrapIfNullIsNotSupported(TypeSerializer<T> originalSerializer,
boolean padNullValueIfFixedLen)
This method tries to serialize
null value with the originalSerializer and
wraps it in case of NullPointerException , otherwise it returns the originalSerializer . |
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
PojoSerializer.PojoSerializerConfigSnapshot.getFieldToSerializerConfigSnapshot()
Deprecated.
|
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
PojoSerializer.PojoSerializerConfigSnapshot.getNonRegisteredSubclassesToSerializerConfigSnapshots()
Deprecated.
|
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> |
PojoSerializer.PojoSerializerConfigSnapshot.getRegisteredSubclassesToSerializerConfigSnapshots()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <T> boolean |
NullableSerializer.checkIfNullSupported(TypeSerializer<T> serializer)
This method checks if
serializer supports null value. |
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 EitherSerializer<L,R> |
JavaEitherSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected NullableSerializer<T> |
NullableSerializer.NullableSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected RowSerializer |
RowSerializer.RowSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected TupleSerializer<T> |
TupleSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
TypeSerializerSchemaCompatibility<Either<L,R>> |
EitherSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<Either<L,R>> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<Either<L,R>> |
EitherSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<Either<L,R>> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<Row> |
RowSerializer.RowSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<Row> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<T> |
WritableSerializer.WritableSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<T> |
NullableSerializer.NullableSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<T> |
PojoSerializer.PojoSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Deprecated.
This legacy snapshot delegates compatibility checks to the
PojoSerializerSnapshot . |
TypeSerializerSchemaCompatibility<T> |
CopyableValueSerializer.CopyableValueSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<T> |
PojoSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer) |
TypeSerializerSchemaCompatibility<T> |
ValueSerializer.ValueSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Deprecated.
|
static <T> TypeSerializer<T> |
NullableSerializer.wrap(TypeSerializer<T> originalSerializer,
boolean padNullValueIfFixedLen)
This method wraps the
originalSerializer with the NullableSerializer if not
already wrapped. |
static <T> TypeSerializer<T> |
NullableSerializer.wrapIfNullIsNotSupported(TypeSerializer<T> originalSerializer,
boolean padNullValueIfFixedLen)
This method tries to serialize
null value with the originalSerializer and
wraps it in case of NullPointerException , otherwise it returns the originalSerializer . |
Constructor and Description |
---|
EitherSerializer(TypeSerializer<L> leftSerializer,
TypeSerializer<R> rightSerializer) |
EitherSerializer(TypeSerializer<L> leftSerializer,
TypeSerializer<R> rightSerializer) |
EitherSerializerSnapshot(TypeSerializer<L> leftSerializer,
TypeSerializer<R> rightSerializer)
Deprecated.
Constructor to create the snapshot for writing.
|
EitherSerializerSnapshot(TypeSerializer<L> leftSerializer,
TypeSerializer<R> rightSerializer)
Deprecated.
Constructor to create the snapshot for writing.
|
GenericTypeComparator(boolean ascending,
TypeSerializer<T> serializer,
Class<T> type) |
PojoComparator(Field[] keyFields,
TypeComparator<?>[] comparators,
TypeSerializer<T> serializer,
Class<T> type) |
PojoSerializer(Class<T> clazz,
TypeSerializer<?>[] fieldSerializers,
Field[] fields,
ExecutionConfig executionConfig)
Constructor to create a new
PojoSerializer . |
RowComparator(int arity,
int[] keyPositions,
TypeComparator<Object>[] comparators,
TypeSerializer<Object>[] serializers,
boolean[] orders)
General constructor for RowComparator.
|
RowSerializer(TypeSerializer<?>[] fieldSerializers) |
RowSerializer(TypeSerializer<?>[] fieldSerializers,
LinkedHashMap<String,Integer> positionByName) |
RowSerializer(TypeSerializer<?>[] fieldSerializers,
LinkedHashMap<String,Integer> positionByName,
boolean supportsRowKind) |
RowSerializerConfigSnapshot(TypeSerializer<?>[] fieldSerializers)
Deprecated.
|
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) |
Constructor and Description |
---|
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots)
Deprecated.
|
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots)
Deprecated.
|
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots)
Deprecated.
|
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots,
boolean ignoreTypeSerializerSerialization)
Deprecated.
|
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots,
boolean ignoreTypeSerializerSerialization)
Deprecated.
|
PojoSerializerConfigSnapshot(Class<T> pojoType,
LinkedHashMap<String,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> fieldToSerializerConfigSnapshot,
LinkedHashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> registeredSubclassesToSerializerConfigSnapshots,
HashMap<Class<?>,Tuple2<TypeSerializer<?>,TypeSerializerSnapshot<?>>> nonRegisteredSubclassesToSerializerConfigSnapshots,
boolean ignoreTypeSerializerSerialization)
Deprecated.
|
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).
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
KryoSerializerSnapshot.restoreSerializer() |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<T> |
KryoSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer) |
TypeSerializerSchemaCompatibility<T> |
KryoSerializer.KryoSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected TypeSerializer<?>[] |
ScalaEitherSerializerSnapshot.getNestedSerializers(org.apache.flink.api.scala.typeutils.EitherSerializer<L,R> outerSerializer) |
protected TypeSerializer<?>[] |
ScalaOptionSerializerSnapshot.getNestedSerializers(org.apache.flink.api.scala.typeutils.OptionSerializer<E> outerSerializer) |
protected TypeSerializer<?>[] |
ScalaCaseClassSerializerSnapshot.getNestedSerializers(org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer<T> outerSerializer) |
protected TypeSerializer<?>[] |
Tuple2CaseClassSerializerSnapshot.getNestedSerializers(org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer<scala.Tuple2<T1,T2>> outerSerializer) |
protected TypeSerializer<?>[] |
TraversableSerializerSnapshot.getNestedSerializers(org.apache.flink.api.scala.typeutils.TraversableSerializer<T,E> outerSerializer) |
protected TypeSerializer<?>[] |
ScalaTrySerializerSnapshot.getNestedSerializers(org.apache.flink.api.scala.typeutils.TrySerializer<E> outerSerializer) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer<scala.Tuple2<T1,T2>> |
Tuple2CaseClassSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected org.apache.flink.api.scala.typeutils.EitherSerializer<L,R> |
ScalaEitherSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected org.apache.flink.api.scala.typeutils.ScalaCaseClassSerializer<T> |
ScalaCaseClassSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected org.apache.flink.api.scala.typeutils.TrySerializer<E> |
ScalaTrySerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected org.apache.flink.api.scala.typeutils.TraversableSerializer<T,E> |
TraversableSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected org.apache.flink.api.scala.typeutils.OptionSerializer<E> |
ScalaOptionSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
TypeSerializerSchemaCompatibility<scala.Option<E>> |
ScalaOptionSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<scala.Option<E>> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<T> |
TraversableSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<scala.util.Try<E>> |
ScalaTrySerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<scala.util.Try<E>> newSerializer)
Deprecated.
|
Constructor and Description |
---|
ScalaOptionSerializerConfigSnapshot(TypeSerializer<E> elementSerializer)
Deprecated.
|
ScalaTrySerializerConfigSnapshot(TypeSerializer<E> elementSerializer,
TypeSerializer<Throwable> throwableSerializer)
Deprecated.
|
ScalaTrySerializerConfigSnapshot(TypeSerializer<E> elementSerializer,
TypeSerializer<Throwable> throwableSerializer)
Deprecated.
|
TraversableSerializerConfigSnapshot(TypeSerializer<E> elementSerializer)
Deprecated.
|
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>
Deprecated.
|
class |
NFAStateSerializer
A
TypeSerializer for NFAState . |
static class |
SharedBuffer.SharedBufferSerializer<K,V>
Deprecated.
A
TypeSerializer for the SharedBuffer . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
SharedBuffer.SharedBufferSerializer.getKeySerializer() |
protected TypeSerializer<?>[] |
NFA.MigratedNFASerializerSnapshot.getNestedSerializers(NFA.NFASerializer<T> outerSerializer) |
protected TypeSerializer<?>[] |
NFAStateSerializerSnapshot.getNestedSerializers(NFAStateSerializer outerSerializer) |
protected TypeSerializer<?>[] |
SharedBuffer.SharedBufferSerializerSnapshot.getNestedSerializers(SharedBuffer.SharedBufferSerializer<K,V> outerSerializer) |
TypeSerializer<V> |
SharedBuffer.SharedBufferSerializer.getValueSerializer() |
TypeSerializer<DeweyNumber> |
SharedBuffer.SharedBufferSerializer.getVersionSerializer() |
Modifier and Type | Method and Description |
---|---|
protected NFA.NFASerializer<T> |
NFA.MigratedNFASerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected NFAStateSerializer |
NFAStateSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected SharedBuffer.SharedBufferSerializer<K,V> |
SharedBuffer.SharedBufferSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
TypeSerializerSchemaCompatibility<NFA.MigratedNFA<T>> |
NFA.NFASerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<NFA.MigratedNFA<T>> newSerializer)
Deprecated.
|
TypeSerializerSchemaCompatibility<SharedBuffer<V>> |
SharedBuffer.SharedBufferSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<SharedBuffer<V>> newSerializer)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
static class |
EventId.EventIdSerializer
TypeSerializer for EventId . |
static class |
Lockable.LockableTypeSerializer<E>
Serializer for
Lockable . |
static class |
NodeId.NodeIdSerializer
Serializer for
NodeId . |
static class |
SharedBufferEdge.SharedBufferEdgeSerializer
Serializer for
SharedBufferEdge . |
static class |
SharedBufferNode.SharedBufferNodeSerializer
Deprecated.
was used in <= 1.12, use
SharedBufferNodeSerializer instead. |
class |
SharedBufferNodeSerializer
Serializer for
SharedBufferNode . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<SharedBufferEdge> |
SharedBufferNodeSerializer.getEdgeSerializer() |
protected TypeSerializer<?>[] |
LockableTypeSerializerSnapshot.getNestedSerializers(Lockable.LockableTypeSerializer<E> outerSerializer) |
protected TypeSerializer<?>[] |
NodeId.NodeIdSerializer.NodeIdSerializerSnapshot.getNestedSerializers(NodeId.NodeIdSerializer outerSerializer) |
protected TypeSerializer<?>[] |
SharedBufferEdge.SharedBufferEdgeSerializer.SharedBufferEdgeSerializerSnapshot.getNestedSerializers(SharedBufferEdge.SharedBufferEdgeSerializer outerSerializer) |
protected TypeSerializer<?>[] |
SharedBufferNode.SharedBufferNodeSerializer.SharedBufferNodeSerializerSnapshot.getNestedSerializers(SharedBufferNode.SharedBufferNodeSerializer outerSerializer) |
protected TypeSerializer<?>[] |
SharedBufferNodeSerializerSnapshotV2.getNestedSerializers(SharedBufferNodeSerializer outerSerializer) |
Modifier and Type | Method and Description |
---|---|
protected Lockable.LockableTypeSerializer<E> |
LockableTypeSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected SharedBufferNode.SharedBufferNodeSerializer |
SharedBufferNode.SharedBufferNodeSerializer.SharedBufferNodeSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected NodeId.NodeIdSerializer |
NodeId.NodeIdSerializer.NodeIdSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected SharedBufferEdge.SharedBufferEdgeSerializer |
SharedBufferEdge.SharedBufferEdgeSerializer.SharedBufferEdgeSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected SharedBufferNodeSerializer |
SharedBufferNodeSerializerSnapshotV2.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
Constructor and Description |
---|
LockableTypeSerializer(TypeSerializer<E> elementSerializer) |
SharedBuffer(KeyedStateStore stateStore,
TypeSerializer<V> valueSerializer) |
SharedBuffer(KeyedStateStore stateStore,
TypeSerializer<V> valueSerializer,
SharedBufferCacheConfig cacheConfig) |
Constructor and Description |
---|
CepOperator(TypeSerializer<IN> inputSerializer,
boolean isProcessingTime,
NFACompiler.NFAFactory<IN> nfaFactory,
EventComparator<IN> comparator,
AfterMatchSkipStrategy afterMatchSkipStrategy,
PatternProcessFunction<IN,OUT> function,
OutputTag<IN> lateDataOutputTag) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<CompactorRequest> |
CompactorRequestTypeInfo.createSerializer(ExecutionConfig config) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
ContinuousPartitionFetcher.Context.getTypeSerializer()
Get the Serializer of partition order.
|
Modifier and Type | Class and Description |
---|---|
class |
CheckpointAndXidSerializer
CheckpointAndXid serializer. |
class |
XaSinkStateSerializer
XaSinkStateSerializer.
|
class |
XidSerializer
Xid serializer. |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<CheckpointAndXid> |
CheckpointAndXidSerializer.duplicate() |
TypeSerializer<Xid> |
XidSerializer.duplicate() |
TypeSerializer<org.apache.flink.connector.jdbc.xa.JdbcXaSinkFunctionState> |
XaSinkStateSerializer.duplicate() |
Modifier and Type | Class and Description |
---|---|
class |
PulsarSchemaTypeSerializer<T>
Wrap the pulsar
Schema into a flink TypeSerializer . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
PulsarSchemaTypeInformation.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
PulsarSchemaTypeSerializer.duplicate() |
TypeSerializer<T> |
PulsarSchemaTypeSerializer.PulsarSchemaTypeSerializerSnapshot.restoreSerializer() |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<T> |
PulsarSchemaTypeSerializer.PulsarSchemaTypeSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer) |
Constructor and Description |
---|
CollectIteratorBuilder(CollectSinkOperator<T> operator,
TypeSerializer<T> serializer,
String accumulatorName,
CheckpointConfig checkpointConfig) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
HiveTableSource.HiveContinuousPartitionFetcherContext.getTypeSerializer() |
Modifier and Type | Method and Description |
---|---|
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> |
RocksDBPriorityQueueSetFactory.create(String stateName,
TypeSerializer<T> byteOrderedElementSerializer) |
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> |
RocksDBKeyedStateBackend.create(String stateName,
TypeSerializer<T> byteOrderedElementSerializer) |
<N,SV,SEV,S extends State,IS extends S> |
RocksDBKeyedStateBackend.createInternalState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
StateSnapshotTransformer.StateSnapshotTransformFactory<SEV> snapshotTransformFactory) |
<K> AbstractKeyedStateBackend<K> |
EmbeddedRocksDBStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
<K> AbstractKeyedStateBackend<K> |
RocksDBStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry)
Deprecated.
|
<K> AbstractKeyedStateBackend<K> |
EmbeddedRocksDBStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry,
double managedMemoryFraction) |
<K> AbstractKeyedStateBackend<K> |
RocksDBStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry,
double managedMemoryFraction)
Deprecated.
|
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) |
void |
AbstractRocksDBState.migrateSerializedValue(DataInputDeserializer serializedOldValueInput,
DataOutputSerializer serializedMigratedValueOutput,
TypeSerializer<V> priorSerializer,
TypeSerializer<V> newSerializer) |
void |
AbstractRocksDBState.migrateSerializedValue(DataInputDeserializer serializedOldValueInput,
DataOutputSerializer serializedMigratedValueOutput,
TypeSerializer<V> priorSerializer,
TypeSerializer<V> newSerializer) |
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.
|
RocksDBKeyedStateBackend(ClassLoader userCodeClassLoader,
File instanceBasePath,
RocksDBResourceContainer optionsContainer,
java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
LatencyTrackingStateConfig latencyTrackingStateConfig,
org.rocksdb.RocksDB db,
LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
Map<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates,
int keyGroupPrefixBytes,
CloseableRegistry cancelStreamRegistry,
StreamCompressionDecorator keyGroupCompressionDecorator,
ResourceGuard rocksDBResourceGuard,
RocksDBSnapshotStrategyBase<K,?> checkpointSnapshotStrategy,
RocksDBWriteBatchWrapper writeBatchWrapper,
org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle,
RocksDBNativeMetricMonitor nativeMetricMonitor,
SerializedCompositeKeyBuilder<K> sharedRocksKeyBuilder,
PriorityQueueSetFactory priorityQueueFactory,
RocksDbTtlCompactFiltersManager ttlCompactFiltersManager,
InternalKeyContext<K> keyContext,
long writeBatchSize) |
RocksDBKeyedStateBackendBuilder(String operatorIdentifier,
ClassLoader userCodeClassLoader,
File instanceBasePath,
RocksDBResourceContainer optionsContainer,
java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
ExecutionConfig executionConfig,
LocalRecoveryConfig localRecoveryConfig,
EmbeddedRocksDBStateBackend.PriorityQueueStateType priorityQueueStateType,
TtlTimeProvider ttlTimeProvider,
LatencyTrackingStateConfig latencyTrackingStateConfig,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
StreamCompressionDecorator keyGroupCompressionDecorator,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<K> |
AbstractRocksStateKeysIterator.keySerializer |
Constructor and Description |
---|
AbstractRocksStateKeysIterator(RocksIteratorWrapper iterator,
String state,
TypeSerializer<K> keySerializer,
int keyGroupPrefixBytes,
boolean ambiguousKeyPossible) |
RocksStateKeysAndNamespaceIterator(RocksIteratorWrapper iterator,
String state,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
int keyGroupPrefixBytes,
boolean ambiguousKeyPossible) |
RocksStateKeysAndNamespaceIterator(RocksIteratorWrapper iterator,
String state,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
int keyGroupPrefixBytes,
boolean ambiguousKeyPossible) |
RocksStateKeysIterator(RocksIteratorWrapper iterator,
String state,
TypeSerializer<K> keySerializer,
int keyGroupPrefixBytes,
boolean ambiguousKeyPossible,
byte[] namespaceBytes) |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<K> |
RocksDBSnapshotStrategyBase.keySerializer
The key serializer of the backend.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
RocksDBFullSnapshotResources.getKeySerializer() |
Modifier and Type | Method and Description |
---|---|
static <K> RocksDBFullSnapshotResources<K> |
RocksDBFullSnapshotResources.create(LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
Map<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates,
org.rocksdb.RocksDB db,
ResourceGuard rocksDBResourceGuard,
KeyGroupRange keyGroupRange,
TypeSerializer<K> keySerializer,
int keyGroupPrefixBytes,
StreamCompressionDecorator keyGroupCompressionDecorator) |
Constructor and Description |
---|
RocksDBFullSnapshotResources(ResourceGuard.Lease lease,
org.rocksdb.Snapshot snapshot,
List<RocksDBKeyedStateBackend.RocksDbKvStateInfo> metaDataCopy,
List<HeapPriorityQueueStateSnapshot<?>> heapPriorityQueuesSnapshots,
List<StateMetaInfoSnapshot> stateMetaInfoSnapshots,
org.rocksdb.RocksDB db,
int keyGroupPrefixBytes,
KeyGroupRange keyGroupRange,
TypeSerializer<K> keySerializer,
StreamCompressionDecorator streamCompressionDecorator) |
RocksDBSnapshotStrategyBase(String description,
org.rocksdb.RocksDB db,
ResourceGuard rocksDBResourceGuard,
TypeSerializer<K> keySerializer,
LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
KeyGroupRange keyGroupRange,
int keyGroupPrefixBytes,
LocalRecoveryConfig localRecoveryConfig) |
RocksFullSnapshotStrategy(org.rocksdb.RocksDB db,
ResourceGuard rocksDBResourceGuard,
TypeSerializer<K> keySerializer,
LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
LinkedHashMap<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates,
KeyGroupRange keyGroupRange,
int keyGroupPrefixBytes,
LocalRecoveryConfig localRecoveryConfig,
StreamCompressionDecorator keyGroupCompressionDecorator) |
RocksIncrementalSnapshotStrategy(org.rocksdb.RocksDB db,
ResourceGuard rocksDBResourceGuard,
TypeSerializer<K> keySerializer,
LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation,
KeyGroupRange keyGroupRange,
int keyGroupPrefixBytes,
LocalRecoveryConfig localRecoveryConfig,
CloseableRegistry cancelStreamRegistry,
File instanceBasePath,
UUID backendUID,
SortedMap<Long,Map<StateHandleID,StreamStateHandle>> uploadedStateHandles,
RocksDBStateUploader rocksDBStateUploader,
long lastCompletedCheckpointId) |
Modifier and Type | Method and Description |
---|---|
void |
RocksDbTtlCompactFiltersManager.configCompactFilter(StateDescriptor<?,?> stateDesc,
TypeSerializer<?> stateSerializer) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleVersionedSerializerTypeSerializerProxy<T>
A
TypeSerializer that delegates to an underlying SimpleVersionedSerializer . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
SimpleVersionedSerializerTypeSerializerProxy.duplicate() |
Modifier and Type | Class and Description |
---|---|
class |
AvroSerializer<T>
A serializer that serializes types via Avro.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<org.apache.avro.generic.GenericRecord> |
GenericRecordAvroTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
AvroTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
AvroSerializer.duplicate() |
TypeSerializer<T> |
AvroSerializerSnapshot.restoreSerializer() |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<T> |
AvroSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<T> newSerializer) |
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(AbstractChannelReaderInputView inView,
List<MemorySegment> freeMemTarget,
TypeSerializer<E> accessors) |
ChannelReaderInputViewIterator(BlockChannelReader<MemorySegment> reader,
LinkedBlockingQueue<MemorySegment> returnQueue,
List<MemorySegment> segments,
List<MemorySegment> freeMemTarget,
TypeSerializer<E> accessors,
int numBlocks) |
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<T> |
AbstractMutableHashTable.buildSideSerializer
The utilities to serialize the build side data types.
|
protected TypeSerializer<BT> |
MutableHashTable.buildSideSerializer
The utilities to serialize the build side data types.
|
protected TypeSerializer<V2> |
ReusingBuildFirstHashJoinIterator.probeSideSerializer |
protected TypeSerializer<V2> |
NonReusingBuildFirstHashJoinIterator.probeSideSerializer |
protected TypeSerializer<V1> |
ReusingBuildSecondHashJoinIterator.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> |
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) |
<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> |
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> |
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) |
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> |
SpillingResettableIterator.serializer |
protected TypeSerializer<T> |
SpillingResettableMutableObjectIterator.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<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 <T> T |
NonReusingMergeOuterJoinIterator.createCopy(TypeSerializer<T> serializer,
T value,
T reuse) |
protected <T> T |
ReusingMergeOuterJoinIterator.createCopy(TypeSerializer<T> serializer,
T value,
T reuse) |
protected <T> T |
ReusingMergeInnerJoinIterator.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> KeyGroupedIterator<T> |
NonReusingMergeInnerJoinIterator.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> |
ReusingMergeOuterJoinIterator.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 abstract <T> KeyGroupedIterator<T> |
AbstractMergeIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
static <E> ExternalSorterBuilder<E> |
ExternalSorter.newBuilder(MemoryManager memoryManager,
AbstractInvokable parentTask,
TypeSerializer<E> serializer,
TypeComparator<E> comparator)
Creates a builder for the
ExternalSorter . |
static <E> ExternalSorterBuilder<E> |
ExternalSorter.newBuilder(MemoryManager memoryManager,
TaskInvokable parentTask,
TypeSerializer<E> serializer,
TypeComparator<E> comparator,
ExecutionConfig executionConfig)
Creates a builder for the
ExternalSorter . |
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> |
class |
JavaSerializer<T extends Serializable>
A
TypeSerializer that uses Java serialization. |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<K> |
AbstractKeyedStateBackend.keySerializer
The key serializer.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<VoidNamespace> |
VoidNamespaceTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
StateSerializerProvider.currentSchemaSerializer()
Gets the serializer that recognizes the current serialization schema of the state.
|
TypeSerializer<ArrayList<T>> |
ArrayListSerializer.duplicate() |
TypeSerializer<T> |
ArrayListSerializer.getElementSerializer() |
TypeSerializer<T> |
RegisteredPriorityQueueStateBackendMetaInfo.getElementSerializer() |
TypeSerializer<K> |
AbstractKeyedStateBackend.getKeySerializer() |
TypeSerializer<K> |
FullSnapshotResources.getKeySerializer()
Returns key
TypeSerializer . |
TypeSerializer<K> |
RegisteredBroadcastStateBackendMetaInfo.getKeySerializer() |
TypeSerializer<K> |
KeyedStateBackend.getKeySerializer() |
TypeSerializer<N> |
RegisteredKeyValueStateBackendMetaInfo.getNamespaceSerializer() |
protected TypeSerializer<?>[] |
ArrayListSerializerSnapshot.getNestedSerializers(ArrayListSerializer<T> outerSerializer) |
TypeSerializer<S> |
RegisteredOperatorStateBackendMetaInfo.getPartitionStateSerializer() |
TypeSerializer<T> |
RegisteredPriorityQueueStateBackendMetaInfo.getPreviousElementSerializer() |
TypeSerializer<K> |
RegisteredBroadcastStateBackendMetaInfo.getPreviousKeySerializer() |
TypeSerializer<N> |
RegisteredKeyValueStateBackendMetaInfo.getPreviousNamespaceSerializer() |
TypeSerializer<S> |
RegisteredOperatorStateBackendMetaInfo.getPreviousPartitionStateSerializer() |
TypeSerializer<S> |
RegisteredKeyValueStateBackendMetaInfo.getPreviousStateSerializer() |
TypeSerializer<V> |
RegisteredBroadcastStateBackendMetaInfo.getPreviousValueSerializer() |
TypeSerializer<S> |
RegisteredKeyValueStateBackendMetaInfo.getStateSerializer() |
TypeSerializer<V> |
RegisteredBroadcastStateBackendMetaInfo.getValueSerializer() |
TypeSerializer<T> |
StateSerializerProvider.previousSchemaSerializer()
Gets the serializer that recognizes the previous serialization schema of the state.
|
Modifier and Type | Method and Description |
---|---|
<N,S extends State,T> |
AbstractKeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function) |
<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,
AbstractKeyedStateBackend.PartitionStateFactory partitionStateFactory) |
<N> byte[] |
SerializedCompositeKeyBuilder.buildCompositeKeyNamespace(N namespace,
TypeSerializer<N> namespaceSerializer)
Returns a serialized composite key, from the key and key-group provided in a previous call to
SerializedCompositeKeyBuilder.setKeyAndKeyGroup(Object, int) and the given namespace. |
<N,UK> byte[] |
SerializedCompositeKeyBuilder.buildCompositeKeyNamesSpaceUserKey(N namespace,
TypeSerializer<N> namespaceSerializer,
UK userKey,
TypeSerializer<UK> userKeySerializer)
Returns a serialized composite key, from the key and key-group provided in a previous call to
SerializedCompositeKeyBuilder.setKeyAndKeyGroup(Object, int) and the given namespace, followed by the given
user-key. |
<N,UK> byte[] |
SerializedCompositeKeyBuilder.buildCompositeKeyNamesSpaceUserKey(N namespace,
TypeSerializer<N> namespaceSerializer,
UK userKey,
TypeSerializer<UK> userKeySerializer)
Returns a serialized composite key, from the key and key-group provided in a previous call to
SerializedCompositeKeyBuilder.setKeyAndKeyGroup(Object, int) and the given namespace, followed by the given
user-key. |
<UK> byte[] |
SerializedCompositeKeyBuilder.buildCompositeKeyUserKey(UK userKey,
TypeSerializer<UK> userKeySerializer)
Returns a serialized composite key, from the key and key-group provided in a previous call to
SerializedCompositeKeyBuilder.setKeyAndKeyGroup(Object, int) and the namespace provided in SerializedCompositeKeyBuilder.setNamespace(Object, TypeSerializer) , followed by the given user-key. |
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> |
PriorityQueueSetFactory.create(String stateName,
TypeSerializer<T> byteOrderedElementSerializer)
Creates a
KeyGroupedInternalPriorityQueue . |
default <N,SV,S extends State,IS extends S> |
KeyedStateFactory.createInternalState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc)
Creates and returns a new
InternalKvState . |
<N,SV,SEV,S extends State,IS extends S> |
KeyedStateFactory.createInternalState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
StateSnapshotTransformer.StateSnapshotTransformFactory<SEV> snapshotTransformFactory)
Creates and returns a new
InternalKvState . |
<K> CheckpointableKeyedStateBackend<K> |
StateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry)
Creates a new
CheckpointableKeyedStateBackend 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,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
default <K> CheckpointableKeyedStateBackend<K> |
StateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry,
double managedMemoryFraction)
Creates a new
CheckpointableKeyedStateBackend with the given managed memory fraction. |
abstract <K> AbstractKeyedStateBackend<K> |
AbstractManagedMemoryStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry,
double managedMemoryFraction) |
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> |
HeapPriorityQueuesManager.createOrUpdate(String stateName,
TypeSerializer<T> byteOrderedElementSerializer) |
protected ArrayListSerializer<T> |
ArrayListSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
<T> List<T> |
ListDelimitedSerializer.deserializeList(byte[] valueBytes,
TypeSerializer<T> elementSerializer) |
static <T> T |
ListDelimitedSerializer.deserializeNextElement(DataInputDeserializer in,
TypeSerializer<T> elementSerializer)
Deserializes a single element from a serialized list.
|
static <T> StateSerializerProvider<T> |
StateSerializerProvider.fromNewRegisteredSerializer(TypeSerializer<T> registeredStateSerializer)
Creates a
StateSerializerProvider from the registered state serializer. |
<N,S extends State> |
AbstractKeyedStateBackend.PartitionStateFactory.get(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor) |
<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> |
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.
|
<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.
|
static boolean |
CompositeKeySerializationUtils.isAmbiguousKeyPossible(TypeSerializer keySerializer,
TypeSerializer namespaceSerializer) |
static boolean |
CompositeKeySerializationUtils.isAmbiguousKeyPossible(TypeSerializer keySerializer,
TypeSerializer namespaceSerializer) |
static boolean |
CompositeKeySerializationUtils.isSerializerTypeVariableSized(TypeSerializer<?> serializer) |
static <K> K |
CompositeKeySerializationUtils.readKey(TypeSerializer<K> keySerializer,
DataInputDeserializer inputView,
boolean ambiguousKeyPossible) |
static <N> N |
CompositeKeySerializationUtils.readNamespace(TypeSerializer<N> namespaceSerializer,
DataInputDeserializer inputView,
boolean ambiguousKeyPossible) |
abstract TypeSerializerSchemaCompatibility<T> |
StateSerializerProvider.registerNewSerializerForRestoredState(TypeSerializer<T> newSerializer)
For restored state, register a new serializer that potentially has a new serialization
schema.
|
<T> byte[] |
ListDelimitedSerializer.serializeList(List<T> valueList,
TypeSerializer<T> elementSerializer) |
<N> void |
SerializedCompositeKeyBuilder.setNamespace(N namespace,
TypeSerializer<N> namespaceSerializer) |
TypeSerializerSchemaCompatibility<T> |
RegisteredPriorityQueueStateBackendMetaInfo.updateElementSerializer(TypeSerializer<T> newElementSerializer) |
TypeSerializerSchemaCompatibility<K> |
RegisteredBroadcastStateBackendMetaInfo.updateKeySerializer(TypeSerializer<K> newKeySerializer) |
TypeSerializerSchemaCompatibility<N> |
RegisteredKeyValueStateBackendMetaInfo.updateNamespaceSerializer(TypeSerializer<N> newNamespaceSerializer) |
TypeSerializerSchemaCompatibility<S> |
RegisteredOperatorStateBackendMetaInfo.updatePartitionStateSerializer(TypeSerializer<S> newPartitionStateSerializer) |
TypeSerializerSchemaCompatibility<S> |
RegisteredKeyValueStateBackendMetaInfo.updateStateSerializer(TypeSerializer<S> newStateSerializer) |
TypeSerializerSchemaCompatibility<V> |
RegisteredBroadcastStateBackendMetaInfo.updateValueSerializer(TypeSerializer<V> newValueSerializer) |
static <K> void |
CompositeKeySerializationUtils.writeKey(K key,
TypeSerializer<K> keySerializer,
DataOutputSerializer keySerializationDataOutputView,
boolean ambiguousKeyPossible) |
static <N> void |
CompositeKeySerializationUtils.writeNameSpace(N namespace,
TypeSerializer<N> namespaceSerializer,
DataOutputSerializer keySerializationDataOutputView,
boolean ambiguousKeyPossible) |
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,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
<K> AbstractKeyedStateBackend<K> |
HashMapStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<K> |
StateTable.keySerializer
The serializer of the key.
|
protected TypeSerializer<K> |
AbstractHeapState.keySerializer |
protected TypeSerializer<N> |
AbstractHeapState.namespaceSerializer |
protected TypeSerializer<S> |
CopyOnWriteStateMap.stateSerializer
The serializer of the state.
|
protected TypeSerializer<SV> |
AbstractHeapState.valueSerializer |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
StateTable.getKeySerializer() |
TypeSerializer<N> |
StateTable.getNamespaceSerializer() |
TypeSerializer<S> |
StateTable.getStateSerializer() |
TypeSerializer<S> |
CopyOnWriteStateMap.getStateSerializer() |
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,
AbstractKeyedStateBackend.PartitionStateFactory partitionStateFactory) |
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> |
HeapPriorityQueueSetFactory.create(String stateName,
TypeSerializer<T> byteOrderedElementSerializer) |
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> |
HeapKeyedStateBackend.create(String stateName,
TypeSerializer<T> byteOrderedElementSerializer) |
<N,SV,SEV,S extends State,IS extends S> |
HeapKeyedStateBackend.createInternalState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
StateSnapshotTransformer.StateSnapshotTransformFactory<SEV> snapshotTransformFactory) |
HeapPriorityQueueSnapshotRestoreWrapper<T> |
HeapPriorityQueueSnapshotRestoreWrapper.forUpdatedSerializer(TypeSerializer<T> updatedSerializer)
Returns a deep copy of the snapshot, where the serializer is changed to the given serializer.
|
Iterator<StateEntry<K,N,S>> |
CopyOnWriteSkipListStateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
Iterator<StateEntry<K,N,S>> |
CopyOnWriteSkipListStateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
Iterator<StateEntry<K,N,S>> |
CopyOnWriteSkipListStateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
abstract Iterator<StateEntry<K,N,S>> |
StateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
abstract Iterator<StateEntry<K,N,S>> |
StateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
abstract Iterator<StateEntry<K,N,S>> |
StateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
org.apache.flink.runtime.state.heap.CopyOnWriteStateMapSnapshot.SnapshotIterator<K,N,S> |
CopyOnWriteStateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
org.apache.flink.runtime.state.heap.CopyOnWriteStateMapSnapshot.SnapshotIterator<K,N,S> |
CopyOnWriteStateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
org.apache.flink.runtime.state.heap.CopyOnWriteStateMapSnapshot.SnapshotIterator<K,N,S> |
CopyOnWriteStateMapSnapshot.getIterator(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
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) |
void |
CopyOnWriteSkipListStateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
void |
CopyOnWriteSkipListStateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
void |
CopyOnWriteSkipListStateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
abstract void |
StateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer)
Writes the state in this snapshot to output.
|
abstract void |
StateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer)
Writes the state in this snapshot to output.
|
abstract void |
StateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer)
Writes the state in this snapshot to output.
|
void |
CopyOnWriteStateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
void |
CopyOnWriteStateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
void |
CopyOnWriteStateMapSnapshot.writeState(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
DataOutputView dov,
StateSnapshotTransformer<S> stateSnapshotTransformer) |
Constructor and Description |
---|
CopyOnWriteSkipListStateMap(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
Allocator spaceAllocator,
int numKeysToDeleteOneTime,
float logicalRemovedKeysRatio) |
CopyOnWriteSkipListStateMap(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
Allocator spaceAllocator,
int numKeysToDeleteOneTime,
float logicalRemovedKeysRatio) |
CopyOnWriteSkipListStateMap(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
TypeSerializer<S> stateSerializer,
Allocator spaceAllocator,
int numKeysToDeleteOneTime,
float logicalRemovedKeysRatio) |
HeapKeyedStateBackend(TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
ClassLoader userCodeClassLoader,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
LatencyTrackingStateConfig latencyTrackingStateConfig,
CloseableRegistry cancelStreamRegistry,
StreamCompressionDecorator keyGroupCompressionDecorator,
Map<String,StateTable<K,?,?>> registeredKVStates,
Map<String,HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates,
LocalRecoveryConfig localRecoveryConfig,
HeapPriorityQueueSetFactory priorityQueueSetFactory,
org.apache.flink.runtime.state.heap.HeapSnapshotStrategy<K> checkpointStrategy,
SnapshotExecutionType snapshotExecutionType,
org.apache.flink.runtime.state.heap.StateTableFactory<K> stateTableFactory,
InternalKeyContext<K> keyContext) |
HeapKeyedStateBackendBuilder(TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
ClassLoader userCodeClassLoader,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
ExecutionConfig executionConfig,
TtlTimeProvider ttlTimeProvider,
LatencyTrackingStateConfig latencyTrackingStateConfig,
Collection<KeyedStateHandle> stateHandles,
StreamCompressionDecorator keyGroupCompressionDecorator,
LocalRecoveryConfig localRecoveryConfig,
HeapPriorityQueueSetFactory priorityQueueSetFactory,
boolean asynchronousSnapshots,
CloseableRegistry cancelStreamRegistry) |
HeapKeyValueStateIterator(KeyGroupRange keyGroupRange,
TypeSerializer<?> keySerializer,
int totalKeyGroups,
Map<org.apache.flink.runtime.state.heap.StateUID,Integer> stateNamesToId,
Map<org.apache.flink.runtime.state.heap.StateUID,StateSnapshot> stateSnapshots) |
StateTable(InternalKeyContext<K> keyContext,
RegisteredKeyValueStateBackendMetaInfo<N,S> metaInfo,
TypeSerializer<K> keySerializer) |
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,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<?> |
StateMetaInfoSnapshot.getTypeSerializer(String key)
TODO this method should be removed once the serializer map is removed.
|
Constructor and Description |
---|
StateMetaInfoSnapshot(String name,
StateMetaInfoSnapshot.BackendStateType backendStateType,
Map<String,String> options,
Map<String,TypeSerializerSnapshot<?>> serializerSnapshots,
Map<String,TypeSerializer<?>> serializers)
TODO this variant, which requires providing the serializers, TODO should actually be removed,
leaving only
StateMetaInfoSnapshot(String, BackendStateType, Map, Map) . |
Modifier and Type | Class and Description |
---|---|
static class |
TtlStateFactory.TtlSerializer<T>
Serializer for user state value with TTL.
|
Modifier and Type | Method and Description |
---|---|
protected TypeSerializer<?>[] |
TtlStateFactory.TtlSerializerSnapshot.getNestedSerializers(TtlStateFactory.TtlSerializer<T> outerSerializer) |
Modifier and Type | Method and Description |
---|---|
protected TtlStateFactory.TtlSerializer<T> |
TtlStateFactory.TtlSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected CompositeSerializer<TtlValue<T>> |
TtlStateFactory.TtlSerializer.createSerializerInstance(CompositeSerializer.PrecomputedParameters precomputed,
TypeSerializer<?>... originalSerializers) |
static <K,N,SV,TTLSV,S extends State,IS extends S> |
TtlStateFactory.createStateAndWrapWithTtlIfEnabled(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
KeyedStateBackend<K> stateBackend,
TtlTimeProvider timeProvider) |
static boolean |
TtlStateFactory.TtlSerializer.isTtlStateSerializer(TypeSerializer<?> typeSerializer) |
Constructor and Description |
---|
TtlSerializer(CompositeSerializer.PrecomputedParameters precomputed,
TypeSerializer<?>... fieldSerializers) |
TtlSerializer(TypeSerializer<Long> timestampSerializer,
TypeSerializer<T> userValueSerializer) |
TtlSerializer(TypeSerializer<Long> timestampSerializer,
TypeSerializer<T> userValueSerializer) |
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 |
---|---|
<K,V> DataSource<Tuple2<K,V>> |
ExistingSavepoint.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Deprecated.
Read operator
BroadcastState from a Savepoint when a custom serializer was
used; e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<K,V> DataSource<Tuple2<K,V>> |
ExistingSavepoint.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Deprecated.
Read operator
BroadcastState from a Savepoint when a custom serializer was
used; e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<K,V> DataStream<Tuple2<K,V>> |
SavepointReader.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Read operator
BroadcastState from a Savepoint when a custom serializer was
used; e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<K,V> DataStream<Tuple2<K,V>> |
SavepointReader.readBroadcastState(String uid,
String name,
TypeInformation<K> keyTypeInfo,
TypeInformation<V> valueTypeInfo,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Read operator
BroadcastState from a Savepoint when a custom serializer was
used; e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<T> DataSource<T> |
ExistingSavepoint.readListState(String uid,
String name,
TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Deprecated.
Read operator
ListState from a Savepoint when a custom serializer was used;
e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<T> DataStream<T> |
SavepointReader.readListState(String uid,
String name,
TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Read operator
ListState from a Savepoint when a custom serializer was used;
e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<T> DataSource<T> |
ExistingSavepoint.readUnionState(String uid,
String name,
TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Deprecated.
Read operator
UnionState from a Savepoint when a custom serializer was used;
e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<T> DataStream<T> |
SavepointReader.readUnionState(String uid,
String name,
TypeInformation<T> typeInfo,
TypeSerializer<T> serializer)
Read operator
UnionState from a Savepoint when a custom serializer was used;
e.g., a different serializer than the one returned by TypeInformation#createSerializer . |
<W extends Window> |
ExistingSavepoint.window(TypeSerializer<W> windowSerializer)
Deprecated.
Read window state from an operator in a
Savepoint . |
<W extends Window> |
SavepointReader.window(TypeSerializer<W> windowSerializer)
Read window state from an operator in a
Savepoint . |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<N> |
StateReaderOperator.namespaceSerializer |
Modifier and Type | Method and Description |
---|---|
static <KEY,T,ACC,R,OUT,W extends Window> |
WindowReaderOperator.aggregate(AggregateFunction<T,ACC,R> function,
WindowReaderFunction<R,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<ACC> accumulatorType) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.evictingWindow(WindowReaderFunction<StreamRecord<T>,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> stateType,
ExecutionConfig config) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.process(WindowReaderFunction<T,OUT,KEY,W> readerFunction,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> stateType) |
static <KEY,T,W extends Window,OUT> |
WindowReaderOperator.reduce(ReduceFunction<T> function,
WindowReaderFunction<T,OUT,KEY,W> reader,
TypeInformation<KEY> keyType,
TypeSerializer<W> windowSerializer,
TypeInformation<T> inputType) |
Constructor and Description |
---|
StateReaderOperator(F function,
TypeInformation<KEY> keyType,
TypeSerializer<N> namespaceSerializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
ChangelogKeyedStateBackend.getKeySerializer() |
Modifier and Type | Method and Description |
---|---|
<N,S extends State,T> |
ChangelogKeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function) |
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> |
ChangelogKeyedStateBackend.create(String stateName,
TypeSerializer<T> byteOrderedElementSerializer) |
<N,SV,SEV,S extends State,IS extends S> |
ChangelogKeyedStateBackend.createInternalState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
StateSnapshotTransformer.StateSnapshotTransformFactory<SEV> snapshotTransformFactory) |
<K> ChangelogKeyedStateBackend<K> |
ChangelogStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
<K> CheckpointableKeyedStateBackend<K> |
ChangelogStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry,
double managedMemoryFraction) |
<N,S extends State,T> |
ChangelogKeyedStateBackend.getOrCreateKeyedState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor) |
<N,S extends State> |
ChangelogKeyedStateBackend.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor) |
Constructor and Description |
---|
ChangelogKeyGroupedPriorityQueue(KeyGroupedInternalPriorityQueue<T> delegatedPriorityQueue,
org.apache.flink.state.changelog.StateChangeLogger<T,Void> logger,
TypeSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
<T> StateChangeApplier |
ChangelogApplierFactory.forPriorityQueue(KeyGroupedInternalPriorityQueue<T> priorityQueue,
TypeSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<CommittableMessage<CommT>> |
CommittableMessageTypeInfo.createSerializer(ExecutionConfig config) |
Modifier and Type | Class and Description |
---|---|
static class |
CoGroupedStreams.UnionSerializer<T1,T2>
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<CoGroupedStreams.TaggedUnion<T1,T2>> |
CoGroupedStreams.UnionSerializer.duplicate() |
TypeSerializer<K> |
QueryableStateStream.getKeySerializer()
Returns the key serializer for the queryable state instance.
|
protected TypeSerializer<?>[] |
CoGroupedStreams.UnionSerializerSnapshot.getNestedSerializers(CoGroupedStreams.UnionSerializer<T1,T2> outerSerializer) |
Modifier and Type | Method and Description |
---|---|
protected CoGroupedStreams.UnionSerializer<T1,T2> |
CoGroupedStreams.UnionSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
TypeSerializerSchemaCompatibility<CoGroupedStreams.TaggedUnion<T1,T2>> |
CoGroupedStreams.UnionSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<CoGroupedStreams.TaggedUnion<T1,T2>> newSerializer)
Deprecated.
|
Constructor and Description |
---|
QueryableStateStream(String queryableStateName,
StateDescriptor<?,V> stateDescriptor,
TypeSerializer<K> keySerializer)
Creates a queryable state stream.
|
UnionSerializer(TypeSerializer<T1> oneSerializer,
TypeSerializer<T2> twoSerializer) |
UnionSerializer(TypeSerializer<T1> oneSerializer,
TypeSerializer<T2> twoSerializer) |
UnionSerializerConfigSnapshot(TypeSerializer<T1> oneSerializer,
TypeSerializer<T2> twoSerializer)
Deprecated.
|
UnionSerializerConfigSnapshot(TypeSerializer<T1> oneSerializer,
TypeSerializer<T2> twoSerializer)
Deprecated.
|
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() |
protected TypeSerializer<?>[] |
TwoPhaseCommitSinkFunction.StateSerializerSnapshot.getNestedSerializers(TwoPhaseCommitSinkFunction.StateSerializer<TXN,CONTEXT> outerSerializer) |
Modifier and Type | Method and Description |
---|---|
protected TwoPhaseCommitSinkFunction.StateSerializer<TXN,CONTEXT> |
TwoPhaseCommitSinkFunction.StateSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
TypeSerializerSchemaCompatibility<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> |
TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<TwoPhaseCommitSinkFunction.State<TXN,CONTEXT>> newSerializer)
Deprecated.
|
Constructor and Description |
---|
StateSerializer(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer) |
StateSerializer(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer) |
StateSerializer(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer,
boolean supportNullPendingTransaction) |
StateSerializer(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer,
boolean supportNullPendingTransaction) |
StateSerializerConfigSnapshot(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer)
Deprecated.
|
StateSerializerConfigSnapshot(TypeSerializer<TXN> transactionSerializer,
TypeSerializer<CONTEXT> contextSerializer)
Deprecated.
|
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. |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
FromElementsFunction.getSerializer() |
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<?> |
StreamConfig.NetworkInputConfig.getTypeSerializer() |
<T> TypeSerializer<T> |
StreamConfig.getTypeSerializerIn(int index,
ClassLoader cl) |
<T> TypeSerializer<T> |
StreamConfig.getTypeSerializerIn1(ClassLoader cl)
Deprecated.
|
<T> TypeSerializer<T> |
StreamConfig.getTypeSerializerIn2(ClassLoader cl)
Deprecated.
|
TypeSerializer<?> |
StreamNode.getTypeSerializerOut() |
<T> TypeSerializer<T> |
StreamConfig.getTypeSerializerOut(ClassLoader cl) |
<T> TypeSerializer<T> |
StreamConfig.getTypeSerializerSideOut(OutputTag<?> outputTag,
ClassLoader cl) |
TypeSerializer<?>[] |
StreamNode.getTypeSerializersIn() |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.setMultipleInputStateKey(Integer vertexID,
List<KeySelector<?,?>> keySelectors,
TypeSerializer<?> keySerializer) |
void |
StreamGraph.setOneInputStateKey(Integer vertexID,
KeySelector<?,?> keySelector,
TypeSerializer<?> keySerializer) |
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.setSerializersIn(TypeSerializer<?>... typeSerializersIn) |
void |
StreamConfig.setStateKeySerializer(TypeSerializer<?> serializer) |
void |
StreamNode.setStateKeySerializer(TypeSerializer<?> stateKeySerializer) |
void |
StreamGraph.setTwoInputStateKey(Integer vertexID,
KeySelector<?,?> keySelector1,
KeySelector<?,?> keySelector2,
TypeSerializer<?> keySerializer) |
void |
StreamConfig.setTypeSerializerOut(TypeSerializer<?> serializer) |
void |
StreamConfig.setTypeSerializerSideOut(OutputTag<?> outputTag,
TypeSerializer<?> serializer) |
void |
StreamConfig.setupNetworkInputs(TypeSerializer<?>... serializers) |
Constructor and Description |
---|
NetworkInputConfig(TypeSerializer<?> typeSerializer,
int inputGateIndex) |
NetworkInputConfig(TypeSerializer<?> typeSerializer,
int inputGateIndex,
StreamConfig.InputRequirement inputRequirement) |
Modifier and Type | Class and Description |
---|---|
static class |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer<K,N>
A
TypeSerializer used to serialize/deserialize a TimerHeapInternalTimer . |
class |
TimerSerializer<K,N>
A serializer for
TimerHeapInternalTimer objects that produces a serialization format that
is lexicographically aligned the priority of the timers. |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<TimerHeapInternalTimer<K,N>> |
InternalTimersSnapshotReaderWriters.LegacyTimerSerializer.duplicate() |
TypeSerializer<K> |
InternalTimerServiceImpl.getKeySerializer() |
TypeSerializer<K> |
TimerSerializer.getKeySerializer() |
TypeSerializer<N> |
InternalTimerServiceImpl.getNamespaceSerializer() |
TypeSerializer<N> |
TimerSerializer.getNamespaceSerializer() |
protected TypeSerializer<?>[] |
TimerSerializerSnapshot.getNestedSerializers(TimerSerializer<K,N> outerSerializer) |
Modifier and Type | Method and Description |
---|---|
protected TimerSerializer<K,N> |
TimerSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
<N> InternalTimerService<N> |
InternalTimeServiceManagerImpl.getInternalTimerService(String name,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable) |
<N> InternalTimerService<N> |
InternalTimeServiceManagerImpl.getInternalTimerService(String name,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable) |
<N> InternalTimerService<N> |
InternalTimeServiceManager.getInternalTimerService(String name,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable)
Creates an
InternalTimerService for handling a group of timers identified by the
given name . |
<N> InternalTimerService<N> |
InternalTimeServiceManager.getInternalTimerService(String name,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable)
Creates an
InternalTimerService for handling a group of timers identified by the
given name . |
<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. |
<K,N> InternalTimerService<N> |
AbstractStreamOperatorV2.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 <N,S extends State,T> |
AbstractStreamOperatorV2.getOrCreateKeyedState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor) |
<N,S extends State,T> |
StreamOperatorStateHandler.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 <S extends State,N> |
AbstractStreamOperatorV2.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor)
Creates a partitioned state handle, using the state backend configured for this task.
|
protected <S extends State,N> |
StreamOperatorStateHandler.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor)
Creates a partitioned state handle, using the state backend configured for this task.
|
static <K,N> InternalTimersSnapshotReaderWriters.InternalTimersSnapshotWriter |
InternalTimersSnapshotReaderWriters.getWriterForVersion(int version,
InternalTimersSnapshot<K,N> timersSnapshot,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer) |
static <K,N> InternalTimersSnapshotReaderWriters.InternalTimersSnapshotWriter |
InternalTimersSnapshotReaderWriters.getWriterForVersion(int version,
InternalTimersSnapshot<K,N> timersSnapshot,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer) |
protected <K> CheckpointableKeyedStateBackend<K> |
StreamTaskStateInitializerImpl.keyedStatedBackend(TypeSerializer<K> keySerializer,
String operatorIdentifierText,
PrioritizedOperatorSubtaskState prioritizedOperatorSubtaskStates,
CloseableRegistry backendCloseableRegistry,
MetricGroup metricGroup,
double managedMemoryFraction) |
TypeSerializerSchemaCompatibility<TimerHeapInternalTimer<K,N>> |
TimerSerializer.TimerSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<TimerHeapInternalTimer<K,N>> newSerializer)
Deprecated.
|
void |
InternalTimerServiceImpl.startTimerService(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerTarget)
Starts the local
InternalTimerServiceImpl by:
Setting the keySerialized and namespaceSerializer for the timers it
will contain. |
void |
InternalTimerServiceImpl.startTimerService(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerTarget)
Starts the local
InternalTimerServiceImpl by:
Setting the keySerialized and namespaceSerializer for the timers it
will contain. |
StreamOperatorStateContext |
StreamTaskStateInitializerImpl.streamOperatorStateContext(OperatorID operatorID,
String operatorClassName,
ProcessingTimeService processingTimeService,
KeyContext keyContext,
TypeSerializer<?> keySerializer,
CloseableRegistry streamTaskCloseableRegistry,
MetricGroup metricGroup,
double managedMemoryFraction,
boolean isUsingCustomRawKeyedState) |
StreamOperatorStateContext |
StreamTaskStateInitializer.streamOperatorStateContext(OperatorID operatorID,
String operatorClassName,
ProcessingTimeService processingTimeService,
KeyContext keyContext,
TypeSerializer<?> keySerializer,
CloseableRegistry streamTaskCloseableRegistry,
MetricGroup metricGroup,
double managedMemoryFraction,
boolean isUsingCustomRawKeyedState)
Returns the
StreamOperatorStateContext for an AbstractStreamOperator that
runs in the stream task that owns this manager. |
Constructor and Description |
---|
BatchGroupedReduceOperator(ReduceFunction<IN> reducer,
TypeSerializer<IN> serializer) |
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Set<TimerHeapInternalTimer<K,N>> eventTimeTimers,
Set<TimerHeapInternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
InternalTimersSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Set<TimerHeapInternalTimer<K,N>> eventTimeTimers,
Set<TimerHeapInternalTimer<K,N>> processingTimeTimers)
Constructor to use when snapshotting the timers.
|
StreamGroupedReduceOperator(ReduceFunction<IN> reducer,
TypeSerializer<IN> serializer) |
StreamProject(int[] fields,
TypeSerializer<OUT> outSerializer) |
TimerSerializer(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer) |
TimerSerializer(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer) |
TimerSerializerConfigSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Deprecated.
|
TimerSerializerConfigSnapshot(TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
static class |
IntervalJoinOperator.BufferEntrySerializer<T>
A
serializer for the IntervalJoinOperator.BufferEntry . |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<IntervalJoinOperator.BufferEntry<T>> |
IntervalJoinOperator.BufferEntrySerializer.duplicate() |
protected TypeSerializer<?>[] |
IntervalJoinOperator.BufferEntrySerializerSnapshot.getNestedSerializers(IntervalJoinOperator.BufferEntrySerializer<T> outerSerializer) |
Modifier and Type | Method and Description |
---|---|
protected IntervalJoinOperator.BufferEntrySerializer<T> |
IntervalJoinOperator.BufferEntrySerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
TypeSerializerSchemaCompatibility<IntervalJoinOperator.BufferEntry<T>> |
IntervalJoinOperator.BufferSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<IntervalJoinOperator.BufferEntry<T>> newSerializer)
Deprecated.
|
Constructor and Description |
---|
BufferEntrySerializer(TypeSerializer<T> elementSerializer) |
BufferSerializerConfigSnapshot(TypeSerializer<T> userTypeSerializer)
Deprecated.
|
IntervalJoinOperator(long lowerBound,
long upperBound,
boolean lowerBoundInclusive,
boolean upperBoundInclusive,
TypeSerializer<T1> leftTypeSerializer,
TypeSerializer<T2> rightTypeSerializer,
ProcessJoinFunction<T1,T2,OUT> udf)
Creates a new IntervalJoinOperator.
|
IntervalJoinOperator(long lowerBound,
long upperBound,
boolean lowerBoundInclusive,
boolean upperBoundInclusive,
TypeSerializer<T1> leftTypeSerializer,
TypeSerializer<T2> rightTypeSerializer,
ProcessJoinFunction<T1,T2,OUT> udf)
Creates a new IntervalJoinOperator.
|
Modifier and Type | Method and Description |
---|---|
<T> List<T> |
CollectCoordinationResponse.getResults(TypeSerializer<T> elementSerializer) |
Constructor and Description |
---|
AbstractCollectResultBuffer(TypeSerializer<T> serializer) |
CheckpointedCollectResultBuffer(TypeSerializer<T> serializer) |
CollectResultIterator(CompletableFuture<OperatorID> operatorIdFuture,
TypeSerializer<T> serializer,
String accumulatorName,
CheckpointConfig checkpointConfig) |
CollectSinkFunction(TypeSerializer<IN> serializer,
long maxBytesPerBatch,
String accumulatorName) |
CollectSinkOperator(TypeSerializer<IN> serializer,
long maxBytesPerBatch,
String accumulatorName) |
CollectSinkOperatorFactory(TypeSerializer<IN> serializer,
String accumulatorName) |
CollectSinkOperatorFactory(TypeSerializer<IN> serializer,
String accumulatorName,
MemorySize maxBatchSize,
java.time.Duration socketTimeout) |
UncheckpointedCollectResultBuffer(TypeSerializer<T> serializer,
boolean failureTolerance) |
Constructor and Description |
---|
PythonKeyedProcessOperator(Configuration config,
DataStreamPythonFunctionInfo pythonFunctionInfo,
RowTypeInfo inputTypeInfo,
TypeInformation<OUT> outputTypeInfo,
TypeSerializer namespaceSerializer) |
Constructor and Description |
---|
TimerRegistration(KeyedStateBackend<Row> keyedStateBackend,
InternalTimerService internalTimerService,
KeyContext keyContext,
TypeSerializer namespaceSerializer,
TypeSerializer<Row> timerDataSerializer) |
TimerRegistration(KeyedStateBackend<Row> keyedStateBackend,
InternalTimerService internalTimerService,
KeyContext keyContext,
TypeSerializer namespaceSerializer,
TypeSerializer<Row> timerDataSerializer) |
Modifier and Type | Method and Description |
---|---|
static <K> MultiInputSortingDataInput.SelectableSortingInputs |
MultiInputSortingDataInput.wrapInputs(TaskInvokable containingTask,
StreamTaskInput<Object>[] sortingInputs,
KeySelector<Object,K>[] keySelectors,
TypeSerializer<Object>[] inputSerializers,
TypeSerializer<K> keySerializer,
StreamTaskInput<Object>[] passThroughInputs,
MemoryManager memoryManager,
IOManager ioManager,
boolean objectReuse,
double managedMemoryFraction,
Configuration jobConfiguration,
ExecutionConfig executionConfig) |
static <K> MultiInputSortingDataInput.SelectableSortingInputs |
MultiInputSortingDataInput.wrapInputs(TaskInvokable containingTask,
StreamTaskInput<Object>[] sortingInputs,
KeySelector<Object,K>[] keySelectors,
TypeSerializer<Object>[] inputSerializers,
TypeSerializer<K> keySerializer,
StreamTaskInput<Object>[] passThroughInputs,
MemoryManager memoryManager,
IOManager ioManager,
boolean objectReuse,
double managedMemoryFraction,
Configuration jobConfiguration,
ExecutionConfig executionConfig) |
Constructor and Description |
---|
SortingDataInput(StreamTaskInput<T> wrappedInput,
TypeSerializer<T> typeSerializer,
TypeSerializer<K> keySerializer,
KeySelector<T,K> keySelector,
MemoryManager memoryManager,
IOManager ioManager,
boolean objectReuse,
double managedMemoryFraction,
Configuration jobConfiguration,
TaskInvokable containingTask,
ExecutionConfig executionConfig) |
SortingDataInput(StreamTaskInput<T> wrappedInput,
TypeSerializer<T> typeSerializer,
TypeSerializer<K> keySerializer,
KeySelector<T,K> keySelector,
MemoryManager memoryManager,
IOManager ioManager,
boolean objectReuse,
double managedMemoryFraction,
Configuration jobConfiguration,
TaskInvokable containingTask,
ExecutionConfig executionConfig) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<K> |
BatchExecutionKeyedStateBackend.getKeySerializer() |
Modifier and Type | Method and Description |
---|---|
<N,S extends State,T> |
BatchExecutionKeyedStateBackend.applyToAllKeys(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor,
KeyedStateFunction<K,S> function) |
<T extends HeapPriorityQueueElement & PriorityComparable<? super T> & Keyed<?>> |
BatchExecutionKeyedStateBackend.create(String stateName,
TypeSerializer<T> byteOrderedElementSerializer) |
<N,SV,SEV,S extends State,IS extends S> |
BatchExecutionKeyedStateBackend.createInternalState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,SV> stateDesc,
StateSnapshotTransformer.StateSnapshotTransformFactory<SEV> snapshotTransformFactory) |
<K> CheckpointableKeyedStateBackend<K> |
BatchExecutionStateBackend.createKeyedStateBackend(Environment env,
JobID jobID,
String operatorIdentifier,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
TaskKvStateRegistry kvStateRegistry,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
CloseableRegistry cancelStreamRegistry) |
<N> InternalTimerService<N> |
BatchExecutionInternalTimeServiceManager.getInternalTimerService(String name,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable) |
<N> InternalTimerService<N> |
BatchExecutionInternalTimeServiceManager.getInternalTimerService(String name,
TypeSerializer<K> keySerializer,
TypeSerializer<N> namespaceSerializer,
Triggerable<K,N> triggerable) |
<N,S extends State,T> |
BatchExecutionKeyedStateBackend.getOrCreateKeyedState(TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,T> stateDescriptor) |
<N,S extends State> |
BatchExecutionKeyedStateBackend.getPartitionedState(N namespace,
TypeSerializer<N> namespaceSerializer,
StateDescriptor<S,?> stateDescriptor) |
Constructor and Description |
---|
BatchExecutionKeyedStateBackend(TypeSerializer<K> keySerializer,
KeyGroupRange keyGroupRange,
ExecutionConfig executionConfig) |
Constructor and Description |
---|
BeamDataStreamPythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String headOperatorFunctionUrn,
List<FlinkFnApi.UserDefinedDataStreamFunction> userDefinedDataStreamFunctions,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> stateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
TimerRegistration timerRegistration,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor timerCoderDescriptor) |
BeamDataStreamPythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String headOperatorFunctionUrn,
List<FlinkFnApi.UserDefinedDataStreamFunction> userDefinedDataStreamFunctions,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> stateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
TimerRegistration timerRegistration,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor timerCoderDescriptor) |
BeamPythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
TimerRegistration timerRegistration,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
BeamPythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
TimerRegistration timerRegistration,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<byte[]> |
PickledByteArrayTypeInfo.createSerializer(ExecutionConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
ByteArrayWrapperSerializer
The serializer of
ByteArrayWrapper . |
Modifier and Type | Method and Description |
---|---|
static <T> TypeSerializer<T> |
PythonTypeUtils.TypeInfoToSerializerConverter.typeInfoSerializerConverter(TypeInformation<T> typeInformation) |
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 |
FlinkKafkaProducer.ContextStateSerializer
Deprecated.
|
static class |
FlinkKafkaProducer.NextTransactionalIdHintSerializer
Deprecated.
|
static class |
FlinkKafkaProducer.TransactionStateSerializer
Deprecated.
|
Constructor and Description |
---|
KafkaShuffleElementDeserializer(TypeSerializer<T> typeSerializer) |
KafkaShuffleFetcher(SourceFunction.SourceContext<T> sourceContext,
Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets,
SerializedValue<WatermarkStrategy<T>> watermarkStrategy,
ProcessingTimeService processingTimeProvider,
long autoWatermarkInterval,
ClassLoader userCodeClassLoader,
String taskNameWithSubtasks,
KafkaDeserializationSchema<T> deserializer,
Properties kafkaProperties,
long pollTimeout,
MetricGroup subtaskMetricGroup,
MetricGroup consumerMetricGroup,
boolean useMetrics,
TypeSerializer<T> typeSerializer,
int producerParallelism) |
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<T> |
AbstractStreamTaskNetworkInput.inputSerializer |
Modifier and Type | Method and Description |
---|---|
static <T> StreamTaskInput<T> |
StreamTaskNetworkInputFactory.create(CheckpointedInputGate checkpointedInputGate,
TypeSerializer<T> inputSerializer,
IOManager ioManager,
StatusWatermarkValve statusWatermarkValve,
int inputIndex,
InflightDataRescalingDescriptor rescalingDescriptorinflightDataRescalingDescriptor,
java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners,
TaskInfo taskInfo)
Factory method for
StreamTaskNetworkInput or RescalingStreamTaskNetworkInput
depending on InflightDataRescalingDescriptor . |
Constructor and Description |
---|
AbstractStreamTaskNetworkInput(CheckpointedInputGate checkpointedInputGate,
TypeSerializer<T> inputSerializer,
StatusWatermarkValve statusWatermarkValve,
int inputIndex,
Map<InputChannelInfo,R> recordDeserializers) |
RecordWriterOutput(RecordWriter<SerializationDelegate<StreamRecord<OUT>>> recordWriter,
TypeSerializer<OUT> outSerializer,
OutputTag outputTag,
boolean supportsUnalignedCheckpoints) |
StreamTaskNetworkInput(CheckpointedInputGate checkpointedInputGate,
TypeSerializer<T> inputSerializer,
IOManager ioManager,
StatusWatermarkValve statusWatermarkValve,
int inputIndex) |
Constructor and Description |
---|
RescalingStreamTaskNetworkInput(CheckpointedInputGate checkpointedInputGate,
TypeSerializer<T> inputSerializer,
IOManager ioManager,
StatusWatermarkValve statusWatermarkValve,
int inputIndex,
InflightDataRescalingDescriptor inflightDataRescalingDescriptor,
java.util.function.Function<Integer,StreamPartitioner<?>> gatePartitioners,
TaskInfo taskInfo) |
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() |
protected TypeSerializer<?>[] |
StreamElementSerializer.StreamElementSerializerSnapshot.getNestedSerializers(StreamElementSerializer<T> outerSerializer) |
Modifier and Type | Method and Description |
---|---|
protected StreamElementSerializer<T> |
StreamElementSerializer.StreamElementSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
TypeSerializerSchemaCompatibility<StreamElement> |
StreamElementSerializer.StreamElementSerializerConfigSnapshot.resolveSchemaCompatibility(TypeSerializer<StreamElement> newSerializer)
Deprecated.
|
Constructor and Description |
---|
StreamElementSerializer(TypeSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
SingleThreadAccessCheckingTypeInfo.createSerializer(ExecutionConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
StatefulComplexPayloadSerializer
A custom stateful serializer to test that serializers are not used concurrently.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<ComplexPayload> |
StatefulComplexPayloadSerializer.duplicate() |
Constructor and Description |
---|
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) |
Modifier and Type | Class and Description |
---|---|
static class |
ValueWithTs.Serializer
Serializer for Serializer.
|
Modifier and Type | Method and Description |
---|---|
protected TypeSerializer<?>[] |
ValueWithTs.ValueWithTsSerializerSnapshot.getNestedSerializers(ValueWithTs.Serializer outerSerializer) |
TypeSerializer<UV> |
TtlStateVerifier.getUpdateSerializer() |
Modifier and Type | Method and Description |
---|---|
protected ValueWithTs.Serializer |
ValueWithTs.ValueWithTsSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers) |
protected CompositeSerializer<ValueWithTs<?>> |
ValueWithTs.Serializer.createSerializerInstance(CompositeSerializer.PrecomputedParameters precomputed,
TypeSerializer<?>... originalSerializers) |
Constructor and Description |
---|
Serializer(TypeSerializer<?> valueSerializer,
TypeSerializer<Long> timestampSerializer) |
Serializer(TypeSerializer<?> valueSerializer,
TypeSerializer<Long> timestampSerializer) |
Modifier and Type | Method and Description |
---|---|
static <T> DataType |
DataTypes.RAW(Class<T> clazz,
TypeSerializer<T> serializer)
Data type of an arbitrary serialized type.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
RawValueData.toBytes(TypeSerializer<T> serializer)
Converts this
RawValueData into a byte array. |
T |
RawValueData.toObject(TypeSerializer<T> serializer)
Converts this
RawValueData into a Java object. |
Modifier and Type | Method and Description |
---|---|
void |
LazyBinaryFormat.ensureMaterialized(TypeSerializer<T> serializer)
Ensure we have materialized binary format.
|
protected BinarySection |
BinaryStringData.materialize(TypeSerializer<String> serializer) |
protected BinarySection |
BinaryRawValueData.materialize(TypeSerializer<T> serializer) |
protected abstract BinarySection |
LazyBinaryFormat.materialize(TypeSerializer<T> serializer)
Materialize java object to binary format.
|
byte[] |
BinaryRawValueData.toBytes(TypeSerializer<T> serializer) |
T |
BinaryRawValueData.toObject(TypeSerializer<T> serializer) |
Constructor and Description |
---|
GenericConverter(TypeSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
static void |
BinaryWriter.write(BinaryWriter writer,
int pos,
Object o,
LogicalType type,
TypeSerializer<?> serializer)
Deprecated.
Use
BinaryWriter.createValueSetter(LogicalType) for avoiding logical types during
runtime. |
Modifier and Type | Class and Description |
---|---|
class |
ListViewSerializer<T>
Deprecated.
|
class |
MapViewSerializer<K,V>
Deprecated.
|
class |
NullAwareMapSerializer<K,V>
Deprecated.
|
class |
NullSerializer
A serializer for null.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<MapView<K,V>> |
MapViewTypeInfo.createSerializer(ExecutionConfig config)
Deprecated.
|
TypeSerializer<ListView<T>> |
ListViewTypeInfo.createSerializer(ExecutionConfig config)
Deprecated.
|
TypeSerializer<Map<K,V>> |
NullAwareMapSerializer.duplicate()
Deprecated.
|
TypeSerializer<ListView<T>> |
ListViewSerializer.duplicate()
Deprecated.
|
TypeSerializer<MapView<K,V>> |
MapViewSerializer.duplicate()
Deprecated.
|
TypeSerializer<K> |
NullAwareMapSerializer.getKeySerializer()
Deprecated.
|
TypeSerializer<List<T>> |
ListViewSerializer.getListSerializer()
Deprecated.
|
TypeSerializer<Map<K,V>> |
MapViewSerializer.getMapSerializer()
Deprecated.
|
protected TypeSerializer<?>[] |
ListViewSerializerSnapshot.getNestedSerializers(ListViewSerializer<T> outerSerializer)
Deprecated.
|
protected TypeSerializer<?>[] |
MapViewSerializerSnapshot.getNestedSerializers(MapViewSerializer<K,V> outerSerializer)
Deprecated.
|
protected TypeSerializer<?>[] |
NullAwareMapSerializerSnapshot.getNestedSerializers(NullAwareMapSerializer<K,V> outerSerializer)
Deprecated.
|
TypeSerializer<V> |
NullAwareMapSerializer.getValueSerializer()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected MapViewSerializer<K,V> |
MapViewSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
Deprecated.
|
protected NullAwareMapSerializer<K,V> |
NullAwareMapSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
Deprecated.
|
protected ListViewSerializer<T> |
ListViewSerializerSnapshot.createOuterSerializerWithNestedSerializers(TypeSerializer<?>[] nestedSerializers)
Deprecated.
|
Constructor and Description |
---|
ListViewSerializer(TypeSerializer<List<T>> listSerializer)
Deprecated.
|
MapViewSerializer(TypeSerializer<Map<K,V>> mapSerializer)
Deprecated.
|
NullAwareMapSerializer(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Deprecated.
|
NullAwareMapSerializer(TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Optional<TypeSerializer<?>> |
ListViewSpec.getElementSerializer() |
Optional<TypeSerializer<?>> |
MapViewSpec.getKeySerializer() |
Optional<TypeSerializer<?>> |
MapViewSpec.getValueSerializer() |
Modifier and Type | Method and Description |
---|---|
<N,EE> StateListView<N,EE> |
PerKeyStateDataViewStore.getStateListView(String stateName,
TypeSerializer<EE> elementSerializer) |
<N,EE> StateListView<N,EE> |
UnsupportedStateDataViewStore.getStateListView(String stateName,
TypeSerializer<EE> elementSerializer) |
<N,EE> StateListView<N,EE> |
PerWindowStateDataViewStore.getStateListView(String stateName,
TypeSerializer<EE> elementSerializer) |
<N,EE> StateListView<N,EE> |
StateDataViewStore.getStateListView(String stateName,
TypeSerializer<EE> elementSerializer)
Creates a state list view.
|
<N,EK,EV> StateMapView<N,EK,EV> |
PerKeyStateDataViewStore.getStateMapView(String stateName,
boolean supportNullKey,
TypeSerializer<EK> keySerializer,
TypeSerializer<EV> valueSerializer) |
<N,EK,EV> StateMapView<N,EK,EV> |
PerKeyStateDataViewStore.getStateMapView(String stateName,
boolean supportNullKey,
TypeSerializer<EK> keySerializer,
TypeSerializer<EV> valueSerializer) |
<N,EK,EV> StateMapView<N,EK,EV> |
UnsupportedStateDataViewStore.getStateMapView(String stateName,
boolean supportNullKey,
TypeSerializer<EK> keySerializer,
TypeSerializer<EV> valueSerializer) |
<N,EK,EV> StateMapView<N,EK,EV> |
UnsupportedStateDataViewStore.getStateMapView(String stateName,
boolean supportNullKey,
TypeSerializer<EK> keySerializer,
TypeSerializer<EV> valueSerializer) |
<N,EK,EV> StateMapView<N,EK,EV> |
PerWindowStateDataViewStore.getStateMapView(String stateName,
boolean supportNullKey,
TypeSerializer<EK> keySerializer,
TypeSerializer<EV> valueSerializer) |
<N,EK,EV> StateMapView<N,EK,EV> |
PerWindowStateDataViewStore.getStateMapView(String stateName,
boolean supportNullKey,
TypeSerializer<EK> keySerializer,
TypeSerializer<EV> valueSerializer) |
<N,EK,EV> StateMapView<N,EK,EV> |
StateDataViewStore.getStateMapView(String stateName,
boolean supportNullKey,
TypeSerializer<EK> keySerializer,
TypeSerializer<EV> valueSerializer)
Creates a state map view.
|
<N,EK,EV> StateMapView<N,EK,EV> |
StateDataViewStore.getStateMapView(String stateName,
boolean supportNullKey,
TypeSerializer<EK> keySerializer,
TypeSerializer<EV> valueSerializer)
Creates a state map view.
|
Constructor and Description |
---|
ListViewSpec(String stateId,
int fieldIndex,
DataType dataType,
TypeSerializer<?> elementSerializer)
Deprecated.
|
MapViewSpec(String stateId,
int fieldIndex,
DataType dataType,
boolean containsNullKey,
TypeSerializer<?> keySerializer,
TypeSerializer<?> valueSerializer)
Deprecated.
|
MapViewSpec(String stateId,
int fieldIndex,
DataType dataType,
boolean containsNullKey,
TypeSerializer<?> keySerializer,
TypeSerializer<?> valueSerializer)
Deprecated.
|
PerWindowStateDataViewStore(KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> windowSerializer,
RuntimeContext runtimeContext) |
Modifier and Type | Field and Description |
---|---|
protected TypeSerializer<RowData> |
AbstractWindowAggProcessor.accSerializer |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<Long> |
AbstractWindowAggProcessor.createWindowSerializer() |
Constructor and Description |
---|
AbstractWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler,
WindowBuffer.Factory bufferFactory,
SliceAssigner sliceAssigner,
TypeSerializer<RowData> accSerializer,
java.time.ZoneId shiftTimeZone) |
SliceSharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler,
WindowBuffer.Factory bufferFactory,
SliceSharedAssigner sliceAssigner,
TypeSerializer<RowData> accSerializer,
int indexOfCountStar,
java.time.ZoneId shiftTimeZone) |
SliceUnsharedWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<Long> genAggsHandler,
WindowBuffer.Factory windowBufferFactory,
SliceUnsharedAssigner sliceAssigner,
TypeSerializer<RowData> accSerializer,
java.time.ZoneId shiftTimeZone) |
Constructor and Description |
---|
ProcTimeMiniBatchDeduplicateKeepFirstRowFunction(TypeSerializer<RowData> serializer,
long stateRetentionTime) |
ProcTimeMiniBatchDeduplicateKeepLastRowFunction(InternalTypeInfo<RowData> typeInfo,
TypeSerializer<RowData> serializer,
long stateRetentionTime,
boolean generateUpdateBefore,
boolean generateInsert,
boolean inputInsertOnly,
GeneratedRecordEqualiser genRecordEqualiser) |
RowTimeMiniBatchDeduplicateFunction(InternalTypeInfo<RowData> typeInfo,
TypeSerializer<RowData> serializer,
long minRetentionTime,
int rowtimeIndex,
boolean generateUpdateBefore,
boolean generateInsert,
boolean keepLastRow) |
RowTimeMiniBatchLatestChangeDeduplicateFunction(InternalTypeInfo<RowData> typeInfo,
TypeSerializer<RowData> serializer,
long minRetentionTime,
int rowtimeIndex,
boolean generateUpdateBefore,
boolean generateInsert,
boolean keepLastRow) |
Constructor and Description |
---|
Factory(TypeSerializer<RowData> recordSerializer,
int rowtimeIndex,
boolean keepLastRow) |
RowTimeDeduplicateRecordsCombiner(WindowTimerService<Long> timerService,
StateKeyContext keyContext,
WindowValueState<Long> dataState,
int rowtimeIndex,
boolean keepLastRow,
TypeSerializer<RowData> recordSerializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<Long> |
RowTimeWindowDeduplicateProcessor.createWindowSerializer() |
Constructor and Description |
---|
RowTimeWindowDeduplicateProcessor(TypeSerializer<RowData> inputSerializer,
WindowBuffer.Factory bufferFactory,
int windowEndIndex,
java.time.ZoneId shiftTimeZone) |
Modifier and Type | Method and Description |
---|---|
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.leftSerializer(TypeSerializer<RowData> leftSerializer) |
WindowJoinOperatorBuilder |
WindowJoinOperatorBuilder.rightSerializer(TypeSerializer<RowData> rightSerializer) |
Constructor and Description |
---|
CopyingFirstInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator,
TypeSerializer<RowData> serializer) |
CopyingOneInputStreamOperatorOutput(OneInputStreamOperator<RowData,RowData> operator,
TypeSerializer<RowData> serializer) |
CopyingSecondInputOfTwoInputStreamOperatorOutput(TwoInputStreamOperator<RowData,RowData,RowData> operator,
TypeSerializer<RowData> serializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<W> |
PythonStreamGroupWindowAggregateOperator.getWindowSerializer() |
Constructor and Description |
---|
Factory(GeneratedRecordComparator genSortKeyComparator,
RowDataKeySelector sortKeySelector,
TypeSerializer<RowData> recordSerializer,
long topN) |
TopNRecordsCombiner(WindowTimerService<Long> timerService,
StateKeyContext keyContext,
WindowMapState<Long,List<RowData>> dataState,
Comparator<RowData> sortKeyComparator,
KeySelector<RowData,RowData> sortKeySelector,
long topN,
TypeSerializer<RowData> recordSerializer,
boolean isEventTime) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<Long> |
WindowRankProcessor.createWindowSerializer() |
Constructor and Description |
---|
WindowRankProcessor(TypeSerializer<RowData> inputSerializer,
GeneratedRecordComparator genSortKeyComparator,
TypeSerializer<RowData> sortKeySerializer,
WindowBuffer.Factory bufferFactory,
long rankStart,
long rankEnd,
boolean outputRankNumber,
int windowEndIndex,
java.time.ZoneId shiftTimeZone) |
WindowRankProcessor(TypeSerializer<RowData> inputSerializer,
GeneratedRecordComparator genSortKeyComparator,
TypeSerializer<RowData> sortKeySerializer,
WindowBuffer.Factory bufferFactory,
long rankStart,
long rankEnd,
boolean outputRankNumber,
int windowEndIndex,
java.time.ZoneId shiftTimeZone) |
Constructor and Description |
---|
SinkUpsertMaterializer(StateTtlConfig ttlConfig,
TypeSerializer<RowData> serializer,
GeneratedRecordEqualiser generatedEqualiser) |
Constructor and Description |
---|
ChannelReaderKVInputViewIterator(AbstractChannelReaderInputView inView,
List<MemorySegment> freeMemTarget,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer) |
ChannelReaderKVInputViewIterator(AbstractChannelReaderInputView inView,
List<MemorySegment> freeMemTarget,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer) |
Modifier and Type | Class and Description |
---|---|
static class |
CountWindow.Serializer
The serializer used to write the CountWindow type.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<CountWindow> |
CountSlidingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<TimeWindow> |
SessionWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<CountWindow> |
CountTumblingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<TimeWindow> |
CumulativeWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<TimeWindow> |
TumblingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
TypeSerializer<TimeWindow> |
SlidingWindowAssigner.getWindowSerializer(ExecutionConfig executionConfig) |
abstract TypeSerializer<W> |
WindowAssigner.getWindowSerializer(ExecutionConfig executionConfig)
Returns a
TypeSerializer for serializing windows that are assigned by this WindowAssigner . |
Constructor and Description |
---|
MergingWindowProcessFunction(MergingWindowAssigner<W> windowAssigner,
NamespaceAggsHandleFunctionBase<W> windowAggregator,
TypeSerializer<W> windowSerializer,
long allowedLateness) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<W> |
SlicingWindowProcessor.createWindowSerializer()
Returns the serializer of the window type.
|
Modifier and Type | Method and Description |
---|---|
static BeamTablePythonFunctionRunner |
BeamTablePythonFunctionRunner.stateful(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
static BeamTablePythonFunctionRunner |
BeamTablePythonFunctionRunner.stateful(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Constructor and Description |
---|
BeamTablePythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
BeamTablePythonFunctionRunner(String taskName,
ProcessPythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRowDataSerializer<T extends RowData>
Row serializer, provided paged serialize paged method.
|
class |
ArrayDataSerializer
Serializer for
ArrayData . |
class |
BinaryRowDataSerializer
Serializer for
BinaryRowData . |
class |
DecimalDataSerializer
Serializer for
DecimalData . |
class |
ExternalSerializer<I,E>
A serializer that can serialize and deserialize all data structures defined by a
DataType . |
class |
LinkedListSerializer<T>
A serializer for
LinkedList . |
class |
MapDataSerializer
Serializer for
MapData . |
class |
PagedTypeSerializer<T>
A type serializer which provides paged serialize and deserialize methods.
|
class |
RawValueDataSerializer<T>
Serializer for
RawValueData . |
class |
RowDataSerializer
Serializer for
RowData . |
class |
SortedMapSerializer<K,V>
A serializer for
SortedMap . |
class |
StringDataSerializer
Serializer for
StringData . |
class |
TimestampDataSerializer
Serializer for
TimestampData . |
class |
WindowKeySerializer
Serializer for
WindowKey which is composite with a BinaryRowData and a long
value. |
Modifier and Type | Method and Description |
---|---|
static <T> TypeSerializer<T> |
InternalSerializers.create(LogicalType type)
Creates a
TypeSerializer for internal data structures of the given LogicalType . |
TypeSerializer<T> |
ExternalTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<SortedMap<K,V>> |
SortedMapTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<StringData> |
StringDataTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<T> |
InternalTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<TimestampData> |
TimestampDataTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<DecimalData> |
DecimalDataTypeInfo.createSerializer(ExecutionConfig config) |
TypeSerializer<SortedMap<K,V>> |
SortedMapSerializer.duplicate() |
TypeSerializer<E> |
ExternalSerializer.duplicate() |
TypeSerializer<BinaryRowData> |
BinaryRowDataSerializer.duplicate() |
TypeSerializer<WindowKey> |
WindowKeySerializer.duplicate() |
TypeSerializer<MapData> |
MapDataSerializer.duplicate() |
TypeSerializer<TimestampData> |
TimestampDataSerializer.duplicate() |
TypeSerializer<RowData> |
RowDataSerializer.duplicate() |
TypeSerializer<LinkedList<T>> |
LinkedListSerializer.duplicate() |
TypeSerializer<ArrayData> |
ArrayDataSerializer.duplicate() |
TypeSerializer<T> |
LinkedListSerializer.getElementSerializer()
Gets the serializer for the elements of the list.
|
TypeSerializer |
ArrayDataSerializer.getEleSer() |
TypeSerializer<T> |
RawValueDataSerializer.getInnerSerializer() |
TypeSerializer |
MapDataSerializer.getKeySerializer() |
protected TypeSerializer<?>[] |
ExternalSerializer.ExternalSerializerSnapshot.getNestedSerializers(ExternalSerializer<I,E> outerSerializer) |
protected TypeSerializer<?>[] |
LinkedListSerializer.LinkedListSerializerSnapshot.getNestedSerializers(LinkedListSerializer<T> outerSerializer) |
protected TypeSerializer<?>[] |
RawValueDataSerializer.RawValueDataSerializerSnapshot.getNestedSerializers(RawValueDataSerializer<T> outerSerializer) |
protected TypeSerializer<?>[] |
WindowKeySerializer.WindowKeySerializerSnapshot.getNestedSerializers(WindowKeySerializer outerSerializer) |
TypeSerializer |
MapDataSerializer.getValueSerializer() |
TypeSerializer<BinaryRowData> |
BinaryRowDataSerializer.BinaryRowDataSerializerSnapshot.restoreSerializer() |
TypeSerializer<MapData> |
MapDataSerializer.MapDataSerializerSnapshot.restoreSerializer() |
TypeSerializer<TimestampData> |
TimestampDataSerializer.TimestampDataSerializerSnapshot.restoreSerializer() |
TypeSerializer<ArrayData> |
ArrayDataSerializer.ArrayDataSerializerSnapshot.restoreSerializer() |
TypeSerializer<DecimalData> |
DecimalDataSerializer.DecimalSerializerSnapshot.restoreSerializer() |
static TypeSerializer |
PythonTypeUtils.toInternalSerializer(LogicalType logicalType) |
TypeSerializer<T> |
InternalTypeInfo.toSerializer() |
Constructor and Description |
---|
LinkedListSerializer(TypeSerializer<T> elementSerializer)
Creates a list serializer that uses the given serializer to serialize the list's elements.
|
LinkedListSerializer(TypeSerializer<T> elementSerializer,
boolean hasNullMask) |
RawValueDataSerializer(TypeSerializer<T> serializer) |
RowDataSerializer(LogicalType[] types,
TypeSerializer<?>[] fieldSerializers) |
SortedMapSerializer(Comparator<K> comparator,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Constructor with given comparator, and the serializers for the keys and values in the map.
|
SortedMapSerializer(Comparator<K> comparator,
TypeSerializer<K> keySerializer,
TypeSerializer<V> valueSerializer)
Constructor with given comparator, and the serializers for the keys and values in the map.
|
Modifier and Type | Class and Description |
---|---|
class |
TimeSerializer
Uses int instead of long as the serialized value.
|
class |
TimestampSerializer
Uses similar serialization/deserialization of SqlTimestampSerializer to serialize Timestamp.
|
Modifier and Type | Method and Description |
---|---|
TypeSerializer<MapData> |
MapDataSerializer.duplicate() |
TypeSerializer<ArrayData> |
ArrayDataSerializer.duplicate() |
TypeSerializer<DecimalData> |
DecimalDataSerializer.duplicate() |
TypeSerializer<MapData> |
MapDataSerializer.BaseMapSerializerSnapshot.restoreSerializer() |
TypeSerializer<Timestamp> |
TimestampSerializer.TimestampSerializerSnapshot.restoreSerializer() |
TypeSerializer<ArrayData> |
ArrayDataSerializer.ArrayDataSerializerSnapshot.restoreSerializer() |
TypeSerializer<DecimalData> |
DecimalDataSerializer.DecimalSerializerSnapshot.restoreSerializer() |
Modifier and Type | Method and Description |
---|---|
TypeSerializerSchemaCompatibility<ArrayData> |
ArrayDataSerializer.ArrayDataSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<ArrayData> newSerializer) |
TypeSerializerSchemaCompatibility<DecimalData> |
DecimalDataSerializer.DecimalSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<DecimalData> newSerializer) |
TypeSerializerSchemaCompatibility<MapData> |
MapDataSerializer.BaseMapSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<MapData> newSerializer) |
TypeSerializerSchemaCompatibility<RowData> |
RowDataSerializer.RowDataSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<RowData> newSerializer) |
TypeSerializerSchemaCompatibility<Timestamp> |
TimestampSerializer.TimestampSerializerSnapshot.resolveSchemaCompatibility(TypeSerializer<Timestamp> newSerializer) |
Constructor and Description |
---|
ArrayDataSerializer(LogicalType eleType,
TypeSerializer elementTypeSerializer) |
MapDataSerializer(LogicalType keyType,
LogicalType valueType,
TypeSerializer keyTypeSerializer,
TypeSerializer valueTypeSerializer) |
MapDataSerializer(LogicalType keyType,
LogicalType valueType,
TypeSerializer keyTypeSerializer,
TypeSerializer valueTypeSerializer) |
RowDataSerializer(LogicalType[] types,
TypeSerializer[] fieldSerializers) |
Constructor and Description |
---|
BytesMap(Object owner,
MemoryManager memoryManager,
long memorySize,
TypeSerializer<K> keySerializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
RawType.getTypeSerializer() |
Constructor and Description |
---|
RawType(boolean isNullable,
Class<T> clazz,
TypeSerializer<T> serializer) |
RawType(Class<T> clazz,
TypeSerializer<T> serializer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<T> |
TimeIntervalTypeInfo.createSerializer(ExecutionConfig config)
Deprecated.
|
TypeSerializer<Timestamp> |
TimeIndicatorTypeInfo.createSerializer(ExecutionConfig executionConfig)
Deprecated.
|
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–2023 The Apache Software Foundation. All rights reserved.