beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Keith Berkoben (JIRA)" <>
Subject [jira] [Commented] (BEAM-2451) writeProtos() should allow a user to specify message attributes
Date Mon, 19 Jun 2017 16:48:00 GMT


Keith Berkoben commented on BEAM-2451:

What values are used for the timestamp and ID when withTimestampAttribute() and withIdAttribute()
is set? 

> writeProtos() should allow a user to specify message attributes
> ---------------------------------------------------------------
>                 Key: BEAM-2451
>                 URL:
>             Project: Beam
>          Issue Type: Improvement
>          Components: sdk-java-core
>    Affects Versions: 2.0.0
>            Reporter: Keith Berkoben
>            Assignee: Reuven Lax
> when using PubsubIO.writeProtos(protoMessage), the PubsubMessage is created in the background
and there is no way to specify the attributes of the message.  This makes the method useless
if a user wants to then use the withTimestampAttribute() or withIdAttribute() of the writer
with anything other than the default timestamp or ID (a common use case).  
> As a workaround the user can manually create the PubsubMessage, but this basically requires
duplication of the writeProtos() logic, which is brittle in the case that the encoding logic

This message was sent by Atlassian JIRA

View raw message