Commit f868d445 by 余根龙

增加fast

parent 15ac2829
...@@ -22,7 +22,7 @@ public class GreenRadioJob { ...@@ -22,7 +22,7 @@ public class GreenRadioJob {
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
FlinkUtils.createKafkaStream(args, env, "signal_cycle_data","greenRadioJob") FlinkUtils.createKafkaStream(args, env)
.map(record -> { .map(record -> {
// 字符串解析为实体类 // 字符串解析为实体类
Cycle cycle = JSON.parseObject(record, Cycle.class); Cycle cycle = JSON.parseObject(record, Cycle.class);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment