public class EventProcessorController extends Object
EventProcessor
s.Constructor and Description |
---|
EventProcessorController(EventProcessingConfiguration eventProcessingConfiguration) |
Modifier and Type | Method and Description |
---|---|
EventProcessor |
getEventProcessor(String processorName) |
void |
onPause(Consumer<String> consumer) |
void |
onStart(Consumer<String> consumer) |
void |
pauseProcessor(String processor) |
void |
releaseSegment(String processor,
int segmentId) |
void |
startProcessor(String processor) |
public EventProcessorController(EventProcessingConfiguration eventProcessingConfiguration)
public EventProcessor getEventProcessor(String processorName)
public void pauseProcessor(String processor)
public void startProcessor(String processor)
public void releaseSegment(String processor, int segmentId)
Copyright © 2010–2018. All rights reserved.