File tree
45 files changed
+403
-587
lines changed- .github/workflows
- .test-infra/jenkins
- buildSrc/src/main/groovy/org/apache/beam/gradle
- examples
- java
- kotlin
- multi-language
- runners
- google-cloud-dataflow-java
- arm
- examples
- spark
- sdks
- go/test
- java
- container
- agent
- extensions/sql
- io
- hcatalog
- iceberg
- testing/jpms-tests
- website/www/site/content/en/documentation/sdks
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
45 files changed
+403
-587
lines changedLines changed: 12 additions & 8 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
95 | 95 |
| |
96 | 96 |
| |
97 | 97 |
| |
98 |
| - | |
99 |
| - | |
| 98 | + | |
| 99 | + | |
| 100 | + | |
100 | 101 |
| |
101 | 102 |
| |
102 | 103 |
| |
| |||
105 | 106 |
| |
106 | 107 |
| |
107 | 108 |
| |
108 |
| - | |
109 |
| - | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
110 | 112 |
| |
111 | 113 |
| |
112 | 114 |
| |
| |||
115 | 117 |
| |
116 | 118 |
| |
117 | 119 |
| |
118 |
| - | |
119 |
| - | |
| 120 | + | |
| 121 | + | |
| 122 | + | |
120 | 123 |
| |
121 | 124 |
| |
122 | 125 |
| |
| |||
125 | 128 |
| |
126 | 129 |
| |
127 | 130 |
| |
128 |
| - | |
129 |
| - | |
| 131 | + | |
| 132 | + | |
| 133 | + | |
130 | 134 |
| |
131 | 135 |
| |
132 | 136 |
|
Lines changed: 12 additions & 8 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
95 | 95 |
| |
96 | 96 |
| |
97 | 97 |
| |
98 |
| - | |
99 |
| - | |
| 98 | + | |
| 99 | + | |
| 100 | + | |
100 | 101 |
| |
101 | 102 |
| |
102 | 103 |
| |
| |||
105 | 106 |
| |
106 | 107 |
| |
107 | 108 |
| |
108 |
| - | |
109 |
| - | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
110 | 112 |
| |
111 | 113 |
| |
112 | 114 |
| |
| |||
115 | 117 |
| |
116 | 118 |
| |
117 | 119 |
| |
118 |
| - | |
119 |
| - | |
| 120 | + | |
| 121 | + | |
| 122 | + | |
120 | 123 |
| |
121 | 124 |
| |
122 | 125 |
| |
| |||
125 | 128 |
| |
126 | 129 |
| |
127 | 130 |
| |
128 |
| - | |
129 |
| - | |
| 131 | + | |
| 132 | + | |
| 133 | + | |
130 | 134 |
| |
131 | 135 |
| |
132 | 136 |
|
Lines changed: 21 additions & 14 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
97 | 97 |
| |
98 | 98 |
| |
99 | 99 |
| |
100 |
| - | |
101 |
| - | |
| 100 | + | |
| 101 | + | |
| 102 | + | |
102 | 103 |
| |
103 | 104 |
| |
104 | 105 |
| |
| |||
108 | 109 |
| |
109 | 110 |
| |
110 | 111 |
| |
111 |
| - | |
112 |
| - | |
| 112 | + | |
| 113 | + | |
| 114 | + | |
113 | 115 |
| |
114 | 116 |
| |
115 | 117 |
| |
| |||
119 | 121 |
| |
120 | 122 |
| |
121 | 123 |
| |
122 |
| - | |
123 |
| - | |
| 124 | + | |
| 125 | + | |
| 126 | + | |
124 | 127 |
| |
125 | 128 |
| |
126 | 129 |
| |
| |||
130 | 133 |
| |
131 | 134 |
| |
132 | 135 |
| |
133 |
| - | |
134 |
| - | |
| 136 | + | |
| 137 | + | |
| 138 | + | |
135 | 139 |
| |
136 | 140 |
| |
137 | 141 |
| |
| |||
141 | 145 |
| |
142 | 146 |
| |
143 | 147 |
| |
144 |
| - | |
145 |
| - | |
| 148 | + | |
| 149 | + | |
| 150 | + | |
146 | 151 |
| |
147 | 152 |
| |
148 | 153 |
| |
| |||
152 | 157 |
| |
153 | 158 |
| |
154 | 159 |
| |
155 |
| - | |
156 |
| - | |
| 160 | + | |
| 161 | + | |
| 162 | + | |
157 | 163 |
| |
158 | 164 |
| |
159 | 165 |
| |
| |||
163 | 169 |
| |
164 | 170 |
| |
165 | 171 |
| |
166 |
| - | |
167 |
| - | |
| 172 | + | |
| 173 | + | |
| 174 | + | |
168 | 175 |
|
Lines changed: 21 additions & 14 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
97 | 97 |
| |
98 | 98 |
| |
99 | 99 |
| |
100 |
| - | |
101 |
| - | |
| 100 | + | |
| 101 | + | |
| 102 | + | |
102 | 103 |
| |
103 | 104 |
| |
104 | 105 |
| |
| |||
108 | 109 |
| |
109 | 110 |
| |
110 | 111 |
| |
111 |
| - | |
112 |
| - | |
| 112 | + | |
| 113 | + | |
| 114 | + | |
113 | 115 |
| |
114 | 116 |
| |
115 | 117 |
| |
| |||
119 | 121 |
| |
120 | 122 |
| |
121 | 123 |
| |
122 |
| - | |
123 |
| - | |
| 124 | + | |
| 125 | + | |
| 126 | + | |
124 | 127 |
| |
125 | 128 |
| |
126 | 129 |
| |
| |||
130 | 133 |
| |
131 | 134 |
| |
132 | 135 |
| |
133 |
| - | |
134 |
| - | |
| 136 | + | |
| 137 | + | |
| 138 | + | |
135 | 139 |
| |
136 | 140 |
| |
137 | 141 |
| |
| |||
141 | 145 |
| |
142 | 146 |
| |
143 | 147 |
| |
144 |
| - | |
145 |
| - | |
| 148 | + | |
| 149 | + | |
| 150 | + | |
146 | 151 |
| |
147 | 152 |
| |
148 | 153 |
| |
| |||
152 | 157 |
| |
153 | 158 |
| |
154 | 159 |
| |
155 |
| - | |
156 |
| - | |
| 160 | + | |
| 161 | + | |
| 162 | + | |
157 | 163 |
| |
158 | 164 |
| |
159 | 165 |
| |
| |||
163 | 169 |
| |
164 | 170 |
| |
165 | 171 |
| |
166 |
| - | |
167 |
| - | |
| 172 | + | |
| 173 | + | |
| 174 | + | |
168 | 175 |
|
Lines changed: 12 additions & 8 deletions
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
98 | 98 |
| |
99 | 99 |
| |
100 | 100 |
| |
101 |
| - | |
102 |
| - | |
| 101 | + | |
| 102 | + | |
| 103 | + | |
103 | 104 |
| |
104 | 105 |
| |
105 | 106 |
| |
| |||
109 | 110 |
| |
110 | 111 |
| |
111 | 112 |
| |
112 |
| - | |
113 |
| - | |
| 113 | + | |
| 114 | + | |
| 115 | + | |
114 | 116 |
| |
115 | 117 |
| |
116 | 118 |
| |
| |||
120 | 122 |
| |
121 | 123 |
| |
122 | 124 |
| |
123 |
| - | |
124 |
| - | |
| 125 | + | |
| 126 | + | |
| 127 | + | |
125 | 128 |
| |
126 | 129 |
| |
127 | 130 |
| |
| |||
131 | 134 |
| |
132 | 135 |
| |
133 | 136 |
| |
134 |
| - | |
135 |
| - | |
| 137 | + | |
| 138 | + | |
| 139 | + | |
136 | 140 |
|
0 commit comments