Uses of Class
org.apache.flink.connector.pulsar.source.config.SourceConfiguration

Packages that use SourceConfiguration

Package	Description
org.apache.flink.connector.pulsar.source.enumerator
org.apache.flink.connector.pulsar.source.enumerator.assigner
org.apache.flink.connector.pulsar.source.enumerator.topic.range
org.apache.flink.connector.pulsar.source.reader
org.apache.flink.connector.pulsar.source.reader.source
org.apache.flink.connector.pulsar.source.reader.split

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

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

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)

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

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

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

Uses of SourceConfiguration in org.apache.flink.connector.pulsar.source.enumerator.topic.range

Methods in org.apache.flink.connector.pulsar.source.enumerator.topic.range with parameters of type SourceConfiguration

Modifier and Type	Method and Description
default void	RangeGenerator.open(Configuration configuration, SourceConfiguration sourceConfiguration)

Uses of SourceConfiguration in org.apache.flink.connector.pulsar.source.reader

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

Modifier and Type	Method and Description
static <OUT> SourceReader<OUT,PulsarPartitionSplit>	PulsarSourceReaderFactory.create(SourceReaderContext readerContext, PulsarDeserializationSchema<OUT> deserializationSchema, Configuration configuration, SourceConfiguration sourceConfiguration)

Uses of SourceConfiguration in org.apache.flink.connector.pulsar.source.reader.source

Constructors in org.apache.flink.connector.pulsar.source.reader.source with parameters of type SourceConfiguration

Constructor and Description
PulsarOrderedSourceReader(FutureCompletingBlockingQueue<RecordsWithSplitIds<PulsarMessage<OUT>>> elementsQueue, java.util.function.Supplier<PulsarOrderedPartitionSplitReader<OUT>> splitReaderSupplier, Configuration configuration, SourceReaderContext context, SourceConfiguration sourceConfiguration, org.apache.pulsar.client.api.PulsarClient pulsarClient, org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin)
PulsarUnorderedSourceReader(FutureCompletingBlockingQueue<RecordsWithSplitIds<PulsarMessage<OUT>>> elementsQueue, java.util.function.Supplier<PulsarUnorderedPartitionSplitReader<OUT>> splitReaderSupplier, Configuration configuration, SourceReaderContext context, SourceConfiguration sourceConfiguration, org.apache.pulsar.client.api.PulsarClient pulsarClient, org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin, org.apache.pulsar.client.api.transaction.TransactionCoordinatorClient coordinatorClient)

Uses of SourceConfiguration in org.apache.flink.connector.pulsar.source.reader.split

Constructors in org.apache.flink.connector.pulsar.source.reader.split with parameters of type SourceConfiguration

Constructor and Description
PulsarOrderedPartitionSplitReader(org.apache.pulsar.client.api.PulsarClient pulsarClient, org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin, Configuration configuration, SourceConfiguration sourceConfiguration, PulsarDeserializationSchema<OUT> deserializationSchema)
PulsarUnorderedPartitionSplitReader(org.apache.pulsar.client.api.PulsarClient pulsarClient, org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin, Configuration configuration, SourceConfiguration sourceConfiguration, PulsarDeserializationSchema<OUT> deserializationSchema, org.apache.pulsar.client.api.transaction.TransactionCoordinatorClient coordinatorClient)