public class SourceConnector extends Object implements DataSetConnector<SourceConnectorParams,ConnectorResult>
Constructor and Description |
---|
SourceConnector() |
Modifier and Type | Method and Description |
---|---|
boolean |
canRead()
Checks if connector can read data.
|
boolean |
canWrite()
Checks if connector can write data.
|
void |
cleanUp(SourceConnectorParams params,
DataSet dataSet,
Driver driver)
Cleans up after DataSetConnector populated or persisted DataSet.
|
SourceConnectorParams |
getDataSetConnectorParams()
Gets the DataSetConnectorParams.
|
String |
getExt()
Gets the file ext.
|
String |
getName()
Gets the name.
|
String |
initQueryLabel()
The init query label.
|
void |
inlinePersist(SourceConnectorParams params,
DataSet dataSet,
Driver driver,
DataSetRecord record,
int row,
int records)
Persists data set row.
|
boolean |
isFileConnector()
Checks if this is a connector to the file based data source.
|
boolean |
isTextFormat()
Checks if this is a connector for the text-based data format, such as
JOSN, XML, etc.
|
ConnectorResult |
persist(SourceConnectorParams params,
DataSet dataSet,
Driver driver)
Persists data set.
|
ConnectorResult |
populate(SourceConnectorParams params,
DataSet dataSet,
Driver driver)
Populates data set.
|
void |
postPersist(SourceConnectorParams params,
DataSet dataSet,
Driver driver)
Called when DataSetConnector finished persisting data set.
|
void |
prePersist(SourceConnectorParams params,
DataSet dataSet,
Driver driver)
Called when DataSetConnector starts persisting data set.
|
boolean |
supportsNested()
Supports nested.
|
boolean |
supportsReadStreaming()
Supports read streaming.
|
boolean |
supportsWorksheets()
Checks if connector supports worksheets.
|
boolean |
supportsWriteStreaming()
Supports write streaming.
|
String |
testConnection(ConnectionParams connectionParams)
Tests the connection.
|
ConnectorResult |
writeMetaData(SourceConnectorParams params,
DataSet dataSet,
Driver driver)
Writes meta data.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
supportsReordering
public boolean supportsReadStreaming()
DataSetConnector
supportsReadStreaming
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public boolean supportsWriteStreaming()
DataSetConnector
supportsWriteStreaming
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public boolean canRead()
DataSetConnector
canRead
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public boolean canWrite()
DataSetConnector
canWrite
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public void cleanUp(SourceConnectorParams params, DataSet dataSet, Driver driver) throws Exception
DataSetConnector
cleanUp
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
params
- the DataSetConnectorParamsdataSet
- the data setdriver
- the driverException
- in case of any errorpublic SourceConnectorParams getDataSetConnectorParams()
DataSetConnector
getDataSetConnectorParams
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public String getExt()
DataSetConnector
getExt
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public String getName()
DataSetConnector
getName
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public void inlinePersist(SourceConnectorParams params, DataSet dataSet, Driver driver, DataSetRecord record, int row, int records) throws Exception
DataSetConnector
inlinePersist
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
params
- the DataSetConnectorParamsdataSet
- the data setdriver
- the driverrecord
- the recordrow
- the rowrecords
- the total number of recordsException
- in case of any errorpublic boolean isFileConnector()
DataSetConnector
isFileConnector
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public boolean isTextFormat()
DataSetConnector
isTextFormat
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public ConnectorResult persist(SourceConnectorParams params, DataSet dataSet, Driver driver) throws Exception
DataSetConnector
persist
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
params
- the DataSetConnectorParamsdataSet
- the data setdriver
- the driverException
- in case of any errorpublic ConnectorResult populate(SourceConnectorParams params, DataSet dataSet, Driver driver) throws Exception
DataSetConnector
populate
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
params
- the DataSetConnectorParamsdataSet
- the data setdriver
- the driverException
- in case of any errorpublic void postPersist(SourceConnectorParams params, DataSet dataSet, Driver driver) throws Exception
DataSetConnector
postPersist
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
params
- the DataSetConnectorParamsdataSet
- the data setdriver
- the driverException
- in case of any errorpublic void prePersist(SourceConnectorParams params, DataSet dataSet, Driver driver) throws Exception
DataSetConnector
prePersist
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
params
- the DataSetConnectorParamsdataSet
- the data setdriver
- the driverException
- in case of any errorpublic String testConnection(ConnectionParams connectionParams) throws Exception
DataSetConnector
testConnection
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
connectionParams
- the connection paramsException
- the exception in case of any errorpublic ConnectorResult writeMetaData(SourceConnectorParams params, DataSet dataSet, Driver driver) throws Exception
DataSetConnector
writeMetaData
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
params
- the DataSetConnectorParamsdataSet
- the data setdriver
- the driverException
- in case of any errorpublic String initQueryLabel()
DataSetConnector
initQueryLabel
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public boolean supportsNested()
DataSetConnector
supportsNested
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
public boolean supportsWorksheets()
DataSetConnector
supportsWorksheets
in interface DataSetConnector<SourceConnectorParams,ConnectorResult>
Copyright © 2010-2020 Toolsverse. All Rights Reserved.