Neo4j

Neo4j source connector

Description​

Read data from Neo4j.

Key features​

• batch

• stream

• exactly-once

• column projection

• parallelism

• support user-defined split

Options​

name	type	required	default value
uri	String	Yes	-
username	String	No	-
password	String	No	-
bearer_token	String	No	-
kerberos_ticket	String	No	-
database	String	Yes	-
query	String	Yes	-
schema	Object	Yes	-
max_transaction_retry_time	Long	No	30
max_connection_timeout	Long	No	30

uri [string]​

The URI of the Neo4j database. Refer to a case: neo4j://localhost:7687

username [string]​

username of the Neo4j

password [string]​

password of the Neo4j. required if username is provided

bearer_token [string]​

base64 encoded bearer token of the Neo4j. for Auth.

kerberos_ticket [string]​

base64 encoded kerberos ticket of the Neo4j. for Auth.

database [string]​

database name.

query [string]​

Query statement.

schema.fields [string]​

returned fields of query

see column projection

max_transaction_retry_time [long]​

maximum transaction retry time(seconds). transaction fail if exceeded

max_connection_timeout [long]​

The maximum amount of time to wait for a TCP connection to be established (seconds)

Example​

source {
    Neo4j {
        uri = "neo4j://localhost:7687"
        username = "neo4j"
        password = "1234"
        database = "neo4j"
    
        max_transaction_retry_time = 1
        max_connection_timeout = 1
    
        query = "MATCH (a:Person) RETURN a.name, a.age"
    
        schema {
            fields {
                a.age=INT
                a.name=STRING
            }
        }
    }
}