Package com.linkedin.venice.spark.input.pubsub

Class SparkPubSubInputPartition

java.lang.Object

com.linkedin.venice.spark.input.pubsub.SparkPubSubInputPartition

All Implemented Interfaces:

Serializable, org.apache.spark.sql.connector.read.InputPartition

public class SparkPubSubInputPartition
extends Object
implements org.apache.spark.sql.connector.read.InputPartition, Serializable

Thin Spark adapter. Serializable wrapper around PubSubPartitionSplit.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SparkPubSubInputPartition(PubSubPartitionSplit split)

Method Summary

Modifier and Type	Method	Description
PubSubPartitionSplit	getPubSubPartitionSplit()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.connector.read.InputPartition

preferredLocations

Constructor Details

SparkPubSubInputPartition

public SparkPubSubInputPartition(PubSubPartitionSplit split)

Method Details

getPubSubPartitionSplit

public PubSubPartitionSplit getPubSubPartitionSplit()

toString

public String toString()

Overrides:

toString in class Object