Skip to content

Commit 351f6d9

Browse files
toxicteddy00077toxicteddy00077
authored
Merge branch 'main' into fluss-admin-inst-and-cache
2 parents f3c415e + 43879ce commit 351f6d9

97 files changed

Lines changed: 6513 additions & 1221 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎.github/actions/verify-tag-version/action.yml‎

Lines changed: 11 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -26,12 +26,16 @@ runs:
2626
using: 'composite'
2727
steps:
2828
- run: |
29-
TAG_VERSION="${GITHUB_REF#refs/tags/v}"
30-
CRATE_VERSION=$(sed -n '/^\[workspace.package\]/,/^\[/p' Cargo.toml | grep '^\s*version\s*=' | head -1 | sed -E 's/.*"([^"]+)".*/\1/')
31-
base() { echo "$1" | sed -E 's/-rc(\.[0-9]+|[0-9]+)$//'; }
32-
if [ "$(base "$TAG_VERSION")" != "$(base "$CRATE_VERSION")" ]; then
33-
echo "::error::Tag version ($TAG_VERSION) does not match Cargo.toml version ($CRATE_VERSION). Run scripts/bump-version.sh before tagging, or tag the version that is in Cargo.toml."
34-
exit 1
35-
fi
3629
echo "Tag and crate version match: $TAG_VERSION"
3730
shell: bash
31+
# uncomment for 0.1.0-incubating-rc0, add it back when incubating is not needed anymore
32+
# - run: |
33+
# TAG_VERSION="${GITHUB_REF#refs/tags/v}"
34+
# CRATE_VERSION=$(sed -n '/^\[workspace.package\]/,/^\[/p' Cargo.toml | grep '^\s*version\s*=' | head -1 | sed -E 's/.*"([^"]+)".*/\1/')
35+
# base() { echo "$1" | sed -E 's/-rc(\.[0-9]+|[0-9]+)$//'; }
36+
# if [ "$(base "$TAG_VERSION")" != "$(base "$CRATE_VERSION")" ]; then
37+
# echo "::error::Tag version ($TAG_VERSION) does not match Cargo.toml version ($CRATE_VERSION). Run scripts/bump-version.sh before tagging, or tag the version that is in Cargo.toml."
38+
# exit 1
39+
# fi
40+
# echo "Tag and crate version match: $TAG_VERSION"
41+
# shell: bash

‎.github/workflows/build_and_test_rust.yml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ jobs:
7979
- name: Integration Test (Linux only)
8080
if: runner.os == 'Linux'
8181
run: |
82-
RUST_TEST_THREADS=1 cargo test --features integration_tests --all-targets --workspace --exclude fluss_python --exclude fluss-cpp -- --nocapture
82+
cargo test --features integration_tests --all-targets --workspace --exclude fluss_python --exclude fluss-cpp
8383
env:
8484
RUST_LOG: DEBUG
8585
RUST_BACKTRACE: full

‎.licenserc.yaml‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,4 +28,5 @@ header:
2828
- 'bindings/python/fluss/py.typed'
2929
- 'website/**'
3030
- '**/*.md'
31+
- '**/DEPENDENCIES.*.tsv'
3132
comment: on-failure

‎Cargo.toml‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,15 +24,15 @@ homepage = "https://fluss.apache.org/"
2424
license = "Apache-2.0"
2525
repository = "https://github.com/apache/fluss-rust"
2626
rust-version = "1.85"
27-
version = "0.1.0"
27+
version = "0.2.0"
2828
keywords = ["fluss", "streaming-storage", "datalake"]
2929

3030
[workspace]
3131
resolver = "2"
3232
members = ["crates/fluss", "crates/examples", "bindings/python", "bindings/cpp"]
3333

3434
[workspace.dependencies]
35-
fluss = { package = "fluss-rs", version = "0.1.0", path = "crates/fluss", features = ["storage-all"] }
35+
fluss = { package = "fluss-rs", version = "0.2.0", path = "crates/fluss", features = ["storage-all"] }
3636
tokio = { version = "1.44.2", features = ["full"] }
3737
clap = { version = "4.5.37", features = ["derive"] }
3838
arrow = { version = "57.0.0", features = ["ipc_compression"] }

‎DEPENDENCIES.rust.tsv‎

Lines changed: 330 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,330 @@
1+
crate Apache-2.0 Apache-2.0 WITH LLVM-exception BSD-2-Clause BSD-3-Clause BSL-1.0 CC0-1.0 CDLA-Permissive-2.0 ISC LGPL-2.1-or-later MIT Unicode-3.0 Unlicense Zlib
2+
ahash@0.8.12 X X
3+
aho-corasick@1.1.3 X X
4+
android-tzdata@0.1.1 X X
5+
android_system_properties@0.1.5 X X
6+
anstream@0.6.20 X X
7+
anstyle@1.0.11 X X
8+
anstyle-parse@0.2.7 X X
9+
anstyle-query@1.1.4 X X
10+
anstyle-wincon@3.0.10 X X
11+
anyhow@1.0.100 X X
12+
arrow@57.1.0 X
13+
arrow-arith@57.1.0 X
14+
arrow-array@57.1.0 X
15+
arrow-buffer@57.1.0 X
16+
arrow-cast@57.1.0 X
17+
arrow-csv@57.1.0 X
18+
arrow-data@57.1.0 X
19+
arrow-ipc@57.1.0 X
20+
arrow-json@57.1.0 X
21+
arrow-ord@57.1.0 X
22+
arrow-pyarrow@57.1.0 X
23+
arrow-row@57.1.0 X
24+
arrow-schema@57.1.0 X
25+
arrow-select@57.1.0 X
26+
arrow-string@57.1.0 X
27+
async-trait@0.1.89 X X
28+
atoi@2.0.0 X
29+
atomic-waker@1.1.2 X X
30+
autocfg@1.5.0 X X
31+
backon@1.6.0 X
32+
base64@0.22.1 X X
33+
bigdecimal@0.4.10 X X
34+
bitflags@2.9.3 X X
35+
bitvec@1.0.1 X
36+
block-buffer@0.10.4 X X
37+
bumpalo@3.19.0 X X
38+
byteorder@1.5.0 X X
39+
bytes@1.11.1 X
40+
cc@1.2.34 X X
41+
cfg-if@1.0.3 X X
42+
chrono@0.4.41 X X
43+
clap@4.5.45 X X
44+
clap_builder@4.5.44 X X
45+
clap_derive@4.5.45 X X
46+
clap_lex@0.7.5 X X
47+
codespan-reporting@0.13.1 X
48+
colorchoice@1.0.4 X X
49+
const-oid@0.9.6 X X
50+
const-random@0.1.18 X X
51+
const-random-macro@0.1.16 X X
52+
core-foundation-sys@0.8.7 X X
53+
cpufeatures@0.2.17 X X
54+
crc32c@0.6.8 X X
55+
crossbeam-utils@0.8.21 X X
56+
crunchy@0.2.4 X
57+
crypto-common@0.1.7 X X
58+
csv@1.3.1 X X
59+
csv-core@0.1.12 X X
60+
cxx@1.0.190 X X
61+
cxx-build@1.0.190 X X
62+
cxxbridge-flags@1.0.190 X X
63+
cxxbridge-macro@1.0.190 X X
64+
dashmap@6.1.0 X
65+
delegate@0.13.5 X X
66+
digest@0.10.7 X X
67+
displaydoc@0.2.5 X X
68+
either@1.15.0 X X
69+
equivalent@1.0.2 X X
70+
errno@0.3.13 X X
71+
fastrand@2.3.0 X X
72+
fixedbitset@0.5.7 X X
73+
flatbuffers@25.2.10 X
74+
fluss-cpp@0.1.0 X
75+
fluss-examples@0.1.0 X
76+
fluss-rs@0.1.0 X
77+
fluss_python@0.1.0 X
78+
fnv@1.0.7 X X
79+
foldhash@0.2.0 X
80+
form_urlencoded@1.2.2 X X
81+
funty@2.0.0 X
82+
futures@0.3.31 X X
83+
futures-channel@0.3.31 X X
84+
futures-core@0.3.31 X X
85+
futures-executor@0.3.31 X X
86+
futures-io@0.3.31 X X
87+
futures-macro@0.3.31 X X
88+
futures-sink@0.3.31 X X
89+
futures-task@0.3.31 X X
90+
futures-util@0.3.31 X X
91+
generic-array@0.14.7 X
92+
getrandom@0.2.16 X X
93+
getrandom@0.3.3 X X
94+
gloo-timers@0.3.0 X X
95+
h2@0.4.12 X
96+
half@2.6.0 X X
97+
hashbrown@0.14.5 X X
98+
hashbrown@0.15.5 X X
99+
hashbrown@0.16.1 X X
100+
heck@0.5.0 X X
101+
hex@0.4.3 X X
102+
hmac@0.12.1 X X
103+
home@0.5.11 X X
104+
http@1.3.1 X X
105+
http-body@1.0.1 X
106+
http-body-util@0.1.3 X
107+
httparse@1.10.1 X X
108+
httpdate@1.0.3 X X
109+
hyper@1.7.0 X
110+
hyper-rustls@0.27.7 X X X
111+
hyper-util@0.1.17 X
112+
iana-time-zone@0.1.63 X X
113+
iana-time-zone-haiku@0.1.2 X X
114+
icu_collections@2.0.0 X
115+
icu_locale_core@2.0.0 X
116+
icu_normalizer@2.0.0 X
117+
icu_normalizer_data@2.0.0 X
118+
icu_properties@2.0.1 X
119+
icu_properties_data@2.0.1 X
120+
icu_provider@2.0.0 X
121+
idna@1.1.0 X X
122+
idna_adapter@1.2.1 X X
123+
indexmap@2.11.0 X X
124+
indoc@2.0.6 X X
125+
ipnet@2.11.0 X X
126+
iri-string@0.7.9 X X
127+
is_terminal_polyfill@1.70.1 X X
128+
itertools@0.14.0 X X
129+
itoa@1.0.15 X X
130+
jiff@0.2.16 X X
131+
jiff-tzdb@0.1.5 X X
132+
jiff-tzdb-platform@0.1.3 X X
133+
jobserver@0.1.34 X X
134+
js-sys@0.3.77 X X
135+
lexical-core@1.0.5 X X
136+
lexical-parse-float@1.0.5 X X
137+
lexical-parse-integer@1.0.5 X X
138+
lexical-util@1.0.6 X X
139+
lexical-write-float@1.0.5 X X
140+
lexical-write-integer@1.0.5 X X
141+
libc@0.2.175 X X
142+
libm@0.2.15 X
143+
link-cplusplus@1.0.12 X X
144+
linked-hash-map@0.5.6 X X
145+
linux-raw-sys@0.9.4 X X X
146+
litemap@0.8.0 X
147+
lock_api@0.4.13 X X
148+
log@0.4.27 X X
149+
lz4_flex@0.12.0 X
150+
md-5@0.10.6 X X
151+
memchr@2.7.5 X X
152+
memoffset@0.9.1 X
153+
mio@1.0.4 X
154+
multimap@0.10.1 X X
155+
num-bigint@0.4.6 X X
156+
num-complex@0.4.6 X X
157+
num-integer@0.1.46 X X
158+
num-traits@0.2.19 X X
159+
once_cell@1.21.3 X X
160+
once_cell_polyfill@1.70.1 X X
161+
opendal@0.55.0 X
162+
ordered-float@5.1.0 X
163+
parking_lot@0.12.4 X X
164+
parking_lot_core@0.9.11 X X
165+
parse-display@0.10.0 X X
166+
parse-display-derive@0.10.0 X X
167+
percent-encoding@2.3.2 X X
168+
petgraph@0.7.1 X X
169+
pin-project-lite@0.2.16 X X
170+
pin-utils@0.1.0 X X
171+
pkg-config@0.3.32 X X
172+
portable-atomic@1.11.1 X X
173+
portable-atomic-util@0.2.4 X X
174+
potential_utf@0.1.3 X
175+
ppv-lite86@0.2.21 X X
176+
prettyplease@0.2.37 X X
177+
proc-macro2@1.0.101 X X
178+
prost@0.14.1 X
179+
prost-build@0.14.1 X
180+
prost-derive@0.14.1 X
181+
prost-types@0.14.1 X
182+
pyo3@0.26.0 X X
183+
pyo3-async-runtimes@0.26.0 X
184+
pyo3-build-config@0.26.0 X X
185+
pyo3-ffi@0.26.0 X X
186+
pyo3-macros@0.26.0 X X
187+
pyo3-macros-backend@0.26.0 X X
188+
quick-xml@0.37.5 X
189+
quick-xml@0.38.4 X
190+
quote@1.0.40 X X
191+
r-efi@5.3.0 X X X
192+
radium@0.7.0 X
193+
rand@0.8.5 X X
194+
rand@0.9.2 X X
195+
rand_chacha@0.3.1 X X
196+
rand_chacha@0.9.0 X X
197+
rand_core@0.6.4 X X
198+
rand_core@0.9.3 X X
199+
redox_syscall@0.5.17 X
200+
regex@1.11.2 X X
201+
regex-automata@0.4.10 X X
202+
regex-syntax@0.8.6 X X
203+
reqsign@0.16.5 X
204+
reqwest@0.12.25 X X
205+
ring@0.17.14 X X
206+
rustc_version@0.4.1 X X
207+
rustix@1.0.8 X X X
208+
rustls@0.23.32 X X X
209+
rustls-pki-types@1.12.0 X X
210+
rustls-webpki@0.103.7 X
211+
rustversion@1.0.22 X X
212+
ryu@1.0.20 X X
213+
scopeguard@1.2.0 X X
214+
scratch@1.0.9 X X
215+
semver@1.0.26 X X
216+
serde@1.0.228 X X
217+
serde_core@1.0.228 X X
218+
serde_derive@1.0.228 X X
219+
serde_json@1.0.143 X X
220+
serde_urlencoded@0.7.1 X X
221+
sha1@0.10.6 X X
222+
sha2@0.10.9 X X
223+
shlex@1.3.0 X X
224+
signal-hook-registry@1.4.6 X X
225+
simdutf8@0.1.5 X X
226+
slab@0.4.11 X
227+
smallvec@1.15.1 X X
228+
snafu@0.8.9 X X
229+
snafu-derive@0.8.9 X X
230+
socket2@0.6.0 X X
231+
stable_deref_trait@1.2.1 X X
232+
static_assertions@1.1.0 X X
233+
strsim@0.11.1 X
234+
structmeta@0.3.0 X X
235+
structmeta-derive@0.3.0 X X
236+
strum@0.26.3 X
237+
strum_macros@0.26.4 X
238+
subtle@2.6.1 X
239+
syn@2.0.106 X X
240+
sync_wrapper@1.0.2 X
241+
synstructure@0.13.2 X
242+
tap@1.0.1 X
243+
target-lexicon@0.13.3 X
244+
tempfile@3.23.0 X X
245+
termcolor@1.4.1 X X
246+
thiserror@1.0.69 X X
247+
thiserror-impl@1.0.69 X X
248+
tiny-keccak@2.0.2 X
249+
tinystr@0.8.1 X
250+
tokio@1.48.0 X
251+
tokio-macros@2.6.0 X
252+
tokio-rustls@0.26.4 X X
253+
tokio-util@0.7.16 X
254+
tower@0.5.2 X
255+
tower-http@0.6.8 X
256+
tower-layer@0.3.3 X
257+
tower-service@0.3.3 X
258+
tracing@0.1.41 X
259+
tracing-attributes@0.1.30 X
260+
tracing-core@0.1.34 X
261+
try-lock@0.2.5 X
262+
twox-hash@2.1.2 X
263+
typenum@1.19.0 X X
264+
unicode-ident@1.0.18 X X X
265+
unicode-width@0.2.2 X X
266+
unindent@0.2.4 X X
267+
untrusted@0.9.0 X
268+
url@2.5.7 X X
269+
utf8_iter@1.0.4 X X
270+
utf8parse@0.2.2 X X
271+
uuid@1.18.0 X X
272+
value-bag@1.12.0 X X
273+
version_check@0.9.5 X X
274+
want@0.3.1 X
275+
wasi@0.11.1+wasi-snapshot-preview1 X X X
276+
wasi@0.14.2+wasi-0.2.4 X X X
277+
wasm-bindgen@0.2.100 X X
278+
wasm-bindgen-backend@0.2.100 X X
279+
wasm-bindgen-futures@0.4.50 X X
280+
wasm-bindgen-macro@0.2.100 X X
281+
wasm-bindgen-macro-support@0.2.100 X X
282+
wasm-bindgen-shared@0.2.100 X X
283+
wasm-streams@0.4.2 X X
284+
web-sys@0.3.77 X X
285+
webpki-roots@1.0.3 X
286+
winapi-util@0.1.11 X X
287+
windows-core@0.61.2 X X
288+
windows-implement@0.60.0 X X
289+
windows-interface@0.59.1 X X
290+
windows-link@0.1.3 X X
291+
windows-link@0.2.1 X X
292+
windows-result@0.3.4 X X
293+
windows-strings@0.4.2 X X
294+
windows-sys@0.52.0 X X
295+
windows-sys@0.59.0 X X
296+
windows-sys@0.60.2 X X
297+
windows-sys@0.61.2 X X
298+
windows-targets@0.52.6 X X
299+
windows-targets@0.53.3 X X
300+
windows_aarch64_gnullvm@0.52.6 X X
301+
windows_aarch64_gnullvm@0.53.0 X X
302+
windows_aarch64_msvc@0.52.6 X X
303+
windows_aarch64_msvc@0.53.0 X X
304+
windows_i686_gnu@0.52.6 X X
305+
windows_i686_gnu@0.53.0 X X
306+
windows_i686_gnullvm@0.52.6 X X
307+
windows_i686_gnullvm@0.53.0 X X
308+
windows_i686_msvc@0.52.6 X X
309+
windows_i686_msvc@0.53.0 X X
310+
windows_x86_64_gnu@0.52.6 X X
311+
windows_x86_64_gnu@0.53.0 X X
312+
windows_x86_64_gnullvm@0.52.6 X X
313+
windows_x86_64_gnullvm@0.53.0 X X
314+
windows_x86_64_msvc@0.52.6 X X
315+
windows_x86_64_msvc@0.53.0 X X
316+
wit-bindgen-rt@0.39.0 X X X
317+
writeable@0.6.1 X
318+
wyz@0.5.1 X
319+
yoke@0.8.0 X
320+
yoke-derive@0.8.0 X
321+
zerocopy@0.8.26 X X X
322+
zerofrom@0.1.6 X
323+
zerofrom-derive@0.1.6 X
324+
zeroize@1.8.2 X X
325+
zerotrie@0.2.2 X
326+
zerovec@0.11.4 X
327+
zerovec-derive@0.11.1 X
328+
zstd@0.13.3 X
329+
zstd-safe@7.2.4 X X
330+
zstd-sys@2.0.16+zstd.1.5.7 X X

0 commit comments

Comments
 (0)