search

vesoft-inc / nebula-flink-connector

Flink Connector for Nebula Graph
48 stars 30 forks source link

parallel read stream or batch data source of nebula #51

Closed TonyAndFriday closed 2 years ago

TonyAndFriday commented 2 years ago

PTAL

CLAassistant commented 2 years ago

CLA assistant check
All committers have signed the CLA.

codecov-commenter commented 2 years ago

Codecov Report

Merging #51 (89a8d28) into master (c530e33) will decrease coverage by 0.83%. The diff coverage is 0.00%.

:exclamation: Current head 89a8d28 differs from pull request most recent head 76a66ad. Consider uploading reports for the commit 76a66ad to get more accurate results

@@             Coverage Diff              @@
##             master      #51      +/-   ##
============================================
- Coverage     39.47%   38.63%   -0.84%     
  Complexity      152      152              
============================================
  Files            48       49       +1     
  Lines          1477     1509      +32     
  Branches        137      142       +5     
============================================
  Hits            583      583              
- Misses          841      873      +32     
  Partials         53       53
Impacted Files Coverage Δ
...la/connection/NebulaStorageConnectionProvider.java 0.00% <ø> (ø)
...link/connector/nebula/source/NebulaEdgeSource.java 0.00% <0.00%> (ø)
...ink/connector/nebula/source/NebulaInputFormat.java 0.00% <0.00%> (ø)
.../connector/nebula/source/NebulaInputRowFormat.java 0.00% <0.00%> (ø)
...ector/nebula/source/NebulaInputTableRowFormat.java 0.00% <0.00%> (ø)
.../connector/nebula/source/NebulaSourceFunction.java 0.00% <0.00%> (ø)
...nk/connector/nebula/source/NebulaVertexSource.java 0.00% <0.00%> (ø)
...e.flink/connector/nebula/utils/PartitionUtils.java 0.00% <0.00%> (ø)

Continue to review full report at Codecov.

Legend - Click here to learn more Δ = absolute <relative> (impact), ø = not affected, ? = missing data Powered by Codecov. Last update c530e33...76a66ad. Read the comment docs.

TonyAndFriday commented 2 years ago

I fixed these problems above, Please take a look. thanks！

TonyAndFriday commented 2 years ago

@Nicole00 @darionyaphet

Nicole00 commented 2 years ago

Thanks for your contributions~~ Could you please describe that how you test this pr?

TonyAndFriday commented 2 years ago

Thanks for your contributions~~ Could you please describe that how you test this pr?

i have run the FlinkConnectorSourceExample class in local and yarn-cluster mode with my nebula cluster for the test

TonyAndFriday commented 2 years ago

PTAL