Skip to content

Commit

Permalink
Bump feldera from f6fb45f to 9e7fdb4
Browse files Browse the repository at this point in the history 
Bumps [feldera](https://github.com/feldera/feldera) from `f6fb45f` to `9e7fdb4`.
- [Release notes](https://github.com/feldera/feldera/releases)
- [Commits](feldera/feldera@f6fb45f...9e7fdb4)

---
updated-dependencies:
- dependency-name: feldera
  dependency-type: direct:production
...

Signed-off-by: dependabot[bot] <[email protected]>
  • Loading branch information
@dependabot
dependabot[bot] authored Nov 21, 2024
1 parent f7a7430 commit 3cf3803
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion feldera
Submodule feldera updated 93 files
+1 −1 .github/workflows/pre-commit.yml
+1 −1 .pre-commit-config.yaml
+27 −1 Cargo.lock
+1 −1 Earthfile
+1 −0 crates/adapterlib/Cargo.toml
+31 −1 crates/adapterlib/src/errors/controller.rs
+37 −16 crates/adapterlib/src/format.rs
+32 −12 crates/adapterlib/src/transport.rs
+4 −0 crates/adapters/Cargo.toml
+9 −1 crates/adapters/src/controller/metadata.rs
+255 −126 crates/adapters/src/controller/mod.rs
+16 −8 crates/adapters/src/controller/stats.rs
+1 −1 crates/adapters/src/format/avro/input.rs
+9 −3 crates/adapters/src/format/avro/test.rs
+1 −1 crates/adapters/src/format/csv.rs
+7 −5 crates/adapters/src/format/json/input.rs
+5 −4 crates/adapters/src/format/mod.rs
+1 −1 crates/adapters/src/format/parquet/mod.rs
+1 −1 crates/adapters/src/integrated/delta_table/input.rs
+29 −15 crates/adapters/src/server/mod.rs
+3 −3 crates/adapters/src/static_compile/catalog.rs
+123 −64 crates/adapters/src/static_compile/deinput.rs
+3 −2 crates/adapters/src/test/datagen.rs
+1 −1 crates/adapters/src/test/kafka.rs
+55 −32 crates/adapters/src/test/mock_dezset.rs
+2 −2 crates/adapters/src/test/mock_input_consumer.rs
+8 −7 crates/adapters/src/test/mod.rs
+10 −5 crates/adapters/src/transport/adhoc.rs
+15 −4 crates/adapters/src/transport/file.rs
+9 −4 crates/adapters/src/transport/http/input.rs
+59 −7 crates/adapters/src/transport/kafka/ft/input.rs
+307 −17 crates/adapters/src/transport/kafka/ft/test.rs
+18 −5 crates/adapters/src/transport/nexmark.rs
+17 −6 crates/adapters/src/transport/s3/mod.rs
+14 −4 crates/adapters/src/transport/url.rs
+1 −0 crates/datagen/Cargo.toml
+22 −7 crates/datagen/src/lib.rs
+13 −2 crates/dbsp/src/circuit/circuit_builder.rs
+13 −0 crates/dbsp/src/dynamic/data.rs
+2 −4 crates/dbsp/src/hash.rs
+64 −0 crates/dbsp/src/operator/controlled_filter.rs
+8 −7 crates/dbsp/src/operator/dynamic/controlled_filter.rs
+45 −30 crates/dbsp/src/trace/spine_async/mod.rs
+10 −0 crates/dbsp/src/typed_batch.rs
+1 −0 crates/fda/src/cli.rs
+10 −6 crates/fda/src/main.rs
+65 −24 crates/feldera-types/src/config.rs
+1 −0 crates/pipeline-manager/Cargo.toml
+37 −12 crates/pipeline-manager/src/api/pipeline.rs
+7 −1 crates/pipeline-manager/src/compiler.rs
+2 −2 crates/pipeline-manager/src/db/types/program.rs
+9 −0 crates/pipeline-manager/src/error.rs
+10 −22 crates/pipeline-manager/src/runner/local_runner.rs
+16 −0 crates/sqllib/src/string.rs
+52 −0 crates/sqllib/src/timestamp.rs
+7 −6 docs/connectors/index.mdx
+17 −0 docs/sql/string.md
+10 −5 openapi.json
+5 −2 python/feldera/pipeline.py
+19 −5 python/feldera/rest/feldera_client.py
+20 −10 python/tests/aggregate_tests/aggtst_base.py
+12 −0 python/tests/aggregate_tests/main.py
+132 −0 python/tests/aggregate_tests/test_atbl_interval.py
+39 −0 python/tests/aggregate_tests/test_interval_count.py
+100 −0 python/tests/aggregate_tests/test_interval_count_col.py
+262 −0 python/tests/aggregate_tests/test_interval_max.py
+79 −0 python/tests/aggregate_tests/test_varbinary_arr_agg.py
+39 −0 python/tests/aggregate_tests/test_varbinary_count.py
+58 −0 python/tests/aggregate_tests/test_varbinary_count_col.py
+67 −0 python/tests/aggregate_tests/test_varbinary_every.py
+67 −0 python/tests/aggregate_tests/test_varbinary_max.py
+67 −0 python/tests/aggregate_tests/test_varbinary_min.py
+67 −0 python/tests/aggregate_tests/test_varbinary_some.py
+31 −0 python/tests/aggregate_tests/test_varbinary_tbl.py
+59 −0 python/tests/test_pipeline_builder.py
+1 −1 python/uv.lock
+9 −0 sql-to-dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/circuit/CircuitToString.java
+13 −5 sql-to-dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/circuit/operator/DBSPNestedOperator.java
+1 −1 sql-to-dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/DBSPCompiler.java
+18 −11 sql-to-dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/backend/rust/ToRustVisitor.java
+7 −1 sql-to-dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/frontend/ExpressionCompiler.java
+1 −1 ...p-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/visitors/outer/CircuitCloneVisitor.java
+4 −3 ...dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/visitors/outer/CircuitOptimizer.java
+1 −1 ...ler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/visitors/outer/OptimizeIncrementalVisitor.java
+32 −7 ...p-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/visitors/outer/RecursiveComponents.java
+9 −3 ...p-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/compiler/visitors/outer/RemoveViewOperators.java
+0 −4 ...-dbsp-compiler/SQL-compiler/src/main/java/org/dbsp/sqlCompiler/ir/expression/literal/DBSPStringLiteral.java
+1 −1 sql-to-dbsp-compiler/SQL-compiler/src/test/java/org/dbsp/sqlCompiler/compiler/sql/OtherTests.java
+84 −1 ...bsp-compiler/SQL-compiler/src/test/java/org/dbsp/sqlCompiler/compiler/sql/postgres/PostgresStringTests.java
+413 −0 ...to-dbsp-compiler/SQL-compiler/src/test/java/org/dbsp/sqlCompiler/compiler/sql/recursive/RecursiveTests.java
+112 −0 ...-dbsp-compiler/SQL-compiler/src/test/java/org/dbsp/sqlCompiler/compiler/sql/simple/TimeArithmeticTests.java
+13 −2 web-console/src/lib/services/manager/schemas.gen.ts
+9 −1 web-console/src/lib/services/manager/types.gen.ts

0 comments on commit 3cf3803

Please sign in to comment.