From 520d7791225cbe85baa55b031dc60f186a060f6e Mon Sep 17 00:00:00 2001 From: Damian Guy Date: Fri, 6 Oct 2017 10:40:13 -0700 Subject: [PATCH] remove unused imports --- .../ksql/ddl/commands/AbstractCreateStreamCommand.java | 1 - .../io/confluent/ksql/ddl/commands/CreateTableCommand.java | 1 - .../io/confluent/ksql/function/KsqlAggFunctionDeterminer.java | 1 - .../ksql/function/udaf/sum/SumAggFunctionDeterminer.java | 1 - .../main/java/io/confluent/ksql/structured/SchemaKStream.java | 4 ---- .../main/java/io/confluent/ksql/structured/SchemaKTable.java | 1 - .../java/io/confluent/ksql/util/ExpressionTypeManager.java | 1 - .../src/main/java/io/confluent/ksql/metastore/KsqlTopic.java | 1 - .../java/io/confluent/ksql/rest/entity/TopicDescription.java | 1 - .../confluent/ksql/rest/server/computation/CommandRunner.java | 3 --- .../confluent/ksql/rest/server/computation/CommandStore.java | 2 -- 11 files changed, 17 deletions(-) diff --git a/ksql-engine/src/main/java/io/confluent/ksql/ddl/commands/AbstractCreateStreamCommand.java b/ksql-engine/src/main/java/io/confluent/ksql/ddl/commands/AbstractCreateStreamCommand.java index c0e258b70c9f..e9e77f21d102 100644 --- a/ksql-engine/src/main/java/io/confluent/ksql/ddl/commands/AbstractCreateStreamCommand.java +++ b/ksql-engine/src/main/java/io/confluent/ksql/ddl/commands/AbstractCreateStreamCommand.java @@ -22,7 +22,6 @@ import io.confluent.ksql.parser.tree.Expression; import io.confluent.ksql.parser.tree.TableElement; import io.confluent.ksql.util.KafkaTopicClient; -import io.confluent.ksql.util.KsqlConfig; import io.confluent.ksql.util.KsqlException; import io.confluent.ksql.util.KsqlPreconditions; import io.confluent.ksql.util.SchemaUtil; diff --git a/ksql-engine/src/main/java/io/confluent/ksql/ddl/commands/CreateTableCommand.java b/ksql-engine/src/main/java/io/confluent/ksql/ddl/commands/CreateTableCommand.java index 731933fe6755..bfb6a2e40b4f 100644 --- a/ksql-engine/src/main/java/io/confluent/ksql/ddl/commands/CreateTableCommand.java +++ b/ksql-engine/src/main/java/io/confluent/ksql/ddl/commands/CreateTableCommand.java @@ -22,7 +22,6 @@ import io.confluent.ksql.parser.tree.CreateTable; import io.confluent.ksql.parser.tree.Expression; import io.confluent.ksql.util.KafkaTopicClient; -import io.confluent.ksql.util.KsqlPreconditions; import io.confluent.ksql.util.StringUtil; import java.util.Map; diff --git a/ksql-engine/src/main/java/io/confluent/ksql/function/KsqlAggFunctionDeterminer.java b/ksql-engine/src/main/java/io/confluent/ksql/function/KsqlAggFunctionDeterminer.java index a75c8951c247..f6b7964c0b8f 100644 --- a/ksql-engine/src/main/java/io/confluent/ksql/function/KsqlAggFunctionDeterminer.java +++ b/ksql-engine/src/main/java/io/confluent/ksql/function/KsqlAggFunctionDeterminer.java @@ -17,7 +17,6 @@ package io.confluent.ksql.function; import org.apache.kafka.connect.data.Schema; -import org.apache.kafka.streams.kstream.Merger; import java.util.List; diff --git a/ksql-engine/src/main/java/io/confluent/ksql/function/udaf/sum/SumAggFunctionDeterminer.java b/ksql-engine/src/main/java/io/confluent/ksql/function/udaf/sum/SumAggFunctionDeterminer.java index b6f5a92a1d8d..40327e2a1fab 100644 --- a/ksql-engine/src/main/java/io/confluent/ksql/function/udaf/sum/SumAggFunctionDeterminer.java +++ b/ksql-engine/src/main/java/io/confluent/ksql/function/udaf/sum/SumAggFunctionDeterminer.java @@ -20,7 +20,6 @@ import io.confluent.ksql.function.KsqlAggregateFunction; import io.confluent.ksql.util.KsqlException; import org.apache.kafka.connect.data.Schema; -import org.apache.kafka.streams.kstream.Merger; import java.util.Arrays; import java.util.List; diff --git a/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKStream.java b/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKStream.java index 79871ac11e47..68816d1f551f 100644 --- a/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKStream.java +++ b/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKStream.java @@ -36,23 +36,19 @@ import org.apache.kafka.connect.data.Schema; import org.apache.kafka.connect.data.SchemaBuilder; import org.apache.kafka.streams.KeyValue; -import org.apache.kafka.streams.kstream.ForeachAction; import org.apache.kafka.streams.kstream.KGroupedStream; import org.apache.kafka.streams.kstream.KStream; import org.apache.kafka.streams.kstream.KeyValueMapper; import org.apache.kafka.streams.kstream.ValueJoiner; import org.apache.kafka.streams.kstream.ValueMapper; -import org.apache.kafka.streams.kstream.Windowed; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.ArrayList; import java.util.Arrays; import java.util.List; -import java.util.Objects; import java.util.Optional; import java.util.Set; -import java.util.concurrent.SynchronousQueue; public class SchemaKStream { diff --git a/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKTable.java b/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKTable.java index d665781aa98e..efd6d6f1769d 100644 --- a/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKTable.java +++ b/ksql-engine/src/main/java/io/confluent/ksql/structured/SchemaKTable.java @@ -45,7 +45,6 @@ import java.util.List; import java.util.Optional; import java.util.Set; -import java.util.concurrent.SynchronousQueue; public class SchemaKTable extends SchemaKStream { diff --git a/ksql-engine/src/main/java/io/confluent/ksql/util/ExpressionTypeManager.java b/ksql-engine/src/main/java/io/confluent/ksql/util/ExpressionTypeManager.java index ae8497990657..a66f57410be2 100644 --- a/ksql-engine/src/main/java/io/confluent/ksql/util/ExpressionTypeManager.java +++ b/ksql-engine/src/main/java/io/confluent/ksql/util/ExpressionTypeManager.java @@ -16,7 +16,6 @@ package io.confluent.ksql.util; -import com.google.common.collect.ImmutableMap; import io.confluent.ksql.function.KsqlFunctions; import io.confluent.ksql.function.KsqlAggregateFunction; import io.confluent.ksql.function.KsqlFunction; diff --git a/ksql-metastore/src/main/java/io/confluent/ksql/metastore/KsqlTopic.java b/ksql-metastore/src/main/java/io/confluent/ksql/metastore/KsqlTopic.java index 8c5a16ca7640..44135c936b2c 100644 --- a/ksql-metastore/src/main/java/io/confluent/ksql/metastore/KsqlTopic.java +++ b/ksql-metastore/src/main/java/io/confluent/ksql/metastore/KsqlTopic.java @@ -18,7 +18,6 @@ import io.confluent.ksql.serde.DataSource; import io.confluent.ksql.serde.KsqlTopicSerDe; -import io.confluent.ksql.util.KsqlException; public class KsqlTopic implements DataSource { diff --git a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/entity/TopicDescription.java b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/entity/TopicDescription.java index ff8e529f6215..1b92fff9d227 100644 --- a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/entity/TopicDescription.java +++ b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/entity/TopicDescription.java @@ -23,7 +23,6 @@ import java.util.Objects; -import io.confluent.ksql.metastore.StructuredDataSource; @JsonTypeName("topic_description") public class TopicDescription extends KsqlEntity { diff --git a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandRunner.java b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandRunner.java index 158d6ea228af..1652580a1ca7 100644 --- a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandRunner.java +++ b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandRunner.java @@ -25,10 +25,7 @@ import java.io.Closeable; import java.io.PrintWriter; import java.io.StringWriter; -import java.util.ArrayList; -import java.util.LinkedHashMap; import java.util.List; -import java.util.Map; import java.util.concurrent.atomic.AtomicBoolean; import io.confluent.ksql.util.Pair; diff --git a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandStore.java b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandStore.java index 254e0438f7c7..e6e4946e8ba1 100644 --- a/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandStore.java +++ b/ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/computation/CommandStore.java @@ -33,9 +33,7 @@ import java.util.ArrayList; import java.util.Collection; import java.util.Collections; -import java.util.HashMap; import java.util.HashSet; -import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.concurrent.atomic.AtomicBoolean;