Package org.apache.hadoop.fs

Examples of org.apache.hadoop.fs.FSDataOutputStream.sync()

135
136
137
138
139
140
141
142
143
144
145
      Path file1 = new Path(dir1, "file1");
      FSDataOutputStream stm1 = TestFileCreation.createFile(fs, file1, 1);
      System.out.println("testFileCreationDeleteParent: "
          + "Created file " + file1);
      TestFileCreation.writeFile(stm1);
      stm1.sync();

      // create file2.
      Path dir2 = new Path("/user/dir2");
      Path file2 = new Path(dir2, "file2");
      FSDataOutputStream stm2 = TestFileCreation.createFile(fs, file2, 1);
View Full Code Here
144
145
146
147
148
149
150
151
152
153
154
      Path file2 = new Path(dir2, "file2");
      FSDataOutputStream stm2 = TestFileCreation.createFile(fs, file2, 1);
      System.out.println("testFileCreationDeleteParent: "
          + "Created file " + file2);
      TestFileCreation.writeFile(stm2);
      stm2.sync();

      // move dir1 while file1 is open
      Path dir3 = new Path("/user/dir3");
      fs.rename(dir1, dir3);
View Full Code Here
207
208
209
210
211
212
213
214
215
216
217
      Path file1 = new Path(dir1, "file1");
      FSDataOutputStream stm1 = TestFileCreation.createFile(fs, file1, 1);
      System.out.println("testFileCreationDeleteParent: " +
                         "Created file " + file1);
      TestFileCreation.writeFile(stm1);
      stm1.sync();

      Path dir2 = new Path("/user/dir2");
      fs.mkdirs(dir2);

      fs.rename(file1, dir2);
View Full Code Here
269
270
271
272
273
274
275
276
277
278
279
      Path file1 = new Path(dir1, "file1");
      FSDataOutputStream stm1 = TestFileCreation.createFile(fs, file1, 1);
      System.out.println("testFileCreationDeleteParent: "
          + "Created file " + file1);
      TestFileCreation.writeFile(stm1);
      stm1.sync();

      Path dir2 = new Path("/user/dir2");

      fs.rename(file1, dir2);
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
    FSDataOutputStream out = fs.create(new Path(test + "/abc"));
    byte[] buffer = new byte[10 * 1024];
    Random r = new Random();
    r.nextBytes(buffer);
    out.write(buffer);
    out.sync();
    ((DistributedFileSystem) fs).setQuota(new Path(test), 5, -1);
    out.close();

    cluster.getStandbyAvatar(0).avatar.quiesceStandby(-1);
  }
View Full Code Here
317
318
319
320
321
322
323
324
325
326
327
    // Create some data.
    FSDataOutputStream out = fs.create(new Path(src));
    byte[] buffer = new byte[BLOCK_SIZE * 2];
    random.nextBytes(buffer);
    out.write(buffer);
    out.sync();

    // Wait for the hard lease time to expire.
    Thread.sleep(LEASE_PERIOD * 2);

    cluster.failOver();
View Full Code Here
339
340
341
342
343
344
345
346
347
348
349
    }
    LOG.info("Wait for lease done");

    // Now try to write to the file.
    out.write(buffer);
    out.sync();
  }

  private void blocksEqual() throws Exception {
    long primaryBlocks = cluster.getPrimaryAvatar(0).avatar.namesystem
        .getBlocksTotal();
View Full Code Here
41
42
43
44
45
46
47
48
49
50
51
    String fileName = "/testLeaseAfterFailover";
    FSDataOutputStream out = fs.create(new Path(fileName));
    byte[] buffer = new byte[1024];
    random.nextBytes(buffer);
    out.write(buffer);
    out.sync();

    FSNamesystem primary = cluster.getPrimaryAvatar(0).avatar.namesystem;

    // Prevents lease recovery to work.
    cluster.shutDownDataNodes();
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
  private void createRBWFile(String fileName) throws IOException {
    FSDataOutputStream out = dafs.create(new Path(fileName));
    random.nextBytes(buffer);
    out.write(buffer);
    out.sync();
  }

  private int initializeTest(String testName) throws IOException {
    String fileName = testName;
    createRBWFile(fileName);
View Full Code Here
241
242
243
244
245
246
247
248
249
250
251
      FSDataOutputStream stm = createFile(fs, file1, 1);
      System.out.println("Created file simpleFlush.dat");

      // write to file
      stm.write(fileContents, 0, blockSize/2);
      stm.sync();
      System.out.println("Wrote and Flushed first part of file.");
     
      // restart NN
      cluster.restartNameNode(0);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.