return windowedKv.withValue(windowedKv.getValue().getKey()); | return ImmutableList.<Object>of(windowedKv.withValue(windowedKv.getValue().getKey())); | windowedKv.withValue(windowedKv.getValue().getKey()) | ImmutableList.<Object>of(windowedKv.withValue(windowedKv.getValue().getKey())) | beam | 748ada7762f4033665b8daaa726fdc5b65952a2a | com.google.cloud.dataflow.sdk.runners.worker.MapTaskExecutorFactory.PairInfo | | _1 | getKeyFromInputPair |
---|
_2 | getKeysFromInputPair |
---|
| v0 | windowedKv.withValue(windowedKv.getValue().getKey()) |
---|
| - com.google.common.collect.ImmutableList
- java.lang.Object
| v0 | windowedKv.withValue(windowedKv.getValue().getKey()) |
---|
| Returns | True |