Package org.apache.beam.runners.flink.translation.wrappers

Class SourceInputSplit<T>

java.lang.Object

org.apache.beam.runners.flink.translation.wrappers.SourceInputSplit<T>

All Implemented Interfaces:

Serializable, org.apache.flink.core.io.InputSplit

public class SourceInputSplit<T>
extends Object
implements org.apache.flink.core.io.InputSplit

InputSplit for SourceInputFormat. We pass the sharded Source around in the input split because Sources simply split up into several Sources for sharding. This is different to how Flink creates a separate InputSplit from an InputFormat.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SourceInputSplit()
SourceInputSplit(Source<T> source, int splitNumber)

Method Summary

Modifier and Type	Method	Description
Source<T>	getSource()
int	getSplitNumber()

Methods inherited from class java.lang.Object

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

Constructor Details

SourceInputSplit

public SourceInputSplit()

SourceInputSplit

public SourceInputSplit(Source<T> source,
 int splitNumber)

Method Details

getSplitNumber

public int getSplitNumber()

Specified by:

getSplitNumber in interface org.apache.flink.core.io.InputSplit

getSource

public Source<T> getSource()