This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch web-deps
in repository https://gitbox.apache.org/repos/asf/iggy.git
from d39019a94 chore(web): update dependencies
add e1b1b22a7 fix(go,csharp): remove duplicate consumer groups in
DeserializeClient/MapClient (#3164)
add 499a26d88 feat(connectors): implement Delta Lake Sink Connector (#2889)
add 4b8b14143 Merge branch 'master' into web-deps
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1344 ++++++++++++++++++--
Cargo.toml | 3 +
DEPENDENCIES.md | 73 ++
.../example_config/connectors/delta_sink.toml} | 14 +-
core/connectors/sdk/src/convert.rs | 114 ++
.../sinks/{stdout_sink => delta_sink}/Cargo.toml | 11 +-
core/connectors/sinks/delta_sink/README.md | 92 ++
core/connectors/sinks/delta_sink/config.toml | 62 +
core/connectors/sinks/delta_sink/src/coercions.rs | 680 ++++++++++
core/connectors/sinks/delta_sink/src/lib.rs | 97 ++
core/connectors/sinks/delta_sink/src/sink.rs | 181 +++
core/connectors/sinks/delta_sink/src/storage.rs | 301 +++++
core/integration/Cargo.toml | 2 +
.../{stdout/stdout_sink.rs => delta/delta_sink.rs} | 120 +-
.../tests/connectors/{api => delta}/mod.rs | 2 +-
.../tests/connectors/{http => delta}/sink.toml | 2 +-
.../tests/connectors/fixtures/delta/fixture.rs | 391 ++++++
.../connectors/{http => fixtures/delta}/mod.rs | 4 +-
core/integration/tests/connectors/fixtures/mod.rs | 2 +
core/integration/tests/connectors/mod.rs | 1 +
examples/rust/src/sink-data-producer/main.rs | 3 +
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 32 +-
.../binary_response_deserializer.go | 28 +-
23 files changed, 3369 insertions(+), 190 deletions(-)
copy core/connectors/{sinks/stdout_sink/config.toml =>
runtime/example_config/connectors/delta_sink.toml} (79%)
copy core/connectors/sinks/{stdout_sink => delta_sink}/Cargo.toml (84%)
create mode 100644 core/connectors/sinks/delta_sink/README.md
create mode 100644 core/connectors/sinks/delta_sink/config.toml
create mode 100644 core/connectors/sinks/delta_sink/src/coercions.rs
create mode 100644 core/connectors/sinks/delta_sink/src/lib.rs
create mode 100644 core/connectors/sinks/delta_sink/src/sink.rs
create mode 100644 core/connectors/sinks/delta_sink/src/storage.rs
copy core/integration/tests/connectors/{stdout/stdout_sink.rs =>
delta/delta_sink.rs} (71%)
copy core/integration/tests/connectors/{api => delta}/mod.rs (98%)
copy core/integration/tests/connectors/{http => delta}/sink.toml (94%)
create mode 100644 core/integration/tests/connectors/fixtures/delta/fixture.rs
copy core/integration/tests/connectors/{http => fixtures/delta}/mod.rs (92%)
