如果 Term 达到某个点,Kusto row_cumsum 会修改 Term

2023-12-04

我有一份按以下顺序排列的员工姓名和工资列表

"Alice", 1, 1000,
"Alice", 2, 2000,
"Alice", 3, 1400,
"Alice", 3, 1400,
"Alice", 3, 1400,

我需要按以下格式创建输出表。即,每当累计工资总额超过 3000 时,我必须检测到这一点并标记该行。

enter image description here

我尝试过 row_cumsum 并重置Term一旦超过 3000,但第二次迭代就不起作用了。

datatable (name:string, month:int, salary:long)
[
    "Alice", 1, 1000,
    "Alice", 2, 2000,
    "Alice", 3, 1400,
    "Alice", 3, 1400,
    "Alice", 3, 1400,
]
| order by name asc, month asc
| extend total=row_cumsum(salary) 
| extend total=iff(total >=3000,total-prev(total),total)

现在这可以通过扫描操作员:

datatable (name:string, salary:long)
[
    "Alice", 1000,
    "Alice", 2000,
    "Alice", 1400,
    "Alice", 1400,
    "Alice", 1400,
    "Alice", 1000,
    "Bob", 2400,
    "Bob", 1000,
    "Bob", 1000
]
| sort by name asc
| scan declare (total:long) with 
(
    step s: true => total = iff(isnull(s.total) or name != s.name, salary, iff(s.total < 3000, s.total + salary, salary));
)
| extend boundary_detected = iff(total >= 3000, 1, long(null))
name salary total boundary_detected
Alice 1000 1000
Alice 2000 3000 1
Alice 1400 1400
Alice 1400 2800
Alice 1400 4200 1
Alice 1000 1000
Bob 2400 2400
Bob 1000 3400 1
Bob 1000 1000
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如果 Term 达到某个点,Kusto row_cumsum 会修改 Term 的相关文章

随机推荐

  • System.out.print 不带“ln”的字符串

    我有一个字节数组 如下所示 0 0 0 0 0 0 0 0 122 98 117 54 46 0 0 115 122 42 0 0 0 0 0 0 0 0 0 0 0 116 121 116 117 108 0 0 0 0 0 0 0 0
  • MPMoviePlayerControlle缩略图ImageAtTime:timeOption:给出空的UIImage

    我用它来获取视频的预览缩略图 void createThumb NSInteger paddingLeft 22 NSInteger paddingTop 22 CGFloat frameWidth self preview frame s
  • Mysql 查询到 ElasticSearch

    我正在尝试将 MYSQL 查询转换为 Elasticsearch 查询包含不同字段上的多个条件 让我解释一下我想要实现的目标 我的 Mysql 查询是 Select from data fl where city IN miami miam
  • Tcl 将变量的值作为变量的名称

    我在使用 Tcl 时遇到一些问题 我有一个变量 里面有一个字符串 但现在我希望这个字符串成为下一个变量的名称 我在网上发现了一些类似的问题 但这些都是关于将一 个变量的值放入另一个变量中 不使用它作为变量的名称 这是一个示例代码来帮助解释
  • 如何在没有 sudo 的情况下构建库?

    我通常会建立我的图书馆 configure make sudo make install 然而 Travis 文档不鼓励使用 sudohttp docs travis ci com user workers container based
  • GridView“ ”引发了未处理的事件 RowUpdating。 asp.net 背后的 C# 代码

    Stackoverflow和其他网站上也有类似的问题 但我似乎错过了一些东西 我有一个 GridView 绑定到来自数据库的 DataTable 我的目标是使用调用以下方法的同一行中的按钮更新当时的一行 protected void Tes
  • TensorFlow:恢复 RNN 网络后损失猛增

    环境信息 操作系统 Windows 7 64位 从预构建的 pip 安装的 Tensorflow 无 CUDA 1 0 1 Python 3 5 2 64 位 Problem 我在恢复网络 RNN 字符基础语言模型 时遇到问题 下面是具有相
  • Spark 查找 Dataframe 提高性能的最佳方法

    数据框A 数百万条记录 其中一列是create date modified date 数据框 B 500 条记录具有 start date 和 end date 目前的方法 Select a b from a join b on a cre
  • 如何检测html5画布是否为空白?

    我有一个涂鸦应用程序 可以将 html5 画布保存到 s3 中的图像中 如果用户在没有绘制任何内容的情况下意外单击 保存 我想避免保存空白 完全透明 的 png 我发现即使对于空白画布 toDataURL 也绝不是空字符串 而是大量数据转储
  • 表单上的两个提交按钮

    假设我有一组机构 每个机构都知道他的父亲是谁 并且一个机构可以有很多孩子 现在我为这个问题创建了一组级联下拉列表 因此在第一个时候 他会找到没有父亲的列表 如果可能的话 为第 0 层 一旦用户选择一个项目 第二个列表上的列表就会加载其子列表
  • Xcode 7: -F/ 的链接器警告,但 app.xcodeproj/project.pbxproj 中没有设置与 匹配

    我使用 Xcode 7 beta 3 将 iOS 的 Swift 1 x 项目转换为 Swift 2 x 它可以编译并运行 但链接器警告仍然存在 我已经在 project pbxprox 中搜索了有问题的路径 并查看了 Xcode 中的 构
  • 在 c# 中使用 asp.net 中的 Windows 身份验证

    我试图了解 Windows 身份验证的工作原理以及如何实现它 我读过很多文章 并在 youtube 上观看了一些相当长的视频 但我仍然不明白需要添加到我的 web config 文件 index aspx 页面中才能使其正常工作 这是ind
  • Python终端打开后报错

    当我尝试通过终端从终端打开 python 时python命令 我突然遇到错误 终端工作正常 但我想了解为什么会发生这种情况 提前致谢 PS C Users blackbird gt py AMD64 on win32 Type help c
  • 适用于 Go 的 AWS 开发工具包 - DynamoDb - 向 FilterExpression 添加多个条件

    我正在尝试使用表达式生成器按多个条件过滤 DynamoDb 扫描 根据这个博客文章 尝试在构建器中添加另一个条件将覆盖先前的条件 必须有某种方法来添加另一个条件 但我还没有找到一种方法来做到这一点 这行不通 cond1 expression
  • c++ * 和 & 同时

    在我的 C 数据结构课程中 我们正在研究二叉树 有些代码包含同时使用 和 的地方 彼此相邻 这非常令人困惑 void balance AvlNode t 是使用 this 的函数定义的一个示例 这里的 和 会发生什么 编辑 这个问题的答案告
  • 如何使用 PHP 和 Javascript 实现服务器推送/长轮询/comet

    如何使用 PHP 和 Javascript 实现彗星 服务器推送设计模式 本质上我想要的是这样的 用户单击 提交 按钮 JavaScript 显示类似 正在处理 0 100 个项目 的消息 每当处理新项目时 php 服务器都会推送更新 并且
  • 使用 sqlalchemy 将数据加载到 Oracle 数据库时不允许使用“Multi”方法

    我正在使用 sqlalchemy 和 pandas 将数据帧加载到 Oracle 数据库 由于 multi 方法允许批量上传 因此我选择该方法 我的pandas版本是1 0 1 但是我收到以下错误 当前数据库版本设置的 oracle 方言不
  • d3.js 可重用饼图,具有动态更新

    我正在尝试创建一个具有动态转换的可重用饼图作为学习任务 我正在研究 Chris Viau 编写的 d3 js 可重用组件电子书 我遇到的问题基本上是它不更新 而是创建多个饼图 我想知道我是否不理解 d3 dispatch 的工作原理 或者我
  • 在 AWS CodeBuild 中缓存 Gradle 包装器

    这就是我当前的构建规范 phases build commands gradlew soakTest s cache paths root gradle caches gradle 但是 当此构建规范在 CodeBuild 中运行时 它会打
  • 如果 Term 达到某个点,Kusto row_cumsum 会修改 Term

    我有一份按以下顺序排列的员工姓名和工资列表 我需要按以下格式创建输出表 即 每当累计工资总额超过 3000 时 我必须检测到这一点并标记该行 我尝试过 row cumsum 并重置Term一旦超过 3000 但第二次迭代就不起作用了 dat