feat(static): allow logical schema to have fields in any order (#3422)

* feat(static): allow logical schema to have fields in any order Our logical schema should be able to support schemas where the is not key column, no rowtime, or has key columns interleaved with value columns. This is because a projection does not necessarily include key at the start, or at all, or rowtime.
confluentinc · Sep 27, 2019 · d935af3 · d935af3
1 parent fe63d21
commit d935af3
Show file tree

Hide file tree

Showing 21 changed files with 371 additions and 271 deletions.
diff --git a/ksql-common/src/main/java/io/confluent/ksql/schema/ksql/LogicalSchema.java b/ksql-common/src/main/java/io/confluent/ksql/schema/ksql/LogicalSchema.java
diff --git a/ksql-common/src/main/java/io/confluent/ksql/util/SchemaUtil.java b/ksql-common/src/main/java/io/confluent/ksql/util/SchemaUtil.java
@@ -81,15 +81,6 @@ public final class SchemaUtil {
 
   private static final char FIELD_NAME_DELIMITER = '.';
 
-  private static final ImmutableMap<Schema.Type, String> SCHEMA_TYPE_TO_CAST_STRING =
-      new ImmutableMap.Builder<Schema.Type, String>()
-          .put(Schema.Type.INT32, "(Integer)")
-          .put(Schema.Type.INT64, "(Long)")
-          .put(Schema.Type.FLOAT64, "(Double)")
-          .put(Schema.Type.STRING, "(String)")
-          .put(Schema.Type.BOOLEAN, "(Boolean)")
-          .build();
-
   private static final Map<Type, BiPredicate<Schema, Schema>> CUSTOM_SCHEMA_EQ =
       ImmutableMap.<Type, BiPredicate<Schema, Schema>>builder()
           .put(Type.MAP, SchemaUtil::mapCompatible)