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