[ https://issues.apache.org/jira/browse/BEAM-6397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Work on BEAM-6397 started by Kasia Kucharczyk. ---------------------------------------------- > Add KeyValue attribute to SyntheticDataPubSubPublisher > ------------------------------------------------------ > > Key: BEAM-6397 > URL: https://issues.apache.org/jira/browse/BEAM-6397 > Project: Beam > Issue Type: Improvement > Components: testing > Reporter: Kasia Kucharczyk > Assignee: Kasia Kucharczyk > Priority: Minor > Time Spent: 10m > Remaining Estimate: 0h > > Currently SyntheticDataPubSubPublisher sends only synthetic elements > converted to ByteArray to PubSub. To perform KeyValue tranforms (such us > GroupByKey) on PubSub source I propose to send generated synthetic data as > Map via attributes parameter in PubsubMessage object. > Also it is required to fix NoClassDefFoundError (details in comment). -- This message was sent by Atlassian JIRA (v7.6.3#76005)