environment.getStreamEnv().enableCheckpointing(checkpointInterval); | environment.getStreamEnv().enableCheckpointing(checkpointInterval.toMillis()); | environment.getStreamEnv().enableCheckpointing(checkpointInterval) | environment.getStreamEnv().enableCheckpointing(checkpointInterval.toMillis()) | beam | 2f13c9e6aa93947916714d6600a26015aae05908 | cz.seznam.euphoria.flink.FlinkExecutor | | _1 | checkpointInterval |
---|
_2 | checkpointInterval |
---|
| TCIVar | checkpointInterval |
---|
v0 | environment.getStreamEnv() |
---|
| | TCIVar | checkpointInterval |
---|
v0 | environment.getStreamEnv() |
---|
| Uses | True |