public abstract class BaseDataSetConnector extends BaseExtension
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_IMPORT
The DEFAULT IMPORT.
|
APP, COMMAND, ETL_DRIVER, FORMATTER, IDE_NODE, NO_RANK, WIDGET
Constructor and Description |
---|
BaseDataSetConnector() |
Modifier and Type | Method and Description |
---|---|
void |
addValue(Object colValue,
DataSetRecord record,
DataSet dataSet)
Adds value to the current field of the current record.
|
void |
basePostPersist(DataSetConnectorParams params,
DataSet dataSet,
Driver driver)
Executed when persisting is done.
|
StreamingCommitPolicy |
getCommitPolicy()
Gets the commit policy.
|
String |
getExt()
Gets the file ext.
|
InputStream |
getInputStream(File dataFile,
InputStream inputStream,
String preProcessor)
Gets the input stream.
|
IoProcessor |
getIoProcessor(Alias alias,
Driver driver)
Gets the io processor.
|
String |
getLicensePropertyName()
Gets the name of the license property.
|
BufferedReader |
getReader(File dataFile,
InputStream inputStream,
String encoding,
String preProcessor,
DataSetConnectorParams params)
Gets the reader.
|
String |
getType()
Gets the type of the extension module.
|
void |
postPersistWhenEmpty(DataSetConnectorParams params)
Called when DataSetConnector finished persisting data set with no
records.
|
void |
setCommitPolicy(StreamingCommitPolicy commitPolicy)
Sets the commit policy.
|
ConnectorResult |
stream(StreamingPackage streamingPackage,
Alias alias,
StreamingConnector connector)
Stream data.
|
boolean |
supportsWorksheets() |
String |
testConnection(ConnectionParams connectionParams)
Test connection.
|
compareTo, getConfigFileName, getExtensionRank, getIconPath, getLocalUnitClassPath, getXmlConfigFileName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getDisplayName, getVendor, getVersion
public static final String DEFAULT_IMPORT
public void addValue(Object colValue, DataSetRecord record, DataSet dataSet)
colValue
- the valuerecord
- the recorddataSet
- the data setpublic void basePostPersist(DataSetConnectorParams params, DataSet dataSet, Driver driver) throws Exception
params
- the parametersdataSet
- the data setdriver
- the driverException
- in case of any errorpublic void postPersistWhenEmpty(DataSetConnectorParams params)
params
- the paramspublic String getExt()
public String getLicensePropertyName()
ExtensionModule
public String getType()
ExtensionModule
public String testConnection(ConnectionParams connectionParams) throws Exception
connectionParams
- the connection paramsException
- the exceptionpublic BufferedReader getReader(File dataFile, InputStream inputStream, String encoding, String preProcessor, DataSetConnectorParams params) throws Exception
dataFile
- the data fileinputStream
- the input streamencoding
- the encodingpreProcessor
- the pre processor codeparams
- the parametersException
- in case of any errorpublic InputStream getInputStream(File dataFile, InputStream inputStream, String preProcessor) throws Exception
dataFile
- the data fileinputStream
- the input streampreProcessor
- the pre processor codeException
- in case of any errorpublic ConnectorResult stream(StreamingPackage streamingPackage, Alias alias, StreamingConnector connector) throws Exception
streamingPackage
- the streaming packagealias
- the aliasconnector
- the connectorException
- in case of any errorpublic StreamingCommitPolicy getCommitPolicy()
public void setCommitPolicy(StreamingCommitPolicy commitPolicy)
commitPolicy
- the new commit policypublic boolean supportsWorksheets()
public IoProcessor getIoProcessor(Alias alias, Driver driver)
alias
- the aliasdriver
- the driverCopyright © 2010-2020 Toolsverse. All Rights Reserved.