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