com.datastax.oss.dsbulk.workflow.commons.settings

Class ConnectorSettings

java.lang.Object

com.datastax.oss.dsbulk.workflow.commons.settings.ConnectorSettings

public class ConnectorSettings
extends Object

Constructor Summary

Constructors

Constructor and Description
ConnectorSettings(Config config, boolean read)

Method Summary

Modifier and Type	Method and Description
Connector	getConnector()
Config	getConnectorConfig()
String	getConnectorName()
void	init(boolean retainRecordSources)
protected Connector	locateConnector(String name)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectorSettings

public ConnectorSettings(Config config,
                         boolean read)

Method Detail

init

public void init(boolean retainRecordSources)

Parameters:

retainRecordSources - Whether the connector should retain sources in records; if true, the connector will emit records containing the original line that they were parsed from as their sources.

getConnector

public Connector getConnector()
                       throws IllegalArgumentException

Throws:

IllegalArgumentException

getConnectorName

public String getConnectorName()

getConnectorConfig

public Config getConnectorConfig()

locateConnector

protected Connector locateConnector(String name)