Class PslContinuousInputPartition (1.0.0)

Version latest

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class PslContinuousInputPartition implements InputPartition

Inheritance

java.lang.Object > PslContinuousInputPartition

Implements

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

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

PslContinuousInputPartition(SparkPartitionOffset startOffset, PslReadDataSourceOptions options)

public PslContinuousInputPartition(SparkPartitionOffset startOffset, PslReadDataSourceOptions options)

Parameters
Name	Description
startOffset	com.google.cloud.pubsublite.spark.SparkPartitionOffset
options	PslReadDataSourceOptions