Uses of Class
org.apache.pulsar.common.io.SourceConfig
Packages that use SourceConfig
Package
Description
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of SourceConfig in org.apache.pulsar.client.admin
Methods in org.apache.pulsar.client.admin that return SourceConfigModifier and TypeMethodDescriptionGet the configuration for the specified source.Methods in org.apache.pulsar.client.admin that return types with arguments of type SourceConfigModifier and TypeMethodDescriptionSources.getSourceAsync
(String tenant, String namespace, String source) Get the configuration for the specified source asynchronously.Methods in org.apache.pulsar.client.admin with parameters of type SourceConfigModifier and TypeMethodDescriptionvoid
Sources.createSource
(SourceConfig sourceConfig, String fileName) Create a new source.Sources.createSourceAsync
(SourceConfig sourceConfig, String fileName) Create a new source asynchronously.void
Sources.createSourceWithUrl
(SourceConfig sourceConfig, String pkgUrl) Create a new source with package url.Sources.createSourceWithUrlAsync
(SourceConfig sourceConfig, String pkgUrl) Create a new source with package url asynchronously.void
Sources.updateSource
(SourceConfig sourceConfig, String fileName) Update the configuration for a source.void
Sources.updateSource
(SourceConfig sourceConfig, String fileName, UpdateOptions updateOptions) Update the configuration for a source.Sources.updateSourceAsync
(SourceConfig sourceConfig, String fileName) Update the configuration for a source asynchronously.Sources.updateSourceAsync
(SourceConfig sourceConfig, String fileName, UpdateOptions updateOptions) Update the configuration for a source asynchronously.void
Sources.updateSourceWithUrl
(SourceConfig sourceConfig, String pkgUrl) Update the configuration for a source.void
Sources.updateSourceWithUrl
(SourceConfig sourceConfig, String pkgUrl, UpdateOptions updateOptions) Update the configuration for a source.Sources.updateSourceWithUrlAsync
(SourceConfig sourceConfig, String pkgUrl) Update the configuration for a source asynchronously.Sources.updateSourceWithUrlAsync
(SourceConfig sourceConfig, String pkgUrl, UpdateOptions updateOptions) Update the configuration for a source asynchronously.