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)) | beam | 8db19a4645b8588ce9e046637b7619815169bdb1 | org.apache.beam.runners.fnexecution.control.SdkHarnessClientTest | | _1 | remoteInputs |
---|
_2 | remoteInputs |
---|
| v0 | RemoteInputDestination.of(FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM) |
---|
| | v0 | RemoteInputDestination.of(FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM) |
---|
| AssignedTo | False |
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)) | beam | 8db19a4645b8588ce9e046637b7619815169bdb1 | org.apache.beam.runners.fnexecution.control.SdkHarnessClientTest | | _1 | remoteInputs |
---|
_2 | remoteInputs |
---|
| v0 | RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM) |
---|
| | v0 | RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM) |
---|
| AssignedTo | False |
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)) | beam | 8db19a4645b8588ce9e046637b7619815169bdb1 | org.apache.beam.runners.fnexecution.control.SdkHarnessClientTest | | _1 | remoteInputs |
---|
_2 | remoteInputs |
---|
| v0 | RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM) |
---|
| | v0 | RemoteInputDestination.of((FullWindowedValueCoder)FullWindowedValueCoder.of(VarIntCoder.of(),GlobalWindow.Coder.INSTANCE),SDK_GRPC_READ_TRANSFORM) |
---|
| AssignedTo | False |