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

Repository.getJobEntryAttributeInteger介绍

暂无

代码示例

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  start = rep.getJobEntryAttributeBoolean( id_jobentry, "start" );
  dummy = rep.getJobEntryAttributeBoolean( id_jobentry, "dummy" );
  repeat = rep.getJobEntryAttributeBoolean( id_jobentry, "repeat" );
  schedulerType = (int) rep.getJobEntryAttributeInteger( id_jobentry, "schedulerType" );
  intervalSeconds = (int) rep.getJobEntryAttributeInteger( id_jobentry, "intervalSeconds" );
  intervalMinutes = (int) rep.getJobEntryAttributeInteger( id_jobentry, "intervalMinutes" );
  hour = (int) rep.getJobEntryAttributeInteger( id_jobentry, "hour" );
  minutes = (int) rep.getJobEntryAttributeInteger( id_jobentry, "minutes" );
  weekDay = (int) rep.getJobEntryAttributeInteger( id_jobentry, "weekDay" );
  dayOfMonth = (int) rep.getJobEntryAttributeInteger( id_jobentry, "dayOfMonth" );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( "Unable to load job entry of type 'special' from the repository for id_jobentry="
   + id_jobentry, dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

@Override
public long getJobEntryAttributeInteger( ObjectId objectId, int i, String s ) throws KettleException {
 return getDelegate().getJobEntryAttributeInteger( objectId, i, s );
}

代码示例来源：origin: pentaho/pentaho-kettle

@Override
public long getJobEntryAttributeInteger( ObjectId objectId, String s ) throws KettleException {
 return getDelegate().getJobEntryAttributeInteger( objectId, s );
}

代码示例来源：origin: pentaho/pentaho-kettle

@Override
public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  maximumTimeout = rep.getJobEntryAttributeString( id_jobentry, "maximumTimeout" );
  scaleTime = (int) rep.getJobEntryAttributeInteger( id_jobentry, "scaletime" );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "JobEntryDelay.UnableToLoadFromRepo.Label" )
   + id_jobentry, dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

startfile = (int) rep.getJobEntryAttributeInteger( id_jobentry, "startfile" );
endfile = (int) rep.getJobEntryAttributeInteger( id_jobentry, "endfile" );
maxerrors = (int) rep.getJobEntryAttributeInteger( id_jobentry, "maxerrors" );
batchsize = (int) rep.getJobEntryAttributeInteger( id_jobentry, "batchsize" );
rowsperbatch = (int) rep.getJobEntryAttributeInteger( id_jobentry, "rowsperbatch" );
adddatetime = rep.getJobEntryAttributeBoolean( id_jobentry, "adddatetime" );

代码示例来源：origin: pentaho/pentaho-kettle

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
 List<SlaveServer> slaveServers ) throws KettleException {
 try {
  zipFilename = rep.getJobEntryAttributeString( id_jobentry, "zipfilename" );
  compressionRate = (int) rep.getJobEntryAttributeInteger( id_jobentry, "compressionrate" );
  ifZipFileExists = (int) rep.getJobEntryAttributeInteger( id_jobentry, "ifzipfileexists" );
  afterZip = (int) rep.getJobEntryAttributeInteger( id_jobentry, "afterzip" );
  wildCard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
  excludeWildCard = rep.getJobEntryAttributeString( id_jobentry, "wildcardexclude" );
  sourceDirectory = rep.getJobEntryAttributeString( id_jobentry, "sourcedirectory" );
  movetoDirectory = rep.getJobEntryAttributeString( id_jobentry, "movetodirectory" );
  addFileToResult = rep.getJobEntryAttributeBoolean( id_jobentry, "addfiletoresult" );
  isFromPrevious = rep.getJobEntryAttributeBoolean( id_jobentry, "isfromprevious" );
  createParentFolder = rep.getJobEntryAttributeBoolean( id_jobentry, "createparentfolder" );
  addDate = rep.getJobEntryAttributeBoolean( id_jobentry, "adddate" );
  addTime = rep.getJobEntryAttributeBoolean( id_jobentry, "addtime" );
  specifyFormat = rep.getJobEntryAttributeBoolean( id_jobentry, "SpecifyFormat" );
  dateTimeFormat = rep.getJobEntryAttributeString( id_jobentry, "date_time_format" );
  createMoveToDirectory = rep.getJobEntryAttributeBoolean( id_jobentry, "createMoveToDirectory" );
  includingSubFolders = rep.getJobEntryAttributeBoolean( id_jobentry, "include_subfolders" );
  storedSourcePathDepth = rep.getJobEntryAttributeString( id_jobentry, "stored_source_path_depth" );
 } catch ( KettleException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "JobEntryZipFile.UnableLoadJobEntryRep", ""
   + 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 {
  schemaname = rep.getJobEntryAttributeString( id_jobentry, "schemaname" );
  tablename = rep.getJobEntryAttributeString( id_jobentry, "tablename" );
  filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
  separator = rep.getJobEntryAttributeString( id_jobentry, "separator" );
  enclosed = rep.getJobEntryAttributeString( id_jobentry, "enclosed" );
  lineterminated = rep.getJobEntryAttributeString( id_jobentry, "lineterminated" );
  limitlines = rep.getJobEntryAttributeString( id_jobentry, "limitlines" );
  listcolumn = rep.getJobEntryAttributeString( id_jobentry, "listcolumn" );
  highpriority = rep.getJobEntryAttributeBoolean( id_jobentry, "highpriority" );
  optionenclosed = rep.getJobEntryAttributeBoolean( id_jobentry, "optionenclosed" );
  outdumpvalue = (int) rep.getJobEntryAttributeInteger( id_jobentry, "outdumpvalue" );
  iffileexists = (int) rep.getJobEntryAttributeInteger( id_jobentry, "iffileexists" );
  addfiletoresult = rep.getJobEntryAttributeBoolean( id_jobentry, "addfiletoresult" );
  connection = rep.loadDatabaseMetaFromJobEntryAttribute( id_jobentry, "connection", "id_database", databases );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException(
   "Unable to load job entry of type 'table exists' 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 {
  xmlfilename = rep.getJobEntryAttributeString( id_jobentry, "xmlfilename" );
  xslfilename = rep.getJobEntryAttributeString( id_jobentry, "xslfilename" );
  outputfilename = rep.getJobEntryAttributeString( id_jobentry, "outputfilename" );
  iffileexists = (int) rep.getJobEntryAttributeInteger( id_jobentry, "iffileexists" );
  addfiletoresult = rep.getJobEntryAttributeBoolean( id_jobentry, "addfiletoresult" );
  filenamesfromprevious = rep.getJobEntryAttributeBoolean( id_jobentry, "filenamesfromprevious" );
  xsltfactory = rep.getJobEntryAttributeString( id_jobentry, "xsltfactory" );
  if ( xsltfactory == null ) {
   xsltfactory = FACTORY_JAXP;
  }
  int nrparams = rep.countNrJobEntryAttributes( id_jobentry, "param_name" );
  int nroutputprops = rep.countNrJobEntryAttributes( id_jobentry, "output_property_name" );
  allocate( nrparams, nroutputprops );
  for ( int i = 0; i < nrparams; i++ ) {
   parameterField[i] = rep.getJobEntryAttributeString( id_jobentry, i, "param_field" );
   parameterName[i] = rep.getJobEntryAttributeString( id_jobentry, i, "param_name" );
  }
  for ( int i = 0; i < nroutputprops; i++ ) {
   outputPropertyName[i] = rep.getJobEntryAttributeString( id_jobentry, i, "output_property_name" );
   outputPropertyValue[i] = rep.getJobEntryAttributeString( id_jobentry, i, "output_property_value" );
  }
 } catch ( KettleException dbe ) {
  throw new KettleException( "Unable to load job entry of type 'xslt' 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 {
  schemaname = rep.getJobEntryAttributeString( id_jobentry, "schemaname" );
  tablename = rep.getJobEntryAttributeString( id_jobentry, "tablename" );
  filename = rep.getJobEntryAttributeString( id_jobentry, "filename" );
  separator = rep.getJobEntryAttributeString( id_jobentry, "separator" );
  enclosed = rep.getJobEntryAttributeString( id_jobentry, "enclosed" );
  escaped = rep.getJobEntryAttributeString( id_jobentry, "escaped" );
  linestarted = rep.getJobEntryAttributeString( id_jobentry, "linestarted" );
  lineterminated = rep.getJobEntryAttributeString( id_jobentry, "lineterminated" );
  replacedata = rep.getJobEntryAttributeBoolean( id_jobentry, "replacedata" );
  ignorelines = rep.getJobEntryAttributeString( id_jobentry, "ignorelines" );
  listattribut = rep.getJobEntryAttributeString( id_jobentry, "listattribut" );
  localinfile = rep.getJobEntryAttributeBoolean( id_jobentry, "localinfile" );
  prorityvalue = (int) rep.getJobEntryAttributeInteger( id_jobentry, "prorityvalue" );
  addfiletoresult = rep.getJobEntryAttributeBoolean( id_jobentry, "addfiletoresult" );
  connection = rep.loadDatabaseMetaFromJobEntryAttribute( id_jobentry, "connection", "id_database", databases );
 } catch ( KettleDatabaseException dbe ) {
  throw new KettleException(
   "Unable to load job entry of type 'Mysql bulk load' 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 {
  serverName = rep.getJobEntryAttributeString( id_jobentry, "servername" );
  serverPort = rep.getJobEntryAttributeString( id_jobentry, "serverport" );
  userName = rep.getJobEntryAttributeString( id_jobentry, "username" );
  password =
   Encr.decryptPasswordOptionallyEncrypted( rep.getJobEntryAttributeString( id_jobentry, "password" ) );
  remoteDirectory = rep.getJobEntryAttributeString( id_jobentry, "remoteDirectory" );
  localDirectory = rep.getJobEntryAttributeString( id_jobentry, "localDirectory" );
  wildcard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
  binaryMode = rep.getJobEntryAttributeBoolean( id_jobentry, "binary" );
  timeout = (int) rep.getJobEntryAttributeInteger( id_jobentry, "timeout" );
  remove = rep.getJobEntryAttributeBoolean( id_jobentry, "remove" );
  onlyPuttingNewFiles = rep.getJobEntryAttributeBoolean( id_jobentry, "only_new" );
  activeConnection = rep.getJobEntryAttributeBoolean( id_jobentry, "active" );
  proxyHost = rep.getJobEntryAttributeString( id_jobentry, "proxy_host" );
  proxyPort = rep.getJobEntryAttributeString( id_jobentry, "proxy_port" );
  proxyUsername = rep.getJobEntryAttributeString( id_jobentry, "proxy_username" );
  proxyPassword = rep.getJobEntryAttributeString( id_jobentry, "proxy_password" );
  connectionType =
   FTPSConnection.getConnectionTypeByCode( Const.NVL( rep.getJobEntryAttributeString(
    id_jobentry, "connection_type" ), "" ) );
 } catch ( KettleException dbe ) {
  throw new KettleException( BaseMessages.getString( PKG, "JobFTPSPUT.UnableToLoadFromRepo", String
   .valueOf( id_jobentry ) ), dbe );
 }
}

代码示例来源：origin: pentaho/pentaho-kettle

wildcard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
binaryMode = rep.getJobEntryAttributeBoolean( id_jobentry, "binary" );
timeout = (int) rep.getJobEntryAttributeInteger( id_jobentry, "timeout" );
remove = rep.getJobEntryAttributeBoolean( id_jobentry, "remove" );
onlyPuttingNewFiles = rep.getJobEntryAttributeBoolean( id_jobentry, "only_new" );

代码示例来源：origin: pentaho/pentaho-kettle

try {
 zipFilename = rep.getJobEntryAttributeString( id_jobentry, "zipfilename" );
 afterunzip = (int) rep.getJobEntryAttributeInteger( id_jobentry, "afterunzip" );
 wildcard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
 wildcardexclude = rep.getJobEntryAttributeString( id_jobentry, "wildcardexclude" );

代码示例来源：origin: pentaho/pentaho-kettle

wildcard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
binaryMode = rep.getJobEntryAttributeBoolean( id_jobentry, "binary" );
timeout = (int) rep.getJobEntryAttributeInteger( id_jobentry, "timeout" );
remove = rep.getJobEntryAttributeBoolean( id_jobentry, "remove" );
onlyGettingNewFiles = rep.getJobEntryAttributeBoolean( id_jobentry, "only_new" );

代码示例来源：origin: pentaho/pentaho-kettle

ftpDirectory = rep.getJobEntryAttributeString( id_jobentry, "ftpdirectory" );
wildcard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
timeout = (int) rep.getJobEntryAttributeInteger( id_jobentry, "timeout" );
activeConnection = rep.getJobEntryAttributeBoolean( id_jobentry, "active" );

代码示例来源：origin: pentaho/pentaho-kettle

wildcard = rep.getJobEntryAttributeString( id_jobentry, "wildcard" );
binaryMode = rep.getJobEntryAttributeBoolean( id_jobentry, "binary" );
timeout = (int) rep.getJobEntryAttributeInteger( id_jobentry, "timeout" );
remove = rep.getJobEntryAttributeBoolean( id_jobentry, "remove" );
onlyGettingNewFiles = rep.getJobEntryAttributeBoolean( id_jobentry, "only_new" );

代码示例来源：origin: pentaho/pentaho-kettle

filenamepattern = DEFAULT_FILE_NAME_PATTERN;
retrievemails = (int) rep.getJobEntryAttributeInteger( id_jobentry, "retrievemails" );
firstmails = rep.getJobEntryAttributeString( id_jobentry, "firstmails" );
delete = rep.getJobEntryAttributeBoolean( id_jobentry, "delete" );