You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flume.apache.org by rg...@apache.org on 2022/03/26 19:50:19 UTC

[flume] 01/01: Merge pull request #356 from apache/FLUME-3413

This is an automated email from the ASF dual-hosted git repository.

rgoers pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/flume.git

commit 6869031c6eeca4fb533307626b05f729370ed465
Merge: ddbf12f c178981
Author: Ralph Goers <rg...@apache.org>
AuthorDate: Sat Mar 26 12:50:14 2022 -0700

    Merge pull request #356 from apache/FLUME-3413
    
    FLUME-3413 3412 - Add LoadBalancingChannelSelector and Initializable

 .mvn/local-settings.xml                            |   7 -
 .../flume/conf/channel/ChannelSelectorType.java    |   5 +
 .../channel/LoadBalancingChannelSelector.java      | 152 +++++++++++++++++++++
 .../flume/sink/AbstractSingleSinkProcessor.java    |  65 +++++++++
 .../apache/flume/sink/AbstractSinkProcessor.java   |   2 +-
 .../apache/flume/sink/DefaultSinkProcessor.java    |  39 +-----
 .../main/java/org/apache/flume/sink/NullSink.java  |   8 ++
 .../channel/TestLoadBalancingChannelSelector.java  |  72 ++++++++++
 flume-ng-doc/sphinx/FlumeDeveloperGuide.rst        |  90 ++++++++++++
 flume-ng-doc/sphinx/FlumeUserGuide.rst             |  23 ++++
 flume-ng-node/pom.xml                              |  12 ++
 .../java/org/apache/flume/node/Application.java    |  36 +++++
 .../java/org/apache/flume/node/Initializable.java  |  30 ++++
 .../org/apache/flume/node/TestApplication.java     |  67 +++++++++
 .../java/org/apache/flume/sink/NullInitSink.java   |  98 ++++++-------
 .../org/apache/flume/source/EventProcessor.java    |  33 +++++
 .../java/org/apache/flume/source/LocalSource.java  |  89 ++++++++++++
 .../src/test/resources/flume-conf-init.properties  |  51 +++++++
 flume-ng-node/src/test/resources/log4j2.xml        |   4 +-
 19 files changed, 778 insertions(+), 105 deletions(-)