org.pentaho.di.repository.Repository.getJobEntryAttributeBoolean()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(13.7k)|赞(0)|评价(0)|浏览(128)

本文整理了Java中org.pentaho.di.repository.Repository.getJobEntryAttributeBoolean方法的一些代码示例,展示了Repository.getJobEntryAttributeBoolean的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Repository.getJobEntryAttributeBoolean方法的具体详情如下:
包路径:org.pentaho.di.repository.Repository
类名称:Repository
方法名:getJobEntryAttributeBoolean

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 );
 }
}

相关文章

Repository类方法