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

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

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

Repository.getStepAttributeBoolean介绍

暂无

代码示例

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

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

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

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

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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  filename = rep.getStepAttributeString( id_step, "file_name" );
  addToResultFilenames = rep.getStepAttributeBoolean( id_step, "add_to_result_filenames" );
  doNotOpenNewFileInit = rep.getStepAttributeBoolean( id_step, "do_not_open_newfile_init" );
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "CubeOutputMeta.Exception.UnexpectedErrorInReadingStepInfo" ), 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

@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

/**
 * {@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 boolean value = repository.getStepAttributeBoolean( stepId, this.getKey() );
 this.setValue( value );
}

代码示例来源: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 );
 try {
  fileAsCommand = rep.getStepAttributeBoolean( id_step, "file_is_command" );
 } 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 {
  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 {
 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 {
 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 {
 hostname = rep.getStepAttributeString( id_step, "hostname" );
 port = rep.getStepAttributeString( id_step, "port" );
 bufferSize = rep.getStepAttributeString( id_step, "buffer_size" );
 compressed = rep.getStepAttributeBoolean( id_step, "compressed" );
}

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

@Override
public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases )
 throws KettleException {
 try {
  parentIdFieldName = rep.getStepAttributeString( id_step, "parent_id_field" );
  childIdFieldName = rep.getStepAttributeString( id_step, "child_id_field" );
  distanceFieldName = rep.getStepAttributeString( id_step, "distance_field" );
  rootIdZero = rep.getStepAttributeBoolean( id_step, "is_root_zero" );
 } 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

public void readRep( Repository rep, IMetaStore metaStore, ObjectId id_step, List<DatabaseMeta> databases ) throws KettleException {
 try {
  databaseMeta = rep.loadDatabaseMetaFromStepAttribute( id_step, "id_connection", databases );
  sql = rep.getStepAttributeString( id_step, "sql" );
  catalog = rep.getStepAttributeString( id_step, "catalog" );
  role = rep.getStepAttributeString( id_step, "role" );
  variableReplacementActive = rep.getStepAttributeBoolean( id_step, "variables_active" );
 } 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 {
 super.readRep( rep, metaStore, id_step, databases );
 try {
  setDeleteField( rep.getStepAttributeString( id_step, "DeleteField" ) );
  setBatchSize( rep.getStepAttributeString( id_step, "batchSize" ) );
  setRollbackAllChangesOnError( rep.getStepAttributeBoolean( id_step, "rollbackAllChangesOnError" ) );
 } catch ( Exception e ) {
  throw new KettleException( BaseMessages.getString(
   PKG, "SalesforceDeleteMeta.Exception.ErrorReadingRepository" ), 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" ) );
}

相关文章

Repository类方法