Flink键控流键为空
我试图在Flink中的KeyedStream上执行映射操作：stream.map(new JsonToMessageObjectMapper()) .keyBy("keyfield") .map(new MessageProcessorStateful())JsonToObjectMapper运算符的输出是 类的POJO，它具有String字段“ ”。然后，将流键入此字段。MessageProcessorStateful是一个Ri...
2024-01-10使用Flink和基于事件时间的流计算平均值
我想在基于历史事件的流中计算Flink中基于窗口的平均值（或由我定义的任何其他函数），因此流必须是事件时间（不处理基于时间）：使用Flink和基于事件时间的流计算平均值val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime) 我已经找...
2024-01-10如何通过Apache Camel调用RESTful服务？
我目前正在使用HTTP方法来调用一些URL，这将导致JIRA问题。现在，我想使用Apache Camel，该如何使用？我需要通过骆驼调用以下链接：http://localhost:8080/rest/api/2/project/" + key + /components由于我是Camel的新手，因此也请提出一些解决方案和示例。谢谢回答：您可以轻松使用CXFRS组件；如果出于某种原因需要...
2024-01-10Apache Flink：如何计算DataStream中的事件总数
我有两个原始流，我正在加入这些流，然后我要计算已加入的事件总数是多少，尚未加入的事件有多少。我通过使用joinedEventDataStream如下所示的地图来做到这一点joinedEventDataStream.map(new RichMapFunction<JoinedEvent, Object>() { @Override public Object map(JoinedEvent joinedEvent) throws Exception { ...
2024-01-10Apache Flink的吞吐量和延迟
我为ApacheFlink写了一个非常简单的Java程序，现在我对测量统计信息感兴趣，例如吞吐量（每秒处理的元组数）和等待时间（程序需要处理每个输入元组的时间）。 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.readTextFile("/home/LizardKing/Documents/Power/Prova.csv") .map(new MyMapper(...
2024-01-10Apache Spark中的矩阵乘法
我正在尝试使用Apache Spark和Java执行矩阵乘法。我有两个主要问题：如何创建可以表示Apache Spark中矩阵的RDD？ 如何将两个这样的RDD相乘？回答：所有这些都取决于输入数据和维度，但总的来说，您需要的不是RDD的分布式数据结构之一org.apache.spark.mllib.linalg.distributed。目前，它提供了四种不同的实现Di...
2024-01-10Apache Tiles替代品
我正在编写一个Spring MVC应用程序，正在寻找一种在视图中进行布局的方法。我看到的唯一选择是ApacheTiles，我以前使用过它，并且知道维护其配置是多么痛苦。有什么好的选择吗？我看着SiteMesh和SpringSurf似乎都处于hibernate状态。回答：大约一个月前，我面临着同样的困境。我是一个使用apache tile的经...
2024-01-10Apache精简“ Authorization”标头
我的Apache 2.2.15服务器有一个小问题。我正在使用mod_wsgi在其上运行Django应用。我激活了WSGIPassAuthorization On，从而使基本身份验证正常运行。但是我最近实现了OAuth2.0来保护我的API（隐式授予），并且我认为Apache不会通过它，因为它的形式为“授权：承载令牌”。我猜是“承载者”的问题，尽管我不知道...
2024-01-10Apache Kafka：生产者-Consume API没有在GCP上运行
我一直试图在Kafka集群上运行我的生产者和消费者api，但它不工作。Apache Kafka：生产者-Consume API没有在GCP上运行1）动物园管理员是在一个GCP VM实例运行2）卡夫卡正在另一个GCP VM实例运行步骤如下：步骤1）使用运行动物园管理员以下命令：bin/zookeeper-server-start.sh config/zookeeper.properties 个Zookeeper.propert...
2024-01-10Apache Camel路由和Spring引导：应用程序启动
我有一个Spring Boot（1.5.1）应用程序。Apache Camel路由和Spring引导：应用程序启动作为应用程序启动的一部分，它需要调用外部服务。这很好 - 我实现了一个实现ApplicationListener的类，并且外部服务被正确调用。我的问题是，外部服务立即将我的应用程序调回回调URL。对我的应用程序的调用失败，出现404 N...
2024-01-10使用Apache FTPClient使FTP服务器返回时间戳列出的文件
我已将以下代码编写为连接到远程FTP服务器（在CentOS 6中为vsftp）。（为简便起见，此处未显示异常处理）FTPClient ftpClient = new FTPClient();ftpClient.setConnectTimeout(20000);ftpClient.connect(serverip);ftpClient.enterLocalPassiveMode();ftpClient.login(username, password);if (!FTPReply.isPositiveComp...
2024-01-10
