Modifier and Type | Class and Description |
---|---|
class |
JobID
Unique (at least statistically unique) identifier for a Flink Job.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DataDistribution |
Modifier and Type | Class and Description |
---|---|
class |
SimpleDistribution |
class |
SimpleIntegerDistribution |
class |
UniformDoubleDistribution |
class |
UniformIntegerDistribution |
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 |
Modifier and Type | Class and Description |
---|---|
class |
Configuration
Lightweight configuration object which stores key/value pairs.
|
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 |
---|---|
static class |
ALS.OutLinks |
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 |
ExecutionAttemptID
Unique identifier for the attempt to execute a tasks.
|
Modifier and Type | Class and Description |
---|---|
class |
InstanceConnectionInfo
This class encapsulates the connection information of a TaskManager.
|
class |
InstanceID
Class for statistically unique instance IDs.
|
Modifier and Type | Class and Description |
---|---|
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> |
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 |
InputChannelID |
Modifier and Type | Class and Description |
---|---|
class |
AllWorkersDoneEvent |
class |
IterationEventWithAggregators |
class |
TerminationEvent
Signals that the iteration is completely executed, participating tasks must terminate now
|
class |
WorkerDoneEvent |
Modifier and Type | Class and Description |
---|---|
class |
IntermediateDataSetID |
class |
IntermediateResultPartitionID |
class |
JobVertexID
A class for statistically unique job vertex IDs.
|
Modifier and Type | Class and Description |
---|---|
class |
ResourceId |
Modifier and Type | Class and Description |
---|---|
static class |
TaskConfig.DelegatingConfiguration
A configuration that manages a subset of keys with a common prefix from a given configuration.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DeserializationDelegate<T> |
Modifier and Type | Class and Description |
---|---|
class |
NonReusingDeserializationDelegate<T> |
class |
ReusingDeserializationDelegate<T> |
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 |
SerializableArrayList<E extends IOReadableWritable>
This class extends a standard
ArrayList by implementing the
IOReadableWritable interface. |
class |
SerializableHashMap<K extends IOReadableWritable,V extends IOReadableWritable>
This class extends a standard
HashMap by implementing the
IOReadableWritable interface. |
class |
SerializableHashMap<K extends IOReadableWritable,V extends IOReadableWritable>
This class extends a standard
HashMap by implementing the
IOReadableWritable interface. |
class |
SerializableHashSet<T extends IOReadableWritable>
This class extends a standard
HashSet by implementing the
IOReadableWritable interface. |
Modifier and Type | Class and Description |
---|---|
class |
SerializableArrayList<E extends IOReadableWritable>
This class extends a standard
ArrayList by implementing the
IOReadableWritable interface. |
class |
SerializableHashMap<K extends IOReadableWritable,V extends IOReadableWritable>
This class extends a standard
HashMap by implementing the
IOReadableWritable interface. |
class |
SerializableHashSet<T extends IOReadableWritable>
This class extends a standard
HashSet by implementing the
IOReadableWritable interface. |
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 | 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 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 |
Pair<U extends Key<U>,V extends Key<V>>
Generic pair base type.
|
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 | Class and Description |
---|---|
class |
AbstractID
A statistically unique identification number.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.