|
2 | 2 | "Test put batch data frame transforms on mixed cluster": |
3 | 3 | - do: |
4 | 4 | cluster.health: |
5 | | - index: "dataframe-transform-airline-data" |
| 5 | + index: "transform-airline-data" |
6 | 6 | wait_for_status: green |
7 | 7 | timeout: 70s |
8 | 8 |
|
9 | 9 | - do: |
10 | | - data_frame.put_data_frame_transform: |
| 10 | + transform.put_transform: |
11 | 11 | transform_id: "mixed-simple-transform" |
12 | 12 | body: > |
13 | 13 | { |
14 | | - "source": { "index": "dataframe-transform-airline-data" }, |
| 14 | + "source": { "index": "transform-airline-data" }, |
15 | 15 | "dest": { "index": "mixed-simple-transform-idx" }, |
16 | 16 | "pivot": { |
17 | 17 | "group_by": { "airline": {"terms": {"field": "airline"}}}, |
|
21 | 21 | - match: { acknowledged: true } |
22 | 22 |
|
23 | 23 | - do: |
24 | | - data_frame.start_data_frame_transform: |
| 24 | + transform.start_transform: |
25 | 25 | transform_id: "mixed-simple-transform" |
26 | 26 | - match: { acknowledged: true } |
27 | 27 | - do: |
28 | | - data_frame.get_data_frame_transform_stats: |
| 28 | + transform.get_transform_stats: |
29 | 29 | transform_id: "mixed-simple-transform" |
30 | 30 | - match: { count: 1 } |
31 | 31 | - match: { transforms.0.id: "mixed-simple-transform" } |
32 | 32 | - match: { transforms.0.state: "/started|indexing|stopping|stopped/" } |
33 | 33 |
|
34 | 34 | - do: |
35 | | - data_frame.stop_data_frame_transform: |
| 35 | + transform.stop_transform: |
36 | 36 | transform_id: "mixed-simple-transform" |
37 | 37 | wait_for_completion: true |
38 | 38 | - match: { acknowledged: true } |
39 | 39 |
|
40 | 40 | - do: |
41 | | - data_frame.get_data_frame_transform_stats: |
| 41 | + transform.get_transform_stats: |
42 | 42 | transform_id: "mixed-simple-transform" |
43 | 43 | - match: { count: 1 } |
44 | 44 | - match: { transforms.0.id: "mixed-simple-transform" } |
45 | 45 | - match: { transforms.0.state: "stopped" } |
46 | 46 |
|
47 | 47 | - do: |
48 | | - data_frame.put_data_frame_transform: |
| 48 | + transform.put_transform: |
49 | 49 | transform_id: "mixed-complex-transform" |
50 | 50 | body: > |
51 | 51 | { |
52 | 52 | "source": { |
53 | | - "index": "dataframe-transform-airline-data", |
| 53 | + "index": "transform-airline-data", |
54 | 54 | "query": { |
55 | 55 | "bool": { |
56 | 56 | "filter": {"term": {"airline": "ElasticAir"}} |
|
73 | 73 | - match: { acknowledged: true } |
74 | 74 |
|
75 | 75 | - do: |
76 | | - data_frame.get_data_frame_transform: |
| 76 | + transform.get_transform: |
77 | 77 | transform_id: "mixed-complex-transform" |
78 | 78 | - match: { count: 1 } |
79 | 79 | - match: { transforms.0.id: "mixed-complex-transform" } |
80 | 80 | - is_true: transforms.0.version |
81 | 81 | - is_true: transforms.0.create_time |
82 | 82 |
|
83 | 83 | - do: |
84 | | - data_frame.start_data_frame_transform: |
| 84 | + transform.start_transform: |
85 | 85 | transform_id: "mixed-complex-transform" |
86 | 86 | - match: { acknowledged: true } |
87 | 87 | - do: |
88 | | - data_frame.get_data_frame_transform_stats: |
| 88 | + transform.get_transform_stats: |
89 | 89 | transform_id: "mixed-complex-transform" |
90 | 90 | - match: { count: 1 } |
91 | 91 | - match: { transforms.0.id: "mixed-complex-transform" } |
92 | 92 | - match: { transforms.0.state: "/started|indexing|stopping|stopped/" } |
93 | 93 |
|
94 | 94 | - do: |
95 | | - data_frame.stop_data_frame_transform: |
| 95 | + transform.stop_transform: |
96 | 96 | transform_id: "mixed-complex-transform" |
97 | 97 | wait_for_completion: true |
98 | 98 | - match: { acknowledged: true } |
99 | 99 |
|
100 | 100 | - do: |
101 | | - data_frame.get_data_frame_transform_stats: |
| 101 | + transform.get_transform_stats: |
102 | 102 | transform_id: "mixed-complex-transform" |
103 | 103 | - match: { count: 1 } |
104 | 104 | - match: { transforms.0.id: "mixed-complex-transform" } |
|
108 | 108 | "Test put continuous data frame transform on mixed cluster": |
109 | 109 | - do: |
110 | 110 | cluster.health: |
111 | | - index: "dataframe-transform-airline-data-cont" |
| 111 | + index: "transform-airline-data-cont" |
112 | 112 | wait_for_status: green |
113 | 113 | timeout: 70s |
114 | 114 |
|
115 | 115 | - do: |
116 | | - data_frame.put_data_frame_transform: |
| 116 | + transform.put_transform: |
117 | 117 | transform_id: "mixed-simple-continuous-transform" |
118 | 118 | body: > |
119 | 119 | { |
120 | | - "source": { "index": "dataframe-transform-airline-data-cont" }, |
| 120 | + "source": { "index": "transform-airline-data-cont" }, |
121 | 121 | "dest": { "index": "mixed-simple-continuous-transform-idx" }, |
122 | 122 | "pivot": { |
123 | 123 | "group_by": { "airline": {"terms": {"field": "airline"}}}, |
|
133 | 133 | - match: { acknowledged: true } |
134 | 134 |
|
135 | 135 | - do: |
136 | | - data_frame.get_data_frame_transform: |
| 136 | + transform.get_transform: |
137 | 137 | transform_id: "mixed-simple-continuous-transform" |
138 | 138 | - match: { count: 1 } |
139 | 139 | - match: { transforms.0.id: "mixed-simple-continuous-transform" } |
|
143 | 143 | - is_true: transforms.0.create_time |
144 | 144 |
|
145 | 145 | - do: |
146 | | - data_frame.start_data_frame_transform: |
| 146 | + transform.start_transform: |
147 | 147 | transform_id: "mixed-simple-continuous-transform" |
148 | 148 | - match: { acknowledged: true } |
149 | 149 | - do: |
150 | | - data_frame.get_data_frame_transform_stats: |
| 150 | + transform.get_transform_stats: |
151 | 151 | transform_id: "mixed-simple-continuous-transform" |
152 | 152 | - match: { count: 1 } |
153 | 153 | - match: { transforms.0.id: "mixed-simple-continuous-transform" } |
154 | 154 | - match: { transforms.0.state: "/started|indexing/" } |
155 | 155 |
|
156 | 156 | - do: |
157 | | - data_frame.stop_data_frame_transform: |
| 157 | + transform.stop_transform: |
158 | 158 | transform_id: "mixed-simple-continuous-transform" |
159 | 159 | wait_for_completion: true |
160 | 160 | - match: { acknowledged: true } |
161 | 161 |
|
162 | 162 | - do: |
163 | | - data_frame.get_data_frame_transform_stats: |
| 163 | + transform.get_transform_stats: |
164 | 164 | transform_id: "mixed-simple-continuous-transform" |
165 | 165 | - match: { count: 1 } |
166 | 166 | - match: { transforms.0.id: "mixed-simple-continuous-transform" } |
|
170 | 170 | "Test GET, start, and stop old cluster batch transforms": |
171 | 171 | - do: |
172 | 172 | cluster.health: |
173 | | - index: "dataframe-transform-airline-data" |
| 173 | + index: "transform-airline-data" |
174 | 174 | wait_for_status: green |
175 | 175 | timeout: 70s |
176 | 176 |
|
177 | 177 | - do: |
178 | | - data_frame.get_data_frame_transform: |
| 178 | + transform.get_transform: |
179 | 179 | transform_id: "old-simple-transform" |
180 | 180 | - match: { count: 1 } |
181 | 181 | - match: { transforms.0.id: "old-simple-transform" } |
182 | | - - match: { transforms.0.source.index.0: "dataframe-transform-airline-data" } |
| 182 | + - match: { transforms.0.source.index.0: "transform-airline-data" } |
183 | 183 | - match: { transforms.0.dest.index: "old-simple-transform-idx" } |
184 | 184 | - match: { transforms.0.pivot.group_by.airline.terms.field: "airline" } |
185 | 185 | - match: { transforms.0.pivot.aggregations.avg_response.avg.field: "responsetime" } |
186 | 186 |
|
187 | 187 | - do: |
188 | | - data_frame.start_data_frame_transform: |
| 188 | + transform.start_transform: |
189 | 189 | transform_id: "old-simple-transform" |
190 | 190 | - match: { acknowledged: true } |
191 | 191 | - do: |
192 | | - data_frame.get_data_frame_transform_stats: |
| 192 | + transform.get_transform_stats: |
193 | 193 | transform_id: "old-simple-transform" |
194 | 194 | - match: { count: 1 } |
195 | 195 | - match: { transforms.0.id: "old-simple-transform" } |
196 | 196 | - match: { transforms.0.state: "/started|indexing|stopping|stopped/" } |
197 | 197 |
|
198 | 198 | - do: |
199 | | - data_frame.stop_data_frame_transform: |
| 199 | + transform.stop_transform: |
200 | 200 | transform_id: "old-simple-transform" |
201 | 201 | wait_for_completion: true |
202 | 202 | - match: { acknowledged: true } |
203 | 203 | - do: |
204 | | - data_frame.get_data_frame_transform_stats: |
| 204 | + transform.get_transform_stats: |
205 | 205 | transform_id: "old-simple-transform" |
206 | 206 | - match: { count: 1 } |
207 | 207 | - match: { transforms.0.id: "old-simple-transform" } |
208 | 208 | - match: { transforms.0.state: "stopped" } |
209 | 209 |
|
210 | 210 | - do: |
211 | | - data_frame.get_data_frame_transform: |
| 211 | + transform.get_transform: |
212 | 212 | transform_id: "old-complex-transform" |
213 | 213 | - match: { count: 1 } |
214 | 214 | - match: { transforms.0.id: "old-complex-transform" } |
215 | | - - match: { transforms.0.source.index.0: "dataframe-transform-airline-data" } |
| 215 | + - match: { transforms.0.source.index.0: "transform-airline-data" } |
216 | 216 | - match: { transforms.0.dest.index: "old-complex-transform-idx" } |
217 | 217 | - match: { transforms.0.dest.pipeline: "data_frame_simple_pipeline" } |
218 | 218 | - match: { transforms.0.pivot.group_by.airline.terms.field: "airline" } |
|
221 | 221 | - match: { transforms.0.pivot.aggregations.avg_response.avg.field: "responsetime" } |
222 | 222 |
|
223 | 223 | - do: |
224 | | - data_frame.start_data_frame_transform: |
| 224 | + transform.start_transform: |
225 | 225 | transform_id: "old-complex-transform" |
226 | 226 | - match: { acknowledged: true } |
227 | 227 | - do: |
228 | | - data_frame.get_data_frame_transform_stats: |
| 228 | + transform.get_transform_stats: |
229 | 229 | transform_id: "old-complex-transform" |
230 | 230 | - match: { count: 1 } |
231 | 231 | - match: { transforms.0.id: "old-complex-transform" } |
232 | 232 | - match: { transforms.0.state: "/started|indexing|stopping|stopped/" } |
233 | 233 |
|
234 | 234 | - do: |
235 | | - data_frame.stop_data_frame_transform: |
| 235 | + transform.stop_transform: |
236 | 236 | transform_id: "old-complex-transform" |
237 | 237 | wait_for_completion: true |
238 | 238 | - match: { acknowledged: true } |
239 | 239 | - do: |
240 | | - data_frame.get_data_frame_transform_stats: |
| 240 | + transform.get_transform_stats: |
241 | 241 | transform_id: "old-complex-transform" |
242 | 242 | - match: { count: 1 } |
243 | 243 | - match: { transforms.0.id: "old-complex-transform" } |
|
247 | 247 | "Test GET, stop, start, old continuous transforms": |
248 | 248 | - do: |
249 | 249 | cluster.health: |
250 | | - index: "dataframe-transform-airline-data-cont" |
| 250 | + index: "transform-airline-data-cont" |
251 | 251 | wait_for_status: green |
252 | 252 | timeout: 70s |
253 | 253 |
|
254 | 254 | - do: |
255 | | - data_frame.get_data_frame_transform: |
| 255 | + transform.get_transform: |
256 | 256 | transform_id: "old-simple-continuous-transform" |
257 | 257 | - match: { count: 1 } |
258 | 258 | - match: { transforms.0.id: "old-simple-continuous-transform" } |
|
262 | 262 | - is_true: transforms.0.create_time |
263 | 263 |
|
264 | 264 | - do: |
265 | | - data_frame.start_data_frame_transform: |
| 265 | + transform.start_transform: |
266 | 266 | transform_id: "old-simple-continuous-transform" |
267 | 267 | - match: { acknowledged: true } |
268 | 268 | - do: |
269 | | - data_frame.get_data_frame_transform_stats: |
| 269 | + transform.get_transform_stats: |
270 | 270 | transform_id: "old-simple-continuous-transform" |
271 | 271 | - match: { count: 1 } |
272 | 272 | - match: { transforms.0.id: "old-simple-continuous-transform" } |
273 | 273 | - match: { transforms.0.state: "/started|indexing/" } |
274 | 274 |
|
275 | 275 | - do: |
276 | | - data_frame.stop_data_frame_transform: |
| 276 | + transform.stop_transform: |
277 | 277 | transform_id: "old-simple-continuous-transform" |
278 | 278 | wait_for_completion: true |
279 | 279 | - match: { acknowledged: true } |
280 | 280 |
|
281 | 281 | - do: |
282 | | - data_frame.get_data_frame_transform_stats: |
| 282 | + transform.get_transform_stats: |
283 | 283 | transform_id: "old-simple-continuous-transform" |
284 | 284 | - match: { count: 1 } |
285 | 285 | - match: { transforms.0.id: "old-simple-continuous-transform" } |
|
0 commit comments