В настоящее время я разрабатываю приложение для потоковой обработки, одна из функций которого - принимать события, которые происходят в часовом поясе [время отправки задания, время отправки задания + T].
как получить доступ к этой конкретной переменной (время отправки задания) с помощью API потоковой обработки во Flink?
Спасибо.
Один из возможных способов - использовать Flink ParameterTool
ParameterTool parameters = ParameterTool.fromArgs(args);
// set up the execution environment
final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
env.getConfig().setGlobalJobParameters(parameters);
Вы можете передать метку времени через параметры интерфейса командной строки или просто получить системное время в Java-коде. С GlobalJobParameters вы можете получить доступ к времени в любых операторах через context.
