Package org.apache.flume

Examples of org.apache.flume.CounterGroup

119
120
121
122
123
124
125
    public void unknown(String a, String b, String c, String d) {
    }
  }

  public IRCSink() {
    counterGroup = new CounterGroup();
  }
View Full Code Here
31
32
33
34
35
36
37
  private CounterGroup counterGroup;

  @Before
  public void setUp() {
    counterGroup = new CounterGroup();
  }
View Full Code Here
51
52
53
54
55
56
57
  private ScheduledExecutorService executorService;
  private CounterGroup counterGroup;

  public AbstractFileConfigurationProvider() {
    lifecycleState = LifecycleState.IDLE;
    counterGroup = new CounterGroup();
  }
View Full Code Here
96
97
98
99
100
101
102
  private int port;
  private SpecificResponder res;
  private HttpServer http;

  public AvroLegacySource() {
    counterGroup = new CounterGroup();
  }
View Full Code Here
104
105
106
107
108
109
110
  private Server server;
  private CounterGroup counterGroup;

  public AvroSource() {
    counterGroup = new CounterGroup();
  }
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
  @Override
  public void start() {
    logger.info("Exec source starting with command:{}", command);

    executor = Executors.newSingleThreadExecutor();
    counterGroup = new CounterGroup();

    ExecRunnable runner = new ExecRunnable();

    runner.command = command;
    runner.channelProcessor = getChannelProcessor();
View Full Code Here
59
60
61
62
63
64
65
66
67
  private EventFormatter formatter;
  private volatile boolean shouldRotate;

  public RollingFileSink() {
    formatter = new TextDelimitedOutputFormatter();
    counterGroup = new CounterGroup();
    pathController = new PathManager();
    shouldRotate = false;
  }
View Full Code Here
120
121
122
123
124
125
126
    port = Integer.parseInt(context.getString("port"));
    host = context.getString("host");
  }

  public ThriftLegacySource() {
    counterGroup = new CounterGroup();
  }
View Full Code Here
115
116
117
118
119
120
121
  private RpcClient client;
  private CounterGroup counterGroup;

  public AvroSink() {
    counterGroup = new CounterGroup();
  }
View Full Code Here
170
171
172
173
174
175
176
    public CounterGroup counterGroup;
    private LifecycleState lifecycleState;

    public CountingLifecycleAware() {
      lifecycleState = LifecycleState.IDLE;
      counterGroup = new CounterGroup();
    }
View Full Code Here
TOP

Related Classes of org.apache.flume.CounterGroup

  • org.apache.flume.conf.file.AbstractFileConfigurationProvider
  • org.apache.flume.lifecycle.TestLifecycleSupervisor$CountingLifecycleAware
  • org.apache.flume.node.PollingPropertiesFileConfigurationProvider
  • org.apache.flume.sink.AvroSink
  • org.apache.flume.sink.irc.IRCSink
  • org.apache.flume.sink.NullSink
  • org.apache.flume.sink.PollableSinkRunner
  • org.apache.flume.sink.RollingFileSink
  • org.apache.flume.source.avroLegacy.AvroLegacySource
  • org.apache.flume.source.AvroSource
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.