已有0人关注此标签
Flink 自定义聚合函数 AggregateFunction 不触发
作者： 何不留下昵称和大家交个朋友
290人浏览
0人回答
本地sock测试AggregateFunction 生效 但是上了flink集群后（连接的kafka源 ，数据能正常收到） 发现AggregateFunction 的getresult方法不触发，而createAccumulator和a…
Rails访问模型中模块中的共享自定义验证
作者： 宋淑婷
144人浏览
1人回答
我正在试图弄清楚如何创建一个共享的自定义验证，我可以在我放在lib / validations.rb文件夹中的模型中使用它。 module Validations extend ActiveSupport::Concern # incl…
在新列中添加唯一标识符，直到另一列满足条件
作者： python小能手
258人浏览
1人回答
我有一个带有npartition = 8的dask数据帧，这里是数据的快照： id1 id2 Page_nbr record_type St1 Sc1 3 START …
kafka-clients与ons-sasl-client版本不配套,有没有配套的ons-sasl-client
作者： 欢乐小母鳄
296人浏览
1人回答
图片 kafka-clients与ons-sasl-client版本不配套,有没有配套的ons-sasl-client
关于ArrayList的问题,请大佬进来看看
作者： 期待l
463人浏览
2人回答
其实ArrayList并不是很难, 但是今天debug学习的时候发现, ArrayList中的elementData在进行首次add的时候,是不是会利用这个elementData加载一些 项目相关路径或者文件啊 ?? 我看着是发生了这…
用于在类中定义索引的python方法（使用“[]”）
作者： python小能手
392人浏览
1人回答
据我所知，__add__可以用来定义+新类的用法。定义使用的等价物是[]什么？ 我想创建一个Parent包含字典的类，codes我想Parent[key]返回Parent.codes[key] 我理解我可能只是使用Parent.codes…
用于在类中定义索引的python方法（使用“[]”）
作者： python小能手
231人浏览
1人回答
据我所知，__add__可以用来定义+新类的用法。定义使用的等价物是[]什么？ 我想创建一个Parent包含字典的类，codes我想Parent[key]返回Parent.codes[key] 我理解我可能只是使用Parent.codes…
通过discord bot为每个人设置唯一关键字
作者： python小能手
378人浏览
1人回答
我目前正在尝试制作一个机器人，允许成员设置机器人然后在服务器中检查的特定关键字（在一段时间内）。如果机器人在消息中检测到该关键字（仅通过另一个bot / webhook），它会警告设置该关键字的用户。 基本上我想做的是像这样的场景： 会员…
django - 我的表单不会保存添加的M2M对象。为什么？
作者： python小能手
274人浏览
1人回答
我的代码： class DataSourceCreateView(CreateView): model = DataSource form_class = DataSourceForm template_name = 'engine/da…
Tensorflow：Logits和标签必须具有相同的第一个维度
作者： python小能手
442人浏览
1人回答
'distributions'列对应于一个独特的方程组，我试图将其压缩成SageMath中的一系列数字。'probs'列对应于是否应该根据它所在的行和列，通过给定的单项式来给定方程式多余。上面仅用于概述，与我的实际问题无关。 无论如何，这…
开放过程中不是不建议用多个if并列嘛，那阿里fastjson源码中会有如下片段呢？
作者： 烛孩
305人浏览
3人回答
com.alibaba.fastjson.serializer.SerializeFilterable.addFilter(SerializeFilter)这个方法中用连续9个if，这样写是合理的，还是有待优化呢？求权威分析…… publ…
Spark Scala：如何同时过滤RDD和更新计数器
作者： 社区小助手
338人浏览
1人回答
我的初始RDD是记录类型，记录的布局是： a_key, b_key,c_key,f_name,l_name,address现在我必须： 删除具有a_key或b_key或c_key为空/空的记录我必须同时更新无效记录的计数器。我这样试过： …
累积器未出现在Spark UI中
作者： 社区小助手
282人浏览
1人回答
我已经实现了累加器来查看代码中的事件计数。但我无法在Spark UI中看到它们。我使用以下东西： val count_Of_2317508_1 = sc.longAccumulator("count_Of_2317508_1") cou…
滑动时间窗口的Flink性能问题
作者： 社区小助手
531人浏览
1人回答
我正在尝试使用一些网络监视器工作。我的目标是不同的计数dst_ip每src_ip。 我的以下代码有效，但性能非常糟糕。似乎每个滑动窗口都会重新计算所有事件，但这不是必需的。 例如，我们有事件按时间秒1 - 600.Flink可以得到每秒的…
Apache Flink 1.6.0 - StateTtlConfig和ListState
作者： 社区小助手
595人浏览
1人回答
我正在使用Apache Flink 1.6.0实现概念验证流处理系统，并存储一个按键分区的接收事件列表ListState。（不要担心我为什么这样做，只是在这里和我一起工作。）我StateTtlConfig有一套相应的ListStateDe…
将DataSet数据发送到elasticsearch
作者： flink小助手
392人浏览
1人回答
正在尝试使用新的elasticsearch连接器将一些数据从DataSet发送到elasticsearch，但除了数据流结构之外我找不到任何资源： https://ci.apache.org/projects/flink/flink-do…
Apache Flink（v1.6.0）验证Elasticsearch Sink（v6.4）
作者： flink小助手
553人浏览
1人回答
我正在使用Apache Flink v1.6.0，我正在尝试写入Elasticsearch v6.4.0，它存放在Elastic Cloud中。我在向Elastic Cloud集群进行身份验证时遇到问题。 我已经能够让Flink写入本地E…
opennms 添加代码后不能开起主页面。
作者： robert.zhu
378人浏览
1人回答
我在opennms 官方网站上找到监控AD域服务目录的代码，但根据要求添加后没有办法打开opennms 的主页。这个是为什么！求解。注：启动的时候没有报错。 Monitoring the services To monitor the s…
java调用dumpe2fs 告知找不到有效的文件系统超级块。linux终端运行成功
作者： 小小小白bai
391人浏览
0人回答
public static void main(String[] args) { String cmd="dumpe2fs /dev/sda3"; List list = this.Cmd(cmd);}public List Cmd(…
