org.apache.beam.runners.gearpump.translators.io

Class BoundedSourceWrapper<T>

java.lang.Object

org.apache.beam.runners.gearpump.translators.io.GearpumpSource<T>

org.apache.beam.runners.gearpump.translators.io.BoundedSourceWrapper<T>

All Implemented Interfaces:

java.io.Serializable, org.apache.gearpump.streaming.source.DataSource

public class BoundedSourceWrapper<T>
extends GearpumpSource<T>

wrapper over BoundedSource for Gearpump DataSource API.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BoundedSourceWrapper(BoundedSource<T> source, PipelineOptions options)

Method Summary

Modifier and Type	Method and Description
protected Source.Reader<T>	createReader(PipelineOptions options)

Methods inherited from class org.apache.beam.runners.gearpump.translators.io.GearpumpSource

close, getWatermark, open, read

Methods inherited from class java.lang.Object

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

Constructor Detail

BoundedSourceWrapper

public BoundedSourceWrapper(BoundedSource<T> source,
                            PipelineOptions options)

Method Detail

createReader

protected Source.Reader<T> createReader(PipelineOptions options)
                                 throws java.io.IOException

Specified by:

createReader in class GearpumpSource<T>

Throws:

java.io.IOException