public abstract class GearpumpSource<T>
extends java.lang.Object
implements io.gearpump.streaming.source.DataSource
BoundedSourceWrapper
and UnboundedSourceWrapper
.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() |
protected abstract Source.Reader<T> createReader(PipelineOptions options) throws java.io.IOException
java.io.IOException
public void open(io.gearpump.streaming.task.TaskContext context, java.time.Instant startTime)
open
in interface io.gearpump.streaming.source.DataSource
public io.gearpump.Message read()
read
in interface io.gearpump.streaming.source.DataSource
public void close()
close
in interface io.gearpump.streaming.source.DataSource
public java.time.Instant getWatermark()
getWatermark
in interface io.gearpump.streaming.source.DataSource