class ConnectDataTranslator implements DataTranslator {

  @Override
  public Object toKsqlRow(final Schema connectSchema, final Object connectData) {
    if (connectData == null) {
      return null;
    }

    return toKsqlValue(schema, connectSchema, connectData, "");
  }

  public  ConnectDataTranslator(final Schema schema);

}