Uses of Class
org.apache.pulsar.common.io.SinkConfig
Packages that use SinkConfig
-
Uses of SinkConfig in org.apache.pulsar.client.admin
Methods in org.apache.pulsar.client.admin that return SinkConfigModifier and TypeMethodDescriptionGet the configuration for the specified sink.Methods in org.apache.pulsar.client.admin that return types with arguments of type SinkConfigModifier and TypeMethodDescriptionSinks.getSinkAsync
(String tenant, String namespace, String sink) Get the configuration for the specified sink asynchronously.Methods in org.apache.pulsar.client.admin with parameters of type SinkConfigModifier 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.