| start = timerData.getLong(2) | encodedNamespace = timerData.getBinary(2) | timerData.getLong(2) | timerData.getBinary(2) | flink | 797b38299e5fd6ab5a6fdd6eb3e3de616e57040d | org.apache.flink.table.runtime.operators.python.aggregate.PassThroughPythonStreamGroupWindowAggregateOperator | | | _1 | start |
|---|
| _2 | encodedNamespace |
|---|
| | | | AssignedTo | True |
| long start=timerData.getLong(2); | byte[] encodedNamespace=timerData.getBinary(2); | timerData.getLong(2) | timerData.getBinary(2) | flink | 797b38299e5fd6ab5a6fdd6eb3e3de616e57040d | org.apache.flink.table.runtime.operators.python.aggregate.PassThroughPythonStreamGroupWindowAggregateOperator | | | _1 | start |
|---|
| _2 | encodedNamespace |
|---|
| | | | AssignedTo | True |
| start = timerData.getLong(3) | encodedNamespace = timerData.getBinary(3) | timerData.getLong(3) | timerData.getBinary(3) | flink | 797b38299e5fd6ab5a6fdd6eb3e3de616e57040d | org.apache.flink.table.runtime.operators.python.aggregate.PythonStreamGroupWindowAggregateOperator | | | _1 | start |
|---|
| _2 | encodedNamespace |
|---|
| | | | AssignedTo | True |
| long start=timerData.getLong(3); | byte[] encodedNamespace=timerData.getBinary(3); | timerData.getLong(3) | timerData.getBinary(3) | flink | 797b38299e5fd6ab5a6fdd6eb3e3de616e57040d | org.apache.flink.table.runtime.operators.python.aggregate.PythonStreamGroupWindowAggregateOperator | | | _1 | start |
|---|
| _2 | encodedNamespace |
|---|
| | | | AssignedTo | True |