Code

[Flink] add arrow datastream source#496

Code

Merged

xuchen-plus merged 14 commits intolakesoul-io:mainlakesoul-io/LakeSoul:mainfrom Ceng23333:dev/flink_arrow_sourceCeng23333/LakeSoul:dev/flink_arrow_sourceCopy head branch name to clipboardJun 19, 2024

+893-238

Commits

Commits on Jun 18, 2024

• add lakesoul arrow source

  Show description for 31067f7
  

  zenghua

  committed
  31067f7

• fix flink writer path

  Show description for cbbc0da
  

  zenghua

  committed
  cbbc0da

• support inferring schema

  Show description for 5e70a2d
  

  zenghua

  committed
  5e70a2d

• tmp commit

  Show description for 54919b0
  

  zenghua

  committed
  54919b0

• fix regression test

  Show description for 58308a7
  

  zenghua

  committed
  58308a7

• fix reading tail recordbatch

  Show description for 1206902
  

  zenghua

  committed
  1206902

• fix stup dao sql

  Show description for 23e5c90
  

  zenghua

  committed
  23e5c90

• fix dynamic schema

  Show description for 9313d91
  

  zenghua

  committed
  9313d91

• optimize imports

  Show description for dfd1ebb
  

  zenghua

  committed
  dfd1ebb

• split DataFileInfo with file_cols

  Show description for ec1e953
  

  zenghua

  committed
  ec1e953

• optimize import

  Show description for 067ee04
  

  zenghua

  committed
  067ee04

• rebase on main

  Show description for ffb2ccd
  

  zenghua

  committed
  ffb2ccd

• fix regresion test

  Show description for 1fcc766
  

  zenghua

  committed
  1fcc766

• fix regresion test

  Show description for d3eb16e
  

  zenghua

  committed
  d3eb16e