olapengine.java

一个数据挖掘软件ALPHAMINERR的整个过程的JAVA版源代码

/*
 *    This program is free software; you can redistribute it and/or modify
 *    it under the terms of the GNU General Public License as published by
 *    the Free Software Foundation; either version 2 of the License, or
 *    (at your option) any later version.
 *
 *    This program is distributed in the hope that it will be useful,
 *    but WITHOUT ANY WARRANTY; without even the implied warranty of
 *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *    GNU General Public License for more details.
 *
 *    You should have received a copy of the GNU General Public License
 *    along with this program; if not, write to the Free Software
 *    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
 */

 /**
  * Title: XELOPES Data Mining Library
  * Description: The XELOPES library is an open platform-independent and data-source-independent library for Embedded Data Mining.
  * Copyright: Copyright (c) 2002 Prudential Systems Software GmbH
  * Company: ZSoft (www.zsoft.ru), Prudsys (www.prudsys.com)
  * @author Michael Thess
  * @version 1.2
  */

package com.prudsys.pdm.Olap;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Enumeration;
import java.util.Iterator;
import java.util.List;
import java.util.Vector;

import javax.olap.OLAPException;
import javax.olap.resource.ConnectionMetaData;

import com.prudsys.pdm.Core.CategoricalAttribute;
import com.prudsys.pdm.Core.Category;
import com.prudsys.pdm.Core.CategoryHierarchy;
import com.prudsys.pdm.Core.MiningAttribute;
import com.prudsys.pdm.Core.MiningDataSpecification;
import com.prudsys.pdm.Core.MiningException;
import com.prudsys.pdm.Input.MiningArrayStream;
import com.prudsys.pdm.Input.MiningFilterStream;
import com.prudsys.pdm.Input.MiningInputStream;
import com.prudsys.pdm.Input.MiningVector;
import com.prudsys.pdm.Input.Multidimensional.MultidimensionalStream;
import com.prudsys.pdm.Olap.Metadata.CodedLevelClass;
import com.prudsys.pdm.Olap.Metadata.ContentMapClass;
import com.prudsys.pdm.Olap.Metadata.Cube;
import com.prudsys.pdm.Olap.Metadata.CubeClass;
import com.prudsys.pdm.Olap.Metadata.CubeDeploymentClass;
import com.prudsys.pdm.Olap.Metadata.CubeDimensionAssociationClass;
import com.prudsys.pdm.Olap.Metadata.CubeRegionClass;
import com.prudsys.pdm.Olap.Metadata.DeploymentGroupClass;
import com.prudsys.pdm.Olap.Metadata.Dimension;
import com.prudsys.pdm.Olap.Metadata.DimensionClass;
import com.prudsys.pdm.Olap.Metadata.DimensionDeploymentClass;
import com.prudsys.pdm.Olap.Metadata.HierarchicalDimension;
import com.prudsys.pdm.Olap.Metadata.HierarchyClass;
import com.prudsys.pdm.Olap.Metadata.HierarchyLevelAssociationClass;
import com.prudsys.pdm.Olap.Metadata.LevelBasedHierarchyClass;
import com.prudsys.pdm.Olap.Metadata.LevelClass;
import com.prudsys.pdm.Olap.Metadata.MeasureClass;
import com.prudsys.pdm.Olap.Metadata.MeasureDimension;
import com.prudsys.pdm.Olap.Metadata.MemberSelectionClass;
import com.prudsys.pdm.Olap.Metadata.MemberSelectionGroupClass;
import com.prudsys.pdm.Olap.Metadata.SchemaClass;
import com.prudsys.pdm.Olap.Metadata.StructureMapClass;
import com.prudsys.pdm.Olap.Metadata.ValueBasedHierarchyClass;
import com.prudsys.pdm.Olap.Query.Core.CubeView;
import com.prudsys.pdm.Olap.Query.Core.DimensionView;
import com.prudsys.pdm.Olap.Query.Core.EdgeView;
import com.prudsys.pdm.Olap.Query.Core.MeasureView;
import com.prudsys.pdm.Transform.MiningTransformationFactory;
import com.prudsys.pdm.Transform.MiningTransformationStep;
import com.prudsys.pdm.Transform.OneToOne.Categorization;
import com.prudsys.pdm.Utils.IntVector;

/**
 * Xelopes OLAP engine. Takes a multidimensional stream as source
 * and an OLAP schema and runs OLAP queries.
 */
public class OlapEngine extends com.prudsys.pdm.Cwm.Core.RefPackageSupport implements javax.olap.OlapPackage
{
  // -----------------------------------------------------------------------
  //  Variables declarations
  // -----------------------------------------------------------------------
  /** Mining input stream used as OLAP source. */
  protected MiningInputStream inputStream;

  /** Meta data of input stream. */
  protected MiningDataSpecification inputMetaData;

  /** Multidimensional stream as physical OLAP model. */
  protected MultidimensionalStream multiStream;

  /** Meta data of multidimensional stream. */
  protected MiningDataSpecification multiMetaData;

  /** Current OLAP schema. */
  protected javax.olap.metadata.Schema schema;

  /** Indicates that new initialization is required. */
  protected boolean init = false;

  // -----------------------------------------------------------------------
  //  Constructor
  // -----------------------------------------------------------------------
  /**
   * Empty constructor.
   */
  public OlapEngine() {

  }

  // -----------------------------------------------------------------------
  //  Getter and setter methods
  // -----------------------------------------------------------------------
  /**
   * Returns input stream used as OLAP source.
   *
   * @return input stream used as OLAP source
   */
  public MiningInputStream getInputStream() {
    return inputStream;
  }

  /**
   * Sets input stream used as OLAP source.
   *
   * @param inputStream new inputStream for OLAP
   * @exception OLAPException OLAP exception
   */
  public void setInputStream(MiningInputStream inputStream) throws OLAPException  {

    if (inputStream == null)
      throw new OLAPException("input stream object can't be null");
    this.inputStream = inputStream;
    try {
      this.inputMetaData = inputStream.getMetaData();
    }
    catch (MiningException ex) {
      throw new OLAPException("can't get meta data from input stream");
    }
    this.init = false;
  }

  /**
   * Returns meta data of OLAP stream.
   *
   * @return meta data of OLAP stream
   */
  public MiningDataSpecification getInputMetaData() {
    return inputMetaData;
  }

  /**
   * Returns attributes of input stream.
   *
   * @param attName name of requested attribute
   * @return (mining) attribute
   * @throws OLAPException attribute not found in source stream
   */
  public MiningAttribute getInputAttribute(String attName) throws OLAPException {

    MiningAttribute ma = inputMetaData.getMiningAttribute(attName);
    if (ma == null)
      throw new OLAPException("attribute '" + attName + "' not in source input stream");
    return ma;
  }

  /**
   * Returns multidimensional stream of OLAP realization.
   *
   * @return multidimensional stream used for OLAP realization
   */
  public MultidimensionalStream getMultiStream() {
    return multiStream;
  }

  /**
   * Returns meta data of OLAP realization.
   *
   * @return meta data of OLAP realization
   */
  public MiningDataSpecification getMultMetaData() {
    return multiMetaData;
  }

  // ----------------- Methods of OlapPackage interface ------------------
  public javax.olap.metadata.CubeDimensionAssociationClass getCubeDimensionAssociation(){
    return new CubeDimensionAssociationClass();
  }

  public javax.olap.metadata.DimensionClass getDimension(){
    return new DimensionClass(this);
  }

  public javax.olap.metadata.HierarchyClass getHierarchy(){
    return new HierarchyClass();
  }

  public javax.olap.metadata.LevelClass getLevel(){
    return new LevelClass();
  }

  public javax.olap.metadata.LevelBasedHierarchyClass getLevelBasedHierarchy(){
    return new LevelBasedHierarchyClass();
  }

  public javax.olap.metadata.MeasureClass getMeasure(){
    return new MeasureClass(this);
  }

  public javax.olap.metadata.MemberSelectionClass getMemberSelection(){
    return new MemberSelectionClass();
  }

  public javax.olap.serversidemetadata.CodedLevelClass getCodedLevel(){
    return new CodedLevelClass();
  }

  public javax.olap.serversidemetadata.ContentMapClass getContentMap(){
    return new ContentMapClass();
  }

  public javax.olap.serversidemetadata.CubeClass getCube(){
    return new CubeClass(this);
  }

  public javax.olap.serversidemetadata.CubeDeploymentClass getCubeDeployment(){
    return new CubeDeploymentClass();
  }

  public javax.olap.serversidemetadata.CubeRegionClass getCubeRegion(){
    return new CubeRegionClass();
  }

  public javax.olap.serversidemetadata.DeploymentGroupClass getDeploymentGroup(){
    return new DeploymentGroupClass();
  }

  public javax.olap.serversidemetadata.DimensionDeploymentClass getDimensionDeployment(){
    return new DimensionDeploymentClass();
  }

  public javax.olap.serversidemetadata.HierarchyLevelAssociationClass getHierarchyLevelAssociation() {
    return new HierarchyLevelAssociationClass();
  }

  public javax.olap.serversidemetadata.MemberSelectionGroupClass getMemberSelectionGroup() {
    return new MemberSelectionGroupClass();
  }

  public javax.olap.serversidemetadata.SchemaClass getSchema(){
    return new SchemaClass(this);
  }

  public javax.olap.serversidemetadata.StructureMapClass getStructureMap(){
    return new StructureMapClass();
  }

  public javax.olap.serversidemetadata.ValueBasedHierarchyClass getValueBasedHierarchy() {
    return new ValueBasedHierarchyClass();
  }