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

Repository.getStepAttributeString介绍

暂无

代码示例

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 port = rep.getStepAttributeString( id_step, "port" );
 bufferSize = rep.getStepAttributeString( id_step, "buffer_size" );
 flushInterval = rep.getStepAttributeString( id_step, "flush_interval" );
 compressed = rep.getStepAttributeBoolean( id_step, "compressed" );
}

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

@Override
public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  valuename = rep.getStepAttributeString( id_step, "valuename" );
  slaveServerName = rep.getStepAttributeString( id_step, "slave" );
  sequenceName = rep.getStepAttributeString( id_step, "seqname" );
  increment = rep.getStepAttributeString( id_step, "increment" );
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString( PKG, "GetSequenceMeta.Exception.UnableToReadStepInfo" )
   + id_step, e );
 }
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  urlField = rep.getStepAttributeString( id_step, "urlField" );
  connectTimeOut = rep.getStepAttributeString( id_step, "connectTimeOut" );
  readTimeOut = rep.getStepAttributeString( id_step, "readTimeOut" );
  resultfieldname = rep.getStepAttributeString( id_step, "resultfieldname" );
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "WebServiceAvailableMeta.Exception.UnexpectedErrorReadingStepInfo" ), e );
 }
}

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

public void readRep(Repository rep, ObjectId id_step, List<DatabaseMeta> databases, Map<String, Counter> counters) throws KettleException 
{
  try
  {
    shapeFilename =      rep.getStepAttributeString (id_step, "shapefilename"    );
    dbfFilename   =      rep.getStepAttributeString (id_step, "dbffilename"      );
  }
  catch(Exception e)
  {
    throw new KettleException("Unexpected error reading step information from the repository", e);
  }
  
}

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

public JobExecutorParameters( Repository rep, ObjectId id_step ) throws KettleException {
 int nrVariables = rep.countNrStepAttributes( id_step, "parameter_variable" );
 variable = new String[nrVariables];
 field = new String[nrVariables];
 input = new String[nrVariables];
 for ( int i = 0; i < nrVariables; i++ ) {
  variable[i] = rep.getStepAttributeString( id_step, i, "parameter_variable" );
  field[i] = rep.getStepAttributeString( id_step, i, "parameter_field" );
  input[i] = rep.getStepAttributeString( id_step, i, "parameter_input" );
 }
 inheritingAllVariables = rep.getStepAttributeBoolean( id_step, "parameter_inherit_all_vars" );
}

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

@Override
public void readRep( Repository rep, IMetaStore metaStore, ObjectId idStep, List<DatabaseMeta> databases )
 throws KettleException {
 try {
  this.databaseMeta = rep.loadDatabaseMetaFromStepAttribute( idStep, "connection", databases );
  this.modelName = rep.getStepAttributeString( idStep, "modelName" );
  this.commitBatchSize = Integer.parseInt( rep.getStepAttributeString( idStep, "readBatchSize" ) );
  this.idFieldName = rep.getStepAttributeString( idStep, "idFieldName" );
 } catch ( Exception e ) {
  throw new KettleException( "Unexpected error reading step information from the repository", e );
 }
}

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

public FormulaMetaFunction( Repository rep, ObjectId id_step, int nr ) throws KettleException {
 fieldName = rep.getStepAttributeString( id_step, nr, "field_name" );
 formula = rep.getStepAttributeString( id_step, nr, "formula_string" );
 valueType = ValueMetaFactory.getIdForValueMeta( rep.getStepAttributeString( id_step, nr, "value_type" ) );
 valueLength = (int) rep.getStepAttributeInteger( id_step, nr, "value_length" );
 valuePrecision = (int) rep.getStepAttributeInteger( id_step, nr, "value_precision" );
 replaceField = rep.getStepAttributeString( id_step, nr, "replace_field" );
}

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

public TransExecutorParameters( Repository rep, ObjectId id_step ) throws KettleException {
 int nrVariables = rep.countNrStepAttributes( id_step, "parameter_variable" );
 allocate( nrVariables );
 for ( int i = 0; i < nrVariables; i++ ) {
  variable[i] = rep.getStepAttributeString( id_step, i, "parameter_variable" );
  field[i] = rep.getStepAttributeString( id_step, i, "parameter_field" );
  input[i] = rep.getStepAttributeString( id_step, i, "parameter_input" );
 }
 inheritingAllVariables = rep.getStepAttributeBoolean( id_step, "parameter_inherit_all_vars" );
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 List<StreamInterface> targetStreams = getStepIOMeta().getTargetStreams();
 targetStreams.get( 0 ).setSubject( rep.getStepAttributeString( id_step, "send_true_to" ) );
 targetStreams.get( 1 ).setSubject( rep.getStepAttributeString( id_step, "send_false_to" ) );
 condition = rep.getStepAttributeString( id_step, "condition" );
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  filenamefield = rep.getStepAttributeString( id_step, "filenamefield" );
  resultfieldname = rep.getStepAttributeString( id_step, "resultfieldname" );
  includefiletype = rep.getStepAttributeBoolean( id_step, "includefiletype" );
  filetypefieldname = rep.getStepAttributeString( id_step, "filetypefieldname" );
  addresultfilenames = rep.getStepAttributeBoolean( id_step, "addresultfilenames" );
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "FileExistsMeta.Exception.UnexpectedErrorReadingStepInfo" ), e );
 }
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  filenamefield = rep.getStepAttributeString( id_step, "filenamefield" );
  resultfieldname = rep.getStepAttributeString( id_step, "resultfieldname" );
  addresultfilenames = rep.getStepAttributeBoolean( id_step, "addresultfilenames" );
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "FileLockedMeta.Exception.UnexpectedErrorReadingStepInfo" ), e );
 }
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 setTargetURL( rep.getStepAttributeString( id_step, "targeturl" ) );
 setUsername( rep.getStepAttributeString( id_step, "username" ) );
 setPassword( Encr.decryptPasswordOptionallyEncrypted( rep.getStepAttributeString( id_step, "password" ) ) );
 setTimeout( rep.getStepAttributeString( id_step, "timeout" ) );
 setCompression( rep.getStepAttributeBoolean( id_step, "useCompression" ) );
 setModule( rep.getStepAttributeString( id_step, "module" ) );
}

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

/**
 * {@inheritDoc}
 *
 * @see at.aschauer.commons.pentaho.plugin.PluginProperty#readFromRepositoryStep(org.pentaho.di.repository.Repository,
 *      long)
 */
public void readFromRepositoryStep( final Repository repository, final IMetaStore metaStore,
 final ObjectId stepId ) throws KettleException {
 final String value = repository.getStepAttributeString( stepId, this.getKey() );
 this.setValue( value );
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  resultfieldname = rep.getStepAttributeString( id_step, "resultfieldname" );
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "DetectLastRowMeta.Exception.UnexpectedErrorReadingStepInfo" ), e );
 }
}

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

@Override
public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  outputRowcount = rep.getStepAttributeBoolean( id_step, "outputRowcount" );
  rowcountField = rep.getStepAttributeString( id_step, "rowcountField" );
 } catch ( Exception e ) {
  throw new KettleException( "Unexpected error reading step information from the repository", e );
 }
}

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

public void loadRep( Repository rep, IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases,
  List<SlaveServer> slaveServers ) throws KettleException {
 try {
  this.databaseMeta =
    rep.loadDatabaseMetaFromJobEntryAttribute( id_jobentry, "connection", "id_database", databases );
  this.setCubeName( rep.getStepAttributeString( id_jobentry, "cubeName" ) );
 } catch ( KettleException dbe ) {
  throw new KettleException( "Unable to load job entry for type file exists from the repository for id_jobentry="
    + id_jobentry, dbe );
 }
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  allocate();
  setTrueStepname( rep.getStepAttributeString( id_step, "send_true_to" ) );
  setFalseStepname( rep.getStepAttributeString( id_step, "send_false_to" ) );
  condition = rep.loadConditionFromStepAttribute( id_step, "id_condition" );
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "FilterRowsMeta.Exception.UnexpectedErrorInReadingStepInfoFromRepository" ), e );
 }
}

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

@Override
public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases )
 throws KettleException {
 super.readRep( rep, metaStore, id_step, databases );
 targetFieldName = rep.getStepAttributeString( id_step, ConcatFieldsNodeNameSpace + "targetFieldName" );
 targetFieldLength =
  (int) rep.getStepAttributeInteger( id_step, ConcatFieldsNodeNameSpace + "targetFieldLength" );
 removeSelectedFields =
  rep.getStepAttributeBoolean( id_step, ConcatFieldsNodeNameSpace + "removeSelectedFields" );
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 int nrValidationFields = rep.countNrStepAttributes( id_step, "validator_field_name" );
 allocate( nrValidationFields );
 validatingAll = rep.getStepAttributeBoolean( id_step, "validate_all" );
 concatenatingErrors = rep.getStepAttributeBoolean( id_step, "concat_errors" );
 concatenationSeparator = rep.getStepAttributeString( id_step, "concat_separator" );
 for ( int i = 0; i < nrValidationFields; i++ ) {
  validations.add( new Validation( rep, id_step, i ) );
 }
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  int nrfields = rep.countNrStepAttributes( id_step, "field_name" );
  allocate( nrfields );
  for ( int i = 0; i < nrfields; i++ ) {
   fieldName[i] = rep.getStepAttributeString( id_step, i, "field_name" );
   ascending[i] = rep.getStepAttributeBoolean( id_step, i, "field_ascending" );
  }
 } catch ( Exception e ) {
  throw new KettleException( "Unexpected error reading step information from the repository", e );
 }
}