Package org.apache.uima.collection.impl.base_cpm.container

Class ProcessingContainer

java.lang.Object
org.apache.uima.resource.Resource_ImplBase
org.apache.uima.collection.impl.base_cpm.container.ProcessingContainer
All Implemented Interfaces:
CasProcessorController, ConfigurableResource, Resource
Direct Known Subclasses:
ProcessingContainer_Impl
public abstract class ProcessingContainer extends Resource_ImplBase implements ConfigurableResource, CasProcessorController
Base interface for implementing a Container object responsible for managing Cas Processor instances at runtime. Aggregates stats and totals and helps with error recovery.

  • Constructor Details

    • ProcessingContainer

      public ProcessingContainer()

  • Method Details

    • processCas

      public abstract boolean processCas(Object[] aCas)

    • releaseCasProcessor

      public abstract void releaseCasProcessor(CasProcessor aCasProcessor)

    • getName

      public abstract String getName()

    • isEndOfBatch

      public abstract boolean isEndOfBatch(CasProcessor aCasProcessor, int aProcessedSize) throws ResourceProcessException, IOException
      Throws:
      ResourceProcessException
      IOException

    • abortCPMOnError

      public abstract boolean abortCPMOnError()

    • incrementCasProcessorErrors

      public abstract void incrementCasProcessorErrors(Throwable aThrowable) throws Exception
      Throws:
      Exception

    • getCasProcessorConfiguration

      public abstract CasProcessorConfiguration getCasProcessorConfiguration()

    • getProcessed

      public abstract long getProcessed()

    • setProcessed

      public abstract void setProcessed(long aProcessedCount)

    • getBytesIn

      public abstract long getBytesIn()

    • addBytesIn

      public abstract void addBytesIn(long aBytesIn)

    • getBytesOut

      public abstract long getBytesOut()

    • addBytesOut

      public abstract void addBytesOut(long aBytesOut)

    • incrementRestartCount

      public abstract void incrementRestartCount(int aCount)

    • getRestartCount

      public abstract int getRestartCount()

    • incrementRetryCount

      public abstract void incrementRetryCount(int aCount)

    • getRetryCount

      public abstract int getRetryCount()

    • incrementAbortCount

      public abstract void incrementAbortCount(int aCount)

    • getAbortCount

      public abstract int getAbortCount()

    • incrementFilteredCount

      public abstract void incrementFilteredCount(int aCount)

    • getFilteredCount

      public abstract int getFilteredCount()

    • getRemaining

      public abstract long getRemaining()

    • setRemaining

      public abstract void setRemaining(long aRemainingCount)

    • setLastProcessedEntityId

      public abstract void setLastProcessedEntityId(String entityId)

    • getLastProcessedEntityId

      public abstract String getLastProcessedEntityId()

    • incrementTotalTime

      public abstract void incrementTotalTime(long aTime)

    • getTotalTime

      public abstract long getTotalTime()

    • logAbortedCases

      public abstract void logAbortedCases(Object[] abortedCasList)

    • setLastCas

      public abstract void setLastCas(Object aCasObject)

    • getLastCas

      public abstract Object getLastCas()

    • setCasProcessorDeployer

      public abstract void setCasProcessorDeployer(CasProcessorDeployer aDeployer)

    • getDeployer

      public abstract CasProcessorDeployer getDeployer()

    • setMetadata

      public abstract void setMetadata(ProcessingResourceMetaData aMetadata)

    • getAllStats

      public abstract HashMap getAllStats()

    • addStat

      public abstract void addStat(String aStatName, Object aStat)

    • incrementStat

      public abstract void incrementStat(String aStatName, Integer aStat)

    • getStat

      public abstract Object getStat(String aStatName)

    • resetRestartCount

      public abstract void resetRestartCount()

    • pause

      public abstract void pause()

    • resume

      public abstract void resume()

    • isPaused

      public abstract boolean isPaused()

    • getPool

      public abstract ServiceProxyPool getPool()

    • setSingleFencedService

      public abstract void setSingleFencedService(boolean aSingleFencedInstance)

    • isSingleFencedService

      public abstract boolean isSingleFencedService()