public class CsvConnector extends AbstractConnector
cfgDir, dnaPool, log, MESSAGE_RECORDING_FORMAT_BINARY, MESSAGE_RECORDING_FORMAT_XML
Constructor and Description |
---|
CsvConnector(java.lang.String name) |
Modifier and Type | Method and Description |
---|---|
java.lang.String[] |
getColumns() |
java.lang.String |
getFilename() |
int |
getIdColumn() |
java.lang.String |
getIdField() |
static ServiceType |
getMetaData()
This static method returns all the details of the class without it having
to be constructed.
|
int |
getNumFields() |
java.lang.String |
getSeparator() |
void |
initialize() |
void |
setColumns(java.lang.String... columns) |
void |
setConfig(ConnectorConfig config) |
void |
setFilename(java.lang.String filename) |
void |
setIdColumn(int idColumn) |
void |
setIdField(java.lang.String idField) |
void |
setNumFields(int numFields) |
void |
setSeparator(java.lang.String separator) |
void |
startCrawling() |
void |
stopCrawling() |
addDocumentListener, feed, flush, getBatchSize, getConnectorState, getDocIdPrefix, getState, publishDocument, publishDocuments, publishFlush, setBatchSize, setDocIdPrefix, setState
addListener, addListener, addTask, addTask, addTask, addTaskOneShot, allowDisplay, allowDisplay, attach, attach, broadcastState, buildDna, buildDna, buildDnaKeys, buildDnaNames, clearLastError, close, containsTask, copyShallowFrom, createPeer, createPeer, createRootReserved, detach, detach, detach, echoHeartbeat, error, error, error, getAttached, getCfgDir, getComm, getDeclaredMethodNames, getDeclaredMethods, getDescription, getDna, getDnaString, getHostName, getInbox, getInstanceId, getIntanceName, getInterfaceSet, getLastError, getMessageSet, getMetaData, getMethodMap, getMethodNames, getMethods, getMethodToolTip, getMsg, getName, getNotifyList, getNotifyListKeySet, getOutbox, getPeerKey, getPeerName, getServiceResourceFile, getSimpleName, getTasks, getThisThread, getType, hasError, hasPeers, help, help, in, info, info, invoke, invoke, invoke, invokeOn, isAttached, isAttached, isLocal, isReady, isRunning, isRuntime, isVirtual, load, load, logTimeEnable, mergeDna, mergeDna, mergePeerDna, movePeerDna, out, out, preProcessHook, preRoutingHook, publishError, publishQueueStats, publishState, publishStats, publishStatus, purgeTask, purgeTasks, releasePeers, releaseService, removeAllListeners, removeListener, requiresSecurity, reserve, reserve, reserveRoot, reserveRoot, reserveRootAs, run, save, save, save, send, send, send, send, sendBlocking, sendBlocking, sendBlocking, sendBlocking, sendPeer, setInstanceId, setName, setPeer, setSecurityProvider, setState, setThisThread, setVirtual, sleep, stackToString, startHeartbeat, startPeer, startPeer, startRecording, startService, stopHeartbeat, stopMsgRecording, stopService, subscribe, subscribe, subscribe, toString, unsubscribe, unsubscribe, unsubscribe, updateStats, warn, warn
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
getName
public void setConfig(ConnectorConfig config)
setConfig
in class AbstractConnector
public void initialize()
public void startCrawling()
public void stopCrawling()
public java.lang.String getFilename()
public void setFilename(java.lang.String filename)
public java.lang.String[] getColumns()
public void setColumns(java.lang.String... columns)
public java.lang.String getIdField()
public void setIdField(java.lang.String idField)
public java.lang.String getSeparator()
public void setSeparator(java.lang.String separator)
public int getNumFields()
public void setNumFields(int numFields)
public int getIdColumn()
public void setIdColumn(int idColumn)
public static ServiceType getMetaData()