tags/uima-as-2.3.1-rc3/uimaj-ep-runtime-deployeditor/src/main/java/org/apache/uima/cpe/model/DefaultCasProcessorSettings.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you 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.apache.uima.cpe.model;

import org.apache.uima.collection.metadata.CasProcessorErrorHandling;
import org.apache.uima.collection.metadata.CasProcessorErrorRateThreshold;
import org.apache.uima.collection.metadata.CasProcessorMaxRestarts;
import org.apache.uima.collection.metadata.CasProcessorTimeout;
import org.apache.uima.collection.metadata.CpeCheckpoint;
import org.apache.uima.collection.metadata.CpeDescriptorException;


/**
 * Default settings for each Cas Processor in CPE descriptor.
 *
 */
public class DefaultCasProcessorSettings {
    
    protected CasProcessorErrorHandling errorHandling       = null;
    protected CpeCheckpoint             cpeCheckpoint       = null;
    protected int                       casProcBatchSize    = -1;
    /**
     * 
     */
    public DefaultCasProcessorSettings() {
        super();
    }

    public void removeAll()
    {
        errorHandling = null;
        cpeCheckpoint = null;
        casProcBatchSize = -1;
    }
    /**
     * @return Returns the cpeCheckpoint.
     */
    public CpeCheckpoint getCpeCheckpoint() {
        return cpeCheckpoint;
    }

    /**
     * @param cpeCheckpoint The cpeCheckpoint to set.
     */
    public void setCpeCheckpoint(CpeCheckpoint cpeCheckpoint) {
        this.cpeCheckpoint = cpeCheckpoint;
    }

    /**
     * @return Returns the errorHandling.
     */
    public CasProcessorErrorHandling getErrorHandling() {
        return errorHandling;
    }
    
    public boolean copyErrorHandlingValue (CasProcessorErrorHandling toErrorhandling)
    {
        if (errorHandling == null) {
            // No value to be copied
            return false;
        }
        toErrorhandling.getErrorRateThreshold().setAction(
                errorHandling.getErrorRateThreshold().getAction());        
        toErrorhandling.getErrorRateThreshold().setMaxErrorCount(
                errorHandling.getErrorRateThreshold().getMaxErrorCount());
        toErrorhandling.getErrorRateThreshold().setMaxErrorSampleSize(
                errorHandling.getErrorRateThreshold().getMaxErrorSampleSize());
        
        return true;
    }

    /**
     * @param errorHandling The errorHandling to set.
     */
    public void setErrorHandling(CasProcessorErrorHandling errorHandling) {
        this.errorHandling = errorHandling;
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CpeCheckpoint#getBatchSize()
     */
//    public int getBatchSize() {
//        return cpeCheckpoint.getBatchSize();
//    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CpeCheckpoint#getFilePath()
     */
    public String getFilePath() {
        return cpeCheckpoint.getFilePath();
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CpeCheckpoint#getFrequency()
     */
    public int getFrequency() {
        return cpeCheckpoint.getFrequency();
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CpeCheckpoint#isTimeBased()
     */
    public boolean isTimeBased() {
        return cpeCheckpoint.isTimeBased();
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CpeCheckpoint#setBatchSize(int)
     */
//    public void setBatchSize(int arg0) {
//        cpeCheckpoint.setBatchSize(arg0);
//    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CpeCheckpoint#setFilePath(java.lang.String)
     */
    public void setFilePath(String arg0) throws CpeDescriptorException {
        cpeCheckpoint.setFilePath(arg0);
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CpeCheckpoint#setFrequency(int, boolean)
     */
    public void setFrequency(int arg0, boolean arg1) {
        cpeCheckpoint.setFrequency(arg0, arg1);
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CasProcessorErrorHandling#getErrorRateThreshold()
     */
    public CasProcessorErrorRateThreshold getErrorRateThreshold() {
        return errorHandling.getErrorRateThreshold();
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CasProcessorErrorHandling#getMaxConsecutiveRestarts()
     */
    public CasProcessorMaxRestarts getMaxConsecutiveRestarts() {
        return errorHandling.getMaxConsecutiveRestarts();
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CasProcessorErrorHandling#getTimeout()
     */
    public CasProcessorTimeout getTimeout() {
        return errorHandling.getTimeout();
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CasProcessorErrorHandling#setErrorRateThreshold(org.apache.uima.collection.metadata.CasProcessorErrorRateThreshold)
     */
    public void setErrorRateThreshold(CasProcessorErrorRateThreshold arg0) {
        errorHandling.setErrorRateThreshold(arg0);
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CasProcessorErrorHandling#setMaxConsecutiveRestarts(org.apache.uima.collection.metadata.CasProcessorMaxRestarts)
     */
    public void setMaxConsecutiveRestarts(CasProcessorMaxRestarts arg0) {
        errorHandling.setMaxConsecutiveRestarts(arg0);
    }

    /* (non-Javadoc)
     * @see org.apache.uima.collection.metadata.CasProcessorErrorHandling#setTimeout(org.apache.uima.collection.metadata.CasProcessorTimeout)
     */
    public void setTimeout(CasProcessorTimeout arg0) {
        errorHandling.setTimeout(arg0);
    }

    /**
     * @return Returns the casProcBatchSize.
     */
    public int getCasProcBatchSize() {
        return casProcBatchSize;
    }

    /**
     * @param casProcBatchSize The casProcBatchSize to set.
     */
    public void setCasProcBatchSize(int casProcBatchSize) {
        this.casProcBatchSize = casProcBatchSize;
    }
    public void removeCasProcBatchSize() {
        this.casProcBatchSize = -1;
    }
}