spotless format

Netflix · Apr 28, 2022 · 51a906f · 51a906f
1 parent ffee4cb
commit 51a906f
Show file tree

Hide file tree

Showing 79 changed files with 1,500 additions and 500 deletions.
diff --git a/cassandra-persistence/src/main/java/com/netflix/conductor/cassandra/util/Statements.java b/cassandra-persistence/src/main/java/com/netflix/conductor/cassandra/util/Statements.java
@@ -289,7 +289,9 @@ public String getDeleteTaskDefStatement() {
     // ExecutionDAO
     // Insert Statements
 
-    /** @return cql query statement to insert a new workflow into the "workflows" table */
+    /**
+     * @return cql query statement to insert a new workflow into the "workflows" table
+     */
     public String getInsertWorkflowStatement() {
         return QueryBuilder.insertInto(keyspace, TABLE_WORKFLOWS)
                 .value(WORKFLOW_ID_KEY, bindMarker())
@@ -302,7 +304,9 @@ public String getInsertWorkflowStatement() {
                 .getQueryString();
     }
 
-    /** @return cql query statement to insert a new task into the "workflows" table */
+    /**
+     * @return cql query statement to insert a new task into the "workflows" table
+     */
     public String getInsertTaskStatement() {
         return QueryBuilder.insertInto(keyspace, TABLE_WORKFLOWS)
                 .value(WORKFLOW_ID_KEY, bindMarker())
@@ -340,7 +344,9 @@ public String getSelectTotalStatement() {
                 .getQueryString();
     }
 
-    /** @return cql query statement to retrieve a task from the "workflows" table */
+    /**
+     * @return cql query statement to retrieve a task from the "workflows" table
+     */
     public String getSelectTaskStatement() {
         return QueryBuilder.select(PAYLOAD_KEY)
                 .from(keyspace, TABLE_WORKFLOWS)
@@ -414,7 +420,9 @@ public String getSelectAllEventExecutionsForMessageFromEventExecutionsStatement(
 
     // Update Statements
 
-    /** @return cql query statement to update a workflow in the "workflows" table */
+    /**
+     * @return cql query statement to update a workflow in the "workflows" table
+     */
     public String getUpdateWorkflowStatement() {
         return QueryBuilder.update(keyspace, TABLE_WORKFLOWS)
                 .with(set(PAYLOAD_KEY, bindMarker()))
@@ -461,7 +469,9 @@ public String getUpdateTaskLookupStatement() {
                 .getQueryString();
     }
 
-    /** @return cql query statement to add a new task_id to the "task_def_limit" table */
+    /**
+     * @return cql query statement to add a new task_id to the "task_def_limit" table
+     */
     public String getUpdateTaskDefLimitStatement() {
         return QueryBuilder.update(keyspace, TABLE_TASK_DEF_LIMIT)
                 .with(set(WORKFLOW_ID_KEY, bindMarker()))
@@ -470,7 +480,9 @@ public String getUpdateTaskDefLimitStatement() {
                 .getQueryString();
     }
 
-    /** @return cql query statement to update an event execution in the "event_executions" table */
+    /**
+     * @return cql query statement to update an event execution in the "event_executions" table
+     */
     public String getUpdateEventExecutionStatement() {
         return QueryBuilder.update(keyspace, TABLE_EVENT_EXECUTIONS)
                 .using(QueryBuilder.ttl(bindMarker()))
@@ -483,7 +495,9 @@ public String getUpdateEventExecutionStatement() {
 
     // Delete statements
 
-    /** @return cql query statement to delete a workflow from the "workflows" table */
+    /**
+     * @return cql query statement to delete a workflow from the "workflows" table
+     */
     public String getDeleteWorkflowStatement() {
         return QueryBuilder.delete()
                 .from(keyspace, TABLE_WORKFLOWS)
@@ -503,7 +517,9 @@ public String getDeleteTaskLookupStatement() {
                 .getQueryString();
     }
 
-    /** @return cql query statement to delete a task from the "workflows" table */
+    /**
+     * @return cql query statement to delete a task from the "workflows" table
+     */
     public String getDeleteTaskStatement() {
         return QueryBuilder.delete()
                 .from(keyspace, TABLE_WORKFLOWS)
@@ -514,7 +530,9 @@ public String getDeleteTaskStatement() {
                 .getQueryString();
     }
 
-    /** @return cql query statement to delete a task_id from the "task_def_limit" table */
+    /**
+     * @return cql query statement to delete a task_id from the "task_def_limit" table
+     */
     public String getDeleteTaskDefLimitStatement() {
         return QueryBuilder.delete()
                 .from(keyspace, TABLE_TASK_DEF_LIMIT)
@@ -523,7 +541,9 @@ public String getDeleteTaskDefLimitStatement() {
                 .getQueryString();
     }
 
-    /** @return cql query statement to delete an event execution from the "event_execution" table */
+    /**
+     * @return cql query statement to delete an event execution from the "event_execution" table
+     */
     public String getDeleteEventExecutionsStatement() {
         return QueryBuilder.delete()
                 .from(keyspace, TABLE_EVENT_EXECUTIONS)
@@ -536,7 +556,9 @@ public String getDeleteEventExecutionsStatement() {
     // EventHandlerDAO
     // Insert Statements
 
-    /** @return cql query statement to insert an event handler into the "event_handlers" table */
+    /**
+     * @return cql query statement to insert an event handler into the "event_handlers" table
+     */
     public String getInsertEventHandlerStatement() {
         return QueryBuilder.insertInto(keyspace, TABLE_EVENT_HANDLERS)
                 .value(HANDLERS_KEY, HANDLERS_KEY)

diff --git a/client/src/main/java/com/netflix/conductor/client/automator/TaskRunnerConfigurer.java b/client/src/main/java/com/netflix/conductor/client/automator/TaskRunnerConfigurer.java
@@ -198,17 +198,23 @@ public TaskRunnerConfigurer build() {
         }
     }
 
-    /** @return Thread Count for the shared executor pool */
+    /**
+     * @return Thread Count for the shared executor pool
+     */
     public int getThreadCount() {
         return threadCount;
     }
 
-    /** @return Thread Count for individual task type */
+    /**
+     * @return Thread Count for individual task type
+     */
     public Map<String, Integer> getTaskThreadCount() {
         return taskThreadCount;
     }
 
-    /** @return seconds before forcing shutdown of worker */
+    /**
+     * @return seconds before forcing shutdown of worker
+     */
     public int getShutdownGracePeriodSeconds() {
         return shutdownGracePeriodSeconds;
     }
@@ -229,7 +235,9 @@ public int getUpdateRetryCount() {
         return updateRetryCount;
     }
 
-    /** @return prefix used for worker names */
+    /**
+     * @return prefix used for worker names
+     */
     public String getWorkerNamePrefix() {
         return workerNamePrefix;
     }

diff --git a/client/src/main/java/com/netflix/conductor/client/http/EventClient.java b/client/src/main/java/com/netflix/conductor/client/http/EventClient.java
@@ -36,7 +36,9 @@ public EventClient() {
         this(new DefaultClientConfig(), new DefaultConductorClientConfiguration(), null);
     }
 
-    /** @param clientConfig REST Client configuration */
+    /**
+     * @param clientConfig REST Client configuration
+     */
     public EventClient(ClientConfig clientConfig) {
         this(clientConfig, new DefaultConductorClientConfiguration(), null);
     }

diff --git a/client/src/main/java/com/netflix/conductor/client/http/MetadataClient.java b/client/src/main/java/com/netflix/conductor/client/http/MetadataClient.java
@@ -34,7 +34,9 @@ public MetadataClient() {
         this(new DefaultClientConfig(), new DefaultConductorClientConfiguration(), null);
     }
 
-    /** @param clientConfig REST Client configuration */
+    /**
+     * @param clientConfig REST Client configuration
+     */
     public MetadataClient(ClientConfig clientConfig) {
         this(clientConfig, new DefaultConductorClientConfiguration(), null);
     }

diff --git a/client/src/main/java/com/netflix/conductor/client/http/TaskClient.java b/client/src/main/java/com/netflix/conductor/client/http/TaskClient.java
@@ -69,7 +69,9 @@ public TaskClient() {
         this(new DefaultClientConfig(), new DefaultConductorClientConfiguration(), null);
     }
 
-    /** @param config REST Client configuration */
+    /**
+     * @param config REST Client configuration
+     */
     public TaskClient(ClientConfig config) {
         this(config, new DefaultConductorClientConfiguration(), null);
     }

diff --git a/client/src/main/java/com/netflix/conductor/client/http/WorkflowClient.java b/client/src/main/java/com/netflix/conductor/client/http/WorkflowClient.java
@@ -54,7 +54,9 @@ public WorkflowClient() {
         this(new DefaultClientConfig(), new DefaultConductorClientConfiguration(), null);
     }
 
-    /** @param config REST Client configuration */
+    /**
+     * @param config REST Client configuration
+     */
     public WorkflowClient(ClientConfig config) {
         this(config, new DefaultConductorClientConfiguration(), null);
     }

diff --git a/common/src/main/java/com/netflix/conductor/common/metadata/Auditable.java b/common/src/main/java/com/netflix/conductor/common/metadata/Auditable.java
@@ -24,52 +24,72 @@ public abstract class Auditable {
 
     private String updatedBy;
 
-    /** @return the ownerApp */
+    /**
+     * @return the ownerApp
+     */
     public String getOwnerApp() {
         return ownerApp;
     }
 
-    /** @param ownerApp the ownerApp to set */
+    /**
+     * @param ownerApp the ownerApp to set
+     */
     public void setOwnerApp(String ownerApp) {
         this.ownerApp = ownerApp;
     }
 
-    /** @return the createTime */
+    /**
+     * @return the createTime
+     */
     public Long getCreateTime() {
         return createTime;
     }
 
-    /** @param createTime the createTime to set */
+    /**
+     * @param createTime the createTime to set
+     */
     public void setCreateTime(Long createTime) {
         this.createTime = createTime;
     }
 
-    /** @return the updateTime */
+    /**
+     * @return the updateTime
+     */
     public Long getUpdateTime() {
         return updateTime;
     }
 
-    /** @param updateTime the updateTime to set */
+    /**
+     * @param updateTime the updateTime to set
+     */
     public void setUpdateTime(Long updateTime) {
         this.updateTime = updateTime;
     }
 
-    /** @return the createdBy */
+    /**
+     * @return the createdBy
+     */
     public String getCreatedBy() {
         return createdBy;
     }
 
-    /** @param createdBy the createdBy to set */
+    /**
+     * @param createdBy the createdBy to set
+     */
     public void setCreatedBy(String createdBy) {
         this.createdBy = createdBy;
     }
 
-    /** @return the updatedBy */
+    /**
+     * @return the updatedBy
+     */
     public String getUpdatedBy() {
         return updatedBy;
     }
 
-    /** @param updatedBy the updatedBy to set */
+    /**
+     * @param updatedBy the updatedBy to set
+     */
     public void setUpdatedBy(String updatedBy) {
         this.updatedBy = updatedBy;
     }