This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from a0d27de943f Update queuing logic to avoid lock notify contention
(#37528)
add b7577e74a6a Bump golang.org/x/oauth2 from 0.34.0 to 0.35.0 in /sdks
(#37548)
add f52cf933446 feat: Introduce agent skills for various Apache Beam
developments (#37467)
add 4b478a70738 Exercise Flink PVR tests on Flink 2.0 (#37538)
add f96db3733c2 [SQL] Alter Catalog and Table statements (#36571)
add dd0f41d3fe7 Fix _OrderedUnionCoder is_deterministic check. (#37550)
add 25d3a2e46bf Add States for Pause (#37546)
add 257fa5a46d3 Fix Components visibility (#37551)
add 6dcb908e9fe Add back flex API option with improved pydoc (#37491)
No new revisions were added by this update.
Summary of changes:
.agent/skills/README.md | 62 +++++
.agent/skills/beam-concepts/SKILL.md | 246 +++++++++++++++++++
.agent/skills/ci-cd/SKILL.md | 188 +++++++++++++++
.agent/skills/contributing/SKILL.md | 149 ++++++++++++
.agent/skills/gradle-build/SKILL.md | 224 ++++++++++++++++++
.agent/skills/io-connectors/SKILL.md | 197 ++++++++++++++++
.agent/skills/java-development/SKILL.md | 153 ++++++++++++
.agent/skills/license-compliance/SKILL.md | 199 ++++++++++++++++
.agent/skills/python-development/SKILL.md | 183 +++++++++++++++
.agent/skills/runners/SKILL.md | 244 +++++++++++++++++++
.github/trigger_files/beam_PostCommit_SQL.json | 2 +-
.github/trigger_files/beam_PreCommit_SQL.json | 2 +-
.../beam_PostCommit_Java_PVR_Flink_Batch.yml | 21 +-
.../beam_PostCommit_Java_PVR_Flink_Streaming.yml | 8 +-
CHANGES.md | 4 +-
build.gradle.kts | 5 +-
.../FlinkStreamingPortablePipelineTranslator.java | 5 +-
.../beam/runners/dataflow/util/MonitoringUtil.java | 2 +
.../runners/dataflow/util/MonitoringUtilTest.java | 2 +
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
sdks/java/core/build.gradle | 1 -
sdks/java/extensions/avro/build.gradle | 2 +
.../sdk/extensions/avro/coders/AvroCoderTest.java | 1 +
sdks/java/extensions/euphoria/build.gradle | 2 +-
sdks/java/extensions/kryo/build.gradle | 2 +-
sdks/java/extensions/sql/iceberg/build.gradle | 2 +
.../provider/iceberg/IcebergAlterTableOps.java | 50 ++++
.../sql/meta/provider/iceberg/IcebergCatalog.java | 50 ++--
.../meta/provider/iceberg/IcebergMetastore.java | 16 +-
.../iceberg/BeamSqlCliIcebergAlterTest.java | 231 ++++++++++++++++++
.../extensions/sql/src/main/codegen/config.fmpp | 7 +
.../sql/src/main/codegen/includes/parserImpls.ftl | 120 +++++++++-
.../sdk/extensions/sql/impl/CatalogSchema.java | 4 +
...{SqlCreateCatalog.java => SqlAlterCatalog.java} | 169 +++++++-------
.../extensions/sql/impl/parser/SqlAlterTable.java | 259 +++++++++++++++++++++
.../sql/impl/parser/SqlCreateExternalTable.java | 2 +-
.../extensions/sql/impl/parser/SqlDdlNodes.java | 41 ++++
.../sql/impl/parser/SqlDropDatabase.java | 6 +-
.../extensions/sql/impl/parser/SqlDropTable.java | 6 +-
.../extensions/sql/impl/parser/SqlUseDatabase.java | 2 +-
.../sdk/extensions/sql/meta/catalog/Catalog.java | 3 +
.../sql/meta/catalog/InMemoryCatalog.java | 8 +-
.../sql/meta/provider/AlterTableOps.java | 45 ++++
.../sql/meta/provider/TableProvider.java | 5 +
.../sql/meta/provider/test/AlterTestTableOps.java | 101 ++++++++
.../sql/meta/provider/test/TestTableProvider.java | 21 ++
.../sql/meta/store/InMemoryMetaStore.java | 11 +
.../sdk/extensions/sql/BeamSqlCliCatalogTest.java | 93 ++++++++
.../beam/sdk/extensions/sql/BeamSqlCliTest.java | 249 ++++++++++++++++++++
.../components/deadletterqueue}/package-info.java | 4 +-
.../deadletterqueue/sinks}/package-info.java | 4 +-
.../io/components/throttling}/package-info.java | 4 +-
.../beam/sdk/io/iceberg/IcebergCatalogConfig.java | 103 ++++++--
.../apache/beam/sdk/io/iceberg/PartitionUtils.java | 37 +++
.../beam/sdk/io/iceberg/FilterUtilsTest.java | 6 -
sdks/python/apache_beam/coders/coders.py | 2 +-
.../apache_beam/coders/coders_test_common.py | 14 ++
.../apache_beam/ml/inference/gemini_inference.py | 26 ++-
.../ml/inference/gemini_inference_test.py | 25 ++
settings.gradle.kts | 1 +
61 files changed, 3476 insertions(+), 161 deletions(-)
create mode 100644 .agent/skills/README.md
create mode 100644 .agent/skills/beam-concepts/SKILL.md
create mode 100644 .agent/skills/ci-cd/SKILL.md
create mode 100644 .agent/skills/contributing/SKILL.md
create mode 100644 .agent/skills/gradle-build/SKILL.md
create mode 100644 .agent/skills/io-connectors/SKILL.md
create mode 100644 .agent/skills/java-development/SKILL.md
create mode 100644 .agent/skills/license-compliance/SKILL.md
create mode 100644 .agent/skills/python-development/SKILL.md
create mode 100644 .agent/skills/runners/SKILL.md
create mode 100644
sdks/java/extensions/sql/iceberg/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/IcebergAlterTableOps.java
create mode 100644
sdks/java/extensions/sql/iceberg/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/iceberg/BeamSqlCliIcebergAlterTest.java
copy
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/{SqlCreateCatalog.java
=> SqlAlterCatalog.java} (54%)
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/parser/SqlAlterTable.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/AlterTableOps.java
create mode 100644
sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/meta/provider/test/AlterTestTableOps.java
copy {it/splunk/src/main/java/org/apache/beam/it/splunk =>
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/deadletterqueue}/package-info.java
(86%)
copy {it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow
=>
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/deadletterqueue/sinks}/package-info.java
(86%)
copy
{examples/java/cdap/hubspot/src/main/java/org/apache/beam/examples/complete/cdap/hubspot/options
=>
sdks/java/io/components/src/main/java/org/apache/beam/sdk/io/components/throttling}/package-info.java
(87%)
