Class PslMicroBatchInputPartition (0.3.4)

public class PslMicroBatchInputPartition implements InputPartition<InternalRow>

Inheritance

java.lang.Object > PslMicroBatchInputPartition

Implements

org.apache.spark.sql.sources.v2.reader.InputPartition<org.apache.spark.sql.catalyst.InternalRow>

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(SubscriptionPath subscriptionPath, FlowControlSettings flowControlSettings, SparkPartitionOffset startOffset, SparkPartitionOffset endOffset, PartitionSubscriberFactory subscriberFactory)

public PslMicroBatchInputPartition(SubscriptionPath subscriptionPath, FlowControlSettings flowControlSettings, SparkPartitionOffset startOffset, SparkPartitionOffset endOffset, PartitionSubscriberFactory subscriberFactory)

Parameters

Name	Description
subscriptionPath	`com.google.cloud.pubsublite.SubscriptionPath`
flowControlSettings	`com.google.cloud.pubsublite.cloudpubsub.FlowControlSettings`
startOffset	`com.google.cloud.pubsublite.spark.SparkPartitionOffset`
endOffset	`com.google.cloud.pubsublite.spark.SparkPartitionOffset`
subscriberFactory	`PartitionSubscriberFactory`

Methods

createPartitionReader()

public InputPartitionReader<InternalRow> createPartitionReader()

Returns

Type	Description
org.apache.spark.sql.sources.v2.reader.InputPartitionReader<org.apache.spark.sql.catalyst.InternalRow>