public long timeStamp

目录 窗口分配器 时间窗口 计数窗口 全局窗口 窗口函数 增量聚合函数 全窗口函数（full window functions） 增量聚合和全窗口函数的结合使用 Window API 主要由两部分构成：窗口分配器（Window Assigners）和窗口函数（Window Functions） stream.keyBy(<key selector>) .window(<window assigner>) //指明窗口的类型 .aggregate(<window function>) //定义窗口具体的处理逻辑 在window()方法中传入一个窗口分配器； 在aggregate()方法中传入一个窗口函数； 窗口分配器 指定窗口的类型，定义数据应该被“分配”到哪个窗口 方法：.window() 参数：WindowAssigner 返回值：WindowedStream 如果是非按键分区窗口，那么直接调用.windowAll()方法，同样传入一个WindowAssigner，返回的是 AllWindowedStream 滚动处理时间窗口 stream.keyBy(...)...

一个Flink程序，其实就是对DataStream的各种转换，代码基本可以由以下几部分构成： 获取执行环境 读取数据源 定义对DataStream的转换操作 输出 触发程序执行 获取执行环境和触发程序执行都属于对执行环境的操作，那么其构成可以用下图表示： 其核心部分就是Transform，对数据各种转换处理。由于新版本的Flink已经实现流批一体，流数据和批数据都统一使用DataStream API来处理 5.1.1 创建执行环境 1.getExecutionEnvironment 最简单的方式，就是直接调用 getExecutionEnvironment 方法。它会根据当前运行的上下文直接得到正确的结果：如果程序是独立运行的，就返回一个本地执行环境；如果是创建了 jar 包，然后从命令行调用它并提交到集群执行，那么就返回集群的执行环境。也就是说，这个方法会根据当前运行的方式，自行决定该返回什么样的运行环境 ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();...

最近使用JSON文件保存模型表情数据，简单记录一下。 首先自定义数据类，需要记录表情每帧的所有BlendShape及时间戳： [System.Serializable] public class RecBlendShape { public List<float> Fram; public long timeStamp; } 使用Unity自带的JSON读写方法： /// <summary> /// 记录BlendShape数据为JSON /// </summary> private void RecBlendShapeToJSON() { //获取表情BlendShape值 List<float> getBS = new List<float>(); RecBlendShape testRecBS = new RecBlendShape(); for (int i = 0; i < targetFace.sharedMesh.blendShapeCount; i++) { getBS.Add(targetFace.GetBlendShapeWeight(i)); }...