Index (ksqldb-api-client 0.29.0 API)

A B C D E F G H I K L M N P Q R S T U V W
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(byte[]) - Method in class io.confluent.ksql.api.client.KsqlArray: Appends the specified value to the end of the array.
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.
assertSchema(int, boolean) - Method in interface io.confluent.ksql.api.client.Client: Asserts the existence of a schema with the given id.
assertSchema(int, boolean, Duration) - Method in interface io.confluent.ksql.api.client.Client: Asserts the existence of a schema with the given id within the specified timeout.
assertSchema(String, boolean) - Method in interface io.confluent.ksql.api.client.Client: Asserts the existence of a schema with the given subject name.
assertSchema(String, boolean, Duration) - Method in interface io.confluent.ksql.api.client.Client: Asserts the existence of a schema with the given subject name within the specified timeout.
assertSchema(String, int, boolean) - Method in interface io.confluent.ksql.api.client.Client: Asserts the existence of a schema with the given subject name and id.
assertSchema(String, int, boolean, Duration) - Method in interface io.confluent.ksql.api.client.Client: Asserts the existence of a schema with the given subject name and id within the specified timeout.
assertTopic(String, boolean) - Method in interface io.confluent.ksql.api.client.Client: Asserts the existence of a topic.
assertTopic(String, boolean, Duration) - Method in interface io.confluent.ksql.api.client.Client: Asserts the existence of a topic within the specified timeout.
assertTopic(String, Map<String, Integer>, boolean) - Method in interface io.confluent.ksql.api.client.Client: Asserts the existence of a topic with the given configurations.
assertTopic(String, Map<String, Integer>, boolean, Duration) - Method in interface io.confluent.ksql.api.client.Client: Asserts the existence of a topic with the given configurations within the specified timeout.

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
body() - Method in interface io.confluent.ksql.api.client.Client.HttpResponse
bodyAsMap() - Method in interface io.confluent.ksql.api.client.Client.HttpResponse: Parse and return JSON response as a Map.
BOOLEAN - io.confluent.ksql.api.client.ColumnType.Type
buildRequest(String, String) - Method in interface io.confluent.ksql.api.client.Client: A factory to construct Client.HttpRequest objects.
BYTES - io.confluent.ksql.api.client.ColumnType.Type

C

className() - Method in interface io.confluent.ksql.api.client.ConnectorInfo
Client - Interface in io.confluent.ksql.api.client: A client that connects to a specific ksqlDB server.
Client.HttpRequest - Interface in io.confluent.ksql.api.client: Instances of Client.HttpRequest are used to make direct HTTP requests to ksqlDB server's REST API.
Client.HttpResponse - Interface in io.confluent.ksql.api.client
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.
ConnectorDescription - Interface in io.confluent.ksql.api.client
ConnectorInfo - Interface in io.confluent.ksql.api.client
ConnectorType - Interface in io.confluent.ksql.api.client
ConnectorType.Type - Enum in io.confluent.ksql.api.client
containsKey(String) - Method in class io.confluent.ksql.api.client.KsqlObject: Returns whether the map contains the specified key.
continueFromLastContinuationToken() - Method in interface io.confluent.ksql.api.client.StreamedQueryResult: Returns a new StreamedQueryResult which starts returning results from the last saved continuation token.
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
createConnector(String, boolean, Map<String, Object>) - Method in interface io.confluent.ksql.api.client.Client: Creates a connector.
createConnector(String, boolean, Map<String, Object>, boolean) - Method in interface io.confluent.ksql.api.client.Client: Creates a connector.

D

DATE - io.confluent.ksql.api.client.ColumnType.Type
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
DEFAULT_HTTP2_MULTIPLEXING_LIMIT - Static variable in interface io.confluent.ksql.api.client.ClientOptions
define(String, Object) - Method in interface io.confluent.ksql.api.client.Client: Define a session variable which can be referenced in sql commands by wrapping the variable name with ${}.
describeConnector(String) - Method in interface io.confluent.ksql.api.client.Client: Returns metadata about a connector.
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.
dropConnector(String) - Method in interface io.confluent.ksql.api.client.Client: Drops a connector.
dropConnector(String, boolean) - Method in interface io.confluent.ksql.api.client.Client: Drops a connector.

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.
getBytes(int) - Method in class io.confluent.ksql.api.client.KsqlArray: Returns the value at a specified index as a byte array.
getBytes(int) - Method in interface io.confluent.ksql.api.client.Row: Returns the value for a particular column of the Row as a byte array.
getBytes(String) - Method in class io.confluent.ksql.api.client.KsqlObject: Returns the value associated with the specified key as a byte array.
getBytes(String) - Method in interface io.confluent.ksql.api.client.Row: Returns the value for a particular column of the Row as byte array.
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.
getHttp2MultiplexingLimit() - Method in interface io.confluent.ksql.api.client.ClientOptions: Returns the maximum number of requests per HTTP/2 connection.
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 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.
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.
getRequestHeaders() - Method in interface io.confluent.ksql.api.client.ClientOptions: Returns a copy of the custom request headers to be sent with ksqlDB requests.
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.
getType() - Method in interface io.confluent.ksql.api.client.ConnectorType: 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.
getValueFormat() - Method in interface io.confluent.ksql.api.client.StreamInfo
getValueFormat() - Method in interface io.confluent.ksql.api.client.TableInfo
getVariables() - Method in interface io.confluent.ksql.api.client.Client

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 the Client.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(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

listConnectors() - Method in interface io.confluent.ksql.api.client.Client: Returns a list of connectors.
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.
method() - Method in interface io.confluent.ksql.api.client.Client.HttpRequest

N

name() - Method in interface io.confluent.ksql.api.client.ConnectorInfo
name() - Method in interface io.confluent.ksql.api.client.FieldInfo
name() - Method in interface io.confluent.ksql.api.client.SourceDescription

P

path() - Method in interface io.confluent.ksql.api.client.Client.HttpRequest
payload() - Method in interface io.confluent.ksql.api.client.Client.HttpRequest
payload(String, Object) - Method in interface io.confluent.ksql.api.client.Client.HttpRequest: Add a key and value in the payload map.
payload(Map<String, Object>) - Method in interface io.confluent.ksql.api.client.Client.HttpRequest: Add all entries from the input map into the payload map.
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.
properties() - Method in interface io.confluent.ksql.api.client.Client.HttpRequest
properties(Map<String, Object>) - Method in interface io.confluent.ksql.api.client.Client.HttpRequest: Add all properties from the given map.
propertiesKey() - Method in interface io.confluent.ksql.api.client.Client.HttpRequest
propertiesKey(String) - Method in interface io.confluent.ksql.api.client.Client.HttpRequest: Set the key to be used for properties map in the request.
property(String, Object) - Method in interface io.confluent.ksql.api.client.Client.HttpRequest: Set a property.
PUSH - io.confluent.ksql.api.client.QueryInfo.QueryType
put(String, byte[]) - Method in class io.confluent.ksql.api.client.KsqlObject
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

send() - Method in interface io.confluent.ksql.api.client.Client.HttpRequest: Complete the HTTP request.
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.
setHttp2MultiplexingLimit(int) - Method in interface io.confluent.ksql.api.client.ClientOptions: Sets the maximum number of requests per HTTP/2 connection.
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.
setRequestHeaders(Map<String, String>) - Method in interface io.confluent.ksql.api.client.ClientOptions: Sets custom request headers to be sent with requests to the ksqlDB server.
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.
SINK - io.confluent.ksql.api.client.ConnectorType.Type
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.
SOURCE - io.confluent.ksql.api.client.ConnectorType.Type
SourceDescription - Interface in io.confluent.ksql.api.client: Metadata for a ksqlDB stream or table.
sources() - Method in interface io.confluent.ksql.api.client.ConnectorDescription
sqlStatement() - Method in interface io.confluent.ksql.api.client.SourceDescription: Returns the ksqlDB statement text used to create this stream/table.
state() - Method in interface io.confluent.ksql.api.client.ConnectorInfo
status() - Method in interface io.confluent.ksql.api.client.Client.HttpResponse
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.
TIME - io.confluent.ksql.api.client.ColumnType.Type
TIMESTAMP - io.confluent.ksql.api.client.ColumnType.Type
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.
topics() - Method in interface io.confluent.ksql.api.client.ConnectorDescription
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.ConnectorInfo
type() - Method in interface io.confluent.ksql.api.client.FieldInfo
type() - Method in interface io.confluent.ksql.api.client.SourceDescription

U

undefine(String) - Method in interface io.confluent.ksql.api.client.Client: Undefine a session variable.
UNKNOWN - io.confluent.ksql.api.client.ConnectorType.Type: Denotes an unknown connector type.

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

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