Modifier and Type | Method and Description |
---|---|
Alias |
IoProcessorCallable.getAlias()
Gets the alias.
|
Alias |
Alias.getConnectionParams() |
Alias |
Alias.getParentAlias()
Gets the parent alias.
|
Modifier and Type | Method and Description |
---|---|
void |
IoProcessorCallable.configure(Alias alias,
TypedKeyValue<String,String> urlPath,
IoProcessor ioProcessor)
Configure callable.
|
static void |
CommonEtlUtils.processFiles(Alias alias,
IoProcessorCallable callable,
boolean disconnect,
boolean closeIfNotDone,
boolean doneOnDone,
String ownerName,
Driver driver)
Process files for the give alias.
|
static void |
CommonEtlUtils.processFiles(Alias alias,
IoProcessorCallable callable,
boolean disconnect,
Driver driver)
Process files for the give alias.
|
Constructor and Description |
---|
DefaultIoProcessorCallable(Alias alias,
String catalog)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
Alias |
SourceConnectorParams.alias2alias(Alias source) |
Alias |
FileConnectorParams.alias2alias(Alias source) |
abstract Alias |
DataSetConnectorParams.alias2alias(Alias source)
Creates an new Alias object using given source alias.
|
Alias |
FileConnectorParams.getAlias()
Gets the alias.
|
Alias |
FileConnectorParams.getOriginalAlias()
Gets the original alias.
|
Modifier and Type | Method and Description |
---|---|
Alias |
SourceConnectorParams.alias2alias(Alias source) |
Alias |
FileConnectorParams.alias2alias(Alias source) |
abstract Alias |
DataSetConnectorParams.alias2alias(Alias source)
Creates an new Alias object using given source alias.
|
boolean |
FileConnectorParams.deserializeToInputStream(IoProcessorCallable ioProcessorCallable,
String fileName,
Alias alias,
TypedKeyValue<String,String> fileNameToRead)
Deserialize data into inputstream.
|
TypedKeyValue<Boolean,String> |
FileConnectorParams.getFileNameIfFileSystem(String fileName,
String ownerName,
Alias alias,
IoProcessor ioProcessor)
Gets the file name if IO processor is a file system.
|
String |
SourceConnectorParams.getInitStr(String name,
Alias alias) |
String |
FileConnectorParams.getInitStr(String name,
Alias alias) |
abstract String |
DataSetConnectorParams.getInitStr(String name,
Alias alias)
Gets the initialization string using given alias.
|
IoProcessor |
BaseDataSetConnector.getIoProcessor(Alias alias,
Driver driver)
Gets the io processor.
|
void |
SourceConnectorParams.init(Alias alis) |
void |
FileConnectorParams.init(Alias alis) |
abstract void |
DataSetConnectorParams.init(Alias alias)
Initializes itself using given alias.
|
ConnectorResult |
BaseDataSetConnector.stream(StreamingPackage streamingPackage,
Alias alias,
StreamingConnector connector)
Stream data.
|
Modifier and Type | Method and Description |
---|---|
String |
ExcelConnectorParams.getInitStr(String name,
Alias alias) |
void |
ExcelConnectorParams.init(Alias alis) |
Modifier and Type | Method and Description |
---|---|
void |
HtmlConnectorParams.init(Alias alis) |
Modifier and Type | Method and Description |
---|---|
void |
JsonDatasetConnectorParams.init(Alias alis) |
void |
JsonConnectorParams.init(Alias alis) |
Modifier and Type | Method and Description |
---|---|
void |
PdfConnectorParams.init(Alias alis) |
Modifier and Type | Method and Description |
---|---|
Alias |
SqlConnectorParams.alias2alias(Alias source) |
Modifier and Type | Method and Description |
---|---|
Alias |
SqlConnectorParams.alias2alias(Alias source) |
String |
SqlConnectorParams.getInitStr(String name,
Alias alias) |
void |
SqlConnectorParams.init(Alias alis) |
Modifier and Type | Method and Description |
---|---|
void |
TextConnectorParams.init(Alias alis) |
void |
KeyValueConnectorParams.init(Alias alis) |
void |
ClobConnectorParams.init(Alias alias) |
Modifier and Type | Method and Description |
---|---|
void |
XmlObjectConnectorParams.init(Alias alis) |
void |
XmlConnectorParams.init(Alias alais) |
Modifier and Type | Method and Description |
---|---|
Map<String,Alias> |
EtlConfig.getAliasesMap()
Gets the map of the aliases.
|
Modifier and Type | Method and Description |
---|---|
void |
EtlConfig.addAlias(Alias alias)
Adds the alias to the map using alias name.
|
void |
EtlConfig.addAliasToMap(String name,
Alias alias)
Adds the alias to the map using given name.
|
void |
EtlConfig.addConnection(Alias alias,
String name,
String defName)
Creates (if needed) and adds the connection using given alias.
|
Modifier and Type | Method and Description |
---|---|
TypedKeyValue<String,EtlConfig.CREATE_CONFIG_ERRORS> |
EtlConfig.createConfig(String fileName,
String scriptName,
Map<String,Alias> connections,
Map<String,String> vars,
int action,
boolean override)
Create ETL configuration file.
|
TypedKeyValue<String,EtlConfig.CREATE_CONFIG_ERRORS> |
EtlConfig.createConfig(String fileName,
String scriptName,
Map<String,Alias> connections,
Map<String,String> vars,
int action,
boolean override,
String scenarioXml)
Create ETL configuration file.
|
void |
EtlConfig.setAliasesMap(Map<String,Alias> value)
Sets the map of aliases.
|
Modifier and Type | Method and Description |
---|---|
void |
MetadataTracker.createTableAndIndexesOrChangeFieldDataTypeIfNeeded(Scenario scenario,
EtlConfig config,
Destination destination,
DataSet dataSet,
Alias alias,
CodeGen codeGen)
Creates the table and indexes or change field data type if needed.
|
Modifier and Type | Method and Description |
---|---|
static Alias |
FileManagerTask.getAlias(EtlConfig config,
String connectionName)
Gets the alias by connection name.
|
static Alias |
FileManagerTask.updateAlias(EtlConfig config,
String connectionName,
String fileName)
Update alias url using given file name.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
FileManagerTask.delete(Alias alias,
String fileName)
Delete file or resource.
|
static boolean |
FileManagerTask.filesExist(Alias alias,
String wildcard)
Check if files exist using given alias and wildcard file name.
|
static String |
FileManagerTask.getFileName(Alias alias,
String fileName,
boolean createFolder)
Get the fully qualified file name from the given connection and base file
name.
|
static List<FileResource> |
FileManagerTask.list(Alias alias,
String wildcard)
Get the list of files for the connection and wildcard.
|
static List<FileResource> |
FileManagerTask.list(Alias alias,
String wildcard,
Set<String> excludedObjects,
Set<String> includedObjects)
Get the list of files for the connection and wildcard.
|
static String |
FileManagerTask.read(Alias alias,
String fileName)
Read data from the given source.
|
static InputStream |
FileManagerTask.readAsStream(Alias alias,
String fileName)
Read data from the given source.
|
static boolean |
FileManagerTask.write(Alias alias,
String fileName,
Object payload)
Send payload to the given destination.
|
static String |
FileManagerTask.write(Alias alias,
String fileName,
Object payload,
boolean createFolder)
Send payload to the given destination.
|
Modifier and Type | Method and Description |
---|---|
static String |
EtlUtils.getDbId(Alias alias,
String delim)
Gets the database id by parsing url.
|
Modifier and Type | Method and Description |
---|---|
Object |
Driver.getAutotrace(ObjectStorage storage,
Connection connection,
Alias alias,
String sql)
Executes sql and produces real execution plan.
|
Object |
AbstractDriver.getAutotrace(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
String |
GenericJdbcDriver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile) |
String |
GenericFileDriver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile) |
String |
Driver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile)
Gets the command line for the external tool.
|
static String |
AbstractDriver.getCmdOptions(Alias alias)
Gets the command line options.
|
TypedKeyValue<String,String> |
Driver.getConnectionFile(Alias alias)
Gets the connection aliases file for the database, for example
tnsnames.ora.
|
TypedKeyValue<String,String> |
AbstractDriver.getConnectionFile(Alias alias) |
Object |
GenericJdbcDriver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
Object |
GenericFileDriver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
Object |
Driver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql)
Gets the explain plan for the sql.
|
String |
GenericJdbcDriver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser) |
String |
GenericFileDriver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser) |
String |
Driver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser)
Gets the sql for external tool.
|
Modifier and Type | Method and Description |
---|---|
Object |
Db2Driver.getAutotrace(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
String |
Db2Driver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile) |
static String |
Db2Driver.getDbName(Alias alias)
Gets the database name.
|
Object |
Db2Driver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
String |
Db2Driver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser) |
Modifier and Type | Method and Description |
---|---|
Object |
InformixDriver.getAutotrace(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
String |
InformixDriver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile) |
static String |
InformixDriver.getDbName(Alias alias)
Gets the database name.
|
Object |
InformixDriver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
static String |
InformixDriver.getServer(Alias alias)
Gets the informix server name.
|
String |
InformixDriver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser) |
Modifier and Type | Method and Description |
---|---|
String |
MySqlDriver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile) |
static String[] |
MySqlDriver.getDbName(Alias alias)
Gets the database name.
|
Object |
MySqlDriver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
String |
MySqlDriver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser) |
Modifier and Type | Method and Description |
---|---|
String |
OracleDriver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile) |
TypedKeyValue<String,String> |
OracleDriver.getConnectionFile(Alias alias) |
static String |
OracleDriver.getDbName(Alias alias)
Gets the database name.
|
static String |
OracleDriver.getEasyConnect(Alias alias)
Gets the easy connect string.
|
Object |
OracleDriver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
static String |
OracleDriver.getRole(Alias alias)
Gets the role.
|
static String |
OracleDriver.getServiceName(Alias alias)
Gets the service name or sid.
|
String |
OracleDriver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser) |
Modifier and Type | Method and Description |
---|---|
Object |
PostgresDriver.getAutotrace(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
String |
PostgresDriver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile) |
static String[] |
PostgresDriver.getDbName(Alias alias)
Gets the database name.
|
Object |
PostgresDriver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
String |
PostgresDriver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser) |
Modifier and Type | Method and Description |
---|---|
String |
SnowflakeDriver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile) |
Object |
SnowflakeDriver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
String |
SnowflakeDriver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser) |
Modifier and Type | Method and Description |
---|---|
Object |
MsSqlDriver.getAutotrace(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
String |
SybaseDriver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile) |
String |
MsSqlDriver.getCmdForExternalTool(ObjectStorage storage,
Alias alias,
String sqlFile) |
static String |
SybaseDriver.getDbName(Alias alias)
Gets the database name.
|
static String |
MsSqlDriver.getDbName(Alias alias)
Gets the database name.
|
Object |
SybaseDriver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
Object |
MsSqlDriver.getExplainPlan(ObjectStorage storage,
Connection connection,
Alias alias,
String sql) |
static String |
SybaseDriver.getServer(Alias alias)
Gets the server name.
|
static String |
MsSqlDriver.getServer(Alias alias,
String subst)
Gets the server name.
|
String |
SybaseDriver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser) |
String |
MsSqlDriver.getSqlForExternalTool(Alias alias,
String sql,
SqlParser parser) |
Modifier and Type | Method and Description |
---|---|
ConnectionParamsProvider<Alias> |
Metadata.getConnectionParamsProvider()
Gets the connection params provider.
|
ConnectionParamsProvider<Alias> |
BaseMetadata.getConnectionParamsProvider() |
Modifier and Type | Method and Description |
---|---|
DataSet |
BaseMetadata.getColumns(Alias alias,
DataSet dataSet,
DataSetConnectorParams params,
DataSetConnector connector)
Gets the columns.
|
static List<String> |
JdbcMetadata.getDbObjectsByWildcard(String wildcard,
Alias alias,
Driver driver,
Set<String> excludedObjects,
Set<String> includedObjects,
boolean includeViews,
boolean includeTables)
Gets the database objects by a wildcard.
|
DataSet |
BaseMetadata.getDefaultColumns(Alias alias,
DataSet dataSet)
Gets the default columns.
|
Modifier and Type | Method and Description |
---|---|
void |
Metadata.init(ConnectionFactory connectionFactory,
ConnectionParamsProvider<Alias> connectionParamsProvider,
Driver driver)
Initializes metadata driver.
|
void |
BaseMetadata.init(ConnectionFactory connectionFactory,
ConnectionParamsProvider<Alias> connectionParamsProvider,
Driver driver) |
Modifier and Type | Method and Description |
---|---|
Alias |
SqlConfig.getAlias(String name)
Gets the alias by name.
|
Modifier and Type | Method and Description |
---|---|
Alias |
DummyConnectionFactory.getConnectionParams() |
Modifier and Type | Method and Description |
---|---|
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
ConnectionCallback.before(Alias alias,
Properties properties)
The callback function executed before connection is established.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ConnectionCallback.after(Connection connection,
Alias alias,
Properties properties)
The callback function executed after connection is established.
|
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
ConnectionCallback.before(Alias alias,
Properties properties)
The callback function executed before connection is established.
|
protected Connection |
PooledAliasConnectionProvider.createConnection(Alias alias) |
protected Connection |
AliasConnectionProvider.createConnection(Alias alias)
Creates the jdbc connection.
|
protected Connection |
PooledAliasConnectionProvider.createConnection(Alias alias,
Properties props) |
protected Connection |
AliasConnectionProvider.createConnection(Alias alias,
Properties props)
Creates the jdbc connection.
|
Connection |
AliasSessionConnectionProvider.getConnection(Alias params) |
Connection |
AliasConnectionProvider.getConnection(Alias alias) |
Connection |
AliasSessionConnectionProvider.getConnection(Alias params,
boolean isNew) |
protected Connection |
AliasConnectionProvider.getJndiConnection(Alias alias)
Gets the database connection using jndi
|
void |
AliasSessionConnectionProvider.releaseConnection(Alias params) |
Constructor and Description |
---|
SshTunnel(Alias alias,
Properties props)
Instantiates a new ssh tunnel.
|
Modifier and Type | Method and Description |
---|---|
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
MySqlConnectionCallback.before(Alias alias,
Properties properties) |
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
HubspotConnectionCallback.before(Alias alias,
Properties properties) |
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
ExchangeConnectionCallback.before(Alias alias,
Properties properties) |
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
ConfluenceConnectionCallback.before(Alias alias,
Properties properties) |
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
ApiDriverConnectionCallback.before(Alias alias,
Properties properties) |
Modifier and Type | Method and Description |
---|---|
boolean |
MySqlConnectionCallback.after(Connection connection,
Alias alias,
Properties properties) |
boolean |
HubspotConnectionCallback.after(Connection connection,
Alias alias,
Properties properties) |
boolean |
ExchangeConnectionCallback.after(Connection connection,
Alias alias,
Properties properties) |
boolean |
ConfluenceConnectionCallback.after(Connection connection,
Alias alias,
Properties properties) |
boolean |
ApiDriverConnectionCallback.after(Connection connection,
Alias alias,
Properties properties) |
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
MySqlConnectionCallback.before(Alias alias,
Properties properties) |
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
HubspotConnectionCallback.before(Alias alias,
Properties properties) |
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
ExchangeConnectionCallback.before(Alias alias,
Properties properties) |
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
ConfluenceConnectionCallback.before(Alias alias,
Properties properties) |
TypedKeyValue<TypedKeyValue<Properties,Alias>,Boolean> |
ApiDriverConnectionCallback.before(Alias alias,
Properties properties) |
Modifier and Type | Method and Description |
---|---|
ConnectionParamsProvider<Alias> |
SqlRequest.getConnectionParamsProvider()
Gets the connection params provider.
|
SessionConnectionProvider<Alias> |
SqlRequest.getProvider()
Gets the connection provider.
|
Modifier and Type | Method and Description |
---|---|
void |
SqlServiceImpl.commitTransaction(SessionConnectionProvider<Alias> provider,
Alias params,
boolean closeOnCommit) |
void |
SqlService.commitTransaction(SessionConnectionProvider<Alias> provider,
Alias params,
boolean closeOnCommit)
Commits current transaction.
|
void |
SqlServiceImpl.releaseConnection(SessionConnectionProvider<Alias> provider,
Alias params) |
void |
SqlService.releaseConnection(SessionConnectionProvider<Alias> provider,
Alias params)
Releases connection.
|
void |
SqlServiceImpl.rollbackTransaction(SessionConnectionProvider<Alias> provider,
Alias params,
boolean closeOnRollback) |
void |
SqlService.rollbackTransaction(SessionConnectionProvider<Alias> provider,
Alias params,
boolean closeOnRollback)
Rollbacks current transaction.
|
Modifier and Type | Method and Description |
---|---|
void |
SqlServiceImpl.cancel(SessionConnectionProvider<Alias> provider) |
void |
SqlService.cancel(SessionConnectionProvider<Alias> provider)
Cancels currently executed sql.
|
void |
SqlServiceImpl.commitTransaction(SessionConnectionProvider<Alias> provider,
Alias params,
boolean closeOnCommit) |
void |
SqlService.commitTransaction(SessionConnectionProvider<Alias> provider,
Alias params,
boolean closeOnCommit)
Commits current transaction.
|
void |
SqlServiceImpl.releaseConnection(SessionConnectionProvider<Alias> provider,
Alias params) |
void |
SqlService.releaseConnection(SessionConnectionProvider<Alias> provider,
Alias params)
Releases connection.
|
void |
SqlServiceImpl.rollbackTransaction(SessionConnectionProvider<Alias> provider,
Alias params,
boolean closeOnRollback) |
void |
SqlService.rollbackTransaction(SessionConnectionProvider<Alias> provider,
Alias params,
boolean closeOnRollback)
Rollbacks current transaction.
|
void |
SqlRequest.setConnectionParamsProvider(ConnectionParamsProvider<Alias> paramsProvider)
Sets the connection params provider.
|
void |
SqlRequest.setProvider(SessionConnectionProvider<Alias> provider)
Sets the connection provider.
|
Constructor and Description |
---|
SqlRequest(SessionConnectionProvider<Alias> provider,
ConnectionParamsProvider<Alias> paramsProvider,
SqlParser parser,
Driver driver,
Map<String,Object> properties,
String sql,
boolean hasParams,
boolean doNotLog)
Instantiates a new sql request.
|
SqlRequest(SessionConnectionProvider<Alias> provider,
ConnectionParamsProvider<Alias> paramsProvider,
SqlParser parser,
Driver driver,
Map<String,Object> properties,
String sql,
boolean hasParams,
boolean doNotLog)
Instantiates a new sql request.
|
SqlRequest(SessionConnectionProvider<Alias> provider,
ConnectionParamsProvider<Alias> paramsProvider,
SqlParser parser,
Driver driver,
Map<String,Object> properties,
String sql,
boolean hasParams,
boolean commit,
boolean close,
boolean doNotLog)
Instantiates a new sql request.
|
SqlRequest(SessionConnectionProvider<Alias> provider,
ConnectionParamsProvider<Alias> paramsProvider,
SqlParser parser,
Driver driver,
Map<String,Object> properties,
String sql,
boolean hasParams,
boolean commit,
boolean close,
boolean doNotLog)
Instantiates a new sql request.
|
SqlRequest(SessionConnectionProvider<Alias> provider,
ConnectionParamsProvider<Alias> paramsProvider,
SqlParser parser,
Driver driver,
Map<String,Object> properties,
String sql,
boolean hasParams,
boolean commit,
boolean close,
int maxRows,
boolean doNotLog)
Instantiates a new sql request.
|
SqlRequest(SessionConnectionProvider<Alias> provider,
ConnectionParamsProvider<Alias> paramsProvider,
SqlParser parser,
Driver driver,
Map<String,Object> properties,
String sql,
boolean hasParams,
boolean commit,
boolean close,
int maxRows,
boolean doNotLog)
Instantiates a new sql request.
|
Copyright © 2010-2020 Toolsverse. All Rights Reserved.