public class SinkGroupConfiguration extends ComponentConfiguration
ComponentConfiguration.ComponentType
componentName, configured, errors
Constructor and Description |
---|
SinkGroupConfiguration(String name) |
Modifier and Type | Method and Description |
---|---|
void |
configure(Context context) |
Context |
getProcessorContext() |
SinkProcessorConfiguration |
getSinkProcessorConfiguration() |
List<String> |
getSinks() |
void |
setProcessorContext(Context processorContext) |
void |
setSinkProcessorConfiguration(SinkProcessorConfiguration conf) |
void |
setSinks(List<String> sinks) |
failIfConfigured, getComponentName, getErrors, getType, isNotFoundConfigClass, setConfigured, setNotFoundConfigClass, setType, toString, toString
public SinkGroupConfiguration(String name)
public void configure(Context context) throws ConfigurationException
configure
in class ComponentConfiguration
ConfigurationException
public Context getProcessorContext()
public void setProcessorContext(Context processorContext)
public SinkProcessorConfiguration getSinkProcessorConfiguration()
public void setSinkProcessorConfiguration(SinkProcessorConfiguration conf)
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.