Class PslContinuousInputPartition (0.4.5)

public class PslContinuousInputPartition implements InputPartition

Inheritance

java.lang.Object > PslContinuousInputPartition

Implements

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

Constructors

PslContinuousInputPartition(SparkPartitionOffset startOffset, PslReadDataSourceOptions options)

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