This class is meant to be inherited, which is why it doesn't have a @TaskAction-annotated method.
| Fields inherited from class | Fields |
|---|---|
class org.gradle.api.DefaultTask |
TASK_NAME, TASK_DESCRIPTION, TASK_GROUP, TASK_TYPE, TASK_DEPENDS_ON, TASK_OVERWRITE, TASK_ACTION, TASK_CONSTRUCTOR_ARGS |
| Type | Name and description |
|---|---|
boolean |
noReverseDropsWhen defined, DROP statements are not processed in reverse order of the CREATE statements, which is the default. |
java.lang.String |
pipelinePathThe base directory containing SQL scripts to execute, including recursive subdirectories. |
| Type Params | Return Type | Name and description |
|---|---|---|
|
java.io.File |
getCreateScript()Returns a File object representation of the KSQL create script. |
|
java.io.File |
getDir()Returns a File object representation of the {@pipelinePath} parameter. |
|
java.lang.Object |
getDirectiveObjects(java.lang.String directiveType)Returns a List of tables or streams that have a specific directive for execution behavior. |
|
java.lang.Object |
getDirectives()Returns a List of Map objects of "Comment Directives" from the KSQL source directory. |
|
java.util.List |
getDropSql()Returns a List of DROP KSQL statements: one for each CREATE statement in the specified pipeline directory. |
|
java.io.File |
getPipelineBuildDir()Returns a File object representation of the {@project.extensions.confluent.pipelineBuildName} parameter. |
|
java.util.List |
getPipelineFiles()Gets the hierarchical collection of pipeline files, sorted using folder structure and alphanumeric logic. |
|
java.lang.Object |
getPipelineSql()Gets the hierarchical collection of pipeline SQL statements--tokenized and normalized--and sorted using getPipelineFiles. |
|
java.lang.Object |
getTokenizedSql()Gets tokenized (based on ';') pipeline KSQL statements using getPipelineFiles. |
| Methods inherited from class | Name |
|---|---|
class org.gradle.api.DefaultTask |
org.gradle.api.DefaultTask#getExtensions(), org.gradle.api.DefaultTask#getLogger(), org.gradle.api.DefaultTask#property(java.lang.String), org.gradle.api.DefaultTask#getAnt(), org.gradle.api.DefaultTask#configure(groovy.lang.Closure), org.gradle.api.DefaultTask#configure(groovy.lang.Closure), org.gradle.api.DefaultTask#isEnabled(), org.gradle.api.DefaultTask#getDescription(), org.gradle.api.DefaultTask#setEnabled(boolean), org.gradle.api.DefaultTask#setGroup(java.lang.String), org.gradle.api.DefaultTask#getTimeout(), org.gradle.api.DefaultTask#hasProperty(java.lang.String), org.gradle.api.DefaultTask#getGroup(), org.gradle.api.DefaultTask#getInputs(), org.gradle.api.DefaultTask#getInputs(), org.gradle.api.DefaultTask#setDescription(java.lang.String), org.gradle.api.DefaultTask#getProject(), org.gradle.api.DefaultTask#getConvention(), org.gradle.api.DefaultTask#getLogging(), org.gradle.api.DefaultTask#getLogging(), org.gradle.api.DefaultTask#getDidWork(), org.gradle.api.DefaultTask#getIdentityPath(), org.gradle.api.DefaultTask#getStandardOutputCapture(), org.gradle.api.DefaultTask#setActions(java.util.List), org.gradle.api.DefaultTask#getTaskDependencies(), org.gradle.api.DefaultTask#getTaskDependencies(), org.gradle.api.DefaultTask#getDependsOn(), org.gradle.api.DefaultTask#setDependsOn(java.lang.Iterable), org.gradle.api.DefaultTask#dependsOn([Ljava.lang.Object;), org.gradle.api.DefaultTask#onlyIf(groovy.lang.Closure), org.gradle.api.DefaultTask#onlyIf(org.gradle.api.specs.Spec), org.gradle.api.DefaultTask#setOnlyIf(groovy.lang.Closure), org.gradle.api.DefaultTask#setOnlyIf(org.gradle.api.specs.Spec), org.gradle.api.DefaultTask#setDidWork(boolean), org.gradle.api.DefaultTask#doFirst(groovy.lang.Closure), org.gradle.api.DefaultTask#doFirst(java.lang.String, org.gradle.api.Action), org.gradle.api.DefaultTask#doFirst(org.gradle.api.Action), org.gradle.api.DefaultTask#doLast(groovy.lang.Closure), org.gradle.api.DefaultTask#doLast(java.lang.String, org.gradle.api.Action), org.gradle.api.DefaultTask#doLast(org.gradle.api.Action), org.gradle.api.DefaultTask#getEnabled(), org.gradle.api.DefaultTask#getOutputs(), org.gradle.api.DefaultTask#getOutputs(), org.gradle.api.DefaultTask#getDestroyables(), org.gradle.api.DefaultTask#getLocalState(), org.gradle.api.DefaultTask#getTemporaryDir(), org.gradle.api.DefaultTask#mustRunAfter([Ljava.lang.Object;), org.gradle.api.DefaultTask#setMustRunAfter(java.lang.Iterable), org.gradle.api.DefaultTask#getMustRunAfter(), org.gradle.api.DefaultTask#finalizedBy([Ljava.lang.Object;), org.gradle.api.DefaultTask#setFinalizedBy(java.lang.Iterable), org.gradle.api.DefaultTask#getFinalizedBy(), org.gradle.api.DefaultTask#shouldRunAfter([Ljava.lang.Object;), org.gradle.api.DefaultTask#setShouldRunAfter(java.lang.Iterable), org.gradle.api.DefaultTask#getShouldRunAfter(), org.gradle.api.DefaultTask#usesService(org.gradle.api.provider.Provider), org.gradle.api.DefaultTask#getAsDynamicObject(), org.gradle.api.DefaultTask#getTaskIdentity(), org.gradle.api.DefaultTask#injectIntoNewInstance(org.gradle.api.internal.project.ProjectInternal, org.gradle.api.internal.project.taskfactory.TaskIdentity, java.util.concurrent.Callable), org.gradle.api.DefaultTask#getTaskActions(), org.gradle.api.DefaultTask#hasTaskActions(), org.gradle.api.DefaultTask#getOnlyIf(), org.gradle.api.DefaultTask#getImpliesSubProjects(), org.gradle.api.DefaultTask#setImpliesSubProjects(boolean), org.gradle.api.DefaultTask#replaceLogger(org.gradle.api.logging.Logger), org.gradle.api.DefaultTask#getTemporaryDirFactory(), org.gradle.api.DefaultTask#prependParallelSafeAction(org.gradle.api.Action), org.gradle.api.DefaultTask#appendParallelSafeAction(org.gradle.api.Action), org.gradle.api.DefaultTask#isHasCustomActions(), org.gradle.api.DefaultTask#getRequiredServices(), org.gradle.api.DefaultTask#getSharedResources(), org.gradle.api.DefaultTask#setProperty(java.lang.String, java.lang.Object), org.gradle.api.DefaultTask#toString(), org.gradle.api.DefaultTask#compareTo(org.gradle.api.Task), org.gradle.api.DefaultTask#compareTo(java.lang.Object), org.gradle.api.DefaultTask#getName(), org.gradle.api.DefaultTask#getActions(), org.gradle.api.DefaultTask#getState(), org.gradle.api.DefaultTask#getState(), org.gradle.api.DefaultTask#getPath(), org.gradle.api.DefaultTask#wait(long, int), org.gradle.api.DefaultTask#wait(long), org.gradle.api.DefaultTask#wait(), org.gradle.api.DefaultTask#equals(java.lang.Object), org.gradle.api.DefaultTask#hashCode(), org.gradle.api.DefaultTask#getClass(), org.gradle.api.DefaultTask#notify(), org.gradle.api.DefaultTask#notifyAll() |
When defined, DROP statements are not processed in reverse order of the CREATE statements, which is the default.
The base directory containing SQL scripts to execute, including recursive subdirectories. Default: {@getDir}.
Returns a File object representation of the KSQL create script.
Returns a File object representation of the {@pipelinePath} parameter.
Returns a List of tables or streams that have a specific directive for execution behavior. Directives are defined in KSQL scripts using: "--@DirectiveName". For instance, the directive that controls whether or not an underlying topic is deleted during {@pipelineExecute} is: --
Returns a List of Map objects of "Comment Directives" from the KSQL source directory. These directives are of the form: "--@", and are used to control certain behaviors.
Returns a List of DROP KSQL statements: one for each CREATE statement in the specified pipeline directory. The default behavior is to return those DROP statements in the reverse order of the CREATE statement. This can be disabled using {@noReverseDrops} in the API, or the task option '--no-reverse-drops'.
Returns a File object representation of the {@project.extensions.confluent.pipelineBuildName} parameter.
Gets the hierarchical collection of pipeline files, sorted using folder structure and alphanumeric logic.
Gets the hierarchical collection of pipeline SQL statements--tokenized and normalized--and sorted using getPipelineFiles.
Gets tokenized (based on ';') pipeline KSQL statements using getPipelineFiles.