我如何使用java或python.I中的flink从卡桑德拉读取。我没有找到关于这个subject.And的很好的文档，我想把这个代码连接到我的website.How。
浏览 39提问于2019-08-22得票数 0
回答已采纳
我是Apache Flink的新手。我使用Pojo Sink将数据加载到Cassandra。现在，我在@ table 注释的帮助下指定表名和键空间名。现在，我希望在运行时动态地传递表名和键空间名，以便将数据加载到用户指定的表中。有办法做到这一点吗？
浏览 3提问于2016-12-16得票数 4
4回答
我打算使用apache将数据读/写到cassandra，使用flink。我希望使用，但没有找到用于连接器的好文档/示例。
请您指出使用Apache从cassandra读取和写入数据的正确方法。apache也是用于从cassandra读取数据的，是否与apache类似？
浏览 7提问于2017-03-06得票数 4
回答已采纳
尝试使用Apache Flink从Cassandra获取数据，引用可以读取数据，但不知道如何将其加载到DataStream对象中。DataStream<byte[]> temp = new DataStream<byte[]>(env, new StreamTransformation<byte[]>(res.toByteArray()));
将res变量中的数据加载到DataStream<b
浏览 1提问于2018-04-04得票数 1
摄入卡夫卡的数据，比如50个分区(输入速率- 100,000毫希/秒)
将输出存储在Cassandra上我是否需要在google数据流中编写数据管道来执行flink上的步骤序列，还是有其他方法来执行实时流的步骤序列？假设我的每一次计算花费大约20毫秒，我如何更好地使用flink来设计它并获得更好的吞吐量
浏览 2提问于2016-06-10得票数 3
我有两个简单的Flink流作业，从Kafka读取，进行一些转换，并将结果放入Cassandra Sink。他们阅读不同的卡夫卡主题，并保存到不同的卡桑德拉表格。触发并完成检查站，并将数据保存到Cassandra。我找不到关于这个错误的很多信息，它可能是由下列任何一个原因造成的：
Flink (v 1.10.0-scala_2.12)，Flink Cassandra连接器(flink-连接器-Cassandra_编辑：
浏览 10提问于2020-10-13得票数 6
回答已采纳
我的Flink作业需要在不同的时间写入不同的Cassandra表。对于这个场景，Cassandra连接器的动态表名或动态查询，或者Flink作业的动态接收器都适合我。
浏览 10提问于2020-03-01得票数 0
回答已采纳
1回答
我是拉格姆和持久性实体数据库概念的新手。
我正在构建流式分析引擎。我的每一个分析都将作为独立的微型服务工作，对于每一个个体的微型服务，根据其设计理念，结果将保存在自己的数据库中(我的案例卡桑德拉)。我使用Flink &，结果是Sink到Cassandra，使用幻影Flink(Scala驱动程序，为Cassandra)。我无法理解拉格姆框架中的以下挑战。为了存储分析结果，我仍然需要实现持久性实体(P.E)来将记录存储在Cassandra<
浏览 6提问于2017-04-19得票数 0
回答已采纳
1回答
现在的优先要求是，产品细节是高度混乱的，这些文件必须组织、处理(10+过程)并转换为另一个公共对象(Json)，然后将文件存储在Cassandra中。我的技术主管建议我在HDFS上使用Apache Flink和Kafka进行设计，在HDFS上，flink直接从供应商的服务器流式传输文件，并在流式传输的同时开始处理它们。因此，我想到了一个独立的调度程序来下载文件并将其加载到HDFS。一旦文件加载到HDFS，我就可以触发Flink处理并将其存储在C
浏览 22提问于2016-09-24得票数 0
使用Apache版本1.3.2和Cassandra 3.11，我编写了一个简单的代码，使用Apache连接器将数据写入Cassandra。我使用代码中导入的下列依赖项：import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.connectors.<e
浏览 2提问于2018-03-24得票数 4
回答已采纳
我试图从cassandra表中提取数据作为数据集，但我遇到了两个问题。另一个问题是，即使我从cassandraInputFormat中提取的数据(不管是元组还是非元组)，我也不知道如何将它设置为数据源。对于文件、csv和HDFS，有很多方法()，但没有一个方法显式地用于cassandra。Source "at execute(CodeBatchProcessorImpl.java:85)
(org.apache.flink
浏览 4提问于2017-05-11得票数 0
回答已采纳
I成功地将csv文件数据从s3加载到FlinkSql本地机器中。username STRING,) WITH ( 'path'='s3://d11-data-lake-load/flink/events_data/test_flink/test-csv',
&
浏览 7提问于2021-05-12得票数 0
所以在cassandra中，我会创建一个这样的表： prodCode text, city text,我想我的问题是，用映射和列表将关系数据库系统中的非规范化表转换到cassandra中的最佳方法是什么？
浏览 2提问于2015-08-12得票数 0
1回答
当应用程序启动时，我可以从数据库中读取数据。然后再一次，我想从数据库获得一些kafka消息为基础的数据。当我在流中接收kafka消息时，我希望从DB again.This获取数据是我的实际用例。
浏览 0提问于2020-06-19得票数 1
我需要使用flink-sql实时计算“每日活跃用户”，这就像是对每日数据的“count(distinct )”操作。
我的问题是，如果userA像预期的那样在凌晨1点登录，并且flink将DAU加1。现在，userA在晚上10点再次登录，flink-sql怎么知道今天早上userA已经被处理了？是否需要对全天的登录日志重复做count(distinct )？如果不是，flink如何处理这个senario？
浏览 6提问于2020-09-14得票数 0
我想使用Flink对Postgresql中的数据进行一些分析。我应该如何和在哪里给出端口地址，用户名和密码。我正在尝试使用链接：中提到的表源。
浏览 0提问于2018-06-21得票数 1
回答已采纳
3回答
我有一个数据驻留在Apache Cassandra中，我想使用hadoop生态系统工具执行map/reduce作业。
如何将数据从Cassandra加载到HDFS？除了Cassandra存储处理程序/brisk之外，是否还有其他存储处理程序？
浏览 3提问于2013-11-27得票数 3
2回答
是否可以从本地HDFS (例如192.168.0.10)迁移/复制/复制/移动处理过的文件到cassandra (192.168.0.20)？我想到的是，我确实创建了一个java应用程序来解析文件，并将它们重新插入cassandra中。非常感谢！
浏览 1提问于2015-09-18得票数 0
Flink是流媒体的一个明显的选择，然而Spark已经成熟了ML pipelines，它可以在spark中训练模型，将其保存为CrossValidatorModel并部署到Flink中的流媒体数据吗？
浏览 16提问于2017-03-16得票数 0
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
