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

Repository.countNrStepAttributes介绍

暂无

代码示例

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

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

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 int nrCalcs = rep.countNrStepAttributes( id_step, "field_name" );
 allocate( nrCalcs );
 for ( int i = 0; i < nrCalcs; i++ ) {
  formula[i] = new FormulaMetaFunction( rep, id_step, i );
 }
}

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

@Override
public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases )
 throws KettleException {
 int nrStats = rep.countNrStepAttributes( id_step, "source_field_name" );
 allocate( nrStats );
 for ( int i = 0; i < nrStats; i++ ) {
  m_stats[i] = new UnivariateStatsMetaFunction( rep, id_step, i );
 }
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 int nrCalcs = rep.countNrStepAttributes( id_step, "field_name" );
 allocate( nrCalcs );
 for ( int i = 0; i < nrCalcs; i++ ) {
  formula[i] = new JaninoMetaFunction( rep, id_step, i );
 }
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId stepId, List<DatabaseMeta> databases ) throws KettleException {
 try {
  acceptingField = rep.getStepAttributeString( stepId, "accept_field" );
  outputFields = new ArrayList<SasInputField>();
  int nrFields = rep.countNrStepAttributes( stepId, "field_name" );
  for ( int i = 0; i < nrFields; i++ ) {
   outputFields.add( new SasInputField( rep, stepId, i ) );
  }
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "SASInputMeta.Exception.UnexpectedErrorReadingMetaDataFromRepository" ), e );
 }
}

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

@Override
public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 failIfNoFile = rep.getStepAttributeBoolean( id_step, "failIfNoFile" );
 int nrCalcs = rep.countNrStepAttributes( id_step, "field_name" );
 allocate( nrCalcs );
 for ( int i = 0; i < nrCalcs; i++ ) {
  calculation[i] = new CalculatorMetaFunction( rep, id_step, i );
 }
}

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

public MappingParameters( Repository rep, ObjectId id_step ) throws KettleException {
 int nrVariables = rep.countNrStepAttributes( id_step, "mapping_parameter_variable" );
 variable = new String[nrVariables];
 input = new String[nrVariables];
 for ( int i = 0; i < nrVariables; i++ ) {
  variable[i] = rep.getStepAttributeString( id_step, i, "mapping_parameter_variable" );
  input[i] = rep.getStepAttributeString( id_step, i, "mapping_parameter_input" );
 }
 inheritingAllVariables = rep.getStepAttributeBoolean( id_step, "mapping_parameter_inherit_all_vars" );
}

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

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

代码示例来源：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 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

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

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

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

代码示例来源：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

@Override
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" );
   fieldType[i] = getType( rep.getStepAttributeString( id_step, i, "field_type" ) );
  }
 } catch ( Exception e ) {
  throw new KettleException( "Unexpected error reading step information from the repository", e );
 }
}

代码示例来源：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" );
   replaceByFieldValue[i] = rep.getStepAttributeString( id_step, i, "replace_by" );
  }
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "SetValueFieldMeta.Exception.UnexpectedErrorReadingStepInfoFromRepository" ), e );
 }
}

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  fieldName = rep.getStepAttributeString( id_step, "field_name" );
  int nrvalues = rep.countNrStepAttributes( id_step, "target_field" );
  allocate( nrvalues );
  for ( int i = 0; i < nrvalues; i++ ) {
   targetField[i] = rep.getStepAttributeString( id_step, i, "target_field" );
  }
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "FlattenerMeta.Exception.UnexpectedErrorInReadingStepInfoFromRepository" ), e );
 }
}

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

@Override
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" );
   fieldType[i] = SystemDataTypes.getTypeFromString( rep.getStepAttributeString( id_step, i, "field_type" ) );
  }
 } catch ( Exception e ) {
  throw new KettleException( "Unexpected error reading step information from the repository", e );
 }
}

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

@Override
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" );
   fieldNewName[i] = rep.getStepAttributeString( id_step, i, "field_rename" );
   aggregateType[i] = getType( rep.getStepAttributeString( id_step, i, "field_type" ) );
  }
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "AggregateRowsMeta.Exception.UnexpectedErrorWhileReadingStepInfo" ), e );
 }
}

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

@Override
public void readRep( Repository rep, IMetaStore metaStore, ObjectId idStep, List<DatabaseMeta> _databases ) throws KettleException {
 int nrfields = rep.countNrStepAttributes( idStep, StorageKeys.COLUMN_NAME.toString() );
 ValueMetaInterface vm = null;
 for ( int i = 0; i < nrfields; i++ ) {
  String name = rep.getStepAttributeString( idStep, i, StorageKeys.COLUMN_NAME.toString() );
  int type = ValueMeta.getType( rep.getStepAttributeString( idStep, i, StorageKeys.COLUMN_TYPE.toString() ) );
  vm = ValueMetaFactory.createValueMeta( name, type );
  getRuleResultColumns().add( vm );
 }
 setRuleFile( rep.getStepAttributeString( idStep, StorageKeys.RULE_FILE.toString() ) );
 setRuleDefinition( rep.getStepAttributeString( idStep, StorageKeys.RULE_DEFINITION.toString() ) );
}

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

@Override
public void readRep( Repository rep, IMetaStore metaStore, ObjectId idStep, List<DatabaseMeta> _databases ) throws KettleException {
 int nrfields = rep.countNrStepAttributes( idStep, StorageKeys.COLUMN_NAME.toString() );
 ValueMetaInterface vm = null;
 for ( int i = 0; i < nrfields; i++ ) {
  String name = rep.getStepAttributeString( idStep, i, StorageKeys.COLUMN_NAME.toString() );
  int type = ValueMeta.getType( rep.getStepAttributeString( idStep, i, StorageKeys.COLUMN_TYPE.toString() ) );
  vm = ValueMetaFactory.createValueMeta( name, type );
  getRuleResultColumns().add( vm );
 }
 setRuleFile( rep.getStepAttributeString( idStep, StorageKeys.RULE_FILE.toString() ) );
 setRuleDefinition( rep.getStepAttributeString( idStep, StorageKeys.RULE_DEFINITION.toString() ) );
}