Elastic-Job中的DataFlowJob

DataFlowJob：Dataflow类型用于处理数据流，必须实现 fetchData()和processData()的方法，一个用来获取数据，一个用来处理获取到的数据。

public class MyDataFlowJob implements DataflowJob<String> {public List<String> fetchData(ShardingContext shardingContext) {System.out.println("开始获取数据");// 假装从文件或者数据库中获取到了数据Random random = new Random();
/*        if( random.nextInt() % 3 != 0 ){return null;}*/return Arrays.asList("qingshan","jack","seven");}public void processData(ShardingContext shardingContext, List<String> data) {for(String val : data){// 处理完数据要移除掉，不然就会一直跑System.out.println("开始处理数据："+val);}}
}

Elastic-Job中的DataFlowJob相关推荐

elastic stack中的Beats是什么？
elastic stack中的Beats是什么? elastic stack栈涉及到以下⼏个组件 beats:⽤于轻量级⽇志采集,⽀持⽂件采集,系统数据采集,特定中间件数据采集等 logstash:⽤ ...
Elasticsearch：如何在 Elastic Agents 中配置 Beats 来采集定制日志
在我之前的文章 "Observability:使用 Elastic Agent 来摄入日志及指标 - Elastic Stack 8.0",我详细地描述了如何安装 Elastics ...
Elasticsearch：从 Elastic Stack 中的时间戳谈开去
时间戳,也就是 timestamp, 它在许多的事件中,特别是时序数据中是一个不可少的字段.它记录事件或文档的时间.在我们对数据可视化时,也是非常重要的一个字段.针对时序时间,在我们对数据创建 ind ...
Elastic Search 中bool组合查询
Bool组合概念逻辑判断是否 Bool组合语法 must:必须符合,包含 should:满足任一条件 filter:必须符合,是否命中,不计算分值,等同must must_not:必须不符合,不包含 ...
Elastic：培训视频 - 在生产环境中配置 Fleet Server 和 Elastic Agent 之间的安全
在这篇文章中,我将会把我写的有些内容录制成视频,供大家参考.希望对大家有所帮助.优酷的视频频道地址在这里,B站频道 Elastic 简介及 Elastic Stack 安装 Elastic Stack ...
Elastic 在 2021 年度《Gartner 应用程序性能监测魔力象限》中被评为有远见者
作者 Asawari Samant 我们非常高兴地宣布,Elastic 在 2021 年度<Gartner 应用程序性能监测魔力象限>中被评为有远见者.我们对进入"有远见者&qu ...
Elasticsearch：如何在 Elastic 中实现图片相似度搜索
作者:Radovan Ondas 在本文章,我们将了解如何通过几个步骤在 Elastic 中实施相似图像搜索. 开始设置应用程序环境,然后导入 NLP 模型,最后完成为你的图像集生成嵌入. Elast ...
使用Elastic APM监控你的.NET Core应用
前言在应用实际的运维过程中,我们需要更多的日志和监控来让我们对自己的应用程序的运行状况有一个全方位的了解.然而对于大部分开发者而言,平时大家所关注的更多的是如何更优雅的实现业务,或者是如何让应用的响 ...
Elastic Stack简介
Elastic Stack简介如果你没有听说过Elastic Stack,那你一定听说过ELK,实际上ELK是三款软件的简称,分别是Elasticsearch. Logstash.Kibana组成, ...

Elastic-Job中的DataFlowJob

Elastic-Job中的DataFlowJob相关推荐

最新文章

热门文章