Index (gradle-confluent 1.1.22 API)

A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _

A

apply(Project) - Method in ConfluentPlugin: Apply the Gradle Plugin.
applyExtension(Project) - Method in ConfluentPlugin: Apply the Gradle Plugin extension.

B

C

ConfluentPlugin - Class in com.redpillanalytics.gradle
ConfluentPluginExtension - Class in com.redpillanalytics.gradle
createKsql(List, Boolean) - Method in KsqlRest: Executes a List of KSQL statements using the KSQL RESTful API.
createScript() - Method in PipelineScriptTask: Builds the KSQL script for the directory or directories.

D

dropKsql(String, Map) - Method in KsqlRest: Executes a KSQL DROP statement using the KSQL RESTful API.

E

execKsql(List, Boolean) - Method in KsqlRest: Executes a List of KSQL statements using the KSQL RESTful API.
executePipelines() - Method in PipelineExecuteTask

F

G

getConfig() - Method in LoadConfigTask: Get the ConfigSlurper representation of the Configuration.
getConfigFile() - Method in LoadConfigTask: Get the configuration File object for managing Streams applications.
getCreateScript() - Method in PipelineTask: Returns a File object representation of the KSQL create script.
getDir() - Method in PipelineTask: Returns a File object representation of the {@pipelinePath} parameter.
getDirectiveObjects(String) - Method in PipelineTask: Returns a List of tables or streams that have a specific directive for execution behavior.
getDirectives() - Method in PipelineTask: Returns a List of Map objects of "Comment Directives" from the KSQL source directory.
getDomainName() - Method in TaskGroupContainer
getDropSql() - Method in PipelineTask: Returns a List of DROP KSQL statements: one for each CREATE statement in the specified pipeline directory.
getExtensionDir() - Method in KsqlRest: Returns File object for the KSQL Server property value for 'ksql.extension.dir'.
getExtensionPath() - Method in KsqlRest: Returns KSQL Server property value for 'ksql.extension.dir'.
getKsqlRest() - Method in PipelineExecuteTask: Instantiates a KsqlRest Class, which is used for interacting with the KSQL RESTful API.
getObjectName(String) - Method in KsqlRest: Returns the object type from a KSQL CREATE or DROP statement.
getPipelineBuildDir() - Method in PipelineTask: Returns a File object representation of the {@project.extensions.confluent.pipelineBuildName} parameter.
getPipelineFiles() - Method in PipelineTask: Gets the hierarchical collection of pipeline files, sorted using folder structure and alphanumeric logic.
getPipelinePath() - Method in ConfluentPluginExtension: Provides the path for Pipeline source files.
getPipelineSql() - Method in PipelineTask: Gets the hierarchical collection of pipeline SQL statements--tokenized and normalized--and sorted using getPipelineFiles.
getProperties() - Method in KsqlRest: Returns KSQL Server properties from the KSQL RESTful API using the 'LIST PROPERTIES' sql statement.
getProperty(String) - Method in KsqlRest: Returns an individual KSQL server property using getProperties.
getQueryIds(String) - Method in KsqlRest: Returns KSQL Server query IDs for all 'writeQueries' and 'readQueries' associated with a particular object.
getReadQueries(String) - Method in KsqlRest: Returns KSQL Server 'readQueries' object, detailing all the queries currently reading a particular table or stream.
getSchemaRegistry() - Method in KsqlRest: Returns the KSQL Server property value for 'ksql.schema.registry.url'.
getSourceDescription(String) - Method in KsqlRest: Returns KSQL Server 'sourceDescription' object, containing the results of the 'DESCRIBE' command.
getStatementType(String) - Method in KsqlRest: Returns the statement type from a KSQL CREATE or DROP statement.
getStreams() - Method in KsqlRest: Return a list of stream objects
getTaskName(String) - Method in TaskGroupContainer: A method that makes it easy for naming 'default' tasks versus non-'default' tasks.
getTokenizedSql() - Method in PipelineTask: Gets tokenized (based on ';') pipeline KSQL statements using getPipelineFiles.
getTopics() - Method in KsqlRest: Return a list of topic objects
getWriteQueries(String) - Method in KsqlRest: Returns KSQL Server 'writeQueries' object, detailing all the queries currently writing to a particular table or stream.

H

I

isDefaultTask(String) - Method in TaskGroupContainer: This plugin has a default set of tasks that are configured with a single task group called 'default'.

J

K

KsqlRest - Class in com.redpillanalytics

L

listTopics() - Method in ListTopicsTask
ListTopicsTask - Class in com.redpillanalytics.gradle.tasks: List all topics available to KSQL
ListTopicsTask() - Constructor in ListTopicsTask
LoadConfigTask - Class in com.redpillanalytics.gradle.tasks
LoadConfigTask() - Constructor in LoadConfigTask
loadProperties() - Method in LoadConfigTask: Execute the Gradle task action.
logTaskName(String) - Method in TaskGroupContainer: Easy method for instrumentation configuring Gradle tasks.

M

N

O

P

PipelineExecuteTask - Class in com.redpillanalytics.gradle.tasks: Use the KSQL RESTful API to execute all pipelines in a particular directory.
PipelineExecuteTask() - Constructor in PipelineExecuteTask
pipelineScript() - Method in PipelineScriptTask
PipelineScriptTask - Class in com.redpillanalytics.gradle.tasks: Generate CREATE and DROP scripts used for deployment to KSQL Servers.
PipelineScriptTask() - Constructor in PipelineScriptTask
PipelineTask - Class in com.redpillanalytics.gradle.tasks: This class is meant to be inherited, which is why it doesn't have a @TaskAction-annotated method.