Class | Description |
---|---|
ArtifactProducer |
Component responsible for continuously filling a work queue with bundles containing Cas'es.
|
BoundedWorkQueue |
Implementation of a Bounded Queue, a queue with a fixed number of slots.
|
ConsumerCasUtils | |
CPECasPool |
Implements object pooling mechanism to limit number of CAS instances.
|
CPMEngine |
Responsible for creating and initializing processing threads.
|
CPMThreadGroup |
This component catches uncaught errors in the CPM.
|
DebugControlThread | |
EOFToken |
Special class interpreted by the CPM's ProcessingUnit as the end of processing.
|
NonThreadedProcessingUnit | |
ProcessingUnit |
This component executes the processing pipeline.
|
SequencedQueue |
This component extends the Bound Queue by guaranteeing delivery of CASes in sequential order.
|
WorkUnit |
Exception | Description |
---|---|
CPMChunkTimeoutException |
Copyright © 2006–2019 The Apache Software Foundation. All rights reserved.