Package | Description |
---|---|
org.apache.flink.runtime.operators.shipping | |
org.apache.flink.runtime.operators.util | |
org.apache.flink.runtime.plugable | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.partitioner | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Class and Description |
---|
SerializationDelegate
The serialization delegate exposes an arbitrary element as a
IOReadableWritable for
serialization, with the help of a type serializer. |
Class and Description |
---|
DeserializationDelegate
The deserialization delegate is used during deserialization to read an arbitrary element as if it implements
IOReadableWritable , with the help of a type serializer. |
Class and Description |
---|
DeserializationDelegate
The deserialization delegate is used during deserialization to read an arbitrary element as if it implements
IOReadableWritable , with the help of a type serializer. |
Class and Description |
---|
SerializationDelegate
The serialization delegate exposes an arbitrary element as a
IOReadableWritable for
serialization, with the help of a type serializer. |
Class and Description |
---|
SerializationDelegate
The serialization delegate exposes an arbitrary element as a
IOReadableWritable for
serialization, with the help of a type serializer. |
Class and Description |
---|
SerializationDelegate
The serialization delegate exposes an arbitrary element as a
IOReadableWritable for
serialization, with the help of a type serializer. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.