@@ -422,10 +422,10 @@ public void testScenario3() throws Exception {
422
422
Path path = new Path (testFile + "/~12/!008/testfile_" + UUID .randomUUID ());
423
423
424
424
// Write
425
- try (FSDataOutputStream nativeFsStream = abfs .create (path , true )) {
426
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
427
- nativeFsStream .flush ();
428
- nativeFsStream .hsync ();
425
+ try (FSDataOutputStream abfsOutputStream = abfs .create (path , true )) {
426
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
427
+ abfsOutputStream .flush ();
428
+ abfsOutputStream .hsync ();
429
429
}
430
430
431
431
// Check file status
@@ -672,10 +672,10 @@ public void testScenario9() throws Exception {
672
672
Path testFile = path ("/testReadFile" );
673
673
Path path = new Path (testFile + "/~12/!008/testfile_" + UUID .randomUUID ());
674
674
675
- try (FSDataOutputStream nativeFsStream = abfs .create (path , true )) {
676
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
677
- nativeFsStream .flush ();
678
- nativeFsStream .hsync ();
675
+ try (FSDataOutputStream abfsOutputStream = abfs .create (path , true )) {
676
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
677
+ abfsOutputStream .flush ();
678
+ abfsOutputStream .hsync ();
679
679
}
680
680
681
681
// Check file status
@@ -715,10 +715,10 @@ public void testScenario10() throws Exception {
715
715
Path testFile = path ("/testReadFile" );
716
716
Path path = new Path (testFile + "/~12/!008/testfile_" + UUID .randomUUID ());
717
717
718
- try (FSDataOutputStream nativeFsStream = abfs .create (path , true )) {
719
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
720
- nativeFsStream .flush ();
721
- nativeFsStream .hsync ();
718
+ try (FSDataOutputStream abfsOutputStream = abfs .create (path , true )) {
719
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
720
+ abfsOutputStream .flush ();
721
+ abfsOutputStream .hsync ();
722
722
}
723
723
724
724
// Check file status
@@ -960,10 +960,10 @@ public void testScenario16() throws Exception {
960
960
961
961
// Write
962
962
wasb .create (path , true );
963
- try (FSDataOutputStream nativeFsStream = abfs .append (path )) {
964
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
965
- nativeFsStream .flush ();
966
- nativeFsStream .hsync ();
963
+ try (FSDataOutputStream abfsOutputStream = abfs .append (path )) {
964
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
965
+ abfsOutputStream .flush ();
966
+ abfsOutputStream .hsync ();
967
967
}
968
968
969
969
// Check file status
@@ -994,10 +994,10 @@ public void testScenario17() throws Exception {
994
994
Path path = new Path (testFile + "/~12/!008/testfile_" + UUID .randomUUID ());
995
995
996
996
// Write
997
- try (FSDataOutputStream nativeFsStream = abfs .create (path , true )) {
998
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
999
- nativeFsStream .flush ();
1000
- nativeFsStream .hsync ();
997
+ try (FSDataOutputStream abfsOutputStream = abfs .create (path , true )) {
998
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
999
+ abfsOutputStream .flush ();
1000
+ abfsOutputStream .hsync ();
1001
1001
}
1002
1002
// --- VALIDATE FILE ---
1003
1003
FileStatus status = abfs .getFileStatus (path );
@@ -1182,10 +1182,10 @@ public void testScenario21() throws Exception {
1182
1182
Path path = new Path (testFile + "/~12/!008/testfile_" + UUID .randomUUID ());
1183
1183
1184
1184
// Write
1185
- try (FSDataOutputStream nativeFsStream = abfs .create (path , true )) {
1186
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
1187
- nativeFsStream .flush ();
1188
- nativeFsStream .hsync ();
1185
+ try (FSDataOutputStream abfsOutputStream = abfs .create (path , true )) {
1186
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
1187
+ abfsOutputStream .flush ();
1188
+ abfsOutputStream .hsync ();
1189
1189
}
1190
1190
// --- VALIDATE FILE ---
1191
1191
FileStatus status = wasb .getFileStatus (path );
@@ -1330,10 +1330,10 @@ public void testScenario24() throws Exception {
1330
1330
Path path = new Path (testFile + "/~12/!008/testfile_" + UUID .randomUUID ());
1331
1331
1332
1332
// Write
1333
- try (FSDataOutputStream nativeFsStream = abfs .create (path , true )) {
1334
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
1335
- nativeFsStream .flush ();
1336
- nativeFsStream .hsync ();
1333
+ try (FSDataOutputStream abfsOutputStream = abfs .create (path , true )) {
1334
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
1335
+ abfsOutputStream .flush ();
1336
+ abfsOutputStream .hsync ();
1337
1337
}
1338
1338
// --- VALIDATE FILE ---
1339
1339
FileStatus status = wasb .getFileStatus (path );
@@ -1423,10 +1423,10 @@ public void testScenario26() throws Exception {
1423
1423
Path path = new Path (testFile + "/~12/!008/testfile_" + UUID .randomUUID ());
1424
1424
1425
1425
// Write
1426
- try (FSDataOutputStream nativeFsStream = abfs .create (path , true )) {
1427
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
1428
- nativeFsStream .flush ();
1429
- nativeFsStream .hsync ();
1426
+ try (FSDataOutputStream abfsOutputStream = abfs .create (path , true )) {
1427
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
1428
+ abfsOutputStream .flush ();
1429
+ abfsOutputStream .hsync ();
1430
1430
}
1431
1431
// --- VALIDATE FILE ---
1432
1432
FileStatus status = abfs .getFileStatus (path );
@@ -1469,10 +1469,10 @@ public void testScenario27() throws Exception {
1469
1469
Path testPath2 = new Path (testFile + "/~12/!008/testfile_" + UUID .randomUUID ());
1470
1470
1471
1471
// Write
1472
- try (FSDataOutputStream nativeFsStream = abfs .create (testPath1 , true )) {
1473
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
1474
- nativeFsStream .flush ();
1475
- nativeFsStream .hsync ();
1472
+ try (FSDataOutputStream abfsOutputStream = abfs .create (testPath1 , true )) {
1473
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
1474
+ abfsOutputStream .flush ();
1475
+ abfsOutputStream .hsync ();
1476
1476
}
1477
1477
1478
1478
// Check file status
@@ -1570,10 +1570,10 @@ public void testScenario29() throws Exception {
1570
1570
1571
1571
// Write
1572
1572
wasb .create (testPath1 , true );
1573
- try (FSDataOutputStream nativeFsStream = abfs .append (testPath1 )) {
1574
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
1575
- nativeFsStream .flush ();
1576
- nativeFsStream .hsync ();
1573
+ try (FSDataOutputStream abfsOutputStream = abfs .append (testPath1 )) {
1574
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
1575
+ abfsOutputStream .flush ();
1576
+ abfsOutputStream .hsync ();
1577
1577
}
1578
1578
1579
1579
// Check file status
@@ -1773,10 +1773,10 @@ public void testScenario33() throws Exception {
1773
1773
1774
1774
// Write
1775
1775
abfs .mkdirs (testFile );
1776
- try (FSDataOutputStream nativeFsStream = abfs .create (testPath1 , true )) {
1777
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
1778
- nativeFsStream .flush ();
1779
- nativeFsStream .hsync ();
1776
+ try (FSDataOutputStream abfsOutputStream = abfs .create (testPath1 , true )) {
1777
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
1778
+ abfsOutputStream .flush ();
1779
+ abfsOutputStream .hsync ();
1780
1780
}
1781
1781
abfs .create (testPath2 , true );
1782
1782
abfs .create (testPath3 , true );
@@ -1823,10 +1823,10 @@ public void testScenario34() throws Exception {
1823
1823
1824
1824
// Write
1825
1825
abfs .mkdirs (testFile );
1826
- try (FSDataOutputStream nativeFsStream = abfs .create (testPath1 , true )) {
1827
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
1828
- nativeFsStream .flush ();
1829
- nativeFsStream .hsync ();
1826
+ try (FSDataOutputStream abfsOutputStream = abfs .create (testPath1 , true )) {
1827
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
1828
+ abfsOutputStream .flush ();
1829
+ abfsOutputStream .hsync ();
1830
1830
}
1831
1831
abfs .create (testPath3 , true );
1832
1832
@@ -1965,10 +1965,10 @@ public void testScenario37() throws Exception {
1965
1965
1966
1966
// Write
1967
1967
abfs .mkdirs (testFile );
1968
- try (FSDataOutputStream nativeFsStream = abfs .create (testPath1 , true )) {
1969
- nativeFsStream .write (TEST_CONTEXT .getBytes ());
1970
- nativeFsStream .flush ();
1971
- nativeFsStream .hsync ();
1968
+ try (FSDataOutputStream abfsOutputStream = abfs .create (testPath1 , true )) {
1969
+ abfsOutputStream .write (TEST_CONTEXT .getBytes ());
1970
+ abfsOutputStream .flush ();
1971
+ abfsOutputStream .hsync ();
1972
1972
}
1973
1973
abfs .create (testPath3 , true );
1974
1974
0 commit comments