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.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ProcessingContainer
public ProcessingContainer()
processCas
public abstract boolean processCas(java.lang.Object[] aCas)
releaseCasProcessor
public abstract void releaseCasProcessor(CasProcessor aCasProcessor)
getName
public abstract java.lang.String getName()
isEndOfBatch
public abstract boolean isEndOfBatch(CasProcessor aCasProcessor,
int aProcessedSize)
throws ResourceProcessException,
java.io.IOException
- Throws:
ResourceProcessException
java.io.IOException
abortCPMOnError
public abstract boolean abortCPMOnError()
incrementCasProcessorErrors
public abstract void incrementCasProcessorErrors(java.lang.Throwable aThrowable)
throws java.lang.Exception
- Throws:
java.lang.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(java.lang.String entityId)
getLastProcessedEntityId
public abstract java.lang.String getLastProcessedEntityId()
incrementTotalTime
public abstract void incrementTotalTime(long aTime)
getTotalTime
public abstract long getTotalTime()
logAbortedCases
public abstract void logAbortedCases(java.lang.Object[] abortedCasList)
setLastCas
public abstract void setLastCas(java.lang.Object aCasObject)
getLastCas
public abstract java.lang.Object getLastCas()
setCasProcessorDeployer
public abstract void setCasProcessorDeployer(CasProcessorDeployer aDeployer)
getDeployer
public abstract CasProcessorDeployer getDeployer()
setMetadata
public abstract void setMetadata(ProcessingResourceMetaData aMetadata)
getAllStats
public abstract java.util.HashMap getAllStats()
addStat
public abstract void addStat(java.lang.String aStatName,
java.lang.Object aStat)
incrementStat
public abstract void incrementStat(java.lang.String aStatName,
java.lang.Integer aStat)
getStat
public abstract java.lang.Object getStat(java.lang.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()
Copyright © 2013. All Rights Reserved.