This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch multi_endpoint_failover
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 5bda045a6 address review
add 2e420398b feat(connectors): add Redshift sink connector (#3654)
new 0e6f96505 Merge branch 'master' into multi_endpoint_failover
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
Cargo.lock | 358 ++++-
Cargo.toml | 5 +
core/connectors/README.md | 1 +
core/connectors/sinks/README.md | 1 +
.../sinks/{s3_sink => redshift_sink}/Cargo.toml | 23 +-
core/connectors/sinks/redshift_sink/README.md | 216 +++
.../{postgres_sink => redshift_sink}/config.toml | 21 +-
core/connectors/sinks/redshift_sink/src/config.rs | 159 +++
core/connectors/sinks/redshift_sink/src/lib.rs | 1491 ++++++++++++++++++++
core/integration/Cargo.toml | 6 +
core/integration/tests/connectors/fixtures/mod.rs | 5 +
.../connectors/fixtures/redshift/container.rs | 276 ++++
.../fixtures/{clickhouse => redshift}/mod.rs | 5 +-
.../fixtures/redshift/redshift_mock/ddl.rs | 77 +
.../fixtures/redshift/redshift_mock/dml.rs | 209 +++
.../fixtures/redshift/redshift_mock/dql.rs | 92 ++
.../fixtures/redshift/redshift_mock/handler.rs | 256 ++++
.../fixtures/redshift/redshift_mock/load.rs | 314 +++++
.../fixtures/redshift/redshift_mock}/mod.rs | 8 +-
.../fixtures/redshift/redshift_mock/parser.rs | 556 ++++++++
.../fixtures/redshift/redshift_mock/util.rs | 152 ++
.../tests/connectors/fixtures/redshift/sink.rs | 480 +++++++
core/integration/tests/connectors/mod.rs | 1 +
.../tests/connectors/{http => redshift}/mod.rs | 2 +-
.../tests/connectors/redshift/redshift_sink.rs | 418 ++++++
.../tests/connectors/{delta => redshift}/sink.toml | 2 +-
26 files changed, 5096 insertions(+), 38 deletions(-)
copy core/connectors/sinks/{s3_sink => redshift_sink}/Cargo.toml (71%)
create mode 100644 core/connectors/sinks/redshift_sink/README.md
copy core/connectors/sinks/{postgres_sink => redshift_sink}/config.toml (70%)
create mode 100644 core/connectors/sinks/redshift_sink/src/config.rs
create mode 100644 core/connectors/sinks/redshift_sink/src/lib.rs
create mode 100644
core/integration/tests/connectors/fixtures/redshift/container.rs
copy core/integration/tests/connectors/fixtures/{clickhouse =>
redshift}/mod.rs (80%)
create mode 100644
core/integration/tests/connectors/fixtures/redshift/redshift_mock/ddl.rs
create mode 100644
core/integration/tests/connectors/fixtures/redshift/redshift_mock/dml.rs
create mode 100644
core/integration/tests/connectors/fixtures/redshift/redshift_mock/dql.rs
create mode 100644
core/integration/tests/connectors/fixtures/redshift/redshift_mock/handler.rs
create mode 100644
core/integration/tests/connectors/fixtures/redshift/redshift_mock/load.rs
copy core/{bench/dashboard/frontend/src/components/theme =>
integration/tests/connectors/fixtures/redshift/redshift_mock}/mod.rs (88%)
create mode 100644
core/integration/tests/connectors/fixtures/redshift/redshift_mock/parser.rs
create mode 100644
core/integration/tests/connectors/fixtures/redshift/redshift_mock/util.rs
create mode 100644 core/integration/tests/connectors/fixtures/redshift/sink.rs
copy core/integration/tests/connectors/{http => redshift}/mod.rs (97%)
create mode 100644 core/integration/tests/connectors/redshift/redshift_sink.rs
copy core/integration/tests/connectors/{delta => redshift}/sink.toml (94%)
