Uses of Interface
org.apache.pulsar.client.api.TableViewBuilder
-
Uses of TableViewBuilder in org.apache.pulsar.client.api
Modifier and TypeMethodDescriptionTableViewBuilder.autoUpdatePartitionsInterval
(int interval, TimeUnit unit) Set the interval of updating partitions (default: 1 minute).TableViewBuilder.cryptoFailureAction
(ConsumerCryptoFailureAction action) Set theConsumerCryptoFailureAction
to specify.TableViewBuilder.cryptoKeyReader
(CryptoKeyReader cryptoKeyReader) Set theCryptoKeyReader
to decrypt the message payloads.TableViewBuilder.defaultCryptoKeyReader
(String privateKey) Set the default implementation ofCryptoKeyReader
.TableViewBuilder.defaultCryptoKeyReader
(Map<String, String> privateKeys) Set the default implementation ofCryptoKeyReader
.Load the configuration from provided config map.TableViewBuilder
<byte[]> PulsarClient.newTableView()
Create a table view builder for subscribing on a specific topic.<T> TableViewBuilder
<T> PulsarClient.newTableView
(Schema<T> schema) Create a table view builder with a specific schema for subscribing on a specific topic.<T> TableViewBuilder
<T> PulsarClient.newTableViewBuilder
(Schema<T> schema) Deprecated.TableViewBuilder.subscriptionName
(String subscriptionName) Set the subscription name of theTableView
.Set the topic name of theTableView
.
PulsarClient.newTableView(Schema)
to build and configure aTableViewBuilder
instance