Modifier and Type | Interface and Description |
---|---|
interface |
DataDistribution |
Modifier and Type | Class and Description |
---|---|
class |
SerializedInputFormat<T extends IOReadableWritable>
Reads elements by deserializing them with their regular serialization/deserialization functionality.
|
class |
SerializedOutputFormat<T extends IOReadableWritable>
Stores elements by serializing them with their regular serialization/deserialization functionality.
|
Modifier and Type | Class and Description |
---|---|
class |
BlockInfo
A block of 24 bytes written at the end of a block in a binary file, and containing
i) the number of records in the block, ii) the accumulated number of records, and
iii) the offset of the first record in the block.
|
Modifier and Type | Class and Description |
---|---|
static class |
CompositeSerializer.ConfigSnapshot
Deprecated.
this snapshot class is no longer in use by any serializers, and is only
kept around for backwards compatibility. All subclass serializers should
have their own serializer snapshot classes.
|
class |
CompositeTypeSerializerConfigSnapshot<T>
A
TypeSerializerConfigSnapshot for serializers that has multiple nested serializers. |
class |
GenericTypeSerializerConfigSnapshot<T>
Configuration snapshot for serializers for generic types.
|
class |
ParameterlessTypeSerializerConfig<T>
Deprecated.
this snapshot class is no longer used by any serializers, and is maintained only
for backward compatibility reasons. It is fully replaced by
SimpleTypeSerializerSnapshot . |
class |
TypeSerializerConfigSnapshot<T>
Deprecated.
|
static class |
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy<T>
Deprecated.
Utility serialization proxy for a
TypeSerializer . |
Modifier and Type | Class and Description |
---|---|
class |
CollectionSerializerConfigSnapshot<C extends Collection<T>,T>
Deprecated.
this snapshot class should no longer be used by any serializers as their snapshot.
|
static class |
EnumSerializer.EnumSerializerConfigSnapshot<T extends Enum<T>>
Deprecated.
|
class |
MapSerializerConfigSnapshot<K,V>
Deprecated.
this snapshot class should not be used by any serializer anymore.
|
Modifier and Type | Class and Description |
---|---|
static class |
CopyableValueSerializer.CopyableValueSerializerConfigSnapshot<T extends CopyableValue<T>>
Deprecated.
|
class |
EitherSerializerConfigSnapshot<L,R>
Deprecated.
|
class |
KryoRegistrationSerializerConfigSnapshot<T>
Configuration snapshot base class for serializers that use Kryo for serialization.
|
static class |
NullableSerializer.NullableSerializerConfigSnapshot<T>
Deprecated.
this snapshot class is no longer in use, and is maintained only for
backwards compatibility purposes. It is fully replaced
by
NullableSerializer.NullableSerializerSnapshot . |
static class |
PojoSerializer.PojoSerializerConfigSnapshot<T>
Deprecated.
This snapshot class is no longer being used.
It has been fully replaced by
PojoSerializerSnapshot . |
static class |
RowSerializer.RowSerializerConfigSnapshot
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards compatibility.
It is fully replaced by
RowSerializer.RowSerializerSnapshot . |
class |
TupleSerializerConfigSnapshot<T>
Snapshot of a tuple serializer's configuration.
|
static class |
ValueSerializer.ValueSerializerConfigSnapshot<T extends Value>
Deprecated.
|
static class |
WritableSerializer.WritableSerializerConfigSnapshot<T extends org.apache.hadoop.io.Writable>
Deprecated.
This class is no longer used as a snapshot for any serializer.
It is fully replaced by
WritableSerializer.WritableSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
static class |
KryoSerializer.KryoSerializerConfigSnapshot<T>
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ScalaOptionSerializerConfigSnapshot<E>
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards compatibility.
It is fully replaced by
ScalaOptionSerializerSnapshot . |
class |
ScalaTrySerializerConfigSnapshot<E>
Deprecated.
|
class |
TraversableSerializerConfigSnapshot<T extends scala.collection.TraversableOnce<E>,E>
Deprecated.
This is being replaced with
TraversableSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
static class |
NFA.NFASerializerConfigSnapshot<T>
Deprecated.
This snapshot class is no longer in use, and only maintained for backwards compatibility
purposes. It is fully replaced by
NFA.MigratedNFASerializerSnapshot . |
static class |
SharedBuffer.SharedBufferSerializerConfigSnapshot<K,V>
Deprecated.
This snapshot class is no longer in use, and only maintained for backwards compatibility
purposes. It is fully replaced by
SharedBuffer.SharedBufferSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
class |
Configuration
Lightweight configuration object which stores key/value pairs.
|
class |
DelegatingConfiguration
A configuration that manages a subset of keys with a common prefix from a given configuration.
|
class |
ReadableConfigToConfigurationAdapter
A simple adapter between
ReadableConfig and Configuration . |
class |
UnmodifiableConfiguration
Unmodifiable version of the Configuration class.
|
Modifier and Type | Class and Description |
---|---|
class |
Path
Names a file or directory in a
FileSystem . |
Modifier and Type | Class and Description |
---|---|
class |
PostVersionedIOReadableWritable
A
VersionedIOReadableWritable which allows to differentiate whether the previous
data was versioned with a VersionedIOReadableWritable . |
class |
VersionedIOReadableWritable
This is the abstract base class for
IOReadableWritable which allows to differentiate between serialization
versions. |
Modifier and Type | Class and Description |
---|---|
class |
LongValueWithProperHashCode
Fix for
LongValue.hashCode() . |
Modifier and Type | Interface and Description |
---|---|
interface |
ValueArray<T>
Basic interface for array types which reuse objects during serialization.
|
Modifier and Type | Class and Description |
---|---|
class |
ByteValueArray
An array of
ByteValue . |
class |
CharValueArray
An array of
CharValue . |
class |
DoubleValueArray
An array of
DoubleValue . |
class |
FloatValueArray
An array of
FloatValue . |
class |
IntValueArray
An array of
IntValue . |
class |
LongValueArray
An array of
LongValue . |
class |
NullValueArray
An array of
NullValue . |
class |
ShortValueArray
An array of
ShortValue . |
class |
StringValueArray
An array of
StringValue . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEvent
This type of event can be used to exchange notification messages between
different
TaskExecutor objects at runtime using the communication
channels. |
class |
RuntimeEvent
Subclasses of this event are recognized as events exchanged by the core runtime.
|
class |
TaskEvent
Subclasses of this event are recognized as custom events that are not part of the core
flink runtime.
|
Modifier and Type | Class and Description |
---|---|
class |
CancelCheckpointMarker
The CancelCheckpointMarker travels through the data streams, similar to the
CheckpointBarrier ,
but signals that a certain checkpoint should be canceled. |
class |
CheckpointBarrier
Checkpoint barriers are used to align checkpoints throughout the streaming topology.
|
class |
EndOfPartitionEvent
This event marks a subpartition as fully consumed.
|
class |
EndOfSuperstepEvent
Marks the end of a superstep of one particular iteration superstep.
|
Modifier and Type | Interface and Description |
---|---|
interface |
MutableReader<T extends IOReadableWritable>
A record-oriented reader for mutable record types.
|
class |
MutableRecordReader<T extends IOReadableWritable>
Implementation of the record-oriented reader for mutable record types.
|
interface |
Reader<T extends IOReadableWritable>
A record-oriented reader for immutable record types.
|
class |
RecordReader<T extends IOReadableWritable>
Record oriented reader for immutable types.
|
Modifier and Type | Interface and Description |
---|---|
interface |
RecordDeserializer<T extends IOReadableWritable>
Interface for turning sequences of memory segments into records.
|
interface |
RecordSerializer<T extends IOReadableWritable>
Interface for turning records into sequences of memory segments.
|
class |
SpanningRecordSerializer<T extends IOReadableWritable>
Record serializer which serializes the complete record to an intermediate
data serialization buffer and copies this buffer to target buffers
one-by-one using
SpanningRecordSerializer.copyToBufferBuilder(BufferBuilder) . |
class |
SpillingAdaptiveSpanningRecordDeserializer<T extends IOReadableWritable> |
Modifier and Type | Class and Description |
---|---|
class |
BroadcastRecordWriter<T extends IOReadableWritable>
A special record-oriented runtime result writer only for broadcast mode.
|
interface |
ChannelSelector<T extends IOReadableWritable>
The
ChannelSelector determines to which logical channels a record
should be written to. |
class |
ChannelSelectorRecordWriter<T extends IOReadableWritable>
A regular record-oriented runtime result writer.
|
class |
MultipleRecordWriters<T extends IOReadableWritable>
The specific delegate implementation for the multiple outputs case.
|
class |
NonRecordWriter<T extends IOReadableWritable>
The specific delegate implementation for the non output case like sink task.
|
class |
RecordWriter<T extends IOReadableWritable>
An abstract record-oriented runtime result writer.
|
class |
RecordWriterBuilder<T extends IOReadableWritable>
Utility class to encapsulate the logic of building a
RecordWriter instance. |
interface |
RecordWriterDelegate<T extends IOReadableWritable>
The record writer delegate provides the availability function for task processor, and it might represent
a single
RecordWriter or multiple RecordWriter instances in specific implementations. |
class |
RoundRobinChannelSelector<T extends IOReadableWritable>
This is the default implementation of the
ChannelSelector interface. |
class |
SingleRecordWriter<T extends IOReadableWritable>
The specific delegate implementation for the single output case.
|
Modifier and Type | Class and Description |
---|---|
class |
AllWorkersDoneEvent
Event sent by the
IterationSynchronizationSinkTask to each
IterationHead signaling to start a new superstep. |
class |
IterationEventWithAggregators
Base class for iteration
TaskEvent transmitting operator aggregators. |
class |
TerminationEvent
Signals that the iteration is completely executed, participating tasks must terminate now.
|
class |
WorkerDoneEvent
Completion event sent from each
IterationHead to the
IterationSynchronizationSinkTask . |
Modifier and Type | Interface and Description |
---|---|
interface |
DeserializationDelegate<T>
The deserialization delegate is used during deserialization to read an arbitrary element as if it implements
IOReadableWritable , with the help of a type serializer. |
Modifier and Type | Class and Description |
---|---|
class |
NonReusingDeserializationDelegate<T>
A
DeserializationDelegate that always creates a new instance upon deserialization. |
class |
ReusingDeserializationDelegate<T>
A
DeserializationDelegate that reuses an existing instance upon deserialization. |
class |
SerializationDelegate<T>
The serialization delegate exposes an arbitrary element as a
IOReadableWritable for
serialization, with the help of a type serializer. |
Modifier and Type | Class and Description |
---|---|
class |
KeyedBackendSerializationProxy<K>
Serialization proxy for all meta data in keyed state backends.
|
class |
OperatorBackendSerializationProxy
Serialization proxy for all meta data in operator state backends.
|
Modifier and Type | Class and Description |
---|---|
static class |
CoGroupedStreams.UnionSerializerConfigSnapshot<T1,T2>
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards compatibility.
It is fully replaced by
CoGroupedStreams.UnionSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
static class |
TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot<TXN,CONTEXT>
Deprecated.
this snapshot class is no longer in use, and is maintained only
for backwards compatibility purposes. It is fully replaced by
TwoPhaseCommitSinkFunction.StateSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
class |
InternalTimerServiceSerializationProxy<K>
Serialization proxy for the timer services for a given key-group.
|
static class |
TimerSerializer.TimerSerializerConfigSnapshot<K,N>
Deprecated.
this snapshot class is no longer in use, and is maintained only
for backwards compatibility purposes. It is fully replaced by
TimerSerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
static class |
IntervalJoinOperator.BufferSerializerConfigSnapshot<T>
Deprecated.
this snapshot class is no longer in use, and is maintained only for backwards compatibility.
It is fully replaced by
IntervalJoinOperator.BufferEntrySerializerSnapshot . |
Modifier and Type | Class and Description |
---|---|
static class |
StreamElementSerializer.StreamElementSerializerConfigSnapshot<T>
Deprecated.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CopyableValue<T>
Interface to be implemented by basic types that support to be copied efficiently.
|
interface |
Key<T>
Deprecated.
The Key type is a relict of a deprecated and removed API and will be removed
in future (2.0) versions as well.
|
interface |
NormalizableKey<T>
The base interface for normalizable keys.
|
interface |
ResettableValue<T extends Value> |
interface |
Value
Basic value interface for types that act as serializable values.
|
Modifier and Type | Class and Description |
---|---|
class |
BooleanValue
Boxed serializable and comparable boolean type, representing the primitive
type
boolean . |
class |
ByteValue
Boxed serializable and comparable byte type, representing the primitive
type
byte (signed 8 bit integer). |
class |
CharValue
Boxed serializable and comparable character type, representing the primitive
type
char . |
class |
DoubleValue
Boxed serializable and comparable double precision floating point type, representing the primitive
type
double . |
class |
FloatValue
Boxed serializable and comparable single precision floating point type, representing the primitive
type
float . |
class |
IntValue
Boxed serializable and comparable integer type, representing the primitive
type
int . |
class |
ListValue<V extends Value>
Generic list base type for PACT programs that implements the Value and List interfaces.
|
class |
LongValue
Boxed serializable and comparable long integer type, representing the primitive
type
long . |
class |
MapValue<K extends Value,V extends Value>
Generic map base type for PACT programs that implements the Value and Map interfaces.
|
class |
NullValue
Null base type for programs that implements the Key interface.
|
class |
Record
The Record represents a multi-valued data record.
|
class |
ShortValue
Boxed serializable and comparable short integer type, representing the primitive
type
short . |
class |
StringValue
Mutable string data type that implements the Key interface.
|
Modifier and Type | Method and Description |
---|---|
static <T extends IOReadableWritable> |
InstantiationUtil.createCopyWritable(T original)
Clones the given writable using the
serialization . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.