@Test(expected = DataException.class) public void testToConnectSchemaMismatchArray() { ProtobufData protobufData = new ProtobufData(); Schema schema = SchemaBuilder.array(OPTIONAL_STRING_SCHEMA).build(); protobufData.toConnectData(schema, Arrays.asList(1, 2, 3)); }
public SchemaAndValue toConnectData(ProtobufSchema protobufSchema, Message message) { if (message == null) { return SchemaAndValue.NULL; } Schema schema = toConnectSchema(protobufSchema); return new SchemaAndValue(schema, toConnectData(schema, message)); }
ProtobufData { public SchemaAndValue toConnectData(ProtobufSchema protobufSchema, Message message) { if (message == null) { return SchemaAndValue.NULL; } Schema schema = toConnectSchema(protobufSchema); return new SchemaAndValue(schema, toConnectData(schema, message)); } }
ProtobufData { public SchemaAndValue toConnectData(ProtobufSchema protobufSchema, Message message) { if (message == null) { return SchemaAndValue.NULL; } Schema schema = toConnectSchema(protobufSchema); return new SchemaAndValue(schema, toConnectData(schema, message)); } ProtobufData();  ProtobufData(int cacheSize);  ProtobufData(ProtobufDataConfig protobufDataConfig); }
ProtobufData { public SchemaAndValue toConnectData(ProtobufSchema protobufSchema, Message message) { if (message == null) { return SchemaAndValue.NULL; } Schema schema = toConnectSchema(protobufSchema); return new SchemaAndValue(schema, toConnectData(schema, message)); } ProtobufData();  ProtobufData(int cacheSize);  ProtobufData(ProtobufDataConfig protobufDataConfig); ProtobufSchemaAndValue fromConnectData(Schema schema, Object value); ProtobufSchema fromConnectSchema(Schema schema); SchemaAndValue toConnectData(ProtobufSchema protobufSchema, Message message); Schema toConnectSchema(ProtobufSchema schema); }
ProtobufData { public SchemaAndValue toConnectData(ProtobufSchema protobufSchema, Message message) { if (message == null) { return SchemaAndValue.NULL; } Schema schema = toConnectSchema(protobufSchema); return new SchemaAndValue(schema, toConnectData(schema, message)); } ProtobufData();  ProtobufData(int cacheSize);  ProtobufData(ProtobufDataConfig protobufDataConfig); ProtobufSchemaAndValue fromConnectData(Schema schema, Object value); ProtobufSchema fromConnectSchema(Schema schema); SchemaAndValue toConnectData(ProtobufSchema protobufSchema, Message message); Schema toConnectSchema(ProtobufSchema schema); static final String NAMESPACE; static final String DEFAULT_SCHEMA_NAME; static final String MAP_ENTRY_SUFFIX; static final String KEY_FIELD; static final String VALUE_FIELD; static final String PROTOBUF_TYPE_ENUM; static final String PROTOBUF_TYPE_ENUM_PREFIX; static final String PROTOBUF_TYPE_UNION; static final String PROTOBUF_TYPE_UNION_PREFIX; static final String PROTOBUF_TYPE_TAG; static final String GOOGLE_PROTOBUF_PACKAGE; static final String GOOGLE_PROTOBUF_TIMESTAMP_NAME; static final String GOOGLE_PROTOBUF_TIMESTAMP_FULL_NAME; static final String GOOGLE_PROTOBUF_TIMESTAMP_LOCATION; }