public class PipelineManager extends BaseTable
| Field | Type | Description |
|---|---|---|
| ownerid | BIGINT | Reference:jobs.id |
| ordinal | BIGINT | |
| prerequisite | BIGINT | |
| outputname | VARCHAR(32) | |
| transformationname | VARCHAR(32) | |
| connectiondesc | VARCHAR(255) | |
| connectionspec | LONGTEXT |
| Modifier and Type | Field and Description |
|---|---|
static String |
_rcsid |
static String |
connectionDescriptionField |
static String |
connectionSpecField |
static String |
ordinalField |
static String |
outputNameField |
static String |
ownerIDField |
static String |
prerequisiteField |
static String |
transformationNameField |
dbInterface, tableName| Constructor and Description |
|---|
PipelineManager(IThreadContext threadContext,
IDBInterface database)
Constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
buildOutputQueryClause(StringBuilder query,
ArrayList params,
String parentIDField,
List<String> connectionNames)
Build a query clause matching a set of output connection names.
|
void |
buildTransformationQueryClause(StringBuilder query,
ArrayList params,
String parentIDField,
List<String> connectionNames)
Build a query clause matching a set of transformation connection names.
|
boolean |
compareRows(Long ownerID,
IJobDescription job)
Compare rows in job description with what's currently in the database.
|
void |
deinstall()
Uninstall.
|
void |
deleteRows(Long ownerID)
Delete rows.
|
String[] |
getOutputConnectionNames(Long ownerID)
Get all the output connection names for a job.
|
void |
getRows(Map<Long,JobDescription> returnValues,
String ownerIDList,
ArrayList ownerIDParams)
Fill in a set of pipelines corresponding to a set of owner id's.
|
String[] |
getTransformationConnectionNames(Long ownerID)
Get all the transformation connection names for a job.
|
void |
install(String ownerTable,
String owningTablePrimaryKey,
String outputTableName,
String outputTableNameField,
String transformationTableName,
String transformationTableNameField)
Install or upgrade.
|
void |
writeOutputStage(Long ownerID,
String outputConnectionName,
String outputSpecification)
Write an output stage (part of the upgrade code).
|
void |
writeRows(Long ownerID,
IJobDescription job)
Write a pipeline list into the database.
|
addTableIndex, analyzeTable, beginTransaction, buildConjunctionClause, constructCountClause, constructDistinctOnClause, constructDoubleCastClause, constructOffsetLimitClause, constructRegexpClause, constructSubstringClause, endTransaction, findConjunctionClauseMax, getDatabaseCacheKey, getDBInterface, getMaxInClause, getMaxOrClause, getSleepAmt, getTableIndexes, getTableName, getTableSchema, getTransactionID, getWindowedReportMaxRows, makeTableKey, noteModifications, performAddIndex, performAlter, performCommit, performCreate, performDelete, performDrop, performInsert, performModification, performQuery, performQuery, performRemoveIndex, performUpdate, prepareRowForSave, readRow, reindexTable, signalRollback, sleepForpublic static final String _rcsid
public static final String ownerIDField
public static final String ordinalField
public static final String prerequisiteField
public static final String outputNameField
public static final String transformationNameField
public static final String connectionDescriptionField
public static final String connectionSpecField
public PipelineManager(IThreadContext threadContext, IDBInterface database) throws ManifoldCFException
threadContext - is the thread context.database - is the database instance.ManifoldCFExceptionpublic void install(String ownerTable, String owningTablePrimaryKey, String outputTableName, String outputTableNameField, String transformationTableName, String transformationTableNameField) throws ManifoldCFException
ownerTable - is the name of the table that owns this one.owningTablePrimaryKey - is the primary key of the owning table.ManifoldCFExceptionpublic void deinstall()
throws ManifoldCFException
ManifoldCFExceptionpublic void buildTransformationQueryClause(StringBuilder query, ArrayList params, String parentIDField, List<String> connectionNames)
public void buildOutputQueryClause(StringBuilder query, ArrayList params, String parentIDField, List<String> connectionNames)
public String[] getTransformationConnectionNames(Long ownerID) throws ManifoldCFException
ownerID - is the job ID.ManifoldCFExceptionpublic String[] getOutputConnectionNames(Long ownerID) throws ManifoldCFException
ownerID - is the job ID.ManifoldCFExceptionpublic void getRows(Map<Long,JobDescription> returnValues, String ownerIDList, ArrayList ownerIDParams) throws ManifoldCFException
returnValues - is a map keyed by ownerID, with value of JobDescription.ownerIDList - is the list of owner id's.ownerIDParams - is the corresponding set of owner id parameters.ManifoldCFExceptionpublic boolean compareRows(Long ownerID, IJobDescription job) throws ManifoldCFException
ownerID - is the owning identifier.job - is a job description.ManifoldCFExceptionpublic void writeOutputStage(Long ownerID, String outputConnectionName, String outputSpecification) throws ManifoldCFException
ManifoldCFExceptionpublic void writeRows(Long ownerID, IJobDescription job) throws ManifoldCFException
ownerID - is the owning identifier.job - is the job description that is the source of the pipeline.ManifoldCFExceptionpublic void deleteRows(Long ownerID) throws ManifoldCFException
ownerID - is the owner whose rows to delete.ManifoldCFException