Package | Description |
---|---|
com.pervasive.datarush.operators.io.jdbc |
Provides operators for reading from JDBC sources and writing to JDBC targets.
|
com.pervasive.datarush.operators.io.paraccel |
Modifier and Type | Field and Description |
---|---|
protected JDBCConnector |
AbstractWriteToJDBC.AbstractWriteHelper.connector |
Modifier and Type | Method and Description |
---|---|
JDBCConnector |
AbstractWriteToJDBC.AbstractWriteToJDBCWorker.getConnector() |
protected JDBCConnector |
JDBCOperator.getJDBCConnector() |
JDBCConnector |
InitializeSQLWorker.getProperties() |
JDBCConnector |
FinalizeSQLWorker.getProperties() |
Modifier and Type | Method and Description |
---|---|
protected abstract AbstractWriteToJDBC.AbstractWriteHelper |
AbstractWriteToJDBC.AbstractWriteToJDBCWorker.createWriteHelper(JDBCConnector connector,
RecordPort input,
RecordPort output,
ExecutionContext ctx,
String onEveryRecordStatement,
AbstractWriteToJDBC.SqlWriteProperties sqlWriteProperties) |
static Namespace<JDBCField> |
ConnectionHelper.getMetadata(JDBCConnector connector,
String statement)
Acquires the metadata associated with a given SQL statement.
|
protected void |
JDBCOperator.setJDBCConnector(JDBCConnector jdbcConnector) |
Constructor and Description |
---|
AbstractWriteHelper(JDBCConnector connector,
RecordPort input,
ExecutionContext ctx,
String onEveryRecordStatement,
AbstractWriteToJDBC.SqlWriteProperties properties) |
AbstractWriteToJDBCWorker(JDBCConnector connector,
String onEveryRecordStatement,
AbstractWriteToJDBC.SqlWriteProperties sqlWriteProperties) |
FinalizeSQLWorker(JDBCConnector properties,
String finalizeTableSQL) |
InitializeSQLWorker(JDBCConnector properties,
String initializeTableSQL) |
Modifier and Type | Method and Description |
---|---|
JDBCConnector |
LoadMatrixDataWorker.getConnector() |
Constructor and Description |
---|
LoadMatrixDataWorker(com.pervasive.datarush.operators.io.paraccel.TableInfo tableInfo,
List<String> columns,
Map<String,String> columnMap,
int logFrequency,
int retryCount,
int startPortRange,
int endPortRange,
JDBCConnector connector) |
Copyright © 2016 Actian Corporation. All rights reserved.