From b1e0e0c6dbbd3f4040623d1cacb8b6de8b04d767 Mon Sep 17 00:00:00 2001 From: Anqi Date: Wed, 10 Apr 2024 10:56:16 +0800 Subject: [PATCH] update version match --- README.md | 23 ++++++++++++++++------- 1 file changed, 16 insertions(+), 7 deletions(-) diff --git a/README.md b/README.md index bec6446..49afd88 100644 --- a/README.md +++ b/README.md @@ -73,6 +73,13 @@ To read data from NebulaGraph using Flink. StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.setParallelism(1); + VertexExecutionOptions vertexExecutionOptions = new VertexExecutionOptions.ExecutionOptionBuilder() + .setGraphSpace("flinkSource") + .setTag("person") + .setNoColumn(false) + .setFields(Arrays.asList()) + .setLimit(100) + .build(); NebulaSourceFunction sourceFunction = new NebulaSourceFunction(storageConnectionProvider) .setExecutionOptions(vertexExecutionOptions); DataStreamSource dataStreamSource = env.addSource(sourceFunction); @@ -204,13 +211,15 @@ To operate Schema and data using Flink SQL. There are the version correspondence between Nebula Flink Connector and Nebula: | Nebula Flink Connector Version | Nebula Version | -|:-----------------------:|:--------------:| -| 2.0.0 | 2.0.0, 2.0.1 | -| 2.5.0 | 2.5.0, 2.5.1 | -| 2.6.0 | 2.6.0, 2.6.1 | -| 2.6.1 | 2.6.0, 2.6.1 | -| 3.0.0 | 3.0.x, 3.1.x | -| 3.0-SNAPSHOT | nightly | +|:------------------------------:|:--------------:| +| 2.0.0 | 2.0.0, 2.0.1 | +| 2.5.0 | 2.5.0, 2.5.1 | +| 2.6.0 | 2.6.0, 2.6.1 | +| 2.6.1 | 2.6.0, 2.6.1 | +| 3.0.0 | 3.x.x | +| 3.3.0 | 3.x.x | +| 3.5.0 | 3.x.x | +| 3.0-SNAPSHOT | nightly | ## Note Flink version requirements: 1.11.x