Kasia Kucharczyk created BEAM-6397:
--------------------------------------
Summary: 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
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)