我目前正在开发一个流处理应用程序，其中一个功能是获取时区内发生的事件[提交作业的时间，提交作业的时间+t]。如何使用flink中的流处理api访问特定变量（提交作业的时间）？谢谢您。
xvw2m8pv1#
一种可能的方法是用Flink的 ParameterTool https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/best_practices.html#getting-将配置值输入参数工具
ParameterTool
ParameterTool parameters = ParameterTool.fromArgs(args); // set up the execution environment final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); env.getConfig().setGlobalJobParameters(parameters);
您可以通过cli参数传递时间戳，或者简单地用java代码获取系统时间。与 GlobalJobParameters ，您可以通过 context .
GlobalJobParameters
context
1条答案
按热度按时间xvw2m8pv1#
一种可能的方法是用Flink的
ParameterToolhttps://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/best_practices.html#getting-将配置值输入参数工具您可以通过cli参数传递时间戳，或者简单地用java代码获取系统时间。与
GlobalJobParameters，您可以通过context.