Object

org.opencypher.spark.api.io.neo4j.sync

Neo4jGraphMerge

Related Doc: package sync

Permalink

object Neo4jGraphMerge extends Logging

Utility class that allows to merge a graph into an existing Neo4j database.

Linear Supertypes
Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Neo4jGraphMerge
  2. Logging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. case class Batches(nodeBatchSize: Int = 1000, relBatchSize: Int = 10) extends Product with Serializable

    Permalink

    Configuration class for Neo4jGraphMerge

    Configuration class for Neo4jGraphMerge

    nodeBatchSize

    size of node batches

    relBatchSize

    size of relationship batches

  2. type NodeKeys = Map[String, Set[String]]

    Permalink

    Defines a set of properties which uniquely identify a node with a given label.

    Defines a set of properties which uniquely identify a node with a given label.

    See also

    org.opencypher.okapi.api.schema.Schema#nodeKeys

  3. type RelationshipKeys = Map[String, Set[String]]

    Permalink

    Defines a set of properties which uniquely identify a relationship with a given type.

    Defines a set of properties which uniquely identify a relationship with a given type.

    See also

    org.opencypher.okapi.api.schema.Schema#relationshipKeys

Value Members

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

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

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

    Permalink
    Definition Classes
    AnyRef → Any

  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  6. def createIndexes(graphName: GraphName, config: Neo4jConfig, nodeKeys: NodeKeys): Unit

    Permalink

    Creates node indexes for the sub-graph specified by graphName in the specified Neo4j database.

    Creates node indexes for the sub-graph specified by graphName in the specified Neo4j database. This speeds up the Neo4j merge feature.

    graphName

    which sub-graph to create the indexes for

    config

    access config for the Neo4j database on which the indexes are created

    nodeKeys

    node keys that identify a node uniquely

    Note

    This feature requires the Neo4j Enterprise Edition.

  7. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  8. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any

  9. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  10. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any

  11. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any

  12. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

  13. val logger: Logger

    Permalink
    Attributes
    protected
    Definition Classes
    Logging

  14. def merge(graphName: GraphName, graph: PropertyGraph, config: Neo4jConfig, nodeKeys: Option[NodeKeys] = None, relationshipKeys: Option[RelationshipKeys] = None, batches: Batches = Batches())(implicit caps: CAPSSession): Unit

    Permalink

    Merges the given graph into the sub-graph specified by graphName within an existing Neo4j database.

    Merges the given graph into the sub-graph specified by graphName within an existing Neo4j database. Properties in the Neo4j graph will be overwritten by values in the merge graph, missing ones are added.

    Nodes and relationships are identified by their entity keys defined by the graph's schema. They can be overridden by optional node and relationship keys

    graphName

    which sub-graph in the Neo4j graph to merge the delta to

    graph

    graph that is merged into the existing Neo4j database

    config

    access config for the Neo4j database into which the graph is merged

    nodeKeys

    additional node keys that override node keys defined by the schema

    relationshipKeys

    additional relationship keys that override relationship keys defined by the schema

    caps

    CAPS session

  15. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef

  16. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  17. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  18. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef

  19. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any

  20. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  21. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  22. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped