本文整理了Java中org.pentaho.di.repository.Repository.getJobEntryAttributeBoolean
方法的一些代码示例,展示了Repository.getJobEntryAttributeBoolean
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Repository.getJobEntryAttributeBoolean
方法的具体详情如下:
包路径:org.pentaho.di.repository.Repository
类名称:Repository
方法名:getJobEntryAttributeBoolean
暂无
代码示例来源:origin: pentaho/pentaho-kettle
@Override
public boolean getJobEntryAttributeBoolean( ObjectId objectId, String s ) throws KettleException {
return getDelegate().getJobEntryAttributeBoolean( objectId, s );
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
failIfFileExists = rep.getJobEntryAttributeBoolean( id_jobentry, "fail_if_file_exists" );
addfilenameresult = rep.getJobEntryAttributeBoolean( id_jobentry, "add_filename_result" );
} catch ( KettleException dbe ) {
throw new KettleException(
"Unable to load job entry of type 'create file' from the repository for id_jobentry=" + id_jobentry, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
@Override
public boolean getJobEntryAttributeBoolean( ObjectId objectId, int i, String s ) throws KettleException {
return getDelegate().getJobEntryAttributeBoolean( objectId, i, s );
}
代码示例来源:origin: pentaho/pentaho-kettle
@Override
public boolean getJobEntryAttributeBoolean( ObjectId objectId, String s, boolean b ) throws KettleException {
return getDelegate().getJobEntryAttributeBoolean( objectId, s, b );
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
foldername = rep.getJobEntryAttributeString( id_jobentry, "foldername" );
includeSubfolders = rep.getJobEntryAttributeBoolean( id_jobentry, "include_subfolders" );
specifywildcard = rep.getJobEntryAttributeBoolean( id_jobentry, "specify_wildcard" );
wildcard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
} catch ( KettleException dbe ) {
throw new KettleException(
"Unable to load job entry of type 'create Folder' from the repository for id_jobentry=" + id_jobentry,
dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
maximumTimeout = rep.getJobEntryAttributeString( id_jobentry, "maximum_timeout" );
checkCycleTime = rep.getJobEntryAttributeString( id_jobentry, "check_cycle_time" );
successOnTimeout = rep.getJobEntryAttributeBoolean( id_jobentry, "success_on_timeout" );
fileSizeCheck = rep.getJobEntryAttributeBoolean( id_jobentry, "file_size_check" );
addFilenameToResult = rep.getJobEntryAttributeBoolean( id_jobentry, "add_filename_result" );
} catch ( KettleException dbe ) {
throw new KettleException(
"Unable to load job entry of type 'wait for file' from the repository for id_jobentry=" + id_jobentry,
dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
isspecificrep = rep.getJobEntryAttributeBoolean( id_jobentry, "isspecificrep" );
repname = rep.getJobEntryAttributeString( id_jobentry, "repname" );
isspecificuser = rep.getJobEntryAttributeBoolean( id_jobentry, "isspecificuser" );
username = rep.getJobEntryAttributeString( id_jobentry, "username" );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( BaseMessages.getString(
PKG, "JobEntryConnectedToRepository.Meta.UnableToLoadFromRep" )
+ id_jobentry, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
foldername = rep.getJobEntryAttributeString( id_jobentry, "foldername" );
failOfFolderExists = rep.getJobEntryAttributeBoolean( id_jobentry, "fail_of_folder_exists" );
} catch ( KettleException dbe ) {
throw new KettleException(
"Unable to load job entry of type 'create Folder' from the repository for id_jobentry=" + id_jobentry,
dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
createParentFolder = rep.getJobEntryAttributeBoolean( id_jobentry, "createParentFolder" );
appendFile = rep.getJobEntryAttributeBoolean( id_jobentry, "appendFile" );
content = rep.getJobEntryAttributeString( id_jobentry, "content" );
encoding = rep.getJobEntryAttributeString( id_jobentry, "encoding" );
} catch ( KettleException dbe ) {
throw new KettleException(
"Unable to load job entry of type 'create file' from the repository for id_jobentry=" + id_jobentry, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
includesubfolders = rep.getJobEntryAttributeBoolean( id_jobentry, "include_subfolders" );
comparefilecontent = rep.getJobEntryAttributeBoolean( id_jobentry, "compare_filecontent" );
comparefilesize = rep.getJobEntryAttributeBoolean( id_jobentry, "compare_filesize" );
compareonly = rep.getJobEntryAttributeString( id_jobentry, "compareonly" );
wildcard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
filename1 = rep.getJobEntryAttributeString( id_jobentry, "filename1" );
filename2 = rep.getJobEntryAttributeString( id_jobentry, "filename2" );
} catch ( KettleException dbe ) {
throw new KettleException( BaseMessages.getString( PKG, "JobFoldersCompare.Meta.UnableLoadRep", ""
+ id_jobentry, dbe.getMessage() ) );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
failIfFileNotExists = rep.getJobEntryAttributeBoolean( id_jobentry, "fail_if_file_not_exists" );
} catch ( KettleException dbe ) {
throw new KettleException( BaseMessages.getString(
PKG, "JobEntryDeleteFile.ERROR_0002_Unable_To_Load_From_Repository", id_jobentry ), dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
xmlfilename = rep.getJobEntryAttributeString( id_jobentry, "xmlfilename" );
dtdfilename = rep.getJobEntryAttributeString( id_jobentry, "dtdfilename" );
dtdintern = rep.getJobEntryAttributeBoolean( id_jobentry, "dtdintern" );
} catch ( KettleException dbe ) {
throw new KettleException( "Unable to load job entry of type 'DTDvalidator' from the repository for id_jobentry="
+ id_jobentry, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
argFromPrevious = rep.getJobEntryAttributeBoolean( id_jobentry, "arg_from_previous" );
includeSubfolders = rep.getJobEntryAttributeBoolean( id_jobentry, "include_subfolders" );
int numberOfArgs = rep.countNrJobEntryAttributes( id_jobentry, "name" );
allocate( numberOfArgs );
for ( int i = 0; i < numberOfArgs; i++ ) {
arguments[i] = rep.getJobEntryAttributeString( id_jobentry, i, "name" );
filemasks[i] = rep.getJobEntryAttributeString( id_jobentry, i, "filemask" );
}
} catch ( KettleException dbe ) {
throw new KettleException( BaseMessages.getString( PKG, "JobEntryDeleteFiles.UnableToLoadFromRepo", String
.valueOf( id_jobentry ) ), dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
port = rep.getJobEntryAttributeString( id_jobentry, "port" );
serverName = rep.getJobEntryAttributeString( id_jobentry, "servername" );
facility = rep.getJobEntryAttributeString( id_jobentry, "facility" );
priority = rep.getJobEntryAttributeString( id_jobentry, "priority" );
message = rep.getJobEntryAttributeString( id_jobentry, "message" );
datePattern = rep.getJobEntryAttributeString( id_jobentry, "datePattern" );
addTimestamp = rep.getJobEntryAttributeBoolean( id_jobentry, "addTimestamp" );
addHostname = rep.getJobEntryAttributeBoolean( id_jobentry, "addHostname" );
} catch ( KettleException dbe ) {
throw new KettleException( "Unable to load job entry of type 'Syslog' from the repository for id_jobentry="
+ id_jobentry, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
filename1 = rep.getJobEntryAttributeString( id_jobentry, "filename1" );
filename2 = rep.getJobEntryAttributeString( id_jobentry, "filename2" );
addFilenameToResult = rep.getJobEntryAttributeBoolean( id_jobentry, "add_filename_result" );
} catch ( KettleException dbe ) {
throw new KettleException( BaseMessages.getString(
PKG, "JobEntryFileCompare.ERROR_0002_Unable_To_Load_Job_From_Repository", id_jobentry ), dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
try {
messagefieldname = rep.getStepAttributeString( id_step, "messagefieldname" );
serverName = rep.getJobEntryAttributeString( id_step, "servername" );
port = rep.getJobEntryAttributeString( id_step, "port" );
facility = rep.getJobEntryAttributeString( id_step, "facility" );
priority = rep.getJobEntryAttributeString( id_step, "priority" );
datePattern = rep.getJobEntryAttributeString( id_step, "datePattern" );
addTimestamp = rep.getJobEntryAttributeBoolean( id_step, "addTimestamp" );
addHostName = rep.getJobEntryAttributeBoolean( id_step, "addHostName" );
} catch ( Exception e ) {
throw new KettleException( BaseMessages.getString(
PKG, "SyslogMessageMeta.Exception.UnexpectedErrorReadingStepInfo" ), e );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
gpglocation = rep.getJobEntryAttributeString( id_jobentry, "gpglocation" );
filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
detachedfilename = rep.getJobEntryAttributeString( id_jobentry, "detachedfilename" );
useDetachedSignature = rep.getJobEntryAttributeBoolean( id_jobentry, "useDetachedSignature" );
} catch ( KettleException dbe ) {
throw new KettleException( BaseMessages.getString(
PKG, "JobEntryPGPVerify.ERROR_0002_Cannot_Load_Job_From_Repository", id_jobentry ), dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
foldername = rep.getJobEntryAttributeString( id_jobentry, "foldername" );
specifywildcard = rep.getJobEntryAttributeBoolean( id_jobentry, "specify_wildcard" );
wildcard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
wildcardexclude = rep.getJobEntryAttributeString( id_jobentry, "wildcardexclude" );
} catch ( KettleException dbe ) {
throw new KettleXMLException( BaseMessages.getString(
PKG, "JobEntryDeleteResultFilenames.CanNotLoadFromRep", "" + id_jobentry, dbe.getMessage() ) );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
smtpCheck = rep.getJobEntryAttributeBoolean( id_jobentry, "smtpCheck" );
timeout = rep.getJobEntryAttributeString( id_jobentry, "timeout" );
defaultSMTP = rep.getJobEntryAttributeString( id_jobentry, "defaultSMTP" );
emailSender = rep.getJobEntryAttributeString( id_jobentry, "emailSender" );
emailAddress = rep.getJobEntryAttributeString( id_jobentry, "emailAddress" );
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( BaseMessages.getString( PKG, "JobEntryMailValidator.Meta.UnableToLoadFromRep" )
+ id_jobentry, dbe );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
List<SlaveServer> slaveServers ) throws KettleException {
try {
connection = rep.loadDatabaseMetaFromJobEntryAttribute( id_jobentry, "connection", "id_database", databases );
this.argFromPrevious = rep.getJobEntryAttributeBoolean( id_jobentry, "arg_from_previous" );
// How many arguments?
int argnr = rep.countNrJobEntryAttributes( id_jobentry, "name" );
allocate( argnr );
// Read them all...
for ( int a = 0; a < argnr; a++ ) {
this.arguments[a] = rep.getJobEntryAttributeString( id_jobentry, a, "name" );
this.schemaname[a] = rep.getJobEntryAttributeString( id_jobentry, a, "schemaname" );
}
} catch ( KettleDatabaseException dbe ) {
throw new KettleException( BaseMessages.getString( PKG, "JobEntryTruncateTables.UnableLoadRep", ""
+ id_jobentry ), dbe );
}
}
内容来源于网络,如有侵权,请联系作者删除!