|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.pentaho.di.repository.Repository
public class Repository
This class handles interactions with a Kettle repository.
Constructor Summary | |
---|---|
Repository(org.pentaho.di.core.logging.LogWriter log,
RepositoryMeta repinfo,
UserInfo userinfo)
|
Method Summary | |
---|---|
static String |
byteArrayToString(byte[] val)
GZips and then base64 encodes an array of bytes to a String |
void |
clearNextIDCounters()
|
void |
closeJobAttributeLookupPreparedStatement()
|
void |
closeLookupJobEntryAttribute()
|
void |
closeStepAttributeInsertPreparedStatement()
|
void |
closeStepAttributeLookupPreparedStatement()
|
void |
closeTransAttributeInsertPreparedStatement()
|
void |
closeTransAttributeLookupPreparedStatement()
|
void |
commit()
|
boolean |
connect(boolean no_lookup,
boolean readDirectory,
String locksource)
|
boolean |
connect(boolean no_lookup,
boolean readDirectory,
String locksource,
boolean ignoreVersion)
|
boolean |
connect(String locksource)
Connect to the repository |
int |
countJobParameter(long id_job)
Count the number of parameters of a job. |
int |
countNrJobAttributes(long id_job,
String code)
|
int |
countNrJobEntryAttributes(long id_jobentry,
String code)
|
int |
countNrStepAttributes(long id_step,
String code)
|
int |
countNrTransAttributes(long id_transformation,
String code)
|
int |
countTransParameter(long id_transformation)
Count the number of parameters of a transaction. |
void |
createRepositorySchema(org.pentaho.di.core.ProgressMonitorListener monitor,
boolean upgrade,
List<String> statements,
boolean dryRun)
Create or upgrade repository tables & fields, populate lookup tables, ... |
void |
delAllFromJob(long id_job)
|
void |
delAllFromTrans(long id_transformation)
|
void |
delClusterSchema(long id_cluster)
|
void |
delClusterSlaves(long id_cluster)
|
void |
delCondition(long id_condition)
|
void |
delDatabase(long id_database)
|
void |
delDatabaseAttributes(long id_database)
|
void |
delDependencies(long id_transformation)
|
void |
deleteDirectory(long id_directory)
|
void |
delJob(long id_job)
|
void |
delJobAttributes(long id_job)
|
void |
delJobEntries(long id_job)
|
void |
delJobEntryAttributes(long id_job)
|
void |
delJobEntryCopies(long id_job)
|
void |
delJobHops(long id_job)
|
void |
delJobNotes(long id_job)
|
void |
delPartitions(long id_partition_schema)
|
void |
delPartitionSchema(long id_partition_schema)
|
void |
delPartitionSchemas(long id_transformation)
|
void |
delProfile(long id_profile)
|
void |
delProfilePermissions(long id_profile)
|
void |
delSlave(long id_slave)
|
void |
delStepAttributes(long id_transformation)
|
void |
delStepConditions(long id_transformation)
|
void |
delStepDatabases(long id_transformation)
Delete the relationships between the transformation/steps and the databases. |
void |
delSteps(long id_transformation)
|
void |
delTrans(long id_transformation)
|
void |
delTransAttributes(long id_transformation)
|
void |
delTransformationClusters(long id_transformation)
|
void |
delTransformationSlaves(long id_transformation)
|
void |
delTransHops(long id_transformation)
|
void |
delTransNotes(long id_transformation)
|
void |
delTransStepCondition(long id_transformation)
|
void |
delUser(long id_user)
|
void |
delValue(long id_value)
|
void |
disconnect()
|
boolean |
dropRepositorySchema()
|
void |
exportAllObjects(org.pentaho.di.core.ProgressMonitorListener monitor,
String xmlFilename,
RepositoryDirectory root,
String exportType)
|
void |
fillStepAttributesBuffer(long id_transformation)
|
long |
findStepAttributeID(long id_step,
int nr,
String code)
|
long |
getClusterID(String name)
|
long[] |
getClusterIDs()
|
String[] |
getClusterNames()
|
org.pentaho.di.core.RowMetaAndData |
getClusterSchema(long id_cluster_schema)
|
String[] |
getClustersUsingSlave(long id_slave)
|
org.pentaho.di.core.RowMetaAndData |
getCondition(long id_condition)
|
long[] |
getConditionIDs(long id_transformation)
|
static Repository |
getCurrentRepository()
Deprecated. this is not thread safe |
org.pentaho.di.core.database.Database |
getDatabase()
|
org.pentaho.di.core.RowMetaAndData |
getDatabase(long id_database)
|
org.pentaho.di.core.RowMetaAndData |
getDatabaseAttribute(long id_database_attribute)
|
long[] |
getDatabaseAttributeIDs(long id_database)
|
Collection<org.pentaho.di.core.RowMetaAndData> |
getDatabaseAttributes()
|
Collection<org.pentaho.di.core.RowMetaAndData> |
getDatabaseAttributes(long id_database)
|
String |
getDatabaseConTypeCode(long id_database_contype)
|
long |
getDatabaseConTypeID(String code)
|
long |
getDatabaseID(String name)
|
long[] |
getDatabaseIDs()
|
long[] |
getDatabaseIDs(long id_transformation)
|
org.pentaho.di.core.database.DatabaseMeta |
getDatabaseMeta()
|
String[] |
getDatabaseNames()
|
List<org.pentaho.di.core.database.DatabaseMeta> |
getDatabases()
|
String |
getDatabaseTypeCode(long id_database_type)
|
long |
getDatabaseTypeID(String code)
|
long |
getDependencyID(long id_transformation,
long id_database,
String tablename)
|
org.pentaho.di.core.RowMetaAndData |
getDirectory(long id_directory)
|
String[] |
getDirectoryNames(long id_directory)
|
RepositoryDirectory |
getDirectoryTree()
|
RepositoryDirectory |
getImportBaseDirectory()
The directory set during import to signal that job entries like Trans and Job need to point to job entries relative to this directory |
org.pentaho.di.core.RowMetaAndData |
getJob(long id_job)
|
boolean |
getJobAttributeBoolean(long id_job,
int nr,
String code)
|
long |
getJobAttributeInteger(long id_job,
int nr,
String code)
|
double |
getJobAttributeNumber(long id_job,
int nr,
String code)
|
org.pentaho.di.core.RowMetaAndData |
getJobAttributeRow(long id_job,
int nr,
String code)
|
List<Object[]> |
getJobAttributes(long id_job,
String code,
long nr)
|
String |
getJobAttributeString(long id_job,
int nr,
String code)
|
org.pentaho.di.core.RowMetaAndData |
getJobEntry(long id_jobentry)
|
boolean |
getJobEntryAttributeBoolean(long id_jobentry,
int nr,
String code)
|
boolean |
getJobEntryAttributeBoolean(long id_jobentry,
int nr,
String code,
boolean def)
|
boolean |
getJobEntryAttributeBoolean(long id_jobentry,
String code)
|
boolean |
getJobEntryAttributeBoolean(long id_jobentry,
String code,
boolean def)
|
long |
getJobEntryAttributeInteger(long id_jobentry,
int nr,
String code)
|
long |
getJobEntryAttributeInteger(long id_jobentry,
String code)
|
double |
getJobEntryAttributeNumber(long id_jobentry,
int nr,
String code)
|
double |
getJobEntryAttributeNumber(long id_jobentry,
String code)
|
String |
getJobEntryAttributeString(long id_jobentry,
int nr,
String code)
|
String |
getJobEntryAttributeString(long id_jobentry,
String code)
|
org.pentaho.di.core.RowMetaAndData |
getJobEntryCopy(long id_jobentry_copy)
|
long[] |
getJobEntryCopyIDs(long id_job)
|
long[] |
getJobEntryCopyIDs(long id_job,
long id_jobentry)
|
long |
getJobEntryID(String name,
long id_job)
|
long[] |
getJobEntryIDs(long id_job)
|
org.pentaho.di.core.RowMetaAndData |
getJobEntryType(long id_jobentry_type)
|
long |
getJobEntryTypeID(String code)
|
org.pentaho.di.core.RowMetaAndData |
getJobHop(long id_job_hop)
|
long |
getJobHopID(long id_job,
long id_jobentry_copy_from,
long id_jobentry_copy_to)
|
long[] |
getJobHopIDs(long id_job)
|
long |
getJobID(String name,
long id_directory)
|
String[] |
getJobNames()
|
String[] |
getJobNames(long id_directory)
|
long[] |
getJobNoteIDs(long id_job)
|
List<RepositoryObject> |
getJobObjects(long id_directory)
|
String |
getJobParameterDefault(long id_job,
int nr)
Get a job parameter default. |
String |
getJobParameterDescription(long id_job,
int nr)
Get a job parameter description. |
String |
getJobParameterKey(long id_job,
int nr)
Get a job parameter key. |
String |
getLocksource()
|
int |
getMajorVersion()
Return the major repository version. |
int |
getMinorVersion()
Return the minor repository version. |
String |
getName()
|
long |
getNextClusterID()
|
long |
getNextClusterSlaveID()
|
long |
getNextConditionID()
|
long |
getNextDatabaseAttributeID()
|
long |
getNextDatabaseConnectionTypeID()
|
long |
getNextDatabaseID()
|
long |
getNextDatabaseTypeID()
|
long |
getNextDepencencyID()
|
long |
getNextDirectoryID()
|
long |
getNextID(String tableName,
String fieldName)
|
long |
getNextJobAttributeID()
|
long |
getNextJobEntryAttributeID()
|
long |
getNextJobEntryCopyID()
|
long |
getNextJobEntryID()
|
long |
getNextJobEntryTypeID()
|
long |
getNextJobHopID()
|
long |
getNextJobID()
|
long |
getNextLogID()
|
long |
getNextLoglevelID()
|
long |
getNextNoteID()
|
long |
getNextPartitionID()
|
long |
getNextPartitionSchemaID()
|
long |
getNextPermissionID()
|
long |
getNextProfileID()
|
long |
getNextSlaveServerID()
|
long |
getNextStepAttributeID()
|
long |
getNextStepID()
|
long |
getNextStepTypeID()
|
long |
getNextTransAttributeID()
|
long |
getNextTransformationClusterID()
|
long |
getNextTransformationID()
|
long |
getNextTransformationPartitionSchemaID()
|
long |
getNextTransformationSlaveID()
|
long |
getNextTransHopID()
|
long |
getNextUserID()
|
long |
getNextValueID()
|
org.pentaho.di.core.RowMetaAndData |
getNote(long id_note)
|
long |
getNoteID(String note)
|
int |
getNrConditions(long id_transforamtion)
|
int |
getNrDatabaseAttributes(long id_database)
|
int |
getNrDatabases()
|
int |
getNrDatabases(long id_transforamtion)
|
int |
getNrDirectories(long id_directory)
|
int |
getNrJobEntries(long id_job)
|
int |
getNrJobEntryCopies(long id_job)
|
int |
getNrJobEntryCopies(long id_job,
long id_jobentry)
|
int |
getNrJobHops(long id_job)
|
int |
getNrJobNotes(long id_job)
|
int |
getNrJobs()
|
int |
getNrJobs(long id_directory)
|
int |
getNrPermissions(long id_profile)
|
int |
getNrProfiles()
|
int |
getNrStepAttributes(long id_step)
|
int |
getNrStepDatabases(long id_database)
|
int |
getNrSteps(long id_transformation)
|
int |
getNrSubConditions(long id_condition)
|
int |
getNrSubDirectories(long id_directory)
|
int |
getNrTransDependencies(long id_transformation)
|
int |
getNrTransformations(long id_directory)
|
int |
getNrTransHops(long id_transformation)
|
int |
getNrTransNotes(long id_transformation)
|
int |
getNrUsers()
|
org.pentaho.di.core.RowMetaAndData |
getPartition(long id_partition)
|
long[] |
getPartitionIDs(long id_partition_schema)
|
org.pentaho.di.core.RowMetaAndData |
getPartitionSchema(long id_partition_schema)
|
long |
getPartitionSchemaID(String name)
|
long[] |
getPartitionSchemaIDs()
|
String[] |
getPartitionSchemaNames()
|
org.pentaho.di.core.RowMetaAndData |
getPermission(long id_permission)
|
long |
getPermissionID(String code)
|
long[] |
getPermissionIDs(long id_profile)
|
org.pentaho.di.core.RowMetaAndData |
getProfile(long id_profile)
|
long |
getProfileID(String profilename)
|
String[] |
getProfiles()
|
RepositoryMeta |
getRepositoryInfo()
|
static String |
getRequiredVersion()
Get the required repository version for this version of Kettle. |
long |
getRootDirectoryID()
|
long |
getSlaveID(String name)
|
long[] |
getSlaveIDs()
|
long[] |
getSlaveIDs(long id_cluster_schema)
|
String[] |
getSlaveNames()
|
org.pentaho.di.core.RowMetaAndData |
getSlaveServer(long id_slave)
|
List<SlaveServer> |
getSlaveServers()
|
org.pentaho.di.core.RowMetaAndData |
getStep(long id_step)
|
org.pentaho.di.core.RowMetaAndData |
getStepAttribute(long id_step_attribute)
|
boolean |
getStepAttributeBoolean(long id_step,
int nr,
String code)
|
boolean |
getStepAttributeBoolean(long id_step,
int nr,
String code,
boolean def)
|
boolean |
getStepAttributeBoolean(long id_step,
String code)
|
long |
getStepAttributeInteger(long id_step,
int nr,
String code)
|
long |
getStepAttributeInteger(long id_step,
String code)
|
List<Object[]> |
getStepAttributesBuffer()
|
org.pentaho.di.core.row.RowMetaInterface |
getStepAttributesRowMeta()
|
String |
getStepAttributeString(long id_step,
int nr,
String code)
|
String |
getStepAttributeString(long id_step,
String code)
|
org.pentaho.di.core.RowMetaAndData |
getStepDatabase(long id_step)
|
long |
getStepID(String name,
long id_transformation)
|
long[] |
getStepIDs(long id_transformation)
|
org.pentaho.di.core.RowMetaAndData |
getStepType(long id_step_type)
|
String |
getStepTypeCode(long id_database_type)
|
long |
getStepTypeID(String code)
|
long[] |
getSubConditionIDs(long id_condition)
|
long[] |
getSubDirectoryIDs(long id_directory)
|
boolean |
getTransAttributeBoolean(long id_transformation,
int nr,
String code)
|
long |
getTransAttributeInteger(long id_transformation,
int nr,
String code)
|
double |
getTransAttributeNumber(long id_transformation,
int nr,
String code)
|
org.pentaho.di.core.RowMetaAndData |
getTransAttributeRow(long id_transformation,
int nr,
String code)
|
List<Object[]> |
getTransAttributes(long id_transformation,
String code,
long nr)
|
String |
getTransAttributeString(long id_transformation,
int nr,
String code)
|
org.pentaho.di.core.RowMetaAndData |
getTransDependency(long id_dependency)
|
long[] |
getTransDependencyIDs(long id_transformation)
|
org.pentaho.di.core.RowMetaAndData |
getTransformation(long id_transformation)
|
long[] |
getTransformationClusterSchemaIDs(long id_transformation)
|
long |
getTransformationID(String name,
long id_directory)
|
String[] |
getTransformationNames(long id_directory)
|
List<RepositoryObject> |
getTransformationObjects(long id_directory)
|
long[] |
getTransformationPartitionSchemaIDs(long id_transformation)
|
String[] |
getTransformationsUsingCluster(long id_cluster)
|
String[] |
getTransformationsUsingDatabase(long id_database)
|
String[] |
getTransformationsUsingPartitionSchema(long id_partition_schema)
|
String[] |
getTransformationsUsingSlave(long id_slave)
|
org.pentaho.di.core.RowMetaAndData |
getTransHop(long id_trans_hop)
|
long |
getTransHopID(long id_transformation,
long id_step_from,
long id_step_to)
|
long[] |
getTransHopIDs(long id_transformation)
|
long[] |
getTransNoteIDs(long id_transformation)
|
String |
getTransParameterDefault(long id_transformation,
int nr)
Get a transformation parameter default. |
String |
getTransParameterDescription(long id_transformation,
int nr)
Get a transformation parameter description. |
String |
getTransParameterKey(long id_transformation,
int nr)
Get a transformation parameter key. |
org.pentaho.di.core.RowMetaAndData |
getUser(long id_user)
|
long |
getUserID(String login)
|
long[] |
getUserIDs()
|
UserInfo |
getUserInfo()
|
String[] |
getUserLogins()
|
org.pentaho.di.core.RowMetaAndData |
getValue(long id_value)
|
String |
getVersion()
Get the repository version. |
long |
insertCluster(ClusterSchema clusterSchema)
|
long |
insertClusterSlave(ClusterSchema clusterSchema,
SlaveServer slaveServer)
|
long |
insertCondition(long id_condition_parent,
Condition condition)
|
long |
insertDatabase(String name,
String type,
String access,
String host,
String dbname,
String port,
String user,
String pass,
String servername,
String data_tablespace,
String index_tablespace)
|
long |
insertDatabaseAttribute(long id_database,
String code,
String value_str)
|
long |
insertDependency(long id_transformation,
long id_database,
String tablename,
String fieldname)
|
long |
insertDirectory(long id_directory_parent,
RepositoryDirectory dir)
|
void |
insertJob(JobMeta jobMeta)
|
long |
insertJobAttribute(long id_job,
long nr,
String code,
long value_num,
String value_str)
|
long |
insertJobEntry(long id_job,
JobEntryBase jobEntryBase)
|
long |
insertJobEntryAttribute(long id_job,
long id_jobentry,
long nr,
String code,
double value_num,
String value_str)
|
long |
insertJobEntryCopy(long id_job,
long id_jobentry,
long id_jobentry_type,
int nr,
long gui_location_x,
long gui_location_y,
boolean gui_draw,
boolean parallel)
|
long |
insertJobHop(long id_job,
long id_jobentry_copy_from,
long id_jobentry_copy_to,
boolean enabled,
boolean evaluation,
boolean unconditional)
|
void |
insertJobNote(long id_job,
long id_note)
|
void |
insertJobParameter(long id_job,
long nr,
String key,
String defValue,
String description)
Insert a parameter for a job in the repository. |
long |
insertLogEntry(String description)
|
long |
insertNote(String note,
long gui_location_x,
long gui_location_y,
long gui_location_width,
long gui_location_height)
|
long |
insertPartition(long id_partition_schema,
String partition_id)
|
long |
insertPartitionSchema(PartitionSchema partitionSchema)
|
long |
insertSlave(SlaveServer slaveServer)
|
long |
insertStep(long id_transformation,
String name,
String description,
String steptype,
boolean distribute,
long copies,
long gui_location_x,
long gui_location_y,
boolean gui_draw)
|
long |
insertStepAttribute(long id_transformation,
long id_step,
long nr,
String code,
double value_num,
String value_str)
|
void |
insertStepDatabase(long id_transformation,
long id_step,
long id_database)
|
void |
insertTableRow(String tablename,
org.pentaho.di.core.RowMetaAndData values)
|
long |
insertTransAttribute(long id_transformation,
long nr,
String code,
long value_num,
String value_str)
|
void |
insertTransformation(TransMeta transMeta)
|
long |
insertTransformationCluster(long id_transformation,
long id_cluster)
|
long |
insertTransformationPartitionSchema(long id_transformation,
long id_partition_schema)
|
long |
insertTransformationSlave(long id_transformation,
long id_slave)
|
long |
insertTransHop(long id_transformation,
long id_step_from,
long id_step_to,
boolean enabled)
|
void |
insertTransNote(long id_transformation,
long id_note)
|
void |
insertTransParameter(long id_transformation,
long nr,
String key,
String defValue,
String description)
Insert a parameter for a transformation in the repository. |
void |
insertTransStepCondition(long id_transformation,
long id_step,
long id_condition)
|
long |
insertValue(String name,
String type,
String value_str,
boolean isnull,
long id_value_prev)
|
boolean |
isUseBatchProcessing()
|
void |
lockRepository()
|
long |
lookupValue(String name,
String type,
String value_str,
boolean isnull)
|
void |
moveJob(String jobname,
long id_directory_from,
long id_directory_to)
|
void |
moveTransformation(String transname,
long id_directory_from,
long id_directory_to)
|
String |
quote(String identifier)
|
List<org.pentaho.di.core.database.DatabaseMeta> |
readDatabases()
Read all the databases defined in the repository |
void |
refreshRepositoryDirectoryTree()
|
void |
renameDatabase(long id_database,
String newname)
|
void |
renameDirectory(long id_directory,
String name)
|
void |
renameJob(long id_job,
String newname)
|
void |
renameProfile(long id_profile,
String newname)
|
void |
renameTransformation(long id_transformation,
String newname)
|
void |
renameUser(long id_user,
String newname)
|
void |
rollback()
|
long |
saveJobEntryAttribute(long id_job,
long id_jobentry,
long nr,
String code,
boolean value)
|
long |
saveJobEntryAttribute(long id_job,
long id_jobentry,
long nr,
String code,
double value)
|
long |
saveJobEntryAttribute(long id_job,
long id_jobentry,
long nr,
String code,
String value)
|
long |
saveJobEntryAttribute(long id_job,
long id_jobentry,
String code,
boolean value)
|
long |
saveJobEntryAttribute(long id_job,
long id_jobentry,
String code,
double value)
|
long |
saveJobEntryAttribute(long id_job,
long id_jobentry,
String code,
String value)
|
long |
saveStepAttribute(long id_transformation,
long id_step,
long nr,
String code,
boolean value)
|
long |
saveStepAttribute(long id_transformation,
long id_step,
long nr,
String code,
double value)
|
long |
saveStepAttribute(long id_transformation,
long id_step,
long nr,
String code,
String value)
|
long |
saveStepAttribute(long id_transformation,
long id_step,
String code,
boolean value)
|
long |
saveStepAttribute(long id_transformation,
long id_step,
String code,
double value)
|
long |
saveStepAttribute(long id_transformation,
long id_step,
String code,
String value)
|
void |
setAutoCommit(boolean autocommit)
|
static void |
setCurrentRepository(Repository currentRepository)
Deprecated. this is not thread safe |
void |
setDatabase(org.pentaho.di.core.database.Database database)
|
void |
setDirectoryTree(RepositoryDirectory directoryTree)
|
void |
setImportBaseDirectory(RepositoryDirectory importBaseDirectory)
Set this directory during import to signal that job entries like Trans and Job need to point to job entries relative to this directory. |
void |
setLookupJobAttribute()
|
void |
setLookupJobEntryAttribute()
|
void |
setLookupStepAttribute()
|
void |
setLookupTransAttribute()
|
void |
setStepAttributesBuffer(List<Object[]> stepAttributesBuffer)
|
void |
setStepAttributesRowMeta(org.pentaho.di.core.row.RowMetaInterface stepAttributesRowMeta)
|
void |
setUseBatchProcessing(boolean useBatchProcessing)
|
void |
setUserInfo(UserInfo userinfo)
|
String |
toString()
|
void |
unlockRepository()
|
void |
updateDatabase(long id_database,
String name,
String type,
String access,
String host,
String dbname,
String port,
String user,
String pass,
String servername,
String data_tablespace,
String index_tablespace)
|
void |
updateJobEntryTypes()
Update the list in R_JOBENTRY_TYPE |
void |
updatePartitionSchema(PartitionSchema partitionSchema)
|
void |
updateSlave(SlaveServer slaveServer)
|
void |
updateStepTypes()
Update the list in R_STEP_TYPE using the StepLoader StepPlugin entries |
void |
updateTableRow(String tablename,
String idfield,
org.pentaho.di.core.RowMetaAndData values)
|
void |
updateTableRow(String tablename,
String idfield,
org.pentaho.di.core.RowMetaAndData values,
long id)
|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final String TABLE_R_VERSION
public static final String FIELD_VERSION_ID_VERSION
public static final String FIELD_VERSION_MAJOR_VERSION
public static final String FIELD_VERSION_MINOR_VERSION
public static final String FIELD_VERSION_IS_UPGRADE
public static final String FIELD_VERSION_UPGRADE_DATE
public static final String TABLE_R_REPOSITORY_LOG
public static final String FIELD_REPOSITORY_LOG_ID_REPOSITORY_LOG
public static final String FIELD_REPOSITORY_LOG_REP_VERSION
public static final String FIELD_REPOSITORY_LOG_LOG_DATE
public static final String FIELD_REPOSITORY_LOG_LOG_USER
public static final String FIELD_REPOSITORY_LOG_OPERATION_DESC
public static final String TABLE_R_DATABASE_TYPE
public static final String FIELD_DATABASE_TYPE_ID_DATABASE_TYPE
public static final String FIELD_DATABASE_TYPE_CODE
public static final String FIELD_DATABASE_TYPE_DESCRIPTION
public static final String TABLE_R_DATABASE_CONTYPE
public static final String FIELD_DATABASE_CONTYPE_ID_DATABASE_CONTYPE
public static final String FIELD_DATABASE_CONTYPE_CODE
public static final String FIELD_DATABASE_CONTYPE_DESCRIPTION
public static final String TABLE_R_DATABASE
public static final String FIELD_DATABASE_ID_DATABASE
public static final String FIELD_DATABASE_NAME
public static final String FIELD_DATABASE_ID_DATABASE_TYPE
public static final String FIELD_DATABASE_ID_DATABASE_CONTYPE
public static final String FIELD_DATABASE_HOST_NAME
public static final String FIELD_DATABASE_DATABASE_NAME
public static final String FIELD_DATABASE_PORT
public static final String FIELD_DATABASE_USERNAME
public static final String FIELD_DATABASE_DATA_TBS
public static final String FIELD_DATABASE_PASSWORD
public static final String FIELD_DATABASE_SERVERNAME
public static final String FIELD_DATABASE_INDEX_TBS
public static final String TABLE_R_DATABASE_ATTRIBUTE
public static final String FIELD_DATABASE_ATTRIBUTE_ID_DATABASE_ATTRIBUTE
public static final String FIELD_DATABASE_ATTRIBUTE_ID_DATABASE
public static final String FIELD_DATABASE_ATTRIBUTE_CODE
public static final String FIELD_DATABASE_ATTRIBUTE_VALUE_STR
public static final String TABLE_R_NOTE
public static final String FIELD_NOTE_ID_NOTE
public static final String FIELD_NOTE_VALUE_STR
public static final String FIELD_NOTE_GUI_LOCATION_X
public static final String FIELD_NOTE_GUI_LOCATION_Y
public static final String FIELD_NOTE_GUI_LOCATION_WIDTH
public static final String FIELD_NOTE_GUI_LOCATION_HEIGHT
public static final String TABLE_R_TRANSFORMATION
public static final String FIELD_TRANSFORMATION_ID_TRANSFORMATION
public static final String FIELD_TRANSFORMATION_ID_DIRECTORY
public static final String FIELD_TRANSFORMATION_NAME
public static final String FIELD_TRANSFORMATION_DESCRIPTION
public static final String FIELD_TRANSFORMATION_EXTENDED_DESCRIPTION
public static final String FIELD_TRANSFORMATION_TRANS_VERSION
public static final String FIELD_TRANSFORMATION_TRANS_STATUS
public static final String FIELD_TRANSFORMATION_ID_STEP_READ
public static final String FIELD_TRANSFORMATION_ID_STEP_WRITE
public static final String FIELD_TRANSFORMATION_ID_STEP_INPUT
public static final String FIELD_TRANSFORMATION_ID_STEP_OUTPUT
public static final String FIELD_TRANSFORMATION_ID_STEP_UPDATE
public static final String FIELD_TRANSFORMATION_ID_DATABASE_LOG
public static final String FIELD_TRANSFORMATION_TABLE_NAME_LOG
public static final String FIELD_TRANSFORMATION_USE_BATCHID
public static final String FIELD_TRANSFORMATION_USE_LOGFIELD
public static final String FIELD_TRANSFORMATION_ID_DATABASE_MAXDATE
public static final String FIELD_TRANSFORMATION_TABLE_NAME_MAXDATE
public static final String FIELD_TRANSFORMATION_FIELD_NAME_MAXDATE
public static final String FIELD_TRANSFORMATION_OFFSET_MAXDATE
public static final String FIELD_TRANSFORMATION_DIFF_MAXDATE
public static final String FIELD_TRANSFORMATION_CREATED_USER
public static final String FIELD_TRANSFORMATION_CREATED_DATE
public static final String FIELD_TRANSFORMATION_MODIFIED_USER
public static final String FIELD_TRANSFORMATION_MODIFIED_DATE
public static final String FIELD_TRANSFORMATION_SIZE_ROWSET
public static final String TABLE_R_DIRECTORY
public static final String FIELD_DIRECTORY_ID_DIRECTORY
public static final String FIELD_DIRECTORY_ID_DIRECTORY_PARENT
public static final String FIELD_DIRECTORY_DIRECTORY_NAME
public static final String TABLE_R_TRANS_ATTRIBUTE
public static final String FIELD_TRANS_ATTRIBUTE_ID_TRANS_ATTRIBUTE
public static final String FIELD_TRANS_ATTRIBUTE_ID_TRANSFORMATION
public static final String FIELD_TRANS_ATTRIBUTE_NR
public static final String FIELD_TRANS_ATTRIBUTE_CODE
public static final String FIELD_TRANS_ATTRIBUTE_VALUE_NUM
public static final String FIELD_TRANS_ATTRIBUTE_VALUE_STR
public static final String TABLE_R_JOB_ATTRIBUTE
public static final String FIELD_JOB_ATTRIBUTE_ID_JOB_ATTRIBUTE
public static final String FIELD_JOB_ATTRIBUTE_ID_JOB
public static final String FIELD_JOB_ATTRIBUTE_NR
public static final String FIELD_JOB_ATTRIBUTE_CODE
public static final String FIELD_JOB_ATTRIBUTE_VALUE_NUM
public static final String FIELD_JOB_ATTRIBUTE_VALUE_STR
public static final String TABLE_R_DEPENDENCY
public static final String FIELD_DEPENDENCY_ID_DEPENDENCY
public static final String FIELD_DEPENDENCY_ID_TRANSFORMATION
public static final String FIELD_DEPENDENCY_ID_DATABASE
public static final String FIELD_DEPENDENCY_TABLE_NAME
public static final String FIELD_DEPENDENCY_FIELD_NAME
public static final String TABLE_R_TRANS_STEP_CONDITION
public static final String FIELD_TRANS_STEP_CONDITION_ID_TRANSFORMATION
public static final String FIELD_TRANS_STEP_CONDITION_ID_STEP
public static final String FIELD_TRANS_STEP_CONDITION_ID_CONDITION
public static final String TABLE_R_CONDITION
public static final String FIELD_CONDITION_ID_CONDITION
public static final String FIELD_CONDITION_ID_CONDITION_PARENT
public static final String FIELD_CONDITION_NEGATED
public static final String FIELD_CONDITION_OPERATOR
public static final String FIELD_CONDITION_LEFT_NAME
public static final String FIELD_CONDITION_CONDITION_FUNCTION
public static final String FIELD_CONDITION_RIGHT_NAME
public static final String FIELD_CONDITION_ID_VALUE_RIGHT
public static final String TABLE_R_VALUE
public static final String FIELD_VALUE_ID_VALUE
public static final String FIELD_VALUE_NAME
public static final String FIELD_VALUE_VALUE_TYPE
public static final String FIELD_VALUE_VALUE_STR
public static final String FIELD_VALUE_IS_NULL
public static final String TABLE_R_TRANS_HOP
public static final String FIELD_TRANS_HOP_ID_TRANS_HOP
public static final String FIELD_TRANS_HOP_ID_TRANSFORMATION
public static final String FIELD_TRANS_HOP_ID_STEP_FROM
public static final String FIELD_TRANS_HOP_ID_STEP_TO
public static final String FIELD_TRANS_HOP_ENABLED
public static final String TABLE_R_STEP_TYPE
public static final String FIELD_STEP_TYPE_ID_STEP_TYPE
public static final String FIELD_STEP_TYPE_CODE
public static final String FIELD_STEP_TYPE_DESCRIPTION
public static final String FIELD_STEP_TYPE_HELPTEXT
public static final String TABLE_R_STEP
public static final String FIELD_STEP_ID_STEP
public static final String FIELD_STEP_ID_TRANSFORMATION
public static final String FIELD_STEP_NAME
public static final String FIELD_STEP_DESCRIPTION
public static final String FIELD_STEP_ID_STEP_TYPE
public static final String FIELD_STEP_DISTRIBUTE
public static final String FIELD_STEP_COPIES
public static final String FIELD_STEP_GUI_LOCATION_X
public static final String FIELD_STEP_GUI_LOCATION_Y
public static final String FIELD_STEP_GUI_DRAW
public static final String TABLE_R_STEP_ATTRIBUTE
public static final String FIELD_STEP_ATTRIBUTE_ID_STEP_ATTRIBUTE
public static final String FIELD_STEP_ATTRIBUTE_ID_TRANSFORMATION
public static final String FIELD_STEP_ATTRIBUTE_ID_STEP
public static final String FIELD_STEP_ATTRIBUTE_CODE
public static final String FIELD_STEP_ATTRIBUTE_NR
public static final String FIELD_STEP_ATTRIBUTE_VALUE_NUM
public static final String FIELD_STEP_ATTRIBUTE_VALUE_STR
public static final String TABLE_R_TRANS_NOTE
public static final String FIELD_TRANS_NOTE_ID_TRANSFORMATION
public static final String FIELD_TRANS_NOTE_ID_NOTE
public static final String TABLE_R_JOB
public static final String FIELD_JOB_ID_JOB
public static final String FIELD_JOB_ID_DIRECTORY
public static final String FIELD_JOB_NAME
public static final String FIELD_JOB_DESCRIPTION
public static final String FIELD_JOB_EXTENDED_DESCRIPTION
public static final String FIELD_JOB_JOB_VERSION
public static final String FIELD_JOB_JOB_STATUS
public static final String FIELD_JOB_ID_DATABASE_LOG
public static final String FIELD_JOB_TABLE_NAME_LOG
public static final String FIELD_JOB_CREATED_USER
public static final String FIELD_JOB_CREATED_DATE
public static final String FIELD_JOB_MODIFIED_USER
public static final String FIELD_JOB_MODIFIED_DATE
public static final String FIELD_JOB_USE_BATCH_ID
public static final String FIELD_JOB_PASS_BATCH_ID
public static final String FIELD_JOB_USE_LOGFIELD
public static final String FIELD_JOB_SHARED_FILE
public static final String TABLE_R_LOGLEVEL
public static final String FIELD_LOGLEVEL_ID_LOGLEVEL
public static final String FIELD_LOGLEVEL_CODE
public static final String FIELD_LOGLEVEL_DESCRIPTION
public static final String TABLE_R_LOG
public static final String FIELD_LOG_ID_LOG
public static final String FIELD_LOG_NAME
public static final String FIELD_LOG_ID_LOGLEVEL
public static final String FIELD_LOG_LOGTYPE
public static final String FIELD_LOG_FILENAME
public static final String FIELD_LOG_FILEEXTENTION
public static final String FIELD_LOG_ADD_DATE
public static final String FIELD_LOG_ADD_TIME
public static final String FIELD_LOG_ID_DATABASE_LOG
public static final String FIELD_LOG_TABLE_NAME_LOG
public static final String TABLE_R_JOBENTRY
public static final String FIELD_JOBENTRY_ID_JOBENTRY
public static final String FIELD_JOBENTRY_ID_JOB
public static final String FIELD_JOBENTRY_ID_JOBENTRY_TYPE
public static final String FIELD_JOBENTRY_NAME
public static final String FIELD_JOBENTRY_DESCRIPTION
public static final String TABLE_R_JOBENTRY_COPY
public static final String FIELD_JOBENTRY_COPY_ID_JOBENTRY_COPY
public static final String FIELD_JOBENTRY_COPY_ID_JOBENTRY
public static final String FIELD_JOBENTRY_COPY_ID_JOB
public static final String FIELD_JOBENTRY_COPY_ID_JOBENTRY_TYPE
public static final String FIELD_JOBENTRY_COPY_NR
public static final String FIELD_JOBENTRY_COPY_GUI_LOCATION_X
public static final String FIELD_JOBENTRY_COPY_GUI_LOCATION_Y
public static final String FIELD_JOBENTRY_COPY_GUI_DRAW
public static final String FIELD_JOBENTRY_COPY_PARALLEL
public static final String TABLE_R_JOBENTRY_TYPE
public static final String FIELD_JOBENTRY_TYPE_ID_JOBENTRY_TYPE
public static final String FIELD_JOBENTRY_TYPE_CODE
public static final String FIELD_JOBENTRY_TYPE_DESCRIPTION
public static final String TABLE_R_JOBENTRY_ATTRIBUTE
public static final String FIELD_JOBENTRY_ATTRIBUTE_ID_JOBENTRY_ATTRIBUTE
public static final String FIELD_JOBENTRY_ATTRIBUTE_ID_JOB
public static final String FIELD_JOBENTRY_ATTRIBUTE_ID_JOBENTRY
public static final String FIELD_JOBENTRY_ATTRIBUTE_NR
public static final String FIELD_JOBENTRY_ATTRIBUTE_CODE
public static final String FIELD_JOBENTRY_ATTRIBUTE_VALUE_NUM
public static final String FIELD_JOBENTRY_ATTRIBUTE_VALUE_STR
public static final String TABLE_R_JOB_HOP
public static final String FIELD_JOB_HOP_ID_JOB_HOP
public static final String FIELD_JOB_HOP_ID_JOB
public static final String FIELD_JOB_HOP_ID_JOBENTRY_COPY_FROM
public static final String FIELD_JOB_HOP_ID_JOBENTRY_COPY_TO
public static final String FIELD_JOB_HOP_ENABLED
public static final String FIELD_JOB_HOP_EVALUATION
public static final String FIELD_JOB_HOP_UNCONDITIONAL
public static final String TABLE_R_JOB_NOTE
public static final String FIELD_JOB_NOTE_ID_JOB
public static final String FIELD_JOB_NOTE_ID_NOTE
public static final String TABLE_R_PROFILE
public static final String FIELD_PROFILE_ID_PROFILE
public static final String FIELD_PROFILE_NAME
public static final String FIELD_PROFILE_DESCRIPTION
public static final String TABLE_R_USER
public static final String FIELD_USER_ID_USER
public static final String FIELD_USER_ID_PROFILE
public static final String FIELD_USER_LOGIN
public static final String FIELD_USER_PASSWORD
public static final String FIELD_USER_NAME
public static final String FIELD_USER_DESCRIPTION
public static final String FIELD_USER_ENABLED
public static final String TABLE_R_PERMISSION
public static final String FIELD_PERMISSION_ID_PERMISSION
public static final String FIELD_PERMISSION_CODE
public static final String FIELD_PERMISSION_DESCRIPTION
public static final String TABLE_R_PROFILE_PERMISSION
public static final String FIELD_PROFILE_PERMISSION_ID_PROFILE
public static final String FIELD_PROFILE_PERMISSION_ID_PERMISSION
public static final String TABLE_R_STEP_DATABASE
public static final String FIELD_STEP_DATABASE_ID_TRANSFORMATION
public static final String FIELD_STEP_DATABASE_ID_STEP
public static final String FIELD_STEP_DATABASE_ID_DATABASE
public static final String TABLE_R_PARTITION_SCHEMA
public static final String FIELD_PARTITION_SCHEMA_ID_PARTITION_SCHEMA
public static final String FIELD_PARTITION_SCHEMA_NAME
public static final String FIELD_PARTITION_SCHEMA_DYNAMIC_DEFINITION
public static final String FIELD_PARTITION_SCHEMA_PARTITIONS_PER_SLAVE
public static final String TABLE_R_PARTITION
public static final String FIELD_PARTITION_ID_PARTITION
public static final String FIELD_PARTITION_ID_PARTITION_SCHEMA
public static final String FIELD_PARTITION_PARTITION_ID
public static final String TABLE_R_TRANS_PARTITION_SCHEMA
public static final String FIELD_TRANS_PARTITION_SCHEMA_ID_TRANS_PARTITION_SCHEMA
public static final String FIELD_TRANS_PARTITION_SCHEMA_ID_TRANSFORMATION
public static final String FIELD_TRANS_PARTITION_SCHEMA_ID_PARTITION_SCHEMA
public static final String TABLE_R_CLUSTER
public static final String FIELD_CLUSTER_ID_CLUSTER
public static final String FIELD_CLUSTER_NAME
public static final String FIELD_CLUSTER_BASE_PORT
public static final String FIELD_CLUSTER_SOCKETS_BUFFER_SIZE
public static final String FIELD_CLUSTER_SOCKETS_FLUSH_INTERVAL
public static final String FIELD_CLUSTER_SOCKETS_COMPRESSED
public static final String FIELD_CLUSTER_DYNAMIC
public static final String TABLE_R_SLAVE
public static final String FIELD_SLAVE_ID_SLAVE
public static final String FIELD_SLAVE_NAME
public static final String FIELD_SLAVE_HOST_NAME
public static final String FIELD_SLAVE_PORT
public static final String FIELD_SLAVE_USERNAME
public static final String FIELD_SLAVE_PASSWORD
public static final String FIELD_SLAVE_PROXY_HOST_NAME
public static final String FIELD_SLAVE_PROXY_PORT
public static final String FIELD_SLAVE_NON_PROXY_HOSTS
public static final String FIELD_SLAVE_MASTER
public static final String TABLE_R_CLUSTER_SLAVE
public static final String FIELD_CLUSTER_SLAVE_ID_CLUSTER_SLAVE
public static final String FIELD_CLUSTER_SLAVE_ID_CLUSTER
public static final String FIELD_CLUSTER_SLAVE_ID_SLAVE
public static final String TABLE_R_TRANS_CLUSTER
public static final String FIELD_TRANS_CLUSTER_ID_TRANS_CLUSTER
public static final String FIELD_TRANS_CLUSTER_ID_TRANSFORMATION
public static final String FIELD_TRANS_CLUSTER_ID_CLUSTER
public static final String TABLE_R_TRANS_SLAVE
public static final String FIELD_TRANS_SLAVE_ID_TRANS_SLAVE
public static final String FIELD_TRANS_SLAVE_ID_TRANSFORMATION
public static final String FIELD_TRANS_SLAVE_ID_SLAVE
public static final String[] repositoryTableNames
public static final int REQUIRED_MAJOR_VERSION
public static final int REQUIRED_MINOR_VERSION
public UserInfo userinfo
public org.pentaho.di.core.logging.LogWriter log
public static final int REP_STRING_LENGTH
public static final int REP_STRING_CODE_LENGTH
public static final String TRANS_ATTRIBUTE_ID_STEP_REJECTED
public static final String TRANS_ATTRIBUTE_UNIQUE_CONNECTIONS
public static final String TRANS_ATTRIBUTE_FEEDBACK_SHOWN
public static final String TRANS_ATTRIBUTE_FEEDBACK_SIZE
public static final String TRANS_ATTRIBUTE_USING_THREAD_PRIORITIES
public static final String TRANS_ATTRIBUTE_SHARED_FILE
public static final String TRANS_ATTRIBUTE_CAPTURE_STEP_PERFORMANCE
public static final String TRANS_ATTRIBUTE_STEP_PERFORMANCE_CAPTURING_DELAY
public static final String TRANS_ATTRIBUTE_STEP_PERFORMANCE_LOG_TABLE
public static final String TRANS_ATTRIBUTE_LOG_SIZE_LIMIT
public static final String TRANS_ATTRIBUTE_PARAM_KEY
public static final String TRANS_ATTRIBUTE_PARAM_DEFAULT
public static final String TRANS_ATTRIBUTE_PARAM_DESCRIPTION
public static final String JOB_ATTRIBUTE_PARAM_KEY
public static final String JOB_ATTRIBUTE_PARAM_DEFAULT
public static final String JOB_ATTRIBUTE_PARAM_DESCRIPTION
public static final String JOB_ATTRIBUTE_LOG_SIZE_LIMIT
Constructor Detail |
---|
public Repository(org.pentaho.di.core.logging.LogWriter log, RepositoryMeta repinfo, UserInfo userinfo)
Method Detail |
---|
public RepositoryMeta getRepositoryInfo()
public UserInfo getUserInfo()
public String getName()
public int getMajorVersion()
public int getMinorVersion()
public String getVersion()
public static final String getRequiredVersion()
public String getLocksource()
public boolean connect(String locksource) throws org.pentaho.di.core.exception.KettleException
locksource
-
org.pentaho.di.core.exception.KettleException
public boolean connect(boolean no_lookup, boolean readDirectory, String locksource) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean connect(boolean no_lookup, boolean readDirectory, String locksource, boolean ignoreVersion) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void refreshRepositoryDirectoryTree() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void disconnect()
public void setAutoCommit(boolean autocommit)
public void commit() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void rollback()
public List<Object[]> getStepAttributesBuffer()
public void setStepAttributesBuffer(List<Object[]> stepAttributesBuffer)
stepAttributesBuffer
- The stepAttributesBuffer to set.public void fillStepAttributesBuffer(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getJobID(String name, long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getTransformationID(String name, long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNoteID(String note) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getDatabaseID(String name) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getPartitionSchemaID(String name) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getSlaveID(String name) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getClusterID(String name) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getDatabaseTypeID(String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getDatabaseConTypeID(String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getStepTypeID(String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getJobEntryID(String name, long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getJobEntryTypeID(String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getStepID(String name, long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getUserID(String login) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getProfileID(String profilename) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getPermissionID(String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getTransHopID(long id_transformation, long id_step_from, long id_step_to) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getJobHopID(long id_job, long id_jobentry_copy_from, long id_jobentry_copy_to) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getDependencyID(long id_transformation, long id_database, String tablename) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getRootDirectoryID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrSubDirectories(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getSubDirectoryIDs(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getDatabaseTypeCode(long id_database_type) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getDatabaseConTypeCode(long id_database_contype) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getStepTypeCode(long id_database_type) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void moveTransformation(String transname, long id_directory_from, long id_directory_to) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void moveJob(String jobname, long id_directory_from, long id_directory_to) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextTransformationID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextJobID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextNoteID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextLogID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextDatabaseID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextDatabaseTypeID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextDatabaseConnectionTypeID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextLoglevelID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextStepTypeID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextStepID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextJobEntryID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextJobEntryTypeID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextJobEntryCopyID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextStepAttributeID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextTransAttributeID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextJobAttributeID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextDatabaseAttributeID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextTransHopID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextJobHopID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextDepencencyID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextPartitionSchemaID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextPartitionID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextTransformationPartitionSchemaID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextClusterID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextSlaveServerID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextClusterSlaveID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextTransformationSlaveID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextTransformationClusterID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextConditionID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextValueID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextUserID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextProfileID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextPermissionID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextJobEntryAttributeID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getNextID(String tableName, String fieldName) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void clearNextIDCounters()
public long getNextDirectoryID() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void insertTransformation(TransMeta transMeta) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void insertJob(JobMeta jobMeta) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertNote(String note, long gui_location_x, long gui_location_y, long gui_location_width, long gui_location_height) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertLogEntry(String description) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void insertTransNote(long id_transformation, long id_note) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void insertJobNote(long id_job, long id_note) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertDatabase(String name, String type, String access, String host, String dbname, String port, String user, String pass, String servername, String data_tablespace, String index_tablespace) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertStep(long id_transformation, String name, String description, String steptype, boolean distribute, long copies, long gui_location_x, long gui_location_y, boolean gui_draw) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertStepAttribute(long id_transformation, long id_step, long nr, String code, double value_num, String value_str) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertTransAttribute(long id_transformation, long nr, String code, long value_num, String value_str) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertJobAttribute(long id_job, long nr, String code, long value_num, String value_str) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void insertStepDatabase(long id_transformation, long id_step, long id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertDatabaseAttribute(long id_database, String code, String value_str) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertJobEntryAttribute(long id_job, long id_jobentry, long nr, String code, double value_num, String value_str) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertTransHop(long id_transformation, long id_step_from, long id_step_to, boolean enabled) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertJobHop(long id_job, long id_jobentry_copy_from, long id_jobentry_copy_to, boolean enabled, boolean evaluation, boolean unconditional) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertDependency(long id_transformation, long id_database, String tablename, String fieldname) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertPartitionSchema(PartitionSchema partitionSchema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void updatePartitionSchema(PartitionSchema partitionSchema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertPartition(long id_partition_schema, String partition_id) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertTransformationPartitionSchema(long id_transformation, long id_partition_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertCluster(ClusterSchema clusterSchema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertSlave(SlaveServer slaveServer) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void updateSlave(SlaveServer slaveServer) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertClusterSlave(ClusterSchema clusterSchema, SlaveServer slaveServer) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertTransformationCluster(long id_transformation, long id_cluster) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertTransformationSlave(long id_transformation, long id_slave) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertCondition(long id_condition_parent, Condition condition) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void insertTransStepCondition(long id_transformation, long id_step, long id_condition) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertDirectory(long id_directory_parent, RepositoryDirectory dir) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void deleteDirectory(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void renameDirectory(long id_directory, String name) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long lookupValue(String name, String type, String value_str, boolean isnull) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertValue(String name, String type, String value_str, boolean isnull, long id_value_prev) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertJobEntry(long id_job, JobEntryBase jobEntryBase) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long insertJobEntryCopy(long id_job, long id_jobentry, long id_jobentry_type, int nr, long gui_location_x, long gui_location_y, boolean gui_draw, boolean parallel) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void insertTableRow(String tablename, org.pentaho.di.core.RowMetaAndData values) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void updateDatabase(long id_database, String name, String type, String access, String host, String dbname, String port, String user, String pass, String servername, String data_tablespace, String index_tablespace) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void updateTableRow(String tablename, String idfield, org.pentaho.di.core.RowMetaAndData values, long id) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void updateTableRow(String tablename, String idfield, org.pentaho.di.core.RowMetaAndData values) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrJobs() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrTransformations(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrJobs(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrDirectories(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrConditions(long id_transforamtion) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrDatabases(long id_transforamtion) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrSubConditions(long id_condition) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrTransNotes(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrJobNotes(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrDatabases() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrDatabaseAttributes(long id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrSteps(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrStepDatabases(long id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrStepAttributes(long id_step) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrTransHops(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrJobHops(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrTransDependencies(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrJobEntries(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrJobEntryCopies(long id_job, long id_jobentry) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrJobEntryCopies(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrUsers() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrPermissions(long id_profile) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int getNrProfiles() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getTransformationNames(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public List<RepositoryObject> getJobObjects(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public List<RepositoryObject> getTransformationObjects(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getJobNames(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getDirectoryNames(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getJobNames() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getSubConditionIDs(long id_condition) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getTransNoteIDs(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getConditionIDs(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getDatabaseIDs(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getJobNoteIDs(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getDatabaseIDs() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getDatabaseAttributeIDs(long id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getPartitionSchemaIDs() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getPartitionIDs(long id_partition_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getTransformationPartitionSchemaIDs(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getTransformationClusterSchemaIDs(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getClusterIDs() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getSlaveIDs() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getSlaveIDs(long id_cluster_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getDatabaseNames() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getPartitionSchemaNames() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getSlaveNames() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getClusterNames() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getStepIDs(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getTransformationsUsingDatabase(long id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getClustersUsingSlave(long id_slave) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getTransformationsUsingSlave(long id_slave) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getTransformationsUsingPartitionSchema(long id_partition_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getTransformationsUsingCluster(long id_cluster) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getTransHopIDs(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getJobHopIDs(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getTransDependencyIDs(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getUserIDs() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getUserLogins() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getPermissionIDs(long id_profile) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getJobEntryIDs(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getJobEntryCopyIDs(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long[] getJobEntryCopyIDs(long id_job, long id_jobentry) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String[] getProfiles() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getNote(long id_note) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getDatabase(long id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getDatabaseAttribute(long id_database_attribute) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public Collection<org.pentaho.di.core.RowMetaAndData> getDatabaseAttributes() throws org.pentaho.di.core.exception.KettleDatabaseException, org.pentaho.di.core.exception.KettleValueException
org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleValueException
public Collection<org.pentaho.di.core.RowMetaAndData> getDatabaseAttributes(long id_database) throws org.pentaho.di.core.exception.KettleDatabaseException, org.pentaho.di.core.exception.KettleValueException
org.pentaho.di.core.exception.KettleDatabaseException
org.pentaho.di.core.exception.KettleValueException
public org.pentaho.di.core.RowMetaAndData getCondition(long id_condition) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getValue(long id_value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getStep(long id_step) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getStepType(long id_step_type) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getStepAttribute(long id_step_attribute) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getStepDatabase(long id_step) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getTransHop(long id_trans_hop) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getJobHop(long id_job_hop) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getTransDependency(long id_dependency) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getTransformation(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getUser(long id_user) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getProfile(long id_profile) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getPermission(long id_permission) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getJob(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getJobEntry(long id_jobentry) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getJobEntryCopy(long id_jobentry_copy) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getJobEntryType(long id_jobentry_type) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getDirectory(long id_directory) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getPartitionSchema(long id_partition_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getPartition(long id_partition) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getClusterSchema(long id_cluster_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getSlaveServer(long id_slave) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveStepAttribute(long id_transformation, long id_step, String code, String value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveStepAttribute(long id_transformation, long id_step, String code, double value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveStepAttribute(long id_transformation, long id_step, String code, boolean value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveStepAttribute(long id_transformation, long id_step, long nr, String code, String value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveStepAttribute(long id_transformation, long id_step, long nr, String code, double value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveStepAttribute(long id_transformation, long id_step, long nr, String code, boolean value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public static final String byteArrayToString(byte[] val) throws IOException
val
- the array of bytes to convert to a string
IOException
- in the case there is a Base64 or GZip encoding problempublic void setLookupStepAttribute() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void setLookupTransAttribute() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void closeTransAttributeLookupPreparedStatement() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void setLookupJobAttribute() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void closeJobAttributeLookupPreparedStatement() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void closeStepAttributeLookupPreparedStatement() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void closeStepAttributeInsertPreparedStatement() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void closeTransAttributeInsertPreparedStatement() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getTransAttributeRow(long id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.RowMetaAndData getJobAttributeRow(long id_job, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getStepAttributeInteger(long id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long findStepAttributeID(long id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getStepAttributeString(long id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean getStepAttributeBoolean(long id_step, int nr, String code, boolean def) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean getStepAttributeBoolean(long id_step, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getStepAttributeInteger(long id_step, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getStepAttributeString(long id_step, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean getStepAttributeBoolean(long id_step, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int countNrStepAttributes(long id_step, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getTransAttributeString(long id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean getTransAttributeBoolean(long id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public double getTransAttributeNumber(long id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getTransAttributeInteger(long id_transformation, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int countNrTransAttributes(long id_transformation, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public List<Object[]> getTransAttributes(long id_transformation, String code, long nr) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getJobAttributeString(long id_job, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean getJobAttributeBoolean(long id_job, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public double getJobAttributeNumber(long id_job, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getJobAttributeInteger(long id_job, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int countNrJobAttributes(long id_job, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public List<Object[]> getJobAttributes(long id_job, String code, long nr) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveJobEntryAttribute(long id_job, long id_jobentry, String code, String value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveJobEntryAttribute(long id_job, long id_jobentry, String code, double value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveJobEntryAttribute(long id_job, long id_jobentry, String code, boolean value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveJobEntryAttribute(long id_job, long id_jobentry, long nr, String code, String value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveJobEntryAttribute(long id_job, long id_jobentry, long nr, String code, double value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long saveJobEntryAttribute(long id_job, long id_jobentry, long nr, String code, boolean value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void setLookupJobEntryAttribute() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void closeLookupJobEntryAttribute() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getJobEntryAttributeInteger(long id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public double getJobEntryAttributeNumber(long id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getJobEntryAttributeString(long id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean getJobEntryAttributeBoolean(long id_jobentry, int nr, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean getJobEntryAttributeBoolean(long id_jobentry, int nr, String code, boolean def) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public double getJobEntryAttributeNumber(long id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public long getJobEntryAttributeInteger(long id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getJobEntryAttributeString(long id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean getJobEntryAttributeBoolean(long id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean getJobEntryAttributeBoolean(long id_jobentry, String code, boolean def) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int countNrJobEntryAttributes(long id_jobentry, String code) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delSteps(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delCondition(long id_condition) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delStepConditions(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delStepDatabases(long id_transformation) throws org.pentaho.di.core.exception.KettleException
id_transformation
- the transformation for which we want to delete the databases.
org.pentaho.di.core.exception.KettleException
- in case something unexpected happens.public void delJobEntries(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delJobEntryCopies(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delDependencies(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delStepAttributes(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delTransAttributes(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delJobAttributes(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delPartitionSchemas(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delPartitions(long id_partition_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delClusterSlaves(long id_cluster) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delTransformationClusters(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delTransformationSlaves(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delJobEntryAttributes(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delTransHops(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delJobHops(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delTransNotes(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delJobNotes(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delTrans(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delJob(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delDatabase(long id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delDatabaseAttributes(long id_database) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delTransStepCondition(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delValue(long id_value) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delUser(long id_user) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delProfile(long id_profile) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delProfilePermissions(long id_profile) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delSlave(long id_slave) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delPartitionSchema(long id_partition_schema) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delClusterSchema(long id_cluster) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delAllFromTrans(long id_transformation) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void renameTransformation(long id_transformation, String newname) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void renameUser(long id_user, String newname) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void renameProfile(long id_profile, String newname) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void renameDatabase(long id_database, String newname) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void delAllFromJob(long id_job) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void renameJob(long id_job, String newname) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean dropRepositorySchema() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void updateStepTypes() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
- if the update didn't go as planned.public void updateJobEntryTypes() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
- if something went wrong during the update.public String toString()
toString
in class Object
public org.pentaho.di.core.database.Database getDatabase()
public void setDatabase(org.pentaho.di.core.database.Database database)
database
- The database to set.public RepositoryDirectory getDirectoryTree()
public void setDirectoryTree(RepositoryDirectory directoryTree)
directoryTree
- The directoryTree to set.public void lockRepository() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void unlockRepository() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public void exportAllObjects(org.pentaho.di.core.ProgressMonitorListener monitor, String xmlFilename, RepositoryDirectory root, String exportType) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public static Repository getCurrentRepository()
public static void setCurrentRepository(Repository currentRepository)
currentRepository
- the current repositorypublic List<org.pentaho.di.core.database.DatabaseMeta> getDatabases() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public List<SlaveServer> getSlaveServers() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.row.RowMetaInterface getStepAttributesRowMeta()
public void setStepAttributesRowMeta(org.pentaho.di.core.row.RowMetaInterface stepAttributesRowMeta)
stepAttributesRowMeta
- the stepAttributesRowMeta to setpublic String quote(String identifier)
public org.pentaho.di.core.database.DatabaseMeta getDatabaseMeta()
public List<org.pentaho.di.core.database.DatabaseMeta> readDatabases() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public boolean isUseBatchProcessing()
public void setUseBatchProcessing(boolean useBatchProcessing)
useBatchProcessing
- the useBatchProcessing to setpublic void setImportBaseDirectory(RepositoryDirectory importBaseDirectory)
importBaseDirectory
- the base import directory, selected by the userpublic RepositoryDirectory getImportBaseDirectory()
public void setUserInfo(UserInfo userinfo)
userinfo
- the UserInfo object to setpublic void createRepositorySchema(org.pentaho.di.core.ProgressMonitorListener monitor, boolean upgrade, List<String> statements, boolean dryRun) throws org.pentaho.di.core.exception.KettleException
monitor
- The progress monitor to use, or null if no monitor is present.upgrade
- True if you want to upgrade the repository, false if you want to create it.statements
- the list of statements to populatedryrun
- true if we don't actually execute the statements
org.pentaho.di.core.exception.KettleException
- in case something goes wrong!public int countTransParameter(long id_transformation) throws org.pentaho.di.core.exception.KettleException
id_transformation
- transformation id
org.pentaho.di.core.exception.KettleException
- Upon any error.public String getTransParameterKey(long id_transformation, int nr) throws org.pentaho.di.core.exception.KettleException
id_transformation
- transformation idnr
- number of the parameter
org.pentaho.di.core.exception.KettleException
- Upon any error.public String getTransParameterDefault(long id_transformation, int nr) throws org.pentaho.di.core.exception.KettleException
id_transformation
- transformation idnr
- number of the parameter
org.pentaho.di.core.exception.KettleException
- Upon any error.public String getTransParameterDescription(long id_transformation, int nr) throws org.pentaho.di.core.exception.KettleException
id_transformation
- transformation idnr
- number of the parameter
org.pentaho.di.core.exception.KettleException
- Upon any error.public void insertTransParameter(long id_transformation, long nr, String key, String defValue, String description) throws org.pentaho.di.core.exception.KettleException
id_transformation
- transformation idnr
- number of the parameter to insertkey
- key to insertdefValue
- default valuedescription
- description to insert
org.pentaho.di.core.exception.KettleException
- Upon any error.public int countJobParameter(long id_job) throws org.pentaho.di.core.exception.KettleException
id_job
- job id
org.pentaho.di.core.exception.KettleException
- Upon any error.public String getJobParameterKey(long id_job, int nr) throws org.pentaho.di.core.exception.KettleException
id_job
- job idnr
- number of the parameter
org.pentaho.di.core.exception.KettleException
- Upon any error.public String getJobParameterDefault(long id_job, int nr) throws org.pentaho.di.core.exception.KettleException
id_job
- job idnr
- number of the parameter
org.pentaho.di.core.exception.KettleException
- Upon any error.public String getJobParameterDescription(long id_job, int nr) throws org.pentaho.di.core.exception.KettleException
id_job
- job idnr
- number of the parameter
org.pentaho.di.core.exception.KettleException
- Upon any error.public void insertJobParameter(long id_job, long nr, String key, String defValue, String description) throws org.pentaho.di.core.exception.KettleException
id_job
- job idnr
- number of the parameter to insertkey
- key to insertdefValue
- default value for keydescription
- description to insert
org.pentaho.di.core.exception.KettleException
- Upon any error.
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |