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 |
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 | Method and Description |
---|---|
AbstractEvent |
EventAnnouncement.getAnnouncedEvent() |
Constructor and Description |
---|
EventAnnouncement(AbstractEvent announcedEvent,
int sequenceNumber) |
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,
boolean hasPriority) |
static BufferConsumer |
EventSerializer.toBufferConsumer(AbstractEvent event,
boolean hasPriority) |
static ByteBuffer |
EventSerializer.toSerializedEvent(AbstractEvent event) |
Modifier and Type | Method and Description |
---|---|
void |
NonRecordWriter.broadcastEvent(AbstractEvent event) |
void |
RecordWriter.broadcastEvent(AbstractEvent event) |
void |
MultipleRecordWriters.broadcastEvent(AbstractEvent event) |
void |
SingleRecordWriter.broadcastEvent(AbstractEvent event) |
void |
RecordWriterDelegate.broadcastEvent(AbstractEvent event)
Broadcasts the provided event to all the internal record writer instances.
|
void |
RecordWriter.broadcastEvent(AbstractEvent event,
boolean isPriorityEvent) |
void |
ResultPartitionWriter.broadcastEvent(AbstractEvent event,
boolean isPriorityEvent)
Writes the given
AbstractEvent to all channels. |
Modifier and Type | Method and Description |
---|---|
static Buffer.DataType |
Buffer.DataType.getDataType(AbstractEvent event,
boolean hasPriority) |
Modifier and Type | Method and Description |
---|---|
void |
SortMergeResultPartition.broadcastEvent(AbstractEvent event,
boolean isPriorityEvent) |
void |
BufferWritingResultPartition.broadcastEvent(AbstractEvent event,
boolean isPriorityEvent) |
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 | Method and Description |
---|---|
AbstractEvent |
BufferOrEvent.getEvent() |
protected AbstractEvent |
ChannelStatePersister.parseEvent(Buffer buffer)
Parses the buffer as an event and returns the
CheckpointBarrier if the event is
indeed a barrier or returns null in all other cases. |
Constructor and Description |
---|
BufferOrEvent(AbstractEvent event,
boolean hasPriority,
InputChannelInfo channelInfo,
boolean moreAvailable,
int size,
boolean morePriorityEvents) |
BufferOrEvent(AbstractEvent event,
InputChannelInfo channelInfo) |
Modifier and Type | Method and Description |
---|---|
void |
HsResultPartition.broadcastEvent(AbstractEvent event,
boolean isPriorityEvent) |
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 | Method and Description |
---|---|
void |
RecordWriterOutput.broadcastEvent(AbstractEvent event,
boolean isPriorityEvent) |
Modifier and Type | Method and Description |
---|---|
void |
OperatorChain.broadcastEvent(AbstractEvent event) |
void |
OperatorChain.broadcastEvent(AbstractEvent event,
boolean isPriorityEvent) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.