Index (ksqldb-api-client 6.0.0-SNAPSHOT API)

A B C D E F G H I K M P Q R S T V
All Classes All Packages

A

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.
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_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
DOUBLE - io.confluent.ksql.api.client.ColumnType.Type

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.

F

fieldNames() - Method in class io.confluent.ksql.api.client.KsqlObject: Returns the keys of the map.
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 a BigDecimal.
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 a BigDecimal.
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.
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.
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 a KsqlArray.
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 a KsqlArray.
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 a KsqlObject.
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 a KsqlObject.
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.
getPort() - Method in interface io.confluent.ksql.api.client.ClientOptions: Returns the host port of the ksqlDB server to connect to.
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.
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 an Object.
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 an Object.

H

hashCode() - Method in class io.confluent.ksql.api.client.KsqlArray
hashCode() - Method in class io.confluent.ksql.api.client.KsqlObject

I

insertInto(String, KsqlObject) - Method in interface io.confluent.ksql.api.client.Client: Inserts a row into a ksqlDB stream.
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.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.StreamedQueryResult: Returns whether the StreamedQueryResult is failed.
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.
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

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.

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.

P

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.
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 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.

R

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

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.
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.
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.
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

T

terminatePushQuery(String) - Method in interface io.confluent.ksql.api.client.Client: Terminates a push query with the specified query ID.
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.
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.

V

valueOf(String) - Static method in enum io.confluent.ksql.api.client.ColumnType.Type: 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() - Method in interface io.confluent.ksql.api.client.Row: Returns the values (data) in this row, represented as a KsqlArray.

A B C D E F G H I K M P Q R S T V
All Classes All Packages