Property Detail

• java.lang.String baseUrl

  Class for interacting and normalizing behavior using the Confluent KSQL RESTful API.

Method Detail

• java.lang.Object createKsql(java.lang.String sql, java.util.Map properties)

  Executes a KSQL statement using the KSQL RESTful API. Optimized for issuing CREATE TABLE/STREAM statements.

  Parameters:

  sql - the SQL statement to execute.

  properties - Any KSQL parameters to include with the KSQL execution.

  Returns:

  Map with meaningful elements returned in the REST call, plus a 'body' key with the full JSON payload.

• java.lang.Object createKsql(java.util.List sql, java.util.Map properties)

  Executes a List of KSQL statements using the KSQL RESTful API. Optimized for issuing CREATE TABLE/STREAM statements.

  Parameters:

  sql - the List of SQL statements to execute.

  properties - Any KSQL parameters to include with the KSQL execution.

  Returns:

  Map with meaningful elements from the JSON payload elevated as attributes, plus a 'body' key will the full JSON payload.

• java.lang.Object createKsql(java.lang.String sql, java.lang.Boolean earliest = false)

  Executes a KSQL statement using the KSQL RESTful API. Optimized for issuing CREATE TABLE/STREAM statements.

  Parameters:

  sql - The SQL statement to execute.

  earliest - Boolean dictating that the statement should set 'auto.offset.reset' to 'earliest'.

  Returns:

  Map with meaningful elements from the JSON payload elevated as attributes, plus a 'body' key will the full JSON payload.

• java.lang.Object createKsql(java.util.List sql, java.lang.Boolean earliest = false)

  Executes a List of KSQL statements using the KSQL RESTful API. Optimized for issuing CREATE TABLE/STREAM statements.

  Parameters:

  sql - the List of SQL statements to execute.

  earliest - Boolean dictating that the statement should set 'auto.offset.reset' to 'earliest'.

  Returns:

  Map with meaningful elements from the JSON payload elevated as attributes, plus a 'body' key will the full JSON payload.

• 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. Manages issuing TERMINATE statements as part of the DROP, if desired.

  Parameters:

  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.

  Returns:

  Map with meaningful elements from the JSON payload elevated as attributes, plus a 'body' key will the full JSON payload.

• java.lang.Object execKsql(java.lang.String sql, java.util.Map properties)

  Executes a KSQL statement using the KSQL RESTful API.

  Parameters:

  sql - the SQL statement to execute.

  properties - Any KSQL parameters to include with the KSQL execution.

  Returns:

  Map with meaningful elements returned in the REST call, plus a 'body' key with the full JSON payload.

• java.lang.Object execKsql(java.util.List sql, java.util.Map properties)

  Executes a List of KSQL statements using the KSQL RESTful API.

  Parameters:

  sql - the List of SQL statements to execute.

  properties - Any KSQL parameters to include with the KSQL execution.

  Returns:

  Map with meaningful elements from the JSON payload elevated as attributes, plus a 'body' key will the full JSON payload.

• java.lang.Object execKsql(java.lang.String sql, java.lang.Boolean earliest = false)

  Executes a KSQL statement using the KSQL RESTful API.

  Parameters:

  sql - The SQL statement to execute.

  earliest - Boolean dictating that the statement should set 'auto.offset.reset' to 'earliest'.

  Returns:

  Map with meaningful elements from the JSON payload elevated as attributes, plus a 'body' key will the full JSON payload.

• java.lang.Object execKsql(java.util.List sql, java.lang.Boolean earliest = false)

  Executes a List of KSQL statements using the KSQL RESTful API.

  Parameters:

  sql - the List of SQL statements to execute.

  earliest - Boolean dictating that the statement should set 'auto.offset.reset' to 'earliest'.

  Returns:

  Map with meaningful elements from the JSON payload elevated as attributes, plus a 'body' key will the full JSON payload.

• java.io.File getExtensionDir()

  Returns File object for the KSQL Server property value for 'ksql.extension.dir'.

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

  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.

  Returns:

  All the KSQL properties. This is a helper method, used to return individual properties in other methods such as getExtensionPath and getRestUrl.

• java.lang.String getProperty(java.lang.String property)

  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.

  Parameters:

  property - The individual property to return a value for.

  Returns:

  The value of the property specified in the 'property' parameter.

• java.lang.Object getReadQueries(java.lang.String object)

  Returns KSQL Server 'readQueries' object, detailing all the queries currently reading a particular table or stream.

  Returns:

  readQueries object, generated by the KSQL 'DESCRIBE' command.

• java.lang.String getRestUrl()

  Returns the KSQL Server property value for 'ksql.schema.registry.url'.

  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.

  Returns:

  sourceDescription object, generated by the KSQL '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.

  Returns:

  writeQueries object, generated by the KSQL 'DESCRIBE' command.