从 Neo4j 读取

该连接器提供三种数据源选项，以从 Neo4j 数据库读取数据。

表 1. 读取选项
选项 描述 值 默认

标签

如果您只需要读取节点及其属性，请使用此选项。

冒号分隔的要读取的节点标签列表。

(空)

关系 (relationship)

如果您需要读取关系以及它们的源节点和目标节点，请使用此选项。

要读取的关系类型。

(空)

query

如果您需要更大的灵活性并且了解如何编写 Cypher® 查询，请使用此选项。

带有 MATCH 子句的 Cypher 查询。

(空)

示例

本页的所有示例均假设已使用适当的身份验证选项初始化了 SparkSession。有关详细信息，请参阅 快速入门示例。

您可以运行每个选项的 写入示例，以获取一些示例数据进行读取。

labels 选项

读取 :Person 节点。

示例
val df = spark.read
    .format("org.neo4j.spark.DataSource")
    .option("labels", ":Person")
    .load()

df.show()
示例
df = (
    spark.read.format("org.neo4j.spark.DataSource")
    .option("labels", ":Person")
    .load()
)

df.show()

有关更多信息和示例，请参阅 读取节点。

relationship 选项

读取带有源节点、目标节点及其属性的 :BOUGHT 关系。

示例
val df = spark.read
    .format("org.neo4j.spark.DataSource")
    .option("relationship", "BOUGHT")
    .option("relationship.source.labels", ":Customer")
    .option("relationship.target.labels", ":Product")
    .load()

df.show()
示例
df = (
    spark.read.format("org.neo4j.spark.DataSource")
    .option("relationship", "BOUGHT")
    .option("relationship.source.labels", ":Customer")
    .option("relationship.target.labels", ":Product")
    .load()
)

df.show()

有关更多信息和示例，请参阅 读取关系。

query 选项

使用 Cypher 查询读取数据。

示例
val readQuery = """
  MATCH (n:Person)
  RETURN id(n) AS id, n.fullName AS name
"""

val df = spark.read
    .format("org.neo4j.spark.DataSource")
    .option("query", readQuery)
    .load()

df.show()
示例
read_query = """
    MATCH (n:Person)
    RETURN id(n) AS id, n.fullName AS name
"""

df = (
    spark.read.format("org.neo4j.spark.DataSource")
    .option("query", read_query)
    .load()
)

df.show()

有关更多信息和示例，请参阅 使用 Cypher 查询读取。

类型映射

有关 Spark DataFrames 与 Neo4j 之间完整类型映射的详细信息，请参阅 数据类型映射。

性能注意事项

如果未指定模式，Spark 连接器将使用抽样。由于抽样可能是一项昂贵的操作，建议定义模式。