Fix code style issues (confluentinc#599)

* Fix code style issue * Add white space back
satybald · Jan 17, 2018 · 8657654 · 8657654
1 parent ef64f44
commit 8657654
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 12 deletions.
diff --git a/ksql-engine/src/main/java/io/confluent/ksql/KsqlEngine.java b/ksql-engine/src/main/java/io/confluent/ksql/KsqlEngine.java
@@ -161,7 +161,6 @@ public List<QueryMetadata> buildMultipleQueries(
     List<Pair<String, Statement>> queries = parseQueries(queriesString, overriddenProperties, tempMetaStore);
 
     return planQueries(queries, overriddenProperties, tempMetaStore);
-
   }
 
   public List<QueryMetadata> planQueries(final List<Pair<String, Statement>> statementList,
@@ -173,9 +172,9 @@ public List<QueryMetadata> planQueries(final List<Pair<String, Statement>> state
     // Physical plan creation from logical plans.
     List<QueryMetadata> runningQueries = queryEngine.buildPhysicalPlans(
         logicalPlans,
-            statementList,
-            overriddenProperties,
-            true
+        statementList,
+        overriddenProperties,
+        true
     );
 
     for (QueryMetadata queryMetadata : runningQueries) {

diff --git a/ksql-engine/src/main/java/io/confluent/ksql/analyzer/Analyzer.java b/ksql-engine/src/main/java/io/confluent/ksql/analyzer/Analyzer.java
@@ -348,8 +348,7 @@ private StructuredDataSource timestampColumn(AliasedRelation aliasedRelation,
   @Override
   protected Node visitAliasedRelation(AliasedRelation node, AnalysisContext context) {
     String structuredDataSourceName = ((Table) node.getRelation()).getName().getSuffix();
-    if (metaStore.getSource(structuredDataSourceName)
-        == null) {
+    if (metaStore.getSource(structuredDataSourceName) == null) {
       throw new KsqlException(structuredDataSourceName + " does not exist.");
     }
 

diff --git a/ksql-engine/src/main/java/io/confluent/ksql/function/udaf/KudafInitializer.java b/ksql-engine/src/main/java/io/confluent/ksql/function/udaf/KudafInitializer.java
@@ -32,10 +32,7 @@ public KudafInitializer(List initialGenericRowColumns) {
 
   @Override
   public GenericRow apply() {
-    List rowColumns = new ArrayList();
-    for (Object obj: initialGenericRowColumns) {
-      rowColumns.add(obj);
-    }
+    List rowColumns = new ArrayList(initialGenericRowColumns);
     return new GenericRow(rowColumns);
   }
 

diff --git a/ksql-engine/src/main/java/io/confluent/ksql/function/udf/datetime/StringToTimestamp.java b/ksql-engine/src/main/java/io/confluent/ksql/function/udf/datetime/StringToTimestamp.java
@@ -38,7 +38,7 @@ public Object evaluate(Object... args) {
                                       + " date value and format.");
     }
     try {
-      if(dateFormat == null) {
+      if (dateFormat == null) {
         dateFormat = new SimpleDateFormat(args[1].toString());
       }
       return dateFormat.parse(args[0].toString()).getTime();

diff --git a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/KsqlRestApplication.java b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/KsqlRestApplication.java
@@ -243,7 +243,7 @@ public static KsqlRestApplication buildApplication(
 
     try {
       short replicationFactor = 1;
-      if(restConfig.getOriginals().containsKey(KsqlConfig.SINK_NUMBER_OF_REPLICAS_PROPERTY)) {
+      if (restConfig.getOriginals().containsKey(KsqlConfig.SINK_NUMBER_OF_REPLICAS_PROPERTY)) {
         replicationFactor = Short.parseShort(restConfig.getOriginals()
                                                      .get(KsqlConfig.SINK_NUMBER_OF_REPLICAS_PROPERTY).toString());
       }