outgoing = Sets.newHashSet(new OutgoingMessage(DATA.getBytes(),TIMESTAMP)) | outgoing = ImmutableList.of(new OutgoingMessage(DATA.getBytes(),TIMESTAMP,getRecordId(DATA))) | Sets.newHashSet(new OutgoingMessage(DATA.getBytes(),TIMESTAMP)) | ImmutableList.of(new OutgoingMessage(DATA.getBytes(),TIMESTAMP,getRecordId(DATA))) | beam | 26941f152cb5bed422ff14ccb10403604a611130 | org.apache.beam.sdk.io.PubsubUnboundedSinkTest | | | v0 | DATA.getBytes() |
---|
v1 | TIMESTAMP |
---|
| - org.apache.beam.sdk.util.PubsubClient.OutgoingMessage
- com.google.common.collect.ImmutableList
| v0 | DATA.getBytes() |
---|
v1 | TIMESTAMP |
---|
| AssignedTo | True |