kettle6.1.0.1-196 MyEclipse源码工程包 part3

/*! ******************************************************************************
 *
 * Pentaho Data Integration
 *
 * Copyright （C） 2002-2013 by Pentaho : http://www.pentaho.com
 *
 *******************************************************************************
 *
 * Licensed under the Apache License Version 2.0 （the “License“）;
 * you may not use this file except in compliance with
 * the License. You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing software
 * distributed under the License is distributed on an “AS IS“ BASIS
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 ******************************************************************************/

package org.pentaho.di.trans.steps.aggregaterows;

import org.pentaho.di.core.exception.KettleException;
import org.pentaho.di.core.exception.KettleValueException;
import org.pentaho.di.core.row.RowDataUtil;
import org.pentaho.di.core.row.RowmetaInterface;
import org.pentaho.di.core.row.ValuemetaInterface;
import org.pentaho.di.i18n.baseMessages;
import org.pentaho.di.trans.Trans;
import org.pentaho.di.trans.Transmeta;
import org.pentaho.di.trans.step.baseStep;
import org.pentaho.di.trans.step.StepDataInterface;
import org.pentaho.di.trans.step.StepInterface;
import org.pentaho.di.trans.step.Stepmeta;
import org.pentaho.di.trans.step.StepmetaInterface;

/**
 * Aggregates rows
 *
 * @author Matt
 * @since 2-jun-2003
 */
public class AggregateRows extends baseStep implements StepInterface {
  private static Class PKG = AggregateRows.class; // for i18n purposes needed by Translator2!!

  private AggregateRowsmeta meta;
  private AggregateRowsData data;

  public AggregateRows（ Stepmeta stepmeta StepDataInterface stepDataInterface int copyNr Transmeta transmeta
    Trans trans ） {
    super（ stepmeta stepDataInterface copyNr transmeta trans ）;
  }

  private synchronized void AddAggregate（ RowmetaInterface rowmeta object[] r ） throws KettleValueException {
    for （ int i = 0; i < data.fieldnrs.length; i++ ） {
      ValuemetaInterface valuemeta = rowmeta.getValuemeta（ data.fieldnrs[i] ）;
      object valueData = r[data.fieldnrs[i]];

      if （ !valuemeta.isNull（ valueData ） ） {
        data.counts[i]++; // only count non-zero values!
        switch （ meta.getAggregateType（）[i] ） {
          case AggregateRowsmeta.TYPE_AGGREGATE_SUM:
          case AggregateRowsmeta.TYPE_AGGREGATE_AVERAGE:
            Double number = valuemeta.getNumber（ valueData ）;
            if （ data.values[i] == null ） {
              data.values[i] = number;
            } else {
              data.values[i] = new Double（ （ （Double） data.values[i] ）.doubleValue（） + number.doubleValue（） ）;
            }

            break;
          case AggregateRowsmeta.TYPE_AGGREGATE_MIN: