Modifier and Type | Class and Description |
---|---|
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 |
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 | Method and Description |
---|---|
protected boolean |
AbstractReader.handleEvent(AbstractEvent event)
Handles the event and returns whether the reader reached an end-of-stream event (either the
end of the whole stream or the end of an superstep).
|
Modifier and Type | Method and Description |
---|---|
static AbstractEvent |
EventSerializer.fromBuffer(Buffer buffer,
ClassLoader classLoader) |
static AbstractEvent |
EventSerializer.fromSerializedEvent(ByteBuffer buffer,
ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
static Buffer |
EventSerializer.toBuffer(AbstractEvent event) |
static ByteBuffer |
EventSerializer.toSerializedEvent(AbstractEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
RecordWriter.broadcastEvent(AbstractEvent event) |
void |
ResultPartitionWriter.writeEvent(AbstractEvent event,
int targetChannel) |
void |
ResultPartitionWriter.writeEventToAllChannels(AbstractEvent event) |
Modifier and Type | Method and Description |
---|---|
AbstractEvent |
BufferOrEvent.getEvent() |
Constructor and Description |
---|
BufferOrEvent(AbstractEvent event,
int channelIndex) |
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 | Method and Description |
---|---|
void |
RecordWriterOutput.broadcastEvent(AbstractEvent barrier) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.