import org.pentaho.di.trans.steps.selectvalues.SelectValuesMeta; //导入依赖的package包/类
private StepMeta generateSelectStep() {
  // Only rename the non function fields
  //
  List<SQLField> fields = sql.getSelectFields().getRegularFields();

  SelectValuesMeta meta = new SelectValuesMeta();
  meta.allocate(fields.size(), 0, 0);
  for (int i=0;i<fields.size();i++) {
    SQLField sqlField = fields.get(i);
    meta.getSelectName()[i] = sqlField.getField(); 
    meta.getSelectRename()[i] = sqlField.getAlias();
  }
  
  StepMeta stepMeta = new StepMeta("Select values", meta);
  stepMeta.setLocation(xLocation, 50);
  xLocation+=100;
  stepMeta.setDraw(true);
  return stepMeta;
}
 

import org.pentaho.di.trans.steps.selectvalues.SelectValuesMeta; //导入依赖的package包/类
private StepMeta getSelectValueToChangeTheDataType(GraphConfigurationInfo graphConfiguration,
    int counter) {
  //
  SelectValuesMeta selectValues = new SelectValuesMeta();
  selectValues.allocate(0, 0, 0);
  StepMeta selectValueMeta = new StepMeta(
      GraphGeneratorConstants.SELECT_REQUIRED_VALUE + "Change Dimension And Measure DataType"
          + System.currentTimeMillis() + counter, (StepMetaInterface) selectValues);
  xAxixLocation += 120;
  selectValueMeta.setName("SelectValueToChangeChangeData");
  selectValueMeta.setLocation(xAxixLocation, yAxixLocation);
  selectValueMeta.setDraw(true);
  selectValueMeta.setDescription(
      "Change The Data Type For Measures: " + GraphGeneratorConstants.SELECT_REQUIRED_VALUE);

  String inputQuery = graphConfiguration.getTableInputSqlQuery();
  String[] columns = parseQueryAndReturnColumns(inputQuery);

  SelectMetadataChange[] changeMeta = new SelectMetadataChange[columns.length];
  Map<String, Boolean> measureDatatypeMap =
      getMeasureDatatypeMap(graphConfiguration.getMeasureDataTypeInfo());
  String[] measures = graphConfiguration.getMeasures();
  String dimensionString = graphConfiguration.getActualDimensionColumns();
  String[] dimension = dimensionString.split(CarbonCommonConstants.AMPERSAND_SPC_CHARACTER);

  for (int i = 0; i < columns.length; i++) {
    changeMeta[i] = new SelectMetadataChange(selectValues);
    changeMeta[i].setName(columns[i]);
    changeMeta[i].setType(2);
    if (isMeasureColumn(measures, columns[i]) && isNotDimesnionColumn(dimension, columns[i])) {
      Boolean isString = measureDatatypeMap.get(columns[i]);
      if (isString != null && isString) {
        changeMeta[i].setType(2);
      } else {
        changeMeta[i].setType(6);
      }
    }
    changeMeta[i].setStorageType(0);
  }
  //
  selectValues.setMeta(changeMeta);
  return selectValueMeta;
}
 

import org.pentaho.di.trans.steps.selectvalues.SelectValuesMeta; //导入依赖的package包/类
public SelectValuesDialog(Shell parent, Object in, TransMeta transMeta, String sname)
{
	super(parent, (BaseStepMeta)in, transMeta, sname);
	input=(SelectValuesMeta)in;
       inputFields =new HashMap<String, Integer>();
}
 

import org.pentaho.di.trans.steps.selectvalues.SelectValuesMeta; //导入依赖的package包/类
/**
 * Create a new SelectValues step in between this step and the previous. If
 * the previous fields are not there, no mapping can be made, same with the
 * required fields.
 * 
 * @param stepMeta
 *            The target step to map against.
 */
@SuppressWarnings("deprecation") // retry of required fields acquisition
public void generateFieldMapping(TransMeta transMeta, StepMeta stepMeta) {
	try {
		if (stepMeta != null) {
			StepMetaInterface smi = stepMeta.getStepMetaInterface();
			RowMetaInterface targetFields = smi.getRequiredFields(transMeta);
			if (targetFields.isEmpty()) smi.getRequiredFields(); // retry, get rid of this method in 4.x
			RowMetaInterface sourceFields = transMeta.getPrevStepFields(stepMeta);

			// Build the mapping: let the user decide!!
			String[] source = sourceFields.getFieldNames();
			for (int i = 0; i < source.length; i++) {
				ValueMetaInterface v = sourceFields.getValueMeta(i);
				source[i] += EnterMappingDialog.STRING_ORIGIN_SEPARATOR + v.getOrigin() + ")";
			}
			String[] target = targetFields.getFieldNames();

			EnterMappingDialog dialog = new EnterMappingDialog(shell, source, target);
			List<SourceToTargetMapping> mappings = dialog.open();
			if (mappings != null) {
				// OK, so we now know which field maps where.
				// This allows us to generate the mapping using a
				// SelectValues Step...
				SelectValuesMeta svm = new SelectValuesMeta();
				svm.allocate(mappings.size(), 0, 0);

				for (int i = 0; i < mappings.size(); i++) {
					SourceToTargetMapping mapping = mappings.get(i);
					svm.getSelectName()[i] = sourceFields.getValueMeta(mapping.getSourcePosition()).getName();
					svm.getSelectRename()[i] = target[mapping.getTargetPosition()];
					svm.getSelectLength()[i] = -1;
					svm.getSelectPrecision()[i] = -1;
				}
				// a new comment
				// Now that we have the meta-data, create a new step info
				// object

				String stepName = stepMeta.getName() + " Mapping";
				stepName = transMeta.getAlternativeStepname(stepName); // if it's already there, rename it.

				StepMeta newStep = new StepMeta("SelectValues", stepName, svm);
				newStep.setLocation(stepMeta.getLocation().x + 20, stepMeta.getLocation().y + 20);
				newStep.setDraw(true);

				transMeta.addStep(newStep);
				addUndoNew(transMeta, new StepMeta[] { newStep }, new int[] { transMeta.indexOfStep(newStep) });

				// Redraw stuff...
				refreshTree();
				refreshGraph();
			}
		} else {
			throw new KettleException("There is no target to do a field mapping against!");
		}
	} catch (KettleException e) {
		new ErrorDialog(shell, "Error creating mapping", "There was an error when Kettle tried to generate a field mapping against the target step", e);
	}
}
 

import org.pentaho.di.trans.steps.selectvalues.SelectValuesMeta; //导入依赖的package包/类
/**
 * Create a new SelectValues step in between this step and the previous. If
 * the previous fields are not there, no mapping can be made, same with the
 * required fields.
 * 
 * @param stepMeta
 *            The target step to map against.
 */
// retry of required fields acquisition
public void generateFieldMapping(TransMeta transMeta, StepMeta stepMeta) {
  try {
    if (stepMeta != null) {
      StepMetaInterface smi = stepMeta.getStepMetaInterface();
      RowMetaInterface targetFields = smi.getRequiredFields(transMeta);
      RowMetaInterface sourceFields = transMeta.getPrevStepFields(stepMeta);

      // Build the mapping: let the user decide!!
      String[] source = sourceFields.getFieldNames();
      for (int i = 0; i < source.length; i++) {
        ValueMetaInterface v = sourceFields.getValueMeta(i);
        source[i] += EnterMappingDialog.STRING_ORIGIN_SEPARATOR + v.getOrigin() + ")";
      }
      String[] target = targetFields.getFieldNames();

      EnterMappingDialog dialog = new EnterMappingDialog(shell, source, target);
      List<SourceToTargetMapping> mappings = dialog.open();
      if (mappings != null) {
        // OK, so we now know which field maps where.
        // This allows us to generate the mapping using a
        // SelectValues Step...
        SelectValuesMeta svm = new SelectValuesMeta();
        svm.allocate(mappings.size(), 0, 0);

        for (int i = 0; i < mappings.size(); i++) {
          SourceToTargetMapping mapping = mappings.get(i);
          svm.getSelectName()[i] = sourceFields.getValueMeta(mapping.getSourcePosition()).getName();
          svm.getSelectRename()[i] = target[mapping.getTargetPosition()];
          svm.getSelectLength()[i] = -1;
          svm.getSelectPrecision()[i] = -1;
        }
        // a new comment
        // Now that we have the meta-data, create a new step info
        // object

        String stepName = stepMeta.getName() + " Mapping";
        stepName = transMeta.getAlternativeStepname(stepName); // if
        // it's
        // already
        // there,
        // rename
        // it.

        StepMeta newStep = new StepMeta("SelectValues", stepName, svm);
        newStep.setLocation(stepMeta.getLocation().x + 20, stepMeta.getLocation().y + 20);
        newStep.setDraw(true);

        transMeta.addStep(newStep);
        addUndoNew(transMeta, new StepMeta[] { newStep }, new int[] { transMeta.indexOfStep(newStep) });

        // Redraw stuff...
        refreshTree();
        refreshGraph();
      }
    } else {
      throw new KettleException("There is no target to do a field mapping against!");
    }
  } catch (KettleException e) {
    new ErrorDialog(shell, "Error creating mapping",
        "There was an error when Kettle tried to generate a field mapping against the target step", e);
  }
}
 

import org.pentaho.di.trans.steps.selectvalues.SelectValuesMeta; //导入依赖的package包/类
public SelectValuesDialog( Shell parent, Object in, TransMeta transMeta, String sname ) {
  super( parent, (BaseStepMeta) in, transMeta, sname );
  input = (SelectValuesMeta) in;
  inputFields = new HashMap<String, Integer>();
}
 

import org.pentaho.di.trans.steps.selectvalues.SelectValuesMeta; //导入依赖的package包/类
/**
 * Create a new SelectValues step in between this step and the previous. If the previous fields are not there, no
 * mapping can be made, same with the required fields.
 *
 * @param stepMeta
 *          The target step to map against.
 */
// retry of required fields acquisition
public void generateFieldMapping( TransMeta transMeta, StepMeta stepMeta ) {
  try {
    if ( stepMeta != null ) {
      StepMetaInterface smi = stepMeta.getStepMetaInterface();
      RowMetaInterface targetFields = smi.getRequiredFields( transMeta );
      RowMetaInterface sourceFields = transMeta.getPrevStepFields( stepMeta );

      // Build the mapping: let the user decide!!
      String[] source = sourceFields.getFieldNames();
      for ( int i = 0; i < source.length; i++ ) {
        ValueMetaInterface v = sourceFields.getValueMeta( i );
        source[i] += EnterMappingDialog.STRING_ORIGIN_SEPARATOR + v.getOrigin() + ")";
      }
      String[] target = targetFields.getFieldNames();

      EnterMappingDialog dialog = new EnterMappingDialog( shell, source, target );
      List<SourceToTargetMapping> mappings = dialog.open();
      if ( mappings != null ) {
        // OK, so we now know which field maps where.
        // This allows us to generate the mapping using a
        // SelectValues Step...
        SelectValuesMeta svm = new SelectValuesMeta();
        svm.allocate( mappings.size(), 0, 0 );

        //CHECKSTYLE:Indentation:OFF
        for ( int i = 0; i < mappings.size(); i++ ) {
          SourceToTargetMapping mapping = mappings.get( i );
          svm.getSelectFields()[i].setName( sourceFields.getValueMeta( mapping.getSourcePosition() ).getName() );
          svm.getSelectFields()[i].setRename( target[mapping.getTargetPosition()] );
          svm.getSelectFields()[i].setLength( -1 );
          svm.getSelectFields()[i].setPrecision( -1 );
        }
        // a new comment. Sincerely yours CO ;)
        // Now that we have the meta-data, create a new step info object
        String stepName = stepMeta.getName() + " Mapping";
        stepName = transMeta.getAlternativeStepname( stepName ); // if
        // it's already there, rename it.

        StepMeta newStep = new StepMeta( "SelectValues", stepName, svm );
        newStep.setLocation( stepMeta.getLocation().x + 20, stepMeta.getLocation().y + 20 );
        newStep.setDraw( true );

        transMeta.addStep( newStep );
        addUndoNew( transMeta, new StepMeta[] { newStep }, new int[] { transMeta.indexOfStep( newStep ) } );

        // Redraw stuff...
        refreshTree();
        refreshGraph();
      }
    } else {
      throw new KettleException( "There is no target to do a field mapping against!" );
    }
  } catch ( KettleException e ) {
    new ErrorDialog(
      shell, "Error creating mapping",
      "There was an error when Kettle tried to generate a field mapping against the target step", e );
  }
}