Commit 1dee57d
committed
HADOOP-19569. put operations from store to multipart, now StoreWriter
All upload operations are in MultipartIO service, which
has been renamed and move to package org.apache.hadoop.fs.s3a.impl.write
to match.
For completeness deletion should also go into this class or an adjacent one on
deletion.1 parent f03e1b9 commit 1dee57d
File tree
16 files changed
+321
-294
lines changed- hadoop-tools/hadoop-aws/src
- main/java/org/apache/hadoop/fs/s3a
- api
- impl
- write
- test/java/org/apache/hadoop/fs/s3a
- commit/magic
- impl
- test
16 files changed
+321
-294
lines changedLines changed: 9 additions & 7 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1419 | 1419 | | |
1420 | 1420 | | |
1421 | 1421 | | |
1422 | | - | |
| 1422 | + | |
1423 | 1423 | | |
1424 | 1424 | | |
1425 | 1425 | | |
| |||
2626 | 2626 | | |
2627 | 2627 | | |
2628 | 2628 | | |
2629 | | - | |
| 2629 | + | |
2630 | 2630 | | |
2631 | 2631 | | |
2632 | 2632 | | |
2633 | 2633 | | |
2634 | | - | |
| 2634 | + | |
2635 | 2635 | | |
2636 | 2636 | | |
2637 | 2637 | | |
| |||
3206 | 3206 | | |
3207 | 3207 | | |
3208 | 3208 | | |
3209 | | - | |
| 3209 | + | |
| 3210 | + | |
3210 | 3211 | | |
3211 | 3212 | | |
3212 | 3213 | | |
| |||
4074 | 4075 | | |
4075 | 4076 | | |
4076 | 4077 | | |
4077 | | - | |
| 4078 | + | |
| 4079 | + | |
4078 | 4080 | | |
4079 | 4081 | | |
4080 | 4082 | | |
| |||
4496 | 4498 | | |
4497 | 4499 | | |
4498 | 4500 | | |
4499 | | - | |
| 4501 | + | |
4500 | 4502 | | |
4501 | 4503 | | |
4502 | 4504 | | |
| |||
5054 | 5056 | | |
5055 | 5057 | | |
5056 | 5058 | | |
5057 | | - | |
| 5059 | + | |
5058 | 5060 | | |
5059 | 5061 | | |
5060 | 5062 | | |
| |||
Lines changed: 6 additions & 71 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
48 | 48 | | |
49 | 49 | | |
50 | 50 | | |
51 | | - | |
52 | | - | |
| 51 | + | |
| 52 | + | |
53 | 53 | | |
54 | 54 | | |
55 | 55 | | |
| |||
118 | 118 | | |
119 | 119 | | |
120 | 120 | | |
121 | | - | |
122 | | - | |
| 121 | + | |
| 122 | + | |
123 | 123 | | |
124 | | - | |
125 | | - | |
| 124 | + | |
| 125 | + | |
126 | 126 | | |
127 | 127 | | |
128 | 128 | | |
| |||
321 | 321 | | |
322 | 322 | | |
323 | 323 | | |
324 | | - | |
325 | | - | |
326 | | - | |
327 | | - | |
328 | | - | |
329 | | - | |
330 | | - | |
331 | | - | |
332 | | - | |
333 | | - | |
334 | | - | |
335 | | - | |
336 | | - | |
337 | | - | |
338 | | - | |
339 | | - | |
340 | | - | |
341 | | - | |
342 | | - | |
343 | | - | |
344 | | - | |
345 | | - | |
346 | | - | |
347 | | - | |
348 | | - | |
349 | | - | |
350 | | - | |
351 | | - | |
352 | | - | |
353 | | - | |
354 | | - | |
355 | | - | |
356 | | - | |
357 | | - | |
358 | | - | |
359 | | - | |
360 | | - | |
361 | | - | |
362 | | - | |
363 | | - | |
364 | | - | |
365 | | - | |
366 | | - | |
367 | | - | |
368 | | - | |
369 | | - | |
370 | | - | |
371 | | - | |
372 | | - | |
373 | | - | |
374 | | - | |
375 | | - | |
376 | | - | |
377 | | - | |
378 | | - | |
379 | | - | |
380 | | - | |
381 | | - | |
382 | | - | |
383 | | - | |
384 | | - | |
385 | | - | |
386 | | - | |
387 | | - | |
388 | | - | |
389 | 324 | | |
390 | 325 | | |
391 | 326 | | |
| |||
Lines changed: 0 additions & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
22 | 22 | | |
23 | 23 | | |
24 | 24 | | |
25 | | - | |
26 | 25 | | |
27 | 26 | | |
28 | 27 | | |
| |||
0 commit comments