OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
try(PubsubTestClientFactory factory=PubsubTestClient.createFactoryForPublish(TOPIC,outgoing))try(PubsubTestClientFactory factory=PubsubTestClient.createFactoryForPublish(TOPIC,outgoing,ImmutableList.<OutgoingMessage>of()))PubsubTestClient.createFactoryForPublish(TOPIC,outgoing)PubsubTestClient.createFactoryForPublish(TOPIC,outgoing,ImmutableList.<OutgoingMessage>of())beam26941f152cb5bed422ff14ccb10403604a611130org.apache.beam.sdk.io.PubsubUnboundedSinkTest
_1120
_2130
_1outgoing
_2outgoing
TCIVaroutgoing
v0TOPIC
  • org.apache.beam.sdk.util.PubsubTestClient
TCIVaroutgoing
v0TOPIC
UsesTrue
try(PubsubTestClientFactory factory=PubsubTestClient.createFactoryForPublish(TOPIC,outgoing))try(PubsubTestClientFactory factory=PubsubTestClient.createFactoryForPublish(TOPIC,outgoing,ImmutableList.<OutgoingMessage>of()))PubsubTestClient.createFactoryForPublish(TOPIC,outgoing)PubsubTestClient.createFactoryForPublish(TOPIC,outgoing,ImmutableList.<OutgoingMessage>of())beam26941f152cb5bed422ff14ccb10403604a611130org.apache.beam.sdk.io.PubsubUnboundedSinkTest
_194
_2102
_1outgoing
_2outgoing
TCIVaroutgoing
v0TOPIC
  • org.apache.beam.sdk.util.PubsubTestClient
TCIVaroutgoing
v0TOPIC
UsesTrue