Ask Your Question

How do I create a record in a Java Custom Processor?

asked 2018-01-16 13:20:30 -0600

Maurin gravatar image

updated 2018-01-16 15:25:49 -0600

metadaddy gravatar image

Is there a way of getting the createRecord function in java custom processor, or in spark custom processor?

edit retag flag offensive close merge delete

1 Answer

Sort by ยป oldest newest most voted

answered 2018-01-16 15:44:31 -0600

metadaddy gravatar image

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.

edit flag offensive delete link more
Login/Signup to Answer

Question Tools

1 follower


Asked: 2018-01-16 13:20:30 -0600

Seen: 4,993 times

Last updated: Jan 16 '18