本文整理汇总了Java中org.pentaho.di.trans.step.StepMetaDataCombi类的典型用法代码示例。如果您正苦于以下问题:Java StepMetaDataCombi类的具体用法?Java StepMetaDataCombi怎么用?Java StepMetaDataCombi使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
StepMetaDataCombi类属于org.pentaho.di.trans.step包,在下文中一共展示了StepMetaDataCombi类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getEnded
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
public int getEnded()
{
int nrEnded=0;
if (steps==null) return 0;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
BaseStep thr=(BaseStep)sid.step;
StepDataInterface data = sid.data;
if ((thr!=null && !thr.isAlive()) || // Should normally not be needed anymore, status is kept in data.
data.getStatus()==StepDataInterface.STATUS_FINISHED || // Finished processing
data.getStatus()==StepDataInterface.STATUS_HALTED || // Not launching because of init error
data.getStatus()==StepDataInterface.STATUS_STOPPED // Stopped because of an error
)
{
nrEnded++;
}
}
return nrEnded;
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:26,代码来源:Trans.java
示例2: killAllNoWait
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
/**
* Ask all steps to stop but don't wait around for it to happen.
* Special method for use with mappings.
*/
private void killAllNoWait()
{
if (steps==null) return;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
BaseStep thr = (BaseStep)sid.step;
if (log.isDebug()) log.logDebug(toString(), Messages.getString("Trans.Log.LookingAtStep")+thr.getStepname()); //$NON-NLS-1$
thr.stopAll();
try
{
Thread.sleep(20);
}
catch(Exception e)
{
log.logError(toString(), Messages.getString("Trans.Log.TransformationErrors")+e.toString()); //$NON-NLS-1$
return;
}
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:28,代码来源:Trans.java
示例3: getRunThread
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
public BaseStep getRunThread(String name, int copy)
{
if (steps==null) return null;
int i;
for( i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
BaseStep rt = (BaseStep)sid.step;
if (rt.getStepname().equalsIgnoreCase(name) && rt.getCopy()==copy)
{
return rt;
}
}
return null;
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:19,代码来源:Trans.java
示例4: findBaseSteps
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
public List<BaseStep> findBaseSteps(String stepname)
{
List<BaseStep> baseSteps = new ArrayList<BaseStep>();
if (steps==null) return baseSteps;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
BaseStep rt = (BaseStep)sid.step;
if (rt.getStepname().equalsIgnoreCase(stepname)) {
baseSteps.add(rt);
}
}
return baseSteps;
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:17,代码来源:Trans.java
示例5: findMappingInput
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
public MappingInput[] findMappingInput()
{
if (steps==null) return null;
List<MappingInput> list = new ArrayList<MappingInput>();
// Look in threads and find the MappingInput step thread...
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi smdc = steps.get(i);
StepInterface step = smdc.step;
if (step.getStepID().equalsIgnoreCase("MappingInput")) //$NON-NLS-1$
{
list.add((MappingInput)step);
}
}
return list.toArray(new MappingInput[list.size()]);
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:19,代码来源:Trans.java
示例6: findMappingOutput
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
public MappingOutput[] findMappingOutput()
{
List<MappingOutput> list = new ArrayList<MappingOutput>();
if (steps!=null)
{
// Look in threads and find the MappingInput step thread...
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi smdc = steps.get(i);
StepInterface step = smdc.step;
if (step.getStepID().equalsIgnoreCase("MappingOutput")) //$NON-NLS-1$
{
list.add((MappingOutput)step);
}
}
}
return list.toArray(new MappingOutput[list.size()]);
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:20,代码来源:Trans.java
示例7: getStepInterface
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
/**
* Find the StepInterface (thread) by looking it up using the name
* @param stepname The name of the step to look for
* @param copy the copy number of the step to look for
* @return the StepInterface or null if nothing was found.
*/
public StepInterface getStepInterface(String stepname, int copy)
{
if (steps==null) return null;
// Now start all the threads...
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
if (sid.stepname.equalsIgnoreCase(stepname) && sid.copy==copy)
{
return sid.step;
}
}
return null;
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:23,代码来源:Trans.java
示例8: lookupStatusStepNumbers
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
private void lookupStatusStepNumbers()
{
if (data.mappingTrans != null)
{
List<StepMetaDataCombi> steps = data.mappingTrans.getSteps();
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
BaseStep rt = (BaseStep)sid.step;
if (data.mappingTransMeta.getReadStep() !=null && rt.getStepname().equals(data.mappingTransMeta.getReadStep().getName())) data.linesReadStepNr = i;
if (data.mappingTransMeta.getInputStep() !=null && rt.getStepname().equals(data.mappingTransMeta.getInputStep().getName())) data.linesInputStepNr = i;
if (data.mappingTransMeta.getWriteStep() !=null && rt.getStepname().equals(data.mappingTransMeta.getWriteStep().getName())) data.linesWrittenStepNr = i;
if (data.mappingTransMeta.getOutputStep() !=null && rt.getStepname().equals(data.mappingTransMeta.getOutputStep().getName())) data.linesOutputStepNr = i;
if (data.mappingTransMeta.getUpdateStep() !=null && rt.getStepname().equals(data.mappingTransMeta.getUpdateStep().getName())) data.linesUpdatedStepNr = i;
if (data.mappingTransMeta.getRejectedStep()!=null && rt.getStepname().equals(data.mappingTransMeta.getRejectedStep().getName())) data.linesRejectedStepNr = i;
}
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:19,代码来源:Mapping.java
示例9: getEnded
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
public int getEnded()
{
int nrEnded=0;
if (steps==null) return 0;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
StepDataInterface data = sid.data;
if ((sid.step!=null && !sid.step.isRunning()) || // Should normally not be needed anymore, status is kept in data.
data.getStatus()==StepExecutionStatus.STATUS_FINISHED || // Finished processing
data.getStatus()==StepExecutionStatus.STATUS_HALTED || // Not launching because of init error
data.getStatus()==StepExecutionStatus.STATUS_STOPPED // Stopped because of an error
)
{
nrEnded++;
}
}
return nrEnded;
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:24,代码来源:Trans.java
示例10: killAllNoWait
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
/**
* Ask all steps to stop but don't wait around for it to happen.
* Special method for use with mappings.
*/
private void killAllNoWait()
{
if (steps==null) return;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
StepInterface step = sid.step;
if (log.isDebug()) log.logDebug(BaseMessages.getString(PKG, "Trans.Log.LookingAtStep")+step.getStepname()); //$NON-NLS-1$
step.stopAll();
try
{
Thread.sleep(20);
}
catch(Exception e)
{
log.logError(BaseMessages.getString(PKG, "Trans.Log.TransformationErrors")+e.toString()); //$NON-NLS-1$
return;
}
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:28,代码来源:Trans.java
示例11: nrActiveSteps
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
public int nrActiveSteps()
{
if (steps==null) return 0;
int nr = 0;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
//without also considering a step status of not finished,
// the step execution results grid shows empty while
// the transformation has steps still running.
//if ( sid.step.isRunning() ) nr++;
if ( sid.step.isRunning() ||
sid.step.getStatus() != StepExecutionStatus.STATUS_FINISHED ) {
nr++;
}
}
return nr;
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:20,代码来源:Trans.java
示例12: getRunThread
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
public StepInterface getRunThread(String name, int copy)
{
if (steps==null) return null;
for(int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
StepInterface step = sid.step;
if (step.getStepname().equalsIgnoreCase(name) && step.getCopy()==copy)
{
return step;
}
}
return null;
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:17,代码来源:Trans.java
示例13: findBaseSteps
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
public List<StepInterface> findBaseSteps(String stepname)
{
List<StepInterface> baseSteps = new ArrayList<StepInterface>();
if (steps==null) return baseSteps;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
StepInterface stepInterface = sid.step;
if (stepInterface.getStepname().equalsIgnoreCase(stepname)) {
baseSteps.add(stepInterface);
}
}
return baseSteps;
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:17,代码来源:Trans.java
示例14: lookupStatusStepNumbers
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
private void lookupStatusStepNumbers()
{
if (data.mappingTrans != null)
{
List<StepMetaDataCombi> steps = data.mappingTrans.getSteps();
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
BaseStep rt = (BaseStep)sid.step;
if (rt.getStepname().equals(data.mappingTransMeta.getTransLogTable().getStepnameRead())) data.linesReadStepNr = i;
if (rt.getStepname().equals(data.mappingTransMeta.getTransLogTable().getStepnameInput())) data.linesInputStepNr = i;
if (rt.getStepname().equals(data.mappingTransMeta.getTransLogTable().getStepnameWritten())) data.linesWrittenStepNr = i;
if (rt.getStepname().equals(data.mappingTransMeta.getTransLogTable().getStepnameOutput())) data.linesOutputStepNr = i;
if (rt.getStepname().equals(data.mappingTransMeta.getTransLogTable().getStepnameUpdated())) data.linesUpdatedStepNr = i;
if (rt.getStepname().equals(data.mappingTransMeta.getTransLogTable().getStepnameRejected())) data.linesRejectedStepNr = i;
}
}
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:19,代码来源:Mapping.java
示例15: getErrors
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
/**
* Gets the number of errors that have occurred during execution of the transformation.
*
* @return the number of errors
*/
public int getErrors()
{
int nrErrors = errors.get();
if (steps==null) return nrErrors;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
if (sid.step.getErrors()!=0L) nrErrors+=sid.step.getErrors();
}
if (nrErrors>0) log.logError(BaseMessages.getString(PKG, "Trans.Log.TransformationErrorsDetected")); //$NON-NLS-1$
return nrErrors;
}
开发者ID:bsspirit,项目名称:kettle-4.4.0-stable,代码行数:21,代码来源:Trans.java
示例16: getEnded
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
/**
* Gets the number of steps in the transformation that are in an end state, such as Finished, Halted, or Stopped.
*
* @return the number of ended steps
*/
public int getEnded()
{
int nrEnded=0;
if (steps==null) return 0;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
StepDataInterface data = sid.data;
if ((sid.step!=null && !sid.step.isRunning()) || // Should normally not be needed anymore, status is kept in data.
data.getStatus()==StepExecutionStatus.STATUS_FINISHED || // Finished processing
data.getStatus()==StepExecutionStatus.STATUS_HALTED || // Not launching because of init error
data.getStatus()==StepExecutionStatus.STATUS_STOPPED // Stopped because of an error
)
{
nrEnded++;
}
}
return nrEnded;
}
开发者ID:bsspirit,项目名称:kettle-4.4.0-stable,代码行数:29,代码来源:Trans.java
示例17: killAllNoWait
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
/**
* Asks all steps to stop but doesn't wait around for it to happen. This is a special method for use with mappings.
*/
private void killAllNoWait()
{
if (steps==null) return;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
StepInterface step = sid.step;
if (log.isDebug()) log.logDebug(BaseMessages.getString(PKG, "Trans.Log.LookingAtStep")+step.getStepname()); //$NON-NLS-1$
step.stopAll();
try
{
Thread.sleep(20);
}
catch(Exception e)
{
log.logError(BaseMessages.getString(PKG, "Trans.Log.TransformationErrors")+e.toString()); //$NON-NLS-1$
return;
}
}
}
开发者ID:bsspirit,项目名称:kettle-4.4.0-stable,代码行数:27,代码来源:Trans.java
示例18: nrActiveSteps
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
/**
* Gets the number of active (i.e. not finished) steps in this transformation
*
* @return the number of active steps
*/
public int nrActiveSteps()
{
if (steps==null) return 0;
int nr = 0;
for (int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
//without also considering a step status of not finished,
// the step execution results grid shows empty while
// the transformation has steps still running.
//if ( sid.step.isRunning() ) nr++;
if ( sid.step.isRunning() ||
sid.step.getStatus() != StepExecutionStatus.STATUS_FINISHED ) {
nr++;
}
}
return nr;
}
开发者ID:bsspirit,项目名称:kettle-4.4.0-stable,代码行数:25,代码来源:Trans.java
示例19: getRunThread
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
/**
* Gets the run thread for the step with the specified name and copy number.
*
* @param name the step name
* @param copy the copy number
* @return a StepInterface object corresponding to the run thread for the specified step
*/
public StepInterface getRunThread(String name, int copy)
{
if (steps==null) return null;
for(int i=0;i<steps.size();i++)
{
StepMetaDataCombi sid = steps.get(i);
StepInterface step = sid.step;
if (step.getStepname().equalsIgnoreCase(name) && step.getCopy()==copy)
{
return step;
}
}
return null;
}
开发者ID:bsspirit,项目名称:kettle-4.4.0-stable,代码行数:24,代码来源:Trans.java
示例20: writeStepLogInformation
import org.pentaho.di.trans.step.StepMetaDataCombi; //导入依赖的package包/类
/**
* Writes step information to a step logging table (if one has been configured).
*
* @throws KettleException if any errors occur during logging
*/
protected void writeStepLogInformation() throws KettleException {
Database db = null;
StepLogTable stepLogTable = transMeta.getStepLogTable();
try {
db = new Database(this, stepLogTable.getDatabaseMeta());
db.shareVariablesWith(this);
db.connect();
db.setCommit(logCommitSize);
for (StepMetaDataCombi combi : steps) {
db.writeLogRecord(stepLogTable, LogStatus.START, combi, null);
}
} catch(Exception e) {
throw new KettleException(BaseMessages.getString(PKG, "Trans.Exception.UnableToWriteStepInformationToLogTable"), e);
} finally {
if (!db.isAutoCommit()) db.commit(true);
db.disconnect();
}
}
开发者ID:bsspirit,项目名称:kettle-4.4.0-stable,代码行数:27,代码来源:Trans.java
注:本文中的org.pentaho.di.trans.step.StepMetaDataCombi类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论