Class PslContinuousInputPartition (0.3.4) 

publicclass PslContinuousInputPartitionimplementsContinuousInputPartition<InternalRow>,Serializable

Inheritance

java.lang.Object > PslContinuousInputPartition

Implements

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

Constructors

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

publicPslContinuousInputPartition(PartitionSubscriberFactorysubscriberFactory,SparkPartitionOffsetstartOffset,SubscriptionPathsubscriptionPath,FlowControlSettingsflowControlSettings)
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)

publicInputPartitionReader<InternalRow>createContinuousReader(PartitionOffsetoffset)
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()

publicInputPartitionReader<InternalRow>createPartitionReader()
Returns
Type Description
org.apache.spark.sql.sources.v2.reader.InputPartitionReader<org.apache.spark.sql.catalyst.InternalRow>

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2025年10月30日 UTC.