问题标签 [windowing]

我正在使用 SQL Server 2014。我有一个Claims表，其中包含我系统中每月提出的索赔总数：

对于我正在编写的报告，我需要能够生成在每个财政年度开始时重置为零的累计运行总计（在我的国家，这是从 3 月 1 日到次年 2 月 28/29 日）。

该报告将与表格类似，但有一个额外的运行总计列，例如：

我知道窗口函数非常强大，我过去曾以基本方式使用它们来获得总和和平均值，同时避免需要对我的结果集行进行分组。我有一种直觉，我需要使用“preceding”关键字来获得每行所属当前财政年度的总和，但我不太明白如何将财政年度表达为一个概念来使用'preceding' 子句（或者如果确实可以以这种方式使用日期范围）。

请在为“前项”条款“措辞”财政年度的方式上提供任何帮助，对我有很大帮助。

我正在用 C# 实现一个 DICOM 图像查看器。我不（因为我不允许）使用任何为我进行图像处理的框架或库。

我可以使用哪种算法计算窗口？（带窗口中心和窗口宽度）

我有以下工作要做：

• 像素数据存储为 byte[]
• 像素存储在 Hounsfield 单元中（见第一个代码）

我尝试了以下方法：

计算重新缩放：（已编辑）

计算窗口

第二个代码几乎总是返回 0，所以图像几乎是黑色的。任何想法我做错了什么？

编辑 21.02.2017

我按照 Paolo Brandolis 的建议编辑了代码。我将 HU 存储在 int[] 中。
例如，Rescale Intercept 为 -1024，Rescale Slope 为 1。当 Window Center 为 40，Window Width 为 350 时，一切都是黑色的。
所以还是有问题。有什么建议么？

在我的数据框中，我想创建一个列“5D_Peak”作为滚动最大值，然后创建另一列滚动计数接近峰值的历史数据。我想知道是否有更简单的方法来简单或理想地矢量化计算。

这是我的代码以一种简单但复杂的方式：

这是我想要的输出：

我有一个数据集，我试图根据在我的情况下发生某些事件（即加载）的时间戳创建一个“会话 ID”

我的数据：

我想要实现的是创建一个名为 session_start_timestamp 的新列，其中该行被标记为每个用户的最后一个“加载”。

我知道如何通过创建子集表（通过采用最小时间戳和自加入）来做到这一点，但是是否有一个滞后/领先/最大/分区函数可以代替？

最终输出应如下所示：

我正在尝试设置我的 X11 光标位置。我尝试调用 XWarpPointer 并将窗口设置为无，根 (DefaultRootWindow(display))，到先前创建的窗口 (XCreateWindow)。正在调用该函数，鼠标速度变慢了一点，但它并没有实际移动。为什么会这样？

编辑：这是整个 X11 Windowing 文件，以防您在这里找不到原因。https://gist.github.com/KarimIO/7db1f50778fda63a36c10242989baab6

我了解翻转窗口设置了一个时间间隔，并且事件不会重叠并在设置的时间间隔内到期。现在，跳跃窗口和滑动窗口重叠，在跳跃窗口的情况下，我们有一个跳跃间隔和正常窗口间隔，滑动窗口有一个不同于窗口间隔的滑动间隔。我在Hopping Window上查看了这个链接，我明白了，但滑动间隔似乎也一样。有人可以帮我解释其中的区别。

我有一张这样的桌子

我想有一个值列的累积帐户

我尝试通过使用此窗口函数来执行上述操作，尽管它似乎没有返回正确的值

我有以下情况

我想要做的是计算我的时间窗口的前 N ​​个。每个窗口的前 N ​​个由接收器存储。

我可以计算flatmap中的top N，但是不知道什么时候发送到sink进行存储。据我所见，无法从 flatmap 函数中知道窗口何时结束。

我知道有一些替代方法，例如 apply 函数可以同时执行这两种操作，或者在流中创建标记以指示结束，但我想知道是否有更优雅的解决方案。

您好，我对 Hive 非常陌生，正在学习 Hive 的窗口功能。我遇到了一个问题。

我试图找到每个股票代码的最低收盘价（每个代码有 22 条记录，我想找到最低的）我写了一个查询：

我得到了结果

但我想为每个股票一个。

然后我运行了相同的查询，但添加了 ORDER BY 子句

我得到了理想的结果。

我的问题是如何通过对代码进行分组来排序？

问题：问题是这个程序在每个窗口不止一次写入Kafka（每个窗口创建2-3行或更多行，同时它应该每个窗口创建1行，因为reduce它只允许一个元素） . 我用 Spark 编写了相同的代码，并且运行良好。我一直在尝试查找有关此问题的信息，但没有找到任何东西:(。此外，我一直在尝试更改某些函数的并行性和更多的东西，但没有任何效果，我无法意识到问题出在哪里。

我正在测试 Flink 延迟。这里有我的问题的环境：

集群：我使用 Flink 1.2.0 和 OpenJDK 8。我有 3 台计算机：1 台 JobManager，2 台 TaskManager（4 核，2GB RAM，每个 TaskManager 4 个任务槽）。

输入数据：一个 java 生产者为 Kafka 24 分区主题生成的行，包含两个元素：增量值和创建时间戳：

• 1 1497790546981
• 2 1497790546982
• 3 1497790546983
• 4 1497790546984
• ......................

我的 Java 类：

• 它从具有 24 个分区的 Kafka 主题中读取数据（Kafka 与 JobManager 在同一台机器上）。
• 这些filter功能与union我一起使用它们只是为了检查它们的延迟而无用。
• 基本上，它在每一行添加一个“1”，然后tumbling window每 2 秒添加一个，并且reduce函数将所有这个 1 和所有时间戳相加，最后一个时间戳稍后在map函数中划分为 1 的总和，这给了我平均，最后在最后一个map函数中，它将当前时刻的时间戳添加到每个缩减的行以及此时间戳与平均时间戳之间的差异。

• 此行写入 Kafka（写入 2 个分区的主题）。

  /li>

一些输出数据：此输出已写入 2 个分区的主题，并且生成速率低于 1000 条记录/秒（**在这种情况下，它会为每个窗口创建 3 行输出）：

• 1969 149779124 0910 1497791241999 1089 1497791242001 1091
• 1973 149779124 0971 1497791241999 1028 1497791242002 1031
• 1970 149779124 0937 1497791242094 1157 1497791242198 1261
• 1917 149779124 2912 1497791243999 1087 1497791244051 1139
• 1905 149779124 2971 1497791243999 1028 1497791244051 1080
• 1916 149779124 2939 1497791244096 1157 1497791244199 1260
• 1994 149779124 4915 1497791245999 1084 1497791246002 1087
• 1993 149779124 4966 1497791245999 1033 1497791246004 1038
• 1990 149779124 4939 1497791246097 1158 1497791246201 1262

提前致谢！