• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号
登陆 注册

Java StepIOMetaInterface类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.pentaho.di.trans.step.StepIOMetaInterface类的典型用法代码示例。如果您正苦于以下问题：Java StepIOMetaInterface类的具体用法？Java StepIOMetaInterface怎么用？Java StepIOMetaInterface使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



StepIOMetaInterface类属于org.pentaho.di.trans.step包，在下文中一共展示了StepIOMetaInterface类的19个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: clone

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
public Object clone() {
  MergeJoinMeta retval = (MergeJoinMeta) super.clone();
  int nrKeys1 = keyFields1.length;
  int nrKeys2 = keyFields2.length;
  retval.allocate( nrKeys1, nrKeys2 );
  System.arraycopy( keyFields1, 0, retval.keyFields1, 0, nrKeys1 );
  System.arraycopy( keyFields2, 0, retval.keyFields2, 0, nrKeys2 );

  StepIOMetaInterface stepIOMeta = new StepIOMeta( true, true, false, false, false, false );
  List<StreamInterface> infoStreams = getStepIOMeta().getInfoStreams();

  for ( StreamInterface infoStream : infoStreams ) {
    stepIOMeta.addStream( new Stream( infoStream ) );
  }
  retval.ioMeta = stepIOMeta;

  return retval;
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:19，代码来源:MergeJoinMeta.java


示例2: init

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
/**
 * @see StepInterface#init(org.pentaho.di.trans.step.StepMetaInterface , org.pentaho.di.trans.step.StepDataInterface)
 */
public boolean init( StepMetaInterface smi, StepDataInterface sdi ) {
  meta = (MultiMergeJoinMeta) smi;
  data = (MultiMergeJoinData) sdi;

  if ( super.init( smi, sdi ) ) {
    StepIOMetaInterface stepIOMeta = meta.getStepIOMeta();
    String[] inputStepNames = meta.getInputSteps();
    String inputStepName;
    List<StreamInterface> infoStreams = stepIOMeta.getInfoStreams();
    StreamInterface stream;
    for ( int i = 0; i < infoStreams.size(); i++ ) {
      inputStepName = inputStepNames[i];
      stream = infoStreams.get( i );
      if ( stream.getStepMeta() == null ) {
        logError( BaseMessages.getString( PKG, "MultiMergeJoin.Log.UnableToFindReferenceStream", inputStepName ) );
        return false;
      }
    }
    String joinType = meta.getJoinType();
    for ( int i = 0; i < MultiMergeJoinMeta.join_types.length; ++i ) {
      if ( joinType.equalsIgnoreCase( MultiMergeJoinMeta.join_types[i] ) ) {
        data.optional = MultiMergeJoinMeta.optionals[i];
        return true;
      }
    }
    logError( BaseMessages.getString( PKG, "MultiMergeJoin.Log.InvalidJoinType", meta.getJoinType() ) );
    return false;
  }
  return true;
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:34，代码来源:MultiMergeJoin.java


示例3: firstStreamIsExecutionStatistics

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
@Test
public void firstStreamIsExecutionStatistics() throws Exception {
  StreamInterface stream = mockStream();
  StepIOMetaInterface stepIo = mockStepIo( stream, 0 );

  TransExecutorMeta meta = new TransExecutorMeta();
  meta = spy( meta );

  when( meta.getStepIOMeta() ).thenReturn( stepIo );
  doCallRealMethod().when( meta ).handleStreamSelection( any( StreamInterface.class ) );

  meta.handleStreamSelection( stream );

  assertEquals( stream.getStepMeta(), meta.getExecutionResultTargetStepMeta() );
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:16，代码来源:TransExecutorMetaTest.java


示例4: secondStreamIsInternalTransformationsOutput

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
@Test
public void secondStreamIsInternalTransformationsOutput() throws Exception {
  StreamInterface stream = mockStream();
  StepIOMetaInterface stepIo = mockStepIo( stream, 1 );

  TransExecutorMeta meta = new TransExecutorMeta();
  meta = spy( meta );

  when( meta.getStepIOMeta() ).thenReturn( stepIo );
  doCallRealMethod().when( meta ).handleStreamSelection( any( StreamInterface.class ) );

  meta.handleStreamSelection( stream );

  assertEquals( stream.getStepMeta(), meta.getOutputRowsSourceStepMeta() );
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:16，代码来源:TransExecutorMetaTest.java


示例5: thirdStreamIsExecutionResultFiles

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
@Test
public void thirdStreamIsExecutionResultFiles() throws Exception {
  StreamInterface stream = mockStream();
  StepIOMetaInterface stepIo = mockStepIo( stream, 2 );

  TransExecutorMeta meta = new TransExecutorMeta();
  meta = spy( meta );

  when( meta.getStepIOMeta() ).thenReturn( stepIo );
  doCallRealMethod().when( meta ).handleStreamSelection( any( StreamInterface.class ) );

  meta.handleStreamSelection( stream );

  assertEquals( stream.getStepMeta(), meta.getResultFilesTargetStepMeta() );
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:16，代码来源:TransExecutorMetaTest.java


示例6: forthStreamIsExecutorsInput

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
@Test
public void forthStreamIsExecutorsInput() throws Exception {
  StreamInterface stream = mockStream();
  StepIOMetaInterface stepIo = mockStepIo( stream, 3 );

  TransExecutorMeta meta = new TransExecutorMeta();
  meta = spy( meta );

  when( meta.getStepIOMeta() ).thenReturn( stepIo );
  doCallRealMethod().when( meta ).handleStreamSelection( any( StreamInterface.class ) );

  meta.handleStreamSelection( stream );

  assertEquals( stream.getStepMeta(), meta.getExecutorsOutputStepMeta() );
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:16，代码来源:TransExecutorMetaTest.java


示例7: mockStepIo

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
@SuppressWarnings( "unchecked" )
private static StepIOMetaInterface mockStepIo( StreamInterface stream, int desiredIndex ) {
  List<StreamInterface> list = mock( List.class );
  when( list.indexOf( stream ) ).thenReturn( desiredIndex );
  when( list.get( eq( desiredIndex ) ) ).thenReturn( stream );

  StepIOMetaInterface stepIo = mock( StepIOMetaInterface.class );
  when( stepIo.getTargetStreams() ).thenReturn( list );
  return stepIo;
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:11，代码来源:TransExecutorMetaTest.java


示例8: getIoMeta

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
public StepIOMetaInterface getIoMeta() {
  return ioMeta;
}
开发者ID:matthewtckr，项目名称:pdi-zendesk-plugin，代码行数:4，代码来源:ZendeskInputUsersMeta.java


示例9: setIoMeta

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
public void setIoMeta( StepIOMetaInterface ioMeta ) {
  this.ioMeta = ioMeta;
}
开发者ID:matthewtckr，项目名称:pdi-zendesk-plugin，代码行数:4，代码来源:ZendeskInputUsersMeta.java


示例10: drawLine

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
private void drawLine(StepMeta fs, StepMeta ts, TransHopMeta hi, boolean is_candidate) {
    int line[] = getLine(fs, ts);

    EColor col;
    ELineStyle linestyle=ELineStyle.SOLID;
    int activeLinewidth = linewidth; 
    
    if (is_candidate)
    {
        col = EColor.BLUE;
    }
    else
    {
        if (hi.isEnabled())
        {
            if (fs.isSendingErrorRowsToStep(ts))
            {
                col = EColor.RED;
                linestyle = ELineStyle.DOT;
                activeLinewidth = linewidth+1;
            }
            else
            {
            	col = EColor.BLACK;
            }
        }
        else
        {
            col = EColor.GRAY;
        }
    }
    if (hi.split) activeLinewidth = linewidth+2;

    // Check to see if the source step is an info step for the target step.
    //
    StepIOMetaInterface ioMeta = ts.getStepMetaInterface().getStepIOMeta();
    List<StreamInterface> infoStreams = ioMeta.getInfoStreams();
    if (!infoStreams.isEmpty()) {
    	// Check this situation, the source step can't run in multiple copies!
    	//
    	for (StreamInterface stream : infoStreams) {
    		if (fs.getName().equalsIgnoreCase(stream.getStepname())) {
    			// This is the info step over this hop!
    			//
    			if (fs.getCopies()>1) {
    				// This is not a desirable situation, it will always end in error.
    				// As such, it's better not to give feedback on it.
    				// We do this by drawing an error icon over the hop...
    				//
    				col=EColor.RED;
    			}
    		}
    	}
    }
    
    gc.setForeground(col);
    gc.setLineStyle(linestyle);
    gc.setLineWidth(activeLinewidth);
    
    drawArrow(line, fs, ts);
    
    if (hi.split) gc.setLineWidth(linewidth);

    gc.setForeground(EColor.BLACK);
    gc.setBackground(EColor.BACKGROUND);
    gc.setLineStyle(ELineStyle.SOLID);
}
开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:68，代码来源:TransPainter.java


示例11: testInfoStreams_single

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
/**
 * Tests that info steps are correctly identified via StepMetaInterface.getStepIOMeta()
 */
public void testInfoStreams_single() throws Exception {
  KettleEnvironment.init();
  PluginRegistry registry = PluginRegistry.getInstance();

  //
  // Create a new transformation with a row generator that feeds a Mapping (Sub-Transformation) Step
  //
  TransMeta transMeta = new TransMeta();
  transMeta.setName("Mapping Info Test"); //$NON-NLS-1$
  StepMeta rowGenerator = buildRowGeneratorStep(registry, "Generate Rows"); //$NON-NLS-1$
  transMeta.addStep(rowGenerator);

  String mappingName = "mapping"; //$NON-NLS-1$
  MappingMeta mappingMeta = new MappingMeta();
  mappingMeta.setSpecificationMethod(ObjectLocationSpecificationMethod.FILENAME);
  mappingMeta.setFileName("test/org/pentaho/di/trans/steps/mapping/subtrans.ktr"); //$NON-NLS-1$
  String mappingInputStepName = "input"; //$NON-NLS-1$
  mappingMeta
      .setInputMappings(Collections.singletonList(createMappingDef(rowGenerator.getName(), mappingInputStepName, "string", "a"))); //$NON-NLS-1$ //$NON-NLS-2$
  String mappingPid = registry.getPluginId(StepPluginType.class, mappingMeta);
  StepMeta mapping = new StepMeta(mappingPid, mappingName, mappingMeta);
  transMeta.addStep(mapping);

  TransHopMeta hopGeneratorToMapping = new TransHopMeta(rowGenerator, mapping);
  transMeta.addTransHop(hopGeneratorToMapping);

  Trans trans = new Trans(transMeta);
  trans.prepareExecution(null);

  // Mimic how a transformation is loaded and initialized from TransMeta.loadXML() or KettleDatabaseRepositoryTransDelegate.loadTransformation()
  // so the StepMeta references are wired up in the MappingMeta properly
  // (Copied from TransMeta.loadXML())
  for (int i = 0; i < transMeta.nrSteps(); i++) {
    StepMeta stepMeta = transMeta.getStep(i);
    StepMetaInterface sii = stepMeta.getStepMetaInterface();
    if (sii != null)
      sii.searchInfoAndTargetSteps(transMeta.getSteps());
  }

  // Verify the transformation was configured properly
  assertEquals("Transformation not initialized properly", 2, transMeta.nrSteps()); //$NON-NLS-1$

  StepMeta meta = transMeta.getStep(1);
  assertTrue("Transformation not initialized properly", meta.getStepMetaInterface() instanceof MappingMeta); //$NON-NLS-1$

  MappingMeta loadedMappingMeta = (MappingMeta) meta.getStepMetaInterface();
  assertEquals("Expected a single input mapping definition", 1, loadedMappingMeta.getInputMappings().size()); //$NON-NLS-1$

  StepIOMetaInterface ioMeta = loadedMappingMeta.getStepIOMeta();
  assertEquals("Expected a single Info Stream", 1, ioMeta.getInfoStreams().size()); //$NON-NLS-1$
  assertEquals("Expected a single Info Step", 1, loadedMappingMeta.getInfoSteps().length); //$NON-NLS-1$

  // Verify the transformation can be executed
  StepInterface si = trans.getStepInterface(mappingName, 0);
  RowStepCollector rc = new RowStepCollector();
  si.addRowListener(rc);

  trans.startThreads();
  trans.waitUntilFinished();

  assertEquals(1, rc.getRowsRead().size());
  assertEquals(1, rc.getRowsWritten().size());
}
开发者ID:bsspirit，项目名称:kettle-4.4.0-stable，代码行数:67，代码来源:MappingTest.java


示例12: testInfoStreams_single

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
/**
 * Tests that info steps are correctly identified via StepMetaInterface.getStepIOMeta()
 */
public void testInfoStreams_single() throws Exception {
  KettleEnvironment.init();
  PluginRegistry registry = PluginRegistry.getInstance();

  //
  // Create a new transformation with a row generator that feeds a Mapping (Sub-Transformation) Step
  //
  TransMeta transMeta = new TransMeta();
  transMeta.setName("Mapping Info Test"); //$NON-NLS-1$
  StepMeta rowGenerator = buildRowGeneratorStep(registry, "Generate Rows"); //$NON-NLS-1$
  transMeta.addStep(rowGenerator);

  String mappingName = "mapping"; //$NON-NLS-1$
  MappingMeta mappingMeta = new MappingMeta();
  mappingMeta.setSpecificationMethod(ObjectLocationSpecificationMethod.FILENAME);
  mappingMeta.setFileName("test-src/org/pentaho/di/trans/steps/mapping/subtrans.ktr"); //$NON-NLS-1$
  String mappingInputStepName = "input"; //$NON-NLS-1$
  mappingMeta
      .setInputMappings(Collections.singletonList(createMappingDef(rowGenerator.getName(), mappingInputStepName, "string", "a"))); //$NON-NLS-1$ //$NON-NLS-2$
  String mappingPid = registry.getPluginId(StepPluginType.class, mappingMeta);
  StepMeta mapping = new StepMeta(mappingPid, mappingName, mappingMeta);
  transMeta.addStep(mapping);

  TransHopMeta hopGeneratorToMapping = new TransHopMeta(rowGenerator, mapping);
  transMeta.addTransHop(hopGeneratorToMapping);

  Trans trans = new Trans(transMeta);
  trans.prepareExecution(null);

  // Mimic how a transformation is loaded and initialized from TransMeta.loadXML() or KettleDatabaseRepositoryTransDelegate.loadTransformation()
  // so the StepMeta references are wired up in the MappingMeta properly
  // (Copied from TransMeta.loadXML())
  for (int i = 0; i < transMeta.nrSteps(); i++) {
    StepMeta stepMeta = transMeta.getStep(i);
    StepMetaInterface sii = stepMeta.getStepMetaInterface();
    if (sii != null)
      sii.searchInfoAndTargetSteps(transMeta.getSteps());
  }

  // Verify the transformation was configured properly
  assertEquals("Transformation not initialized properly", 2, transMeta.nrSteps()); //$NON-NLS-1$

  StepMeta meta = transMeta.getStep(1);
  assertTrue("Transformation not initialized properly", meta.getStepMetaInterface() instanceof MappingMeta); //$NON-NLS-1$

  MappingMeta loadedMappingMeta = (MappingMeta) meta.getStepMetaInterface();
  assertEquals("Expected a single input mapping definition", 1, loadedMappingMeta.getInputMappings().size()); //$NON-NLS-1$

  StepIOMetaInterface ioMeta = loadedMappingMeta.getStepIOMeta();
  assertEquals("Expected a single Info Stream", 1, ioMeta.getInfoStreams().size()); //$NON-NLS-1$
  assertEquals("Expected a single Info Step", 1, loadedMappingMeta.getInfoSteps().length); //$NON-NLS-1$

  // Verify the transformation can be executed
  StepInterface si = trans.getStepInterface(mappingName, 0);
  RowStepCollector rc = new RowStepCollector();
  si.addRowListener(rc);

  trans.startThreads();
  trans.waitUntilFinished();

  assertEquals(1, rc.getRowsRead().size());
  assertEquals(1, rc.getRowsWritten().size());
}
开发者ID:jjeb，项目名称:kettle-trunk，代码行数:67，代码来源:MappingTest.java


示例13: testInfoStreams_single

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
/**
 * Tests that info steps are correctly identified via StepMetaInterface.getStepIOMeta()
 */
public void testInfoStreams_single() throws Exception {
  KettleEnvironment.init();
  PluginRegistry registry = PluginRegistry.getInstance();

  //
  // Create a new transformation with a row generator that feeds a Mapping (Sub-Transformation) Step
  //
  TransMeta transMeta = new TransMeta();
  transMeta.setName( "Mapping Info Test" );
  StepMeta rowGenerator = buildRowGeneratorStep( registry, "Generate Rows" );
  transMeta.addStep( rowGenerator );

  String mappingName = "mapping";
  MappingMeta mappingMeta = new MappingMeta();
  mappingMeta.setSpecificationMethod( ObjectLocationSpecificationMethod.FILENAME );
  mappingMeta.setFileName( "test/org/pentaho/di/trans/steps/mapping/subtrans.ktr" );
  String mappingInputStepName = "input";
  mappingMeta.setInputMappings( Collections.singletonList( createMappingDef(
    rowGenerator.getName(), mappingInputStepName, "string", "a" ) ) );
  String mappingPid = registry.getPluginId( StepPluginType.class, mappingMeta );
  StepMeta mapping = new StepMeta( mappingPid, mappingName, mappingMeta );
  transMeta.addStep( mapping );

  TransHopMeta hopGeneratorToMapping = new TransHopMeta( rowGenerator, mapping );
  transMeta.addTransHop( hopGeneratorToMapping );

  Trans trans = new Trans( transMeta );
  trans.prepareExecution( null );

  // Mimic how a transformation is loaded and initialized from TransMeta.loadXML() or
  // KettleDatabaseRepositoryTransDelegate.loadTransformation()
  // so the StepMeta references are wired up in the MappingMeta properly
  // (Copied from TransMeta.loadXML())
  for ( int i = 0; i < transMeta.nrSteps(); i++ ) {
    StepMeta stepMeta = transMeta.getStep( i );
    StepMetaInterface sii = stepMeta.getStepMetaInterface();
    if ( sii != null ) {
      sii.searchInfoAndTargetSteps( transMeta.getSteps() );
    }
  }

  // Verify the transformation was configured properly
  assertEquals( "Transformation not initialized properly", 2, transMeta.nrSteps() );

  StepMeta meta = transMeta.getStep( 1 );
  assertTrue( "Transformation not initialized properly", meta.getStepMetaInterface() instanceof MappingMeta );

  MappingMeta loadedMappingMeta = (MappingMeta) meta.getStepMetaInterface();
  assertEquals( "Expected a single input mapping definition", 1, loadedMappingMeta.getInputMappings().size() );

  StepIOMetaInterface ioMeta = loadedMappingMeta.getStepIOMeta();
  assertEquals( "Expected a single Info Stream", 1, ioMeta.getInfoStreams().size() );
  assertEquals( "Expected a single Info Step", 1, loadedMappingMeta.getInfoSteps().length );

  // Verify the transformation can be executed
  StepInterface si = trans.getStepInterface( mappingName, 0 );
  RowStepCollector rc = new RowStepCollector();
  si.addRowListener( rc );

  trans.startThreads();
  trans.waitUntilFinished();

  assertEquals( 1, rc.getRowsRead().size() );
  assertEquals( 1, rc.getRowsWritten().size() );
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:69，代码来源:MappingIT.java


示例14: getStepIOMeta

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
/**
 * Returns the Input/Output metadata for this step. The generator step only produces output, does not accept input!
 */
public StepIOMetaInterface getStepIOMeta() {
  return new StepIOMeta( false, true, false, false, false, false );
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:7，代码来源:RowGeneratorMeta.java


示例15: getStepIOMeta

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
/**
 * Returns the Input/Output metadata for this step.
 *
 */
@Override
public StepIOMetaInterface getStepIOMeta() {
  return new StepIOMeta( isDynamicCommand(), true, false, false, false, false );
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:9，代码来源:SSHMeta.java


示例16: drawLine

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
private void drawLine( StepMeta fs, StepMeta ts, TransHopMeta hi, boolean is_candidate ) {
  int[] line = getLine( fs, ts );

  EColor col;
  ELineStyle linestyle = ELineStyle.SOLID;
  int activeLinewidth = linewidth;

  EImage arrow;
  if ( is_candidate ) {
    col = EColor.BLUE;
    arrow = EImage.ARROW_CANDIDATE;
  } else {
    if ( hi.isEnabled() ) {
      if ( fs.isSendingErrorRowsToStep( ts ) ) {
        col = EColor.RED;
        linestyle = ELineStyle.DASH;
        activeLinewidth = linewidth + 1;
        arrow = EImage.ARROW_ERROR;
      } else {
        col = EColor.HOP_DEFAULT;
        arrow = EImage.ARROW_DEFAULT;
      }
    } else {
      col = EColor.GRAY;
      arrow = EImage.ARROW_DISABLED;
    }
  }
  if ( hi.split ) {
    activeLinewidth = linewidth + 2;
  }

  // Check to see if the source step is an info step for the target step.
  //
  StepIOMetaInterface ioMeta = ts.getStepMetaInterface().getStepIOMeta();
  List<StreamInterface> infoStreams = ioMeta.getInfoStreams();
  if ( !infoStreams.isEmpty() ) {
    // Check this situation, the source step can't run in multiple copies!
    //
    for ( StreamInterface stream : infoStreams ) {
      if ( fs.getName().equalsIgnoreCase( stream.getStepname() ) ) {
        // This is the info step over this hop!
        //
        if ( fs.getCopies() > 1 ) {
          // This is not a desirable situation, it will always end in error.
          // As such, it's better not to give feedback on it.
          // We do this by drawing an error icon over the hop...
          //
          col = EColor.RED;
          arrow = EImage.ARROW_ERROR;
        }
      }
    }
  }

  gc.setForeground( col );
  gc.setLineStyle( linestyle );
  gc.setLineWidth( activeLinewidth );

  drawArrow( arrow, line, hi, fs, ts );

  if ( hi.split ) {
    gc.setLineWidth( linewidth );
  }

  gc.setForeground( EColor.BLACK );
  gc.setBackground( EColor.BACKGROUND );
  gc.setLineStyle( ELineStyle.SOLID );
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:69，代码来源:TransPainter.java


示例17: testReadLookupValues

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
@Test
public void testReadLookupValues() throws Exception {
  FuzzyMatchData data = spy( new FuzzyMatchData() );
  data.indexOfCachedFields = new int[2];
  data.minimalDistance = 0;
  data.maximalDistance = 5;
  FuzzyMatchMeta meta = spy( new FuzzyMatchMeta() );
  meta.setOutputMatchField( "I don't want NPE here!" );
  data.readLookupValues = true;
  fuzzyMatch =
      new FuzzyMatchHandler( mockHelper.stepMeta, mockHelper.stepDataInterface, 0, mockHelper.transMeta,
          mockHelper.trans );

  fuzzyMatch.init( meta, data );
  RowSet lookupRowSet = mockHelper.getMockInputRowSet( binaryLookupRows );
  fuzzyMatch.getInputRowSets().add( mockHelper.getMockInputRowSet( binaryRows ) );
  fuzzyMatch.getInputRowSets().add( lookupRowSet );
  fuzzyMatch.rowset = lookupRowSet;

  RowMetaInterface rowMetaInterface = new RowMeta();
  ValueMetaInterface valueMeta = new ValueMetaString( "field1" );
  valueMeta.setStorageMetadata( new ValueMetaString( "field1" ) );
  valueMeta.setStorageType( ValueMetaInterface.STORAGE_TYPE_BINARY_STRING );
  rowMetaInterface.addValueMeta( valueMeta );
  when( lookupRowSet.getRowMeta() ).thenReturn( rowMetaInterface );
  when( meta.getLookupField() ).thenReturn( "field1" );
  when( meta.getMainStreamField() ).thenReturn( "field1" );
  fuzzyMatch.setInputRowMeta( rowMetaInterface.clone() );

  when( meta.getAlgorithmType() ).thenReturn( 1 );
  StepIOMetaInterface stepIOMetaInterface = mock( StepIOMetaInterface.class );
  when( meta.getStepIOMeta() ).thenReturn( stepIOMetaInterface );
  StreamInterface streamInterface = mock( StreamInterface.class );
  List<StreamInterface> streamInterfaceList = new ArrayList<StreamInterface>();
  streamInterfaceList.add( streamInterface );
  when( streamInterface.getStepMeta() ).thenReturn( mockHelper.stepMeta );

  when( stepIOMetaInterface.getInfoStreams() ).thenReturn( streamInterfaceList );

  fuzzyMatch.processRow( meta, data );
  Assert.assertEquals( rowMetaInterface.getString( row3B, 0 ),
      data.outputRowMeta.getString( fuzzyMatch.resultRow, 1 ) );
}
开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:44，代码来源:FuzzyMatchTest.java


示例18: getStepIOMeta

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
/**
 * Returns the Input/Output metadata for this step.
 * The generator step only produces output, does not accept input!
 */
public StepIOMetaInterface getStepIOMeta() {
	return new StepIOMeta(false, true, false, false, false, false);
}
开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:8，代码来源:RowGeneratorMeta.java


示例19: getStepIOMeta

import org.pentaho.di.trans.step.StepIOMetaInterface; //导入依赖的package包/类
/**
 * Returns the Input/Output metadata for this step.
 * 
 */
public StepIOMetaInterface getStepIOMeta() {
	return new StepIOMeta(isDynamicCommand(), true, false, false, false, false);
}
开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:8，代码来源:SSHMeta.java



注：本文中的org.pentaho.di.trans.step.StepIOMetaInterface类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花
握手
雷人
路过
鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
More+
上一篇：
Java Marker类代码示例发布时间：2022-05-23
下一篇：
Java IExtensionHost类代码示例发布时间：2022-05-23
热门推荐
More+
热门话题
More+
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服（服务时间 9:00～18:00）

在线QQ客服
地址：深圳市南山区西丽大学城创智工业园
电邮：jeky_zhao#qq.com
移动电话：139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap