49505152535455
private static final Logger logger = LoggerFactory.getLogger(NullSink.class); private CounterGroup counterGroup; public NullSink() { counterGroup = new CounterGroup(); }
5859606162636465
private Thread runnerThread; private LifecycleState lifecycleState; public PollableSourceRunner() { shouldStop = new AtomicBoolean(); counterGroup = new CounterGroup(); lifecycleState = LifecycleState.IDLE; }
36373839404142
private long sequence; private CounterGroup counterGroup; public SequenceGeneratorSource() { sequence = 0; counterGroup = new CounterGroup(); }
111112113114115116117118
public NetcatSource() { super(); port = 0; counterGroup = new CounterGroup(); acceptThreadShouldStop = new AtomicBoolean(); }
126127128129130131132
port = Integer.parseInt(context.getString("port")); host = context.getString("host"); } public ThriftLegacySource() { counterGroup = new CounterGroup(); }
5455565758596061
private Event event; private List<Event> eventBatchList; private List<Event> eventBatchListToProcess; public StressSource() { counterGroup = new CounterGroup(); }
6061626364656667
51525354555657
private ScheduledExecutorService executorService; private CounterGroup counterGroup; public AbstractFileConfigurationProvider() { lifecycleState = LifecycleState.IDLE; counterGroup = new CounterGroup(); }
50515253545556
4041424344454647
private PollingRunner runner; private Thread runnerThread; private LifecycleState lifecycleState; public PollableSinkRunner() { counterGroup = new CounterGroup(); lifecycleState = LifecycleState.IDLE; }