Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

Table of Contents
stylecircle

...

SectionUser Facing NameWidget TypeDescriptionConstraints
GeneralLabeltextboxLabel for UI.

Reference NametextboxUniquely identified name for lineage.Required

Neo4j Host
textboxNeo4j database host.Required

Neo4j PortnumberNeo4j database port.Required

Input Querytextbox

The query to use to import data from the Neo4j database.
Query example: 'MATCH (n:Label) RETURN n.property_1, n.property_2'.

Required
CredentialsUsernametextboxUser identity for connecting to the Neo4j.Required

PasswordpasswordPassword to use to connect to the Neo4j.Required
AdvancedSplits NumbernumberThe number of splits to generate. If set to one, the orderBy is not needed.

Order Bytextbox

Field Name which will be used for ordering during splits generation. This is required unless numSplits is set to one.


...

Source Data Types Mapping

Neo4j Data TypesCDAP Schema Data Types
nullnull
Listarray
Maprecord
Booleanboolean
Integerlong
Floatdouble
Stringstring
ByteArraybytes
Datedate
Timetime-micros
LocalTimetime-micros
DateTimetimestamp-micros
LocalDateTimetimestamp-micros
Node

record

Schema example:

Code Block
{"name": "n", "type": {
	"type": "record", "name": "n", "fields": [
		{"name": "born", "type": "long"}, 
		{"name": "name", "type": "string"}, 
		{"name": "_id", "type": "long"}, 
		{"name": "_labels", "type": {"type": "array", "items": "string"}}
	]
}}
Relationship

record


Schema example:

Code Block
{"name": "r", "type": {
    "type": "record", "name": "r", "fields": [
        {"name": "_startId", "type": "long"},
        {"name": "roles", "type": {"type": "array", "items": "string"}},
        {"name": "_type", "type": "string"},
        {"name": "_endId", "type": "long"},
        {"name": "_id", "type": "long"}
    ]
}}

Duration

A Duration represents a temporal amount, capturing the difference in time between two instants, and can be negative.

record

Schema example:

Code Block
{"name": "dr", "type": {
    "type": "record", "name": "dr", "fields": [
        {"name": "duration", "type": "string"},
        {"name": "seconds", "type": "long"},
        {"name": "months", "type": "long"},
        {"name": "days", "type": "long"},
        {"name": "nanoseconds", "type": "string"}
    ]
}}
Point

record

Schema example:

Code Block
{"name": "p", "type": {
    "type": "record", "name": "p", "fields": [
        {"name": "crs", "type": "string"},
        {"name": "x", "type": "double"},
        {"name": "y", "type": "double"},
        {"name": "srid", "type": "string"}
    ]
}}
Path


Sink Properties

SectionUser Facing NameWidget TypeDescriptionConstraints
GeneralLabeltextboxLabel for UI.

Reference NametextboxUniquely identified name for lineage.Required

Neo4j HosttextboxNeo4j database host.Required

Neo4j PortnumberNeo4j database port.Required

Output QuerytextboxThe query to use to export data to the Neo4j database.
Query example: 'CREATE (n:<label_field>l {property_1, property_2})'.
Required
CredentialsUsernametextboxUser identity for connecting to the Neo4j.Required

PasswordpasswordPassword to use to connect to the Neo4j.Required

...