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

Class VeniceBasicPubsubInputPartition

java.lang.Object

com.linkedin.venice.spark.input.pubsub.raw.VeniceBasicPubsubInputPartition

All Implemented Interfaces:

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

public class VeniceBasicPubsubInputPartition
extends Object
implements org.apache.spark.sql.connector.read.InputPartition

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
VeniceBasicPubsubInputPartition(String region, PubSubTopicPartition topicPartition, PubSubPosition beginningPosition, PubSubPosition endPosition)

Method Summary

Modifier and Type	Method	Description
long	getEndOffset()
int	getPartitionNumber()
String	getRegion()
long	getStartOffset()
String	getTopicName()

Methods inherited from class java.lang.Object

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

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

preferredLocations

Constructor Details

VeniceBasicPubsubInputPartition

public VeniceBasicPubsubInputPartition(String region,
 PubSubTopicPartition topicPartition,
 PubSubPosition beginningPosition,
 PubSubPosition endPosition)

Method Details

getRegion

public String getRegion()

getTopicName

public String getTopicName()

getPartitionNumber

public int getPartitionNumber()

getStartOffset

public long getStartOffset()

getEndOffset

public long getEndOffset()