Class PslMicroBatchInputPartition (0.4.5) 

public class PslMicroBatchInputPartition implements InputPartition

Inheritance

java.lang.Object > PslMicroBatchInputPartition

Implements

org.apache.spark.sql.connector.read.InputPartition

Constructors

PslMicroBatchInputPartition(SparkPartitionOffset startOffset, SparkPartitionOffset endOffset, PslReadDataSourceOptions options)

public PslMicroBatchInputPartition(SparkPartitionOffset startOffset, SparkPartitionOffset endOffset, PslReadDataSourceOptions options)
Parameters
NameDescription
startOffsetcom.google.cloud.pubsublite.spark.SparkPartitionOffset
endOffsetcom.google.cloud.pubsublite.spark.SparkPartitionOffset
optionsPslReadDataSourceOptions