@@ -73,6 +73,13 @@ To read data from NebulaGraph using Flink.
73
73
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
74
74
env.setParallelism(1);
75
75
76
+ VertexExecutionOptions vertexExecutionOptions = new VertexExecutionOptions.ExecutionOptionBuilder()
77
+ .setGraphSpace("flinkSource")
78
+ .setTag("person")
79
+ .setNoColumn(false)
80
+ .setFields(Arrays.asList())
81
+ .setLimit(100)
82
+ .build();
76
83
NebulaSourceFunction sourceFunction = new NebulaSourceFunction(storageConnectionProvider)
77
84
.setExecutionOptions(vertexExecutionOptions);
78
85
DataStreamSource<BaseTableRow> dataStreamSource = env.addSource(sourceFunction);
@@ -204,13 +211,15 @@ To operate Schema and data using Flink SQL.
204
211
There are the version correspondence between Nebula Flink Connector and Nebula:
205
212
206
213
| Nebula Flink Connector Version | Nebula Version |
207
- | :-----------------------:| :--------------:|
208
- | 2.0.0 | 2.0.0, 2.0.1 |
209
- | 2.5.0 | 2.5.0, 2.5.1 |
210
- | 2.6.0 | 2.6.0, 2.6.1 |
211
- | 2.6.1 | 2.6.0, 2.6.1 |
212
- | 3.0.0 | 3.0.x, 3.1.x |
213
- | 3.0-SNAPSHOT | nightly |
214
+ | :------------------------------:| :--------------:|
215
+ | 2.0.0 | 2.0.0, 2.0.1 |
216
+ | 2.5.0 | 2.5.0, 2.5.1 |
217
+ | 2.6.0 | 2.6.0, 2.6.1 |
218
+ | 2.6.1 | 2.6.0, 2.6.1 |
219
+ | 3.0.0 | 3.x.x |
220
+ | 3.3.0 | 3.x.x |
221
+ | 3.5.0 | 3.x.x |
222
+ | 3.0-SNAPSHOT | nightly |
214
223
215
224
## Note
216
225
Flink version requirements: 1.11.x
0 commit comments