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 |
UnmodifiableConfiguration
Unmodifiable version of the Configuration class.
|
Modifier and Type | Class and Description |
---|---|
class |
PulsarConfiguration
An unmodifiable
Configuration for Pulsar. |
Modifier and Type | Class and Description |
---|---|
class |
SinkConfiguration
The configured class for pulsar sink.
|
Modifier and Type | Class and Description |
---|---|
class |
SourceConfiguration
The configuration class for pulsar source.
|
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 |
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 |
EndOfData
This event indicates there will be no more data records in a subpartition.
|
class |
EndOfPartitionEvent
This event marks a subpartition as fully consumed.
|
class |
EndOfSuperstepEvent
Marks the end of a superstep of one particular iteration superstep.
|
class |
EventAnnouncement
EventAnnouncement is announcing presence or receiving of an AbstractEvent . |
class |
SubtaskConnectionDescriptor
An event that is used to (de)multiplex old channels over the same new channel.
|
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.
|
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 | Method and Description |
---|---|
static ByteBuffer |
RecordWriter.serializeRecord(DataOutputSerializer serializer,
IOReadableWritable record) |
Modifier and Type | Class and Description |
---|---|
class |
EndOfChannelStateEvent
Marks the end of recovered state of
RecoveredInputChannel of this subtask or ResultSubpartition on the
upstream. |
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–2022 The Apache Software Foundation. All rights reserved.