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

kettle源码部署教程：http://blog.csdn.net/zutsoft/article/details/52998148

/*! ******************************************************************************
 *
 * 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:
  

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件    5617718  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\poi-ooxml-schemas-3.12.jar

     文件     592407  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\postgresql-9.3-1102-jdbc4.jar

     文件     219671  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\rome-1.0.jar

     文件     520806  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\rsyntaxtextarea-1.3.2.jar

     文件      15808  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\sac-1.3.jar

     文件     402219  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\sapdbc-7.4.4.jar

     文件      23262  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\SassyReader-0.5.jar

     文件    5046534  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\saxon-9.1.0.8.jar

     文件     129236  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\saxon-dom-9.1.0.8.jar

     文件      18277  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\scannotation-1.0.2.jar

     文件     177061  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\secondstring-20060615.jar

     文件      43993  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\simple-jndi-1.0.0.jar

     文件      29257  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\slf4j-api-1.7.7.jar

     文件       8870  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\slf4j-log4j12-1.7.7.jar

     文件     253432  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\snakeyaml-1.7.jar

     文件     410710  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\snappy-java-1.1.0.jar

     文件     370448  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\snmp4j-1.9.3d.jar

     文件     338657  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\spring-aop-3.2.14.RELEASE.jar

     文件     614471  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\spring-beans-3.2.14.RELEASE.jar

     文件     868300  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\spring-context-3.2.14.RELEASE.jar

     文件     885640  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\spring-core-3.2.14.RELEASE.jar

     文件     196571  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\spring-expression-3.2.14.RELEASE.jar

     文件     788627  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\spring-security-core-2.0.8.RELEASE.jar

     文件     117045  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\spring-support-2.0.8.jar

     文件    3201133  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\sqlite-jdbc-3.7.2.jar

     文件      26514  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\stax-api-1.0.1.jar

     文件     194278  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\syslog4j-0.9.34.jar

     文件      29512  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\tinybundles-2.0.0.jar

     文件     252914  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\trilead-ssh2-build213.jar

     文件      47433  2016-11-01 19:57  kettle（6.1.0.1-196 MyEclipse源码工程包）\lib\validation-api-1.0.0.GA.jar

............此处省略3749个文件信息