本文整理了Java中org.pentaho.di.repository.Repository.saveJobEntryAttribute
方法的一些代码示例,展示了Repository.saveJobEntryAttribute
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Repository.saveJobEntryAttribute
方法的具体详情如下:
包路径:org.pentaho.di.repository.Repository
类名称:Repository
方法名:saveJobEntryAttribute
暂无
代码示例来源:origin: pentaho/pentaho-kettle
protected void saveSourceRep( Repository rep, ObjectId id_job, ObjectId id_jobentry, int i, String value )
throws KettleException {
String namedCluster = configurationMappings.get( value );
rep.saveJobEntryAttribute( id_job, getObjectId(), i, SOURCE_FILE_FOLDER, value );
rep.saveJobEntryAttribute( id_job, id_jobentry, i, SOURCE_CONFIGURATION_NAME, namedCluster );
}
代码示例来源:origin: pentaho/pentaho-kettle
protected void saveDestinationRep( Repository rep, ObjectId id_job, ObjectId id_jobentry, int i, String value )
throws KettleException {
String namedCluster = configurationMappings.get( value );
rep.saveJobEntryAttribute( id_job, getObjectId(), i, DESTINATION_FILE_FOLDER, value );
rep.saveJobEntryAttribute( id_job, id_jobentry, i, DESTINATION_CONFIGURATION_NAME, namedCluster );
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "server", server );
rep.saveJobEntryAttribute( id_job, getObjectId(), "port", port );
rep.saveJobEntryAttribute( id_job, getObjectId(), "message_variable", messageVariableName );
rep.saveJobEntryAttribute( id_job, getObjectId(), "type_variable", messageTypeVariableName );
rep.saveJobEntryAttribute( id_job, getObjectId(), "version_variable", versionVariableName );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( "Unable to save job entry of type 'ftp' to the repository for id_job=" + id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "filename", filename );
rep.saveJobEntryAttribute( id_job, getObjectId(), "createParentFolder", createParentFolder );
rep.saveJobEntryAttribute( id_job, getObjectId(), "appendFile", appendFile );
rep.saveJobEntryAttribute( id_job, getObjectId(), "content", content );
rep.saveJobEntryAttribute( id_job, getObjectId(), "encoding", encoding );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( "Unable to save job entry of type 'create file' to the repository for id_job="
+ id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "xmlfilename", xmlfilename );
rep.saveJobEntryAttribute( id_job, getObjectId(), "dtdfilename", dtdfilename );
rep.saveJobEntryAttribute( id_job, getObjectId(), "dtdintern", dtdintern );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( "Unable to save job entry of type 'DTDvalidator' to the repository for id_job="
+ id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "filename", filename );
rep.saveJobEntryAttribute( id_job, getObjectId(), "fail_if_file_exists", failIfFileExists );
rep.saveJobEntryAttribute( id_job, getObjectId(), "add_filename_result", addfilenameresult );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( "Unable to save job entry of type 'create file' to the repository for id_job="
+ id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "hostname", hostname );
rep.saveJobEntryAttribute( id_job, getObjectId(), "port", port );
rep.saveJobEntryAttribute( id_job, getObjectId(), "timeout", timeout );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( "Unable to save job entry of type 'Telnet' to the repository for id_job="
+ id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "server", server );
rep.saveJobEntryAttribute( id_job, getObjectId(), "port", port );
rep.saveJobEntryAttribute( id_job, getObjectId(), "variable", variableName );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( "Unable to save job entry of type 'ftp' to the repository for id_job=" + id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "smtpCheck", smtpCheck );
rep.saveJobEntryAttribute( id_job, getObjectId(), "timeout", timeout );
rep.saveJobEntryAttribute( id_job, getObjectId(), "defaultSMTP", defaultSMTP );
rep.saveJobEntryAttribute( id_job, getObjectId(), "emailSender", emailSender );
rep.saveJobEntryAttribute( id_job, getObjectId(), "emailAddress", emailAddress );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( BaseMessages.getString( PKG, "JobEntryMailValidator.Meta.UnableToSaveToRep" )
+ id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "bodymessage", bodymessage );
rep.saveJobEntryAttribute( id_job, getObjectId(), "titremessage", titremessage );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( "Unable to save job entry of type 'Msgbox Info' to the repository for id_job="
+ id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "xmlfilename", xmlfilename );
rep.saveJobEntryAttribute( id_job, getObjectId(), "xsdfilename", xsdfilename );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( "Unable to save job entry of type 'xsdvalidator' to the repository for id_job="
+ id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "foldername", foldername );
rep.saveJobEntryAttribute( id_job, getObjectId(), "fail_of_folder_exists", failOfFolderExists );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( "Unable to save job entry of type 'create Folder' to the repository for id_job="
+ id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "url", url );
rep.saveJobEntryAttribute( id_job, getObjectId(), "connectTimeOut", connectTimeOut );
rep.saveJobEntryAttribute( id_job, getObjectId(), "readTimeOut", readTimeOut );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( BaseMessages.getString(
PKG, "JobEntryWebServiceAvailable.ERROR_0003_Cannot_Save_Job_Entry", "" + id_job ), dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
@Override
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "logmessage", logmessage );
rep.saveJobEntryAttribute( id_job, getObjectId(), "loglevel", ( entryLogLevel != null ? entryLogLevel
.getCode() : "" ) );
rep.saveJobEntryAttribute( id_job, getObjectId(), "logsubject", logsubject );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( BaseMessages.getString( PKG, "WriteToLog.Error.UnableToSaveToRepository.Label" )
+ id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "filename", filename );
rep.saveJobEntryAttribute( id_job, getObjectId(), "fail_if_file_not_exists", failIfFileNotExists );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( BaseMessages.getString(
PKG, "JobEntryDeleteFile.ERROR_0003_Unable_To_Save_Job_To_Repository", id_job ), dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
@Override
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "maximumTimeout", maximumTimeout );
rep.saveJobEntryAttribute( id_job, getObjectId(), "scaletime", scaleTime );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException(
BaseMessages.getString( PKG, "JobEntryDelay.UnableToSaveToRepo.Label" ) + id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "script", script );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( BaseMessages.getString( PKG, "JobEntryEval.UnableToSaveToRepo", String
.valueOf( id_job ) ), dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveDatabaseMetaJobEntryAttribute( id_job, getObjectId(), "connection", "id_database", databaseMeta );
rep.saveJobEntryAttribute( id_job, getObjectId(), "cubeName", this.getCubeName() );
for ( int i = 0; i < this.dimensionNames.size(); i++ ) {
rep.saveJobEntryAttribute( id_job, getObjectId(), i, "dimensionname", this.dimensionNames.get( i ) );
}
} catch ( KettleDatabaseException dbe ) {
throw new KettleException(
"unable to save jobentry of type 'file exists' to the repository for id_job=" + id_job, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "message", messageAbort );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( BaseMessages.getString( PKG, "JobEntryAbort.UnableToSaveToRepo.Label", String
.valueOf( id_job ) ), dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void saveRep( Repository rep, IMetaStore metaStore, ObjectId id_job ) throws KettleException {
try {
rep.saveJobEntryAttribute( id_job, getObjectId(), "filename", filename );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( BaseMessages.getString(
PKG, "JobEntryFileExists.ERROR_0003_Cannot_Save_Job_Entry", id_job ), dbe );
}
}
内容来源于网络,如有侵权,请联系作者删除!