@InterfaceStability.Unstable public abstract class SourceConnector extends Connector
context
SourceConnector()
config, initialize, initialize, reconfigure, start, stop, taskClass, taskConfigs, validate, version
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public SourceConnector()