Class PslContinuousInputPartition (0.3.4)

public class PslContinuousInputPartition implements ContinuousInputPartition<InternalRow>, Serializable

Inheritance

java.lang.Object > PslContinuousInputPartition

Implements

org.apache.spark.sql.sources.v2.reader.ContinuousInputPartition<org.apache.spark.sql.catalyst.InternalRow>, Serializable

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

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

Parameters

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

Methods

createContinuousReader(PartitionOffset offset)

public InputPartitionReader<InternalRow> createContinuousReader(PartitionOffset offset)

Parameter

Name	Description
offset	`org.apache.spark.sql.sources.v2.reader.streaming.PartitionOffset`

Returns

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

createPartitionReader()

public InputPartitionReader<InternalRow> createPartitionReader()

Returns

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