Package org.apache.beam.runners.flink.translation.wrappers.streaming.io.source

Class FlinkSourceReaderBase.ReaderAndOutput

java.lang.Object

org.apache.beam.runners.flink.translation.wrappers.streaming.io.source.FlinkSourceReaderBase.ReaderAndOutput

Enclosing class:

FlinkSourceReaderBase<T,OutputT>

protected final class FlinkSourceReaderBase.ReaderAndOutput
extends Object

A wrapper for the reader and its associated information.

Field Summary

Fields

Modifier and Type	Field	Description
final Source.Reader<T>	reader
final String	splitId

Constructor Summary

Constructors

Constructor	Description
ReaderAndOutput(String splitId, Source.Reader<T> reader, boolean started)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.SourceOutput<OutputT>	getAndMaybeCreateSplitOutput(org.apache.flink.api.connector.source.ReaderOutput<OutputT> output)
@Nullable org.apache.flink.api.connector.source.SourceOutput<OutputT>	sourceOutput()
boolean	startOrAdvance(org.apache.flink.api.connector.source.ReaderOutput<OutputT> output)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

splitId

public final String splitId

reader

public final Source.Reader<T> reader

Constructor Details

ReaderAndOutput

public ReaderAndOutput(String splitId,
 Source.Reader<T> reader,
 boolean started)

Method Details

getAndMaybeCreateSplitOutput

public org.apache.flink.api.connector.source.SourceOutput<OutputT> getAndMaybeCreateSplitOutput(org.apache.flink.api.connector.source.ReaderOutput<OutputT> output)

startOrAdvance

public boolean startOrAdvance(org.apache.flink.api.connector.source.ReaderOutput<OutputT> output)
                       throws IOException

Throws:

IOException

sourceOutput

public @Nullable org.apache.flink.api.connector.source.SourceOutput<OutputT> sourceOutput()

toString

public String toString()

Overrides:

toString in class Object