Class PslMicroBatchInputPartition (0.4.5)

Version 0.4.5

• 1.0.0 (latest)
• 0.4.5
• 0.3.4

public class PslMicroBatchInputPartition implements InputPartition

Inheritance

java.lang.Object > PslMicroBatchInputPartition

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

PslMicroBatchInputPartition(SparkPartitionOffset startOffset, SparkPartitionOffset endOffset, PslReadDataSourceOptions options)

public PslMicroBatchInputPartition(SparkPartitionOffset startOffset, SparkPartitionOffset endOffset, PslReadDataSourceOptions options)

Parameters

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