| 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 |