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 © 2021 Actian Corporation. All rights reserved.