{ # Spark相关配置 spark: { app: { name: Nebula Exchange 2.5.1 } driver: { cores: 1 maxResultSize: 1G } executor: { memory:1G } cores:{ max: 16 } } # Nebula Graph相关配置 nebula: { address:{ graph:["192.168.3.41:9669"] meta:["192.168.3.41:9559","192.168.3.41:9560"] } user: root pswd: nebula space: HO connection { timeout: 3000 retry: 3 } execution { retry: 3 } error: { max: 32 output: /tmp/errors } rate: { limit: 1024 timeout: 1000 } } # 处理点 tags: [ # 设置Tag player相关信息。 { name: HO_NEO4J_DEVICE_CLASS type: { source: neo4j sink: client } server: "bolt://172.17.20.233:7687" user: neo4j password: 123456 database: hsdb exec: "match (n:HO_NEO4J_DEVICE_CLASS) return id(n) as id,n.hoid as hoid" fields: [hoid] nebula.fields: [hoid] vertex: { field:id } partition: 10 batch: 1000 check_point_path: /tmp/test } ] # 处理边数据 edges: [ # 设置Edge type follow相关信息 { name: REFERENCES_CLASS type: { source: neo4j sink: client } server: "bolt://172.17.20.233:7687" user: neo4j password: 123456 database: hsdb exec: "match (a:HO_NEO4J_DEVICE_CLASS)-[r:REFERENCES_CLASS]->(b:HO_NEO4J_DEVICE_CLASS) return id(a) as src, id(b) as dst, r.hoid as hoid order by id(r)" fields: [hoid] nebula.fields: [hoid] source: { field: src } target: { field: dst } partition: 10 batch: 1000 check_point_path: /tmp/test } ] }