localManager.setBaseDir(new File("target/bucket/hdfs/dump")); // make local and hdfs base dir same
for (int i = 0; i < num; i++) {
MessageTree tree = newMessageTree(factory.getNextId(), i, now + i * 10L);
MessageId id = MessageId.parse(tree.getMessageId());
localManager.storeMessage(tree,id);
}
for (int i = 0; i < num; i++) {
String messageId = "source-7f000001-373203-" + i;
MessageTree tree = hdfsManager.loadMessage(messageId);