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 viaClient.streamInserts(String, Publisher)
.Client A client that connects to a specific ksqlDB server.ClientOptions Options for the ksqlDBClient
.ColumnType The type of a column returned as part of a query result.ExecuteStatementResult The result of executing a 'CREATE', 'CREATE ...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.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 Aorg.reactivestreams.Publisher
suitable for use with theClient.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 QueryInfo.QueryType