|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of KettleException in org.pentaho.di.blackbox |
---|
Methods in org.pentaho.di.blackbox that throw KettleException | |
---|---|
Result |
BlackBoxTests.runTrans(String fileName,
LogChannelInterface log)
|
Uses of KettleException in org.pentaho.di.cluster |
---|
Methods in org.pentaho.di.cluster that throw KettleException | |
---|---|
SlaveServer |
ClusterSchema.findMaster()
|
long |
SlaveServer.getNextSlaveSequenceValue(String slaveSequenceName,
long incrementValue)
|
List<SlaveServer> |
ClusterSchema.getSlaveServersFromMasterOrLocal()
|
TransMeta |
BaseCluster.loadAndModifyTestTransformation(ClusterGenerator clusterGenerator,
String filename)
|
Constructors in org.pentaho.di.cluster that throw KettleException | |
---|---|
ClusterGenerator()
|
Uses of KettleException in org.pentaho.di.core |
---|
Methods in org.pentaho.di.core that throw KettleException | |
---|---|
static ClassLoader |
Const.createNewClassLoader()
|
String |
EngineMetaInterface.getXML()
Gets the XML representation. |
static void |
KettleVariablesList.init()
|
static void |
KettleEnvironment.init()
Initializes the Kettle environment. |
static void |
KettleEnvironment.init(boolean simpleJndi)
Initializes the Kettle environment. |
static void |
JndiUtil.initJNDI()
|
void |
EngineMetaInterface.saveSharedObjects()
Saves shared objects, including databases, steps, partition schemas, slave servers, and cluster schemas, to a file. |
Constructors in org.pentaho.di.core that throw KettleException | |
---|---|
Result(Node node)
Instantiates a new Result object from a DOM node |
Uses of KettleException in org.pentaho.di.core.database |
---|
Subclasses of KettleException in org.pentaho.di.core.database | |
---|---|
class |
DataSourceNamingException
This class provides a wrapper around NamingException or other exceptions that may occur when trying to get a data source by name. |
Methods in org.pentaho.di.core.database that throw KettleException | |
---|---|
void |
Database.cleanupLogRecords(LogTableInterface logTable)
|
void |
Database.writeLogRecord(LogTableInterface logTable,
LogStatus status,
Object subject,
Object parent)
|
Uses of KettleException in org.pentaho.di.core.exception |
---|
Subclasses of KettleException in org.pentaho.di.core.exception | |
---|---|
class |
KettleAuthException
This exception is used by implementations of the Repository API to designate an authentication error. |
class |
KettleConfigException
|
class |
KettleConversionException
|
class |
KettleDatabaseBatchException
This exception is used by the Database class. |
class |
KettleDatabaseException
This exception is used by the Database class. |
class |
KettleDependencyException
This exception is used by the Database class. |
class |
KettleEOFException
This is an exception thrown by file handling (I/O) |
class |
KettleFileException
This is an exception thrown by file handling (I/O) when an End Of File marker has been reached. |
class |
KettleJobException
This exception is used when handling Jobs. |
class |
KettleObjectExistsException
|
class |
KettlePluginException
This exception is thrown in case there is an error in the Kettle plugin loader |
class |
KettleRepositoryNotSupportedException
This exception is used when a repository type is not recognized |
class |
KettleRowException
This exception is used in row manipulations |
class |
KettleSecurityException
This exception is used by the Database class. |
class |
KettleStepException
This Exception is used when handling steps. |
class |
KettleStepLoaderException
This Exception is throws when an error occurs loading the steps. |
class |
KettleTransException
This exception is used in transformations. |
class |
KettleValueException
This exception is used in value calculations. |
class |
KettleXMLException
This exception is throws when and error is found in an XML snippet. |
Uses of KettleException in org.pentaho.di.core.gui |
---|
Methods in org.pentaho.di.core.gui that throw KettleException | |
---|---|
static SwingGUIResource |
SwingGUIResource.getInstance()
|
Constructors in org.pentaho.di.core.gui that throw KettleException | |
---|---|
SwingGC(Graphics2D gc,
Rectangle2D rect,
int iconsize,
int xOffset,
int yOffset)
|
|
SwingGC(ImageObserver observer,
Point area,
int iconsize,
int xOffset,
int yOffset)
|
Uses of KettleException in org.pentaho.di.core.lifecycle |
---|
Methods in org.pentaho.di.core.lifecycle that throw KettleException | |
---|---|
void |
KettleLifecycleSupport.onEnvironmentInit()
Execute all known listener's KettleLifecycleSupport.onEnvironmentInit() methods. |
Uses of KettleException in org.pentaho.di.core.logging |
---|
Methods in org.pentaho.di.core.logging that return KettleException | |
---|---|
KettleException |
LogChannelFileWriter.getException()
|
Methods in org.pentaho.di.core.logging that throw KettleException | |
---|---|
static LogWriter |
LogWriter.getInstance(String filename,
boolean exact)
Get a new log instance for the specified file if it is not open yet! |
void |
JobLogTable.loadFromRepository(RepositoryAttributeInterface attributeInterface)
|
void |
PerformanceLogTable.loadFromRepository(RepositoryAttributeInterface attributeInterface)
|
void |
TransLogTable.loadFromRepository(RepositoryAttributeInterface attributeInterface)
|
void |
LogTableInterface.loadFromRepository(RepositoryAttributeInterface attributeInterface)
Loads details of the log table from a repository. |
void |
JobLogTable.saveToRepository(RepositoryAttributeInterface attributeInterface)
|
void |
PerformanceLogTable.saveToRepository(RepositoryAttributeInterface attributeInterface)
|
void |
TransLogTable.saveToRepository(RepositoryAttributeInterface attributeInterface)
|
void |
LogTableInterface.saveToRepository(RepositoryAttributeInterface attributeInterface)
Saves the log table to a repository. |
Constructors in org.pentaho.di.core.logging that throw KettleException | |
---|---|
LogChannelFileWriter(String logChannelId,
org.apache.commons.vfs.FileObject logFile,
boolean appending)
Create a new log channel file writer |
|
LogChannelFileWriter(String logChannelId,
org.apache.commons.vfs.FileObject logFile,
boolean appending,
int pollingInterval)
Create a new log channel file writer |
Uses of KettleException in org.pentaho.di.core.parameters |
---|
Subclasses of KettleException in org.pentaho.di.core.parameters | |
---|---|
class |
DuplicateParamException
This is a PDI Exception for the named parameters. |
class |
NamedParamsException
This is a PDI Exception for the named parameters. |
class |
UnknownParamException
This is a PDI Exception for the named parameters. |
Uses of KettleException in org.pentaho.di.core.playlist |
---|
Methods in org.pentaho.di.core.playlist that throw KettleException | |
---|---|
boolean |
FilePlayListReplay.isProcessingNeeded(org.apache.commons.vfs.FileObject file,
long lineNr,
String filePart)
|
boolean |
FilePlayList.isProcessingNeeded(org.apache.commons.vfs.FileObject file,
long lineNr,
String filePart)
|
boolean |
FilePlayListReplayErrorFile.isProcessingNeeded(org.apache.commons.vfs.FileObject file,
long lineNr,
String filePart)
|
boolean |
FilePlayListReplayFile.isProcessingNeeded(org.apache.commons.vfs.FileObject file,
long lineNr,
String filePart)
|
Uses of KettleException in org.pentaho.di.core.row |
---|
Methods in org.pentaho.di.core.row that throw KettleException | |
---|---|
Object[] |
RowMetaInterface.getRow(Node node)
Convert an XML node into binary data using the row metadata supplied. |
Object[] |
RowMeta.getRow(Node node)
Convert an XML node into binary data using the row metadata supplied. |
Object |
ValueMeta.getValue(Node node)
Convert a data XML node to an Object that corresponds to the metadata. |
Object |
ValueMetaInterface.getValue(Node node)
Convert a data XML node to an Object that corresponds to the metadata. |
Constructors in org.pentaho.di.core.row that throw KettleException | |
---|---|
RowMeta(Node node)
Create a new row metadata object from XML |
|
ValueMeta(Node node)
|
Uses of KettleException in org.pentaho.di.core.util |
---|
Methods in org.pentaho.di.core.util that throw KettleException | |
---|---|
static void |
EnvUtil.environmentInit()
Adds the kettle properties the the global system properties. |
String |
AbstractStepMeta.getXML()
Produces the XML string that describes this step's information. |
void |
IntegerPluginProperty.readFromRepositoryStep(Repository repository,
ObjectId stepId)
|
void |
StringPluginProperty.readFromRepositoryStep(Repository repository,
ObjectId stepId)
|
void |
StringListPluginProperty.readFromRepositoryStep(Repository repository,
ObjectId stepId)
|
void |
BooleanPluginProperty.readFromRepositoryStep(Repository repository,
ObjectId stepId)
|
void |
PluginProperty.readFromRepositoryStep(Repository repository,
ObjectId stepId)
|
static void |
SerializationHelper.readJobRep(Object object,
Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases)
Handle reading of the input (object) from the kettle repository by getting the job-xml from the repository step attribute string and then re-hydrate the job entry (object) with our already existing read method. |
static Properties |
EnvUtil.readProperties(String fileName)
Returns the properties from the users kettle home directory. |
void |
AbstractStepMeta.readRep(Repository repo,
ObjectId stepId,
List<DatabaseMeta> databaseList,
Map<String,Counter> counters)
Read the steps information from a Kettle repository |
static void |
SerializationHelper.readStepRep(Object object,
Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
Handle reading of the input (object) from the kettle repository by getting the step-xml from the repository step attribute string and then re-hydrate the step (object) with our already existing read method. |
static void |
SerializationHelper.saveJobRep(Object object,
Repository rep,
ObjectId id_job,
ObjectId id_job_entry)
Handle saving of the input (object) to the kettle repository using the most simple method available, by calling write and then saving the job-xml as a job attribute. |
void |
AbstractStepMeta.saveRep(Repository repo,
ObjectId transformationId,
ObjectId stepId)
Save the steps data into a Kettle repository |
static void |
SerializationHelper.saveStepRep(Object object,
Repository rep,
ObjectId id_transformation,
ObjectId id_step)
Handle saving of the input (object) to the kettle repository using the most simple method available, by calling write and then saving the step-xml as a step attribute. |
void |
IntegerPluginProperty.saveToRepositoryStep(Repository repository,
ObjectId transformationId,
ObjectId stepId)
|
void |
StringPluginProperty.saveToRepositoryStep(Repository repository,
ObjectId transformationId,
ObjectId stepId)
|
void |
StringListPluginProperty.saveToRepositoryStep(Repository repository,
ObjectId transformationId,
ObjectId stepId)
|
void |
BooleanPluginProperty.saveToRepositoryStep(Repository repository,
ObjectId transformationId,
ObjectId stepId)
|
void |
PluginProperty.saveToRepositoryStep(Repository repository,
ObjectId transformationId,
ObjectId stepId)
|
static void |
PluginPropertyHandler.walk(KeyValueSet properties,
org.apache.commons.collections.Closure handler)
|
Uses of KettleException in org.pentaho.di.core.xml |
---|
Methods in org.pentaho.di.core.xml that throw KettleException | |
---|---|
String |
XMLInterface.getXML()
Describes the Object implementing this interface as XML |
static boolean |
XMLCheck.isXMLFileWellFormed(org.apache.commons.vfs.FileObject file)
Checks an xml file is well formed. |
static boolean |
XMLCheck.isXMLWellFormed(InputStream is)
Checks an xml string is well formed. |
static byte[] |
XMLHandler.stringToBinary(String string)
Convert a XML encoded binary string back to binary format |
Uses of KettleException in org.pentaho.di.imp |
---|
Methods in org.pentaho.di.imp that throw KettleException | |
---|---|
void |
ImportRules.loadXML(Node rulesNode)
|
static void |
Import.main(String[] a)
|
Uses of KettleException in org.pentaho.di.imp.rule |
---|
Methods in org.pentaho.di.imp.rule that throw KettleException | |
---|---|
void |
ImportRuleInterface.loadXML(Node ruleNode)
|
Uses of KettleException in org.pentaho.di.imp.rules |
---|
Methods in org.pentaho.di.imp.rules that throw KettleException | |
---|---|
void |
BaseImportRule.loadXML(Node ruleNode)
|
void |
JobHasDescriptionImportRule.loadXML(Node ruleNode)
|
void |
TransformationHasANoteImportRule.loadXML(Node ruleNode)
|
void |
TransformationHasDescriptionImportRule.loadXML(Node ruleNode)
|
void |
JobHasJobLogConfiguredImportRule.loadXML(Node ruleNode)
|
void |
JobHasANoteImportRule.loadXML(Node ruleNode)
|
void |
JobHasNoDisabledHopsImportRule.loadXML(Node ruleNode)
|
void |
TransformationHasNoDisabledHopsImportRule.loadXML(Node ruleNode)
|
void |
DatabaseConfigurationImportRule.loadXML(Node ruleNode)
|
void |
TransformationHasTransLogConfiguredImportRule.loadXML(Node ruleNode)
|
Uses of KettleException in org.pentaho.di.job |
---|
Methods in org.pentaho.di.job that throw KettleException | |
---|---|
boolean |
Job.beginProcessing()
Handle logging at start. |
static Job |
Job.createJobWithNewClassLoader()
Creates the job with new class loader. |
Result |
Job.execute(int nr,
Result result)
Execute a job with previous results passed in. Execute called by JobEntryJob: don't clear the jobEntryResults. |
String |
JobMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface namingInterface,
Repository repository)
|
void |
Job.fireJobFinishListeners()
Sets the finished flag. Then launch all the job listeners and call the jobFinished method for each. |
void |
Job.fireJobStartListeners()
Call all the jobStarted method for each listener. |
static JobConfiguration |
JobConfiguration.fromXML(String xml)
|
List<SQLStatement> |
JobMeta.getSQLStatements(Repository repository,
ProgressMonitorListener monitor)
Builds a list of all the SQL statements that this transformation needs in order to work properly. |
void |
JobListener.jobFinished(Job job)
|
void |
JobAdapter.jobFinished(Job job)
|
void |
JobListener.jobStarted(Job job)
|
void |
JobAdapter.jobStarted(Job job)
|
void |
JobMeta.lookupRepositoryReferences(Repository repository)
Look up the references after import |
SharedObjects |
JobMeta.readSharedObjects()
Read shared objects. |
void |
JobMeta.saveSharedObjects()
|
static String |
Job.sendToSlaveServer(JobMeta jobMeta,
JobExecutionConfiguration executionConfiguration,
Repository repository)
Send to slave server. |
Constructors in org.pentaho.di.job that throw KettleException | |
---|---|
JobConfiguration(Node configNode)
|
|
JobExecutionConfiguration(Node trecNode)
|
Uses of KettleException in org.pentaho.di.job.entries.abort |
---|
Methods in org.pentaho.di.job.entries.abort that throw KettleException | |
---|---|
void |
JobEntryAbort.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryAbort.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.addresultfilenames |
---|
Methods in org.pentaho.di.job.entries.addresultfilenames that throw KettleException | |
---|---|
Result |
JobEntryAddResultFilenames.execute(Result result,
int nr)
|
void |
JobEntryAddResultFilenames.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryAddResultFilenames.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.checkdbconnection |
---|
Methods in org.pentaho.di.job.entries.checkdbconnection that throw KettleException | |
---|---|
void |
JobEntryCheckDbConnections.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryCheckDbConnections.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.checkfilelocked |
---|
Methods in org.pentaho.di.job.entries.checkfilelocked that throw KettleException | |
---|---|
void |
JobEntryCheckFilesLocked.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryCheckFilesLocked.saveRep(Repository rep,
ObjectId id_job)
|
Constructors in org.pentaho.di.job.entries.checkfilelocked that throw KettleException | |
---|---|
LockFile(String filename)
Checks if a file is locked In order to check is a file is locked we will use a dummy renaming exercise |
Uses of KettleException in org.pentaho.di.job.entries.columnsexist |
---|
Methods in org.pentaho.di.job.entries.columnsexist that throw KettleException | |
---|---|
void |
JobEntryColumnsExist.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryColumnsExist.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.connectedtorepository |
---|
Methods in org.pentaho.di.job.entries.connectedtorepository that throw KettleException | |
---|---|
void |
JobEntryConnectedToRepository.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryConnectedToRepository.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.copyfiles |
---|
Methods in org.pentaho.di.job.entries.copyfiles that throw KettleException | |
---|---|
Result |
JobEntryCopyFiles.execute(Result previousResult,
int nr)
|
void |
JobEntryCopyFiles.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryCopyFiles.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.copymoveresultfilenames |
---|
Methods in org.pentaho.di.job.entries.copymoveresultfilenames that throw KettleException | |
---|---|
void |
JobEntryCopyMoveResultFilenames.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryCopyMoveResultFilenames.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.createfile |
---|
Methods in org.pentaho.di.job.entries.createfile that throw KettleException | |
---|---|
Result |
JobEntryCreateFile.execute(Result previousResult,
int nr)
|
void |
JobEntryCreateFile.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryCreateFile.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.createfolder |
---|
Methods in org.pentaho.di.job.entries.createfolder that throw KettleException | |
---|---|
void |
JobEntryCreateFolder.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryCreateFolder.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.delay |
---|
Methods in org.pentaho.di.job.entries.delay that throw KettleException | |
---|---|
void |
JobEntryDelay.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryDelay.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.deletefile |
---|
Methods in org.pentaho.di.job.entries.deletefile that throw KettleException | |
---|---|
void |
JobEntryDeleteFile.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryDeleteFile.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.deletefiles |
---|
Methods in org.pentaho.di.job.entries.deletefiles that throw KettleException | |
---|---|
Result |
JobEntryDeleteFiles.execute(Result result,
int nr)
|
void |
JobEntryDeleteFiles.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryDeleteFiles.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.deletefolders |
---|
Methods in org.pentaho.di.job.entries.deletefolders that throw KettleException | |
---|---|
Result |
JobEntryDeleteFolders.execute(Result result,
int nr)
|
void |
JobEntryDeleteFolders.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryDeleteFolders.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.deleteresultfilenames |
---|
Methods in org.pentaho.di.job.entries.deleteresultfilenames that throw KettleException | |
---|---|
void |
JobEntryDeleteResultFilenames.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryDeleteResultFilenames.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.dostounix |
---|
Methods in org.pentaho.di.job.entries.dostounix that throw KettleException | |
---|---|
Result |
JobEntryDosToUnix.execute(Result previousResult,
int nr)
|
void |
JobEntryDosToUnix.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryDosToUnix.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.dtdvalidator |
---|
Methods in org.pentaho.di.job.entries.dtdvalidator that throw KettleException | |
---|---|
void |
JobEntryDTDValidator.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryDTDValidator.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.empty |
---|
Methods in org.pentaho.di.job.entries.empty that throw KettleException | |
---|---|
Result |
JobEntryEmpty.execute(Result prev_result,
int nr)
|
Uses of KettleException in org.pentaho.di.job.entries.eval |
---|
Methods in org.pentaho.di.job.entries.eval that throw KettleException | |
---|---|
void |
JobEntryEval.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryEval.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.evalfilesmetrics |
---|
Methods in org.pentaho.di.job.entries.evalfilesmetrics that throw KettleException | |
---|---|
Result |
JobEntryEvalFilesMetrics.execute(Result previousResult,
int nr)
|
void |
JobEntryEvalFilesMetrics.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryEvalFilesMetrics.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.evaluatetablecontent |
---|
Methods in org.pentaho.di.job.entries.evaluatetablecontent that throw KettleException | |
---|---|
void |
JobEntryEvalTableContent.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryEvalTableContent.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.exportrepository |
---|
Methods in org.pentaho.di.job.entries.exportrepository that throw KettleException | |
---|---|
void |
JobEntryExportRepository.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryExportRepository.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.filecompare |
---|
Methods in org.pentaho.di.job.entries.filecompare that throw KettleException | |
---|---|
void |
JobEntryFileCompare.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryFileCompare.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.fileexists |
---|
Methods in org.pentaho.di.job.entries.fileexists that throw KettleException | |
---|---|
String |
JobEntryFileExists.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported job that runs this will reside in a ZIP file, we can't reference files relatively. |
void |
JobEntryFileExists.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryFileExists.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.filesexist |
---|
Methods in org.pentaho.di.job.entries.filesexist that throw KettleException | |
---|---|
void |
JobEntryFilesExist.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryFilesExist.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.folderisempty |
---|
Methods in org.pentaho.di.job.entries.folderisempty that throw KettleException | |
---|---|
void |
JobEntryFolderIsEmpty.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryFolderIsEmpty.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.folderscompare |
---|
Methods in org.pentaho.di.job.entries.folderscompare that throw KettleException | |
---|---|
void |
JobEntryFoldersCompare.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryFoldersCompare.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.ftp |
---|
Methods in org.pentaho.di.job.entries.ftp that throw KettleException | |
---|---|
void |
JobEntryFTP.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryFTP.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.ftpdelete |
---|
Methods in org.pentaho.di.job.entries.ftpdelete that throw KettleException | |
---|---|
void |
JobEntryFTPDelete.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryFTPDelete.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.ftpput |
---|
Methods in org.pentaho.di.job.entries.ftpput that throw KettleException | |
---|---|
void |
JobEntryFTPPUT.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryFTPPUT.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.ftpsget |
---|
Methods in org.pentaho.di.job.entries.ftpsget that throw KettleException | |
---|---|
void |
FTPSConnection.changeDirectory(String directory)
this method change FTP working directory |
void |
FTPSConnection.connect()
this method is used to connect to a remote host |
void |
FTPSConnection.createDirectory(String directory)
this method is used to create a directory in remote host |
void |
FTPSConnection.deleteFile(org.ftp4che.util.ftpfile.FTPFile file)
this method is used to delete a file in remote host |
void |
FTPSConnection.deleteFile(String filename)
this method is used to delete a file in remote host |
void |
FTPSConnection.downloadFile(org.ftp4che.util.ftpfile.FTPFile file,
String localFilename)
this method is used to download a file from a remote host |
Result |
JobEntryFTPSGet.execute(Result previousResult,
int nr)
|
List<org.ftp4che.util.ftpfile.FTPFile> |
FTPSConnection.getFileList(String folder)
|
String[] |
FTPSConnection.getFileNames()
this method is used to return filenames in working directory |
void |
JobEntryFTPSGet.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
FTPSConnection.moveToFolder(org.ftp4che.util.ftpfile.FTPFile fromFile,
String targetFoldername)
this method is used to move a file to remote directory |
void |
JobEntryFTPSGet.saveRep(Repository rep,
ObjectId id_job)
|
void |
FTPSConnection.setBinaryMode(boolean type)
public void setBinaryMode(boolean type) this method is used to set the transfer type to binary |
void |
FTPSConnection.uploadFile(String localFileName,
String shortFileName)
this method is used to upload a file to a remote host |
Uses of KettleException in org.pentaho.di.job.entries.ftpsput |
---|
Methods in org.pentaho.di.job.entries.ftpsput that throw KettleException | |
---|---|
void |
JobEntryFTPSPUT.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryFTPSPUT.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.getpop |
---|
Methods in org.pentaho.di.job.entries.getpop that throw KettleException | |
---|---|
void |
MailConnection.closeFolder(boolean expunge)
Close folder. |
void |
MailConnection.connect()
Open the connection. |
void |
MailConnection.deleteMessage()
Delete current fetched message |
void |
MailConnection.deleteMessages(boolean setCounter)
Delete messages. |
void |
MailConnection.disconnect()
Disconnect from the server and close folder, connection. |
void |
MailConnection.disconnect(boolean expunge)
Disconnect from the server and close folder, connection. |
Result |
JobEntryGetPOP.execute(Result previousResult,
int nr)
|
void |
MailConnection.fetchNext()
Get next message. |
int |
MailConnection.getAttachedFilesCount(Pattern pattern)
Returns attached files count for the current message |
void |
JobEntryGetPOP.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
MailConnection.moveMessage()
Move current message to a target folder. |
void |
MailConnection.moveMessages()
Move messages to a folder. |
void |
MailConnection.openFolder(boolean write)
Open the default folder (INBOX) |
void |
MailConnection.openFolder(String foldername,
boolean write)
Open the folder. |
void |
MailConnection.openFolder(String foldername,
boolean defaultFolder,
boolean write)
Open the folder. |
void |
MailConnection.retrieveMessages()
Retrieve all messages from server |
String[] |
MailConnection.returnAllFolders()
Returns all subfolders of the current folder |
String[] |
MailConnection.returnAllFolders(javax.mail.Folder folder)
Returns all subfolders of the specified folder |
String[] |
MailConnection.returnAllFolders(String folder)
Returns all subfolders of the folder folder |
void |
MailConnection.saveAttachedFiles(String foldername)
Save attached files to a folder. |
void |
MailConnection.saveAttachedFiles(String foldername,
Pattern pattern)
Save attached files to a folder. |
void |
MailConnection.saveMessageContentToFile(String filename,
String foldername)
Export message content to a filename. |
void |
JobEntryGetPOP.saveRep(Repository rep,
ObjectId id_job)
|
void |
MailConnection.setDestinationFolder(String foldername,
boolean createFolder)
Set destination folder |
Constructors in org.pentaho.di.job.entries.getpop that throw KettleException | |
---|---|
MailConnection(LogChannelInterface log,
int protocol,
String server,
int port,
String username,
String password,
boolean usessl,
boolean useproxy,
String proxyusername)
Construct a new Database MailConnection |
Uses of KettleException in org.pentaho.di.job.entries.http |
---|
Methods in org.pentaho.di.job.entries.http that throw KettleException | |
---|---|
void |
JobEntryHTTP.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryHTTP.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.job |
---|
Methods in org.pentaho.di.job.entries.job that throw KettleException | |
---|---|
Result |
JobEntryJob.execute(Result result,
int nr)
|
String |
JobEntryJob.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface namingInterface,
Repository repository)
We're going to load the transformation meta data referenced here. |
JobMeta |
JobEntryJob.getJobMeta(Repository rep,
VariableSpace space)
|
List<SQLStatement> |
JobEntryJob.getSQLStatements(Repository repository)
|
List<SQLStatement> |
JobEntryJob.getSQLStatements(Repository repository,
VariableSpace space)
|
void |
JobEntryJob.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
Load the jobentry from repository |
void |
JobEntryJob.lookupRepositoryReferences(Repository repository)
Look up the references after import |
void |
JobEntryJob.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.mail |
---|
Methods in org.pentaho.di.job.entries.mail that throw KettleException | |
---|---|
void |
JobEntryMail.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryMail.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.mailvalidator |
---|
Methods in org.pentaho.di.job.entries.mailvalidator that throw KettleException | |
---|---|
void |
JobEntryMailValidator.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryMailValidator.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.movefiles |
---|
Methods in org.pentaho.di.job.entries.movefiles that throw KettleException | |
---|---|
Result |
JobEntryMoveFiles.execute(Result previousResult,
int nr)
|
void |
JobEntryMoveFiles.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryMoveFiles.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.msaccessbulkload |
---|
Methods in org.pentaho.di.job.entries.msaccessbulkload that throw KettleException | |
---|---|
void |
JobEntryMSAccessBulkLoad.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryMSAccessBulkLoad.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.msgboxinfo |
---|
Methods in org.pentaho.di.job.entries.msgboxinfo that throw KettleException | |
---|---|
void |
JobEntryMsgBoxInfo.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryMsgBoxInfo.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.mssqlbulkload |
---|
Methods in org.pentaho.di.job.entries.mssqlbulkload that throw KettleException | |
---|---|
void |
JobEntryMssqlBulkLoad.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryMssqlBulkLoad.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.mysqlbulkfile |
---|
Methods in org.pentaho.di.job.entries.mysqlbulkfile that throw KettleException | |
---|---|
void |
JobEntryMysqlBulkFile.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryMysqlBulkFile.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.mysqlbulkload |
---|
Methods in org.pentaho.di.job.entries.mysqlbulkload that throw KettleException | |
---|---|
void |
JobEntryMysqlBulkLoad.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryMysqlBulkLoad.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.pgpdecryptfiles |
---|
Methods in org.pentaho.di.job.entries.pgpdecryptfiles that throw KettleException | |
---|---|
Result |
JobEntryPGPDecryptFiles.execute(Result previousResult,
int nr)
|
void |
JobEntryPGPDecryptFiles.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryPGPDecryptFiles.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.pgpencryptfiles |
---|
Methods in org.pentaho.di.job.entries.pgpencryptfiles that throw KettleException | |
---|---|
String |
GPG.decrypt(String cryptedText,
String passPhrase)
Decrypt a string |
void |
GPG.decryptFile(org.apache.commons.vfs.FileObject cryptedFilename,
String passPhrase,
org.apache.commons.vfs.FileObject decryptedFilename)
Decrypt a file |
void |
GPG.decryptFile(String cryptedFilename,
String passPhrase,
String decryptedFilename)
Decrypt a file |
void |
JobEntryPGPEncryptFiles.doJob(int actionType,
org.apache.commons.vfs.FileObject sourcefile,
String userID,
org.apache.commons.vfs.FileObject destinationfile)
|
String |
GPG.encrypt(String plainText,
String keyID)
Encrypt a string |
void |
GPG.encryptFile(org.apache.commons.vfs.FileObject filename,
String userID,
org.apache.commons.vfs.FileObject cryptedFilename,
boolean asciiMode)
Encrypt a file |
void |
GPG.encryptFile(String filename,
String userID,
String cryptedFilename,
boolean asciiMode)
Encrypt a file |
void |
JobEntryPGPEncryptFiles.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryPGPEncryptFiles.saveRep(Repository rep,
ObjectId id_job)
|
String |
GPG.sign(String stringToSign,
String passPhrase)
Sign |
String |
GPG.signAndEncrypt(String plainText,
String userID,
String passPhrase)
Signs and encrypts a string |
void |
GPG.signAndEncryptFile(org.apache.commons.vfs.FileObject file,
String userID,
org.apache.commons.vfs.FileObject cryptedFile,
boolean asciiMode)
Sign and encrypt a file |
void |
GPG.signAndEncryptFile(String filename,
String userID,
String cryptedFilename,
boolean asciiMode)
Sign and encrypt a file |
void |
GPG.signFile(org.apache.commons.vfs.FileObject file,
String userID,
org.apache.commons.vfs.FileObject signedFile,
boolean asciiMode)
Sign a file |
void |
GPG.signFile(String filename,
String userID,
String signedFilename,
boolean asciiMode)
Sign a file |
void |
GPG.verifyDetachedSignature(org.apache.commons.vfs.FileObject signatureFile,
org.apache.commons.vfs.FileObject originalFile)
Verify a signature for detached file |
void |
GPG.verifyDetachedSignature(String signatureFilename,
String originalFilename)
Verify a signature for detached file |
void |
GPG.verifySignature(org.apache.commons.vfs.FileObject filename)
Verify a signature |
void |
GPG.verifySignature(String filename)
Verify a signature |
Constructors in org.pentaho.di.job.entries.pgpencryptfiles that throw KettleException | |
---|---|
GPG(String gpgFilename,
LogChannelInterface logInterface)
Constructs a new GnuPG |
Uses of KettleException in org.pentaho.di.job.entries.pgpverify |
---|
Methods in org.pentaho.di.job.entries.pgpverify that throw KettleException | |
---|---|
String |
JobEntryPGPVerify.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported job that runs this will reside in a ZIP file, we can't reference files relatively. |
void |
JobEntryPGPVerify.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryPGPVerify.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.ping |
---|
Methods in org.pentaho.di.job.entries.ping that throw KettleException | |
---|---|
void |
JobEntryPing.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryPing.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.setvariables |
---|
Methods in org.pentaho.di.job.entries.setvariables that throw KettleException | |
---|---|
Result |
JobEntrySetVariables.execute(Result result,
int nr)
|
void |
JobEntrySetVariables.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySetVariables.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.sftp |
---|
Methods in org.pentaho.di.job.entries.sftp that throw KettleException | |
---|---|
void |
JobEntrySFTP.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySFTP.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.sftpput |
---|
Methods in org.pentaho.di.job.entries.sftpput that throw KettleException | |
---|---|
Result |
JobEntrySFTPPUT.execute(Result previousResult,
int nr)
|
void |
JobEntrySFTPPUT.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySFTPPUT.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.shell |
---|
Methods in org.pentaho.di.job.entries.shell that throw KettleException | |
---|---|
Result |
JobEntryShell.execute(Result result,
int nr)
|
void |
JobEntryShell.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryShell.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.simpleeval |
---|
Methods in org.pentaho.di.job.entries.simpleeval that throw KettleException | |
---|---|
Result |
JobEntrySimpleEval.execute(Result previousResult,
int nr)
|
void |
JobEntrySimpleEval.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySimpleEval.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.snmptrap |
---|
Methods in org.pentaho.di.job.entries.snmptrap that throw KettleException | |
---|---|
void |
JobEntrySNMPTrap.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySNMPTrap.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.special |
---|
Methods in org.pentaho.di.job.entries.special that throw KettleException | |
---|---|
void |
JobEntrySpecial.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySpecial.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.sql |
---|
Methods in org.pentaho.di.job.entries.sql that throw KettleException | |
---|---|
void |
JobEntrySQL.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySQL.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.ssh2get |
---|
Methods in org.pentaho.di.job.entries.ssh2get that throw KettleException | |
---|---|
void |
JobEntrySSH2GET.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySSH2GET.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.ssh2put |
---|
Methods in org.pentaho.di.job.entries.ssh2put that throw KettleException | |
---|---|
void |
JobEntrySSH2PUT.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySSH2PUT.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.success |
---|
Methods in org.pentaho.di.job.entries.success that throw KettleException | |
---|---|
void |
JobEntrySuccess.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySuccess.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.syslog |
---|
Subclasses of KettleException in org.pentaho.di.job.entries.syslog | |
---|---|
class |
SyslogException
This exception is throws when and error is found in a Syslog sending process. |
Methods in org.pentaho.di.job.entries.syslog that throw KettleException | |
---|---|
void |
JobEntrySyslog.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntrySyslog.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.tableexists |
---|
Methods in org.pentaho.di.job.entries.tableexists that throw KettleException | |
---|---|
void |
JobEntryTableExists.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryTableExists.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.talendjobexec |
---|
Methods in org.pentaho.di.job.entries.talendjobexec that throw KettleException | |
---|---|
String |
JobEntryTalendJobExec.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported job that runs this will reside in a ZIP file, we can't reference files relatively. |
void |
JobEntryTalendJobExec.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryTalendJobExec.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.trans |
---|
Methods in org.pentaho.di.job.entries.trans that throw KettleException | |
---|---|
Result |
JobEntryTrans.execute(Result result,
int nr)
Execute this job entry and return the result. |
String |
JobEntryTrans.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface namingInterface,
Repository repository)
We're going to load the transformation meta data referenced here. |
List<SQLStatement> |
JobEntryTrans.getSQLStatements(Repository repository)
|
List<SQLStatement> |
JobEntryTrans.getSQLStatements(Repository repository,
VariableSpace space)
|
TransMeta |
JobEntryTrans.getTransMeta(Repository rep,
VariableSpace space)
|
void |
JobEntryTrans.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryTrans.lookupRepositoryReferences(Repository repository)
Look up the references after import |
void |
JobEntryTrans.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.truncatetables |
---|
Methods in org.pentaho.di.job.entries.truncatetables that throw KettleException | |
---|---|
void |
JobEntryTruncateTables.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryTruncateTables.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.unzip |
---|
Methods in org.pentaho.di.job.entries.unzip that throw KettleException | |
---|---|
void |
JobEntryUnZip.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryUnZip.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.waitforfile |
---|
Methods in org.pentaho.di.job.entries.waitforfile that throw KettleException | |
---|---|
void |
JobEntryWaitForFile.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryWaitForFile.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.waitforsql |
---|
Methods in org.pentaho.di.job.entries.waitforsql that throw KettleException | |
---|---|
void |
JobEntryWaitForSQL.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryWaitForSQL.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.webserviceavailable |
---|
Methods in org.pentaho.di.job.entries.webserviceavailable that throw KettleException | |
---|---|
void |
JobEntryWebServiceAvailable.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryWebServiceAvailable.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.writetofile |
---|
Methods in org.pentaho.di.job.entries.writetofile that throw KettleException | |
---|---|
void |
JobEntryWriteToFile.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryWriteToFile.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.writetolog |
---|
Methods in org.pentaho.di.job.entries.writetolog that throw KettleException | |
---|---|
void |
JobEntryWriteToLog.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryWriteToLog.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.xmlwellformed |
---|
Methods in org.pentaho.di.job.entries.xmlwellformed that throw KettleException | |
---|---|
Result |
JobEntryXMLWellFormed.execute(Result previousResult,
int nr)
|
void |
JobEntryXMLWellFormed.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryXMLWellFormed.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.xsdvalidator |
---|
Methods in org.pentaho.di.job.entries.xsdvalidator that throw KettleException | |
---|---|
void |
JobEntryXSDValidator.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryXSDValidator.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.xslt |
---|
Methods in org.pentaho.di.job.entries.xslt that throw KettleException | |
---|---|
Result |
JobEntryXSLT.execute(Result previousResult,
int nr)
|
void |
JobEntryXSLT.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryXSLT.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entries.zipfile |
---|
Methods in org.pentaho.di.job.entries.zipfile that throw KettleException | |
---|---|
void |
JobEntryZipFile.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
JobEntryZipFile.saveRep(Repository rep,
ObjectId id_job)
|
Uses of KettleException in org.pentaho.di.job.entry |
---|
Methods in org.pentaho.di.job.entry that throw KettleException | |
---|---|
Result |
JobEntryInterface.execute(Result prev_result,
int nr)
Execute the job entry. |
String |
JobEntryBase.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface namingInterface,
Repository repository)
Exports the object to a flat-file system, adding content with filename keys to a set of definitions. |
String |
JobEntryInterface.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface namingInterface,
Repository repository)
Exports the object to a flat-file system, adding content with filename keys to a set of definitions. |
List<SQLStatement> |
JobEntryBase.getSQLStatements(Repository repository)
Gets the SQL statements needed by this job entry to execute successfully. |
List<SQLStatement> |
JobEntryInterface.getSQLStatements(Repository repository)
Gets the SQL statements needed by this job entry to execute successfully. |
List<SQLStatement> |
JobEntryBase.getSQLStatements(Repository repository,
VariableSpace space)
Gets the SQL statements needed by this job entry to execute successfully, given a set of variables. |
List<SQLStatement> |
JobEntryInterface.getSQLStatements(Repository repository,
VariableSpace space)
Gets the SQL statements needed by this job entry to execute successfully, given a set of variables. |
void |
JobEntryBase.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
This method is called by PDI whenever a job entry needs to read its configuration from a PDI repository. |
void |
JobEntryInterface.loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
This method is called by PDI whenever a job entry needs to read its configuration from a PDI repository. |
void |
JobEntryBase.lookupRepositoryReferences(Repository repository)
Looks up the references after import |
void |
JobEntryInterface.lookupRepositoryReferences(Repository repository)
Look up the references after import |
void |
JobEntryBase.parseRepositoryObjects(Repository rep)
Parses the repository objects. |
void |
JobEntryBase.saveRep(Repository rep,
ObjectId id_job)
This method is called by PDI whenever a job entry needs to save its settings to a PDI repository. |
void |
JobEntryInterface.saveRep(Repository rep,
ObjectId id_job)
This method is called by PDI whenever a job entry needs to save its settings to a PDI repository. |
Uses of KettleException in org.pentaho.di.kitchen |
---|
Methods in org.pentaho.di.kitchen that throw KettleException | |
---|---|
static void |
Kitchen.configureLogging(CommandLineOption maxLogLinesOption,
CommandLineOption maxLogTimeoutOption)
Configure the central log store from the provided command line options |
static void |
Kitchen.main(String[] a)
|
void |
KitchenTest.testArgumentMaxLogLines_valid()
|
void |
KitchenTest.testArgumentMaxLogTimeout_valid()
|
void |
KitchenTest.testConfigureLogging()
|
Uses of KettleException in org.pentaho.di.pan |
---|
Methods in org.pentaho.di.pan that throw KettleException | |
---|---|
static void |
Pan.main(String[] a)
|
Uses of KettleException in org.pentaho.di.repository |
---|
Methods in org.pentaho.di.repository that throw KettleException | |
---|---|
void |
Repository.connect(String username,
String password)
Connect to the repository. |
IUser |
RepositorySecurityManager.constructUser()
|
int |
Repository.countNrJobEntryAttributes(ObjectId id_jobentry,
String code)
|
int |
Repository.countNrStepAttributes(ObjectId id_step,
String code)
|
RepositoryDirectoryInterface |
Repository.createRepositoryDirectory(RepositoryDirectoryInterface parentDirectory,
String directoryPath)
Create a new directory, possibly by creating several sub-directies of / at the same time. |
void |
Repository.deleteClusterSchema(ObjectId id_cluster)
|
void |
Repository.deleteDatabaseMeta(String databaseName)
Remove a database connection from the repository |
void |
Repository.deleteJob(ObjectId id_job)
|
void |
Repository.deletePartitionSchema(ObjectId id_partition_schema)
|
void |
Repository.deleteRepositoryDirectory(RepositoryDirectoryInterface dir)
|
void |
Repository.deleteSlave(ObjectId id_slave)
|
void |
Repository.deleteTransformation(ObjectId id_transformation)
Delete everything related to a transformation from the repository. |
void |
RepositorySecurityManager.deleteUsers(List<IUser> users)
|
void |
RepositorySecurityManager.delUser(ObjectId id_user)
|
void |
RepositorySecurityManager.delUser(String name)
|
boolean |
Repository.exists(String name,
RepositoryDirectoryInterface repositoryDirectory,
RepositoryObjectType objectType)
See if a repository object exists in the repository |
void |
IRepositoryExporter.exportAllObjects(ProgressMonitorListener monitor,
String xmlFilename,
RepositoryDirectoryInterface root,
String exportType)
Export objects of a repository. |
void |
RepositoryExporter.exportAllObjects(ProgressMonitorListener monitor,
String xmlFilename,
RepositoryDirectoryInterface root,
String exportType)
|
RepositoryDirectoryInterface |
Repository.findDirectory(ObjectId directory)
|
RepositoryDirectoryInterface |
Repository.findDirectory(String directory)
|
List<String> |
RepositorySecurityProvider.getAllRoles()
Retrieves all roles in the system |
List<String> |
RepositorySecurityProvider.getAllUsers()
Retrieves all users in the system |
boolean |
RepositoryAttributeInterface.getAttributeBoolean(String code)
Get a boolean attribute, if the attribute is not found, return false; |
long |
RepositoryAttributeInterface.getAttributeInteger(String code)
Get an integer attribute. |
String |
RepositoryAttributeInterface.getAttributeString(String code)
Get a string attribute. |
ObjectId |
Repository.getClusterID(String name)
|
ObjectId[] |
Repository.getClusterIDs(boolean includeDeleted)
|
String[] |
Repository.getClusterNames(boolean includeDeleted)
|
ObjectId |
Repository.getDatabaseID(String name)
|
ObjectId[] |
Repository.getDatabaseIDs(boolean includeDeleted)
|
String[] |
Repository.getDatabaseNames(boolean includeDeleted)
|
RepositoryDirectoryInterface |
Repository.getDefaultSaveDirectory(RepositoryElementInterface repositoryElement)
|
String[] |
Repository.getDirectoryNames(ObjectId id_directory)
Returns the child directory names of a parent directory |
List<RepositoryElementMetaInterface> |
Repository.getJobAndTransformationObjects(ObjectId id_directory,
boolean includeDeleted)
Gets all job and transformation objects in the given directory. |
boolean |
Repository.getJobEntryAttributeBoolean(ObjectId id_jobentry,
int nr,
String code)
|
boolean |
Repository.getJobEntryAttributeBoolean(ObjectId id_jobentry,
String code)
|
boolean |
Repository.getJobEntryAttributeBoolean(ObjectId id_jobentry,
String code,
boolean def)
|
long |
Repository.getJobEntryAttributeInteger(ObjectId id_jobentry,
int nr,
String code)
|
long |
Repository.getJobEntryAttributeInteger(ObjectId id_jobentry,
String code)
|
String |
Repository.getJobEntryAttributeString(ObjectId id_jobentry,
int nr,
String code)
|
String |
Repository.getJobEntryAttributeString(ObjectId id_jobentry,
String code)
|
ObjectId |
Repository.getJobId(String name,
RepositoryDirectoryInterface repositoryDirectory)
|
String[] |
Repository.getJobNames(ObjectId id_directory,
boolean includeDeleted)
|
List<RepositoryElementMetaInterface> |
Repository.getJobObjects(ObjectId id_directory,
boolean includeDeleted)
|
String[] |
Repository.getJobsUsingDatabase(ObjectId id_database)
Get the repository version. |
RepositoryObject |
Repository.getObjectInformation(ObjectId objectId,
RepositoryObjectType objectType)
Get more information about a certain object ID in the form of the RepositoryObject |
ObjectId |
Repository.getPartitionSchemaID(String name)
|
ObjectId[] |
Repository.getPartitionSchemaIDs(boolean includeDeleted)
|
String[] |
Repository.getPartitionSchemaNames(boolean includeDeleted)
|
IRepositoryService |
Repository.getService(Class<? extends IRepositoryService> clazz)
Retrieves a given repository service |
List<Class<? extends IRepositoryService>> |
Repository.getServiceInterfaces()
Retrieves the current list of of IRepository Services. |
ObjectId |
Repository.getSlaveID(String name)
|
ObjectId[] |
Repository.getSlaveIDs(boolean includeDeleted)
|
String[] |
Repository.getSlaveNames(boolean includeDeleted)
|
List<SlaveServer> |
Repository.getSlaveServers()
|
boolean |
Repository.getStepAttributeBoolean(ObjectId id_step,
int nr,
String code)
|
boolean |
Repository.getStepAttributeBoolean(ObjectId id_step,
int nr,
String code,
boolean def)
|
boolean |
Repository.getStepAttributeBoolean(ObjectId id_step,
String code)
|
long |
Repository.getStepAttributeInteger(ObjectId id_step,
int nr,
String code)
|
long |
Repository.getStepAttributeInteger(ObjectId id_step,
String code)
|
String |
Repository.getStepAttributeString(ObjectId id_step,
int nr,
String code)
|
String |
Repository.getStepAttributeString(ObjectId id_step,
String code)
|
ObjectId |
Repository.getTransformationID(String name,
RepositoryDirectoryInterface repositoryDirectory)
|
String[] |
Repository.getTransformationNames(ObjectId id_directory,
boolean includeDeleted)
|
List<RepositoryElementMetaInterface> |
Repository.getTransformationObjects(ObjectId id_directory,
boolean includeDeleted)
|
String[] |
Repository.getTransformationsUsingDatabase(ObjectId id_database)
|
RepositoryDirectoryInterface |
Repository.getUserHomeDirectory()
|
ObjectId |
RepositorySecurityManager.getUserID(String login)
|
ObjectId[] |
RepositorySecurityManager.getUserIDs()
|
String[] |
RepositorySecurityProvider.getUserLogins()
|
List<IUser> |
RepositorySecurityManager.getUsers()
|
boolean |
Repository.hasService(Class<? extends IRepositoryService> clazz)
Checks whether a given repository service is available or not |
void |
Repository.insertJobEntryDatabase(ObjectId id_job,
ObjectId id_jobentry,
ObjectId id_database)
|
ObjectId |
Repository.insertLogEntry(String description)
Insert an entry in the audit trail of the repository. |
void |
Repository.insertStepDatabase(ObjectId id_transformation,
ObjectId id_step,
ObjectId id_database)
|
boolean |
RepositorySecurityManager.isManaged()
|
ClusterSchema |
Repository.loadClusterSchema(ObjectId id_cluster_schema,
List<SlaveServer> slaveServers,
String versionLabel)
|
Condition |
Repository.loadConditionFromStepAttribute(ObjectId id_step,
String code)
Load a condition from the repository with the Object ID stored in a step attribute. |
DatabaseMeta |
Repository.loadDatabaseMeta(ObjectId id_database,
String revision)
Load the Database connection Metadata from the repository |
DatabaseMeta |
Repository.loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry,
String nameCode,
int nr,
String idCode,
List<DatabaseMeta> databases)
This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code. |
DatabaseMeta |
Repository.loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry,
String nameCode,
String idCode,
List<DatabaseMeta> databases)
This method is introduced to avoid having to go over an integer/string/whatever in the interface and the job entry code. |
DatabaseMeta |
Repository.loadDatabaseMetaFromStepAttribute(ObjectId id_step,
String code,
List<DatabaseMeta> databases)
This method is introduced to avoid having to go over an integer/string/whatever in the interface and the step code. |
JobMeta |
Repository.loadJob(ObjectId id_job,
String versionLabel)
Load a job from the repository by id |
JobMeta |
Repository.loadJob(String jobname,
RepositoryDirectoryInterface repdir,
ProgressMonitorListener monitor,
String revision)
Load a job from the repository |
PartitionSchema |
Repository.loadPartitionSchema(ObjectId id_partition_schema,
String versionLabel)
|
RepositoryDirectoryInterface |
Repository.loadRepositoryDirectoryTree()
|
SlaveServer |
Repository.loadSlaveServer(ObjectId id_slave_server,
String versionLabel)
|
TransMeta |
Repository.loadTransformation(ObjectId id_transformation,
String versionLabel)
Load a transformation by id |
TransMeta |
Repository.loadTransformation(String transname,
RepositoryDirectoryInterface repdir,
ProgressMonitorListener monitor,
boolean setInternalVariables,
String revision)
Load a transformation with a name from a folder in the repository |
IUser |
RepositorySecurityManager.loadUserInfo(String username)
|
void |
BaseRepositoryMeta.loadXML(Node repnode,
List<DatabaseMeta> databases)
|
void |
RepositoryMeta.loadXML(Node repnode,
List<DatabaseMeta> databases)
|
boolean |
RepositoriesMeta.readData()
|
List<DatabaseMeta> |
Repository.readDatabases()
Read all the databases defined in the repository |
void |
RepositoriesMeta.readDataFromInputStream(InputStream is)
|
SharedObjects |
Repository.readJobMetaSharedObjects(JobMeta jobMeta)
|
SharedObjects |
Repository.readTransSharedObjects(TransMeta transMeta)
|
ObjectId |
Repository.renameJob(ObjectId id_job,
RepositoryDirectoryInterface newDirectory,
String newName)
Move / rename a job |
ObjectId |
Repository.renameRepositoryDirectory(ObjectId id,
RepositoryDirectoryInterface newParentDir,
String newName)
Move / rename a repository directory |
ObjectId |
Repository.renameTransformation(ObjectId id_transformation,
RepositoryDirectoryInterface newDirectory,
String newName)
Move / rename a transformation |
void |
RepositorySecurityManager.renameUser(ObjectId id_user,
String newname)
|
void |
Repository.save(RepositoryElementInterface repositoryElement,
String versionComment,
ProgressMonitorListener monitor)
|
void |
Repository.save(RepositoryElementInterface repositoryElement,
String versionComment,
ProgressMonitorListener monitor,
boolean overwrite)
Save an object to the repository optionally overwriting any associated objects. |
void |
Repository.saveConditionStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
Condition condition)
This method saves the object ID of the condition object (if not null) in the step attributes |
void |
Repository.saveDatabaseMetaJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String nameCode,
String idCode,
DatabaseMeta database)
This method saves the object ID of the database object (if not null) in the job entry attributes |
void |
Repository.saveDatabaseMetaJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String nameCode,
String idCode,
DatabaseMeta database)
This method saves the object ID of the database object (if not null) in the job entry attributes |
void |
Repository.saveDatabaseMetaStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
DatabaseMeta database)
This method saves the object ID of the database object (if not null) in the step attributes |
void |
Repository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String code,
boolean value)
|
void |
Repository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String code,
long value)
|
void |
Repository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String code,
String value)
|
void |
Repository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
boolean value)
|
void |
Repository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
long value)
|
void |
Repository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
String value)
|
void |
Repository.saveRepositoryDirectory(RepositoryDirectoryInterface dir)
|
void |
Repository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
boolean value)
|
void |
Repository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
double value)
|
void |
Repository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
long value)
|
void |
Repository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
String value)
|
void |
Repository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
boolean value)
|
void |
Repository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
double value)
|
void |
Repository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
long value)
|
void |
Repository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
String value)
|
void |
RepositorySecurityManager.saveUserInfo(IUser user)
|
void |
RepositoryAttributeInterface.setAttribute(String code,
boolean value)
Set a boolean attribute |
void |
RepositoryAttributeInterface.setAttribute(String code,
long value)
Set an integer attribute |
void |
RepositoryAttributeInterface.setAttribute(String code,
String value)
Set a String attribute |
void |
RepositorySecurityManager.setUsers(List<IUser> users)
|
void |
Repository.undeleteObject(RepositoryElementMetaInterface repositoryObject)
Removes he deleted flag from a repository element in the repository. |
void |
RepositorySecurityManager.updateUser(IUser user)
|
void |
BaseRepositorySecurityProvider.validateAction(RepositoryOperation... operations)
|
void |
RepositorySecurityProvider.validateAction(RepositoryOperation... operations)
Validates the supplied operation. |
static void |
RepositoryImporter.validateImportedElement(ImportRules importRules,
Object subject)
Validates the repository element that is about to get imported against the list of import rules. |
void |
RepositoriesMeta.writeData()
|
Uses of KettleException in org.pentaho.di.repository.filerep |
---|
Methods in org.pentaho.di.repository.filerep that throw KettleException | |
---|---|
void |
KettleFileRepository.connect(String username,
String password)
|
int |
KettleFileRepository.countNrJobEntryAttributes(ObjectId id_jobentry,
String code)
|
int |
KettleFileRepository.countNrStepAttributes(ObjectId id_step,
String code)
|
RepositoryDirectoryInterface |
KettleFileRepository.createRepositoryDirectory(RepositoryDirectoryInterface parentDirectory,
String directoryPath)
|
void |
KettleFileRepository.deleteClusterSchema(ObjectId id_cluster)
|
void |
KettleFileRepository.deleteCondition(ObjectId id_condition)
|
void |
KettleFileRepository.deleteDatabaseMeta(String databaseName)
|
void |
KettleFileRepository.deleteFile(String filename)
|
void |
KettleFileRepository.deleteJob(ObjectId id_job)
|
void |
KettleFileRepository.deletePartitionSchema(ObjectId id_partition_schema)
|
void |
KettleFileRepository.deleteRepositoryDirectory(RepositoryDirectoryInterface dir)
|
void |
KettleFileRepository.deleteRootObject(String name,
String extension)
|
void |
KettleFileRepository.deleteSlave(ObjectId id_slave)
|
void |
KettleFileRepository.deleteTransformation(ObjectId id_transformation)
|
void |
KettleFileRepository.delUser(ObjectId id_user)
|
boolean |
KettleFileRepository.exists(String name,
RepositoryDirectoryInterface repositoryDirectory,
RepositoryObjectType objectType)
|
RepositoryDirectoryInterface |
KettleFileRepository.findDirectory(ObjectId directory)
|
RepositoryDirectoryInterface |
KettleFileRepository.findDirectory(String directory)
|
List<String> |
KettleFileRepositorySecurityProvider.getAllRoles()
|
List<String> |
KettleFileRepositorySecurityProvider.getAllUsers()
|
ObjectId |
KettleFileRepository.getClusterID(String name)
|
ObjectId[] |
KettleFileRepository.getClusterIDs(boolean includeDeleted)
|
String[] |
KettleFileRepository.getClusterNames(boolean includeDeleted)
|
ObjectId[] |
KettleFileRepository.getClusterSlaveIDs(ObjectId id_cluster_schema)
|
String[] |
KettleFileRepository.getClustersUsingSlave(ObjectId id_slave)
|
ObjectId[] |
KettleFileRepository.getDatabaseAttributeIDs(ObjectId id_database)
|
ObjectId |
KettleFileRepository.getDatabaseID(String name)
|
ObjectId[] |
KettleFileRepository.getDatabaseIDs(boolean includeDeleted)
|
String[] |
KettleFileRepository.getDatabaseNames(boolean includeDeleted)
|
RepositoryDirectoryInterface |
KettleFileRepository.getDefaultSaveDirectory(RepositoryElementInterface repositoryElement)
|
String[] |
KettleFileRepository.getDirectoryNames(ObjectId id_directory)
|
List<RepositoryElementMetaInterface> |
KettleFileRepository.getJobAndTransformationObjects(ObjectId id_directory,
boolean includeDeleted)
|
boolean |
KettleFileRepository.getJobEntryAttributeBoolean(ObjectId id_jobentry,
int nr,
String code)
|
boolean |
KettleFileRepository.getJobEntryAttributeBoolean(ObjectId id_jobentry,
String code)
|
boolean |
KettleFileRepository.getJobEntryAttributeBoolean(ObjectId id_jobentry,
String code,
boolean def)
|
long |
KettleFileRepository.getJobEntryAttributeInteger(ObjectId id_jobentry,
int nr,
String code)
|
long |
KettleFileRepository.getJobEntryAttributeInteger(ObjectId id_jobentry,
String code)
|
String |
KettleFileRepository.getJobEntryAttributeString(ObjectId id_jobentry,
int nr,
String code)
|
String |
KettleFileRepository.getJobEntryAttributeString(ObjectId id_jobentry,
String code)
|
ObjectId |
KettleFileRepository.getJobId(String name,
RepositoryDirectoryInterface repositoryDirectory)
|
String[] |
KettleFileRepository.getJobNames(ObjectId id_directory,
boolean includeDeleted)
|
ObjectId[] |
KettleFileRepository.getJobNoteIDs(ObjectId id_job)
|
List<RepositoryElementMetaInterface> |
KettleFileRepository.getJobObjects(ObjectId id_directory,
boolean includeDeleted)
|
String[] |
KettleFileRepository.getJobsUsingDatabase(ObjectId id_database)
|
int |
KettleFileRepository.getNrSubDirectories(ObjectId id_directory)
|
RepositoryObject |
KettleFileRepository.getObjectInformation(ObjectId objectId,
RepositoryObjectType objectType)
|
ObjectId |
KettleFileRepository.getPartitionSchemaID(String name)
|
ObjectId[] |
KettleFileRepository.getPartitionSchemaIDs(boolean includeDeleted)
|
String[] |
KettleFileRepository.getPartitionSchemaNames(boolean includeDeleted)
|
ObjectId |
KettleFileRepository.getRootDirectoryID()
|
IRepositoryService |
KettleFileRepository.getService(Class<? extends IRepositoryService> clazz)
|
List<Class<? extends IRepositoryService>> |
KettleFileRepository.getServiceInterfaces()
|
ObjectId |
KettleFileRepository.getSlaveID(String name)
|
ObjectId[] |
KettleFileRepository.getSlaveIDs(boolean includeDeleted)
|
String[] |
KettleFileRepository.getSlaveNames(boolean includeDeleted)
|
List<SlaveServer> |
KettleFileRepository.getSlaveServers()
|
boolean |
KettleFileRepository.getStepAttributeBoolean(ObjectId id_step,
int nr,
String code)
|
boolean |
KettleFileRepository.getStepAttributeBoolean(ObjectId id_step,
int nr,
String code,
boolean def)
|
boolean |
KettleFileRepository.getStepAttributeBoolean(ObjectId id_step,
String code)
|
long |
KettleFileRepository.getStepAttributeInteger(ObjectId id_step,
int nr,
String code)
|
long |
KettleFileRepository.getStepAttributeInteger(ObjectId id_step,
String code)
|
String |
KettleFileRepository.getStepAttributeString(ObjectId id_step,
int nr,
String code)
|
String |
KettleFileRepository.getStepAttributeString(ObjectId id_step,
String code)
|
ObjectId[] |
KettleFileRepository.getSubConditionIDs(ObjectId id_condition)
|
ObjectId[] |
KettleFileRepository.getSubDirectoryIDs(ObjectId id_directory)
|
ObjectId[] |
KettleFileRepository.getTransformationClusterSchemaIDs(ObjectId id_transformation)
|
ObjectId[] |
KettleFileRepository.getTransformationConditionIDs(ObjectId id_transformation)
|
ObjectId[] |
KettleFileRepository.getTransformationDatabaseIDs(ObjectId id_transformation)
|
ObjectId |
KettleFileRepository.getTransformationID(String name,
RepositoryDirectoryInterface repositoryDirectory)
|
String[] |
KettleFileRepository.getTransformationNames(ObjectId id_directory,
boolean includeDeleted)
|
List<RepositoryElementMetaInterface> |
KettleFileRepository.getTransformationObjects(ObjectId idDirectory,
boolean includeDeleted)
|
ObjectId[] |
KettleFileRepository.getTransformationPartitionSchemaIDs(ObjectId id_transformation)
|
String[] |
KettleFileRepository.getTransformationsUsingCluster(ObjectId id_cluster)
|
String[] |
KettleFileRepository.getTransformationsUsingDatabase(ObjectId id_database)
|
String[] |
KettleFileRepository.getTransformationsUsingPartitionSchema(ObjectId id_partition_schema)
|
String[] |
KettleFileRepository.getTransformationsUsingSlave(ObjectId id_slave)
|
ObjectId[] |
KettleFileRepository.getTransNoteIDs(ObjectId id_transformation)
|
RepositoryDirectoryInterface |
KettleFileRepository.getUserHomeDirectory()
|
ObjectId |
KettleFileRepository.getUserID(String login)
|
ObjectId[] |
KettleFileRepository.getUserIDs()
|
String[] |
KettleFileRepository.getUserLogins()
|
String[] |
KettleFileRepositorySecurityProvider.getUserLogins()
|
boolean |
KettleFileRepository.hasService(Class<? extends IRepositoryService> clazz)
|
ObjectId |
KettleFileRepository.insertClusterSlave(ClusterSchema clusterSchema,
SlaveServer slaveServer)
|
void |
KettleFileRepository.insertJobEntryDatabase(ObjectId id_job,
ObjectId id_jobentry,
ObjectId id_database)
|
void |
KettleFileRepository.insertJobNote(ObjectId id_job,
ObjectId id_note)
|
ObjectId |
KettleFileRepository.insertLogEntry(String description)
|
void |
KettleFileRepository.insertStepDatabase(ObjectId id_transformation,
ObjectId id_step,
ObjectId id_database)
|
ObjectId |
KettleFileRepository.insertTransformationCluster(ObjectId id_transformation,
ObjectId id_cluster)
|
ObjectId |
KettleFileRepository.insertTransformationPartitionSchema(ObjectId id_transformation,
ObjectId id_partition_schema)
|
ObjectId |
KettleFileRepository.insertTransformationSlave(ObjectId id_transformation,
ObjectId id_slave)
|
void |
KettleFileRepository.insertTransNote(ObjectId id_transformation,
ObjectId id_note)
|
void |
KettleFileRepository.insertTransStepCondition(ObjectId id_transformation,
ObjectId id_step,
ObjectId id_condition)
|
ClusterSchema |
KettleFileRepository.loadClusterSchema(ObjectId id_cluster_schema,
List<SlaveServer> slaveServers,
String versionName)
|
Condition |
KettleFileRepository.loadCondition(ObjectId id_condition)
|
Condition |
KettleFileRepository.loadConditionFromStepAttribute(ObjectId id_step,
String code)
|
DatabaseMeta |
KettleFileRepository.loadDatabaseMeta(ObjectId id_database,
String versionName)
|
DatabaseMeta |
KettleFileRepository.loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry,
String nameCode,
int nr,
String idCode,
List<DatabaseMeta> databases)
|
DatabaseMeta |
KettleFileRepository.loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry,
String nameCode,
String idCode,
List<DatabaseMeta> databases)
|
DatabaseMeta |
KettleFileRepository.loadDatabaseMetaFromStepAttribute(ObjectId id_step,
String code,
List<DatabaseMeta> databases)
|
JobMeta |
KettleFileRepository.loadJob(ObjectId idJob,
String versionLabel)
|
JobMeta |
KettleFileRepository.loadJob(String jobname,
RepositoryDirectoryInterface repdir,
ProgressMonitorListener monitor,
String versionName)
|
Node |
KettleFileRepository.loadNodeFromXML(ObjectId id,
String tag)
|
PartitionSchema |
KettleFileRepository.loadPartitionSchema(ObjectId id_partition_schema,
String versionName)
|
RepositoryDirectoryInterface |
KettleFileRepository.loadRepositoryDirectoryTree()
|
RepositoryDirectoryInterface |
KettleFileRepository.loadRepositoryDirectoryTree(RepositoryDirectoryInterface dir)
|
SlaveServer |
KettleFileRepository.loadSlaveServer(ObjectId id_slave_server,
String versionName)
|
TransMeta |
KettleFileRepository.loadTransformation(ObjectId idTransformation,
String versionLabel)
|
TransMeta |
KettleFileRepository.loadTransformation(String transname,
RepositoryDirectoryInterface repdir,
ProgressMonitorListener monitor,
boolean setInternalVariables,
String versionName)
|
UserInfo |
KettleFileRepository.loadUserInfo(String login)
|
UserInfo |
KettleFileRepository.loadUserInfo(String login,
String password)
|
ValueMetaAndData |
KettleFileRepository.loadValueMetaAndData(ObjectId id_value)
|
void |
KettleFileRepositoryMeta.loadXML(Node repnode,
List<DatabaseMeta> databases)
|
void |
KettleFileRepository.moveJob(String jobname,
ObjectId id_directory_from,
ObjectId id_directory_to)
|
void |
KettleFileRepository.moveTransformation(String transname,
ObjectId id_directory_from,
ObjectId id_directory_to)
|
List<DatabaseMeta> |
KettleFileRepository.readDatabases()
|
void |
KettleFileRepository.readDatabases(HasDatabasesInterface transMeta,
boolean overWriteShared)
Read all the databases from the repository, insert into the has databases object, overwriting optionally |
SharedObjects |
KettleFileRepository.readJobMetaSharedObjects(JobMeta jobMeta)
|
SharedObjects |
KettleFileRepository.readTransSharedObjects(TransMeta transMeta)
|
ObjectId |
KettleFileRepository.renameJob(ObjectId id_job,
RepositoryDirectoryInterface newDir,
String newName)
|
ObjectId |
KettleFileRepository.renameRepositoryDirectory(ObjectId id,
RepositoryDirectoryInterface newParentDir,
String newName)
|
ObjectId |
KettleFileRepository.renameTransformation(ObjectId id_transformation,
RepositoryDirectoryInterface newDir,
String newName)
|
void |
KettleFileRepository.renameUser(ObjectId id_user,
String newname)
|
void |
KettleFileRepository.save(RepositoryElementInterface repositoryElement,
String versionComment)
|
void |
KettleFileRepository.save(RepositoryElementInterface repositoryElement,
String versionComment,
ProgressMonitorListener monitor)
|
void |
KettleFileRepository.save(RepositoryElementInterface repositoryElement,
String versionComment,
ProgressMonitorListener monitor,
boolean overwrite)
|
void |
KettleFileRepository.save(RepositoryElementInterface repositoryElement,
String versionComment,
ProgressMonitorListener monitor,
ObjectId parentId,
boolean used)
|
ObjectId |
KettleFileRepository.saveCondition(Condition condition)
|
ObjectId |
KettleFileRepository.saveCondition(Condition condition,
ObjectId id_condition_parent)
|
void |
KettleFileRepository.saveConditionStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
Condition condition)
|
void |
KettleFileRepository.saveDatabaseMetaJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String nameCode,
String idCode,
DatabaseMeta database)
|
void |
KettleFileRepository.saveDatabaseMetaJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
DatabaseMeta database)
|
void |
KettleFileRepository.saveDatabaseMetaJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String nameCode,
String idCode,
DatabaseMeta database)
|
void |
KettleFileRepository.saveDatabaseMetaStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
DatabaseMeta database)
|
void |
KettleFileRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String code,
boolean value)
|
void |
KettleFileRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String code,
long value)
|
void |
KettleFileRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String code,
String value)
|
void |
KettleFileRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
boolean value)
|
void |
KettleFileRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
long value)
|
void |
KettleFileRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
String value)
|
void |
KettleFileRepository.saveRepositoryDirectory(RepositoryDirectoryInterface dir)
|
void |
KettleFileRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
boolean value)
|
void |
KettleFileRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
double value)
|
void |
KettleFileRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
long value)
|
void |
KettleFileRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
String value)
|
void |
KettleFileRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
boolean value)
|
void |
KettleFileRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
double value)
|
void |
KettleFileRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
long value)
|
void |
KettleFileRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
String value)
|
void |
KettleFileRepository.saveUserInfo(UserInfo userInfo)
|
void |
KettleFileRepository.undeleteObject(RepositoryElementMetaInterface repositoryObject)
|
void |
KettleFileRepositorySecurityProvider.validateAction(RepositoryOperation... operations)
|
Uses of KettleException in org.pentaho.di.repository.kdr |
---|
Methods in org.pentaho.di.repository.kdr that throw KettleException | |
---|---|
void |
KettleDatabaseRepository.commit()
|
void |
KettleDatabaseRepository.connect(String username,
String password)
Connect to the repository. |
void |
KettleDatabaseRepository.connect(String username,
String password,
boolean upgrade)
Connect to the repository. |
IUser |
KettleDatabaseRepositorySecurityProvider.constructUser()
|
int |
KettleDatabaseRepository.countNrJobEntryAttributes(ObjectId id_jobentry,
String code)
|
int |
KettleDatabaseRepository.countNrStepAttributes(ObjectId id_step,
String code)
|
RepositoryDirectoryInterface |
KettleDatabaseRepository.createRepositoryDirectory(RepositoryDirectoryInterface parentDirectory,
String directoryPath)
Create a new directory, possibly by creating several sub-directies of / at the same time. |
void |
KettleDatabaseRepositoryCreationHelper.createRepositorySchema(ProgressMonitorListener monitor,
boolean upgrade,
List<String> statements,
boolean dryrun)
Create or upgrade repository tables & fields, populate lookup tables, ... |
void |
KettleDatabaseRepository.createRepositorySchema(ProgressMonitorListener monitor,
boolean upgrade,
List<String> statements,
boolean dryRun)
Create or upgrade repository tables & fields, populate lookup tables, ... |
void |
KettleDatabaseRepository.delClusterSlaves(ObjectId id_cluster)
|
void |
KettleDatabaseRepository.delDependencies(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.deleteClusterSchema(ObjectId id_cluster)
|
void |
KettleDatabaseRepository.deleteCondition(ObjectId id_condition)
|
void |
KettleDatabaseRepository.deleteDatabaseMeta(String databaseName)
Remove a database connection from the repository |
void |
KettleDatabaseRepository.deleteJob(ObjectId id_job)
|
void |
KettleDatabaseRepository.deletePartitionSchema(ObjectId id_partition_schema)
|
void |
KettleDatabaseRepository.deleteRepositoryDirectory(RepositoryDirectoryInterface dir)
|
void |
KettleDatabaseRepository.deleteSlave(ObjectId id_slave)
|
void |
KettleDatabaseRepository.deleteTransformation(ObjectId id_transformation)
|
void |
KettleDatabaseRepositorySecurityProvider.deleteUsers(List<IUser> users)
|
void |
KettleDatabaseRepository.delJob(ObjectId id_job)
|
void |
KettleDatabaseRepository.delJobAttributes(ObjectId id_job)
|
void |
KettleDatabaseRepository.delJobEntries(ObjectId id_job)
|
void |
KettleDatabaseRepository.delJobEntryAttributes(ObjectId id_job)
|
void |
KettleDatabaseRepository.delJobEntryCopies(ObjectId id_job)
|
void |
KettleDatabaseRepository.delJobEntryDatabases(ObjectId id_job)
Delete the relationships between the job/job entries and the databases. |
void |
KettleDatabaseRepository.delJobHops(ObjectId id_job)
|
void |
KettleDatabaseRepository.delJobNotes(ObjectId id_job)
|
void |
KettleDatabaseRepository.delPartitions(ObjectId id_partition_schema)
|
void |
KettleDatabaseRepository.delPartitionSchemas(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.delStepAttributes(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.delStepConditions(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.delStepDatabases(ObjectId id_transformation)
Delete the relationships between the transformation/steps and the databases. |
void |
KettleDatabaseRepository.delSteps(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.delTrans(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.delTransAttributes(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.delTransformationClusters(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.delTransformationSlaves(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.delTransHops(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.delTransNotes(ObjectId id_transformation)
|
void |
KettleDatabaseRepository.delTransStepCondition(ObjectId id_transformation)
|
void |
KettleDatabaseRepositorySecurityProvider.delUser(ObjectId id_user)
|
void |
KettleDatabaseRepositorySecurityProvider.delUser(String name)
|
void |
KettleDatabaseRepository.delValue(ObjectId id_value)
|
boolean |
KettleDatabaseRepository.dropRepositorySchema()
|
void |
KettleDatabaseRepository.execStatement(String sql)
|
boolean |
KettleDatabaseRepository.exists(String name,
RepositoryDirectoryInterface repositoryDirectory,
RepositoryObjectType objectType)
|
RepositoryDirectoryInterface |
KettleDatabaseRepository.findDirectory(ObjectId directory)
|
RepositoryDirectoryInterface |
KettleDatabaseRepository.findDirectory(String directory)
|
ObjectId |
KettleDatabaseRepository.findStepAttributeID(ObjectId id_step,
int nr,
String code)
This method is only used to check backward compatibility with the 2.x series. |
List<String> |
KettleDatabaseRepositorySecurityProvider.getAllRoles()
|
List<String> |
KettleDatabaseRepositorySecurityProvider.getAllUsers()
|
ObjectId |
KettleDatabaseRepository.getClusterID(String name)
|
ObjectId[] |
KettleDatabaseRepository.getClusterIDs(boolean includeDeleted)
|
String[] |
KettleDatabaseRepository.getClusterNames(boolean includeDeleted)
|
ObjectId[] |
KettleDatabaseRepository.getClusterSlaveIDs(ObjectId id_cluster_schema)
|
String[] |
KettleDatabaseRepository.getClustersUsingSlave(ObjectId id_slave)
|
ObjectId[] |
KettleDatabaseRepository.getDatabaseAttributeIDs(ObjectId id_database)
|
ObjectId |
KettleDatabaseRepository.getDatabaseID(String name)
|
ObjectId[] |
KettleDatabaseRepository.getDatabaseIDs(boolean includeDeleted)
|
String[] |
KettleDatabaseRepository.getDatabaseNames(boolean includeDeleted)
|
List<DatabaseMeta> |
KettleDatabaseRepository.getDatabases()
|
RepositoryDirectory |
KettleDatabaseRepository.getDefaultSaveDirectory(RepositoryElementInterface repositoryElement)
|
String[] |
KettleDatabaseRepository.getDirectoryNames(ObjectId id_directory)
|
List<RepositoryElementMetaInterface> |
KettleDatabaseRepository.getJobAndTransformationObjects(ObjectId id_directory,
boolean includeDeleted)
|
boolean |
KettleDatabaseRepository.getJobEntryAttributeBoolean(ObjectId id_jobentry,
int nr,
String code)
|
boolean |
KettleDatabaseRepository.getJobEntryAttributeBoolean(ObjectId id_jobentry,
String code)
|
boolean |
KettleDatabaseRepository.getJobEntryAttributeBoolean(ObjectId id_jobentry,
String code,
boolean def)
|
long |
KettleDatabaseRepository.getJobEntryAttributeInteger(ObjectId id_jobentry,
int nr,
String code)
|
long |
KettleDatabaseRepository.getJobEntryAttributeInteger(ObjectId id_jobentry,
String code)
|
String |
KettleDatabaseRepository.getJobEntryAttributeString(ObjectId id_jobentry,
int nr,
String code)
|
String |
KettleDatabaseRepository.getJobEntryAttributeString(ObjectId id_jobentry,
String code)
|
ObjectId[] |
KettleDatabaseRepository.getJobEntryCopyIDs(ObjectId id_job)
|
ObjectId[] |
KettleDatabaseRepository.getJobEntryCopyIDs(ObjectId id_job,
ObjectId id_jobentry)
|
ObjectId[] |
KettleDatabaseRepository.getJobEntryIDs(ObjectId id_job)
|
ObjectId[] |
KettleDatabaseRepository.getJobHopIDs(ObjectId id_job)
|
ObjectId |
KettleDatabaseRepository.getJobId(String name,
RepositoryDirectoryInterface repositoryDirectory)
|
String[] |
KettleDatabaseRepository.getJobNames()
|
String[] |
KettleDatabaseRepository.getJobNames(ObjectId id_directory,
boolean includeDeleted)
|
ObjectId[] |
KettleDatabaseRepository.getJobNoteIDs(ObjectId id_job)
|
List<RepositoryElementMetaInterface> |
KettleDatabaseRepository.getJobObjects(ObjectId id_directory,
boolean includeDeleted)
|
String[] |
KettleDatabaseRepository.getJobsUsingDatabase(ObjectId id_database)
|
int |
KettleDatabaseRepository.getNrSubDirectories(ObjectId id_directory)
|
RepositoryObject |
KettleDatabaseRepository.getObjectInformation(ObjectId objectId,
RepositoryObjectType objectType)
|
ObjectId[] |
KettleDatabaseRepository.getPartitionIDs(ObjectId id_partition_schema)
|
ObjectId |
KettleDatabaseRepository.getPartitionSchemaID(String name)
|
ObjectId[] |
KettleDatabaseRepository.getPartitionSchemaIDs(boolean includeDeleted)
|
String[] |
KettleDatabaseRepository.getPartitionSchemaNames(boolean includeDeleted)
|
ObjectId |
KettleDatabaseRepository.getRootDirectoryID()
|
IRepositoryService |
KettleDatabaseRepository.getService(Class<? extends IRepositoryService> clazz)
|
List<Class<? extends IRepositoryService>> |
KettleDatabaseRepository.getServiceInterfaces()
|
ObjectId |
KettleDatabaseRepository.getSlaveID(String name)
|
ObjectId[] |
KettleDatabaseRepository.getSlaveIDs(boolean includeDeleted)
|
String[] |
KettleDatabaseRepository.getSlaveNames(boolean includeDeleted)
|
List<SlaveServer> |
KettleDatabaseRepository.getSlaveServers()
|
boolean |
KettleDatabaseRepository.getStepAttributeBoolean(ObjectId id_step,
int nr,
String code)
|
boolean |
KettleDatabaseRepository.getStepAttributeBoolean(ObjectId id_step,
int nr,
String code,
boolean def)
|
boolean |
KettleDatabaseRepository.getStepAttributeBoolean(ObjectId id_step,
String code)
|
long |
KettleDatabaseRepository.getStepAttributeInteger(ObjectId id_step,
int nr,
String code)
|
long |
KettleDatabaseRepository.getStepAttributeInteger(ObjectId id_step,
String code)
|
String |
KettleDatabaseRepository.getStepAttributeString(ObjectId id_step,
int nr,
String code)
|
String |
KettleDatabaseRepository.getStepAttributeString(ObjectId id_step,
String code)
|
ObjectId[] |
KettleDatabaseRepository.getStepIDs(ObjectId id_transformation)
|
ObjectId[] |
KettleDatabaseRepository.getSubConditionIDs(ObjectId id_condition)
|
ObjectId[] |
KettleDatabaseRepository.getSubDirectoryIDs(ObjectId id_directory)
|
ObjectId[] |
KettleDatabaseRepository.getTransDependencyIDs(ObjectId id_transformation)
|
ObjectId[] |
KettleDatabaseRepository.getTransformationClusterSchemaIDs(ObjectId id_transformation)
|
ObjectId[] |
KettleDatabaseRepository.getTransformationConditionIDs(ObjectId id_transformation)
|
ObjectId[] |
KettleDatabaseRepository.getTransformationDatabaseIDs(ObjectId id_transformation)
|
ObjectId |
KettleDatabaseRepository.getTransformationID(String name,
RepositoryDirectoryInterface repositoryDirectory)
|
String[] |
KettleDatabaseRepository.getTransformationNames(ObjectId id_directory,
boolean includeDeleted)
|
List<RepositoryElementMetaInterface> |
KettleDatabaseRepository.getTransformationObjects(ObjectId id_directory,
boolean includeDeleted)
|
ObjectId[] |
KettleDatabaseRepository.getTransformationPartitionSchemaIDs(ObjectId id_transformation)
|
String[] |
KettleDatabaseRepository.getTransformationsUsingCluster(ObjectId id_cluster)
|
String[] |
KettleDatabaseRepository.getTransformationsUsingDatabase(ObjectId id_database)
|
String[] |
KettleDatabaseRepository.getTransformationsUsingPartitionSchema(ObjectId id_partition_schema)
|
String[] |
KettleDatabaseRepository.getTransformationsUsingSlave(ObjectId id_slave)
|
ObjectId[] |
KettleDatabaseRepository.getTransNoteIDs(ObjectId id_transformation)
|
RepositoryDirectory |
KettleDatabaseRepository.getUserHomeDirectory()
|
ObjectId |
KettleDatabaseRepositorySecurityProvider.getUserID(String login)
|
ObjectId[] |
KettleDatabaseRepositorySecurityProvider.getUserIDs()
|
String[] |
KettleDatabaseRepositorySecurityProvider.getUserLogins()
|
List<IUser> |
KettleDatabaseRepositorySecurityProvider.getUsers()
|
boolean |
KettleDatabaseRepository.hasService(Class<? extends IRepositoryService> clazz)
|
ObjectId |
KettleDatabaseRepository.insertClusterSlave(ClusterSchema clusterSchema,
SlaveServer slaveServer)
|
ObjectId |
KettleDatabaseRepository.insertJobEntry(ObjectId id_job,
JobEntryBase jobEntryBase)
|
void |
KettleDatabaseRepository.insertJobEntryDatabase(ObjectId id_job,
ObjectId id_jobentry,
ObjectId id_database)
|
void |
KettleDatabaseRepository.insertJobNote(ObjectId id_job,
ObjectId id_note)
|
ObjectId |
KettleDatabaseRepository.insertLogEntry(String description)
|
void |
KettleDatabaseRepository.insertStepDatabase(ObjectId id_transformation,
ObjectId id_step,
ObjectId id_database)
|
ObjectId |
KettleDatabaseRepository.insertTransformationCluster(ObjectId id_transformation,
ObjectId id_cluster)
|
ObjectId |
KettleDatabaseRepository.insertTransformationPartitionSchema(ObjectId id_transformation,
ObjectId id_partition_schema)
|
ObjectId |
KettleDatabaseRepository.insertTransformationSlave(ObjectId id_transformation,
ObjectId id_slave)
|
void |
KettleDatabaseRepository.insertTransNote(ObjectId id_transformation,
ObjectId id_note)
|
void |
KettleDatabaseRepository.insertTransStepCondition(ObjectId id_transformation,
ObjectId id_step,
ObjectId id_condition)
|
boolean |
KettleDatabaseRepositorySecurityProvider.isManaged()
|
ClusterSchema |
KettleDatabaseRepository.loadClusterSchema(ObjectId idClusterSchema,
List<SlaveServer> slaveServers,
String versionLabel)
|
Condition |
KettleDatabaseRepository.loadCondition(ObjectId id_condition)
Read a condition from the repository. |
Condition |
KettleDatabaseRepository.loadConditionFromStepAttribute(ObjectId id_step,
String code)
Load a condition from the repository with the Object ID stored in a step attribute. |
DatabaseMeta |
KettleDatabaseRepository.loadDatabaseMeta(ObjectId id_database,
String versionName)
Load the Database connection Metadata from the repository |
DatabaseMeta |
KettleDatabaseRepository.loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry,
String nameCode,
int nr,
String idCode,
List<DatabaseMeta> databases)
|
DatabaseMeta |
KettleDatabaseRepository.loadDatabaseMetaFromJobEntryAttribute(ObjectId id_jobentry,
String nameCode,
String idCode,
List<DatabaseMeta> databases)
|
DatabaseMeta |
KettleDatabaseRepository.loadDatabaseMetaFromStepAttribute(ObjectId idStep,
String code,
List<DatabaseMeta> databases)
|
JobMeta |
KettleDatabaseRepository.loadJob(ObjectId idJob,
String versionLabel)
|
JobMeta |
KettleDatabaseRepository.loadJob(String jobname,
RepositoryDirectoryInterface repdir,
ProgressMonitorListener monitor,
String versionName)
Load a job in a directory |
void |
KettleDatabaseRepository.loadJobEntry(JobEntryBase jobEntryBase,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
NotePadMeta |
KettleDatabaseRepository.loadNotePadMeta(ObjectId id_note)
|
PartitionSchema |
KettleDatabaseRepository.loadPartitionSchema(ObjectId id_partition_schema,
String versionName)
|
RepositoryDirectoryInterface |
KettleDatabaseRepository.loadRepositoryDirectoryTree()
|
RepositoryDirectoryInterface |
KettleDatabaseRepository.loadRepositoryDirectoryTree(RepositoryDirectoryInterface root)
|
SlaveServer |
KettleDatabaseRepository.loadSlaveServer(ObjectId id_slave_server,
String versionName)
|
TransMeta |
KettleDatabaseRepository.loadTransformation(ObjectId idTransformation,
String versionLabel)
|
TransMeta |
KettleDatabaseRepository.loadTransformation(String transname,
RepositoryDirectoryInterface repdir,
ProgressMonitorListener monitor,
boolean setInternalVariables,
String versionName)
|
IUser |
KettleDatabaseRepositorySecurityProvider.loadUserInfo(String login)
|
ValueMetaAndData |
KettleDatabaseRepository.loadValueMetaAndData(ObjectId id_value)
|
void |
KettleDatabaseRepositoryMeta.loadXML(Node repnode,
List<DatabaseMeta> databases)
|
void |
KettleDatabaseRepository.lockRepository()
|
List<DatabaseMeta> |
KettleDatabaseRepository.readDatabases()
Read all the databases defined in the repository |
SharedObjects |
KettleDatabaseRepository.readJobMetaSharedObjects(JobMeta jobMeta)
|
SharedObjects |
KettleDatabaseRepository.readTransSharedObjects(TransMeta transMeta)
|
ObjectId |
KettleDatabaseRepository.renameJob(ObjectId id_job,
RepositoryDirectoryInterface dir,
String newname)
|
ObjectId |
KettleDatabaseRepository.renameRepositoryDirectory(ObjectId id,
RepositoryDirectoryInterface newParentDir,
String newName)
|
ObjectId |
KettleDatabaseRepository.renameTransformation(ObjectId id_transformation,
RepositoryDirectoryInterface newDir,
String newName)
|
void |
KettleDatabaseRepositorySecurityProvider.renameUser(ObjectId id_user,
String newname)
|
void |
KettleDatabaseRepository.save(RepositoryElementInterface repositoryElement,
String versionComment)
|
void |
KettleDatabaseRepository.save(RepositoryElementInterface repositoryElement,
String versionComment,
ProgressMonitorListener monitor)
|
void |
KettleDatabaseRepository.save(RepositoryElementInterface repositoryElement,
String versionComment,
ProgressMonitorListener monitor,
boolean overwrite)
|
void |
KettleDatabaseRepository.save(RepositoryElementInterface repositoryElement,
String versionComment,
ProgressMonitorListener monitor,
ObjectId parentId,
boolean used,
boolean overwrite)
|
ObjectId |
KettleDatabaseRepository.saveCondition(Condition condition)
|
ObjectId |
KettleDatabaseRepository.saveCondition(Condition condition,
ObjectId id_condition_parent)
|
void |
KettleDatabaseRepository.saveConditionStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
Condition condition)
This method saves the object ID of the condition object (if not null) in the step attributes |
void |
KettleDatabaseRepository.saveDatabaseMetaJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String nameCode,
String idCode,
DatabaseMeta database)
This method saves the object ID of the database object (if not null) in the step attributes |
void |
KettleDatabaseRepository.saveDatabaseMetaJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String nameCode,
String idCode,
DatabaseMeta database)
This method saves the object ID of the database object (if not null) in the step attributes |
void |
KettleDatabaseRepository.saveDatabaseMetaStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
DatabaseMeta database)
This method saves the object ID of the database object (if not null) in the step attributes |
void |
KettleDatabaseRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String code,
boolean value)
|
void |
KettleDatabaseRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String code,
long value)
|
void |
KettleDatabaseRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
int nr,
String code,
String value)
|
void |
KettleDatabaseRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
boolean value)
|
void |
KettleDatabaseRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
long value)
|
void |
KettleDatabaseRepository.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
String value)
|
void |
KettleDatabaseRepository.saveNotePadMeta(NotePadMeta note,
ObjectId id_transformation)
|
void |
KettleDatabaseRepository.saveRepositoryDirectory(RepositoryDirectoryInterface dir)
|
void |
KettleDatabaseRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
boolean value)
|
void |
KettleDatabaseRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
double value)
|
void |
KettleDatabaseRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
long value)
|
void |
KettleDatabaseRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
int nr,
String code,
String value)
|
void |
KettleDatabaseRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
boolean value)
|
void |
KettleDatabaseRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
double value)
|
void |
KettleDatabaseRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
long value)
|
void |
KettleDatabaseRepository.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
String value)
|
void |
KettleDatabaseRepositorySecurityProvider.saveUserInfo(IUser userInfo)
|
void |
KettleDatabaseRepositorySecurityProvider.setUsers(List<IUser> users)
|
void |
KettleDatabaseRepository.undeleteObject(RepositoryElementMetaInterface element)
|
void |
KettleDatabaseRepository.unlockRepository()
|
void |
KettleDatabaseRepository.updateDatabaseTypes()
Update the list in R_DATABASE_TYPE using the plugin registry |
List<String> |
KettleDatabaseRepositoryCreationHelper.updateDatabaseTypes(List<String> statements,
boolean dryrun,
boolean create)
Update the list in R_DATABASE_TYPE using the database plugin entries |
void |
KettleDatabaseRepository.updateJobEntryTypes()
Update the list in R_JOBENTRY_TYPE |
void |
KettleDatabaseRepositoryCreationHelper.updateJobEntryTypes(List<String> statements,
boolean dryrun,
boolean create)
Update the list in R_JOBENTRY_TYPE |
void |
KettleDatabaseRepository.updateStepTypes()
Update the list in R_STEP_TYPE using the StepLoader StepPlugin entries |
List<String> |
KettleDatabaseRepositoryCreationHelper.updateStepTypes(List<String> statements,
boolean dryrun,
boolean create)
Update the list in R_STEP_TYPE using the StepLoader StepPlugin entries |
void |
KettleDatabaseRepositorySecurityProvider.updateUser(IUser user)
|
void |
KettleDatabaseRepositorySecurityProvider.validateAction(RepositoryOperation... operations)
|
Uses of KettleException in org.pentaho.di.repository.kdr.delegates |
---|
Methods in org.pentaho.di.repository.kdr.delegates that throw KettleException | |
---|---|
void |
KettleDatabaseRepositoryConnectionDelegate.closeJobAttributeInsertPreparedStatement()
|
void |
KettleDatabaseRepositoryConnectionDelegate.closeJobAttributeLookupPreparedStatement()
|
void |
KettleDatabaseRepositoryConnectionDelegate.closeLookupJobEntryAttribute()
|
void |
KettleDatabaseRepositoryConnectionDelegate.closeStepAttributeInsertPreparedStatement()
|
void |
KettleDatabaseRepositoryConnectionDelegate.closeStepAttributeLookupPreparedStatement()
|
void |
KettleDatabaseRepositoryConnectionDelegate.closeTransAttributeInsertPreparedStatement()
|
void |
KettleDatabaseRepositoryConnectionDelegate.closeTransAttributeLookupPreparedStatement()
|
void |
KettleDatabaseRepositoryConnectionDelegate.commit()
|
void |
KettleDatabaseRepositoryConnectionDelegate.connect()
Connect to the repository |
void |
KettleDatabaseRepositoryConnectionDelegate.connect(boolean no_lookup)
|
void |
KettleDatabaseRepositoryConnectionDelegate.connect(boolean no_lookup,
boolean ignoreVersion)
|
int |
KettleDatabaseRepositoryJobDelegate.countJobParameter(ObjectId id_job)
Count the number of parameters of a job. |
int |
KettleDatabaseRepositoryConnectionDelegate.countNrJobAttributes(ObjectId id_job,
String code)
|
int |
KettleDatabaseRepositoryConnectionDelegate.countNrJobEntryAttributes(ObjectId id_jobentry,
String code)
|
int |
KettleDatabaseRepositoryConnectionDelegate.countNrStepAttributes(ObjectId id_step,
String code)
|
int |
KettleDatabaseRepositoryConnectionDelegate.countNrTransAttributes(ObjectId id_transformation,
String code)
|
int |
KettleDatabaseRepositoryTransDelegate.countTransParameter(ObjectId id_transformation)
Count the number of parameters of a transaction. |
RepositoryDirectoryInterface |
KettleDatabaseRepositoryDirectoryDelegate.createRepositoryDirectory(RepositoryDirectoryInterface parentDirectory,
String directoryPath)
Create a new directory, possibly by creating several sub-directies of / at the same time. |
void |
KettleDatabaseRepositoryClusterSchemaDelegate.delClusterSchema(ObjectId id_cluster)
|
void |
KettleDatabaseRepositoryDatabaseDelegate.delDatabase(ObjectId id_database)
|
void |
KettleDatabaseRepositoryDatabaseDelegate.delDatabaseAttributes(ObjectId id_database)
|
void |
KettleDatabaseRepositoryDatabaseDelegate.deleteDatabaseMeta(String databaseName)
Remove a database connection from the repository |
void |
KettleDatabaseRepositoryDirectoryDelegate.deleteDirectory(ObjectId id_directory)
|
void |
KettleDatabaseRepositoryDirectoryDelegate.deleteDirectory(RepositoryDirectoryInterface dir)
|
void |
KettleDatabaseRepositoryPartitionSchemaDelegate.delPartitionSchema(ObjectId id_partition_schema)
|
void |
KettleDatabaseRepositoryDirectoryDelegate.delRepositoryDirectory(RepositoryDirectoryInterface dir,
boolean deleteNonEmptyFolder)
|
boolean |
KettleDatabaseRepositoryJobDelegate.existsJobMeta(String name,
RepositoryDirectoryInterface repositoryDirectory,
RepositoryObjectType objectType)
|
boolean |
KettleDatabaseRepositoryTransDelegate.existsTransMeta(String transname,
RepositoryDirectory directory)
|
boolean |
KettleDatabaseRepositoryTransDelegate.existsTransMeta(String name,
RepositoryDirectoryInterface repositoryDirectory,
RepositoryObjectType objectType)
|
boolean |
KettleDatabaseRepositoryUserDelegate.existsUserInfo(RepositoryElementInterface user)
|
void |
KettleDatabaseRepositoryConnectionDelegate.fillStepAttributesBuffer(ObjectId id_transformation)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.findStepAttributeID(ObjectId id_step,
int nr,
String code)
|
boolean |
KettleDatabaseRepositoryTransAttribute.getAttributeBoolean(String code)
|
boolean |
KettleDatabaseRepositoryJobAttribute.getAttributeBoolean(String code)
|
long |
KettleDatabaseRepositoryTransAttribute.getAttributeInteger(String code)
|
long |
KettleDatabaseRepositoryJobAttribute.getAttributeInteger(String code)
|
String |
KettleDatabaseRepositoryTransAttribute.getAttributeString(String code)
|
String |
KettleDatabaseRepositoryJobAttribute.getAttributeString(String code)
|
ObjectId |
KettleDatabaseRepositoryClusterSchemaDelegate.getClusterID(String name)
|
RowMetaAndData |
KettleDatabaseRepositoryClusterSchemaDelegate.getClusterSchema(ObjectId id_cluster_schema)
|
RowMetaAndData |
KettleDatabaseRepositoryConditionDelegate.getCondition(ObjectId id_condition)
|
RowMetaAndData |
KettleDatabaseRepositoryDatabaseDelegate.getDatabase(ObjectId id_database)
|
RowMetaAndData |
KettleDatabaseRepositoryDatabaseDelegate.getDatabaseAttribute(ObjectId id_database_attribute)
|
String |
KettleDatabaseRepositoryDatabaseDelegate.getDatabaseConTypeCode(ObjectId id_database_contype)
|
ObjectId |
KettleDatabaseRepositoryDatabaseDelegate.getDatabaseConTypeID(String code)
|
ObjectId |
KettleDatabaseRepositoryDatabaseDelegate.getDatabaseID(String name)
|
String |
KettleDatabaseRepositoryDatabaseDelegate.getDatabaseTypeCode(ObjectId id_database_type)
|
ObjectId |
KettleDatabaseRepositoryDatabaseDelegate.getDatabaseTypeID(String code)
|
ObjectId |
KettleDatabaseRepositoryTransDelegate.getDependencyID(ObjectId id_transformation,
ObjectId id_database,
String tablename)
|
RowMetaAndData |
KettleDatabaseRepositoryDirectoryDelegate.getDirectory(ObjectId id_directory)
|
ObjectId[] |
KettleDatabaseRepositoryConnectionDelegate.getIDs(String sql,
ObjectId... objectId)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getIDWithValue(String tablename,
String idfield,
String[] lookupkey,
ObjectId[] key)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getIDWithValue(String tablename,
String idfield,
String lookupfield,
String value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getIDWithValue(String tablename,
String idfield,
String lookupfield,
String value,
String[] lookupkey,
ObjectId[] key)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getIDWithValue(String tablename,
String idfield,
String lookupfield,
String value,
String lookupkey,
ObjectId key)
|
RowMetaAndData |
KettleDatabaseRepositoryJobDelegate.getJob(ObjectId id_job)
|
boolean |
KettleDatabaseRepositoryJobDelegate.getJobAttributeBoolean(ObjectId id_job,
int nr,
String code)
|
boolean |
KettleDatabaseRepositoryConnectionDelegate.getJobAttributeBoolean(ObjectId id_job,
int nr,
String code)
|
long |
KettleDatabaseRepositoryJobDelegate.getJobAttributeInteger(ObjectId id_job,
int nr,
String code)
|
long |
KettleDatabaseRepositoryConnectionDelegate.getJobAttributeInteger(ObjectId id_job,
int nr,
String code)
|
double |
KettleDatabaseRepositoryConnectionDelegate.getJobAttributeNumber(ObjectId id_job,
int nr,
String code)
|
RowMetaAndData |
KettleDatabaseRepositoryConnectionDelegate.getJobAttributeRow(ObjectId id_job,
int nr,
String code)
|
List<Object[]> |
KettleDatabaseRepositoryConnectionDelegate.getJobAttributes(ObjectId id_job,
String code,
long nr)
|
String |
KettleDatabaseRepositoryJobDelegate.getJobAttributeString(ObjectId id_job,
int nr,
String code)
|
String |
KettleDatabaseRepositoryConnectionDelegate.getJobAttributeString(ObjectId id_job,
int nr,
String code)
|
RowMetaAndData |
KettleDatabaseRepositoryJobEntryDelegate.getJobEntry(ObjectId id_jobentry)
|
boolean |
KettleDatabaseRepositoryConnectionDelegate.getJobEntryAttributeBoolean(ObjectId id_jobentry,
int nr,
String code)
|
boolean |
KettleDatabaseRepositoryConnectionDelegate.getJobEntryAttributeBoolean(ObjectId id_jobentry,
int nr,
String code,
boolean def)
|
boolean |
KettleDatabaseRepositoryConnectionDelegate.getJobEntryAttributeBoolean(ObjectId id_jobentry,
String code)
|
boolean |
KettleDatabaseRepositoryConnectionDelegate.getJobEntryAttributeBoolean(ObjectId id_jobentry,
String code,
boolean def)
|
long |
KettleDatabaseRepositoryConnectionDelegate.getJobEntryAttributeInteger(ObjectId id_jobentry,
int nr,
String code)
|
long |
KettleDatabaseRepositoryConnectionDelegate.getJobEntryAttributeInteger(ObjectId id_jobentry,
String code)
|
double |
KettleDatabaseRepositoryConnectionDelegate.getJobEntryAttributeNumber(ObjectId id_jobentry,
int nr,
String code)
|
double |
KettleDatabaseRepositoryConnectionDelegate.getJobEntryAttributeNumber(ObjectId id_jobentry,
String code)
|
String |
KettleDatabaseRepositoryConnectionDelegate.getJobEntryAttributeString(ObjectId id_jobentry,
int nr,
String code)
|
String |
KettleDatabaseRepositoryConnectionDelegate.getJobEntryAttributeString(ObjectId id_jobentry,
String code)
|
RowMetaAndData |
KettleDatabaseRepositoryJobEntryDelegate.getJobEntryCopy(ObjectId id_jobentry_copy)
|
ObjectId |
KettleDatabaseRepositoryJobEntryDelegate.getJobEntryID(String name,
ObjectId id_job)
|
RowMetaAndData |
KettleDatabaseRepositoryJobEntryDelegate.getJobEntryType(ObjectId id_jobentry_type)
|
ObjectId |
KettleDatabaseRepositoryJobEntryDelegate.getJobEntryTypeID(String code)
|
RowMetaAndData |
KettleDatabaseRepositoryJobDelegate.getJobHop(ObjectId id_job_hop)
|
ObjectId |
KettleDatabaseRepositoryJobDelegate.getJobHopID(ObjectId id_job,
ObjectId id_jobentry_copy_from,
ObjectId id_jobentry_copy_to)
|
ObjectId |
KettleDatabaseRepositoryJobDelegate.getJobID(String name,
ObjectId id_directory)
|
String |
KettleDatabaseRepositoryJobDelegate.getJobParameterDefault(ObjectId id_job,
int nr)
Get a job parameter default. |
String |
KettleDatabaseRepositoryJobDelegate.getJobParameterDescription(ObjectId id_job,
int nr)
Get a job parameter description. |
String |
KettleDatabaseRepositoryJobDelegate.getJobParameterKey(ObjectId id_job,
int nr)
Get a job parameter key. |
String[] |
KettleDatabaseRepositoryJobDelegate.getJobsWithIDList(List<Object[]> list,
RowMetaInterface rowMeta)
|
String[] |
KettleDatabaseRepositoryJobDelegate.getJobsWithIDList(ObjectId[] ids)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextClusterID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextClusterSlaveID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextConditionID()
|
LongObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextDatabaseAttributeID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextDatabaseConnectionTypeID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextDatabaseID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextDatabaseTypeID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextDepencencyID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextDirectoryID()
|
LongObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextID(String tableName,
String fieldName)
|
LongObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextJobAttributeID()
|
LongObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextJobEntryAttributeID()
|
LongObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextJobEntryCopyID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextJobEntryID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextJobEntryTypeID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextJobHopID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextJobID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextLogID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextLoglevelID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextNoteID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextPartitionID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextPartitionSchemaID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextSlaveServerID()
|
LongObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextStepAttributeID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextStepID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextStepTypeID()
|
LongObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextTransAttributeID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextTransformationClusterID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextTransformationID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextTransformationPartitionSchemaID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextTransformationSlaveID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextTransHopID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextUserID()
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.getNextValueID()
|
RowMetaAndData |
KettleDatabaseRepositoryNotePadDelegate.getNote(ObjectId id_note)
|
ObjectId |
KettleDatabaseRepositoryNotePadDelegate.getNoteID(String note)
|
int |
KettleDatabaseRepositoryDatabaseDelegate.getNrDatabaseAttributes(ObjectId id_database)
|
int |
KettleDatabaseRepositoryDatabaseDelegate.getNrDatabases()
|
int |
KettleDatabaseRepositoryDatabaseDelegate.getNrDatabases(ObjectId id_transformation)
|
int |
KettleDatabaseRepositoryJobEntryDelegate.getNrJobEntries(ObjectId id_job)
|
int |
KettleDatabaseRepositoryJobDelegate.getNrJobHops(ObjectId id_job)
|
int |
KettleDatabaseRepositoryJobDelegate.getNrJobs()
|
int |
KettleDatabaseRepositoryJobDelegate.getNrJobs(ObjectId id_directory)
|
int |
KettleDatabaseRepositoryStepDelegate.getNrStepAttributes(ObjectId id_step)
|
int |
KettleDatabaseRepositoryStepDelegate.getNrSteps(ObjectId id_transformation)
|
int |
KettleDatabaseRepositoryDirectoryDelegate.getNrSubDirectories(ObjectId id_directory)
|
int |
KettleDatabaseRepositoryTransDelegate.getNrTransDependencies(ObjectId id_transformation)
|
int |
KettleDatabaseRepositoryTransDelegate.getNrTransformations(ObjectId id_directory)
|
int |
KettleDatabaseRepositoryTransDelegate.getNrTransHops(ObjectId id_transformation)
|
int |
KettleDatabaseRepositoryUserDelegate.getNrUsers()
|
RowMetaAndData |
KettleDatabaseRepositoryConnectionDelegate.getOneRow(String tablename,
String keyfield,
ObjectId id)
|
RowMetaAndData |
KettleDatabaseRepositoryConnectionDelegate.getParameterMetaData(ObjectId... ids)
|
RowMetaAndData |
KettleDatabaseRepositoryPartitionSchemaDelegate.getPartition(ObjectId id_partition)
|
RowMetaAndData |
KettleDatabaseRepositoryPartitionSchemaDelegate.getPartitionSchema(ObjectId id_partition_schema)
|
ObjectId |
KettleDatabaseRepositoryPartitionSchemaDelegate.getPartitionSchemaID(String name)
|
List<RepositoryElementMetaInterface> |
KettleDatabaseRepositoryConnectionDelegate.getRepositoryObjects(String tableName,
RepositoryObjectType objectType,
ObjectId id_directory)
|
ObjectId |
KettleDatabaseRepositorySlaveServerDelegate.getSlaveID(String name)
|
RowMetaAndData |
KettleDatabaseRepositorySlaveServerDelegate.getSlaveServer(ObjectId id_slave)
|
RowMetaAndData |
KettleDatabaseRepositoryStepDelegate.getStep(ObjectId id_step)
|
RowMetaAndData |
KettleDatabaseRepositoryStepDelegate.getStepAttribute(ObjectId id_step_attribute)
|
boolean |
KettleDatabaseRepositoryConnectionDelegate.getStepAttributeBoolean(ObjectId id_step,
int nr,
String code)
|
boolean |
KettleDatabaseRepositoryConnectionDelegate.getStepAttributeBoolean(ObjectId id_step,
int nr,
String code,
boolean def)
|
boolean |
KettleDatabaseRepositoryConnectionDelegate.getStepAttributeBoolean(ObjectId id_step,
String code)
|
long |
KettleDatabaseRepositoryConnectionDelegate.getStepAttributeInteger(ObjectId id_step,
int nr,
String code)
|
long |
KettleDatabaseRepositoryConnectionDelegate.getStepAttributeInteger(ObjectId id_step,
String code)
|
String |
KettleDatabaseRepositoryConnectionDelegate.getStepAttributeString(ObjectId id_step,
int nr,
String code)
|
String |
KettleDatabaseRepositoryConnectionDelegate.getStepAttributeString(ObjectId id_step,
String code)
|
ObjectId |
KettleDatabaseRepositoryStepDelegate.getStepID(String name,
ObjectId id_transformation)
|
RowMetaAndData |
KettleDatabaseRepositoryStepDelegate.getStepType(ObjectId id_step_type)
|
String |
KettleDatabaseRepositoryStepDelegate.getStepTypeCode(ObjectId id_database_type)
|
ObjectId |
KettleDatabaseRepositoryStepDelegate.getStepTypeID(String code)
|
String[] |
KettleDatabaseRepositoryConnectionDelegate.getStrings(String sql,
ObjectId... objectId)
|
String |
KettleDatabaseRepositoryConnectionDelegate.getStringWithID(String tablename,
String keyfield,
ObjectId id,
String fieldname)
|
ObjectId[] |
KettleDatabaseRepositoryDirectoryDelegate.getSubDirectoryIDs(ObjectId id_directory)
|
boolean |
KettleDatabaseRepositoryTransDelegate.getTransAttributeBoolean(ObjectId id_transformation,
int nr,
String code)
|
boolean |
KettleDatabaseRepositoryConnectionDelegate.getTransAttributeBoolean(ObjectId id_transformation,
int nr,
String code)
|
long |
KettleDatabaseRepositoryTransDelegate.getTransAttributeInteger(ObjectId id_transformation,
int nr,
String code)
|
long |
KettleDatabaseRepositoryConnectionDelegate.getTransAttributeInteger(ObjectId id_transformation,
int nr,
String code)
|
double |
KettleDatabaseRepositoryConnectionDelegate.getTransAttributeNumber(ObjectId id_transformation,
int nr,
String code)
|
RowMetaAndData |
KettleDatabaseRepositoryConnectionDelegate.getTransAttributeRow(ObjectId id_transformation,
int nr,
String code)
|
List<Object[]> |
KettleDatabaseRepositoryConnectionDelegate.getTransAttributes(ObjectId id_transformation,
String code,
long nr)
|
String |
KettleDatabaseRepositoryTransDelegate.getTransAttributeString(ObjectId id_transformation,
int nr,
String code)
|
String |
KettleDatabaseRepositoryConnectionDelegate.getTransAttributeString(ObjectId id_transformation,
int nr,
String code)
|
RowMetaAndData |
KettleDatabaseRepositoryTransDelegate.getTransDependency(ObjectId id_dependency)
|
RowMetaAndData |
KettleDatabaseRepositoryTransDelegate.getTransformation(ObjectId id_transformation)
|
ObjectId |
KettleDatabaseRepositoryTransDelegate.getTransformationID(String name,
ObjectId id_directory)
|
String[] |
KettleDatabaseRepositoryTransDelegate.getTransformationsWithIDList(List<Object[]> list,
RowMetaInterface rowMeta)
|
String[] |
KettleDatabaseRepositoryTransDelegate.getTransformationsWithIDList(ObjectId[] ids)
|
RowMetaAndData |
KettleDatabaseRepositoryTransDelegate.getTransHop(ObjectId id_trans_hop)
|
ObjectId |
KettleDatabaseRepositoryTransDelegate.getTransHopID(ObjectId id_transformation,
ObjectId id_step_from,
ObjectId id_step_to)
|
ObjectId[] |
KettleDatabaseRepositoryTransDelegate.getTransHopIDs(ObjectId id_transformation)
|
String |
KettleDatabaseRepositoryTransDelegate.getTransParameterDefault(ObjectId id_transformation,
int nr)
Get a transformation parameter default. |
String |
KettleDatabaseRepositoryTransDelegate.getTransParameterDescription(ObjectId id_transformation,
int nr)
Get a transformation parameter description. |
String |
KettleDatabaseRepositoryTransDelegate.getTransParameterKey(ObjectId id_transformation,
int nr)
Get a transformation parameter key. |
RowMetaAndData |
KettleDatabaseRepositoryUserDelegate.getUser(ObjectId id_user)
|
ObjectId |
KettleDatabaseRepositoryUserDelegate.getUserID(String login)
|
RowMetaAndData |
KettleDatabaseRepositoryValueDelegate.getValue(ObjectId id_value)
|
ObjectId |
KettleDatabaseRepositoryConditionDelegate.insertCondition(ObjectId id_condition_parent,
Condition condition)
|
ObjectId |
KettleDatabaseRepositoryDatabaseDelegate.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)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.insertJobAttribute(ObjectId id_job,
long nr,
String code,
long value_num,
String value_str)
|
ObjectId |
KettleDatabaseRepositoryJobEntryDelegate.insertJobEntry(ObjectId id_job,
JobEntryBase jobEntryBase)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.insertJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
long nr,
String code,
double value_num,
String value_str)
|
ObjectId |
KettleDatabaseRepositoryJobEntryDelegate.insertJobEntryCopy(ObjectId id_job,
ObjectId id_jobentry,
ObjectId id_jobentry_type,
int nr,
long gui_location_x,
long gui_location_y,
boolean gui_draw,
boolean parallel)
|
ObjectId |
KettleDatabaseRepositoryJobDelegate.insertJobHop(ObjectId id_job,
ObjectId id_jobentry_copy_from,
ObjectId id_jobentry_copy_to,
boolean enabled,
boolean evaluation,
boolean unconditional)
|
void |
KettleDatabaseRepositoryJobDelegate.insertJobParameter(ObjectId id_job,
long nr,
String key,
String defValue,
String description)
Insert a parameter for a job in the repository. |
ObjectId |
KettleDatabaseRepositoryNotePadDelegate.insertNote(String note,
long gui_location_x,
long gui_location_y,
long gui_location_width,
long gui_location_height,
String fontname,
long fontsize,
boolean fontbold,
boolean fontitalic,
long fontcolorred,
long fontcolorgreen,
long fontcolorblue,
long fontbackcolorred,
long fontbackcolorgreen,
long fontbackcolorblue,
long fontbordercolorred,
long fontbordercolorgreen,
long fontbordercolorblue,
boolean drawshadow)
|
ObjectId |
KettleDatabaseRepositoryPartitionSchemaDelegate.insertPartition(ObjectId id_partition_schema,
String partition_id)
|
ObjectId |
KettleDatabaseRepositoryPartitionSchemaDelegate.insertPartitionSchema(PartitionSchema partitionSchema)
|
ObjectId |
KettleDatabaseRepositorySlaveServerDelegate.insertSlave(SlaveServer slaveServer)
|
ObjectId |
KettleDatabaseRepositoryStepDelegate.insertStep(ObjectId id_transformation,
String name,
String description,
String steptype,
boolean distribute,
long copies,
long gui_location_x,
long gui_location_y,
boolean gui_draw)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.insertStepAttribute(ObjectId id_transformation,
ObjectId id_step,
long nr,
String code,
double value_num,
String value_str)
|
void |
KettleDatabaseRepositoryConnectionDelegate.insertTableRow(String tablename,
RowMetaAndData values)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.insertTransAttribute(ObjectId id_transformation,
long nr,
String code,
long value_num,
String value_str)
|
void |
KettleDatabaseRepositoryTransDelegate.insertTransParameter(ObjectId id_transformation,
long nr,
String key,
String defValue,
String description)
Insert a parameter for a transformation in the repository. |
ObjectId |
KettleDatabaseRepositoryConditionDelegate.insertValue(String name,
String type,
String value_str,
boolean isnull,
ObjectId id_value_prev)
|
ClusterSchema |
KettleDatabaseRepositoryClusterSchemaDelegate.loadClusterSchema(ObjectId id_cluster_schema,
List<SlaveServer> slaveServers)
|
Condition |
KettleDatabaseRepositoryConditionDelegate.loadCondition(ObjectId id_condition)
Read a condition from the repository. |
DatabaseMeta |
KettleDatabaseRepositoryDatabaseDelegate.loadDatabaseMeta(ObjectId id_database)
Load the Database Info |
void |
KettleDatabaseRepositoryJobEntryDelegate.loadJobEntryBase(JobEntryBase jobEntryBase,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
JobEntryCopy |
KettleDatabaseRepositoryJobEntryDelegate.loadJobEntryCopy(ObjectId id_job,
ObjectId id_jobentry_copy,
List<JobEntryInterface> jobentries,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
Load the chef graphical entry from repository We load type, name & description if no entry can be found. |
JobHopMeta |
KettleDatabaseRepositoryJobDelegate.loadJobHopMeta(ObjectId id_job_hop,
List<JobEntryCopy> jobcopies)
|
JobMeta |
KettleDatabaseRepositoryJobDelegate.loadJobMeta(String jobname,
RepositoryDirectoryInterface repdir)
Load a job from the repository |
JobMeta |
KettleDatabaseRepositoryJobDelegate.loadJobMeta(String jobname,
RepositoryDirectoryInterface repdir,
ProgressMonitorListener monitor)
Load a job in a directory |
NotePadMeta |
KettleDatabaseRepositoryNotePadDelegate.loadNotePadMeta(ObjectId id_note)
|
PartitionSchema |
KettleDatabaseRepositoryPartitionSchemaDelegate.loadPartitionSchema(ObjectId id_partition_schema)
|
RepositoryDirectoryInterface |
KettleDatabaseRepositoryDirectoryDelegate.loadPathToRoot(ObjectId id_directory)
|
void |
KettleDatabaseRepositoryDirectoryDelegate.loadRepositoryDirectory(RepositoryDirectory repositoryDirectory,
ObjectId id_directory)
|
RepositoryDirectoryInterface |
KettleDatabaseRepositoryDirectoryDelegate.loadRepositoryDirectoryTree(RepositoryDirectoryInterface root)
|
SlaveServer |
KettleDatabaseRepositorySlaveServerDelegate.loadSlaveServer(ObjectId id_slave_server)
|
StepErrorMeta |
KettleDatabaseRepositoryStepDelegate.loadStepErrorMeta(VariableSpace variables,
StepMeta stepMeta,
List<StepMeta> steps)
|
StepMeta |
KettleDatabaseRepositoryStepDelegate.loadStepMeta(ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters,
List<PartitionSchema> partitionSchemas)
Create a new step by loading the metadata from the specified repository. |
StepPartitioningMeta |
KettleDatabaseRepositoryStepDelegate.loadStepPartitioningMeta(ObjectId id_step)
|
TransDependency |
KettleDatabaseRepositoryTransDelegate.loadTransDependency(ObjectId id_dependency,
List<DatabaseMeta> databases)
|
TransMeta |
KettleDatabaseRepositoryTransDelegate.loadTransformation(TransMeta transMeta,
String transname,
RepositoryDirectoryInterface repdir,
ProgressMonitorListener monitor,
boolean setInternalVariables)
Read a transformation with a certain name from a repository |
TransHopMeta |
KettleDatabaseRepositoryTransDelegate.loadTransHopMeta(ObjectId id_trans_hop,
List<StepMeta> steps)
|
IUser |
KettleDatabaseRepositoryUserDelegate.loadUserInfo(IUser userInfo,
String login)
|
IUser |
KettleDatabaseRepositoryUserDelegate.loadUserInfo(IUser userInfo,
String login,
String passwd)
Load user with login from repository and verify the password... |
ValueMetaAndData |
KettleDatabaseRepositoryValueDelegate.loadValueMetaAndData(ObjectId id_value)
|
void |
KettleDatabaseRepositoryConnectionDelegate.lockRepository()
|
ObjectId |
KettleDatabaseRepositoryConditionDelegate.lookupValue(String name,
String type,
String value_str,
boolean isnull)
|
void |
KettleDatabaseRepositoryJobDelegate.moveJob(String jobname,
ObjectId id_directory_from,
ObjectId id_directory_to)
|
void |
KettleDatabaseRepositoryTransDelegate.moveTransformation(String transname,
ObjectId id_directory_from,
ObjectId id_directory_to)
|
void |
KettleDatabaseRepositoryConnectionDelegate.performDelete(String sql,
ObjectId... ids)
|
void |
KettleDatabaseRepositoryTransDelegate.readClusters(TransMeta transMeta,
boolean overWriteShared)
Read the clusters in the repository and add them to this transformation if they are not yet present. |
void |
KettleDatabaseRepositoryJobDelegate.readDatabases(JobMeta jobMeta)
Read the database connections in the repository and add them to this job if they are not yet present. |
void |
KettleDatabaseRepositoryJobDelegate.readDatabases(JobMeta jobMeta,
boolean overWriteShared)
Read the database connections in the repository and add them to this job if they are not yet present. |
void |
KettleDatabaseRepositoryTransDelegate.readDatabases(TransMeta transMeta,
boolean overWriteShared)
Read all the databases from the repository, insert into the TransMeta object, overwriting optionally |
void |
KettleDatabaseRepositoryTransDelegate.readPartitionSchemas(TransMeta transMeta,
boolean overWriteShared)
Read the partitions in the repository and add them to this transformation if they are not yet present. |
SharedObjects |
KettleDatabaseRepositoryJobDelegate.readSharedObjects(JobMeta jobMeta)
|
void |
KettleDatabaseRepositoryJobDelegate.readSlaves(JobMeta jobMeta,
boolean overWriteShared)
Read the slave servers in the repository and add them to this transformation if they are not yet present. |
void |
KettleDatabaseRepositoryTransDelegate.readSlaves(TransMeta transMeta,
boolean overWriteShared)
Read the slave servers in the repository and add them to this transformation if they are not yet present. |
SharedObjects |
KettleDatabaseRepositoryTransDelegate.readTransSharedObjects(TransMeta transMeta)
|
void |
KettleDatabaseRepositoryClusterSchemaDelegate.renameClusterSchema(ObjectId id_cluster,
String new_name)
|
void |
KettleDatabaseRepositoryDirectoryDelegate.renameDirectory(ObjectId id_directory,
ObjectId id_directory_parent,
String newName)
Move / rename a directory in the repository |
void |
KettleDatabaseRepositoryJobDelegate.renameJob(ObjectId id_job,
RepositoryDirectoryInterface newParentDir,
String newname)
|
ObjectId |
KettleDatabaseRepositoryDirectoryDelegate.renameRepositoryDirectory(ObjectId id,
RepositoryDirectoryInterface newParentDir,
String newName)
|
ObjectId |
KettleDatabaseRepositoryDirectoryDelegate.renameRepositoryDirectory(RepositoryDirectory dir)
Deprecated. |
void |
KettleDatabaseRepositoryTransDelegate.renameTransformation(ObjectId id_transformation,
RepositoryDirectoryInterface newParentDir,
String newname)
|
void |
KettleDatabaseRepositoryUserDelegate.renameUser(ObjectId id_user,
String newname)
|
void |
KettleDatabaseRepositoryClusterSchemaDelegate.saveClusterSchema(ClusterSchema clusterSchema,
String versionComment)
|
void |
KettleDatabaseRepositoryClusterSchemaDelegate.saveClusterSchema(ClusterSchema clusterSchema,
String versionComment,
ObjectId id_transformation,
boolean isUsedByTransformation)
|
void |
KettleDatabaseRepositoryClusterSchemaDelegate.saveClusterSchema(ClusterSchema clusterSchema,
String versionComment,
ObjectId id_transformation,
boolean isUsedByTransformation,
boolean overwrite)
|
ObjectId |
KettleDatabaseRepositoryConditionDelegate.saveCondition(Condition condition)
|
ObjectId |
KettleDatabaseRepositoryConditionDelegate.saveCondition(Condition condition,
ObjectId id_condition_parent)
|
void |
KettleDatabaseRepositoryDatabaseDelegate.saveDatabaseMeta(DatabaseMeta databaseMeta)
Saves the database information into a given repository. |
void |
KettleDatabaseRepositoryJobDelegate.saveJob(JobMeta jobMeta,
String versionComment,
ProgressMonitorListener monitor,
boolean overwrite)
Stored a job in the repository |
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
long nr,
String code,
boolean value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
long nr,
String code,
double value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
long nr,
String code,
String value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
boolean value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
double value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveJobEntryAttribute(ObjectId id_job,
ObjectId id_jobentry,
String code,
String value)
|
void |
KettleDatabaseRepositoryJobEntryDelegate.saveJobEntryCopy(JobEntryCopy copy,
ObjectId id_job)
|
void |
KettleDatabaseRepositoryJobDelegate.saveJobHopMeta(JobHopMeta hop,
ObjectId id_job)
|
void |
KettleDatabaseRepositoryNotePadDelegate.saveNotePadMeta(NotePadMeta note,
ObjectId id_transformation)
|
void |
KettleDatabaseRepositoryPartitionSchemaDelegate.savePartitionSchema(PartitionSchema partitionSchema)
|
void |
KettleDatabaseRepositoryPartitionSchemaDelegate.savePartitionSchema(PartitionSchema partitionSchema,
ObjectId id_transformation,
boolean isUsedByTransformation)
|
void |
KettleDatabaseRepositoryPartitionSchemaDelegate.savePartitionSchema(PartitionSchema partitionSchema,
ObjectId id_transformation,
boolean isUsedByTransformation,
boolean overwrite)
|
void |
KettleDatabaseRepositoryDirectoryDelegate.saveRepositoryDirectory(RepositoryDirectoryInterface dir)
|
void |
KettleDatabaseRepositorySlaveServerDelegate.saveSlaveServer(SlaveServer slaveServer)
|
void |
KettleDatabaseRepositorySlaveServerDelegate.saveSlaveServer(SlaveServer slaveServer,
ObjectId id_transformation,
boolean isUsedByTransformation)
|
void |
KettleDatabaseRepositorySlaveServerDelegate.saveSlaveServer(SlaveServer slaveServer,
ObjectId id_transformation,
boolean isUsedByTransformation,
boolean overwrite)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
long nr,
String code,
boolean value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
long nr,
String code,
double value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
long nr,
String code,
String value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
boolean value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
double value)
|
ObjectId |
KettleDatabaseRepositoryConnectionDelegate.saveStepAttribute(ObjectId id_transformation,
ObjectId id_step,
String code,
String value)
|
void |
KettleDatabaseRepositoryStepDelegate.saveStepErrorMeta(StepErrorMeta meta,
ObjectId id_transformation,
ObjectId id_step)
|
void |
KettleDatabaseRepositoryStepDelegate.saveStepMeta(StepMeta stepMeta,
ObjectId id_transformation)
|
void |
KettleDatabaseRepositoryStepDelegate.saveStepPartitioningMeta(StepPartitioningMeta meta,
ObjectId id_transformation,
ObjectId id_step)
Saves partitioning properties in the repository for the given step. |
void |
KettleDatabaseRepositoryTransDelegate.saveTransDependency(TransDependency transDependency,
ObjectId id_transformation)
|
void |
KettleDatabaseRepositoryTransDelegate.saveTransformation(TransMeta transMeta,
String versionComment,
ProgressMonitorListener monitor,
boolean overwriteAssociated)
Saves the transformation to a repository. |
void |
KettleDatabaseRepositoryTransDelegate.saveTransHopMeta(TransHopMeta transHopMeta,
ObjectId id_transformation)
|
void |
KettleDatabaseRepositoryTransDelegate.saveTransParameters(TransMeta transMeta)
Save the parameters of this transformation to the repository. |
void |
KettleDatabaseRepositoryUserDelegate.saveUserInfo(IUser userInfo)
|
void |
KettleDatabaseRepositoryTransAttribute.setAttribute(String code,
boolean value)
|
void |
KettleDatabaseRepositoryJobAttribute.setAttribute(String code,
boolean value)
|
void |
KettleDatabaseRepositoryTransAttribute.setAttribute(String code,
long value)
|
void |
KettleDatabaseRepositoryJobAttribute.setAttribute(String code,
long value)
|
void |
KettleDatabaseRepositoryTransAttribute.setAttribute(String code,
String value)
|
void |
KettleDatabaseRepositoryJobAttribute.setAttribute(String code,
String value)
|
void |
KettleDatabaseRepositoryConnectionDelegate.setLookupJobAttribute()
|
void |
KettleDatabaseRepositoryConnectionDelegate.setLookupJobEntryAttribute()
|
void |
KettleDatabaseRepositoryConnectionDelegate.setLookupStepAttribute()
|
void |
KettleDatabaseRepositoryConnectionDelegate.setLookupTransAttribute()
|
void |
KettleDatabaseRepositoryConnectionDelegate.unlockRepository()
|
void |
KettleDatabaseRepositoryClusterSchemaDelegate.updateCluster(ClusterSchema clusterSchema)
|
void |
KettleDatabaseRepositoryDatabaseDelegate.updateDatabase(ObjectId 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 |
KettleDatabaseRepositoryPartitionSchemaDelegate.updatePartitionSchema(PartitionSchema partitionSchema)
|
void |
KettleDatabaseRepositorySlaveServerDelegate.updateSlave(SlaveServer slaveServer)
|
void |
KettleDatabaseRepositoryConnectionDelegate.updateTableRow(String tablename,
String idfield,
RowMetaAndData values)
|
void |
KettleDatabaseRepositoryConnectionDelegate.updateTableRow(String tablename,
String idfield,
RowMetaAndData values,
ObjectId id)
|
Uses of KettleException in org.pentaho.di.resource |
---|
Methods in org.pentaho.di.resource that throw KettleException | |
---|---|
String |
ResourceExportInterface.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface namingInterface,
Repository repository)
Exports the object to a flat-file system, adding content with filename keys to a set of definitions. |
static TopLevelResource |
ResourceUtil.serializeResourceExportInterface(String zipFilename,
ResourceExportInterface resourceExportInterface,
VariableSpace space,
Repository repository)
Serializes the referenced resource export interface (Job, Transformation, Mapping, Step, Job Entry, etc) to a ZIP file. |
static TopLevelResource |
ResourceUtil.serializeResourceExportInterface(String zipFilename,
ResourceExportInterface resourceExportInterface,
VariableSpace space,
Repository repository,
String injectXML,
String injectFilename)
Serializes the referenced resource export interface (Job, Transformation, Mapping, Step, Job Entry, etc) to a ZIP file. |
Uses of KettleException in org.pentaho.di.run |
---|
Methods in org.pentaho.di.run that throw KettleException | |
---|---|
boolean |
TimedTransRunner.runEngine()
|
boolean |
TimedTransRunner.runEngine(boolean printDescription)
|
Uses of KettleException in org.pentaho.di.shared |
---|
Methods in org.pentaho.di.shared that throw KettleException | |
---|---|
String |
SharedObjectInterface.getXML()
|
void |
SharedObjects.saveToFile()
|
Uses of KettleException in org.pentaho.di.trans |
---|
Methods in org.pentaho.di.trans that throw KettleException | |
---|---|
RowProducer |
Trans.addRowProducer(String stepname,
int copynr)
This adds a row producer to the transformation that just got set up. |
static void |
Trans.cleanupSlaveServer(TransSplitter transSplitter,
SlaveServer slaveServer,
TransMeta slaveTransMeta)
Cleanup the slave server as part of a clustered transformation. |
void |
SingleThreadedTransExecutor.dispose()
|
void |
Trans.execute(String[] arguments)
Executes the transformation. |
static TransSplitter |
Trans.executeClustered(TransMeta transMeta,
TransExecutionConfiguration executionConfiguration)
Execute the transformation in a clustered fashion. |
static void |
Trans.executeClustered(TransSplitter transSplitter,
TransExecutionConfiguration executionConfiguration)
Executes an existing TransSplitter, with the transformation already split. |
static List<RowMetaAndData> |
TransTestFactory.executeTestTransformation(TransMeta transMeta,
String injectorStepname,
String testStepname,
String dummyStepname,
List<RowMetaAndData> inputData)
|
String |
TransMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Exports the specified objects to a flat-file system, adding content with filename keys to a set of definitions. |
static TransConfiguration |
TransConfiguration.fromXML(String xml)
|
TransMeta |
TransProfileFactory.generateTransformation(LoggingObjectInterface parentLoggingInterface)
|
int |
Partitioner.getPartition(RowMetaInterface rowMeta,
Object[] r)
Gets the partition. |
int |
ModPartitioner.getPartition(RowMetaInterface rowMeta,
Object[] row)
|
String |
TransMeta.getXML()
Gets the XML representation of this transformation. |
String |
TransConfiguration.getXML()
|
String |
TransMeta.getXML(boolean includeSteps,
boolean includeDatabase,
boolean includeSlaves,
boolean includeClusters,
boolean includePartitions)
Gets the XML representation of this transformation, including or excluding step, database, slave server, cluster, or partition information as specified by the parameters |
boolean |
SingleThreadedTransExecutor.init()
|
void |
BasePartitioner.init(RowMetaInterface rowMeta)
Inits the. |
boolean |
TransMeta.isUsingSlaveServer(SlaveServer slaveServer)
Checks if the transformation is using the specified slave server. |
void |
Partitioner.loadRep(Repository rep,
ObjectId id_step)
Load rep. |
void |
ModPartitioner.loadRep(Repository rep,
ObjectId id_step)
|
void |
TransMeta.lookupRepositoryReferences(Repository repository)
Looks up the references after a repository import. |
boolean |
SingleThreadedTransExecutor.oneIteration()
Give all steps in the transformation the chance to process all rows on input... |
void |
Trans.prepareExecution(String[] arguments)
Prepares the transformation for execution. |
SharedObjects |
TransMeta.readSharedObjects()
Reads the shared objects (steps, connections, etc.). |
void |
Partitioner.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
Saves partitioning properties in the repository for the given step. |
void |
ModPartitioner.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
TransMeta.saveSharedObjects()
Save shared objects, including databases, steps, partition schemas, slave servers, and cluster schemas, to a file |
static String |
Trans.sendToSlaveServer(TransMeta transMeta,
TransExecutionConfiguration executionConfiguration,
Repository repository)
Send the transformation for execution to a Carte slave server. |
void |
Trans.startThreads()
Starts the threads prepared by prepareThreads(). |
void |
TransListener.transFinished(Trans trans)
The transformation has finished. |
void |
TransAdapter.transFinished(Trans trans)
|
void |
TransListener.transStarted(Trans trans)
This transformation started |
void |
TransAdapter.transStarted(Trans trans)
|
Constructors in org.pentaho.di.trans that throw KettleException | |
---|---|
Trans(VariableSpace parentVariableSpace,
Repository rep,
String name,
String dirname,
String filename)
Instantiates a new transformation using any of the provided parameters including the variable bindings, a repository, a name, a repository directory name, and a filename. |
|
TransConfiguration(Node configNode)
|
|
TransExecutionConfiguration(Node trecNode)
|
|
TransformationTestCase()
|
|
TransformationTestCase(String name)
|
Uses of KettleException in org.pentaho.di.trans.cluster |
---|
Methods in org.pentaho.di.trans.cluster that throw KettleException | |
---|---|
SlaveServer |
TransSplitter.getMasterServer()
|
void |
TransSplitter.splitOriginalTransformation()
|
Constructors in org.pentaho.di.trans.cluster that throw KettleException | |
---|---|
TransSplitter(TransMeta transMeta)
|
Uses of KettleException in org.pentaho.di.trans.step |
---|
Methods in org.pentaho.di.trans.step that throw KettleException | |
---|---|
void |
StepInterface.batchComplete()
Calling this method will alert the step that we finished passing a batch of records to the step. |
void |
BaseStep.batchComplete()
|
String |
StepMetaInterface.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
|
String |
StepMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
|
String |
BaseStepMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Export resources. |
int |
StepPartitioningMeta.getPartition(RowMetaInterface rowMeta,
Object[] row)
|
RowMetaInterface |
BaseStepMeta.getRequiredFields()
Deprecated. |
RowMetaInterface |
StepMetaInterface.getRequiredFields(VariableSpace space)
The natural way of data flow in a transformation is source-to-target. |
RowMetaInterface |
BaseStepMeta.getRequiredFields(VariableSpace space)
The natural way of data flow in a transformation is source-to-target. |
Object[] |
StepInterface.getRow()
|
Object[] |
BaseStep.getRow()
In case of getRow, we receive data from previous steps through the input rowset. |
List<StepInjectionMetaEntry> |
StepMetaInjectionInterface.getStepInjectionMetadataEntries()
|
String |
StepMetaInterface.getXML()
Get the XML that represents the values in this step |
String |
StepMeta.getXML()
|
String |
BaseStepMeta.getXML()
Produces the XML string that describes this step's information. |
String |
StepMeta.getXML(boolean includeInterface)
|
void |
StepMetaInjectionInterface.injectStepMetadataEntries(List<StepInjectionMetaEntry> metadata)
|
void |
StepMetaDataPlugin.loadFromRepository(Repository repository,
ObjectId transformationId,
ObjectId stepId)
|
void |
StepMetaInterface.lookupRepositoryReferences(Repository repository)
Look up the references after import |
void |
BaseStepMeta.lookupRepositoryReferences(Repository repository)
Look up the references after import |
BlockingRowSet |
RemoteStep.openReaderSocket(BaseStep baseStep)
|
boolean |
StepInterface.processRow(StepMetaInterface smi,
StepDataInterface sdi)
Perform the equivalent of processing one row. |
boolean |
BaseStep.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
StepInterface.putRow(RowMetaInterface row,
Object[] data)
Put a row on the destination rowsets. |
void |
StepMetaInterface.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
Read the steps information from a Kettle repository |
void |
StepMetaInterface.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
Save the steps data into a Kettle repository |
void |
StepMetaDataPlugin.saveToRepository(Repository repository,
ObjectId transformationId,
ObjectId stepId)
|
void |
StepPartitioningMeta.setPartitionSchemaAfterLoading(List<PartitionSchema> partitionSchemas)
Set the partitioning schema after loading from XML or repository |
void |
StepInterface.stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
Stop running operations... |
void |
BaseStep.stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
Perform actions to stop a running step. |
Constructors in org.pentaho.di.trans.step that throw KettleException | |
---|---|
RemoteStep(Node node)
|
|
StepPartitioningMeta(Node partitioningMethodNode)
|
Uses of KettleException in org.pentaho.di.trans.step.errorhandling |
---|
Methods in org.pentaho.di.trans.step.errorhandling that throw KettleException | |
---|---|
void |
AbstractFileErrorHandler.close()
|
void |
CompositeFileErrorHandler.close()
|
void |
FileErrorHandler.close()
This method closes the handler; |
void |
AbstractFileErrorHandler.handleFile(org.apache.commons.vfs.FileObject file)
|
void |
CompositeFileErrorHandler.handleFile(org.apache.commons.vfs.FileObject file)
|
void |
FileErrorHandler.handleFile(org.apache.commons.vfs.FileObject file)
Tells the handler which file is being processed. |
void |
CompositeFileErrorHandler.handleLineError(long lineNr,
String filePart)
|
void |
FileErrorHandler.handleLineError(long lineNr,
String filePart)
This method handles an error when processing the line with corresponding lineNr. |
void |
FileErrorHandlerContentLineNumber.handleLineError(long lineNr,
String filePart)
|
void |
CompositeFileErrorHandler.handleNonAccessibleFile(org.apache.commons.vfs.FileObject file)
|
void |
FileErrorHandler.handleNonAccessibleFile(org.apache.commons.vfs.FileObject file)
This method handles a file that is required, but is not accessible. |
void |
FileErrorHandlerMissingFiles.handleNonAccessibleFile(org.apache.commons.vfs.FileObject file)
|
void |
CompositeFileErrorHandler.handleNonExistantFile(org.apache.commons.vfs.FileObject file)
|
void |
FileErrorHandler.handleNonExistantFile(org.apache.commons.vfs.FileObject file)
This method handles a file that is required, but does not exist. |
void |
FileErrorHandlerMissingFiles.handleNonExistantFile(org.apache.commons.vfs.FileObject file)
|
Uses of KettleException in org.pentaho.di.trans.steps.abort |
---|
Methods in org.pentaho.di.trans.steps.abort that throw KettleException | |
---|---|
boolean |
Abort.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
AbortMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
AbortMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.accessinput |
---|
Methods in org.pentaho.di.trans.steps.accessinput that throw KettleException | |
---|---|
String |
AccessInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
AccessInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
AccessInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
AccessInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.accessoutput |
---|
Methods in org.pentaho.di.trans.steps.accessoutput that throw KettleException | |
---|---|
String |
AccessOutputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
RowMetaInterface |
AccessOutputMeta.getRequiredFields(VariableSpace space)
|
boolean |
AccessOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
AccessOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
AccessOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.addsequence |
---|
Methods in org.pentaho.di.trans.steps.addsequence that throw KettleException | |
---|---|
Object[] |
AddSequence.addSequence(RowMetaInterface inputRowMeta,
Object[] inputRowData)
|
boolean |
AddSequence.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
AddSequenceMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
AddSequenceMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.addxml |
---|
Methods in org.pentaho.di.trans.steps.addxml that throw KettleException | |
---|---|
boolean |
AddXML.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
AddXMLMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
AddXMLMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.aggregaterows |
---|
Methods in org.pentaho.di.trans.steps.aggregaterows that throw KettleException | |
---|---|
boolean |
AggregateRows.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
AggregateRowsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
AggregateRowsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.analyticquery |
---|
Methods in org.pentaho.di.trans.steps.analyticquery that throw KettleException | |
---|---|
boolean |
AnalyticQuery.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
AnalyticQueryMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
AnalyticQueryMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.append |
---|
Methods in org.pentaho.di.trans.steps.append that throw KettleException | |
---|---|
boolean |
Append.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
AppendMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
AppendMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.autodoc |
---|
Uses of KettleException in org.pentaho.di.trans.steps.blockingstep |
---|
Methods in org.pentaho.di.trans.steps.blockingstep that throw KettleException | |
---|---|
boolean |
BlockingStep.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
BlockingStepMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
BlockingStepMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.blockuntilstepsfinish |
---|
Methods in org.pentaho.di.trans.steps.blockuntilstepsfinish that throw KettleException | |
---|---|
boolean |
BlockUntilStepsFinish.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
BlockUntilStepsFinishMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
BlockUntilStepsFinishMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.calculator |
---|
Methods in org.pentaho.di.trans.steps.calculator that throw KettleException | |
---|---|
boolean |
Calculator.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
CalculatorMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
CalculatorMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
CalculatorMetaFunction.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step,
int nr)
|
Constructors in org.pentaho.di.trans.steps.calculator that throw KettleException | |
---|---|
CalculatorMetaFunction(Repository rep,
ObjectId id_step,
int nr)
|
Uses of KettleException in org.pentaho.di.trans.steps.changefileencoding |
---|
Methods in org.pentaho.di.trans.steps.changefileencoding that throw KettleException | |
---|---|
boolean |
ChangeFileEncoding.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ChangeFileEncodingMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ChangeFileEncodingMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.checksum |
---|
Methods in org.pentaho.di.trans.steps.checksum that throw KettleException | |
---|---|
boolean |
CheckSum.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
CheckSumMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
CheckSumMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.clonerow |
---|
Methods in org.pentaho.di.trans.steps.clonerow that throw KettleException | |
---|---|
boolean |
CloneRow.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
CloneRowMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
CloneRowMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.closure |
---|
Methods in org.pentaho.di.trans.steps.closure that throw KettleException | |
---|---|
boolean |
ClosureGenerator.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ClosureGeneratorMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ClosureGeneratorMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.columnexists |
---|
Methods in org.pentaho.di.trans.steps.columnexists that throw KettleException | |
---|---|
boolean |
ColumnExists.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ColumnExistsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ColumnExistsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.combinationlookup |
---|
Methods in org.pentaho.di.trans.steps.combinationlookup that throw KettleException | |
---|---|
boolean |
CombinationLookup.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
CombinationLookupMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
CombinationLookupMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.concatfields |
---|
Methods in org.pentaho.di.trans.steps.concatfields that throw KettleException | |
---|---|
boolean |
ConcatFields.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ConcatFieldsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ConcatFieldsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.constant |
---|
Methods in org.pentaho.di.trans.steps.constant that throw KettleException | |
---|---|
boolean |
Constant.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ConstantMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ConstantMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.creditcardvalidator |
---|
Methods in org.pentaho.di.trans.steps.creditcardvalidator that throw KettleException | |
---|---|
boolean |
CreditCardValidator.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
CreditCardValidatorMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
CreditCardValidatorMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.csvinput |
---|
Methods in org.pentaho.di.trans.steps.csvinput that throw KettleException | |
---|---|
void |
CsvInput.closeFile()
|
String |
CsvInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
List<StepInjectionMetaEntry> |
CsvInputMeta.getStepInjectionMetadataEntries()
Describe the metadata attributes that can be injected into this step metadata object. |
static String[] |
CsvInput.guessStringsFromLine(LogChannelInterface log,
String line,
String delimiter,
String enclosure,
String escapeCharacter)
This method is borrowed from TextFileInput |
boolean |
CsvInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
CsvInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
CsvInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.cubeinput |
---|
Methods in org.pentaho.di.trans.steps.cubeinput that throw KettleException | |
---|---|
String |
CubeInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
CubeInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
CubeInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
CubeInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.cubeoutput |
---|
Methods in org.pentaho.di.trans.steps.cubeoutput that throw KettleException | |
---|---|
String |
CubeOutputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
CubeOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
CubeOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
CubeOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.databasejoin |
---|
Methods in org.pentaho.di.trans.steps.databasejoin that throw KettleException | |
---|---|
boolean |
DatabaseJoin.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DatabaseJoinMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DatabaseJoinMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
DatabaseJoin.stopRunning(StepMetaInterface smi,
StepDataInterface sdi)
Stop the running query |
Uses of KettleException in org.pentaho.di.trans.steps.databaselookup |
---|
Methods in org.pentaho.di.trans.steps.databaselookup that throw KettleException | |
---|---|
boolean |
DatabaseLookup.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DatabaseLookupMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DatabaseLookupMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
DatabaseLookup.stopRunning(StepMetaInterface smi,
StepDataInterface sdi)
Stop the running query |
Uses of KettleException in org.pentaho.di.trans.steps.datagrid |
---|
Methods in org.pentaho.di.trans.steps.datagrid that throw KettleException | |
---|---|
boolean |
DataGrid.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DataGridMeta.readRep(Repository rep,
ObjectId idStep,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DataGridMeta.saveRep(Repository rep,
ObjectId idTransformation,
ObjectId idStep)
|
Uses of KettleException in org.pentaho.di.trans.steps.dbproc |
---|
Methods in org.pentaho.di.trans.steps.dbproc that throw KettleException | |
---|---|
boolean |
DBProc.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DBProcMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DBProcMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.delay |
---|
Methods in org.pentaho.di.trans.steps.delay that throw KettleException | |
---|---|
boolean |
Delay.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DelayMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DelayMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.delete |
---|
Methods in org.pentaho.di.trans.steps.delete that throw KettleException | |
---|---|
boolean |
Delete.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DeleteMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DeleteMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.denormaliser |
---|
Methods in org.pentaho.di.trans.steps.denormaliser that throw KettleException | |
---|---|
void |
Denormaliser.batchComplete()
|
List<StepInjectionMetaEntry> |
DenormaliserMetaInjection.getStepInjectionMetadataEntries()
|
void |
DenormaliserMetaInjection.injectStepMetadataEntries(List<StepInjectionMetaEntry> all)
|
boolean |
Denormaliser.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DenormaliserMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DenormaliserMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.detectemptystream |
---|
Methods in org.pentaho.di.trans.steps.detectemptystream that throw KettleException | |
---|---|
boolean |
DetectEmptyStream.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DetectEmptyStreamMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DetectEmptyStreamMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.detectlastrow |
---|
Methods in org.pentaho.di.trans.steps.detectlastrow that throw KettleException | |
---|---|
boolean |
DetectLastRow.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DetectLastRowMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DetectLastRowMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.dimensionlookup |
---|
Methods in org.pentaho.di.trans.steps.dimensionlookup that throw KettleException | |
---|---|
void |
DimensionLookup.checkDimZero()
|
Long |
DimensionLookup.dimInsert(RowMetaInterface inputRowMeta,
Object[] row,
Long technicalKey,
boolean newEntry,
Long versionNr,
Date dateFrom,
Date dateTo)
This inserts new record into dimension Optionally, if the entry already exists, update date range from previous version of the entry. |
int |
DimensionCache.lookupRow(Object[] lookupRowData)
Looks up a row in the (sorted) cache. |
boolean |
DimensionLookup.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DimensionLookupMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DimensionLookupMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.dummytrans |
---|
Methods in org.pentaho.di.trans.steps.dummytrans that throw KettleException | |
---|---|
boolean |
DummyTrans.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DummyTransMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DummyTransMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.dynamicsqlrow |
---|
Methods in org.pentaho.di.trans.steps.dynamicsqlrow that throw KettleException | |
---|---|
boolean |
DynamicSQLRow.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
DynamicSQLRowMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
DynamicSQLRowMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
DynamicSQLRow.stopRunning(StepMetaInterface smi,
StepDataInterface sdi)
Stop the running query |
Uses of KettleException in org.pentaho.di.trans.steps.edi2xml |
---|
Methods in org.pentaho.di.trans.steps.edi2xml that throw KettleException | |
---|---|
boolean |
Edi2Xml.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
Edi2XmlMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
Edi2XmlMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.elasticsearchbulk |
---|
Methods in org.pentaho.di.trans.steps.elasticsearchbulk that throw KettleException | |
---|---|
boolean |
ElasticSearchBulk.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ElasticSearchBulkMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ElasticSearchBulkMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.excelinput |
---|
Subclasses of KettleException in org.pentaho.di.trans.steps.excelinput | |
---|---|
class |
KettleCellValueException
Extended KettleValueException that allows passing extra
context info up the chain (sheet, row, and column IDs). |
Methods in org.pentaho.di.trans.steps.excelinput that throw KettleException | |
---|---|
String |
ExcelInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
List<StepInjectionMetaEntry> |
ExcelInputMetaInjection.getStepInjectionMetadataEntries()
|
static KWorkbook |
WorkbookFactory.getWorkbook(SpreadSheetType type,
String filename,
String encoding)
|
void |
ExcelInputMetaInjection.injectStepMetadataEntries(List<StepInjectionMetaEntry> all)
|
boolean |
ExcelInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ExcelInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ExcelInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Constructors in org.pentaho.di.trans.steps.excelinput with parameters of type KettleException | |
---|---|
KettleCellValueException(KettleException ex,
int sheetnr,
int rownr,
int colnr,
String fieldName)
Standard constructor. |
Uses of KettleException in org.pentaho.di.trans.steps.excelinput.jxl |
---|
Constructors in org.pentaho.di.trans.steps.excelinput.jxl that throw KettleException | |
---|---|
XLSWorkbook(String filename,
String encoding)
|
Uses of KettleException in org.pentaho.di.trans.steps.excelinput.ods |
---|
Constructors in org.pentaho.di.trans.steps.excelinput.ods that throw KettleException | |
---|---|
OdfWorkbook(String filename,
String encoding)
|
Uses of KettleException in org.pentaho.di.trans.steps.excelinput.poi |
---|
Constructors in org.pentaho.di.trans.steps.excelinput.poi that throw KettleException | |
---|---|
PoiWorkbook(String filename,
String encoding)
|
Uses of KettleException in org.pentaho.di.trans.steps.exceloutput |
---|
Methods in org.pentaho.di.trans.steps.exceloutput that throw KettleException | |
---|---|
String |
ExcelOutputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
ExcelOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ExcelOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ExcelOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.excelwriter |
---|
Methods in org.pentaho.di.trans.steps.excelwriter that throw KettleException | |
---|---|
static void |
ExcelWriterStep.copyFile(org.apache.commons.vfs.FileObject in,
org.apache.commons.vfs.FileObject out)
Copies a VFS File |
String |
ExcelWriterStepMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
void |
ExcelWriterStep.prepareNextOutputFile()
|
boolean |
ExcelWriterStep.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ExcelWriterStepMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ExcelWriterStepMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
ExcelWriterStep.writeNextLine(Object[] r)
|
Uses of KettleException in org.pentaho.di.trans.steps.execprocess |
---|
Methods in org.pentaho.di.trans.steps.execprocess that throw KettleException | |
---|---|
boolean |
ExecProcess.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ExecProcessMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ExecProcessMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.execsqlrow |
---|
Methods in org.pentaho.di.trans.steps.execsqlrow that throw KettleException | |
---|---|
boolean |
ExecSQLRow.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ExecSQLRowMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ExecSQLRowMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
ExecSQLRow.stopRunning(StepMetaInterface smi,
StepDataInterface sdi)
Stop the running query |
Uses of KettleException in org.pentaho.di.trans.steps.fieldschangesequence |
---|
Methods in org.pentaho.di.trans.steps.fieldschangesequence that throw KettleException | |
---|---|
boolean |
FieldsChangeSequence.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FieldsChangeSequenceMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FieldsChangeSequenceMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.fieldsplitter |
---|
Methods in org.pentaho.di.trans.steps.fieldsplitter that throw KettleException | |
---|---|
boolean |
FieldSplitter.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FieldSplitterMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FieldSplitterMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.fileexists |
---|
Methods in org.pentaho.di.trans.steps.fileexists that throw KettleException | |
---|---|
boolean |
FileExists.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FileExistsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FileExistsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.filelocked |
---|
Methods in org.pentaho.di.trans.steps.filelocked that throw KettleException | |
---|---|
boolean |
FileLocked.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FileLockedMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FileLockedMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.filesfromresult |
---|
Methods in org.pentaho.di.trans.steps.filesfromresult that throw KettleException | |
---|---|
boolean |
FilesFromResult.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FilesFromResultMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FilesFromResultMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.filestoresult |
---|
Methods in org.pentaho.di.trans.steps.filestoresult that throw KettleException | |
---|---|
boolean |
FilesToResult.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FilesToResultMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FilesToResultMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.filterrows |
---|
Methods in org.pentaho.di.trans.steps.filterrows that throw KettleException | |
---|---|
String |
FilterRowsMeta.getXML()
|
boolean |
FilterRows.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FilterRowsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FilterRowsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.fixedinput |
---|
Methods in org.pentaho.di.trans.steps.fixedinput that throw KettleException | |
---|---|
String |
FixedInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
List<StepInjectionMetaEntry> |
FixedInputMetaInjection.getStepInjectionMetadataEntries()
|
void |
FixedInputMetaInjection.injectStepMetadataEntries(List<StepInjectionMetaEntry> all)
|
boolean |
FixedInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FixedInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FixedInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.flattener |
---|
Methods in org.pentaho.di.trans.steps.flattener that throw KettleException | |
---|---|
boolean |
Flattener.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FlattenerMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FlattenerMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.formula |
---|
Methods in org.pentaho.di.trans.steps.formula that throw KettleException | |
---|---|
boolean |
Formula.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FormulaMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FormulaMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
FormulaMetaFunction.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step,
int nr)
|
Constructors in org.pentaho.di.trans.steps.formula that throw KettleException | |
---|---|
FormulaMetaFunction(Repository rep,
ObjectId id_step,
int nr)
|
Uses of KettleException in org.pentaho.di.trans.steps.fuzzymatch |
---|
Methods in org.pentaho.di.trans.steps.fuzzymatch that throw KettleException | |
---|---|
boolean |
FuzzyMatch.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
FuzzyMatchMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
FuzzyMatchMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.getfilenames |
---|
Methods in org.pentaho.di.trans.steps.getfilenames that throw KettleException | |
---|---|
String |
GetFileNamesMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
GetFileNames.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GetFileNamesMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GetFileNamesMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.getfilesrowscount |
---|
Methods in org.pentaho.di.trans.steps.getfilesrowscount that throw KettleException | |
---|---|
String |
GetFilesRowsCountMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
GetFilesRowsCount.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GetFilesRowsCountMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GetFilesRowsCountMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.getpreviousrowfield |
---|
Methods in org.pentaho.di.trans.steps.getpreviousrowfield that throw KettleException | |
---|---|
boolean |
GetPreviousRowField.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GetPreviousRowFieldMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GetPreviousRowFieldMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.getrepositorynames |
---|
Methods in org.pentaho.di.trans.steps.getrepositorynames that throw KettleException | |
---|---|
boolean |
GetRepositoryNames.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GetRepositoryNamesMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GetRepositoryNamesMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.getslavesequence |
---|
Methods in org.pentaho.di.trans.steps.getslavesequence that throw KettleException | |
---|---|
Object[] |
GetSlaveSequence.addSequence(RowMetaInterface inputRowMeta,
Object[] inputRowData)
|
boolean |
GetSlaveSequence.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GetSlaveSequenceMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GetSlaveSequenceMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.getsubfolders |
---|
Methods in org.pentaho.di.trans.steps.getsubfolders that throw KettleException | |
---|---|
String |
GetSubFoldersMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
GetSubFolders.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GetSubFoldersMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GetSubFoldersMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.gettablenames |
---|
Methods in org.pentaho.di.trans.steps.gettablenames that throw KettleException | |
---|---|
boolean |
GetTableNames.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GetTableNamesMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GetTableNamesMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.getvariable |
---|
Methods in org.pentaho.di.trans.steps.getvariable that throw KettleException | |
---|---|
boolean |
GetVariable.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GetVariableMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GetVariableMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Constructors in org.pentaho.di.trans.steps.getvariable that throw KettleException | |
---|---|
GetVariableMetaTest()
|
Uses of KettleException in org.pentaho.di.trans.steps.getxmldata |
---|
Methods in org.pentaho.di.trans.steps.getxmldata that throw KettleException | |
---|---|
String |
GetXMLDataMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
GetXMLData.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GetXMLDataMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GetXMLDataMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.googleanalytics |
---|
Methods in org.pentaho.di.trans.steps.googleanalytics that throw KettleException | |
---|---|
boolean |
GaInputStep.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GaInputStepMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GaInputStepMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.gpbulkloader |
---|
Methods in org.pentaho.di.trans.steps.gpbulkloader that throw KettleException | |
---|---|
String |
GPBulkLoader.createCommandLine(GPBulkLoaderMeta meta,
boolean password)
Create the command line for a psql process depending on the meta information supplied. |
void |
GPBulkLoader.createControlFile(String filename,
Object[] row,
GPBulkLoaderMeta meta)
Create a control file. |
boolean |
GPBulkLoader.execute(GPBulkLoaderMeta meta,
boolean wait)
|
String |
GPBulkLoader.getControlFileContents(GPBulkLoaderMeta meta,
RowMetaInterface rm,
Object[] r)
Get the contents of the control file as specified in the meta object |
RowMetaInterface |
GPBulkLoaderMeta.getRequiredFields(VariableSpace space)
|
void |
GPBulkDataOutput.open(VariableSpace space,
Process sqlldrProcess)
|
boolean |
GPBulkLoader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GPBulkLoaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GPBulkLoaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
GPBulkDataOutput.writeLine(RowMetaInterface mi,
Object[] row)
|
Uses of KettleException in org.pentaho.di.trans.steps.groupby |
---|
Methods in org.pentaho.di.trans.steps.groupby that throw KettleException | |
---|---|
void |
GroupBy.batchComplete()
|
boolean |
GroupBy.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
GroupByMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
GroupByMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.http |
---|
Methods in org.pentaho.di.trans.steps.http that throw KettleException | |
---|---|
boolean |
HTTP.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
HTTPMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
HTTPMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.httppost |
---|
Methods in org.pentaho.di.trans.steps.httppost that throw KettleException | |
---|---|
boolean |
HTTPPOST.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
HTTPPOSTMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
HTTPPOSTMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.ifnull |
---|
Methods in org.pentaho.di.trans.steps.ifnull that throw KettleException | |
---|---|
boolean |
IfNull.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
IfNullMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
IfNullMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.infobrightoutput |
---|
Methods in org.pentaho.di.trans.steps.infobrightoutput that throw KettleException | |
---|---|
boolean |
InfobrightLoader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
Perform the equivalent of processing one row. |
void |
InfobrightLoaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
InfobrightLoaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.injector |
---|
Methods in org.pentaho.di.trans.steps.injector that throw KettleException | |
---|---|
boolean |
Injector.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
InjectorMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
InjectorMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.insertupdate |
---|
Methods in org.pentaho.di.trans.steps.insertupdate that throw KettleException | |
---|---|
RowMetaInterface |
InsertUpdateMeta.getRequiredFields(VariableSpace space)
|
boolean |
InsertUpdate.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
InsertUpdateMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
InsertUpdateMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.ivwloader |
---|
Methods in org.pentaho.di.trans.steps.ivwloader that throw KettleException | |
---|---|
String |
IngresVectorwiseLoader.createCommandLine(IngresVectorwiseLoaderMeta meta)
Create the command line for a sql process depending on the meta information supplied. |
boolean |
IngresVectorwiseLoader.execute(IngresVectorwiseLoaderMeta meta)
|
boolean |
IngresVectorwiseLoader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
IngresVectorwiseLoaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
IngresVectorwiseLoaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.janino |
---|
Methods in org.pentaho.di.trans.steps.janino that throw KettleException | |
---|---|
boolean |
Janino.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
JaninoMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
JaninoMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
JaninoMetaFunction.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step,
int nr)
|
Constructors in org.pentaho.di.trans.steps.janino that throw KettleException | |
---|---|
JaninoMetaFunction(Repository rep,
ObjectId id_step,
int nr)
|
Uses of KettleException in org.pentaho.di.trans.steps.javafilter |
---|
Methods in org.pentaho.di.trans.steps.javafilter that throw KettleException | |
---|---|
boolean |
JavaFilter.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
JavaFilterMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
JavaFilterMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.joinrows |
---|
Methods in org.pentaho.di.trans.steps.joinrows that throw KettleException | |
---|---|
void |
JoinRows.batchComplete()
|
Object[] |
JoinRows.getRowData(int filenr)
Get a row of data from the indicated rowset or buffer (memory/disk) |
String |
JoinRowsMeta.getXML()
|
void |
JoinRows.initialize()
|
boolean |
JoinRows.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
JoinRowsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
JoinRowsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.jsoninput |
---|
Methods in org.pentaho.di.trans.steps.jsoninput that throw KettleException | |
---|---|
String |
JsonInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
NJSONArray |
JsonReader.getPath(String value)
|
boolean |
JsonInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
JsonReader.readFile(String filename)
|
void |
JsonInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
JsonReader.readString(String value)
|
void |
JsonReader.readUrl(String value)
|
void |
JsonInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Constructors in org.pentaho.di.trans.steps.jsoninput that throw KettleException | |
---|---|
JsonReader()
|
|
NJSONArray()
|
|
NJSONArray(org.json.simple.JSONArray ja)
|
Uses of KettleException in org.pentaho.di.trans.steps.jsonoutput |
---|
Methods in org.pentaho.di.trans.steps.jsonoutput that throw KettleException | |
---|---|
boolean |
JsonOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
JsonOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
JsonOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.ldapinput |
---|
Methods in org.pentaho.di.trans.steps.ldapinput that throw KettleException | |
---|---|
int |
LDAPConnection.add(String dn,
String[] attributes,
String[] values,
String multValuedSeparator,
boolean checkEntry)
|
void |
LDAPConnection.close()
Close the LDAP connection |
void |
LDAPConnection.connect()
Connect to LDAP server |
void |
LDAPConnection.connect(String username,
String password)
Connect to LDAP server |
int |
LDAPConnection.delete(String dn,
boolean checkEntry)
|
Attributes |
LDAPConnection.getAttributes()
|
RowMeta |
LDAPConnection.getFields(String searchBase)
|
void |
LDAPConnection.insert(String dn,
String[] attributes,
String[] values,
String multValuedSeparator)
Insert record in LDAP based on DN |
boolean |
LDAPInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
LDAPInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
LDAPConnection.rename(String oldDn,
String newDn,
boolean deleteRDN)
Rename an entry |
void |
LDAPInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
LDAPConnection.search(String searchBase,
String filter,
int limitRows,
String[] attributeReturned,
int searchScope)
|
int |
LDAPConnection.update(String dn,
String[] attributes,
String[] values,
boolean checkEntry)
|
int |
LDAPConnection.upsert(String dn,
String[] attributes,
String[] values,
String[] attributesToUpdate,
String[] valuesToUpdate,
String multValuedSeparator)
Upsert record in LDAP First we will check if the entry exist based on DN If we can not find it, we will create it otherwise, we will perform an update |
Constructors in org.pentaho.di.trans.steps.ldapinput that throw KettleException | |
---|---|
LDAPConnection(LogChannelInterface logInterface,
String hostName,
int port)
Construct a new LDAP Connection |
Uses of KettleException in org.pentaho.di.trans.steps.ldapinput.store |
---|
Methods in org.pentaho.di.trans.steps.ldapinput.store that throw KettleException | |
---|---|
static void |
CustomSocketFactory.configure(String path,
String password)
Configures this SSLSocketFactory so that it uses the given keystore as its truststore. |
Constructors in org.pentaho.di.trans.steps.ldapinput.store that throw KettleException | |
---|---|
KettleTrustManager(KeyStore keyStore,
String certFilename,
String certPassword)
|
Uses of KettleException in org.pentaho.di.trans.steps.ldapoutput |
---|
Methods in org.pentaho.di.trans.steps.ldapoutput that throw KettleException | |
---|---|
boolean |
LDAPOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
LDAPOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
LDAPOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.ldifinput |
---|
Methods in org.pentaho.di.trans.steps.ldifinput that throw KettleException | |
---|---|
String |
LDIFInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
LDIFInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
LDIFInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
LDIFInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.loadfileinput |
---|
Methods in org.pentaho.di.trans.steps.loadfileinput that throw KettleException | |
---|---|
String |
LoadFileInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
|
static String |
LoadFileInput.getTextFileContent(String vfsFilename,
String encoding)
Read a text file. |
boolean |
LoadFileInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
LoadFileInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
LoadFileInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.luciddbbulkloader |
---|
Methods in org.pentaho.di.trans.steps.luciddbbulkloader that throw KettleException | |
---|---|
boolean |
LucidDBBulkLoader.execute(LucidDBBulkLoaderMeta meta,
boolean wait)
|
RowMetaInterface |
LucidDBBulkLoaderMeta.getRequiredFields(VariableSpace space)
|
boolean |
LucidDBBulkLoader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
LucidDBBulkLoaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
LucidDBBulkLoaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.luciddbstreamingloader |
---|
Methods in org.pentaho.di.trans.steps.luciddbstreamingloader that throw KettleException | |
---|---|
RowMetaInterface |
LucidDBStreamingLoaderMeta.getRequiredFields(VariableSpace space)
|
boolean |
LucidDBStreamingLoader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
LucidDBStreamingLoaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
LucidDBStreamingLoaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
LucidDBStreamingLoader.stopRunning(StepMetaInterface smi,
StepDataInterface sdi)
|
Uses of KettleException in org.pentaho.di.trans.steps.mail |
---|
Methods in org.pentaho.di.trans.steps.mail that throw KettleException | |
---|---|
String |
MailMeta.getXML()
|
boolean |
Mail.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MailMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MailMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.mailinput |
---|
Methods in org.pentaho.di.trans.steps.mailinput that throw KettleException | |
---|---|
String[] |
MailInput.getFolders(String realIMAPFolder)
|
boolean |
MailInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MailInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MailInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.mailvalidator |
---|
Methods in org.pentaho.di.trans.steps.mailvalidator that throw KettleException | |
---|---|
boolean |
MailValidator.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MailValidatorMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MailValidatorMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.mapping |
---|
Methods in org.pentaho.di.trans.steps.mapping that throw KettleException | |
---|---|
String |
MappingMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
|
static TransMeta |
MappingMeta.loadMappingMeta(MappingMeta mappingMeta,
Repository rep,
VariableSpace space)
|
void |
MappingMeta.lookupRepositoryReferences(Repository repository)
|
void |
Mapping.prepareMappingExecution()
|
boolean |
Mapping.processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process a single row. |
void |
MappingMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MappingParameters.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
MappingMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
MappingIODefinition.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step,
String prefix,
int nr)
|
void |
Mapping.stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
|
Constructors in org.pentaho.di.trans.steps.mapping that throw KettleException | |
---|---|
MappingIODefinition(Repository rep,
ObjectId id_step,
String prefix,
int nr)
|
|
MappingParameters(Repository rep,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.mappinginput |
---|
Methods in org.pentaho.di.trans.steps.mappinginput that throw KettleException | |
---|---|
boolean |
MappingInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MappingInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MappingInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.mappingoutput |
---|
Methods in org.pentaho.di.trans.steps.mappingoutput that throw KettleException | |
---|---|
boolean |
MappingOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MappingOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MappingOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.memgroupby |
---|
Methods in org.pentaho.di.trans.steps.memgroupby that throw KettleException | |
---|---|
void |
MemoryGroupBy.batchComplete()
|
boolean |
MemoryGroupBy.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MemoryGroupByMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MemoryGroupByMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.mergejoin |
---|
Methods in org.pentaho.di.trans.steps.mergejoin that throw KettleException | |
---|---|
boolean |
MergeJoin.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MergeJoinMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MergeJoinMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.mergerows |
---|
Methods in org.pentaho.di.trans.steps.mergerows that throw KettleException | |
---|---|
boolean |
MergeRows.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MergeRowsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MergeRowsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.metainject |
---|
Methods in org.pentaho.di.trans.steps.metainject that throw KettleException | |
---|---|
static TransMeta |
MetaInjectMeta.loadTransformationMeta(MetaInjectMeta mappingMeta,
Repository rep,
VariableSpace space)
|
boolean |
MetaInject.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MetaInjectMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MetaInjectMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.mondrianinput |
---|
Methods in org.pentaho.di.trans.steps.mondrianinput that throw KettleException | |
---|---|
String |
MondrianInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
MondrianInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MondrianInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MondrianInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.monetdbagilemart |
---|
Subclasses of KettleException in org.pentaho.di.trans.steps.monetdbagilemart | |
---|---|
class |
MonetDBRowLimitException
Custom exception to indicate that the row limit has been reached User: RFellows Date: 10/31/12 |
Methods in org.pentaho.di.trans.steps.monetdbagilemart that throw KettleException | |
---|---|
boolean |
MonetDBAgileMart.execute(MonetDBBulkLoaderMeta meta,
boolean wait)
|
Uses of KettleException in org.pentaho.di.trans.steps.monetdbbulkloader |
---|
Methods in org.pentaho.di.trans.steps.monetdbbulkloader that throw KettleException | |
---|---|
void |
MonetDBBulkLoader.autoAdjustSchema(MonetDBBulkLoaderMeta meta,
Runtime rt,
String mClientCmd)
|
String |
MonetDBBulkLoader.createCommandLine(MonetDBBulkLoaderMeta meta,
boolean lSql)
Create the command line for a psql process depending on the meta information supplied. |
void |
MonetDBBulkLoader.dropTable(Runtime rt,
String mClientCmd)
|
boolean |
MonetDBBulkLoader.execute(MonetDBBulkLoaderMeta meta,
boolean wait)
|
RowMetaInterface |
MonetDBBulkLoaderMeta.getRequiredFields(VariableSpace space)
|
SQLStatement |
MonetDBBulkLoaderMeta.getTableDdl(TransMeta transMeta,
String stepname,
boolean autoSchema,
MonetDBBulkLoaderData data,
boolean safeMode)
|
boolean |
MonetDBBulkLoader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MonetDBBulkLoaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MonetDBBulkLoaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
MonetDBBulkLoader.truncateTable(Runtime rt,
String mClientCmd)
|
Uses of KettleException in org.pentaho.di.trans.steps.multimerge |
---|
Methods in org.pentaho.di.trans.steps.multimerge that throw KettleException | |
---|---|
boolean |
MultiMergeJoin.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MultiMergeJoinMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MultiMergeJoinMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.mysqlbulkloader |
---|
Methods in org.pentaho.di.trans.steps.mysqlbulkloader that throw KettleException | |
---|---|
boolean |
MySQLBulkLoader.execute(MySQLBulkLoaderMeta meta)
|
RowMetaInterface |
MySQLBulkLoaderMeta.getRequiredFields(VariableSpace space)
|
boolean |
MySQLBulkLoader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
MySQLBulkLoaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
MySQLBulkLoaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.normaliser |
---|
Methods in org.pentaho.di.trans.steps.normaliser that throw KettleException | |
---|---|
List<StepInjectionMetaEntry> |
NormaliserMetaInjection.getStepInjectionMetadataEntries()
|
void |
NormaliserMetaInjection.injectStepMetadataEntries(List<StepInjectionMetaEntry> all)
|
boolean |
Normaliser.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
NormaliserMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
NormaliserMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.nullif |
---|
Methods in org.pentaho.di.trans.steps.nullif that throw KettleException | |
---|---|
boolean |
NullIf.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
NullIfMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
NullIfMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.numberrange |
---|
Methods in org.pentaho.di.trans.steps.numberrange that throw KettleException | |
---|---|
String |
NumberRangeSet.evaluate(Double value)
Evaluates a value against all rules. |
String |
NumberRangeSet.evaluate(String strValue)
Evaluates a value against all rules. |
boolean |
NumberRange.processRow(StepMetaInterface smi,
StepDataInterface sdi)
Column number where the input value is stored |
void |
NumberRangeMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
NumberRangeMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Constructors in org.pentaho.di.trans.steps.numberrange that throw KettleException | |
---|---|
NumberRangeMeta(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
Uses of KettleException in org.pentaho.di.trans.steps.olapinput |
---|
Methods in org.pentaho.di.trans.steps.olapinput that throw KettleException | |
---|---|
boolean |
OlapInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
OlapInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
OlapInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.orabulkloader |
---|
Methods in org.pentaho.di.trans.steps.orabulkloader that throw KettleException | |
---|---|
void |
OraBulkLoader.checkExitVal(int exitVal)
|
String |
OraBulkLoader.createCommandLine(OraBulkLoaderMeta meta,
boolean password)
Create the command line for an sqlldr process depending on the meta information supplied. |
void |
OraBulkLoader.createControlFile(String filename,
Object[] row,
OraBulkLoaderMeta meta)
Create a control file. |
boolean |
OraBulkLoader.execute(OraBulkLoaderMeta meta,
boolean wait)
|
String |
OraBulkLoader.getControlFileContents(OraBulkLoaderMeta meta,
RowMetaInterface rm,
Object[] r)
Get the contents of the control file as specified in the meta object |
RowMetaInterface |
OraBulkLoaderMeta.getRequiredFields(VariableSpace space)
|
void |
OraBulkDataOutput.open(VariableSpace space,
Process sqlldrProcess)
|
boolean |
OraBulkLoader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
OraBulkLoaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
OraBulkLoaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
OraBulkDataOutput.writeLine(RowMetaInterface mi,
Object[] row)
|
Uses of KettleException in org.pentaho.di.trans.steps.parallelgzipcsv |
---|
Methods in org.pentaho.di.trans.steps.parallelgzipcsv that throw KettleException | |
---|---|
void |
ParGzipCsvInput.closeFile()
|
String |
ParGzipCsvInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
ParGzipCsvInputData.getMoreData()
Read more data from our current file... |
boolean |
ParGzipCsvInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ParGzipCsvInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ParGzipCsvInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.pentahoreporting |
---|
Methods in org.pentaho.di.trans.steps.pentahoreporting that throw KettleException | |
---|---|
boolean |
PentahoReportingOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
PentahoReportingOutputMeta.readRep(Repository rep,
ObjectId idStep,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
PentahoReportingOutputMeta.saveRep(Repository rep,
ObjectId idTransformation,
ObjectId idStep)
|
Uses of KettleException in org.pentaho.di.trans.steps.pgbulkloader |
---|
Methods in org.pentaho.di.trans.steps.pgbulkloader that throw KettleException | |
---|---|
String |
PGBulkLoader.createCommandLine(PGBulkLoaderMeta meta,
boolean password)
Create the command line for a psql process depending on the meta information supplied. |
boolean |
PGBulkLoader.execute(PGBulkLoaderMeta meta,
boolean wait)
|
String |
PGBulkLoader.getCopyCommand(RowMetaInterface rm,
Object[] r)
Get the contents of the control file as specified in the meta object |
RowMetaInterface |
PGBulkLoaderMeta.getRequiredFields(VariableSpace space)
|
boolean |
PGBulkLoader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
PGBulkLoaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
PGBulkLoaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.prioritizestreams |
---|
Methods in org.pentaho.di.trans.steps.prioritizestreams that throw KettleException | |
---|---|
boolean |
PrioritizeStreams.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
PrioritizeStreamsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
PrioritizeStreamsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.processfiles |
---|
Methods in org.pentaho.di.trans.steps.processfiles that throw KettleException | |
---|---|
boolean |
ProcessFiles.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ProcessFilesMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ProcessFilesMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.propertyinput |
---|
Methods in org.pentaho.di.trans.steps.propertyinput that throw KettleException | |
---|---|
String |
PropertyInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
PropertyInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
PropertyInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
PropertyInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.propertyoutput |
---|
Methods in org.pentaho.di.trans.steps.propertyoutput that throw KettleException | |
---|---|
boolean |
PropertyOutput.checkSameFile()
|
String |
PropertyOutputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
PropertyOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
PropertyOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
PropertyOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.randomccnumber |
---|
Methods in org.pentaho.di.trans.steps.randomccnumber that throw KettleException | |
---|---|
static String[] |
RandomCreditCardNumberGenerator.GenerateCreditCardNumbers(int cardType,
int size,
int howMany)
|
boolean |
RandomCCNumberGenerator.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
RandomCCNumberGeneratorMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
RandomCCNumberGeneratorMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.randomvalue |
---|
Methods in org.pentaho.di.trans.steps.randomvalue that throw KettleException | |
---|---|
boolean |
RandomValue.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
RandomValueMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
RandomValueMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.regexeval |
---|
Methods in org.pentaho.di.trans.steps.regexeval that throw KettleException | |
---|---|
boolean |
RegexEval.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
RegexEvalMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
RegexEvalMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Constructors in org.pentaho.di.trans.steps.regexeval that throw KettleException | |
---|---|
RegexEvalTest()
|
Uses of KettleException in org.pentaho.di.trans.steps.replacestring |
---|
Methods in org.pentaho.di.trans.steps.replacestring that throw KettleException | |
---|---|
boolean |
ReplaceString.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ReplaceStringMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ReplaceStringMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.reservoirsampling |
---|
Methods in org.pentaho.di.trans.steps.reservoirsampling that throw KettleException | |
---|---|
boolean |
ReservoirSampling.processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process an incoming row of data. |
void |
ReservoirSamplingMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
Read this step's configuration from a repository |
void |
ReservoirSamplingMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
Save this step's meta data to a repository |
Uses of KettleException in org.pentaho.di.trans.steps.rest |
---|
Methods in org.pentaho.di.trans.steps.rest that throw KettleException | |
---|---|
boolean |
Rest.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
RestMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
RestMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.rowgenerator |
---|
Methods in org.pentaho.di.trans.steps.rowgenerator that throw KettleException | |
---|---|
boolean |
RowGenerator.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
RowGeneratorMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
RowGeneratorMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.rowsfromresult |
---|
Methods in org.pentaho.di.trans.steps.rowsfromresult that throw KettleException | |
---|---|
boolean |
RowsFromResult.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
RowsFromResultMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
RowsFromResultMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.rowstoresult |
---|
Methods in org.pentaho.di.trans.steps.rowstoresult that throw KettleException | |
---|---|
boolean |
RowsToResult.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
RowsToResultMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
RowsToResultMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.rssinput |
---|
Methods in org.pentaho.di.trans.steps.rssinput that throw KettleException | |
---|---|
boolean |
RssInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
RssInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
RssInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.rssoutput |
---|
Methods in org.pentaho.di.trans.steps.rssoutput that throw KettleException | |
---|---|
boolean |
RssOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
RssOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
RssOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.rules |
---|
Methods in org.pentaho.di.trans.steps.rules that throw KettleException | |
---|---|
boolean |
Rules.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
RulesMeta.readRep(Repository rep,
ObjectId idStep,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
RulesMeta.saveRep(Repository rep,
ObjectId idTransformation,
ObjectId idStep)
|
Uses of KettleException in org.pentaho.di.trans.steps.salesforcedelete |
---|
Methods in org.pentaho.di.trans.steps.salesforcedelete that throw KettleException | |
---|---|
boolean |
SalesforceDelete.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SalesforceDeleteMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SalesforceDeleteMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.salesforceinput |
---|
Methods in org.pentaho.di.trans.steps.salesforceinput that throw KettleException | |
---|---|
void |
SalesforceConnection.close()
|
void |
SalesforceConnection.connect()
|
com.sforce.soap.partner.DeleteResult[] |
SalesforceConnection.delete(String[] id)
|
String[] |
SalesforceConnection.getAllAvailableObjects(boolean OnlyQueryableObjects)
|
String[] |
SalesforceConnection.getFields(String objectName)
|
com.sforce.soap.partner.Field[] |
SalesforceConnection.getObjectFields(String objectName)
|
com.sforce.soap.partner.SaveResult[] |
SalesforceConnection.insert(com.sforce.soap.partner.sobject.SObject[] sfBuffer)
|
boolean |
SalesforceInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SalesforceConnection.query(boolean specifyQuery)
|
boolean |
SalesforceConnection.queryMore()
|
void |
SalesforceInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SalesforceInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
SalesforceConnection.setCalendar(int recordsFilter,
GregorianCalendar startDate,
GregorianCalendar endDate)
|
com.sforce.soap.partner.SaveResult[] |
SalesforceConnection.update(com.sforce.soap.partner.sobject.SObject[] sfBuffer)
|
com.sforce.soap.partner.UpsertResult[] |
SalesforceConnection.upsert(String upsertField,
com.sforce.soap.partner.sobject.SObject[] sfBuffer)
|
Constructors in org.pentaho.di.trans.steps.salesforceinput that throw KettleException | |
---|---|
SalesforceConnection(LogChannelInterface logInterface,
String url,
String username,
String password)
Construct a new Salesforce Connection |
Uses of KettleException in org.pentaho.di.trans.steps.salesforceinsert |
---|
Methods in org.pentaho.di.trans.steps.salesforceinsert that throw KettleException | |
---|---|
boolean |
SalesforceInsert.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SalesforceInsertMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SalesforceInsertMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.salesforceupdate |
---|
Methods in org.pentaho.di.trans.steps.salesforceupdate that throw KettleException | |
---|---|
boolean |
SalesforceUpdate.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SalesforceUpdateMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SalesforceUpdateMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.salesforceupsert |
---|
Methods in org.pentaho.di.trans.steps.salesforceupsert that throw KettleException | |
---|---|
boolean |
SalesforceUpsert.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SalesforceUpsertMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SalesforceUpsertMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.samplerows |
---|
Methods in org.pentaho.di.trans.steps.samplerows that throw KettleException | |
---|---|
boolean |
SampleRows.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SampleRowsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SampleRowsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.sapinput |
---|
Methods in org.pentaho.di.trans.steps.sapinput that throw KettleException | |
---|---|
boolean |
SapInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SapInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SapInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.sapinput.sap |
---|
Subclasses of KettleException in org.pentaho.di.trans.steps.sapinput.sap | |
---|---|
class |
SAPException
|
Uses of KettleException in org.pentaho.di.trans.steps.sasinput |
---|
Methods in org.pentaho.di.trans.steps.sasinput that throw KettleException | |
---|---|
boolean |
SasInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SasInputMeta.readRep(Repository rep,
ObjectId stepId,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SasInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
SasInputField.saveRep(Repository rep,
ObjectId transformationId,
ObjectId stepId,
int fieldNr)
|
void |
SasInput.stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
|
Constructors in org.pentaho.di.trans.steps.sasinput that throw KettleException | |
---|---|
SasInputField(Repository rep,
ObjectId stepId,
int fieldNr)
|
|
SasInputHelper(String filename)
|
Uses of KettleException in org.pentaho.di.trans.steps.script |
---|
Methods in org.pentaho.di.trans.steps.script that throw KettleException | |
---|---|
void |
ScriptDummy.batchComplete()
|
Object[] |
ScriptInterface.getRow()
|
Object[] |
ScriptDummy.getRow()
|
void |
ScriptMeta.parseXmlForAdditionalClasses()
|
boolean |
ScriptInterface.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
boolean |
Script.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
boolean |
ScriptDummy.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ScriptInterface.putRow(RowMetaInterface rowMeta,
Object[] row)
|
void |
ScriptDummy.putRow(RowMetaInterface rowMeta,
Object[] row)
|
void |
ScriptMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ScriptMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
ScriptInterface.stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
|
void |
ScriptDummy.stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
|
Uses of KettleException in org.pentaho.di.trans.steps.scriptvalues_mod |
---|
Methods in org.pentaho.di.trans.steps.scriptvalues_mod that throw KettleException | |
---|---|
void |
ScriptValuesModDummy.batchComplete()
|
Object[] |
ScriptValuesModDummy.getRow()
|
void |
ScriptValuesMetaMod.parseXmlForAdditionalClasses()
|
boolean |
ScriptValuesMod.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
boolean |
ScriptValuesModDummy.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ScriptValuesModDummy.putRow(RowMetaInterface rowMeta,
Object[] row)
|
void |
ScriptValuesMetaMod.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ScriptValuesMetaMod.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
ScriptValuesModDummy.stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
|
Uses of KettleException in org.pentaho.di.trans.steps.selectvalues |
---|
Methods in org.pentaho.di.trans.steps.selectvalues that throw KettleException | |
---|---|
boolean |
SelectValues.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SelectValuesMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SelectValuesMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.setvalueconstant |
---|
Methods in org.pentaho.di.trans.steps.setvalueconstant that throw KettleException | |
---|---|
boolean |
SetValueConstant.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SetValueConstantMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SetValueConstantMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.setvaluefield |
---|
Methods in org.pentaho.di.trans.steps.setvaluefield that throw KettleException | |
---|---|
boolean |
SetValueField.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SetValueFieldMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SetValueFieldMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.setvariable |
---|
Methods in org.pentaho.di.trans.steps.setvariable that throw KettleException | |
---|---|
boolean |
SetVariable.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SetVariableMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SetVariableMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.singlethreader |
---|
Methods in org.pentaho.di.trans.steps.singlethreader that throw KettleException | |
---|---|
String |
SingleThreaderMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
|
static TransMeta |
SingleThreaderMeta.loadSingleThreadedTransMeta(SingleThreaderMeta mappingMeta,
Repository rep,
VariableSpace space)
|
void |
SingleThreaderMeta.lookupRepositoryReferences(Repository repository)
|
void |
SingleThreader.prepareMappingExecution()
|
boolean |
SingleThreader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process rows in batches of N rows. |
void |
SingleThreaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SingleThreaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
SingleThreader.stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
|
Uses of KettleException in org.pentaho.di.trans.steps.socketreader |
---|
Methods in org.pentaho.di.trans.steps.socketreader that throw KettleException | |
---|---|
boolean |
SocketReader.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SocketReaderMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SocketReaderMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.socketwriter |
---|
Methods in org.pentaho.di.trans.steps.socketwriter that throw KettleException | |
---|---|
boolean |
SocketWriter.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SocketWriterMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SocketWriterMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.sort |
---|
Methods in org.pentaho.di.trans.steps.sort that throw KettleException | |
---|---|
void |
SortRows.batchComplete()
Calling this method will alert the step that we finished passing records to the step. |
boolean |
SortRows.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SortRows.quickSort(List<Object[]> elements)
Sort the entire vector, if it is not empty. |
void |
SortRowsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SortRowsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.sortedmerge |
---|
Methods in org.pentaho.di.trans.steps.sortedmerge that throw KettleException | |
---|---|
boolean |
SortedMerge.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SortedMergeMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SortedMergeMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.splitfieldtorows |
---|
Methods in org.pentaho.di.trans.steps.splitfieldtorows that throw KettleException | |
---|---|
boolean |
SplitFieldToRows.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SplitFieldToRowsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SplitFieldToRowsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.sql |
---|
Methods in org.pentaho.di.trans.steps.sql that throw KettleException | |
---|---|
boolean |
ExecSQL.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ExecSQLMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ExecSQLMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
ExecSQL.stopRunning(StepMetaInterface smi,
StepDataInterface sdi)
Stop the running query |
Uses of KettleException in org.pentaho.di.trans.steps.sqlfileoutput |
---|
Methods in org.pentaho.di.trans.steps.sqlfileoutput that throw KettleException | |
---|---|
String |
SQLFileOutputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
RowMetaInterface |
SQLFileOutputMeta.getRequiredFields(VariableSpace space)
|
boolean |
SQLFileOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SQLFileOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SQLFileOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.ssh |
---|
Methods in org.pentaho.di.trans.steps.ssh that throw KettleException | |
---|---|
static com.trilead.ssh2.Connection |
SSHMeta.OpenConnection(String serveur,
int port,
String username,
String password,
boolean useKey,
String keyFilename,
String passPhrase,
int timeOut,
VariableSpace space,
String proxyhost,
int proxyport,
String proxyusername,
String proxypassword)
|
boolean |
SSH.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SSHMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SSHMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Constructors in org.pentaho.di.trans.steps.ssh that throw KettleException | |
---|---|
SessionResult(com.trilead.ssh2.Session session)
|
Uses of KettleException in org.pentaho.di.trans.steps.stepmeta |
---|
Methods in org.pentaho.di.trans.steps.stepmeta that throw KettleException | |
---|---|
boolean |
StepMetastructure.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
StepMetastructureMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
StepMetastructureMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.stepsmetrics |
---|
Methods in org.pentaho.di.trans.steps.stepsmetrics that throw KettleException | |
---|---|
boolean |
StepsMetrics.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
StepsMetricsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
StepsMetricsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.streamlookup |
---|
Methods in org.pentaho.di.trans.steps.streamlookup that throw KettleException | |
---|---|
boolean |
StreamLookup.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
StreamLookupMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
StreamLookupMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.stringcut |
---|
Methods in org.pentaho.di.trans.steps.stringcut that throw KettleException | |
---|---|
boolean |
StringCut.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
StringCutMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
StringCutMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
StringCutTest.testStringCut1()
This is a test for PDI-8042, where the first row of meta has no output field but the second does. |
void |
StringCutTest.testStringCut2()
This is a generic test using two input fields and different cuts for each |
Constructors in org.pentaho.di.trans.steps.stringcut that throw KettleException | |
---|---|
StringCutTest()
|
Uses of KettleException in org.pentaho.di.trans.steps.stringoperations |
---|
Methods in org.pentaho.di.trans.steps.stringoperations that throw KettleException | |
---|---|
boolean |
StringOperations.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
StringOperationsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
StringOperationsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.switchcase |
---|
Methods in org.pentaho.di.trans.steps.switchcase that throw KettleException | |
---|---|
boolean |
SwitchCase.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SwitchCaseMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SwitchCaseMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.symmetriccrypto.secretkeygenerator |
---|
Methods in org.pentaho.di.trans.steps.symmetriccrypto.secretkeygenerator that throw KettleException | |
---|---|
boolean |
SecretKeyGenerator.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SecretKeyGeneratorMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SecretKeyGeneratorMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.symmetriccrypto.symmetricalgorithm |
---|
Subclasses of KettleException in org.pentaho.di.trans.steps.symmetriccrypto.symmetricalgorithm | |
---|---|
class |
CryptoException
Symmetric algorithm |
class |
CryptoKeyException
Symmetric algorithm |
Uses of KettleException in org.pentaho.di.trans.steps.symmetriccrypto.symmetriccryptotrans |
---|
Methods in org.pentaho.di.trans.steps.symmetriccrypto.symmetriccryptotrans that throw KettleException | |
---|---|
boolean |
SymmetricCryptoTrans.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SymmetricCryptoTransMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SymmetricCryptoTransMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.synchronizeaftermerge |
---|
Methods in org.pentaho.di.trans.steps.synchronizeaftermerge that throw KettleException | |
---|---|
RowMetaInterface |
SynchronizeAfterMergeMeta.getRequiredFields(VariableSpace space)
|
boolean |
SynchronizeAfterMerge.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SynchronizeAfterMergeMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SynchronizeAfterMergeMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.syslog |
---|
Methods in org.pentaho.di.trans.steps.syslog that throw KettleException | |
---|---|
boolean |
SyslogMessage.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SyslogMessageMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SyslogMessageMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.systemdata |
---|
Methods in org.pentaho.di.trans.steps.systemdata that throw KettleException | |
---|---|
boolean |
SystemData.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
SystemDataMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
SystemDataMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.tableagilemart |
---|
Methods in org.pentaho.di.trans.steps.tableagilemart that throw KettleException | |
---|---|
boolean |
TableAgileMart.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
Uses of KettleException in org.pentaho.di.trans.steps.tableexists |
---|
Methods in org.pentaho.di.trans.steps.tableexists that throw KettleException | |
---|---|
boolean |
TableExists.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
TableExistsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
TableExistsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.tableinput |
---|
Methods in org.pentaho.di.trans.steps.tableinput that throw KettleException | |
---|---|
boolean |
TableInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
TableInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
TableInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
TableInput.stopRunning(StepMetaInterface smi,
StepDataInterface sdi)
Stop the running query |
Uses of KettleException in org.pentaho.di.trans.steps.tableoutput |
---|
Methods in org.pentaho.di.trans.steps.tableoutput that throw KettleException | |
---|---|
RowMetaInterface |
TableOutputMeta.getRequiredFields(VariableSpace space)
|
boolean |
TableOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
TableOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
TableOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.terafast |
---|
Methods in org.pentaho.di.trans.steps.terafast that throw KettleException | |
---|---|
Database |
TeraFastMeta.connectToDatabase()
|
String |
TeraFast.createCommandLine()
Create the command line for a fastload process depending on the meta information supplied. |
void |
TeraFast.execute()
Execute fastload. |
String |
TeraFastMeta.getQuotedSchemaTableName(VariableSpace space)
|
RowMetaInterface |
TeraFastMeta.getRequiredFields(VariableSpace space)
The natural way of data flow in a transformation is source-to-target. |
boolean |
TeraFast.processRow(StepMetaInterface smi,
StepDataInterface sdi)
Perform the equivalent of processing one row. |
Uses of KettleException in org.pentaho.di.trans.steps.textfileinput |
---|
Methods in org.pentaho.di.trans.steps.textfileinput that throw KettleException | |
---|---|
static Object[] |
TextFileInput.convertLineToRow(LogChannelInterface log,
TextFileLine textFileLine,
InputFileMetaInterface info,
Object[] passThruFields,
int nrPassThruFields,
RowMetaInterface outputRowMeta,
RowMetaInterface convertRowMeta,
String fname,
long rowNr,
String delimiter,
FileErrorHandler errorHandler,
boolean addShortFilename,
boolean addExtension,
boolean addPath,
boolean addSize,
boolean addIsHidden,
boolean addLastModificationDate,
boolean addUri,
boolean addRootUri,
String shortFilename,
String path,
boolean hidden,
Date modificationDateTime,
String uri,
String rooturi,
String extension,
long size)
|
static Object[] |
TextFileInput.convertLineToRow(LogChannelInterface log,
TextFileLine textFileLine,
InputFileMetaInterface info,
RowMetaInterface outputRowMeta,
RowMetaInterface convertRowMeta,
String fname,
long rowNr,
String delimiter,
FileErrorHandler errorHandler,
boolean addShortFilename,
boolean addExtension,
boolean addPath,
boolean addSize,
boolean addIsHidden,
boolean addLastModificationDate,
boolean addUri,
boolean addRootUri,
String shortFilename,
String path,
boolean hidden,
Date modificationDateTime,
String uri,
String rooturi,
String extension,
long size)
Deprecated. Use #convertLineToRow(TextFileLine,InputFileMetaInterface,Object[],int,RowMetaInterface,RowMetaInterface,String,long, FileErrorHandler) instead |
static String[] |
TextFileInput.convertLineToStrings(LogChannelInterface log,
String line,
InputFileMetaInterface inf,
String delimiter)
|
String |
TextFileInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
static String[] |
TextFileInput.guessStringsFromLine(LogChannelInterface log,
String line,
TextFileInputMeta inf,
String delimiter)
|
boolean |
TextFileInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
TextFileInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
TextFileInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.textfileoutput |
---|
Methods in org.pentaho.di.trans.steps.textfileoutput that throw KettleException | |
---|---|
String |
TextFileOutputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
void |
TextFileOutput.openNewFile(String baseFilename)
|
boolean |
TextFileOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
TextFileOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
TextFileOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.uniquerows |
---|
Methods in org.pentaho.di.trans.steps.uniquerows that throw KettleException | |
---|---|
void |
UniqueRows.batchComplete()
|
boolean |
UniqueRows.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
UniqueRowsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
UniqueRowsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.uniquerowsbyhashset |
---|
Methods in org.pentaho.di.trans.steps.uniquerowsbyhashset that throw KettleException | |
---|---|
boolean |
UniqueRowsByHashSet.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
UniqueRowsByHashSetMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
UniqueRowsByHashSetMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.univariatestats |
---|
Methods in org.pentaho.di.trans.steps.univariatestats that throw KettleException | |
---|---|
boolean |
UnivariateStats.processRow(StepMetaInterface smi,
StepDataInterface sdi)
Process an incoming row of data. |
void |
UnivariateStatsMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
UnivariateStatsMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
Save this step's meta data to a repository |
void |
UnivariateStatsMetaFunction.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step,
int nr)
Save this UnivariateStatsMetaFunction to a repository |
Constructors in org.pentaho.di.trans.steps.univariatestats that throw KettleException | |
---|---|
UnivariateStatsMetaFunction(Repository rep,
ObjectId id_step,
int nr)
Construct using data stored in repository |
Uses of KettleException in org.pentaho.di.trans.steps.update |
---|
Methods in org.pentaho.di.trans.steps.update that throw KettleException | |
---|---|
boolean |
Update.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
UpdateMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
UpdateMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.userdefinedjavaclass |
---|
Methods in org.pentaho.di.trans.steps.userdefinedjavaclass that throw KettleException | |
---|---|
RowSet |
TransformClassBase.findInfoRowSet(String tag)
|
RowSet |
TransformClassBase.findTargetRowSet(String tag)
|
Object[] |
UserDefinedJavaClass.getRow()
|
Object[] |
TransformClassBase.getRow()
|
Object[] |
UserDefinedJavaClass.getRowImpl()
|
boolean |
UserDefinedJavaClass.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
abstract boolean |
TransformClassBase.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
UserDefinedJavaClassMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
UserDefinedJavaClassMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
UserDefinedJavaClass.stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
|
void |
TransformClassBase.stopRunning(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
|
void |
UserDefinedJavaClass.stopRunningImpl(StepMetaInterface stepMetaInterface,
StepDataInterface stepDataInterface)
|
Uses of KettleException in org.pentaho.di.trans.steps.validator |
---|
Subclasses of KettleException in org.pentaho.di.trans.steps.validator | |
---|---|
class |
KettleValidatorException
|
Methods in org.pentaho.di.trans.steps.validator that throw KettleException | |
---|---|
boolean |
Validator.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ValidatorMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ValidatorMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
Validation.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step,
int i)
|
Constructors in org.pentaho.di.trans.steps.validator that throw KettleException | |
---|---|
Validation(Repository rep,
ObjectId id_step,
int i)
|
Uses of KettleException in org.pentaho.di.trans.steps.valuemapper |
---|
Methods in org.pentaho.di.trans.steps.valuemapper that throw KettleException | |
---|---|
boolean |
ValueMapper.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
ValueMapperMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
ValueMapperMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.webserviceavailable |
---|
Methods in org.pentaho.di.trans.steps.webserviceavailable that throw KettleException | |
---|---|
boolean |
WebServiceAvailable.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
WebServiceAvailableMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
WebServiceAvailableMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.webservices |
---|
Methods in org.pentaho.di.trans.steps.webservices that throw KettleException | |
---|---|
boolean |
WebService.processRow(StepMetaInterface metaInterface,
StepDataInterface dataInterface)
|
void |
WebServiceMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
WebServiceMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Constructors in org.pentaho.di.trans.steps.webservices that throw KettleException | |
---|---|
WebServiceMeta(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Hashtable<String,Counter> counters)
|
Uses of KettleException in org.pentaho.di.trans.steps.writetolog |
---|
Methods in org.pentaho.di.trans.steps.writetolog that throw KettleException | |
---|---|
boolean |
WriteToLog.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
WriteToLogMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
WriteToLogMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.xbaseinput |
---|
Methods in org.pentaho.di.trans.steps.xbaseinput that throw KettleException | |
---|---|
String |
XBaseInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
RowMetaInterface |
XBase.getFields()
|
Object[] |
XBase.getRow(Object[] r)
|
Object[] |
XBase.getRow(RowMetaInterface fields)
|
void |
XBase.open()
|
boolean |
XBaseInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
XBaseInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
XBaseInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.xmlinput |
---|
Methods in org.pentaho.di.trans.steps.xmlinput that throw KettleException | |
---|---|
String |
XMLInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
XMLInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
XMLInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
XMLInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
XMLInputField.setFieldPosition(String encoded)
|
Uses of KettleException in org.pentaho.di.trans.steps.xmlinputsax |
---|
Methods in org.pentaho.di.trans.steps.xmlinputsax that throw KettleException | |
---|---|
String |
XMLInputSaxMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
XMLInputSax.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
XMLInputSaxMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
XMLInputSaxMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
void |
XMLInputSaxField.setFieldPosition(String encoded)
|
Uses of KettleException in org.pentaho.di.trans.steps.xmlinputstream |
---|
Methods in org.pentaho.di.trans.steps.xmlinputstream that throw KettleException | |
---|---|
boolean |
XMLInputStream.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
XMLInputStreamMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
XMLInputStreamMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.xmljoin |
---|
Methods in org.pentaho.di.trans.steps.xmljoin that throw KettleException | |
---|---|
boolean |
XMLJoin.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
XMLJoinMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
XMLJoinMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.xmloutput |
---|
Methods in org.pentaho.di.trans.steps.xmloutput that throw KettleException | |
---|---|
String |
XMLOutputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
RowMetaInterface |
XMLOutputMeta.getRequiredFields(VariableSpace space)
|
boolean |
XMLOutput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
XMLOutputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
XMLOutputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.xsdvalidator |
---|
Methods in org.pentaho.di.trans.steps.xsdvalidator that throw KettleException | |
---|---|
String |
XsdValidatorMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
boolean |
XsdValidator.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
XsdValidatorMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
XsdValidatorMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.xslt |
---|
Methods in org.pentaho.di.trans.steps.xslt that throw KettleException | |
---|---|
boolean |
Xslt.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
XsltMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
XsltMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.trans.steps.yamlinput |
---|
Methods in org.pentaho.di.trans.steps.yamlinput that throw KettleException | |
---|---|
String |
YamlInputMeta.exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface resourceNamingInterface,
Repository repository)
Since the exported transformation that runs this will reside in a ZIP file, we can't reference files relatively. |
Object[] |
YamlReader.getRow(RowMetaInterface rowMeta)
|
boolean |
YamlInput.processRow(StepMetaInterface smi,
StepDataInterface sdi)
|
void |
YamlInputMeta.readRep(Repository rep,
ObjectId id_step,
List<DatabaseMeta> databases,
Map<String,Counter> counters)
|
void |
YamlInputMeta.saveRep(Repository rep,
ObjectId id_transformation,
ObjectId id_step)
|
Uses of KettleException in org.pentaho.di.ui.core.dialog |
---|
Constructors in org.pentaho.di.ui.core.dialog that throw KettleException | |
---|---|
Splash(Display display)
|
Uses of KettleException in org.pentaho.di.ui.i18n |
---|
Methods in org.pentaho.di.ui.i18n that throw KettleException | |
---|---|
void |
LocaleStore.read(List<String> directories)
Read all the messages stores from the specified locale from all the specified packages |
void |
MessagesStore.read(List<String> directories)
|
void |
TranslationsStore.read(List<String> directories)
Read all the translated messages for all the specified locale and all the specified locale |
void |
MessagesStore.write()
|
void |
MessagesStore.write(String filename)
|
Uses of KettleException in org.pentaho.di.ui.imp |
---|
Methods in org.pentaho.di.ui.imp that throw KettleException | |
---|---|
ImportRuleCompositeInterface |
ImportRulesDialog.getImportRuleComposite(ImportRuleInterface rule)
|
Uses of KettleException in org.pentaho.di.ui.repository |
---|
Methods in org.pentaho.di.ui.repository that throw KettleException | |
---|---|
void |
RepositoriesHelper.loginToRepository()
|
Uses of KettleException in org.pentaho.di.ui.repository.repositoryexplorer.model |
---|
Methods in org.pentaho.di.ui.repository.repositoryexplorer.model that throw KettleException | |
---|---|
UIRepositoryObjects |
UIRepositoryDirectory.getRepositoryObjects()
|
IUser |
UISecurityUser.getUserInfo()
|
void |
UIJob.move(UIRepositoryDirectory newParentDir)
|
void |
UITransformation.move(UIRepositoryDirectory newParentDir)
|
Uses of KettleException in org.pentaho.di.ui.spoon |
---|
Methods in org.pentaho.di.ui.spoon that throw KettleException | |
---|---|
void |
SpoonPerspectiveManager.activatePerspective(Class<? extends SpoonPerspective> clazz)
Activates the given instance of the class literal passed in. |
boolean |
TabItemInterface.applyChanges()
|
void |
Spoon.clearSharedObjectCache()
|
static void |
Spoon.main(String[] a)
This is the main procedure for Spoon. |
void |
Spoon.monitorClusterSchema()
|
boolean |
Spoon.quitFile(boolean canCancel)
|
boolean |
Spoon.saveFileAs()
|
boolean |
Spoon.saveFileAs(EngineMetaInterface meta)
|
boolean |
Spoon.saveJobRepository(JobMeta jobMeta)
|
boolean |
Spoon.saveJobRepository(JobMeta jobMeta,
boolean ask_name)
|
boolean |
Spoon.saveToFile(EngineMetaInterface meta)
|
boolean |
Spoon.saveToRepository(EngineMetaInterface meta)
|
boolean |
Spoon.saveToRepository(EngineMetaInterface meta,
boolean ask_name)
|
int |
AbstractGraph.showChangedWarning()
|
int |
TabItemInterface.showChangedWarning()
|
int |
AbstractGraph.showChangedWarning(String fileName)
Show the ChangedWarning and return the users selection |
void |
Spoon.start(CommandLineOption[] options)
|
Uses of KettleException in org.pentaho.di.ui.spoon.delegates |
---|
Methods in org.pentaho.di.ui.spoon.delegates that throw KettleException | |
---|---|
void |
SpoonSlaveDelegate.delSlaveServer(HasSlaveServersInterface hasSlaveServersInterface,
SlaveServer slaveServer)
|
void |
SpoonJobDelegate.executeJob(JobMeta jobMeta,
boolean local,
boolean remote,
Date replayDate,
boolean safe,
String startCopyName,
int startCopyNr)
|
void |
SpoonTransformationDelegate.executeTransformation(TransMeta transMeta,
boolean local,
boolean remote,
boolean cluster,
boolean preview,
boolean debug,
Date replayDate,
boolean safe)
|
StepDialogInterface |
SpoonStepsDelegate.getPartitionerDialog(StepMeta stepMeta,
StepPartitioningMeta partitioningMeta,
TransMeta transMeta)
|
StepDialogInterface |
SpoonStepsDelegate.getStepEntryDialog(StepMetaInterface stepMeta,
TransMeta transMeta,
String stepName)
|
boolean |
SpoonTabsDelegate.tabClose(org.pentaho.xul.swt.tab.TabItem item)
|
Uses of KettleException in org.pentaho.di.ui.spoon.job |
---|
Methods in org.pentaho.di.ui.spoon.job that throw KettleException | |
---|---|
boolean |
JobGraph.applyChanges()
|
void |
JobGraph.duplicateEntry()
|
void |
JobGraph.saveFile()
|
void |
JobGraph.saveFileAs()
|
int |
JobGraph.showChangedWarning()
|
void |
JobGraph.startJob(JobExecutionConfiguration executionConfiguration)
|
Uses of KettleException in org.pentaho.di.ui.spoon.trans |
---|
Methods in org.pentaho.di.ui.spoon.trans that throw KettleException | |
---|---|
boolean |
TransGraph.applyChanges()
|
void |
TransGraph.handleTransMetaChanges(TransMeta transMeta)
|
void |
TransGraph.saveFile()
|
void |
TransGraph.saveFileAs()
|
int |
TransGraph.showChangedWarning()
|
void |
TransGraph.start(TransExecutionConfiguration executionConfiguration)
|
Uses of KettleException in org.pentaho.di.ui.trans.step |
---|
Methods in org.pentaho.di.ui.trans.step that throw KettleException | |
---|---|
static void |
BaseStepDialog.generateFieldMapping(Shell shell,
RowMetaInterface sourceFields,
RowMetaInterface targetFields,
List<SourceToTargetMapping> fieldMapping)
Create a new field mapping between source and target steps. |
static void |
BaseStepXulDialog.generateFieldMapping(Shell shell,
RowMetaInterface sourceFields,
RowMetaInterface targetFields,
List<SourceToTargetMapping> fieldMapping)
Create a new field mapping between source and target steps. |
Uses of KettleException in org.pentaho.di.ui.trans.steps.ldapoutput |
---|
Methods in org.pentaho.di.ui.trans.steps.ldapoutput that throw KettleException | |
---|---|
RowMetaInterface |
LDAPOutputDialog.getLDAPFields()
|
Uses of KettleException in org.pentaho.di.ui.trans.steps.mapping |
---|
Methods in org.pentaho.di.ui.trans.steps.mapping that throw KettleException | |
---|---|
RowMetaInterface |
MappingDialog.getFieldsFromStep(String stepname,
boolean getTransformationStep,
boolean mappingInput)
|
Uses of KettleException in org.pentaho.di.www |
---|
Methods in org.pentaho.di.www that throw KettleException | |
---|---|
SlaveSequence |
TransformationMap.createSlaveSequence(String name)
|
static SlaveServerJobStatus |
SlaveServerJobStatus.fromXML(String xml)
|
static SlaveServerStatus |
SlaveServerStatus.fromXML(String xml)
|
long |
SlaveSequence.getNextValue(LoggingObjectInterface log,
long incrementValue)
|
String |
SlaveServerJobStatus.getXML()
|
String |
SlaveServerTransStatus.getXML()
|
String |
SlaveServerStatus.getXML()
|
void |
SlaveServerConfig.readAutoSequences()
|
Constructors in org.pentaho.di.www that throw KettleException | |
---|---|
SlaveServerJobStatus(Node jobStatusNode)
|
|
SlaveServerStatus(Node statusNode)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |