TestFileChannelFormatRegression.java 文件源码

/**
 * This is regression test with files generated by a file channel
 * with the FLUME-1432 patch.
 */
@Test
public void testFileFormatV2postFLUME1432()
        throws Exception {
  TestUtils.copyDecompressed("fileformat-v2-checkpoint.gz",
          new File(checkpointDir, "checkpoint"));
  for (int i = 0; i < dataDirs.length; i++) {
    int fileIndex = i + 1;
    TestUtils.copyDecompressed("fileformat-v2-log-" + fileIndex + ".gz",
                               new File(dataDirs[i], "log-" + fileIndex));
  }
  Map<String, String> overrides = Maps.newHashMap();
  overrides.put(FileChannelConfiguration.CAPACITY, String.valueOf(10));
  overrides.put(FileChannelConfiguration.TRANSACTION_CAPACITY,
      String.valueOf(10));
  channel = createFileChannel(overrides);
  channel.start();
  Assert.assertTrue(channel.isOpen());
  Set<String> events = takeEvents(channel, 1);
  Set<String> expected = new HashSet<String>();
  expected.addAll(Arrays.asList(
          (new String[]{
            "2684", "2685", "2686", "2687", "2688", "2689", "2690", "2691"
          })));
  compareInputAndOut(expected, events);

}