operatorfactory.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.
 */

/*
 * Created on 2006/8/8
 *
 * @Author: Xiaojun Chen
 * $Revision$ 1.0
 *
 */
package eti.bi.alphaminer.operation.operator;

import java.io.IOException;
import java.io.InputStream;
import java.lang.reflect.Constructor;
import java.util.Iterator;

import eti.bi.alphaminer.core.Node.NodeLoader;
import eti.bi.alphaminer.core.Plugin.NodeInfor_Plugin;
import eti.bi.alphaminer.core.Plugin.PluginFactory;
import eti.bi.alphaminer.core.handler.CaseHandler;
import eti.bi.alphaminer.operation.operator.Operator;
import eti.bi.common.System.SysLog;
import eti.bi.exception.SysException;


/**
 * OperatorFactory is responsible to return a particular Operator which is created
 * based on the given operator type.
 */
public class OperatorFactory {

	public static void loadOperator() throws SysException {
		//load system operator
		NodeLoader.loadNodes();
		
		//load the plugin operator
		loadPlugins();
	}
	
	private static void loadPlugins() {
		try {
			
			if(!PluginFactory.hasLoad()){
				PluginFactory.loadPlugins();
				try {
					PluginFactory.registerAllPlugins();
				}
				catch(Exception e) {
					SysLog.info(null, e);
				}
			}
			
			Iterator<NodeInfor_Plugin> iterator = PluginFactory.getAllRegisteredPluginsNodeDefition();
			String definitionString;
			byte[] bytes;
			int totalread,size;
			NodeInfor_Plugin op;
			InputStream in;
			int index = 0;
			while(iterator.hasNext()){
				op = iterator.next();
				if(op!=null) {
					size = op.size;
					bytes = new byte[size];
					totalread = 0;
					in = op.in;
					while(totalread<size){
						totalread += in.read(bytes, totalread, size-totalread);
					}
					definitionString = new String(bytes);
					NodeLoader.loadNodes(definitionString, op.cl,"",op.localePath,op.jarfile, index++);
					in.close();
				}
				else {
					iterator.remove();
				}
			}
			
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			SysLog.error(null,e);
		} catch (SysException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			SysLog.error(null,e);
		}
	}
	
	public static Operator createOperator(
			String a_CaseID,
			String a_OperatorDefinitionID) throws SysException {

		Operator operator = null;
		NodeInfo nodeInfo = NodeLoader.getNodeInfo(a_OperatorDefinitionID);
		
		// The operatorDefinition ID stored in the XML file is not definied in OperatorDefinition file
		if (nodeInfo==null)
		{
			return null;
		}
		
		String classname = nodeInfo.getOperatorClassName();
		try {
			Class operatorClass = Class.forName(classname,true,nodeInfo.getClassLoader());
			Class [] parameterTypes = {Class.forName("java.lang.String"), Class.forName("eti.bi.alphaminer.operation.operator.INodeInfo"),Class.forName("eti.bi.alphaminer.core.handler.ICaseHandler")};
			Object [] parameters = {a_CaseID, nodeInfo, CaseHandler.getInstance()};
			
			// get class constructor
			Constructor constructor = operatorClass.getConstructor(parameterTypes);
			
			operator = (Operator)constructor.newInstance(parameters);
			//operator.setOperatorDefinitionID(a_OperatorDefinitionID);
		} catch (Exception e) {
			e.printStackTrace();
			throw new SysException(e);
		}
		return operator;
	}
			
	

}