Repository: flume Updated Branches: refs/heads/trunk 9e28ea671 -> 5c5b96a8c
FLUME-2450 - Improve replay index insertion speed. (Hari via Brock) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/5c5b96a8 Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/5c5b96a8 Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/5c5b96a8 Branch: refs/heads/trunk Commit: 5c5b96a8c89d2fe58f1425a4ece8160b76f03f26 Parents: 9e28ea6 Author: Brock Noland <[email protected]> Authored: Fri Aug 29 12:01:03 2014 -0700 Committer: Brock Noland <[email protected]> Committed: Fri Aug 29 12:01:03 2014 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/flume/channel/file/FlumeEventQueue.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/5c5b96a8/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java ---------------------------------------------------------------------- diff --git a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java index 83309ac..d305f4d 100644 --- a/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java +++ b/flume-ng-channels/flume-file-channel/src/main/java/org/apache/flume/channel/file/FlumeEventQueue.java @@ -105,8 +105,10 @@ final class FlumeEventQueue { .syncOnCommitDisable() .deleteFilesAfterClose() .cacheDisable() + .mmapFileEnableIfSupported() .make(); - queueSet = db.createTreeSet("QueueSet").make(); + queueSet = + db.createHashSet("QueueSet " + " - " + backingStore.getName()).make(); long start = System.currentTimeMillis(); for (int i = 0; i < backingStore.getSize(); i++) { queueSet.add(get(i));
