@Test public void testToConnectBytes() { org.apache.avro.Schema avroSchema = org.apache.avro.SchemaBuilder.builder().bytesType(); assertEquals(new SchemaAndValue(Schema.BYTES_SCHEMA, ByteBuffer.wrap("foo".getBytes())), avroData.toConnectData(avroSchema, "foo".getBytes())); assertEquals(new SchemaAndValue(Schema.BYTES_SCHEMA, ByteBuffer.wrap("foo".getBytes())), avroData.toConnectData(avroSchema, ByteBuffer.wrap("foo".getBytes()))); }
public SchemaAndValue toConnectData(org.apache.avro.Schema avroSchema, Object value) { return toConnectData(avroSchema, value, null); }
AvroData { public SchemaAndValue toConnectData(org.apache.avro.Schema avroSchema, Object value) { return toConnectData(avroSchema, value, null); } }
AvroData { public SchemaAndValue toConnectData(org.apache.avro.Schema avroSchema, Object value) { return toConnectData(avroSchema, value, null); } AvroData(int cacheSize);  AvroData(AvroDataConfig avroDataConfig); }
AvroData { public SchemaAndValue toConnectData(org.apache.avro.Schema avroSchema, Object value) { return toConnectData(avroSchema, value, null); } AvroData(int cacheSize);  AvroData(AvroDataConfig avroDataConfig); Object fromConnectData(Schema schema, Object value); org.apache.avro.Schema fromConnectSchema(Schema schema); org.apache.avro.Schema fromConnectSchema(Schema schema,
                                                  Map<Schema, org.apache.avro.Schema> schemaMap); org.apache.avro.Schema fromConnectSchema(Schema schema,
                                                  FromConnectContext fromConnectContext,
                                                  boolean ignoreOptional); org.apache.avro.Schema fromConnectSchemaWithCycle(
      Schema schema,
      FromConnectContext fromConnectContext, boolean ignoreOptional); SchemaAndValue toConnectData(org.apache.avro.Schema avroSchema, Object value); SchemaAndValue toConnectData(org.apache.avro.Schema avroSchema, Object value,
                                      Integer version); Schema toConnectSchema(org.apache.avro.Schema schema); static Schema nonOptional(Schema schema); static List<Field> fields(Schema schema); static Schema keySchema(Schema schema); static Schema valueSchema(Schema schema); }
AvroData { public SchemaAndValue toConnectData(org.apache.avro.Schema avroSchema, Object value) { return toConnectData(avroSchema, value, null); } AvroData(int cacheSize);  AvroData(AvroDataConfig avroDataConfig); Object fromConnectData(Schema schema, Object value); org.apache.avro.Schema fromConnectSchema(Schema schema); org.apache.avro.Schema fromConnectSchema(Schema schema,
                                                  Map<Schema, org.apache.avro.Schema> schemaMap); org.apache.avro.Schema fromConnectSchema(Schema schema,
                                                  FromConnectContext fromConnectContext,
                                                  boolean ignoreOptional); org.apache.avro.Schema fromConnectSchemaWithCycle(
      Schema schema,
      FromConnectContext fromConnectContext, boolean ignoreOptional); SchemaAndValue toConnectData(org.apache.avro.Schema avroSchema, Object value); SchemaAndValue toConnectData(org.apache.avro.Schema avroSchema, Object value,
                                      Integer version); Schema toConnectSchema(org.apache.avro.Schema schema); static Schema nonOptional(Schema schema); static List<Field> fields(Schema schema); static Schema keySchema(Schema schema); static Schema valueSchema(Schema schema); static final String NAMESPACE; static final String DEFAULT_SCHEMA_NAME; static final String DEFAULT_SCHEMA_FULL_NAME; static final String MAP_ENTRY_TYPE_NAME; static final String KEY_FIELD; static final String VALUE_FIELD; static final String CONNECT_NAME_PROP; static final String CONNECT_DOC_PROP; static final String CONNECT_VERSION_PROP; static final String CONNECT_DEFAULT_VALUE_PROP; static final String CONNECT_PARAMETERS_PROP; static final String CONNECT_INTERNAL_TYPE_NAME; static final String AVRO_RECORD_DOC_PROP; static final String AVRO_ENUM_DOC_PREFIX_PROP; static final String AVRO_FIELD_DOC_PREFIX_PROP; static final String AVRO_FIELD_DEFAULT_FLAG_PROP; static final String AVRO_ENUM_DEFAULT_PREFIX_PROP; static final String CONNECT_TYPE_PROP; static final String CONNECT_TYPE_INT8; static final String CONNECT_TYPE_INT16; static final String AVRO_TYPE_UNION; static final String AVRO_TYPE_ENUM; static final String AVRO_TYPE_ANYTHING; static final org.apache.avro.Schema ANYTHING_SCHEMA_MAP_ELEMENT; static final org.apache.avro.Schema ANYTHING_SCHEMA; }