Uses of Class
org.apache.pulsar.common.io.SinkConfig
-
Uses of SinkConfig in org.apache.pulsar.client.admin
Modifier and TypeMethodDescriptionGet the configuration for the specified sink.Modifier and TypeMethodDescriptionSinks.getSinkAsync
(String tenant, String namespace, String sink) Get the configuration for the specified sink asynchronously.Modifier and TypeMethodDescriptionvoid
Sinks.createSink
(SinkConfig sinkConfig, String fileName) Create a new sink.Sinks.createSinkAsync
(SinkConfig sinkConfig, String fileName) Create a new sink asynchronously.void
Sinks.createSinkWithUrl
(SinkConfig sinkConfig, String pkgUrl) Create a new sink with package url.Sinks.createSinkWithUrlAsync
(SinkConfig sinkConfig, String pkgUrl) Create a new sink with package url asynchronously.void
Sinks.updateSink
(SinkConfig sinkConfig, String fileName) Update the configuration for a sink.void
Sinks.updateSink
(SinkConfig sinkConfig, String fileName, UpdateOptions updateOptions) Update the configuration for a sink.Sinks.updateSinkAsync
(SinkConfig sinkConfig, String fileName) Update the configuration for a sink asynchronously.Sinks.updateSinkAsync
(SinkConfig sinkConfig, String fileName, UpdateOptions updateOptions) Update the configuration for a sink asynchronously.void
Sinks.updateSinkWithUrl
(SinkConfig sinkConfig, String pkgUrl) Update the configuration for a sink.void
Sinks.updateSinkWithUrl
(SinkConfig sinkConfig, String pkgUrl, UpdateOptions updateOptions) Update the configuration for a sink.Sinks.updateSinkWithUrlAsync
(SinkConfig sinkConfig, String pkgUrl) Update the configuration for a sink asynchronously.Sinks.updateSinkWithUrlAsync
(SinkConfig sinkConfig, String pkgUrl, UpdateOptions updateOptions) Update the configuration for a sink asynchronously.