class ConnectFormatSchemaTranslator implements SchemaTranslator {

  @Override
  public ParsedSchema toParsedSchema(final PersistenceSchema schema) {
    SerdeUtils.throwOnUnsupportedFeatures(schema.features(), format.supportedFeatures());

    final ConnectSchema outerSchema = ConnectSchemas.columnsToConnectSchema(schema.columns());
    final ConnectSchema innerSchema = SerdeUtils
        .applySinglesUnwrapping(outerSchema, schema.features());

    return connectSrTranslator.fromConnectSchema(innerSchema);
  }

    ConnectFormatSchemaTranslator(
      final ConnectFormat format,
      final Map<String, String> formatProps,
      final Function<Schema, Schema> connectKsqlTranslator
  );

}