bvaradar commented on a change in pull request #1150: [HUDI-288]: Add support
for ingesting multiple kafka streams in a single DeltaStreamer deployment
URL: https://github.com/apache/incubator-hudi/pull/1150#discussion_r362693191
##########
File path:
hudi-client/src/test/java/org/apache/hudi/common/HoodieTestDataGenerator.java
##########
@@ -80,16 +79,27 @@
+ "{\"name\": \"begin_lat\", \"type\": \"double\"},{\"name\":
\"begin_lon\", \"type\": \"double\"},"
+ "{\"name\": \"end_lat\", \"type\": \"double\"},{\"name\": \"end_lon\",
\"type\": \"double\"},"
+ "{\"name\":\"fare\",\"type\": \"double\"}]}";
+ public static String GROCERY_PURCHASE_SCHEMA =
"{\"type\":\"record\",\"name\":\"purchaserec\",\"fields\":["
Review comment:
@pratyakshsharma : I would also vote to keep one schema. If you want to add
different schema, you would need to encapsulate the schemas separately, have
its own RecordPayload or use generic one (not TestRawTripPayload). Maybe add a
nullable column in TestRawtripPayload to distinguish the topic from which the
record got ingested ?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
