Removed unused methods

Author: garrix-fan

src/main/java/io/confluent/kafka/connect/datagen/DatagenTask.java

@@ -259,80 +259,4 @@ private GenericRecord generateRecord() throws ConnectException {
   @Override
   public void stop() {
   }
-
-  private Schema getOptionalSchema(
-      final Schema schema
-  ) {
-    switch (schema.type()) {
-      case BOOLEAN:
-        return Schema.OPTIONAL_BOOLEAN_SCHEMA;
-      case INT32:
-        return Schema.OPTIONAL_INT32_SCHEMA;
-      case INT64:
-        return Schema.OPTIONAL_INT64_SCHEMA;
-      case FLOAT64:
-        return Schema.OPTIONAL_FLOAT64_SCHEMA;
-      case STRING:
-        return Schema.OPTIONAL_STRING_SCHEMA;
-      case ARRAY:
-        return SchemaBuilder.array(getOptionalSchema(schema.valueSchema())).optional().build();
-      case MAP:
-        return SchemaBuilder.map(
-            getOptionalSchema(schema.keySchema()),
-            getOptionalSchema(schema.valueSchema())
-        ).optional().build();
-      case STRUCT:
-        final SchemaBuilder schemaBuilder = SchemaBuilder.struct();
-        for (Field field : schema.fields()) {
-          schemaBuilder.field(
-              field.name(),
-              getOptionalSchema(field.schema())
-          );
-        }
-        return schemaBuilder.optional().build();
-      default:
-        throw new ConnectException("Unsupported type: " + schema);
-    }
-  }
-
-  private Object getOptionalValue(
-      final Schema schema,
-      final Object value
-  ) {
-    switch (schema.type()) {
-      case BOOLEAN:
-      case INT32:
-      case INT64:
-      case FLOAT64:
-      case STRING:
-        return value;
-      case ARRAY:
-        final List<?> list = (List<?>) value;
-        return list.stream()
-          .map(listItem -> getOptionalValue(schema.valueSchema(), listItem))
-          .collect(Collectors.toList());
-      case MAP:
-        final Map<?, ?> map = (Map<?, ?>) value;
-        return map.entrySet().stream()
-            .collect(Collectors.toMap(
-                k -> getOptionalValue(schema.keySchema(), k),
-                v -> getOptionalValue(schema.valueSchema(), v)
-            ));
-      case STRUCT:
-        final Struct struct = (Struct) value;
-        final Struct optionalStruct = new Struct(getOptionalSchema(schema));
-        for (Field field : schema.fields()) {
-          optionalStruct.put(
-              field.name(),
-              getOptionalValue(
-                  field.schema(),
-                  struct.get(field.name())
-              )
-          );
-        }
-        return optionalStruct;
-      default:
-        throw new ConnectException("Invalid value schema: " + schema + ", value = " + value);
-    }
-  }
 }