Package | Description |
---|---|
org.apache.flink.connector.pulsar.source |
Modifier and Type | Method and Description |
---|---|
static <OUT> PulsarSourceBuilder<OUT> |
PulsarSource.builder()
Get a PulsarSourceBuilder to builder a
PulsarSource . |
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setAdminUrl(String adminUrl)
Sets the admin endpoint for the PulsarAdmin of the PulsarSource.
|
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. |
<T> PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setConfig(ConfigOption<T> key,
T value)
Set an arbitrary property for the PulsarSource and Pulsar Consumer.
|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setConfig(Configuration config)
Set arbitrary properties for the PulsarSource and Pulsar Consumer.
|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setConsumerName(String consumerName)
The consumer name is informative, and it can be used to identify a particular consumer
instance from the topic stats.
|
<T extends OUT> |
PulsarSourceBuilder.setDeserializationSchema(PulsarDeserializationSchema<T> deserializationSchema)
DeserializationSchema is required for getting the
Schema for deserialize message from
pulsar and getting the TypeInformation for message serialization in flink. |
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setProperties(Properties properties)
Set arbitrary properties for the PulsarSource and Pulsar Consumer.
|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setRangeGenerator(RangeGenerator rangeGenerator)
Set a topic range generator for Key_Shared subscription.
|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setServiceUrl(String serviceUrl)
Sets the server's link for the PulsarConsumer of the PulsarSource.
|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setStartCursor(StartCursor startCursor)
Specify from which offsets the PulsarSource should start consume from by providing an
StartCursor . |
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setSubscriptionName(String subscriptionName)
Sets the name for this pulsar subscription.
|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setSubscriptionType(org.apache.pulsar.client.api.SubscriptionType subscriptionType)
SubscriptionType is the consuming behavior for pulsar, we would generator different
split by the given subscription type. |
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setTopicPattern(Pattern topicsPattern)
Set a topic pattern to consume from the java
Pattern . |
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setTopicPattern(Pattern topicsPattern,
org.apache.pulsar.client.api.RegexSubscriptionMode regexSubscriptionMode)
Set a topic pattern to consume from the java
Pattern . |
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setTopicPattern(String topicsPattern)
Set a topic pattern to consume from the java regex str.
|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setTopicPattern(String topicsPattern,
org.apache.pulsar.client.api.RegexSubscriptionMode regexSubscriptionMode)
Set a topic pattern to consume from the java regex str.
|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setTopics(List<String> topics)
Set a pulsar topic list for flink source.
|
PulsarSourceBuilder<OUT> |
PulsarSourceBuilder.setTopics(String... topics)
Set a pulsar topic list for flink source.
|
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. |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.