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 |
---|---|
<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 | Method and Description |
---|---|
static org.apache.pulsar.client.admin.PulsarAdmin |
PulsarClientFactory.createAdmin(PulsarConfiguration configuration)
PulsarAdmin shares almost the same configuration with PulsarClient, but we separate this
creating method for directly use it.
|
static org.apache.pulsar.client.api.PulsarClient |
PulsarClientFactory.createClient(PulsarConfiguration configuration)
Create a PulsarClient by using the flink Configuration and the config customizer.
|
Modifier and Type | Class and Description |
---|---|
class |
SinkConfiguration
The configured class for pulsar sink.
|
Modifier and Type | Class and Description |
---|---|
class |
SourceConfiguration
The configuration class for pulsar source.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.