Modifier and Type | Method and Description |
---|---|
static <T> org.apache.pulsar.client.api.ConsumerBuilder<T> |
PulsarSourceConfigUtils.createConsumerBuilder(org.apache.pulsar.client.api.PulsarClient client,
org.apache.pulsar.client.api.Schema<T> schema,
SourceConfiguration configuration)
Create a pulsar consumer builder by using the given Configuration.
|
Constructor and Description |
---|
PulsarSourceEnumerator(PulsarSubscriber subscriber,
StartCursor startCursor,
StopCursor stopCursor,
RangeGenerator rangeGenerator,
SourceConfiguration sourceConfiguration,
SplitEnumeratorContext<PulsarPartitionSplit> context) |
PulsarSourceEnumerator(PulsarSubscriber subscriber,
StartCursor startCursor,
StopCursor stopCursor,
RangeGenerator rangeGenerator,
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 |
---|---|
default void |
RangeGenerator.open(Configuration configuration,
SourceConfiguration sourceConfiguration)
Deprecated.
Use
RangeGenerator.open(SourceConfiguration) instead. |
default void |
RangeGenerator.open(SourceConfiguration sourceConfiguration)
Initialize some extra resource when bootstrap the source.
|
Modifier and Type | Method and Description |
---|---|
static <OUT> SourceReader<OUT,PulsarPartitionSplit> |
PulsarSourceReaderFactory.create(SourceReaderContext readerContext,
PulsarDeserializationSchema<OUT> deserializationSchema,
SourceConfiguration sourceConfiguration) |
Modifier and Type | Method and Description |
---|---|
default void |
PulsarDeserializationSchema.open(DeserializationSchema.InitializationContext context,
SourceConfiguration configuration)
Initialization method for the schema.
|
Constructor and Description |
---|
PulsarOrderedSourceReader(FutureCompletingBlockingQueue<RecordsWithSplitIds<PulsarMessage<OUT>>> elementsQueue,
java.util.function.Supplier<PulsarOrderedPartitionSplitReader<OUT>> splitReaderSupplier,
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,
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) |
Constructor and Description |
---|
PulsarOrderedPartitionSplitReader(org.apache.pulsar.client.api.PulsarClient pulsarClient,
org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
SourceConfiguration sourceConfiguration,
PulsarDeserializationSchema<OUT> deserializationSchema) |
PulsarUnorderedPartitionSplitReader(org.apache.pulsar.client.api.PulsarClient pulsarClient,
org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin,
SourceConfiguration sourceConfiguration,
PulsarDeserializationSchema<OUT> deserializationSchema,
org.apache.pulsar.client.api.transaction.TransactionCoordinatorClient coordinatorClient) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.