This is an automated email from the ASF dual-hosted git repository.
gkoszyk pushed a change to branch experiment
in repository https://gitbox.apache.org/repos/asf/iggy.git
from c20b513b7 optionable components
add 0316511b7 fix(web): remove logout side-effect from page load (#2597)
add efd8809f8 feat(connector): add iggy-pinot external connector (#2499)
add ba30118c7 feat(cluster): Abstract out `Pipeline` into a trait similar
to `Sequencer` trait (#2567)
add 397514cf5 Merge branch 'master' into experiment
No new revisions were added by this update.
Summary of changes:
core/consensus/src/impls.rs | 82 +++++--
core/consensus/src/lib.rs | 22 ++
.../build.gradle.kts | 34 ++-
.../iggy-connector-pinot/deployment/schema.json | 31 +++
.../iggy-connector-pinot/deployment/table.json | 42 ++++
.../iggy-connector-pinot/docker-compose.yml | 135 +++++++++++
.../examples/sample-messages.json | 47 ++++
.../iggy-connector-pinot/examples/schema.json | 59 +++++
.../examples/table-config.json | 43 ++++
.../iggy-connector-pinot/integration-test.sh | 234 ++++++++++++++++++
.../connector/pinot/config/IggyStreamConfig.java | 206 ++++++++++++++++
.../pinot/consumer/IggyConsumerFactory.java | 116 +++++++++
.../connector/pinot/consumer/IggyMessageBatch.java | 130 ++++++++++
.../pinot/consumer/IggyPartitionGroupConsumer.java | 265 +++++++++++++++++++++
.../pinot/consumer/IggyPartitionLevelConsumer.java | 49 ++++
.../consumer/IggyStreamPartitionMsgOffset.java | 80 +++++++
.../pinot/decoder/IggyJsonMessageDecoder.java | 97 ++++++++
.../pinot/metadata/IggyStreamMetadataProvider.java | 243 +++++++++++++++++++
....apache.pinot.spi.stream.StreamConsumerFactory} | 4 +-
.../src/main/resources/pinot-plugin.properties | 27 ++-
.../pinot/config/IggyStreamConfigTest.java | 193 +++++++++++++++
.../pinot/consumer/IggyMessageBatchTest.java | 123 ++++++++++
.../consumer/IggyStreamPartitionMsgOffsetTest.java | 90 +++++++
foreign/java/gradle/libs.versions.toml | 8 +
foreign/java/settings.gradle.kts | 3 +
web/package-lock.json | 18 +-
web/src/routes/auth/logout/+page.ts | 34 ---
27 files changed, 2327 insertions(+), 88 deletions(-)
copy
foreign/java/external-processors/{iggy-connector-flink/iggy-connector-library
=> iggy-connector-pinot}/build.gradle.kts (58%)
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/deployment/schema.json
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/deployment/table.json
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/docker-compose.yml
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/examples/sample-messages.json
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/examples/schema.json
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/examples/table-config.json
create mode 100755
foreign/java/external-processors/iggy-connector-pinot/integration-test.sh
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/main/java/org/apache/iggy/connector/pinot/config/IggyStreamConfig.java
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/main/java/org/apache/iggy/connector/pinot/consumer/IggyConsumerFactory.java
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/main/java/org/apache/iggy/connector/pinot/consumer/IggyMessageBatch.java
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/main/java/org/apache/iggy/connector/pinot/consumer/IggyPartitionGroupConsumer.java
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/main/java/org/apache/iggy/connector/pinot/consumer/IggyPartitionLevelConsumer.java
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/main/java/org/apache/iggy/connector/pinot/consumer/IggyStreamPartitionMsgOffset.java
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/main/java/org/apache/iggy/connector/pinot/decoder/IggyJsonMessageDecoder.java
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/main/java/org/apache/iggy/connector/pinot/metadata/IggyStreamMetadataProvider.java
copy foreign/{python/tests/__init__.py =>
java/external-processors/iggy-connector-pinot/src/main/resources/META-INF/services/org.apache.pinot.spi.stream.StreamConsumerFactory}
(92%)
copy helm/charts/iggy/Chart.yaml =>
foreign/java/external-processors/iggy-connector-pinot/src/main/resources/pinot-plugin.properties
(65%)
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/test/java/org/apache/iggy/connector/pinot/config/IggyStreamConfigTest.java
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/test/java/org/apache/iggy/connector/pinot/consumer/IggyMessageBatchTest.java
create mode 100644
foreign/java/external-processors/iggy-connector-pinot/src/test/java/org/apache/iggy/connector/pinot/consumer/IggyStreamPartitionMsgOffsetTest.java
delete mode 100644 web/src/routes/auth/logout/+page.ts
