java中如何创建一个带滚动条的窗体? 10
2个回答
2020-08-19 · 百度认证:北京中公教育科技官方账号
中公教育IT培训优就业
中公教育IT培训品牌,致力于培养互联网领域的高端人才,以学员就业为目的,优质就业为宗旨,是一家集Java开发、Web前端、UI/UE交互设计、大数据、软件测试等课程为一体的IT培训机构。
向TA提问
关注
展开全部
例子:
我们设置公交车10秒钟跑一趟,陆陆续续来的客户端输入的数据,
公交车来了,没人空跑一圈 不执行,相当于不显示,
公交车来了,站点有5个人就是拉5个人走,相当于执行5条数据,
公交车来了,站点一次性来了50个人但是公交车到了10秒钟要走了,只有20个上车了,就只带走这20个乘客,剩下的30个人只能等下一趟公交车了,相当于这一趟只执行20条数据,剩下的数据将会和后来的数据一起在10秒钟结束的时候一起执行。
未分组按照Processingtime时间执行:
public class Tumbling {
public static void main(String[] args) throws Exception{
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStreamSource lines = env.socketTextStream("localhost", 8888);
SingleOutputStreamOperator upper = lines.map(Integer::parseInt);
//设置发车的时间
AllWindowedStream all = upper.windowAll(TumblingProcessingTimeWindows.of(Time.seconds(5)));
//将乘客相加
SingleOutputStreamOperator summed = all.sum(0);
summed.print();
env.execute();
}
}
分组按照Processingtime时间执行:
public class Tumbling2 {
public static void main(String[] args) throws Exception{
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStreamSource lines = env.socketTextStream("localhost", 8888);
//设置分组
SingleOutputStreamOperator> wordAndOne = lines.map(new MapFunction>() {
@Override
public Tuple2 map(String value) throws Exception {
return Tuple2.of(value, 1);
}
});
KeyedStream, Tuple> keyed = wordAndOne.keyBy(0);
//设置发车的时间
WindowedStream, Tuple, TimeWindow> window = keyed.window(TumblingProcessingTimeWindows.of(Time.seconds(5)));
//将乘客相加
SingleOutputStreamOperator> summed = window.sum(1);
summed.print();
env.execute();
}
}
我们设置公交车10秒钟跑一趟,陆陆续续来的客户端输入的数据,
公交车来了,没人空跑一圈 不执行,相当于不显示,
公交车来了,站点有5个人就是拉5个人走,相当于执行5条数据,
公交车来了,站点一次性来了50个人但是公交车到了10秒钟要走了,只有20个上车了,就只带走这20个乘客,剩下的30个人只能等下一趟公交车了,相当于这一趟只执行20条数据,剩下的数据将会和后来的数据一起在10秒钟结束的时候一起执行。
未分组按照Processingtime时间执行:
public class Tumbling {
public static void main(String[] args) throws Exception{
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStreamSource lines = env.socketTextStream("localhost", 8888);
SingleOutputStreamOperator upper = lines.map(Integer::parseInt);
//设置发车的时间
AllWindowedStream all = upper.windowAll(TumblingProcessingTimeWindows.of(Time.seconds(5)));
//将乘客相加
SingleOutputStreamOperator summed = all.sum(0);
summed.print();
env.execute();
}
}
分组按照Processingtime时间执行:
public class Tumbling2 {
public static void main(String[] args) throws Exception{
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStreamSource lines = env.socketTextStream("localhost", 8888);
//设置分组
SingleOutputStreamOperator> wordAndOne = lines.map(new MapFunction>() {
@Override
public Tuple2 map(String value) throws Exception {
return Tuple2.of(value, 1);
}
});
KeyedStream, Tuple> keyed = wordAndOne.keyBy(0);
//设置发车的时间
WindowedStream, Tuple, TimeWindow> window = keyed.window(TumblingProcessingTimeWindows.of(Time.seconds(5)));
//将乘客相加
SingleOutputStreamOperator> summed = window.sum(1);
summed.print();
env.execute();
}
}
推荐律师服务:
若未解决您的问题,请您详细描述您的问题,通过百度律临进行免费专业咨询