Uses of Class
org.apache.flink.connector.pulsar.source.enumerator.PulsarSourceEnumState

Packages that use PulsarSourceEnumState

Package	Description
org.apache.flink.connector.pulsar.source
org.apache.flink.connector.pulsar.source.enumerator
org.apache.flink.connector.pulsar.source.enumerator.assigner

Uses of PulsarSourceEnumState in org.apache.flink.connector.pulsar.source

Methods in org.apache.flink.connector.pulsar.source that return types with arguments of type PulsarSourceEnumState

Modifier and Type	Method and Description
SplitEnumerator<PulsarPartitionSplit,PulsarSourceEnumState>	PulsarSource.createEnumerator(SplitEnumeratorContext<PulsarPartitionSplit> enumContext)
SimpleVersionedSerializer<PulsarSourceEnumState>	PulsarSource.getEnumeratorCheckpointSerializer()
SplitEnumerator<PulsarPartitionSplit,PulsarSourceEnumState>	PulsarSource.restoreEnumerator(SplitEnumeratorContext<PulsarPartitionSplit> enumContext, PulsarSourceEnumState checkpoint)

Methods in org.apache.flink.connector.pulsar.source with parameters of type PulsarSourceEnumState

Modifier and Type	Method and Description
SplitEnumerator<PulsarPartitionSplit,PulsarSourceEnumState>	PulsarSource.restoreEnumerator(SplitEnumeratorContext<PulsarPartitionSplit> enumContext, PulsarSourceEnumState checkpoint)

Uses of PulsarSourceEnumState in org.apache.flink.connector.pulsar.source.enumerator

Methods in org.apache.flink.connector.pulsar.source.enumerator that return PulsarSourceEnumState

Modifier and Type	Method and Description
PulsarSourceEnumState	PulsarSourceEnumStateSerializer.deserialize(int version, byte[] serialized)
static PulsarSourceEnumState	PulsarSourceEnumState.initialState() The initial assignment state for Pulsar.
PulsarSourceEnumState	PulsarSourceEnumerator.snapshotState(long checkpointId)

Methods in org.apache.flink.connector.pulsar.source.enumerator with parameters of type PulsarSourceEnumState

Modifier and Type	Method and Description
byte[]	PulsarSourceEnumStateSerializer.serialize(PulsarSourceEnumState obj)

Constructors in org.apache.flink.connector.pulsar.source.enumerator with parameters of type PulsarSourceEnumState

Constructor and Description
PulsarSourceEnumerator(PulsarSubscriber subscriber, StartCursor startCursor, StopCursor stopCursor, RangeGenerator rangeGenerator, SourceConfiguration sourceConfiguration, SplitEnumeratorContext<PulsarPartitionSplit> context, PulsarSourceEnumState enumState)

Uses of PulsarSourceEnumState in org.apache.flink.connector.pulsar.source.enumerator.assigner

Methods in org.apache.flink.connector.pulsar.source.enumerator.assigner that return PulsarSourceEnumState

Modifier and Type	Method and Description
PulsarSourceEnumState	SplitAssigner.snapshotState() Snapshot the current assign state into checkpoint.

Methods in org.apache.flink.connector.pulsar.source.enumerator.assigner with parameters of type PulsarSourceEnumState

Modifier and Type	Method and Description
static SplitAssigner	SplitAssignerFactory.createAssigner(StopCursor stopCursor, SourceConfiguration sourceConfiguration, SplitEnumeratorContext<PulsarPartitionSplit> context, PulsarSourceEnumState enumState)

Constructors in org.apache.flink.connector.pulsar.source.enumerator.assigner with parameters of type PulsarSourceEnumState

Constructor and Description
KeySharedSplitAssigner(StopCursor stopCursor, boolean enablePartitionDiscovery, SplitEnumeratorContext<PulsarPartitionSplit> context, PulsarSourceEnumState enumState)