Package | Description |
---|---|
org.apache.flink.api.common.eventtime | |
org.apache.flink.api.connector.source | |
org.apache.flink.connector.testutils.source.reader | |
org.apache.flink.streaming.api.operators.source | |
org.apache.flink.streaming.connectors.kafka.internals | |
org.apache.flink.streaming.runtime.operators |
This package contains the operators that perform the stream transformations.
|
org.apache.flink.streaming.runtime.operators.util | |
org.apache.flink.table.runtime.generated |
Modifier and Type | Method and Description |
---|---|
WatermarkOutput |
WatermarkOutputMultiplexer.getDeferredOutput(String outputId)
Returns a deferred
WatermarkOutput for the given output ID. |
WatermarkOutput |
WatermarkOutputMultiplexer.getImmediateOutput(String outputId)
Returns an immediate
WatermarkOutput for the given output ID. |
Modifier and Type | Method and Description |
---|---|
void |
NoWatermarksGenerator.onEvent(E event,
long eventTimestamp,
WatermarkOutput output) |
void |
WatermarksWithIdleness.onEvent(T event,
long eventTimestamp,
WatermarkOutput output) |
void |
WatermarkGenerator.onEvent(T event,
long eventTimestamp,
WatermarkOutput output)
Called for every event, allows the watermark generator to examine and remember the event
timestamps, or to emit a watermark based on the event itself.
|
void |
BoundedOutOfOrdernessWatermarks.onEvent(T event,
long eventTimestamp,
WatermarkOutput output) |
void |
WatermarksWithIdleness.onPeriodicEmit(WatermarkOutput output) |
void |
WatermarkGenerator.onPeriodicEmit(WatermarkOutput output)
Called periodically, and might emit a new watermark, or not.
|
void |
NoWatermarksGenerator.onPeriodicEmit(WatermarkOutput output) |
void |
BoundedOutOfOrdernessWatermarks.onPeriodicEmit(WatermarkOutput output) |
Constructor and Description |
---|
WatermarkOutputMultiplexer(WatermarkOutput underlyingOutput)
Creates a new
WatermarkOutputMultiplexer that emits combined updates to the given
WatermarkOutput . |
Modifier and Type | Interface and Description |
---|---|
interface |
ReaderOutput<T>
The interface provided by the Flink runtime to the
SourceReader to emit records, and
optionally watermarks, to downstream operators for message processing. |
interface |
SourceOutput<T>
The
SourceOutput is the gateway for a SourceReader ) to emit the produced records
and watermarks. |
Modifier and Type | Class and Description |
---|---|
class |
SourceReaderTestBase.ValidatingSourceOutput
A source output that validates the output.
|
class |
TestingReaderOutput<E>
A
ReaderOutput for testing that collects the emitted records. |
Modifier and Type | Class and Description |
---|---|
class |
SourceOutputWithWatermarks<T>
Implementation of the SourceOutput.
|
class |
WatermarkToDataOutput
An adapter that exposes a
WatermarkOutput based on a PushingAsyncDataInput.DataOutput . |
Modifier and Type | Method and Description |
---|---|
static <E> SourceOutputWithWatermarks<E> |
SourceOutputWithWatermarks.createWithSeparateOutputs(PushingAsyncDataInput.DataOutput<E> recordsOutput,
WatermarkOutput onEventWatermarkOutput,
WatermarkOutput periodicWatermarkOutput,
TimestampAssigner<E> timestampAssigner,
WatermarkGenerator<E> watermarkGenerator)
Creates a new SourceOutputWithWatermarks that emits records to the given DataOutput and
watermarks to the different WatermarkOutputs.
|
Constructor and Description |
---|
SourceOutputWithWatermarks(PushingAsyncDataInput.DataOutput<T> recordsOutput,
WatermarkOutput onEventWatermarkOutput,
WatermarkOutput periodicWatermarkOutput,
TimestampAssigner<T> timestampAssigner,
WatermarkGenerator<T> watermarkGenerator)
Creates a new SourceOutputWithWatermarks that emits records to the given DataOutput and
watermarks to the (possibly different) WatermarkOutput.
|
Modifier and Type | Class and Description |
---|---|
class |
SourceContextWatermarkOutputAdapter<T>
A
WatermarkOutput that forwards calls to a SourceFunction.SourceContext . |
Modifier and Type | Field and Description |
---|---|
protected WatermarkOutput |
AbstractFetcher.watermarkOutput
Wrapper around our SourceContext for allowing the
WatermarkGenerator to emit watermarks and mark
idleness. |
Constructor and Description |
---|
KafkaTopicPartitionStateWithWatermarkGenerator(KafkaTopicPartition partition,
KPH kafkaPartitionHandle,
TimestampAssigner<T> timestampAssigner,
WatermarkGenerator<T> watermarkGenerator,
WatermarkOutput immediateOutput,
WatermarkOutput deferredOutput) |
Modifier and Type | Class and Description |
---|---|
static class |
TimestampsAndWatermarksOperator.WatermarkEmitter
Implementation of the
WatermarkEmitter , based on the components that are available
inside a stream operator. |
Modifier and Type | Method and Description |
---|---|
void |
AssignerWithPunctuatedWatermarksAdapter.onEvent(T event,
long eventTimestamp,
WatermarkOutput output) |
void |
AssignerWithPeriodicWatermarksAdapter.onEvent(T event,
long eventTimestamp,
WatermarkOutput output) |
void |
AssignerWithPunctuatedWatermarksAdapter.onPeriodicEmit(WatermarkOutput output) |
void |
AssignerWithPeriodicWatermarksAdapter.onPeriodicEmit(WatermarkOutput output) |
Modifier and Type | Method and Description |
---|---|
void |
GeneratedWatermarkGeneratorSupplier.DefaultWatermarkGenerator.onEvent(RowData event,
long eventTimestamp,
WatermarkOutput output) |
void |
GeneratedWatermarkGeneratorSupplier.DefaultWatermarkGenerator.onPeriodicEmit(WatermarkOutput output) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.