@Internal public class PulsarPartitionSplit extends Object implements SourceSplit, Serializable
SourceSplit
implementation for a Pulsar's partition.Constructor and Description |
---|
PulsarPartitionSplit(TopicPartition partition,
StopCursor stopCursor) |
PulsarPartitionSplit(TopicPartition partition,
StopCursor stopCursor,
org.apache.pulsar.client.api.MessageId latestConsumedId,
org.apache.pulsar.client.api.transaction.TxnID uncommittedTransactionId) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
org.apache.pulsar.client.api.MessageId |
getLatestConsumedId() |
TopicPartition |
getPartition() |
StopCursor |
getStopCursor() |
org.apache.pulsar.client.api.transaction.TxnID |
getUncommittedTransactionId() |
int |
hashCode() |
void |
open(org.apache.pulsar.client.admin.PulsarAdmin admin)
Open stop cursor.
|
String |
splitId()
Get the split id of this source split.
|
String |
toString() |
public PulsarPartitionSplit(TopicPartition partition, StopCursor stopCursor)
public PulsarPartitionSplit(TopicPartition partition, StopCursor stopCursor, @Nullable org.apache.pulsar.client.api.MessageId latestConsumedId, @Nullable org.apache.pulsar.client.api.transaction.TxnID uncommittedTransactionId)
public String splitId()
SourceSplit
splitId
in interface SourceSplit
public TopicPartition getPartition()
public StopCursor getStopCursor()
@Nullable public org.apache.pulsar.client.api.MessageId getLatestConsumedId()
@Nullable public org.apache.pulsar.client.api.transaction.TxnID getUncommittedTransactionId()
public void open(org.apache.pulsar.client.admin.PulsarAdmin admin)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.