Package | Description |
---|---|
org.apache.flink.connector.pulsar.common.config | |
org.apache.flink.connector.pulsar.sink.config | |
org.apache.flink.connector.pulsar.source.config |
Modifier and Type | Method and Description |
---|---|
PulsarConfigValidator |
PulsarConfigValidator.PulsarConfigValidatorBuilder.build() |
Modifier and Type | Method and Description |
---|---|
<T extends PulsarConfiguration> |
PulsarConfigBuilder.build(PulsarConfigValidator validator,
java.util.function.Function<Configuration,T> constructor)
Validate the current config instance and return a unmodifiable configuration.
|
Modifier and Type | Field and Description |
---|---|
static PulsarConfigValidator |
PulsarSinkConfigUtils.SINK_CONFIG_VALIDATOR |
Modifier and Type | Field and Description |
---|---|
static PulsarConfigValidator |
PulsarSourceConfigUtils.SOURCE_CONFIG_VALIDATOR |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.