个人中心
文章发布
退出
作者热门文章
- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
26
4
我开始学习大数据和Apache Spark我有疑问。
将来我需要从 IoT 收集数据，这些数据将以 time series data 的形式传给我.我在阅读时间序列数据库 (TSDB) 时发现了一些开源选项，例如 Atlas、KairosDB、OpenTSDB 等。
我实际上需要 Apache Spark，所以我想知道:我可以在 Apache Spark 上使用时间序列数据库吗？这有什么意义吗？请记住，我对大数据、Apache Spark 的概念以及我在这个问题中谈到的所有问题都非常陌生。
如果我可以在 Spark 上运行 TSDB，我该如何实现？
最佳答案
我是 OpenTSDB 提交者，我知道这是一个老问题，但我想回答。我的建议是将传入数据写入 OpenTSDB，假设您只想存储原始数据并在以后处理它。然后使用 Spark，使用 OpenTSDB 类执行 OpenTSDB 查询。
你也可以用类写数据，我想你想使用 IncomingDataPoint 构造，实际上我现在手头没有细节。如有更多问题，请随时通过 OpenTSDB 邮件列表与我联系。
您可以在此处查看 OpenTSDB 如何处理传入的“put”请求，您应该能够在写入代码中执行相同的操作:
https://github.com/OpenTSDB/opentsdb/blob/master/src/tsd/PutDataPointRpc.java#L42
您可以在此处看到 Splicer 项目提交 OpenTSDB 查询，我认为可以在您的 Spark 项目中使用类似的方法:
关于database - 我可以在 Apache Spark 上运行时间序列数据库 (TSDB) 吗？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/32530588/
26
4
0
考虑以下示例代码: void main() { List array = []; for (int i = 0; i newList = array.where( (value) => v
我在java中实现了textrank，但它看起来很慢。有谁知道它的预期性能吗？ 如果预计速度不会很慢，则可能是以下任一问题: 1) 似乎没有办法在 JGraphT 时间内创建一条边并同时为其添加权重，
我正在尝试提交解决方案(使用一些具有编译时间限制的在线编译器)来对数组进行排序 - 这是我的代码片段 - class TSORT { public static void main(Strin
只是一个困惑......部分C++示例代码如下 我只是重新编辑了整个帖子。抱歉造成任何混淆 int i, j; i = 0; // c1 j = 0; // c2 while (i
我正在使用 OpenMP 运行一些并行工作，但发现加速无法很好地扩展。然后我发现随着线程数量的增加，完成相同工作量的时间也会增加。这是示例: void fillingVec(vector& vec)
我目前正在分析 maximum subarray problem 用于强力算法和分而治之算法(递归)。 使用蛮力算法，最坏情况下的运行时间为 O(n^2)。使用递归算法，最坏情况下的运行时间为 O(n
如果我有两个数组都有 10000 个项目，现在我想将它们合并到一个数组中，所以我用 concat 来完成: array1=array1.concat(array2); 但是有人知道运行时间是多少吗？
{ clock_t t1, t2; double time1 = 0; t1 = clock(); bubbleSort(data, n); t2 = cloc
我在某处读到有人可以在运行时访问配置值，但不能在设计时访问。在这种情况下，运行时和设计时有什么区别？ 最佳答案 设计时间是有人用愉快的“看起来不错!”在我们的 Word 文档和 UML 图表上签字的时
我正在比较我们一个项目的两个分支的性能，一个比另一个慢得多。我注意到其中一个的 GC 运行计数更高(见下图)。 更有趣的是，运行时间要长很多倍，远远超过额外运行所能解释的时间。什么可以解释运行次数增加
我想以可读的方式格式化 log4j 经过的运行时间，%r 参数: [00:36:25.844] 和 [01 13:35:25.844] [时:分:ss.SSS] ... [dd 时:分:ss.SSS]
如何计算此代码的大 O 运行时效率？我的直觉告诉我它是 O(n^3)，但我不确定，因为我不确定循环是独立的还是相关的。 for (i=1; i<=n; i++) for (j=1; j<=n;
确定这些不同循环的大 O 运行时间？ for i = 1 to n { ... for j = 1 to 2*i { ... k = j; while (k>=0)
运行时间、复杂性、编译时间和执行时间有什么区别？ 运行时间与时间复杂度有冲突，执行时间和执行时间有什么区别？ 最佳答案 您真正需要的是如何将大O时间复杂度转换为运行时。这不像一开始看起来那么容易。 因
斯内普的《Unfriendly Algorithms for Wizards》教科书声称合并的运行时间排序是 O(n^4)。这种说法是否正确？ 解决方案:是的。这个说法在技术上是正确的，因为 O(n^
我有一系列问题需要反馈和答案。我会评论我的想法，这不是家庭作业而是准备为了我的考试。 我的主要问题是确定不同情况下循环的迭代。试图弄清楚这一点会如何？ 评估运行时间。 Q2。 for(int i =
我试图找到一个合理的机会来测量我的 java 程序/程序部分的速度，例如测试两种方法中哪一种执行得更快。注释掉这两种方法中的一种，确定运行时间，最后比较时间。我不想在我的程序中使用任何代码，例如: p
好吧，这些都是非常简单的方法，而且有几个，所以当它们都是同一件事时，我不想只创建多个问题。 BigO 是我的弱点。我只是想不通他们是如何得出这些答案的。无论如何，您是否可以让我深入了解您对分析其中一些
如何计算此给定代码的 Theta 运行时间: void f(int n) { for (int i=3; i
使用 leiningen 创建 uberjar 并使用 java -jar foo-uberjar.jar 运行该 jar 后程序运行良好，最后一行代码执行得相当快，但程序在关闭前挂了大约一分钟。这是
我是一名优秀的程序员,十分优秀！