com.google.cloud.dataflow.sdk.runners.dataflow

Class BasicSerializableSourceFormat.BoundedSourceSplit<T>

java.lang.Object

com.google.cloud.dataflow.sdk.runners.dataflow.BasicSerializableSourceFormat.BoundedSourceSplit<T>

All Implemented Interfaces:

Reader.DynamicSplitResult

Enclosing class:

BasicSerializableSourceFormat

public static final class BasicSerializableSourceFormat.BoundedSourceSplit<T>
extends Object
implements Reader.DynamicSplitResult

A DynamicSplitResult specified explicitly by a pair of BoundedSource objects describing the primary and residual sources.

Field Summary

Fields

Modifier and Type	Field and Description
BoundedSource<T>	primary
BoundedSource<T>	residual

Constructor Summary

Constructors

Constructor and Description
BoundedSourceSplit(BoundedSource<T> primary, BoundedSource<T> residual)

Method Summary

Modifier and Type	Method and Description
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

primary

public final BoundedSource<T> primary

residual

public final BoundedSource<T> residual

Constructor Detail

BoundedSourceSplit

public BoundedSourceSplit(BoundedSource<T> primary,
                          BoundedSource<T> residual)

Method Detail

toString

public String toString()

Overrides:

toString in class Object