Package org.apache.hadoop.hdfs

Examples of org.apache.hadoop.hdfs.DistributedRaidFileSystem.rename()

152
153
154
155
156
157
158
159
160
161
162
      }
     
      raidFs.mkdirs(destHarPath);
      raidFs.mkdirs(new Path(destHarPath, "rename" + RaidNode.HAR_SUFFIX));
     
      raidFs.rename(new Path("/user/dikang/raidtest"),
          new Path("/user/dikang/raidtest1"));
      fail("Expected fail for HAR rename");
    } catch (IOException ie) {
      String message = ie.getMessage();
      assertTrue(message.contains("HAR dir"));
View Full Code Here
195
196
197
198
199
200
201
202
203
204
205
      parity = ParityFilePair.getParityFile(Codec.getCodec("xor"),
          destPath,
          conf);
      assertNull(parity);
      // do the rename file
      assertTrue(raidFs.rename(srcPath, destPath));
      // verify the results.
      assertFalse(raidFs.exists(srcPath));
      assertTrue(raidFs.exists(destPath));
      assertFalse(raidFs.exists(srcParityPath));
      parity = ParityFilePair.getParityFile(Codec.getCodec("xor"),
View Full Code Here
207
208
209
210
211
212
213
214
215
216
217
          conf);
      assertTrue(raidFs.exists(parity.getPath()));
     
      // rename the dir
      assertFalse(raidFs.exists(destDirPath));
      assertTrue(raidFs.rename(srcPath2.getParent(), destDirPath));
      // verify the results.
      assertFalse(raidFs.exists(srcPath2.getParent()));
      assertTrue(raidFs.exists(destDirPath));
     
      parity = ParityFilePair.getParityFile(Codec.getCodec("xor"),
View Full Code Here
153
154
155
156
157
158
159
160
161
162
163
      }
     
      raidFs.mkdirs(destHarPath);
      raidFs.mkdirs(new Path(destHarPath, "rename" + RaidNode.HAR_SUFFIX));
     
      raidFs.rename(new Path("/user/dikang/raidtest"),
          new Path("/user/dikang/raidtest1"));
      fail("Expected fail for HAR rename");
    } catch (IOException ie) {
      String message = ie.getMessage();
      assertTrue(message.contains("HAR dir"));
View Full Code Here
196
197
198
199
200
201
202
203
204
205
206
      Path srcParityPath = parity.getPath();
      assertTrue(raidFs.exists(srcParityPath));
      assertFalse(raidFs.exists(destPath));
     
      // do the rename file
      assertTrue(raidFs.rename(srcPath, destPath));
      // verify the results.
      assertFalse(raidFs.exists(srcPath));
      assertTrue(raidFs.exists(destPath));
      assertFalse(raidFs.exists(srcParityPath));
      FileStatus srcDest = fileSys.getFileStatus(destPath);
View Full Code Here
209
210
211
212
213
214
215
216
217
218
219
          conf);
      assertTrue(raidFs.exists(parity.getPath()));
     
      // rename the dir
      assertFalse(raidFs.exists(destDirPath));
      assertTrue(raidFs.rename(srcPath2.getParent(), destDirPath));
      // verify the results.
      assertFalse(raidFs.exists(srcPath2.getParent()));
      assertTrue(raidFs.exists(destDirPath));
      FileStatus srcDest2 = fileSys.getFileStatus(destPath2);
      parity = ParityFilePair.getParityFile(Codec.getCodec("xor"),
View Full Code Here
222
223
224
225
226
227
228
229
230
231
232
      assertTrue(raidFs.exists(parity.getPath()));
     
      // try to rename not existed file.
      Path notExistedPath = new Path("/user/dhruba/raidtest/raidnotexist");
      Path notExistedPath2 = new Path("/user/dhruba/raidtest/raidnotexist2");
      assertFalse(raidFs.rename(notExistedPath, notExistedPath2));
    } finally {
      stopCluster();
    }
  }
 
View Full Code Here
267
268
269
270
271
272
273
274
275
276
277
      // verify we did not delete the parityPath
      assertFalse(raidFs.exists(srcPath));
      assertTrue(raidFs.exists(srcParityPath));
     
      // test rename file
      raidFs.rename(srcPath2, new Path("/tmp/raidtest/rename/f3"));
      // verify we did not rename the parityPath
      assertFalse(raidFs.exists(srcPath2));
      assertTrue(raidFs.exists(srcParityPath2));
    } finally {
      stopCluster();
View Full Code Here
311
312
313
314
315
316
317
318
319
320
321
      Path srcParityPath2 = parity2.getPath();
      assertTrue(raidFs.exists(srcParityPath));
      assertTrue(raidFs.exists(srcParityPath2));
     
      // test rename files
      raidFs.rename(srcPath, new Path("/ignore1/test/rename/f2"));
      raidFs.rename(srcPath2, new Path("/ignore2/test/rename/f2"));
      // verify we did not rename the parityPath
      assertFalse(raidFs.exists(srcPath));
      assertTrue(raidFs.exists(srcParityPath));
      assertFalse(raidFs.exists(srcPath2));
View Full Code Here
312
313
314
315
316
317
318
319
320
321
322
      assertTrue(raidFs.exists(srcParityPath));
      assertTrue(raidFs.exists(srcParityPath2));
     
      // test rename files
      raidFs.rename(srcPath, new Path("/ignore1/test/rename/f2"));
      raidFs.rename(srcPath2, new Path("/ignore2/test/rename/f2"));
      // verify we did not rename the parityPath
      assertFalse(raidFs.exists(srcPath));
      assertTrue(raidFs.exists(srcParityPath));
      assertFalse(raidFs.exists(srcPath2));
      assertTrue(raidFs.exists(srcParityPath2));
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.