public abstract class ProcessingContainer extends Resource_ImplBase implements ConfigurableResource, CasProcessorController
PARAM_AGGREGATE_SOFA_MAPPINGS, PARAM_CONFIG_MANAGER, PARAM_CONFIG_PARAM_SETTINGS, PARAM_EXTERNAL_OVERRIDE_SETTINGS, PARAM_PERFORMANCE_TUNING_SETTINGS, PARAM_RESOURCE_MANAGER, PARAM_UIMA_CONTEXT
DISABLED, INITIALIZED, KILLED, NOTINITIALIZED, RUNNING
Constructor and Description |
---|
ProcessingContainer() |
Modifier and Type | Method and Description |
---|---|
abstract boolean |
abortCPMOnError() |
abstract void |
addBytesIn(long aBytesIn) |
abstract void |
addBytesOut(long aBytesOut) |
abstract void |
addStat(String aStatName,
Object aStat) |
abstract int |
getAbortCount() |
abstract HashMap |
getAllStats() |
abstract long |
getBytesIn() |
abstract long |
getBytesOut() |
abstract CasProcessorConfiguration |
getCasProcessorConfiguration() |
abstract CasProcessorDeployer |
getDeployer() |
abstract int |
getFilteredCount() |
abstract Object |
getLastCas() |
abstract String |
getLastProcessedEntityId() |
abstract String |
getName() |
abstract ServiceProxyPool |
getPool() |
abstract long |
getProcessed() |
abstract long |
getRemaining() |
abstract int |
getRestartCount() |
abstract int |
getRetryCount() |
abstract Object |
getStat(String aStatName) |
abstract long |
getTotalTime() |
abstract void |
incrementAbortCount(int aCount) |
abstract void |
incrementCasProcessorErrors(Throwable aThrowable) |
abstract void |
incrementFilteredCount(int aCount) |
abstract void |
incrementRestartCount(int aCount) |
abstract void |
incrementRetryCount(int aCount) |
abstract void |
incrementStat(String aStatName,
Integer aStat) |
abstract void |
incrementTotalTime(long aTime) |
abstract boolean |
isEndOfBatch(CasProcessor aCasProcessor,
int aProcessedSize) |
abstract boolean |
isPaused() |
abstract boolean |
isSingleFencedService() |
abstract void |
logAbortedCases(Object[] abortedCasList) |
abstract void |
pause() |
abstract boolean |
processCas(Object[] aCas) |
abstract void |
releaseCasProcessor(CasProcessor aCasProcessor) |
abstract void |
resetRestartCount() |
abstract void |
resume() |
abstract void |
setCasProcessorDeployer(CasProcessorDeployer aDeployer) |
abstract void |
setLastCas(Object aCasObject) |
abstract void |
setLastProcessedEntityId(String entityId) |
abstract void |
setMetadata(ProcessingResourceMetaData aMetadata) |
abstract void |
setProcessed(long aProcessedCount) |
abstract void |
setRemaining(long aRemainingCount) |
abstract void |
setSingleFencedService(boolean aSingleFencedInstance) |
destroy, getCasManager, getLogger, getMetaData, getResourceManager, getUimaContext, getUimaContextAdmin, initialize, setLogger, setMetaData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConfigParameterValue, getConfigParameterValue, reconfigure, setConfigParameterValue, setConfigParameterValue
destroy, getLogger, getMetaData, getResourceManager, getUimaContext, getUimaContextAdmin, initialize, setLogger
getCasProcessor, getStatus, isAbortable, isIntegrated, isLocal, isRemote, setStatus
public abstract boolean processCas(Object[] aCas)
public abstract void releaseCasProcessor(CasProcessor aCasProcessor)
public abstract String getName()
public abstract boolean isEndOfBatch(CasProcessor aCasProcessor, int aProcessedSize) throws ResourceProcessException, IOException
ResourceProcessException
IOException
public abstract boolean abortCPMOnError()
public abstract void incrementCasProcessorErrors(Throwable aThrowable) throws Exception
Exception
public abstract CasProcessorConfiguration getCasProcessorConfiguration()
public abstract long getProcessed()
public abstract void setProcessed(long aProcessedCount)
public abstract long getBytesIn()
public abstract void addBytesIn(long aBytesIn)
public abstract long getBytesOut()
public abstract void addBytesOut(long aBytesOut)
public abstract void incrementRestartCount(int aCount)
public abstract int getRestartCount()
public abstract void incrementRetryCount(int aCount)
public abstract int getRetryCount()
public abstract void incrementAbortCount(int aCount)
public abstract int getAbortCount()
public abstract void incrementFilteredCount(int aCount)
public abstract int getFilteredCount()
public abstract long getRemaining()
public abstract void setRemaining(long aRemainingCount)
public abstract void setLastProcessedEntityId(String entityId)
public abstract String getLastProcessedEntityId()
public abstract void incrementTotalTime(long aTime)
public abstract long getTotalTime()
public abstract void logAbortedCases(Object[] abortedCasList)
public abstract void setLastCas(Object aCasObject)
public abstract Object getLastCas()
public abstract void setCasProcessorDeployer(CasProcessorDeployer aDeployer)
public abstract CasProcessorDeployer getDeployer()
public abstract void setMetadata(ProcessingResourceMetaData aMetadata)
public abstract HashMap getAllStats()
public abstract void resetRestartCount()
public abstract void pause()
public abstract void resume()
public abstract boolean isPaused()
public abstract ServiceProxyPool getPool()
public abstract void setSingleFencedService(boolean aSingleFencedInstance)
public abstract boolean isSingleFencedService()
Copyright © 2006–2021 The Apache Software Foundation. All rights reserved.