Return-Path: X-Original-To: apmail-flume-commits-archive@www.apache.org Delivered-To: apmail-flume-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id A46DD18DB0 for ; Wed, 29 Jul 2015 21:21:08 +0000 (UTC) Received: (qmail 20529 invoked by uid 500); 29 Jul 2015 21:21:08 -0000 Delivered-To: apmail-flume-commits-archive@flume.apache.org Received: (qmail 20500 invoked by uid 500); 29 Jul 2015 21:21:08 -0000 Mailing-List: contact commits-help@flume.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flume.apache.org Delivered-To: mailing list commits@flume.apache.org Received: (qmail 20491 invoked by uid 99); 29 Jul 2015 21:21:08 -0000 Received: from eris.apache.org (HELO hades.apache.org) (140.211.11.105) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 29 Jul 2015 21:21:08 +0000 Received: from hades.apache.org (localhost [127.0.0.1]) by hades.apache.org (ASF Mail Server at hades.apache.org) with ESMTP id 47477AC0321 for ; Wed, 29 Jul 2015 21:21:08 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Subject: svn commit: r960084 - in /websites/staging/flume/trunk/content: ./ .doctrees/FlumeUserGuide.doctree .doctrees/environment.pickle FlumeUserGuide.html _sources/FlumeUserGuide.txt Date: Wed, 29 Jul 2015 21:21:08 -0000 To: commits@flume.apache.org From: buildbot@apache.org X-Mailer: svnmailer-1.0.9 Message-Id: <20150729212108.47477AC0321@hades.apache.org> Author: buildbot Date: Wed Jul 29 21:21:07 2015 New Revision: 960084 Log: Staging update by buildbot for flume Modified: websites/staging/flume/trunk/content/ (props changed) websites/staging/flume/trunk/content/.doctrees/FlumeUserGuide.doctree websites/staging/flume/trunk/content/.doctrees/environment.pickle websites/staging/flume/trunk/content/FlumeUserGuide.html websites/staging/flume/trunk/content/_sources/FlumeUserGuide.txt Propchange: websites/staging/flume/trunk/content/ ------------------------------------------------------------------------------ --- cms:source-revision (original) +++ cms:source-revision Wed Jul 29 21:21:07 2015 @@ -1 +1 @@ -1693347 +1693348 Modified: websites/staging/flume/trunk/content/.doctrees/FlumeUserGuide.doctree ============================================================================== Binary files - no diff available. Modified: websites/staging/flume/trunk/content/.doctrees/environment.pickle ============================================================================== Binary files - no diff available. Modified: websites/staging/flume/trunk/content/FlumeUserGuide.html ============================================================================== --- websites/staging/flume/trunk/content/FlumeUserGuide.html (original) +++ websites/staging/flume/trunk/content/FlumeUserGuide.html Wed Jul 29 21:21:07 2015 @@ -5800,44 +5800,38 @@ not to throw any exception from the impl Additional parameters can be passed to EventValitor implementation via -D options.

Let’s see an example of simple size based Event Validator, which shall reject event’s larger than maximum size specified.

-

-

System Message: ERROR/3 (/usr/home/cmsslave/slave15/flume-site-staging/build/trunk/content/sphinx/FlumeUserGuide.rst, line 3793)

-

Error in “code-block” directive: -maximum 1 argument(s) allowed, 8 supplied.

-

.. code-block:: java
-  public static class MyEventValidator implements EventValidator {
-
-    private int value = 0;
-
-    private MyEventValidator(int val) {
-      value = val;
-    }
-
-    @Override
-    public boolean validateEvent(Event event) {
-      return event.getBody() <= value;
-    }
-
-    public static class Builder implements EventValidator.Builder {
-
-      private int sizeValidator = 0;
-
-      @Override
-      public EventValidator build() {
-        return new DummyEventVerifier(sizeValidator);
-      }
-
-      @Override
-      public void configure(Context context) {
-        binaryValidator = context.getInteger("maxSize");
-      }
-    }
-  }
+public static class MyEventValidator implements EventValidator {
+
+  private int value = 0;
+
+  private MyEventValidator(int val) {
+    value = val;
+  }
+
+  @Override
+  public boolean validateEvent(Event event) {
+    return event.getBody() <= value;
+  }
+
+  public static class Builder implements EventValidator.Builder {
+
+    private int sizeValidator = 0;
+
+    @Override
+    public EventValidator build() {
+      return new DummyEventVerifier(sizeValidator);
+    }
+
+    @Override
+    public void configure(Context context) {
+      binaryValidator = context.getInteger("maxSize");
+    }
+  }
+}
 

-

Topology Design ConsiderationsÂ¶

Flume is very flexible and allows a large range of possible deployment Modified: websites/staging/flume/trunk/content/_sources/FlumeUserGuide.txt ============================================================================== --- websites/staging/flume/trunk/content/_sources/FlumeUserGuide.txt (original) +++ websites/staging/flume/trunk/content/_sources/FlumeUserGuide.txt Wed Jul 29 21:21:07 2015 @@ -3791,6 +3791,7 @@ Let's see an example of simple size base than maximum size specified. .. code-block:: java + public static class MyEventValidator implements EventValidator { private int value = 0;