Java TableInputMeta类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: getTableInputStep

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
private StepMeta getTableInputStep(GraphConfigurationInfo configurationInfo)
    throws GraphGeneratorException {
  TableInputMeta tableInput = new TableInputMeta();
  tableInput.setDatabaseMeta(getDatabaseMeta(configurationInfo));
  tableInput.setSQL(configurationInfo.getTableInputSqlQuery());
  //
  StepMeta tableInputStep =
      new StepMeta(GraphGeneratorConstants.TABLE_INPUT, (StepMetaInterface) tableInput);
  xAxixLocation += 120;
  tableInputStep.setLocation(xAxixLocation, yAxixLocation);
  //
  tableInputStep.setDraw(true);
  tableInputStep
      .setDescription("Read Data From Fact Table: " + GraphGeneratorConstants.TABLE_INPUT);

  return tableInputStep;
}

开发者ID:carbondata，项目名称:carbondata，代码行数:18，代码来源:GraphGenerator.java

示例2: getInfo

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
private void getInfo(TableInputMeta meta)
{
    meta.setSQL( wSQL.getText() );
    meta.setDatabaseMeta( transMeta.findDatabase(wConnection.getText()) );
    meta.setRowLimit( Const.toInt(wLimit.getText(), 0) );
    meta.setLookupFromStep( transMeta.findStep( wDatefrom.getText() ) );
    meta.setExecuteEachInputRow(wEachRow.getSelection());
    meta.setVariableReplacementActive(wVariables.getSelection());
    meta.setLazyConversionActive(wLazyConversion.getSelection());
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:11，代码来源:TableInputDialog.java

示例3: preview

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
/**
 * Preview the data generated by this step.
 * This generates a transformation using this step & a dummy and previews it.
 *
 */
private void preview()
{
    // Create the table input reader step...
    TableInputMeta oneMeta = new TableInputMeta();
    getInfo(oneMeta);
    
    TransMeta previewMeta = TransPreviewFactory.generatePreviewTransformation(transMeta, oneMeta, wStepname.getText());
    
    EnterNumberDialog numberDialog = new EnterNumberDialog(shell, props.getDefaultPreviewSize(), Messages.getString("TableInputDialog.EnterPreviewSize"), Messages.getString("TableInputDialog.NumberOfRowsToPreview")); //$NON-NLS-1$ //$NON-NLS-2$
    int previewSize = numberDialog.open();
    if (previewSize>0)
    {
        TransPreviewProgressDialog progressDialog = new TransPreviewProgressDialog(shell, previewMeta, new String[] { wStepname.getText() }, new int[] { previewSize } );
        progressDialog.open();

        Trans trans = progressDialog.getTrans();
        String loggingText = progressDialog.getLoggingText();

        if (!progressDialog.isCancelled())
        {
            if (trans.getResult()!=null && trans.getResult().getNrErrors()>0)
            {
            	EnterTextDialog etd = new EnterTextDialog(shell, Messages.getString("System.Dialog.PreviewError.Title"),  
            			Messages.getString("System.Dialog.PreviewError.Message"), loggingText, true );
            	etd.setReadOnly();
            	etd.open();
            }
        }
        
        PreviewRowsDialog prd =new PreviewRowsDialog(shell, transMeta, SWT.NONE, wStepname.getText(), progressDialog.getPreviewRowsMeta(wStepname.getText()), progressDialog.getPreviewRows(wStepname.getText()), loggingText);
        prd.open();
    }
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:39，代码来源:TableInputDialog.java

示例4: getInfo

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
private void getInfo(TableInputMeta meta, boolean preview)
{
    meta.setSQL(preview && !Const.isEmpty(wSQL.getSelectionText())?wSQL.getSelectionText():wSQL.getText());
    meta.setDatabaseMeta( transMeta.findDatabase(wConnection.getText()) );
    meta.setRowLimit( wLimit.getText() );
    StreamInterface infoStream = input.getStepIOMeta().getInfoStreams().get(0);
    infoStream.setStepMeta( transMeta.findStep( wDatefrom.getText() ) );
    meta.setExecuteEachInputRow(wEachRow.getSelection());
    meta.setVariableReplacementActive(wVariables.getSelection());
    meta.setLazyConversionActive(wLazyConversion.getSelection());
}

开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:12，代码来源:TableInputDialog.java

示例5: preview

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
/**
 * Preview the data generated by this step.
 * This generates a transformation using this step & a dummy and previews it.
 *
 */
private void preview()
{
    // Create the table input reader step...
    TableInputMeta oneMeta = new TableInputMeta();
    getInfo(oneMeta, true);
    
    TransMeta previewMeta = TransPreviewFactory.generatePreviewTransformation(transMeta, oneMeta, wStepname.getText());
    
    EnterNumberDialog numberDialog = new EnterNumberDialog(shell, props.getDefaultPreviewSize(), BaseMessages.getString(PKG, "TableInputDialog.EnterPreviewSize"), BaseMessages.getString(PKG, "TableInputDialog.NumberOfRowsToPreview")); //$NON-NLS-1$ //$NON-NLS-2$
    int previewSize = numberDialog.open();
    if (previewSize>0)
    {
        TransPreviewProgressDialog progressDialog = new TransPreviewProgressDialog(shell, previewMeta, new String[] { wStepname.getText() }, new int[] { previewSize } );
        progressDialog.open();

        Trans trans = progressDialog.getTrans();
        String loggingText = progressDialog.getLoggingText();

        if (!progressDialog.isCancelled())
        {
            if (trans.getResult()!=null && trans.getResult().getNrErrors()>0)
            {
            	EnterTextDialog etd = new EnterTextDialog(shell, BaseMessages.getString(PKG, "System.Dialog.PreviewError.Title"),  
            			BaseMessages.getString(PKG, "System.Dialog.PreviewError.Message"), loggingText, true );
            	etd.setReadOnly();
            	etd.open();
            } 
            else
            {
                PreviewRowsDialog prd =new PreviewRowsDialog(shell, transMeta, SWT.NONE, wStepname.getText(), progressDialog.getPreviewRowsMeta(wStepname.getText()), progressDialog.getPreviewRows(wStepname.getText()), loggingText);
                prd.open();
            }
        }
        
    }
}

开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:42，代码来源:TableInputDialog.java

示例6: getInfo

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
private void getInfo(TableInputMeta meta, boolean preview) {
  meta.setSQL(preview && !Const.isEmpty(wSQL.getSelectionText()) ? wSQL.getSelectionText() : wSQL.getText());
  meta.setDatabaseMeta(transMeta.findDatabase(wConnection.getText()));
  meta.setRowLimit(wLimit.getText());
  StreamInterface infoStream = input.getStepIOMeta().getInfoStreams().get(0);
  infoStream.setStepMeta(transMeta.findStep(wDatefrom.getText()));
  meta.setExecuteEachInputRow(wEachRow.getSelection());
  meta.setVariableReplacementActive(wVariables.getSelection());
  meta.setLazyConversionActive(wLazyConversion.getSelection());
}

开发者ID:jjeb，项目名称:kettle-trunk，代码行数:11，代码来源:TableInputDialog.java

示例7: preview

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
/**
 * Preview the data generated by this step. This generates a transformation
 * using this step & a dummy and previews it.
 * 
 */
private void preview() {
  // Create the table input reader step...
  TableInputMeta oneMeta = new TableInputMeta();
  getInfo(oneMeta, true);

  TransMeta previewMeta = TransPreviewFactory.generatePreviewTransformation(transMeta, oneMeta, wStepname.getText());

  EnterNumberDialog numberDialog = new EnterNumberDialog(shell, props.getDefaultPreviewSize(), BaseMessages.getString(PKG, "TableInputDialog.EnterPreviewSize"), BaseMessages.getString(PKG, "TableInputDialog.NumberOfRowsToPreview")); //$NON-NLS-1$ //$NON-NLS-2$
  int previewSize = numberDialog.open();
  if (previewSize > 0) {
    TransPreviewProgressDialog progressDialog = new TransPreviewProgressDialog(shell, previewMeta, new String[] { wStepname.getText() }, new int[] { previewSize });
    progressDialog.open();

    Trans trans = progressDialog.getTrans();
    String loggingText = progressDialog.getLoggingText();

    if (!progressDialog.isCancelled()) {
      if (trans.getResult() != null && trans.getResult().getNrErrors() > 0) {
        EnterTextDialog etd = new EnterTextDialog(shell, BaseMessages.getString(PKG, "System.Dialog.PreviewError.Title"), BaseMessages.getString(PKG, "System.Dialog.PreviewError.Message"), loggingText, true);
        etd.setReadOnly();
        etd.open();
      } else {
        PreviewRowsDialog prd = new PreviewRowsDialog(shell, transMeta, SWT.NONE, wStepname.getText(), progressDialog.getPreviewRowsMeta(wStepname.getText()), progressDialog.getPreviewRows(wStepname.getText()), loggingText);
        prd.open();
      }
    }

  }
}

开发者ID:jjeb，项目名称:kettle-trunk，代码行数:35，代码来源:TableInputDialog.java

示例8: lazyConversionTurnedOff

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
@Test
public void lazyConversionTurnedOff() throws KettleException {
  KettleEnvironment.init();

  TransMeta transMeta = new TransMeta();

  CsvInputMeta csvInputMeta = new CsvInputMeta();
  csvInputMeta.setLazyConversionActive( true );
  StepMeta csvInput = new StepMeta( "Csv", csvInputMeta );
  transMeta.addStep( csvInput );

  TableInputMeta tableInputMeta = new TableInputMeta();
  tableInputMeta.setLazyConversionActive( true );
  StepMeta tableInput = new StepMeta( "Table", tableInputMeta );
  transMeta.addStep( tableInput );

  Transformation trans = TransMetaConverter.convert( transMeta );

  TransMeta cloneMeta;

  String transMetaXml = (String) trans.getConfig().get( TransMetaConverter.TRANS_META_CONF_KEY );
  Document doc;
  try {
    doc = XMLHandler.loadXMLString( transMetaXml );
    Node stepNode = XMLHandler.getSubNode( doc, "transformation" );
    cloneMeta = new TransMeta( stepNode, null );
  } catch ( KettleXMLException | KettleMissingPluginsException e ) {
    throw new RuntimeException( e );
  }

  assertThat( ( (CsvInputMeta) cloneMeta.findStep( "Csv" ).getStepMetaInterface() ).isLazyConversionActive(),
      is( false ) );
  assertThat( ( (TableInputMeta) cloneMeta.findStep( "Table" ).getStepMetaInterface() ).isLazyConversionActive(),
      is( false ) );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:36，代码来源:TransMetaConverterTest.java

示例9: getInfo

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
private void getInfo( TableInputMeta meta, boolean preview ) {
  meta.setSQL( preview && !Utils.isEmpty( wSQL.getSelectionText() ) ? wSQL.getSelectionText() : wSQL.getText() );
  meta.setDatabaseMeta( transMeta.findDatabase( wConnection.getText() ) );
  meta.setRowLimit( wLimit.getText() );
  StreamInterface infoStream = input.getStepIOMeta().getInfoStreams().get( 0 );
  infoStream.setStepMeta( transMeta.findStep( wDatefrom.getText() ) );
  meta.setExecuteEachInputRow( wEachRow.getSelection() );
  meta.setVariableReplacementActive( wVariables.getSelection() );
  meta.setLazyConversionActive( wLazyConversion.getSelection() );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:11，代码来源:TableInputDialog.java

示例10: get

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
private void get()
{
	Table table = wFields.table;
	for (int i=0;i<transMeta.nrSteps();i++)
	{
		StepMeta stepMeta = transMeta.getStep(i);
		String con=null;
		String tab=null;
		TableItem item=null;
		StepMetaInterface sii = stepMeta.getStepMetaInterface();
		if (sii instanceof TableInputMeta)
		{
			TableInputMeta tii = (TableInputMeta)stepMeta.getStepMetaInterface();
			if (tii.getDatabaseMeta()==null)
			{
				 MessageBox mb = new MessageBox(shell, SWT.OK | SWT.ICON_ERROR);
                    mb.setMessage(Messages.getString("TransDialog.DatabaseMetaNotSet.Text"));
                    mb.open();
                    
                    return;
			}
			con  = tii.getDatabaseMeta().getName();
			tab  = getTableFromSQL(tii.getSQL());
			if (tab==null) tab=stepMeta.getName();
		}
		if (sii instanceof DatabaseLookupMeta)
		{
			DatabaseLookupMeta dvli = (DatabaseLookupMeta)stepMeta.getStepMetaInterface();
			con  = dvli.getDatabaseMeta().getName();
			tab  = dvli.getTablename();
			if (tab==null) tab=stepMeta.getName();
			break;	
		}

		if (tab!=null || con!=null)
		{
			item = new TableItem(table, SWT.NONE);
			if (con!=null) item.setText(1, con);
			if (tab!=null) item.setText(2, tab);
		}
	}
	wFields.setRowNums();
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:44，代码来源:TransDialog.java

示例11: TableInputDialog

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
public TableInputDialog(Shell parent, Object in, TransMeta transMeta, String sname)
{
	super(parent, (BaseStepMeta)in, transMeta, sname);
	input=(TableInputMeta)in;
}

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:6，代码来源:TableInputDialog.java

示例12: testCombinationLookup

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
/**
* Test case for Combination lookup/update.
*/
  public void testCombinationLookup() throws Exception
  {
      EnvUtil.environmentInit();
      try
      {
          //
          // Create a new transformation...
          //
          TransMeta transMeta = new TransMeta();
          transMeta.setName("transname");

          // Add the database connections
          for (int i=0;i<databasesXML.length;i++)
          {
              DatabaseMeta databaseMeta = new DatabaseMeta(databasesXML[i]);
              transMeta.addDatabase(databaseMeta);
          }

          DatabaseMeta lookupDBInfo = transMeta.findDatabase("lookup");

          // Execute our setup SQLs in the database.
          Database lookupDatabase = new Database(lookupDBInfo);
          lookupDatabase.connect();
          createTables(lookupDatabase);
          createData(lookupDatabase);

          StepLoader steploader = StepLoader.getInstance();            

          // 
          // create the source step...
          //
          String fromstepname = "read from [" + source_table + "]";
          TableInputMeta tii = new TableInputMeta();
          tii.setDatabaseMeta(transMeta.findDatabase("lookup"));
          String selectSQL = "SELECT "+Const.CR;
          selectSQL+="DLR_CD, DLR_NM, DLR_DESC ";
          selectSQL+="FROM " + source_table + " ORDER BY ORDNO;";
          tii.setSQL(selectSQL);

          String fromstepid = steploader.getStepPluginID(tii);
          StepMeta fromstep = new StepMeta(fromstepid, fromstepname, (StepMetaInterface) tii);
          fromstep.setLocation(150, 100);
          fromstep.setDraw(true);
          fromstep.setDescription("Reads information from table [" + source_table + "] on database [" + lookupDBInfo + "]");
          transMeta.addStep(fromstep);

          // 
          // create the combination lookup/update step...
          //
          String lookupstepname = "lookup from [lookup]";
          CombinationLookupMeta clm = new CombinationLookupMeta();
          String lookupKey[] = { "DLR_CD" };
          clm.setTablename(target_table);
          clm.setKeyField(lookupKey);
          clm.setKeyLookup(lookupKey);
          clm.setTechnicalKeyField("ID");
          clm.setTechKeyCreation(CombinationLookupMeta.CREATION_METHOD_TABLEMAX);
          clm.setDatabaseMeta(lookupDBInfo);

          String lookupstepid = steploader.getStepPluginID(clm);
          StepMeta lookupstep = new StepMeta(lookupstepid, lookupstepname, (StepMetaInterface) clm);
          lookupstep.setDescription("Looks up information from table [lookup] on database [" + lookupDBInfo + "]");
          transMeta.addStep(lookupstep);                              

          TransHopMeta hi = new TransHopMeta(fromstep, lookupstep);
          transMeta.addTransHop(hi);

          // Now execute the transformation...
          Trans trans = new Trans(transMeta);
          trans.execute(null);            

          trans.waitUntilFinished();            

          checkResults(lookupDatabase);
      }    	
      finally {}    
  }

开发者ID:icholy，项目名称:geokettle-2.0，代码行数:81，代码来源:CombinationLookupTest.java

示例13: get

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
private void get()
{
	Table table = wFields.table;
	for (int i=0;i<transMeta.nrSteps();i++)
	{
		StepMeta stepMeta = transMeta.getStep(i);
		String con=null;
		String tab=null;
		TableItem item=null;
		StepMetaInterface sii = stepMeta.getStepMetaInterface();
		if (sii instanceof TableInputMeta)
		{
			TableInputMeta tii = (TableInputMeta)stepMeta.getStepMetaInterface();
			if (tii.getDatabaseMeta()==null)
			{
				 MessageBox mb = new MessageBox(shell, SWT.OK | SWT.ICON_ERROR);
                    mb.setMessage(BaseMessages.getString(PKG, "TransDialog.DatabaseMetaNotSet.Text"));
                    mb.open();
                    
                    return;
			}
			con  = tii.getDatabaseMeta().getName();
			tab  = getTableFromSQL(tii.getSQL());
			if (tab==null) tab=stepMeta.getName();
		}
		if (sii instanceof DatabaseLookupMeta)
		{
			DatabaseLookupMeta dvli = (DatabaseLookupMeta)stepMeta.getStepMetaInterface();
			con  = dvli.getDatabaseMeta().getName();
			tab  = dvli.getTablename();
			if (tab==null) tab=stepMeta.getName();
			break;	
		}

		if (tab!=null || con!=null)
		{
			item = new TableItem(table, SWT.NONE);
			if (con!=null) item.setText(1, con);
			if (tab!=null) item.setText(2, tab);
		}
	}
	wFields.setRowNums();
}

开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:44，代码来源:TransDialog.java

示例14: testCombinationLookup

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
/**
* Test case for Combination lookup/update.
*/
  public void testCombinationLookup() throws Exception
  {
      KettleEnvironment.init();

      try
      {
          //
          // Create a new transformation...
          //
          TransMeta transMeta = new TransMeta();
          transMeta.setName("transname");

          // Add the database connections
          for (int i=0;i<databasesXML.length;i++)
          {
              DatabaseMeta databaseMeta = new DatabaseMeta(databasesXML[i]);
              transMeta.addDatabase(databaseMeta);
          }

          DatabaseMeta lookupDBInfo = transMeta.findDatabase("lookup");

          // Execute our setup SQLs in the database.
          Database lookupDatabase = new Database(transMeta, lookupDBInfo);
          lookupDatabase.connect();
          createTables(lookupDatabase);
          createData(lookupDatabase);

          PluginRegistry registry = PluginRegistry.getInstance();            

          // 
          // create the source step...
          //
          String fromstepname = "read from [" + source_table + "]";
          TableInputMeta tii = new TableInputMeta();
          tii.setDatabaseMeta(transMeta.findDatabase("lookup"));
          String selectSQL = "SELECT "+Const.CR;
          selectSQL+="DLR_CD, DLR_NM, DLR_DESC ";
          selectSQL+="FROM " + source_table + " ORDER BY ORDNO;";
          tii.setSQL(selectSQL);

          String fromstepid = registry.getPluginId(StepPluginType.class, tii);
          StepMeta fromstep = new StepMeta(fromstepid, fromstepname, (StepMetaInterface) tii);
          fromstep.setLocation(150, 100);
          fromstep.setDraw(true);
          fromstep.setDescription("Reads information from table [" + source_table + "] on database [" + lookupDBInfo + "]");
          transMeta.addStep(fromstep);

          // 
          // create the combination lookup/update step...
          //
          String lookupstepname = "lookup from [lookup]";
          CombinationLookupMeta clm = new CombinationLookupMeta();
          String lookupKey[] = { "DLR_CD" };
          clm.setTablename(target_table);
          clm.setKeyField(lookupKey);
          clm.setKeyLookup(lookupKey);
          clm.setTechnicalKeyField("ID");
          clm.setTechKeyCreation(CombinationLookupMeta.CREATION_METHOD_TABLEMAX);
          clm.setDatabaseMeta(lookupDBInfo);

          String lookupstepid = registry.getPluginId(StepPluginType.class, clm);
          StepMeta lookupstep = new StepMeta(lookupstepid, lookupstepname, (StepMetaInterface) clm);
          lookupstep.setDescription("Looks up information from table [lookup] on database [" + lookupDBInfo + "]");
          transMeta.addStep(lookupstep);                              

          TransHopMeta hi = new TransHopMeta(fromstep, lookupstep);
          transMeta.addTransHop(hi);

          // Now execute the transformation...
          Trans trans = new Trans(transMeta);
          trans.execute(null);            

          trans.waitUntilFinished();            

          checkResults(lookupDatabase);
      }    	
      finally {}    
  }

开发者ID:bsspirit，项目名称:kettle-4.4.0-stable，代码行数:82，代码来源:CombinationLookupTest.java

示例15: generateDimensionTransformation

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
/**
 * Generates a template 
 * @param databaseMeta 
 * @param logicalModel
 * @return
 */
public TransMeta generateDimensionTransformation(DatabaseMeta databaseMeta, LogicalTable logicalTable) {
  TransMeta transMeta = new TransMeta();
  
  String tableName = ConceptUtil.getName(logicalTable, locale);
  String tableDescription = ConceptUtil.getDescription(logicalTable, locale);
  DimensionType dimensionType = ConceptUtil.getDimensionType(logicalTable);
  
  transMeta.setName("Update dimension '"+tableName+"'");
  transMeta.setDescription(tableDescription);
  
  // Let's not forget to add the target database
  // 
  transMeta.addDatabase(databaseMeta);
  
  Point location = new Point(GRAPH_LEFT, GRAPH_TOP);
  
  // Find all the source columns and source tables and put them into a table input step...
  //
  StepMeta inputStep = generateTableInputStepFromLogicalTable(logicalTable);
  DatabaseMeta sourceDatabaseMeta = ((TableInputMeta)inputStep.getStepMetaInterface()).getDatabaseMeta();
  if (sourceDatabaseMeta!=null) transMeta.addOrReplaceDatabase(sourceDatabaseMeta);
  inputStep.setLocation(location.x, location.y);
  nextLocation(location);
  transMeta.addStep(inputStep);
  StepMeta lastStep = inputStep;
  
  // Generate an dimension lookup/update step for each table
  //
  StepMeta dimensionStep;
  if (dimensionType==DimensionType.SLOWLY_CHANGING_DIMENSION) {
    dimensionStep = generateDimensionLookupStepFromLogicalTable(databaseMeta, logicalTable);
  } else {
    dimensionStep = generateCombinationLookupStepFromLogicalTable(databaseMeta, logicalTable);
  }
  dimensionStep.setLocation(location.x, location.y);
  nextLocation(location);
  transMeta.addStep(dimensionStep);
  
  TransHopMeta transHop = new TransHopMeta(lastStep, dimensionStep);
  transMeta.addTransHop(transHop);
  
  return transMeta;
}

开发者ID:jjeb，项目名称:kettle-trunk，代码行数:50，代码来源:JobGenerator.java

示例16: generateTableInputStepFromLogicalTable

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
private StepMeta generateTableInputStepFromLogicalTable(LogicalTable logicalTable) {
  
  String name = ConceptUtil.getName(logicalTable, locale);
  String description = ConceptUtil.getDescription(logicalTable, locale);
  
  TableInputMeta meta = new TableInputMeta();
  
  // Source database, retain first
  // Source table, retain first
  // Source columns, retain all
  //
  DatabaseMeta sourceDatabaseMeta = null;
  String sourceTable = null;
  List<String> sourceColumns = new ArrayList<String>();
  for (LogicalColumn column : logicalTable.getLogicalColumns()) {
    String phDb = ConceptUtil.getString(column, DefaultIDs.LOGICAL_COLUMN_SOURCE_DB);
    String phTable = ConceptUtil.getString(column, DefaultIDs.LOGICAL_COLUMN_SOURCE_TABLE);
    String phCol = ConceptUtil.getString(column, DefaultIDs.LOGICAL_COLUMN_SOURCE_COLUMN);
    if (!Const.isEmpty(phDb) && sourceDatabaseMeta==null) {
      sourceDatabaseMeta = DatabaseMeta.findDatabase(databases, phDb);
    }
    if (!Const.isEmpty(phTable)) {
      sourceTable = phDb;
    }
    if (!Const.isEmpty(phCol)) {
      sourceColumns.add(phCol);
    }
  }
  String sql = "SELECT * FROM --< Source query for dimension '"+name+"'";
  
  meta.setDatabaseMeta(sourceDatabaseMeta);
  
  if (sourceDatabaseMeta!=null && !Const.isEmpty(sourceTable)) {
    sql = "SELECT ";
    if (sourceColumns.isEmpty()) {
      sql+=" * ";
    } else {
      sql+=Const.CR;
    }
    boolean first=true;
    for (String sourceColumn : sourceColumns) {
      if (first) {
        first=false;
      } else {
        sql+="      , ";
      }
      sql+=sourceDatabaseMeta.quoteField(sourceColumn)+Const.CR;
    }
    sql+="FROM "+sourceDatabaseMeta.getQuotedSchemaTableCombination(null, sourceTable);
  }
  meta.setSQL(sql);
  
  // Wrap it up...
  //
  StepMeta stepMeta = new StepMeta("Source data for '"+name+"'", meta);
  stepMeta.drawStep();
  stepMeta.setDescription("Reads data for '"+name+"' : "+description);
  
  return stepMeta;
}

开发者ID:jjeb，项目名称:kettle-trunk，代码行数:61，代码来源:JobGenerator.java

示例17: testCombinationLookup

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
/**
 * Test case for Combination lookup/update.
 */
public void testCombinationLookup() throws Exception {
  //
  // Create a new transformation...
  //
  TransMeta transMeta = new TransMeta();
  transMeta.setName( "transname" );

  // Add the database connections
  for ( int i = 0; i < databasesXML.length; i++ ) {
    DatabaseMeta databaseMeta = new DatabaseMeta( databasesXML[i] );
    transMeta.addDatabase( databaseMeta );
  }

  DatabaseMeta lookupDBInfo = transMeta.findDatabase( "lookup" );

  // Execute our setup SQLs in the database.
  Database lookupDatabase = new Database( transMeta, lookupDBInfo );
  lookupDatabase.connect();
  createTables( lookupDatabase );
  createData( lookupDatabase );

  PluginRegistry registry = PluginRegistry.getInstance();

  //
  // create the source step...
  //
  String fromstepname = "read from [" + source_table + "]";
  TableInputMeta tii = new TableInputMeta();
  tii.setDatabaseMeta( transMeta.findDatabase( "lookup" ) );
  String selectSQL = "SELECT " + Const.CR;
  selectSQL += "DLR_CD, DLR_NM, DLR_DESC ";
  selectSQL += "FROM " + source_table + " ORDER BY ORDNO;";
  tii.setSQL( selectSQL );

  String fromstepid = registry.getPluginId( StepPluginType.class, tii );
  StepMeta fromstep = new StepMeta( fromstepid, fromstepname, tii );
  fromstep.setLocation( 150, 100 );
  fromstep.setDraw( true );
  fromstep.setDescription( "Reads information from table ["
    + source_table + "] on database [" + lookupDBInfo + "]" );
  transMeta.addStep( fromstep );

  //
  // create the combination lookup/update step...
  //
  String lookupstepname = "lookup from [lookup]";
  CombinationLookupMeta clm = new CombinationLookupMeta();
  String[] lookupKey = { "DLR_CD" };
  clm.setTablename( target_table );
  clm.setKeyField( lookupKey );
  clm.setKeyLookup( lookupKey );
  clm.setTechnicalKeyField( "ID" );
  clm.setTechKeyCreation( CombinationLookupMeta.CREATION_METHOD_TABLEMAX );
  clm.setDatabaseMeta( lookupDBInfo );

  String lookupstepid = registry.getPluginId( StepPluginType.class, clm );
  StepMeta lookupstep = new StepMeta( lookupstepid, lookupstepname, clm );
  lookupstep.setDescription( "Looks up information from table [lookup] on database [" + lookupDBInfo + "]" );
  transMeta.addStep( lookupstep );

  TransHopMeta hi = new TransHopMeta( fromstep, lookupstep );
  transMeta.addTransHop( hi );

  // Now execute the transformation...
  Trans trans = new Trans( transMeta );
  trans.execute( null );

  trans.waitUntilFinished();

  checkResults( lookupDatabase );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:75，代码来源:CombinationLookupIT.java

示例18: disableLazyConversion

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
private static void disableLazyConversion( TransMeta transMeta ) {
  transMeta.getSteps().stream().filter( step -> "CsvInput".equals( step.getStepID() ) )
      .forEach( step -> ( (CsvInputMeta) step.getStepMetaInterface() ).setLazyConversionActive( false ) );
  transMeta.getSteps().stream().filter( step -> "TableInput".equals( step.getStepID() ) )
      .forEach( step -> ( (TableInputMeta) step.getStepMetaInterface() ).setLazyConversionActive( false ) );
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:7，代码来源:TransMetaConverter.java

示例19: get

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
private void get() {
  Table table = wFields.table;
  for ( int i = 0; i < transMeta.nrSteps(); i++ ) {
    StepMeta stepMeta = transMeta.getStep( i );
    String con = null;
    String tab = null;
    TableItem item = null;
    StepMetaInterface sii = stepMeta.getStepMetaInterface();
    if ( sii instanceof TableInputMeta ) {
      TableInputMeta tii = (TableInputMeta) stepMeta.getStepMetaInterface();
      if ( tii.getDatabaseMeta() == null ) {
        MessageBox mb = new MessageBox( shell, SWT.OK | SWT.ICON_ERROR );
        mb.setMessage( BaseMessages.getString( PKG, "TransDialog.DatabaseMetaNotSet.Text" ) );
        mb.open();

        return;
      }
      con = tii.getDatabaseMeta().getName();
      tab = getTableFromSQL( tii.getSQL() );
      if ( tab == null ) {
        tab = stepMeta.getName();
      }
    }
    if ( sii instanceof DatabaseLookupMeta ) {
      DatabaseLookupMeta dvli = (DatabaseLookupMeta) stepMeta.getStepMetaInterface();
      con = dvli.getDatabaseMeta().getName();
      tab = dvli.getTablename();
      if ( tab == null ) {
        tab = stepMeta.getName();
      }
      break;
    }

    if ( tab != null || con != null ) {
      item = new TableItem( table, SWT.NONE );
      if ( con != null ) {
        item.setText( 1, con );
      }
      if ( tab != null ) {
        item.setText( 2, tab );
      }
    }
  }
  wFields.setRowNums();
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:46，代码来源:TransDialog.java

示例20: TableInputDialog

import org.pentaho.di.trans.steps.tableinput.TableInputMeta; //导入依赖的package包/类
public TableInputDialog( Shell parent, Object in, TransMeta transMeta, String sname ) {
  super( parent, (BaseStepMeta) in, transMeta, sname );
  input = (TableInputMeta) in;
}

开发者ID:pentaho，项目名称:pentaho-kettle，代码行数:5，代码来源:TableInputDialog.java

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

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java Direct类代码示例发布时间：2022-05-23

Java GitHubRequest类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：17914|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9549|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8116|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8496|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8401|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9288|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8365|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7794|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8346|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7352|2022-11-06

客服电话

电子邮件

Java TableInputMeta类代码示例

示例1: getTableInputStep

示例2: getInfo

示例3: preview

示例4: getInfo

示例5: preview

示例6: getInfo

示例7: preview

示例8: lazyConversionTurnedOff

示例9: getInfo

示例10: get

示例11: TableInputDialog

示例12: testCombinationLookup

示例13: get

示例14: testCombinationLookup

示例15: generateDimensionTransformation

示例16: generateTableInputStepFromLogicalTable

示例17: testCombinationLookup

示例18: disableLazyConversion

示例19: get

示例20: TableInputDialog

请发表评论

全部评论

上一篇：

下一篇：

GitbookIO/gitbook:

takuoka/TKSubmitTransition: Animated UIB

juleswhite/mobile-cloud-asgn1

kyamagu/matlab-json: Use official API: h

墙壁眼睛膝盖

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053