public final class GenerateStatsCdrProcessor extends CdrProcessorAdapter
Gathers statistics related to:
By default statistics are output to standard error (stderr).CONTINUE_ON_ERROR_PROPERTY
Constructor and Description |
---|
GenerateStatsCdrProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Called to indicate to a
CdrProcessor that the processor is being taken out of service. |
void |
initialize(Properties properties)
This method is called from
CdrProcessorAdapter.init(Properties) and may be overridden to customize the initialization process. |
boolean |
processBinaryCdr(com.opencloud.slee.resources.cdr.protobuf.CdrFileFormat.CdrFile.BinaryCDR binaryCdr,
com.google.protobuf.Descriptors.Descriptor descriptor,
com.opencloud.slee.resources.cdr.protobuf.CdrFileFormat.CdrFile.DateTime timeStamp,
com.google.protobuf.ExtensionRegistry registry)
Called when encountering a binary CDR in CDR file.
|
void |
processedFile(String path)
Called after processing all data contained in file denoted by
path . |
void |
processingFile(String path)
Called before processing any data contained in file denoted by
path . |
boolean |
processStringCdr(com.opencloud.slee.resources.cdr.protobuf.CdrFileFormat.CdrFile.StringCDR stringCdr,
com.opencloud.slee.resources.cdr.protobuf.CdrFileFormat.CdrFile.DateTime timeStamp)
Called when encountering a string CDR in CDR file.
|
getContinueOnError, init, processFooter, processHeader
public void initialize(Properties properties)
CdrProcessorAdapter
CdrProcessorAdapter.init(Properties)
and may be overridden to customize the initialization process.initialize
in class CdrProcessorAdapter
properties
- properties provided using "processor-property" options when invoking CdrPipeline
.public void destroy()
CdrProcessor
CdrProcessor
that the processor is being taken out of service.
This method is called only once and only if previous invocation of init
did NOT throw an exception.
After call to this method no further calls are invoked on CdrProcessor
instance.destroy
in interface CdrProcessor
destroy
in class CdrProcessorAdapter
public void processingFile(String path)
CdrProcessor
path
.processingFile
in interface CdrProcessor
processingFile
in class CdrProcessorAdapter
path
- path denoting the CDR file to be processed.public void processedFile(String path)
CdrProcessor
path
.processedFile
in interface CdrProcessor
processedFile
in class CdrProcessorAdapter
path
- path denoting the CDR file that was processed.public boolean processBinaryCdr(com.opencloud.slee.resources.cdr.protobuf.CdrFileFormat.CdrFile.BinaryCDR binaryCdr, com.google.protobuf.Descriptors.Descriptor descriptor, com.opencloud.slee.resources.cdr.protobuf.CdrFileFormat.CdrFile.DateTime timeStamp, com.google.protobuf.ExtensionRegistry registry)
CdrProcessor
processBinaryCdr
in interface CdrProcessor
processBinaryCdr
in class CdrProcessorAdapter
binaryCdr
- BinaryCDR
record encapsulating the bytes of CDR Message
.descriptor
- Descriptor
of the CDR Message
.timeStamp
- timestamp when the record was written.registry
- ExtensionRegistry
to properly decode extension fields of the CDR Message
.CdrProcessor
in pipeline, false otherwise.public boolean processStringCdr(com.opencloud.slee.resources.cdr.protobuf.CdrFileFormat.CdrFile.StringCDR stringCdr, com.opencloud.slee.resources.cdr.protobuf.CdrFileFormat.CdrFile.DateTime timeStamp)
CdrProcessor
processStringCdr
in interface CdrProcessor
processStringCdr
in class CdrProcessorAdapter
stringCdr
- string representing the CDR.timeStamp
- timestamp when the record was written.CdrProcessor
in pipeline, false otherwise.