Skip to content

Commit

Permalink
comment corrections
Browse files Browse the repository at this point in the history
  • Loading branch information
johnyangk committed May 19, 2015
1 parent 26ec35a commit e0257a6
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -66,14 +66,14 @@ public static void setUpClass() throws IOException, InjectionException {
surfFs = new SurfFS();
surfFs.initialize(URI.create(SURF + "://" + SURF_ADDRESS), conf);

// FILE_SIZE < BLOCK_SIZE < PACKET_SIZE
// FILE_SIZE < PACKET_SIZE
final FSDataOutputStream stream1 = surfFs.create(new Path(SMALL), true, BUFFER_SIZE, REPLICATION, BLOCK_SIZE);
for (int i = 0; i < SMALL_SIZE; i++) {
stream1.write(b);
}
stream1.close();

// PACKET_SIZE > FILE_SIZE == BLOCK_SIZE
// PACKET_SIZE > FILE_SIZE
final FSDataOutputStream stream2 = surfFs.create(new Path(ONE_MB), true, BUFFER_SIZE, REPLICATION, BLOCK_SIZE);
for (int i = 0; i < ONE_MB_SIZE; i++) {
stream2.write(b);
Expand Down

0 comments on commit e0257a6

Please sign in to comment.