本文整理了Java中org.pentaho.di.repository.Repository.getStepAttributeBoolean
方法的一些代码示例,展示了Repository.getStepAttributeBoolean
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Repository.getStepAttributeBoolean
方法的具体详情如下:
包路径:org.pentaho.di.repository.Repository
类名称: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" ) );
}
内容来源于网络,如有侵权,请联系作者删除!