Modifier and Type | Method and Description |
---|---|
InputStatus |
SourceReader.pollNext(ReaderOutput<T> output)
Poll the next available record into the
ReaderOutput . |
Modifier and Type | Method and Description |
---|---|
InputStatus |
IteratorSourceReader.pollNext(ReaderOutput<E> output) |
Modifier and Type | Method and Description |
---|---|
InputStatus |
HybridSourceReader.pollNext(ReaderOutput output) |
Modifier and Type | Method and Description |
---|---|
InputStatus |
SourceReaderBase.pollNext(ReaderOutput<T> output) |
Modifier and Type | Method and Description |
---|---|
InputStatus |
PulsarOrderedSourceReader.pollNext(ReaderOutput<OUT> output) |
Modifier and Type | Method and Description |
---|---|
InputStatus |
FromElementsSourceReader.pollNext(ReaderOutput<T> output) |
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 | Method and Description |
---|---|
ReaderOutput<T> |
NoOpTimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output,
TimestampsAndWatermarks.WatermarkUpdateListener watermarkEmitted) |
ReaderOutput<T> |
TimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output,
TimestampsAndWatermarks.WatermarkUpdateListener watermarkCallback)
Creates the ReaderOutput for the source reader, than internally runs the timestamp extraction
and watermark generation.
|
ReaderOutput<T> |
ProgressiveTimestampsAndWatermarks.createMainOutput(PushingAsyncDataInput.DataOutput<T> output,
TimestampsAndWatermarks.WatermarkUpdateListener watermarkUpdateListener) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.