| Type | Name and description |
|---|---|
java.lang.String |
baseUrlClass for interacting and normalizing behavior using the Confluent KSQL RESTful API. |
| Type Params | Return Type | Name and description |
|---|---|---|
|
java.lang.Object |
createKsql(java.lang.String sql, java.util.Map properties)Executes a KSQL statement using the KSQL RESTful API. |
|
java.lang.Object |
createKsql(java.util.List sql, java.util.Map properties)Executes a List of KSQL statements using the KSQL RESTful API. |
|
java.lang.Object |
createKsql(java.lang.String sql, java.lang.Boolean earliest = false)Executes a KSQL statement using the KSQL RESTful API. |
|
java.lang.Object |
createKsql(java.util.List sql, java.lang.Boolean earliest = false)Executes a List of KSQL statements using the KSQL RESTful API. |
|
java.lang.Object |
dropKsql(java.util.List sql, java.util.Map properties, java.lang.Boolean terminate = true)Executes a List of KSQL DROP statements using the KSQL RESTful API. |
|
java.lang.Object |
execKsql(java.lang.String sql, java.util.Map properties)Executes a KSQL statement using the KSQL RESTful API. |
|
java.lang.Object |
execKsql(java.util.List sql, java.util.Map properties)Executes a List of KSQL statements using the KSQL RESTful API. |
|
java.lang.Object |
execKsql(java.lang.String sql, java.lang.Boolean earliest = false)Executes a KSQL statement using the KSQL RESTful API. |
|
java.lang.Object |
execKsql(java.util.List sql, java.lang.Boolean earliest = false)Executes a List of KSQL statements using the KSQL RESTful API. |
|
java.io.File |
getExtensionDir()Returns File object for the KSQL Server property value for 'ksql.extension.dir'. |
|
java.lang.String |
getExtensionPath()Returns KSQL Server property value for 'ksql.extension.dir'. |
|
java.lang.Object |
getProperties()Returns KSQL Server properties from the KSQL RESTful API using the 'LIST PROPERTIES' sql statement. |
|
java.lang.String |
getProperty(java.lang.String property)Returns an individual KSQL server property using getProperties. |
|
java.lang.Object |
getReadQueries(java.lang.String object)Returns KSQL Server 'readQueries' object, detailing all the queries currently reading a particular table or stream. |
|
java.lang.String |
getRestUrl()Returns the KSQL Server property value for 'ksql.schema.registry.url'. |
|
java.lang.Object |
getSourceDescription(java.lang.String object)Returns KSQL Server 'sourceDescription' object, containing the results of the 'DESCRIBE' command. |
|
java.lang.Object |
getWriteQueries(java.lang.String object)Returns KSQL Server 'writeQueries' object, detailing all the queries currently writing to a particular table or stream. |
| Methods inherited from class | Name |
|---|---|
class java.lang.Object |
java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll() |
Class for interacting and normalizing behavior using the Confluent KSQL RESTful API.
Executes a KSQL statement using the KSQL RESTful API. Optimized for issuing CREATE TABLE/STREAM statements.
sql - the SQL statement to execute.properties - Any KSQL parameters to include with the KSQL execution.Executes a List of KSQL statements using the KSQL RESTful API. Optimized for issuing CREATE TABLE/STREAM statements.
sql - the List of SQL statements to execute.properties - Any KSQL parameters to include with the KSQL execution.Executes a KSQL statement using the KSQL RESTful API. Optimized for issuing CREATE TABLE/STREAM statements.
sql - The SQL statement to execute.earliest - Boolean dictating that the statement should set 'auto.offset.reset' to 'earliest'.Executes a List of KSQL statements using the KSQL RESTful API. Optimized for issuing CREATE TABLE/STREAM statements.
sql - the List of SQL statements to execute.earliest - Boolean dictating that the statement should set 'auto.offset.reset' to 'earliest'.Executes a List of KSQL DROP statements using the KSQL RESTful API. Manages issuing TERMINATE statements as part of the DROP, if desired.
sql - the List of SQL DROP statements to execute.properties - Any KSQL parameters to include with the KSQL execution.terminate - Determines whether TERMINATE statements are issued, along with a retry of the DROP.Executes a KSQL statement using the KSQL RESTful API.
sql - the SQL statement to execute.properties - Any KSQL parameters to include with the KSQL execution.Executes a List of KSQL statements using the KSQL RESTful API.
sql - the List of SQL statements to execute.properties - Any KSQL parameters to include with the KSQL execution.Executes a KSQL statement using the KSQL RESTful API.
sql - The SQL statement to execute.earliest - Boolean dictating that the statement should set 'auto.offset.reset' to 'earliest'.Executes a List of KSQL statements using the KSQL RESTful API.
sql - the List of SQL statements to execute.earliest - Boolean dictating that the statement should set 'auto.offset.reset' to 'earliest'.Returns File object for the KSQL Server property value for 'ksql.extension.dir'.
Returns KSQL Server property value for 'ksql.extension.dir'.
Returns KSQL Server properties from the KSQL RESTful API using the 'LIST PROPERTIES' sql statement.
Returns an individual KSQL server property using getProperties. This is a helper method, used to return individual properties in other methods such as getExtensionPath and getRestUrl.
property - The individual property to return a value for.Returns KSQL Server 'readQueries' object, detailing all the queries currently reading a particular table or stream.
Returns the KSQL Server property value for 'ksql.schema.registry.url'.
Returns KSQL Server 'sourceDescription' object, containing the results of the 'DESCRIBE' command.
Returns KSQL Server 'writeQueries' object, detailing all the queries currently writing to a particular table or stream.