Commit 48c1a02
File tree
476 files changed
+16972
-23523
lines changed- .gemini
- .github
- trigger_files
- workflows
- .test-infra/mock-apis
- buildSrc
- src/main/groovy/org/apache/beam/gradle
- contributor-docs/discussion-docs
- dev-support/docker
- examples
- java
- src/main/java/org/apache/beam/examples/cookbook
- notebooks/beam-ml
- data_preprocessing
- gradle/wrapper
- infra/iam
- it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow
- runners/google-cloud-dataflow-java
- sdks
- go
- examples/xlang/sql
- pkg/beam
- core
- metrics
- runtime/harness
- options/jobopts
- runners/prism/internal
- engine
- worker
- transforms/sql
- java
- build-tools/src/main/resources/beam/checkstyle
- core/src/main/java/org/apache/beam/sdk
- fn
- data
- splittabledofn
- stream
- io
- options
- schemas
- logicaltypes
- transforms/splittabledofn
- util
- values
- extensions
- google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util
- sql
- datacatalog
- src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/datacatalog
- expansion-service
- src/main/java/org/apache/beam/sdk/extensions/sql/expansion
- jdbc
- src/test/java/org/apache/beam/sdk/extensions/sql/jdbc
- perf-tests/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery
- src
- main
- codegen
- includes
- java/org/apache/beam/sdk/extensions/sql
- impl
- cep
- parser
- planner
- rel
- rule
- schema
- transform
- agg
- udf
- utils
- meta
- catalog
- provider
- bigquery
- bigtable
- datagen
- iceberg
- mongodb
- test
- resources
- test/java/org/apache/beam/sdk/extensions/sql
- impl
- parser
- planner
- rel
- rule
- schema
- utils
- integrationtest
- meta
- provider
- datastore
- iceberg
- pubsub
- test
- zetasql
- src
- main/java/org/apache/beam/sdk/extensions/sql/zetasql
- translation
- impl
- unnest
- test/java/org/apache/beam/sdk/extensions/sql/zetasql
- harness
- jmh/src/main/java/org/apache/beam/fn/harness/jmh/control
- src
- main/java/org/apache/beam/fn/harness
- control
- state
- test/java/org/apache/beam/fn/harness
- control
- data
- logging
- state
- io
- amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/common
- google-cloud-platform/src
- main/java/org/apache/beam/sdk/io/gcp
- bigquery
- providers
- bigtable
- test/java/org/apache/beam/sdk/io/gcp
- bigquery
- providers
- bigtable
- iceberg
- src
- main/java/org/apache/beam/sdk/io/iceberg
- test/java/org/apache/beam/sdk/io/iceberg
- catalog
- jdbc/src/main/java/org/apache/beam/sdk/io/jdbc
- kafka/src
- main/java/org/apache/beam/sdk/io/kafka
- test/java/org/apache/beam/sdk/io/kafka
- testing
- nexmark/src/main/java/org/apache/beam/sdk/nexmark/queries/sql
- tpcds
- src/main/java/org/apache/beam/sdk/tpcds
- python
- apache_beam
- dataframe
- examples/inference
- io
- external
- gcp
- healthcare
- ml/transforms
- embeddings
- options
- runners
- dataflow
- internal
- direct
- interactive/extensions/apache-beam-jupyterlab-sidepanel
- portability
- transforms
- yaml
- examples
- testing
- transforms/ml
- sentiment_analysis
- taxi_fare
- extended_tests/databases
- tests
- container
- py310
- py311
- py312
- py39
- scripts
- test-suites/portable
- typescript
- vendor/calcite-1_40_0
- website/www/site
- content/en
- documentation
- ml
- transforms
- java
- other
- python
- other
- roadmap
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
476 files changed
+16972
-23523
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
51 | 51 | | |
52 | 52 | | |
53 | 53 | | |
| 54 | + | |
54 | 55 | | |
55 | 56 | | |
56 | 57 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
46 | 46 | | |
47 | 47 | | |
48 | 48 | | |
49 | | - | |
| 49 | + | |
50 | 50 | | |
51 | 51 | | |
52 | 52 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
49 | 49 | | |
50 | 50 | | |
51 | 51 | | |
52 | | - | |
53 | | - | |
54 | | - | |
55 | 52 | | |
56 | 53 | | |
57 | 54 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
5 | 5 | | |
Lines changed: 3 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
3 | | - | |
| 2 | + | |
4 | 3 | | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
3 | | - | |
| 2 | + | |
4 | 3 | | |
0 commit comments