Commit f11e5b8
File tree
303 files changed
+5207
-2858
lines changed- .github
- actions/gradle-command-self-hosted-action
- trigger_files
- workflows
- load-tests-pipeline-options
- buildSrc/src/main/groovy/org/apache/beam/gradle
- examples/java
- src/main/java/org/apache/beam/examples/complete
- datatokenization/utils
- game/injector
- webapis/src/main/java/org/apache/beam/examples/webapis
- it
- clickhouse/src/main/java/org/apache/beam/it/clickhouse/conditions
- datadog/src/main/java/org/apache/beam/it/datadog/conditions
- google-cloud-platform/src
- main/java/org/apache/beam/it/gcp
- bigquery/conditions
- pubsub/conditions
- test/java/org/apache/beam/it/gcp
- bigquery
- bigtable
- spanner
- storage
- kafka/src/test/java/org/apache/beam/it/kafka
- mongodb/src/main/java/org/apache/beam/it/mongodb/conditions
- splunk/src/main/java/org/apache/beam/it/splunk/conditions
- runners
- core-java/src/main/java/org/apache/beam/runners/core
- direct-java/src/main/java/org/apache/beam/runners/direct
- flink
- 1.19/src/test/java/org/apache/beam/runners/flink/streaming
- 1.20/src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming
- 2.0/src
- main/java/org/apache/beam/runners/flink/translation/wrappers/streaming
- test/java/org/apache/beam/runners/flink/streaming
- src/main/java/org/apache/beam/runners/flink/translation/wrappers/streaming
- google-cloud-dataflow-java
- src
- main/java/org/apache/beam/runners/dataflow
- options
- test/java/org/apache/beam/runners/dataflow
- worker
- src
- main/java/org/apache/beam/runners/dataflow/worker
- counters
- logging
- windmill
- client
- grpc
- stubs
- work/refresh
- test/java/org/apache/beam/runners/dataflow/worker
- logging
- status
- streaming
- config
- harness
- windmill
- client/grpc
- testing
- work/refresh
- windmill/src/main/proto
- java-fn-execution/src
- main/java/org/apache/beam/runners/fnexecution/artifact
- test/java/org/apache/beam/runners/fnexecution
- control
- wire
- java-job-service/src/main/java/org/apache/beam/runners/jobsubmission
- prism/java/src/main/java/org/apache/beam/runners/prism
- samza/src/main/java/org/apache/beam/runners/samza/runtime
- spark
- 3/src/main/java/org/apache/beam/runners/spark/structuredstreaming/translation/helpers
- src/main/java/org/apache/beam/runners/spark
- translation
- util
- sdks
- java
- core/src
- main/java/org/apache/beam/sdk
- fn
- channel
- server
- test
- io
- metrics
- providers
- schemas
- logicaltypes
- transforms
- transforms
- reflect
- windowing
- util
- construction
- resources
- test/java/org/apache/beam/sdk
- io
- schemas
- transforms
- transforms
- errorhandling
- reflect
- splittabledofn
- windowing
- util
- expansion-service/src
- main/java/org/apache/beam/sdk/expansion/service
- test/java/org/apache/beam/sdk/expansion/service
- extensions
- avro/src
- main/java/org/apache/beam/sdk/extensions/avro/schemas/utils
- test/java/org/apache/beam/sdk/extensions/avro/schemas/utils
- euphoria/src
- main/java/org/apache/beam/sdk/extensions/euphoria/core/client/operator
- test/java/org/apache/beam/sdk/extensions/euphoria/core
- client/util
- translate
- collector
- google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/util
- ml/src/main/java/org/apache/beam/sdk/extensions/ml
- ordered/src
- main/java/org/apache/beam/sdk/extensions/ordered
- test/java/org/apache/beam/sdk/extensions/ordered
- sql
- perf-tests/src/test/java/org/apache/beam/sdk/extensions/sql/meta/provider/bigquery
- src
- main/java/org/apache/beam/sdk/extensions/sql
- impl/parser
- meta/catalog
- test/java/org/apache/beam/sdk/extensions/sql
- timeseries/src/main/java/org/apache/beam/sdk/extensions/timeseries
- zetasketch/src/main/java/org/apache/beam/sdk/extensions/zetasketch
- harness/src/main/java/org/apache/beam/fn/harness
- io
- amazon-web-services2/src
- main/java/org/apache/beam/sdk/io/aws2
- common
- kinesis
- sqs
- test/java/org/apache/beam/sdk/io/aws2
- dynamodb/testing
- kinesis
- cdap/src
- main/java/org/apache/beam/sdk/io/cdap
- test/java/org/apache/beam/sdk/io/cdap
- common/src/main/java/org/apache/beam/sdk/io/common
- datadog/src/main/java/org/apache/beam/sdk/io/datadog
- debezium/src
- main/java/org/apache/beam/io/debezium
- test/java/org/apache/beam/io/debezium
- elasticsearch/src/main/java/org/apache/beam/sdk/io/elasticsearch
- file-schema-transform/src/test/java/org/apache/beam/sdk/io/fileschematransform
- google-cloud-platform/src
- main/java/org/apache/beam/sdk/io/gcp
- bigquery
- firestore
- pubsub
- spanner
- changestreams/action
- testing
- test/java/org/apache/beam/sdk/io/gcp
- bigquery
- bigtable
- changestreams
- dofn
- estimator
- spanner/changestreams
- restriction
- util
- hadoop-format/src/test/java/org/apache/beam/sdk/io/hadoop/format
- hbase/src
- main/java/org/apache/beam/sdk/io/hbase
- test/java/org/apache/beam/sdk/io/hbase
- 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
- test/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
- parquet/src
- main/java/org/apache/beam/sdk/io/parquet
- test/java/org/apache/beam/sdk/io/parquet
- rabbitmq/src/test/java/org/apache/beam/sdk/io/rabbitmq
- rrio/src
- main/java/org/apache/beam/io/requestresponse
- test/java/org/apache/beam/io/requestresponse
- singlestore/src
- main/java/org/apache/beam/sdk/io/singlestore
- test/java/org/apache/beam/sdk/io/singlestore
- snowflake/src/main/java/org/apache/beam/sdk/io/snowflake/data
- solace/src/main/java/org/apache/beam/sdk/io/solace/data
- sparkreceiver/3/src/test/java/org/apache/beam/sdk/io/sparkreceiver
- splunk/src/main/java/org/apache/beam/sdk/io/splunk
- synthetic/src/main/java/org/apache/beam/sdk/io/synthetic
- managed/src/main/java/org/apache/beam/sdk/managed/testing
- testing/load-tests/src/main/java/org/apache/beam/sdk/loadtests
- python
- apache_beam
- coders
- io
- ml
- inference
- rag/embeddings
- transforms/embeddings
- testing/benchmarks/cloudml
- typehints
- container
- license_scripts
- ml
- py310
- py311
- py312
- py313
- py310
- py311
- py312
- py313
- test-suites/tox/py310
- typescript
- website/www/site
- layouts/shortcodes
- static/images/colab
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
303 files changed
+5207
-2858
lines changedLines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
42 | 42 | | |
43 | 43 | | |
44 | 44 | | |
45 | | - | |
| 45 | + | |
46 | 46 | | |
| 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 | |
|---|---|---|---|
| |||
38 | 38 | | |
39 | 39 | | |
40 | 40 | | |
| 41 | + | |
| 42 | + | |
41 | 43 | | |
42 | 44 | | |
43 | 45 | | |
| |||
86 | 88 | | |
87 | 89 | | |
88 | 90 | | |
89 | | - | |
| 91 | + | |
| 92 | + | |
Lines changed: 1 addition & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
105 | 105 | | |
106 | 106 | | |
107 | 107 | | |
| 108 | + | |
108 | 109 | | |
109 | 110 | | |
110 | 111 | | |
| |||
Lines changed: 1 addition & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
119 | 119 | | |
120 | 120 | | |
121 | 121 | | |
| 122 | + | |
122 | 123 | | |
123 | 124 | | |
124 | 125 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
102 | 102 | | |
103 | 103 | | |
104 | 104 | | |
105 | | - | |
| 105 | + | |
| 106 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
127 | 127 | | |
128 | 128 | | |
129 | 129 | | |
| 130 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
82 | 82 | | |
83 | 83 | | |
84 | 84 | | |
85 | | - | |
| 85 | + | |
| 86 | + | |
86 | 87 | | |
87 | 88 | | |
88 | 89 | | |
89 | 90 | | |
90 | 91 | | |
91 | 92 | | |
92 | | - | |
| 93 | + | |
| 94 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
25 | 25 | | |
26 | 26 | | |
27 | 27 | | |
| 28 | + | |
28 | 29 | | |
29 | 30 | | |
30 | | - | |
31 | 31 | | |
32 | 32 | | |
33 | 33 | | |
| |||
244 | 244 | | |
245 | 245 | | |
246 | 246 | | |
247 | | - | |
| 247 | + | |
248 | 248 | | |
249 | 249 | | |
250 | 250 | | |
251 | 251 | | |
252 | 252 | | |
253 | | - | |
| 253 | + | |
254 | 254 | | |
255 | 255 | | |
256 | 256 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
20 | 20 | | |
21 | 21 | | |
22 | 22 | | |
23 | | - | |
| 23 | + | |
0 commit comments