flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From br...@apache.org
Subject git commit: FLUME-2450 - Improve replay index insertion speed. (Hari via Brock)
Date Fri, 29 Aug 2014 19:01:58 GMT
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 <brock@apache.org>
Authored: Fri Aug 29 12:01:03 2014 -0700
Committer: Brock Noland <brock@apache.org>
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));


Mime
View raw message