OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
remoteInputs = Collections.singletonMap(STR0,RemoteInputDestination.of(FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))remoteInputs = Collections.singletonList(RemoteInputDestination.of(FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))Collections.singletonMap(STR0,RemoteInputDestination.of(FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))Collections.singletonList(RemoteInputDestination.of(FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))beam8db19a4645b8588ce9e046637b7619815169bdb1org.apache.beam.runners.fnexecution.control.SdkHarnessClientTest
_1592
_2581
_1remoteInputs
_2remoteInputs
v0RemoteInputDestination.of(FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM)
  • java.util.Collections
v0RemoteInputDestination.of(FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM)
AssignedToFalse
remoteInputs = Collections.singletonMap(STR0,RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))remoteInputs = Collections.singletonList(RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))Collections.singletonMap(STR0,RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))Collections.singletonList(RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))beam8db19a4645b8588ce9e046637b7619815169bdb1org.apache.beam.runners.fnexecution.control.SdkHarnessClientTest
_1200
_2198
_1remoteInputs
_2remoteInputs
v0RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM)
  • java.util.Collections
v0RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM)
AssignedToFalse
remoteInputs = Collections.singletonMap(STR0,RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))remoteInputs = Collections.singletonList(RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))Collections.singletonMap(STR0,RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))Collections.singletonList(RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM))beam8db19a4645b8588ce9e046637b7619815169bdb1org.apache.beam.runners.fnexecution.control.SdkHarnessClientTest
_1172
_2171
_1remoteInputs
_2remoteInputs
v0RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM)
  • java.util.Collections
v0RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM)
AssignedToFalse