org.apache.beam.sdk.io.sparkreceiver

Interface HasOffset

public interface HasOffset

Interface for any Spark Receiver that supports reading from and to some offset.

Method Summary

Modifier and Type	Method and Description
java.lang.Long	getEndOffset()
default void	setCheckpoint(java.lang.Long recordsProcessed) Some Receiver support mechanism of checkpoint (e.g.
void	setStartOffset(java.lang.Long offset)

Method Detail

setStartOffset

void setStartOffset(java.lang.Long offset)

Parameters:

offset - inclusive start offset from which the reading should be started.

getEndOffset

java.lang.Long getEndOffset()

Returns:

exclusive end offset to which the reading from current page will occur.

setCheckpoint

default void setCheckpoint(java.lang.Long recordsProcessed)

Some Receiver support mechanism of checkpoint (e.g. ack). This method should be called before stopping the receiver.