keysAndWindows = getKeyedStateBackend().<W>getKeysAndNamespaces(descriptor.getName()).iterator() | keysAndWindows = getKeyedStateBackend().getKeysAndNamespaces(descriptor.getName()) | getKeyedStateBackend().<W>getKeysAndNamespaces(descriptor.getName()).iterator() | getKeyedStateBackend().getKeysAndNamespaces(descriptor.getName()) | flink | dad729752ee43d95d47ba079b5ea2cfb6f6ca22c | org.apache.flink.state.api.input.operator.WindowReaderOperator | | _1 | keysAndWindows |
---|
_2 | keysAndWindows |
---|
| v0 | descriptor.getName() |
---|
v1 | getKeyedStateBackend() |
---|
| | v0 | descriptor.getName() |
---|
v1 | getKeyedStateBackend() |
---|
| AssignedTo | True |