Package | Description |
---|---|
org.apache.flink.configuration | |
org.apache.flink.connector.pulsar.common.config | |
org.apache.flink.connector.pulsar.sink | |
org.apache.flink.connector.pulsar.source |
Modifier and Type | Class and Description |
---|---|
class |
CleanupOptions
ConfigOption collection for the configuration of repeatable cleanup of resource cleanup
after a job reached a globally-terminated state. |
class |
CoreOptions
The set of configuration options for core parameters.
|
class |
RestartStrategyOptions
Config options for restart strategies.
|
class |
TaskManagerOptions
The set of configuration options relating to TaskManager and Task settings.
|
Modifier and Type | Class and Description |
---|---|
class |
PulsarOptions
Configuration for Pulsar Client, these config options would be used for both source, sink and
table.
|
Modifier and Type | Class and Description |
---|---|
class |
PulsarSinkOptions
Configurations for PulsarSink.
|
Modifier and Type | Class and Description |
---|---|
class |
PulsarSourceOptions
Configurations for PulsarSource.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.