Package org.apache.beam.sdk.io.neo4j
package org.apache.beam.sdk.io.neo4j
Transforms for reading from and writing to from Neo4j.
-
ClassDescriptionThis is a Beam IO to read from, and write data to, Neo4j.This describes all the information needed to create a Neo4j
Session
.Wraps aNeo4jIO.DriverConfiguration
to provide aDriver
.Neo4jIO.ReadAll<ParameterT,OutputT> This is the class which handles the work behind theNeo4jIO.readAll()
method.An interface used byNeo4jIO.ReadAll
for converting each row of a Neo4jResult
recordRecord
into an element of the resultingPCollection
.Neo4jIO.WriteUnwind<ParameterT>This is the class which handles the work behind theNeo4jIO.writeUnwind()
method.