Repository: flume Updated Branches: refs/heads/flume-1.6 42d8f95a8 -> c0364d0a9
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/c0364d0a Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/c0364d0a Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/c0364d0a Branch: refs/heads/flume-1.6 Commit: c0364d0a9f89706ce05d310af5af61888d22ce6d Parents: 42d8f95 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:29 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/c0364d0a/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));
