Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
A) RelSchemaConverter/SamzaRelConverter currently converts KV to SamzaSqlRelMessage without initializing the SamzaSqlRelMessage.SamzaSqlRelMsgMetadata. We need to change SamzaRelConverter interface to consume the SamzaSqlInputMessage creating SamzaSqlRelMessage with initialized SamzaSqlRelMsgMetadata
B) We should remove the IsSystemMessage interface.