本文整理汇总了Java中org.pentaho.di.trans.debug.StepDebugMeta类的典型用法代码示例。如果您正苦于以下问题:Java StepDebugMeta类的具体用法?Java StepDebugMeta怎么用?Java StepDebugMeta使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
StepDebugMeta类属于org.pentaho.di.trans.debug包,在下文中一共展示了StepDebugMeta类的15个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getStepDebugMeta
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
/**
* Grab the step debugging information from the dialog.
* Store it in our private map
*/
private void getStepDebugMeta() {
int index = wSteps.getSelectionIndex();
if (previousIndex>=0)
{
// Is there anything on the composite to save yet?
//
if (wComposite.getChildren().length==0) return;
StepMeta stepMeta = transDebugMeta.getTransMeta().getStep(previousIndex);
StepDebugMeta stepDebugMeta = new StepDebugMeta(stepMeta);
stepDebugMeta.setCondition(condition);
stepDebugMeta.setPausingOnBreakPoint(wPauseBreakPoint.getSelection());
stepDebugMeta.setReadingFirstRows(wFirstRows.getSelection());
stepDebugMeta.setRowCount(Const.toInt(wRowCount.getText(), -1));
stepDebugMetaMap.put(stepMeta, stepDebugMeta);
}
previousIndex = index;
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:24,代码来源:TransDebugDialog.java
示例2: showLastPreviewResults
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
public synchronized void showLastPreviewResults() {
if (lastTransDebugMeta == null || lastTransDebugMeta.getStepDebugMetaMap().isEmpty())
return;
final List<String> stepnames = new ArrayList<String>();
final List<RowMetaInterface> rowMetas = new ArrayList<RowMetaInterface>();
final List<List<Object[]>> rowBuffers = new ArrayList<List<Object[]>>();
// Assemble the buffers etc in the old style...
//
for (StepMeta stepMeta : lastTransDebugMeta.getStepDebugMetaMap().keySet()) {
StepDebugMeta stepDebugMeta = lastTransDebugMeta.getStepDebugMetaMap().get(stepMeta);
stepnames.add(stepMeta.getName());
rowMetas.add(stepDebugMeta.getRowBufferMeta());
rowBuffers.add(stepDebugMeta.getRowBuffer());
}
getDisplay().asyncExec(new Runnable() {
public void run() {
EnterPreviewRowsDialog dialog = new EnterPreviewRowsDialog(shell, SWT.NONE, stepnames, rowMetas, rowBuffers);
dialog.open();
}
});
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:26,代码来源:TransGraph.java
示例3: getStepDebugMeta
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
/**
* Grab the step debugging information from the dialog. Store it in our private map
*/
private void getStepDebugMeta() {
int index = wSteps.getSelectionIndex();
if ( previousIndex >= 0 ) {
// Is there anything on the composite to save yet?
//
if ( wComposite.getChildren().length == 0 ) {
return;
}
StepMeta stepMeta = transDebugMeta.getTransMeta().getStep( previousIndex );
StepDebugMeta stepDebugMeta = new StepDebugMeta( stepMeta );
stepDebugMeta.setCondition( condition );
stepDebugMeta.setPausingOnBreakPoint( wPauseBreakPoint.getSelection() );
stepDebugMeta.setReadingFirstRows( wFirstRows.getSelection() );
stepDebugMeta.setRowCount( Const.toInt( wRowCount.getText(), -1 ) );
stepDebugMetaMap.put( stepMeta, stepDebugMeta );
}
previousIndex = index;
}
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:24,代码来源:TransDebugDialog.java
示例4: getPreviewRows
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
/**
* @param stepname
* the name of the step to get the preview rows for
* @return A list of rows as the result of the preview run.
*/
public List<Object[]> getPreviewRows( String stepname ) {
if ( transDebugMeta == null ) {
return null;
}
for ( StepMeta stepMeta : transDebugMeta.getStepDebugMetaMap().keySet() ) {
if ( stepMeta.getName().equals( stepname ) ) {
StepDebugMeta stepDebugMeta = transDebugMeta.getStepDebugMetaMap().get( stepMeta );
return stepDebugMeta.getRowBuffer();
}
}
return null;
}
开发者ID:majinju,项目名称:KettleEasyExpand,代码行数:19,代码来源:TransPreviewUtil.java
示例5: getPreviewRowsMeta
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
/**
* @param stepname
* the name of the step to get the preview rows for
* @return A description of the row (metadata)
*/
public RowMetaInterface getPreviewRowsMeta( String stepname ) {
if ( transDebugMeta == null ) {
return null;
}
for ( StepMeta stepMeta : transDebugMeta.getStepDebugMetaMap().keySet() ) {
if ( stepMeta.getName().equals( stepname ) ) {
StepDebugMeta stepDebugMeta = transDebugMeta.getStepDebugMetaMap().get( stepMeta );
return stepDebugMeta.getRowBufferMeta();
}
}
return null;
}
开发者ID:majinju,项目名称:KettleEasyExpand,代码行数:19,代码来源:TransPreviewUtil.java
示例6: getPreviewRows
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
/**
* @param stepname the name of the step to get the preview rows for
* @return A list of rows as the result of the preview run.
*/
public List<Object[]> getPreviewRows(String stepname)
{
if (transDebugMeta==null) return null;
for (StepMeta stepMeta : transDebugMeta.getStepDebugMetaMap().keySet()) {
if (stepMeta.getName().equals(stepname)) {
StepDebugMeta stepDebugMeta = transDebugMeta.getStepDebugMetaMap().get(stepMeta);
return stepDebugMeta.getRowBuffer();
}
}
return null;
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:17,代码来源:TransPreviewProgressDialog.java
示例7: getPreviewRowsMeta
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
/**
* @param stepname the name of the step to get the preview rows for
* @return A description of the row (metadata)
*/
public RowMetaInterface getPreviewRowsMeta(String stepname)
{
if (transDebugMeta==null) return null;
for (StepMeta stepMeta : transDebugMeta.getStepDebugMetaMap().keySet()) {
if (stepMeta.getName().equals(stepname)) {
StepDebugMeta stepDebugMeta = transDebugMeta.getStepDebugMetaMap().get(stepMeta);
return stepDebugMeta.getRowBufferMeta();
}
}
return null;
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:17,代码来源:TransPreviewProgressDialog.java
示例8: TransDebugDialog
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
public TransDebugDialog(Shell parent, TransDebugMeta transDebugMeta) {
super(parent);
this.parent = parent;
this.transDebugMeta = transDebugMeta;
props = PropsUI.getInstance();
// Keep our own map of step debugging information...
//
stepDebugMetaMap = new Hashtable<StepMeta, StepDebugMeta>();
stepDebugMetaMap.putAll(transDebugMeta.getStepDebugMetaMap());
previousIndex=-1;
retval = DEBUG_CANCEL;
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:16,代码来源:TransDebugDialog.java
示例9: refreshStepList
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
private void refreshStepList() {
GUIResource resource = GUIResource.getInstance();
// Add the list of steps...
//
int maxIconSize=0;
int indexSelected = -1;
wSteps.table.removeAll();
for (int i=0;i<transDebugMeta.getTransMeta().getSteps().size();i++) {
StepMeta stepMeta = transDebugMeta.getTransMeta().getStep(i);
TableItem item = new TableItem(wSteps.table, SWT.NONE);
Image image = resource.getImagesSteps().get(stepMeta.getStepID());
item.setImage(0, image);
item.setText(0, "");
item.setText(1, stepMeta.getName());
if (image.getBounds().width>maxIconSize) maxIconSize=image.getBounds().width;
StepDebugMeta stepDebugMeta = stepDebugMetaMap.get(stepMeta);
if (stepDebugMeta!=null) {
// We have debugging information so we mark the row
//
item.setBackground(resource.getColorLightPentaho());
if (indexSelected<0) indexSelected=i;
}
}
wSteps.removeEmptyRows();
wSteps.optWidth(false);
wSteps.table.getColumn(0).setWidth(maxIconSize+10);
wSteps.table.getColumn(0).setAlignment(SWT.CENTER);
// OK, select the first used step debug line...
//
if (indexSelected>=0) {
wSteps.table.setSelection(indexSelected);
showStepDebugInformation();
}
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:41,代码来源:TransDebugDialog.java
示例10: getStepDebugData
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
private void getStepDebugData(StepDebugMeta stepDebugMeta) {
if (stepDebugMeta==null) return;
if (stepDebugMeta.getRowCount()>0) {
wRowCount.setText(Integer.toString(stepDebugMeta.getRowCount()));
}
else {
wRowCount.setText("");
}
wFirstRows.setSelection(stepDebugMeta.isReadingFirstRows());
wPauseBreakPoint.setSelection(stepDebugMeta.isPausingOnBreakPoint());
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:14,代码来源:TransDebugDialog.java
示例11: TransDebugDialog
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
public TransDebugDialog( Shell parent, TransDebugMeta transDebugMeta ) {
super( parent );
this.parent = parent;
this.transDebugMeta = transDebugMeta;
props = PropsUI.getInstance();
// Keep our own map of step debugging information...
//
stepDebugMetaMap = new Hashtable<StepMeta, StepDebugMeta>();
stepDebugMetaMap.putAll( transDebugMeta.getStepDebugMetaMap() );
previousIndex = -1;
retval = DEBUG_CANCEL;
}
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:16,代码来源:TransDebugDialog.java
示例12: getStepDebugData
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
private void getStepDebugData( StepDebugMeta stepDebugMeta ) {
if ( stepDebugMeta == null ) {
return;
}
if ( stepDebugMeta.getRowCount() > 0 ) {
wRowCount.setText( Integer.toString( stepDebugMeta.getRowCount() ) );
} else {
wRowCount.setText( "" );
}
wFirstRows.setSelection( stepDebugMeta.isReadingFirstRows() );
wPauseBreakPoint.setSelection( stepDebugMeta.isPausingOnBreakPoint() );
}
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:15,代码来源:TransDebugDialog.java
示例13: showLastPreviewResults
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
public synchronized void showLastPreviewResults() {
if ( lastTransDebugMeta == null || lastTransDebugMeta.getStepDebugMetaMap().isEmpty() ) {
return;
}
final List<String> stepnames = new ArrayList<>();
final List<RowMetaInterface> rowMetas = new ArrayList<>();
final List<List<Object[]>> rowBuffers = new ArrayList<>();
// Assemble the buffers etc in the old style...
//
for ( StepMeta stepMeta : lastTransDebugMeta.getStepDebugMetaMap().keySet() ) {
StepDebugMeta stepDebugMeta = lastTransDebugMeta.getStepDebugMetaMap().get( stepMeta );
stepnames.add( stepMeta.getName() );
rowMetas.add( stepDebugMeta.getRowBufferMeta() );
rowBuffers.add( stepDebugMeta.getRowBuffer() );
}
getDisplay().asyncExec( new Runnable() {
@Override
public void run() {
EnterPreviewRowsDialog dialog = new EnterPreviewRowsDialog( shell, SWT.NONE, stepnames, rowMetas, rowBuffers );
dialog.open();
}
} );
}
开发者ID:pentaho,项目名称:pentaho-kettle,代码行数:28,代码来源:TransGraph.java
示例14: showPreview
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
public synchronized void showPreview(final TransDebugMeta transDebugMeta, final StepDebugMeta stepDebugMeta,
final RowMetaInterface rowBufferMeta, final List<Object[]> rowBuffer) {
shell.getDisplay().asyncExec(new Runnable() {
public void run() {
if (isDisposed())
return;
spoon.enableMenus();
// The transformation is now paused, indicate this in the log dialog...
//
pausing = true;
setControlStates();
checkErrorVisuals();
PreviewRowsDialog previewRowsDialog = new PreviewRowsDialog(shell, transMeta, SWT.APPLICATION_MODAL,
stepDebugMeta.getStepMeta().getName(), rowBufferMeta, rowBuffer);
previewRowsDialog.setProposingToGetMoreRows(true);
previewRowsDialog.setProposingToStop(true);
previewRowsDialog.open();
if (previewRowsDialog.isAskingForMoreRows()) {
// clear the row buffer.
// That way if you click resume, you get the next N rows for the step :-)
//
rowBuffer.clear();
// Resume running: find more rows...
//
pauseResume();
}
if (previewRowsDialog.isAskingToStop()) {
// Stop running
//
stop();
}
}
});
}
开发者ID:icholy,项目名称:geokettle-2.0,代码行数:46,代码来源:TransGraph.java
示例15: showPreview
import org.pentaho.di.trans.debug.StepDebugMeta; //导入依赖的package包/类
public synchronized void showPreview(final TransDebugMeta transDebugMeta, final StepDebugMeta stepDebugMeta,
final RowMetaInterface rowBufferMeta, final List<Object[]> rowBuffer) {
shell.getDisplay().asyncExec(new Runnable() {
public void run() {
if (isDisposed())
return;
spoon.enableMenus();
// The transformation is now paused, indicate this in the log dialog...
//
pausing = true;
setControlStates();
checkErrorVisuals();
PreviewRowsDialog previewRowsDialog = new PreviewRowsDialog(shell, transMeta, SWT.DIALOG_TRIM | SWT.RESIZE | SWT.MAX | SWT.APPLICATION_MODAL,
stepDebugMeta.getStepMeta().getName(), rowBufferMeta, rowBuffer);
previewRowsDialog.setProposingToGetMoreRows(true);
previewRowsDialog.setProposingToStop(true);
previewRowsDialog.open();
if (previewRowsDialog.isAskingForMoreRows()) {
// clear the row buffer.
// That way if you click resume, you get the next N rows for the step :-)
//
rowBuffer.clear();
// Resume running: find more rows...
//
pauseResume();
}
if (previewRowsDialog.isAskingToStop()) {
// Stop running
//
stop();
}
}
});
}
开发者ID:yintaoxue,项目名称:read-open-source-code,代码行数:46,代码来源:TransGraph.java
注:本文中的org.pentaho.di.trans.debug.StepDebugMeta类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论