Commit 9f6235f
committed
File tree
444 files changed
+12882
-21746
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
- 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
- stream
- io
- options
- schemas
- logicaltypes
- util
- 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
- google-cloud-platform/src
- main/java/org/apache/beam/sdk/io/gcp/bigtable
- test/java/org/apache/beam/sdk/io/gcp/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
- gcp
- healthcare
- ml
- rag/ingestion
- transforms
- embeddings
- options
- runners
- dataflow
- internal
- direct
- interactive/extensions/apache-beam-jupyterlab-sidepanel
- portability
- transforms
- typehints
- 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/transforms
- java
- other
- python
- other
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
444 files changed
+12882
-21746
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 | | |
| |||
| 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 | | |
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 | | - | |
3 | | - | |
| 2 | + | |
4 | 3 | | |
| 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 | |
|---|---|---|---|
| |||
54 | 54 | | |
55 | 55 | | |
56 | 56 | | |
57 | | - | |
| 57 | + | |
58 | 58 | | |
59 | 59 | | |
60 | 60 | | |
61 | 61 | | |
62 | 62 | | |
63 | 63 | | |
64 | 64 | | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
65 | 72 | | |
66 | 73 | | |
67 | 74 | | |
| |||
99 | 106 | | |
100 | 107 | | |
101 | 108 | | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + | |
| 113 | + | |
102 | 114 | | |
103 | 115 | | |
104 | 116 | | |
| |||
0 commit comments