How do I create a record in a Java Custom Processor?
Is there a way of getting the createRecord function in java custom processor, or in spark custom processor?
add a comment
You can use the createRecord(Record originatorRecord, String sourceIdPostfix) method on Processor.Context to create a record based on the record you're currently processing, providing a suffix that will be appended to the sourceId of the original record to form a unique sourceId for the new record.
Asked: 2018-01-16 13:20:30 -0600
Seen: 4,993 times
Last updated: Jan 16 '18
