| Package | Description |
|---|---|
| com.pervasive.datarush.operators.io |
Provides base file I/O components including encoders and decoders.
|
| com.pervasive.datarush.operators.io.jdbc |
Provides operators for reading from JDBC sources and writing to JDBC targets.
|
| com.pervasive.datarush.operators.io.paraccel | |
| com.pervasive.datarush.operators.io.vectorwise | |
| com.pervasive.datarush.operators.io.vectorwise.dl |
| Modifier and Type | Method and Description |
|---|---|
static void |
SQLWorkerUtil.executeSql(JDBCConnector connection,
String sql) |
| 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) |
| Modifier and Type | Method and Description |
|---|---|
static String[] |
Vectorwise.getAllUniqueKeys(JDBCConnector connector) |
static String[] |
Vectorwise.getPrimaryKeys(JDBCConnector connector) |
static String[] |
Vectorwise.getSortKeys(JDBCConnector connector) |
static String[] |
Vectorwise.getUniqueKeys(JDBCConnector connector) |
static int |
Vectorwise.getUniqueKeysSize(JDBCConnector connector) |
| Constructor and Description |
|---|
VW5Validator(JDBCConnector connector) |
| Modifier and Type | Method and Description |
|---|---|
static com.pervasive.datarush.operators.io.vectorwise.dl.FinalizeWorker |
VectorDirectWorkerFactory.getDirectFinalizeWorker(JDBCConnector jdbc,
String instance,
String database,
int port,
String finalizeTableSQL) |
static com.pervasive.datarush.operators.io.vectorwise.dl.InitializeWorker |
VectorDirectWorkerFactory.getDirectInitializeWorker(JDBCConnector jdbc,
String instance,
String database,
int port,
String insertMode,
int partitions,
String initializeTableSQL) |
Copyright © 2020 Actian Corporation. All rights reserved.