A B C D E F G H I K L M N P Q R S T V W
All Classes All Packages
All Classes All Packages
All Classes All Packages
A
- accept(KsqlObject) - Method in class io.confluent.ksql.api.client.InsertsPublisher
-
Provides a new row for insertion.
- AcksPublisher - Interface in io.confluent.ksql.api.client
-
A Reactive Streams Publisher that publishes server acknowledgments for rows inserted into an existing ksqlDB stream via
Client.streamInserts(String, Publisher)
. - add(KsqlArray) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends the specified value to the end of the array.
- add(KsqlObject) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends the specified value to the end of the array.
- add(Boolean) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends the specified value to the end of the array.
- add(Double) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends the specified value to the end of the array.
- add(Integer) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends the specified value to the end of the array.
- add(Long) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends the specified value to the end of the array.
- add(Object) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends the specified value to the end of the array.
- add(String) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends the specified value to the end of the array.
- add(BigDecimal) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends the specified value to the end of the array.
- addAll(KsqlArray) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends the values in the specified
KsqlArray
to the end of this instance. - addNull() - Method in class io.confluent.ksql.api.client.KsqlArray
-
Appends a null value to the end of the array.
- ARRAY - io.confluent.ksql.api.client.ColumnType.Type
- asObject() - Method in interface io.confluent.ksql.api.client.Row
-
Returns the data in this row represented as a
KsqlObject
where keys are column names and values are column values.
B
- BatchedQueryResult - Class in io.confluent.ksql.api.client
-
The result of a query (push or pull), returned as a single batch once the query has finished executing, or the query has been terminated.
- BatchedQueryResult() - Constructor for class io.confluent.ksql.api.client.BatchedQueryResult
- BIGINT - io.confluent.ksql.api.client.ColumnType.Type
- BOOLEAN - io.confluent.ksql.api.client.ColumnType.Type
C
- Client - Interface in io.confluent.ksql.api.client
-
A client that connects to a specific ksqlDB server.
- ClientOptions - Interface in io.confluent.ksql.api.client
-
Options for the ksqlDB
Client
. - close() - Method in interface io.confluent.ksql.api.client.Client
-
Closes the underlying HTTP client.
- columnNames() - Method in interface io.confluent.ksql.api.client.Row
-
Returns column names for the data in this row.
- columnNames() - Method in interface io.confluent.ksql.api.client.StreamedQueryResult
-
Returns column names for these results.
- ColumnType - Interface in io.confluent.ksql.api.client
-
The type of a column returned as part of a query result.
- ColumnType.Type - Enum in io.confluent.ksql.api.client
- columnTypes() - Method in interface io.confluent.ksql.api.client.Row
-
Returns column types for the data in this row.
- columnTypes() - Method in interface io.confluent.ksql.api.client.StreamedQueryResult
-
Returns column types for these results.
- complete() - Method in class io.confluent.ksql.api.client.InsertsPublisher
-
Marks the incoming stream of elements as complete.
- containsKey(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns whether the map contains the specified key.
- copy() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Creates a copy of these
ClientOptions
. - copy() - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns a copy of this.
- copy() - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns a copy of this.
- create() - Static method in interface io.confluent.ksql.api.client.ClientOptions
- create(ClientOptions) - Static method in interface io.confluent.ksql.api.client.Client
- create(ClientOptions, Vertx) - Static method in interface io.confluent.ksql.api.client.Client
D
- DECIMAL - io.confluent.ksql.api.client.ColumnType.Type
- DEFAULT_BUFFER_MAX_SIZE - Static variable in class io.confluent.ksql.api.client.InsertsPublisher
-
The buffer max size indicator value used by the default constructor.
- DEFAULT_EXECUTE_QUERY_MAX_RESULT_ROWS - Static variable in interface io.confluent.ksql.api.client.ClientOptions
- DEFAULT_HOST - Static variable in interface io.confluent.ksql.api.client.ClientOptions
- DEFAULT_HOST_PORT - Static variable in interface io.confluent.ksql.api.client.ClientOptions
- describeSource(String) - Method in interface io.confluent.ksql.api.client.Client
-
Returns metadata about the ksqlDB stream or table of the provided name.
- DOUBLE - io.confluent.ksql.api.client.ColumnType.Type
- drainHandler(Runnable) - Method in class io.confluent.ksql.api.client.InsertsPublisher
-
Sets a drain handler on the publisher.
E
- equals(Object) - Method in class io.confluent.ksql.api.client.KsqlArray
- equals(Object) - Method in class io.confluent.ksql.api.client.KsqlObject
- executeQuery(String) - Method in interface io.confluent.ksql.api.client.Client
-
Executes a query (push or pull) and returns all result rows in a single batch, once the query has completed.
- executeQuery(String, Map<String, Object>) - Method in interface io.confluent.ksql.api.client.Client
-
Executes a query (push or pull) and returns all result rows in a single batch, once the query has completed.
- executeStatement(String) - Method in interface io.confluent.ksql.api.client.Client
-
Sends a SQL request to the ksqlDB server.
- executeStatement(String, Map<String, Object>) - Method in interface io.confluent.ksql.api.client.Client
-
Sends a SQL request with the specified properties to the ksqlDB server.
- ExecuteStatementResult - Interface in io.confluent.ksql.api.client
-
The result of executing a 'CREATE', 'CREATE ...
F
- FieldInfo - Interface in io.confluent.ksql.api.client
-
Represents a field/column of a ksqlDB stream/table.
- fieldNames() - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the keys of the map.
- fields() - Method in interface io.confluent.ksql.api.client.SourceDescription
- fromArray(List<String>, KsqlArray) - Static method in class io.confluent.ksql.api.client.KsqlObject
G
- getBasicAuthPassword() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the password to be used for HTTP basic authentication, if applicable.
- getBasicAuthUsername() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the username to be used for HTTP basic authentication, if applicable.
- getBoolean(int) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns the value at a specified index as a boolean.
- getBoolean(int) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as a boolean. - getBoolean(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the value associated with the specified key as a boolean.
- getBoolean(String) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as a boolean. - getDecimal(int) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns the value at a specified index as a
BigDecimal
. - getDecimal(int) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as aBigDecimal
. - getDecimal(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the value associated with the specified key as a
BigDecimal
. - getDecimal(String) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as aBigDecimal
. - getDouble(int) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns the value at a specified index as a double.
- getDouble(int) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as a double. - getDouble(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the value associated with the specified key as a double.
- getDouble(String) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as a double. - getExecuteQueryMaxResultRows() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the maximum number of rows that may be returned in a
BatchedQueryResult
. - getHost() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the host name of the ksqlDB server to connect to.
- getId() - Method in interface io.confluent.ksql.api.client.QueryInfo
-
Returns the ID of this query, used for control operations such as terminating the query.
- getInteger(int) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns the value at a specified index as an integer.
- getInteger(int) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as an integer. - getInteger(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the value associated with the specified key as an integer.
- getInteger(String) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as an integer. - getKafkaClusterId() - Method in interface io.confluent.ksql.api.client.ServerInfo
- getKeyAlias() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the key alias.
- getKeyFormat() - Method in interface io.confluent.ksql.api.client.StreamInfo
- getKeyFormat() - Method in interface io.confluent.ksql.api.client.TableInfo
- getKeyPassword() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the key password.
- getKeyStore() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the key store path.
- getKeyStorePassword() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the key store password.
- getKsqlArray(int) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns the value at a specified index as a
KsqlArray
. - getKsqlArray(int) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as aKsqlArray
. - getKsqlArray(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the value associated with the specified key as a
KsqlArray
. - getKsqlArray(String) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as aKsqlArray
. - getKsqlObject(int) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns the value at a specified index as a
KsqlObject
. - getKsqlObject(int) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as aKsqlObject
. - getKsqlObject(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the value associated with the specified key as a
KsqlObject
. - getKsqlObject(String) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as aKsqlObject
. - getKsqlServiceId() - Method in interface io.confluent.ksql.api.client.ServerInfo
- getList() - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns values of the array as a list.
- getLong(int) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns the value at a specified index as a long.
- getLong(int) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as a long. - getLong(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the value associated with the specified key as a long.
- getLong(String) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as a long. - getMap() - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the entries of the map as a
Map
. - getName() - Method in interface io.confluent.ksql.api.client.StreamInfo
- getName() - Method in interface io.confluent.ksql.api.client.TableInfo
- getName() - Method in interface io.confluent.ksql.api.client.TopicInfo
- getPartitions() - Method in interface io.confluent.ksql.api.client.TopicInfo
- getPort() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the host port of the ksqlDB server to connect to.
- getQueryType() - Method in interface io.confluent.ksql.api.client.QueryInfo
- getReplicasPerPartition() - Method in interface io.confluent.ksql.api.client.TopicInfo
-
Returns the number of replicas for each topic partition.
- getServerVersion() - Method in interface io.confluent.ksql.api.client.ServerInfo
- getSink() - Method in interface io.confluent.ksql.api.client.QueryInfo
-
Returns the name of the sink ksqlDB stream or table that this query writes to, if this query is persistent.
- getSinkTopic() - Method in interface io.confluent.ksql.api.client.QueryInfo
-
Returns the name of the Kafka topic that backs the sink ksqlDB stream or table that this query writes to, if this query is persistent.
- getSourceConstraints() - Method in interface io.confluent.ksql.api.client.SourceDescription
-
Returns a list of sources that have a DROP constraint reference on this source.
- getSql() - Method in interface io.confluent.ksql.api.client.QueryInfo
-
Returns the ksqlDB statement text corresponding to this query.
- getString(int) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns the value at a specified index as a string.
- getString(int) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as a string. - getString(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the value associated with the specified key as a string.
- getString(String) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as a string. - getTopic() - Method in interface io.confluent.ksql.api.client.StreamInfo
- getTopic() - Method in interface io.confluent.ksql.api.client.TableInfo
- getTrustStore() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the trust store path.
- getTrustStorePassword() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns the trust store password.
- getType() - Method in interface io.confluent.ksql.api.client.ColumnType
-
Returns the type.
- getValue(int) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns the value at a specified index as an
Object
. - getValue(int) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as anObject
. - getValue(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the value associated with the specified key as an
Object
. - getValue(String) - Method in interface io.confluent.ksql.api.client.Row
-
Returns the value for a particular column of the
Row
as anObject
. - getValueFormat() - Method in interface io.confluent.ksql.api.client.StreamInfo
- getValueFormat() - Method in interface io.confluent.ksql.api.client.TableInfo
H
- hashCode() - Method in class io.confluent.ksql.api.client.KsqlArray
- hashCode() - Method in class io.confluent.ksql.api.client.KsqlObject
I
- InsertAck - Interface in io.confluent.ksql.api.client
-
An acknowledgment from the ksqlDB server that a row has been successfully inserted into a ksqlDB stream.
- insertInto(String, KsqlObject) - Method in interface io.confluent.ksql.api.client.Client
-
Inserts a row into a ksqlDB stream.
- InsertsPublisher - Class in io.confluent.ksql.api.client
-
A
org.reactivestreams.Publisher
suitable for use with theClient.streamInserts(String, Publisher)
method. - InsertsPublisher() - Constructor for class io.confluent.ksql.api.client.InsertsPublisher
-
Creates an
InsertsPublisher
. - InsertsPublisher(int) - Constructor for class io.confluent.ksql.api.client.InsertsPublisher
-
Creates an
InsertsPublisher
. - INTEGER - io.confluent.ksql.api.client.ColumnType.Type
- io.confluent.ksql.api.client - package io.confluent.ksql.api.client
- io.confluent.ksql.api.client.exception - package io.confluent.ksql.api.client.exception
- isComplete() - Method in interface io.confluent.ksql.api.client.AcksPublisher
-
Returns whether the
AcksPublisher
is complete. - isComplete() - Method in interface io.confluent.ksql.api.client.StreamedQueryResult
-
Returns whether the
StreamedQueryResult
is complete. - isEmpty() - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns whether the array is empty.
- isEmpty() - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns whether the map is empty.
- isFailed() - Method in interface io.confluent.ksql.api.client.AcksPublisher
-
Returns whether the
AcksPublisher
is failed. - isFailed() - Method in interface io.confluent.ksql.api.client.StreamedQueryResult
-
Returns whether the
StreamedQueryResult
is failed. - isKey() - Method in interface io.confluent.ksql.api.client.FieldInfo
- isNull(int) - Method in interface io.confluent.ksql.api.client.Row
-
Returns whether the value for a particular column of the
Row
is null. - isNull(String) - Method in interface io.confluent.ksql.api.client.Row
-
Returns whether the value for a particular column of the
Row
is null. - isUseAlpn() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns whether ALPN should be used.
- isUseBasicAuth() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns whether HTTP basic authentication will be used when connecting to the ksqlDB server.
- isUseTls() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns whether TLS should be used when connecting to the ksqlDB server.
- isVerifyHost() - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Returns whether hostname verification (for TLS) is enabled.
- isWindowed() - Method in interface io.confluent.ksql.api.client.StreamInfo
- isWindowed() - Method in interface io.confluent.ksql.api.client.TableInfo
- iterator() - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns an iterator over values of the array.
- iterator() - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns an iterator over the entries of the map.
K
- keyFormat() - Method in interface io.confluent.ksql.api.client.SourceDescription
- KsqlArray - Class in io.confluent.ksql.api.client
-
A representation of an array of values.
- KsqlArray() - Constructor for class io.confluent.ksql.api.client.KsqlArray
-
Creates an empty instance.
- KsqlArray(List<?>) - Constructor for class io.confluent.ksql.api.client.KsqlArray
-
Creates an instance with the specified values.
- KsqlClientException - Exception in io.confluent.ksql.api.client.exception
- KsqlClientException(String) - Constructor for exception io.confluent.ksql.api.client.exception.KsqlClientException
- KsqlClientException(String, Throwable) - Constructor for exception io.confluent.ksql.api.client.exception.KsqlClientException
- KsqlException - Exception in io.confluent.ksql.api.client.exception
-
Converts
KsqlErrorMessage
into an exception to be passed to client exception handlers. - KsqlException(int, String) - Constructor for exception io.confluent.ksql.api.client.exception.KsqlException
- KsqlObject - Class in io.confluent.ksql.api.client
-
A representation of a map of string keys to values.
- KsqlObject() - Constructor for class io.confluent.ksql.api.client.KsqlObject
-
Creates an empty instance.
- KsqlObject(Map<String, Object>) - Constructor for class io.confluent.ksql.api.client.KsqlObject
-
Creates an instance with the specified entries.
L
- listQueries() - Method in interface io.confluent.ksql.api.client.Client
-
Returns the list of queries currently running on the ksqlDB server.
- listStreams() - Method in interface io.confluent.ksql.api.client.Client
-
Returns the list of ksqlDB streams from the ksqlDB server's metastore.
- listTables() - Method in interface io.confluent.ksql.api.client.Client
-
Returns the list of ksqlDB tables from the ksqlDB server's metastore
- listTopics() - Method in interface io.confluent.ksql.api.client.Client
-
Returns the list of Kafka topics available for use with ksqlDB.
M
- MAP - io.confluent.ksql.api.client.ColumnType.Type
- mergeIn(KsqlObject) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds entries from the specified
KsqlObject
into this instance.
N
- name() - Method in interface io.confluent.ksql.api.client.FieldInfo
- name() - Method in interface io.confluent.ksql.api.client.SourceDescription
P
- PERSISTENT - io.confluent.ksql.api.client.QueryInfo.QueryType
- poll() - Method in interface io.confluent.ksql.api.client.StreamedQueryResult
-
Returns the next row.
- poll(Duration) - Method in interface io.confluent.ksql.api.client.StreamedQueryResult
-
Returns the next row.
- PUSH - io.confluent.ksql.api.client.QueryInfo.QueryType
- put(String, KsqlArray) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds an entry for the specified key and value to the map.
- put(String, KsqlObject) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds an entry for the specified key and value to the map.
- put(String, Boolean) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds an entry for the specified key and value to the map.
- put(String, Double) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds an entry for the specified key and value to the map.
- put(String, Integer) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds an entry for the specified key and value to the map.
- put(String, Long) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds an entry for the specified key and value to the map.
- put(String, Object) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds an entry for the specified key and value to the map.
- put(String, String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds an entry for the specified key and value to the map.
- put(String, BigDecimal) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds an entry for the specified key and value to the map.
- putNull(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Adds an entry for the specified key with null value to the map.
Q
- queryId() - Method in interface io.confluent.ksql.api.client.ExecuteStatementResult
-
Returns the ID of a newly started persistent query, if applicable.
- queryID() - Method in class io.confluent.ksql.api.client.BatchedQueryResult
-
Returns a
CompletableFuture
containing the ID of the underlying query if the query is a push query, else null. - queryID() - Method in interface io.confluent.ksql.api.client.StreamedQueryResult
-
Returns the ID of the underlying query if the query is a push query.
- QueryInfo - Interface in io.confluent.ksql.api.client
-
Metadata for a ksqlDB query.
- QueryInfo.QueryType - Enum in io.confluent.ksql.api.client
R
- readQueries() - Method in interface io.confluent.ksql.api.client.SourceDescription
- remove(int) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Removes the value at a specified index from the array.
- remove(Object) - Method in class io.confluent.ksql.api.client.KsqlArray
-
Removes the first occurrence of the specified value from the array, if present.
- remove(String) - Method in class io.confluent.ksql.api.client.KsqlObject
-
Removes the value associated with a specified key.
- Row - Interface in io.confluent.ksql.api.client
-
A single record, returned as part of a query result.
S
- seqNum() - Method in interface io.confluent.ksql.api.client.InsertAck
-
Returns the corresponding sequence number for this acknowledgment.
- serverInfo() - Method in interface io.confluent.ksql.api.client.Client
-
Returns metadata about the ksqlDB server.
- ServerInfo - Interface in io.confluent.ksql.api.client
-
Metadata for a ksqlDB server.
- setBasicAuthCredentials(String, String) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets the username and password to be used for HTTP basic authentication when connecting to the ksqlDB server.
- setExecuteQueryMaxResultRows(int) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets the maximum number of rows that may be returned in a
BatchedQueryResult
. - setHost(String) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets the host name of the ksqlDB server to connect to.
- setKeyAlias(String) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets the key alias.
- setKeyPassword(String) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets the key password.
- setKeyStore(String) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets the key store path.
- setKeyStorePassword(String) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets the key store password.
- setPort(int) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets the host port of the ksqlDB server to connect to.
- setTrustStore(String) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets the trust store path.
- setTrustStorePassword(String) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets the trust store password.
- setUseAlpn(boolean) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets whether ALPN should be used.
- setUseTls(boolean) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets whether TLS should be used when connecting to the ksqlDB server.
- setVerifyHost(boolean) - Method in interface io.confluent.ksql.api.client.ClientOptions
-
Sets whether hostname verification (for TLS) is enabled.
- size() - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns the size (number of values) of the array.
- size() - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns the size (number of entries) of the map.
- SourceDescription - Interface in io.confluent.ksql.api.client
-
Metadata for a ksqlDB stream or table.
- sqlStatement() - Method in interface io.confluent.ksql.api.client.SourceDescription
-
Returns the ksqlDB statement text used to create this stream/table.
- stream() - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns values of the array as a stream.
- stream() - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns entries of the map as a stream.
- StreamedQueryResult - Interface in io.confluent.ksql.api.client
-
The result of a query (push or pull), streamed one row at time.
- StreamInfo - Interface in io.confluent.ksql.api.client
-
Metadata for a ksqlDB stream.
- streamInserts(String, Publisher<KsqlObject>) - Method in interface io.confluent.ksql.api.client.Client
-
Inserts rows into a ksqlDB stream.
- streamQuery(String) - Method in interface io.confluent.ksql.api.client.Client
-
Executes a query (push or pull) and returns the results one row at a time.
- streamQuery(String, Map<String, Object>) - Method in interface io.confluent.ksql.api.client.Client
-
Executes a query (push or pull) and returns the results one row at a time.
- STRING - io.confluent.ksql.api.client.ColumnType.Type
- STRUCT - io.confluent.ksql.api.client.ColumnType.Type
- subscribe(Subscriber<? super KsqlObject>) - Method in class io.confluent.ksql.api.client.InsertsPublisher
T
- TableInfo - Interface in io.confluent.ksql.api.client
-
Metadata for a ksqlDB table.
- terminatePushQuery(String) - Method in interface io.confluent.ksql.api.client.Client
-
Terminates a push query with the specified query ID.
- timestampColumn() - Method in interface io.confluent.ksql.api.client.SourceDescription
- toJsonString() - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns a JSON string representing the values in the array.
- toJsonString() - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns a JSON string representing the entries in the map.
- topic() - Method in interface io.confluent.ksql.api.client.SourceDescription
- TopicInfo - Interface in io.confluent.ksql.api.client
-
Metadata for a Kafka topic available for use with ksqlDB.
- toString() - Method in class io.confluent.ksql.api.client.KsqlArray
-
Returns a JSON string representing the values in the array.
- toString() - Method in class io.confluent.ksql.api.client.KsqlObject
-
Returns a JSON string representing the entries in the map.
- type() - Method in interface io.confluent.ksql.api.client.FieldInfo
- type() - Method in interface io.confluent.ksql.api.client.SourceDescription
V
- valueFormat() - Method in interface io.confluent.ksql.api.client.SourceDescription
- valueOf(String) - Static method in enum io.confluent.ksql.api.client.ColumnType.Type
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum io.confluent.ksql.api.client.QueryInfo.QueryType
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum io.confluent.ksql.api.client.ColumnType.Type
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Static method in enum io.confluent.ksql.api.client.QueryInfo.QueryType
-
Returns an array containing the constants of this enum type, in the order they are declared.
- values() - Method in interface io.confluent.ksql.api.client.Row
-
Returns the values (data) in this row, represented as a
KsqlArray
.
W
- windowType() - Method in interface io.confluent.ksql.api.client.SourceDescription
-
Returns the type of the window (e.g., "TUMBLING", "HOPPING", "SESSION") associated with this source, if this source is a windowed table.
- writeQueries() - Method in interface io.confluent.ksql.api.client.SourceDescription
All Classes All Packages