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)