---

Clusterer.java

gehe zur Dokumentation dieser Datei

/*
 * $Source: /shared/cvsroot/diplom/app/src/java/de/picana/clusterer/Clusterer.java,v $
 * $Author: mstolpe $
 * $Date: 2003/04/22 09:51:27 $
 * $Revision: 1.8 $
 * $Release$ 
 *
 * Created on 28. Oktober 2002, 00:24
 *
 * Copyright 2002 by Marco Stolpe
 */

package de.picana.clusterer;

import de.picana.control.*;
import de.picana.logging.*;

import weka.core.*;

import java.io.*;


public abstract class Clusterer extends Task {
    
    protected String infile;
    protected String modelfile;
    protected String statfile;
    protected int num_clusters;
    
    protected Instances training_set;
    
    protected PrintWriter statwriter;
    
    
    public Clusterer() {
    }

    
    public void init(ParameterSet params, Logger logger) {
    
        super.init(params, logger);
        
        infile = (String)params.getParameter("training_set");
        modelfile = (String)params.getParameter("model");
        statfile = (String)params.getParameter("statistics");
        
        num_clusters = 10;
        try {
            num_clusters = Integer.parseInt((String)params.getParameter("num_clusters"));
        } catch (NumberFormatException nfe) {}
    }
    
    
    public void start() throws TaskException {
        
        try {
            logger.info(LOGSRC, "Started.");
            
            statwriter = new PrintWriter(new FileOutputStream(new File(statfile), true));
            
            logger.info(LOGSRC, "Read infile '" + infile + "' ...");
            File input = new File(infile);
            FileInputStream fis = new FileInputStream(input);
            InputStreamReader reader = new InputStreamReader(fis);
            training_set = new Instances(reader);
            logger.info(LOGSRC, "reading '" + infile + "' done.");
            logger.info(LOGSRC, "read in " + training_set.numInstances() + " instances.");
         
            logger.info(LOGSRC, "Cluster instances ...");
            buildClusterer(training_set);
            logger.info(LOGSRC, "clustering done.");
            
            logger.info(LOGSRC, "Write model to '" + modelfile + "' ...");
            saveModel(modelfile);
            logger.info(LOGSRC, "written model to '" + modelfile + "'.");
            
            statwriter.close();
            
            logger.info(LOGSRC, "Stopped.");
            
        } catch (Exception e) {
            throw new TaskException(e.toString());   
        }
        
    }
    
    public void stop() {
        
    }
    
    public void pause() {
        
    }
    
    public void resume() {
        
    }
    
    public abstract void buildClusterer(Instances set) throws TaskException ;
    public abstract void saveModel(String filename) throws TaskException;
}

---