Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   Any

2.  final def ##: Int

   Definition Classes

   Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   Any

4.  final def asInstanceOf[T0]: T0

   Definition Classes

   Any

5.  def getClass(): Class[_ <: AnyVal]

   Definition Classes

   AnyVal → Any

6.  final def isInstanceOf[T0]: Boolean

   Definition Classes

   Any

7.  def neo4jCypher[U](neo4jConf: Neo4jOptions, cypher: String)(implicit neo4jInType: ValueType[T], neo4jOutType: ValueType[U], coder: Coder[U]): SCollection[U]

   Execute parallel instances of the provided Cypher query to the specified Neo4j database; one instance of the query will be executed for each element in this SCollection.

   Execute parallel instances of the provided Cypher query to the specified Neo4j database; one instance of the query will be executed for each element in this SCollection. Results from each query invocation will be added to the resulting SCollection as if by a flatMap transformation (where the Neo4j-query-execution returns an Iterable).

   This operation parameterizes each query invocation by first transforming each SCollection element via magnolify.neo4j.ValueType.to. Parameter names in the provided Cypher query String must match the names of keys in the org.neo4j.driver.Value generated by the (implicit) ValueType for the input SCollection type. (If the input type is a case class, that means that parameter names in the query should correspond to the fields defined in the case class.)

   neo4jConf

   options for configuring a Neo4J driver

   cypher

   parameterized Cypher query

   returns

   SCollection containing the union of query results from a parameterized query invocation for each original SCollection element

   See also

   Reading from Neo4j in the Beam Neo4jIO documentation

   syntax for Cypher query parameters defined in Cypher Manual (Syntax / Parameters)

8.  def saveAsNeo4j(neo4jOptions: Neo4jOptions, unwindCypher: String, batchSize: Long = WriteParam.DefaultBatchSize)(implicit neo4jType: ValueType[T], coder: Coder[T]): ClosedTap[Nothing]

   Save this SCollection as a Neo4J database.

   Save this SCollection as a Neo4J database.

   neo4jOptions

   options for configuring a Neo4J driver

   unwindCypher

   Neo4J cypher query representing an UNWIND parameter cypher statement

   batchSize

   batch size when executing the unwind cypher query. Default batch size of 5000

9.  def toString(): String

   Definition Classes

   Any