Class PslContinuousInputPartition (0.4.5)

Version 0.4.5

• 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