Package org.apache.flume

Examples of org.apache.flume.CounterGroup

60
61
62
63
64
65
66
67
  private Thread runnerThread;
  private LifecycleState lifecycleState;

  public PollableSourceRunner() {
    shouldStop = new AtomicBoolean();
    counterGroup = new CounterGroup();
    lifecycleState = LifecycleState.IDLE;
  }
View Full Code Here
120
121
122
123
124
125
126
127
  public NetcatSource() {
    super();

    port = 0;
    counterGroup = new CounterGroup();
    acceptThreadShouldStop = new AtomicBoolean(false);
  }
View Full Code Here
57
58
59
60
61
62
63
64
  private Thread runnerThread;
  private LifecycleState lifecycleState;

  public PollableSourceRunner() {
    shouldStop = new AtomicBoolean();
    counterGroup = new CounterGroup();
    lifecycleState = LifecycleState.IDLE;
  }
View Full Code Here
37
38
39
40
41
42
43
  private long sequence;
  private CounterGroup counterGroup;

  public SequenceGeneratorSource() {
    sequence = 0;
    counterGroup = new CounterGroup();
  }
View Full Code Here
111
112
113
114
115
116
117
118
  public NetcatSource() {
    super();

    port = 0;
    counterGroup = new CounterGroup();
    acceptThreadShouldStop = new AtomicBoolean();
  }
View Full Code Here
106
107
108
109
110
111
112
  private Server server;
  private CounterGroup counterGroup;

  public AvroSource() {
    counterGroup = new CounterGroup();
  }
View Full Code Here
123
124
125
126
127
128
129
130
131
132
133
  @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.channel = getChannel();
View Full Code Here
57
58
59
60
61
62
63
  private CounterGroup counterGroup;
  private int batchSize = DFLT_BATCH_SIZE;
  private int logEveryNEvents = DFLT_LOG_EVERY_N_EVENTS;

  public NullSink() {
    counterGroup = new CounterGroup();
  }
View Full Code Here
122
123
124
125
126
127
128
129
  public NetcatSource() {
    super();

    port = 0;
    counterGroup = new CounterGroup();
    acceptThreadShouldStop = new AtomicBoolean(false);
  }
View Full Code Here
50
51
52
53
54
55
56
57
      File file, EventBus eventBus, int interval) {
    super(agentName, file);
    this.eventBus = eventBus;
    this.file = file;
    this.interval = interval;
    counterGroup = new CounterGroup();
    lifecycleState = LifecycleState.IDLE;
  }
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.