OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
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)))beam26941f152cb5bed422ff14ccb10403604a611130org.apache.beam.sdk.io.PubsubUnboundedSinkTest
_175
_279
_1outgoing
_2outgoing
v0DATA.getBytes()
v1TIMESTAMP
  • org.apache.beam.sdk.util.PubsubClient.OutgoingMessage
  • com.google.common.collect.ImmutableList
v0DATA.getBytes()
v1TIMESTAMP
AssignedToTrue