1回答
我是spark和neo4j的新手，需要帮助设置它们。 我的目标是在spark中读取HDFS文件，并将其放入/表示为neo4j。有没有人可以帮我在spark和neo4j之间创建一个连接器，但是neo4j是一个容器？我对我在互联网上找到的所有东西都有点迷失，而且我在我的容器中也得不到结果
浏览 35提问于2020-07-06得票数 1
1回答
我需要输入火花流输出到Neo4j的图形实时。有没有办法做到这一点。如果是这样，你能分享一些示例代码吗？我见过Mazerunner，但它只将图形数据从Neo4j输入到Spark-Graphx。谢谢。
浏览 1提问于2015-06-07得票数 1
1回答
我想使用GraphX将星火Neo4j与集成我应该对新4j连接器-apache_2.12-4.0.jar文件做什么？我把它放在星火文件夹中的jar文件中。我在bash中写道：有什么建议吗更新1
我试过这个C:\Spark</em
浏览 5提问于2021-04-01得票数 1
我使用的是neo4j-connector-apache-spark_2.11-4.0.2_for_spark_2.4.jar这个连接器，它的spark版本为2.4.4、Scala2.11.12和neo4j3.3.x
抛出此org.neo4j.driver.exceptions.ClientException:服务器不支持此驱动程序支持的任何协议版本。确保您使用的是相互兼容的驱动程序和服务器版本，同时
浏览 6提问于2022-10-12得票数 0
回答已采纳
我需要在spark map函数中得到一个小的子图。我试过使用AnormCypher和NEO4J-SPARK-CONNECTOR，但都不起作用。和Neo4j-spark-connector将导致下面的任务NOT SERIALIZABLE异常。在Spark worker节点中有没有一个很好的方法来获得一个子图(或者连接到neo4j这样的图形数据库)？我的代码片段使用了ne4j-spark</em
浏览 7提问于2017-03-09得票数 2
我一直在学习本教程，我希望将我的NEo4j数据库与教程中描述的Dockerized集成在一起。Dockerized提供了Neo4j和Spark之间的接口。我是码头新来的。up -d
5.我想将Graph.db的位置更改为本地的./3.0.3
浏览 1提问于2016-08-10得票数 0
我正在尝试使用neo4j连接器构建Spark应用程序，但我得到了一个错误：importorg.neo4j.spark.Neo4jlibraryDependencies += "org.neo4j" % "neo4j-connector-apach
浏览 1提问于2022-08-29得票数 0
2回答
我正在尝试将Neo4j与Apache Spark Streaming结合使用，但我发现可序列化是一个问题。org.apache.spark.SparkException: Task not serializable
浏览 1提问于2015-03-06得票数 2
1回答
Neo4j作为火花放电的数据源
、、、、
我有一个要求，我必须从Neo4j中提取数据，并从这些数据中创建Spark。我在我的项目中使用Python。连接器具有相同的用途，但它是用Scala编写的。所以我现在可以想出解决办法-
另一种方
浏览 7提问于2018-01-09得票数 2
在最近版本的中，官方文档中有一个示例，它演示了使用火花()阅读Neo4j：
spark.read.format("org.neo4j.spark.DataSource我想知道如何指定要从其中读取数据的数据库名称。这个连接器甚至支持这种事务
浏览 2提问于2021-01-02得票数 0
回答已采纳
我正在尝试使用spark neo4j连接器创建数据集myDF.createOrReplaceTempView("Mytable");
当我们有来自Neo4j的查询结果时，这可以很好地工作。在这里，neo4j查询可能返回0条记录，在这种
浏览 0提问于2018-12-24得票数 0
1回答
我的目标是使用Spark结构化流将转换后的数据从MongoDB集合写入Neo4j。根据Neo4j文档，这在"“版本4.1.2中是可能的。spark-shell --packages org.mongodb.spark:mongo-spark-connector:10.0.2,org.neo4j:neo4j-connector-apache-<em
浏览 17提问于2022-06-27得票数 0
我在Kubernetes上使用Spark 3.0.1，spark cassandra连接器和cassandra。我使用spark cassandra Cassandra API来获取Spark Partition的数据局部性特性，首先是Cassandra，然后是joinWithCassandraTable。但是这个重新分区失败了，因为cassandra数据对于Spark容器来说不是本地的。正因为如此，joinWith
浏览 2提问于2021-06-14得票数 1
mongo-hadoop和mongo-spark连接器有什么不同，pymongo只能和mango-hadoop一起使用吗？
pymongo只与mongo-hadoop一起使用吗？
浏览 2提问于2018-07-10得票数 0
2回答
有一项要求，即来自应用程序的数据必须与数据仓库尽可能接近实时地同步(延迟3-5分钟以上的所有内容都是不可接受的，实时复制将是最好的)。Citus是Postgres的扩展，你能把它当作一个普通的Postgres数据库吗？如果是，那么逻辑复制理论上应该工作，但是它如何处理分布式表呢？我是否需要将逻辑级别的WAL流到Kafka中，然后编写自定义逻辑将其转换为目标数据库上的SQL语句？有什么工具吗？额外的问题:是否有人有使用过Citus和Gr
浏览 0提问于2021-02-04得票数 0
我创建了一个运行Neo4j数据库的任务定义，为数据库http和螺栓连接器打开了端口7474和7687，并在私有子网中的类型为Fargate的ECS服务中启动了任务定义。没有ALB如何获取运行数据库的容器的IP地址？
谢谢
浏览 0提问于2018-05-15得票数 1
1回答
容器主机名未解析为IP。
、、、
Neo4j用作docker-come.yml文件中的图像。当我使用Neo4j容器的主机名运行应用程序的映像时，会得到一个错误ServiceUnavailableException: Unable to connect to neo4jdb:7687, ensure因此容器的名称不被解析为IP地址。我怎么才能修好它？neo4j{
url= "bolt://localhost:7687&
浏览 5提问于2018-06-26得票数 0
回答已采纳
当我尝试连接spark和cassandra时，我得到了“没有常见的密码套装”异常。
浏览 6提问于2020-10-28得票数 0
1回答
我是Azure和Databricks的初学者，我很难保存很多数据。5 GB)从Azure数据库到Cosmos DB的火花连接器。
序言：我面临一个问题，因为我想用很多行填充Cosmos容器(例如。( 500mil+)用于进一步的测试。目前我有一个集装箱(前。容器#1)，其中我是流遥测数据使用流分析。我想要实现的是从容器#1获取数据，多次乘以数据，然后将其保存到一个新的容器#2。我想使用Spa
浏览 4提问于2022-09-26得票数 1
回答已采纳
有没有人知道Neo4j 3.0是否与Mazerunner兼容？是否有人试图将Mazerunner连接到他们的Neo4j 3.0数据库？
浏览 3提问于2016-05-31得票数 0
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
