0回答
IgniteRDD SQL表名称
、、、、
当在IgniteRDDs上使用.sql方法时，我需要有"table“名称来执行WHERE子句。我不知道如何检索它，这个示例为Int类型的缓存提供了名称Integer。我尝试过用字符串、Int缓存等重新创建它，但还没能弄清楚它们是如何获得Integer名称的。他们的例子可以在这里查看：
配置文件：
浏览 0提问于2018-07-18得票数 0
我想问Ignite是否适合我的用例，即：
将oracle表的所有数据加载到Ignite缓存中，然后对缓存中的数据执行各种SQL查询(聚合/连接/子查询)。另外，我注意到IgniteRDD不是不变的，IgniteRDD是否适合这个用例？也就是说，我首先将oracle中的数据加载到IgniteRDD中，然后使用新创建/更新的数据对IgniteRDD进行相应的更改。但是看起来IgniteRDD不支持复杂的SQL?(聚合&#x
浏览 6提问于2016-12-07得票数 2
我已经用Spark创建了一个Apache应用程序
调用检索时import java.util.Map;
import org.apache.ignite.spark.IgniteRDDprivate static void retrieve(IgniteContext ic, String cacheName) {
浏览 0提问于2016-06-09得票数 1
回答已采纳
1回答
我试图找到一个清晰的示例，说明如何使用Scala的Ignite RDD索引表，但是什么都找不到。请有人给出简单明了的例子，如何做到这一点？谢谢。
浏览 2提问于2016-05-02得票数 1
回答已采纳
看来IgniteRDD.sql只支持ANSI，而不支持SparkSQL或HiveQL？当我使用IgniteRDD.sql(sqlText) (为错误的sql抛出异常)时，它可以追溯到org.h2.jdbc.JdbcSQLException，这意味着h2解析正在解析sql？org.apache.ignite.internal.processors.cache.IgniteCacheProxy.query(IgniteCacheProxy.java:700)
at org.apach
浏览 3提问于2016-12-07得票数 1
回答已采纳
2回答
我试图通过使用IgniteRDD引入speed作为缓存层来加快spark查询的速度。从RDD示例中，它从RDD缓存加载数据以构造RDD。但是在我们的使用中，数据大小可能太大而不能放入内存中，实际上我们只是将数据放在hbase中，所以可以这样做: 1、通过从hbase 2加载数据构建igniteRDD，使用generated缓存sql生成的共享
浏览 4提问于2017-12-21得票数 0
回答已采纳
如果我在我的spark作业中创建了一个有10M个条目的缓存之外的igniteRDD，它会将所有10M条目加载到我的spark上下文中吗？请在下面找到我的代码以供参考。Integer,Subscriber> cache = igniteCxt.fromCache("subscriberCache");
DataFrame query_res = cache.sql
浏览 1提问于2016-04-06得票数 2
有一个运行ANSI sql (not spark sql)的IgniteRDD.sql方法，该方法返回一个DataFrame，这是spark sql的概念。也就是说，我可以注册临时表，然后与其他DataFrame进行分布式连接。在执行sql时，Ignite是使用Spark SQL引擎还是使用Ignite引擎来运行sql？
浏览 0提问于2016-12-13得票数 0
1回答
setMaster("local[*]") val sqlContext = new org.apache.spark.sql.SQLContext(sc)
val sql_dump1=sqlContext.read.format("jdbc").option("url", "jdbc URL").option("driver", "com.my
浏览 1提问于2016-05-12得票数 2
回答已采纳
1回答
我正在IgniteRDD上执行一个sql查询。它正在运行用于RDD转换和操作的ok，但是当我在IgniteRDD上调用一个sql时，它不会返回任何结果。[Int, Int] = igniteContext.fromCache[Int, Int]("sharedRDD")
浏览 6提问于2017-01-12得票数 1
回答已采纳
2回答
我使用以下代码将Spark数据save保存到Apache表：.format("ignite")\.option("primaryKeyFields
浏览 10提问于2019-12-06得票数 0
回答已采纳
我看到了使用Java访问Ignite RDD/访问Spark数据集的Ignite SQL的选项。任何人尝试使用IgniteRDD/IgniteSQL使用Scala访问Spark数据集。
浏览 0提问于2016-10-19得票数 1
1回答
IgniteContext(sc, () => new IgniteConfiguration())
cacheRdd.sqlorg.apache.ignite.internal.processors.cache.IgniteCacheProxy.query(IgniteCacheProxy.java:690)
at org.apache.ignite.spark.IgniteRDD.sql(IgniteRDD.scala:147
浏览 5提问于2016-10-12得票数 2
回答已采纳
如何在Apache中保存和读取/ DataSet？我尝试了其他类似问题的各种解决方案，但没有任何最新的点火和火花版本的工作。(我正在使用Scala2.11)谢谢。<?xml version="1.0" encoding="UTF-8"?> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
x
浏览 4提问于2017-11-22得票数 0
回答已采纳
我在IgniteRDD中保存了一些Spark，键和值都是BinaryObject，它工作得很好，我还可以使用Ignite代码在后面查询，下面是% dataset解释器示例。ID：-1422444403的解析类失败”
在我看来，这两种方法的不同之处在于，首先我指定了withKeepBinary()，如何在%ignite.ignitesql中实现类似的操作，以便可以直接使用sql
浏览 4提问于2016-10-26得票数 0
回答已采纳
相同的代码可以很好地处理较小的SQL参数输入。代码如下：
subEntries = dataRDD.sql("SELECT v.id,v.sub,v.obj FROM VPRow v JOIN table(id bigint = ?)
浏览 0提问于2017-06-14得票数 0
在创建一个包时，我需要帮助，它可以遍历给定服务器中的数据库，查找包含单词“EventLog”的表名，并删除超过一年的所有行。删除应批次为50000。我能够使用Execute SQL任务读取数据库名称，将完整的结果集存储在一个对象类型变量中，并用于每个循环容器来读取变量的结果，并需要那里的帮助。
浏览 5提问于2017-06-09得票数 1
这似乎是一种奇怪的行为，但下面的代码抛出了一个错误：{ alter index @indexName on @tableName rebuild;", { tableName = tableName}System.
浏览 0提问于2019-04-05得票数 2
回答已采纳
1回答
我需要获得数据库名称，并将名称的一部分附加到跨数据库查询中。DECLARE @sql NVARCHAR(MAX)
FRO
浏览 5提问于2022-07-21得票数 -1
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号