1730576dcb9ae7d1fba224872a1d75e5e248d984 - pulsar-connectors

commit	1730576dcb9ae7d1fba224872a1d75e5e248d984	[log] [tgz]
author	congbo <39078850+congbobo184@users.noreply.github.com>	Sun Apr 28 12:04:45 2019 +0800
committer	Sijie Guo <sijie@apache.org>	Sun Apr 28 12:04:45 2019 +0800
tree	e09cc45cb23ce6322fdfdbfad86f244ef06c2d16
parent	29b3f2df838e6227d51b65a77ffac720c7801a73 [diff]

Add the multi version schema support (#3876)

### Motivation

Fix #3742

In order to decode the message correctly by AVRO schema, we need to know the schema what the message is.

### Modification

- Introduced Schema Reader and Schema Writer for StructSchema.
   - Reader is used to decode message
   - Writer is used to encode message
- The implementations of StructSchema, provides their schema reader and writer implementations. 
- Introduced a schema reader cache for caching the readers for different schema versions.

pulsar-io/hbase/src/test/java/org/apache/pulsar/io/hbase/sink/HbaseGenericRecordSinkTest.java[diff]
pulsar-io/influxdb/src/test/java/org/apache/pulsar/io/influxdb/InfluxDBGenericRecordSinkTest.java[diff]
pulsar-io/jdbc/src/test/java/org/apache/pulsar/io/jdbc/JdbcSinkTest.java[diff]
pulsar-io/solr/src/test/java/org/apache/pulsar/io/solr/SolrGenericRecordSinkTest.java[diff]

4 files changed

tree: e09cc45cb23ce6322fdfdbfad86f244ef06c2d16

pulsar-io/