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()
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.