Modifier and Type | Method and Description |
---|---|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setBoundedStopCursor(StopCursor stopCursor)
By default, the PulsarSource is set to run in
Boundedness.CONTINUOUS_UNBOUNDED manner
and thus never stops until the Flink job fails or is canceled. |
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setUnboundedStopCursor(StopCursor stopCursor)
By default, the PulsarSource runs in an
Boundedness.CONTINUOUS_UNBOUNDED mode and
never stop until the Flink job is canceled or fails. |
Constructor and Description |
---|
PulsarSourceEnumerator(PulsarSubscriber subscriber,
StartCursor startCursor,
StopCursor stopCursor,
RangeGenerator rangeGenerator,
Configuration configuration,
SourceConfiguration sourceConfiguration,
SplitEnumeratorContext<PulsarPartitionSplit> context) |
PulsarSourceEnumerator(PulsarSubscriber subscriber,
StartCursor startCursor,
StopCursor stopCursor,
RangeGenerator rangeGenerator,
Configuration configuration,
SourceConfiguration sourceConfiguration,
SplitEnumeratorContext<PulsarPartitionSplit> context,
PulsarSourceEnumState enumState) |
Modifier and Type | Method and Description |
---|---|
static SplitAssigner |
SplitAssignerFactory.createAssigner(StopCursor stopCursor,
SourceConfiguration sourceConfiguration,
SplitEnumeratorContext<PulsarPartitionSplit> context,
PulsarSourceEnumState enumState) |
Modifier and Type | Method and Description |
---|---|
static StopCursor |
StopCursor.afterEventTime(long timestamp)
Stop consuming when message eventTime is greater than the specified timestamp.
|
static StopCursor |
StopCursor.afterMessageId(org.apache.pulsar.client.api.MessageId messageId)
Stop consuming when the messageId is greater than the specified messageId.
|
static StopCursor |
StopCursor.afterPublishTime(long timestamp)
Stop consuming when message publishTime is greater than the specified timestamp.
|
static StopCursor |
StopCursor.atEventTime(long timestamp)
Stop consuming when message eventTime is greater than or equals the specified timestamp.
|
static StopCursor |
StopCursor.atMessageId(org.apache.pulsar.client.api.MessageId messageId)
Stop consuming when the messageId is equal or greater than the specified messageId.
|
static StopCursor |
StopCursor.atPublishTime(long timestamp)
Stop consuming when message publishTime is greater than or equals the specified timestamp.
|
static StopCursor |
StopCursor.defaultStopCursor() |
static StopCursor |
StopCursor.latest() |
static StopCursor |
StopCursor.never() |
Modifier and Type | Class and Description |
---|---|
class |
EventTimestampStopCursor
Stop consuming message at the given event time.
|
class |
LatestMessageStopCursor
A stop cursor that initialize the position to the latest message id.
|
class |
MessageIdStopCursor
Stop consuming message at a given message id.
|
class |
NeverStopCursor
A implementation which wouldn't stop forever.
|
class |
PublishTimestampStopCursor
Stop consuming message at the given publish time.
|
Modifier and Type | Method and Description |
---|---|
StopCursor |
PulsarPartitionSplit.getStopCursor() |
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) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.