Reversion: Tech debt: Revert to KCQL java tests

java-connectors/kafka-connect-query-language/src/main/java/io/lenses/kcql/Field.java

@@ -17,6 +17,7 @@
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Objects;
 
 public class Field {
 
@@ -34,10 +35,10 @@ public Field(String name, FieldType fieldType, List<String> parents) {
   }
 
   public Field(String name, String alias, FieldType fieldType, List<String> parents) {
-    if (name == null || name.trim().length() == 0) {
+    if (name == null || name.trim().isEmpty()) {
       throw new IllegalArgumentException(String.format("field is not valid:<%s>", String.valueOf(name)));
     }
-    if (alias == null || alias.trim().length() == 0) {
+    if (alias == null || alias.trim().isEmpty()) {
       throw new IllegalArgumentException(String.format("alias is not valid:<%s>", String.valueOf(alias)));
     }
     this.name = name;
@@ -77,6 +78,33 @@ public String toString() {
     return sb.toString();
   }
 
+  @Override
+  public boolean equals(Object o) {
+    if (this == o)
+      return true;
+    if (o == null || getClass() != o.getClass())
+      return false;
+
+    Field field = (Field) o;
+
+    if (!Objects.equals(name, field.name))
+      return false;
+    if (!Objects.equals(alias, field.alias))
+      return false;
+    if (fieldType != field.fieldType)
+      return false;
+    return Objects.equals(parentFields, field.parentFields);
+  }
+
+  @Override
+  public int hashCode() {
+    int result = name != null ? name.hashCode() : 0;
+    result = 31 * result + (alias != null ? alias.hashCode() : 0);
+    result = 31 * result + (fieldType != null ? fieldType.hashCode() : 0);
+    result = 31 * result + (parentFields != null ? parentFields.hashCode() : 0);
+    return result;
+  }
+
   public static Field from(String name, List<String> parents) {
     return from(name, null, parents);
   }

java-connectors/kafka-connect-query-language/src/main/java/io/lenses/kcql/Kcql.java

@@ -24,6 +24,7 @@
 import java.util.*;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 /**
  * Parsing support for Kafka Connect Query Language.
@@ -248,6 +249,14 @@ public Iterator<String> getPartitionBy() {
     return partitionBy.iterator();
   }
 
+  public Set<String> getPartitionByAsSet() {
+    Iterator<String> partitionByIter = getPartitionBy();
+    return Stream.generate(() -> null)
+        .takeWhile(x -> partitionByIter.hasNext())
+        .map(n -> partitionByIter.next())
+        .collect(Collectors.toSet());
+  }
+
   public List<Tag> getTags() {
     return tags;
   }

java-connectors/kafka-connect-query-language/src/main/java/io/lenses/kcql/Tag.java

@@ -15,6 +15,8 @@
  */
 package io.lenses.kcql;
 
+import java.util.Objects;
+
 public class Tag {
 
   private final String key;
@@ -50,4 +52,28 @@ public enum TagType {
     ALIAS,
     CONSTANT
   }
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o)
+      return true;
+    if (o == null || getClass() != o.getClass())
+      return false;
+
+    Tag tag = (Tag) o;
+
+    if (!Objects.equals(key, tag.key))
+      return false;
+    if (!Objects.equals(value, tag.value))
+      return false;
+    return type == tag.type;
+  }
+
+  @Override
+  public int hashCode() {
+    int result = key != null ? key.hashCode() : 0;
+    result = 31 * result + (value != null ? value.hashCode() : 0);
+    result = 31 * result + (type != null ? type.hashCode() : 0);
+    return result;
+  }
 }