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 |
---|---|
class |
CompositeTypeSerializerConfigSnapshot
A
TypeSerializerConfigSnapshot for serializers that has multiple nested serializers. |
class |
GenericTypeSerializerConfigSnapshot<T>
Configuration snapshot for serializers for generic types.
|
class |
ParameterlessTypeSerializerConfig
A base class for
TypeSerializerConfigSnapshot s that do not have any parameters. |
class |
TypeSerializerConfigSnapshot
A
TypeSerializerConfigSnapshot is a point-in-time view of a TypeSerializer's configuration. |
static class |
TypeSerializerSerializationUtil.TypeSerializerSerializationProxy<T>
Utility serialization proxy for a
TypeSerializer . |
Modifier and Type | Class and Description |
---|---|
class |
CollectionSerializerConfigSnapshot<T>
Configuration snapshot of a serializer for collection types.
|
static class |
EnumSerializer.EnumSerializerConfigSnapshot<T extends Enum<T>>
Configuration snapshot of a serializer for enumerations.
|
class |
GenericArraySerializerConfigSnapshot<C>
Point-in-time configuration of a
GenericArraySerializer . |
class |
MapSerializerConfigSnapshot<K,V>
Configuration snapshot for serializers of maps, containing the
configuration snapshot of its key serializer and value serializer.
|
Modifier and Type | Class and Description |
---|---|
static class |
AvroSerializer.AvroSerializerConfigSnapshot<T>
Deprecated.
Config snapshot for this serializer.
|
static class |
CopyableValueSerializer.CopyableValueSerializerConfigSnapshot<T extends CopyableValue<T>> |
class |
EitherSerializerConfigSnapshot<L,R>
Configuration snapshot for serializers of the
Either type,
containing configuration snapshots of the Left and Right serializers. |
class |
KryoRegistrationSerializerConfigSnapshot<T>
Configuration snapshot base class for serializers that use Kryo for serialization.
|
static class |
PojoSerializer.PojoSerializerConfigSnapshot<T> |
static class |
RowSerializer.RowSerializerConfigSnapshot |
class |
TupleSerializerConfigSnapshot<T>
Snapshot of a tuple serializer's configuration.
|
static class |
ValueSerializer.ValueSerializerConfigSnapshot<T extends Value> |
static class |
WritableSerializer.WritableSerializerConfigSnapshot<T extends org.apache.hadoop.io.Writable>
The config snapshot for this serializer.
|
Modifier and Type | Class and Description |
---|---|
static class |
KryoSerializer.KryoSerializerConfigSnapshot<T> |
Modifier and Type | Class and Description |
---|---|
class |
ScalaOptionSerializerConfigSnapshot<E>
A
TypeSerializerConfigSnapshot for the Scala OptionSerializer . |
class |
ScalaTrySerializerConfigSnapshot<E>
A
TypeSerializerConfigSnapshot for the Scala TrySerializer . |
class |
TraversableSerializerConfigSnapshot<E>
A
TypeSerializerConfigSnapshot for the Scala TraversableSerializer . |
Modifier and Type | Class and Description |
---|---|
static class |
NFA.NFASerializerConfigSnapshot<T>
The
TypeSerializerConfigSnapshot serializer configuration to be stored with the managed state. |
static class |
SharedBuffer.SharedBufferSerializerConfigSnapshot<K,V>
The
TypeSerializerConfigSnapshot serializer configuration to be stored with the managed state. |
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 |
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 |
---|---|
static class |
AvroSerializer.AvroSchemaSerializerConfigSnapshot
A config snapshot for the Avro Serializer that stores the Avro Schema to check compatibility.
|
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
TaskManager 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> |
interface |
Reader<T extends IOReadableWritable>
A record-oriented reader for immutable record types.
|
class |
RecordReader<T extends IOReadableWritable> |
Modifier and Type | Class and Description |
---|---|
class |
AdaptiveSpanningRecordDeserializer<T extends IOReadableWritable> |
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.setNextBuffer(Buffer) . |
class |
SpillingAdaptiveSpanningRecordDeserializer<T extends IOReadableWritable> |
Modifier and Type | Interface and Description |
---|---|
interface |
ChannelSelector<T extends IOReadableWritable>
The
ChannelSelector determines to which logical channels a record
should be written to. |
class |
RecordWriter<T extends IOReadableWritable>
A record-oriented runtime result writer.
|
class |
RoundRobinChannelSelector<T extends IOReadableWritable>
This is the default implementation of the
ChannelSelector interface. |
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>
The
TypeSerializerConfigSnapshot for the UnionSerializer . |
Modifier and Type | Class and Description |
---|---|
static class |
TwoPhaseCommitSinkFunction.StateSerializerConfigSnapshot<TXN,CONTEXT>
TypeSerializerConfigSnapshot for sink state. |
Modifier and Type | Class and Description |
---|---|
class |
InternalTimerServiceSerializationProxy<K,N>
Serialization proxy for the timer services for a given key-group.
|
Modifier and Type | Class and Description |
---|---|
class |
StreamRecordWriter<T extends IOReadableWritable>
This record writer keeps data in buffers at most for a certain timeout.
|
Modifier and Type | Class and Description |
---|---|
static class |
StreamElementSerializer.StreamElementSerializerConfigSnapshot<T>
Configuration snapshot specific to the
StreamElementSerializer . |
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–2018 The Apache Software Foundation. All rights reserved.