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

Class GearpumpSource<T>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

BoundedSourceWrapper, UnboundedSourceWrapper

public abstract class GearpumpSource<T>
extends java.lang.Object
implements io.gearpump.streaming.source.DataSource

common methods for BoundedSourceWrapper and UnboundedSourceWrapper.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract Source.Reader<T>	createReader(PipelineOptions options)
java.time.Instant	getWatermark()
void	open(io.gearpump.streaming.task.TaskContext context, java.time.Instant startTime)
io.gearpump.Message	read()

Methods inherited from class java.lang.Object

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

Method Detail

createReader

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

Throws:

java.io.IOException

open

public void open(io.gearpump.streaming.task.TaskContext context,
                 java.time.Instant startTime)

Specified by:

open in interface io.gearpump.streaming.source.DataSource

read

public io.gearpump.Message read()

Specified by:

read in interface io.gearpump.streaming.source.DataSource

close

public void close()

Specified by:

close in interface io.gearpump.streaming.source.DataSource

getWatermark

public java.time.Instant getWatermark()

Specified by:

getWatermark in interface io.gearpump.streaming.source.DataSource