This is an automated email from the ASF dual-hosted git repository.
karp pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git
from 150387f6 Merge pull request #222 from ni-ze/supportRsqldb
new 66446984 add custom deserializer
new 101c69e3 add custom deserializer
new b7a96729 Merge pull request #221 from MatrixHB/add_custom_serde
The 583 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../rocketmq/streams/schema/AvroSchemaWrapper.java | 4 +--
...SchemaWrapper.java => CustomSchemaWrapper.java} | 21 ++++++++---
.../rocketmq/streams/schema/JsonSchemaWrapper.java | 4 +--
.../rocketmq/streams/schema/SchemaConfig.java | 41 ++++++++++++++++------
.../streams/schema/SchemaWrapperFactory.java | 5 +++
...xample.java => CustomeDeserializerExample.java} | 14 +++-----
.../streams/examples/schema/DataDeserializer.java | 24 +++++--------
7 files changed, 69 insertions(+), 44 deletions(-)
copy
rocketmq-streams-channel-rocketmq/src/main/java/org/apache/rocketmq/streams/schema/{StringSchemaWrapper.java
=> CustomSchemaWrapper.java} (58%)
copy
rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/{SchemaRocketmqExample.java
=> CustomeDeserializerExample.java} (88%)
copy
rocketmq-streams-window/src/main/java/org/apache/rocketmq/streams/window/storage/WindowInstanceIterator.java
=>
rocketmq-streams-examples/src/main/java/org/apache/rocketmq/streams/examples/schema/DataDeserializer.java
(66%)
