Package io.confluent.ksql.api.client

Interface Summary

Interface	Description
AcksPublisher	A Reactive Streams Publisher that publishes server acknowledgments for rows inserted into an existing ksqlDB stream via Client.streamInserts(String, Publisher).
Client	A client that connects to a specific ksqlDB server.
Client.HttpRequest	Instances of Client.HttpRequest are used to make direct HTTP requests to ksqlDB server's REST API.
Client.HttpResponse
ClientOptions	Options for the ksqlDB Client.
ColumnType	The type of a column returned as part of a query result.
ConnectorDescription
ConnectorInfo
ConnectorType
ExecuteStatementResult	The result of executing a 'CREATE', 'CREATE ...
FieldInfo	Represents a field/column of a ksqlDB stream/table.
InsertAck	An acknowledgment from the ksqlDB server that a row has been successfully inserted into a ksqlDB stream.
QueryInfo	Metadata for a ksqlDB query.
Row	A single record, returned as part of a query result.
ServerInfo	Metadata for a ksqlDB server.
SourceDescription	Metadata for a ksqlDB stream or table.
StreamedQueryResult	The result of a query (push or pull), streamed one row at time.
StreamInfo	Metadata for a ksqlDB stream.
TableInfo	Metadata for a ksqlDB table.
TopicInfo	Metadata for a Kafka topic available for use with ksqlDB.

Class Summary

Class	Description
BatchedQueryResult	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.
InsertsPublisher	A org.reactivestreams.Publisher suitable for use with the Client.streamInserts(String, Publisher) method.
KsqlArray	A representation of an array of values.
KsqlObject	A representation of a map of string keys to values.

Enum Summary

Enum	Description
ColumnType.Type
ConnectorType.Type
QueryInfo.QueryType