public class CpeDescriptorFactory extends Object
Constructor and Description |
---|
CpeDescriptorFactory() |
public static CpeDescription produceDescriptor()
public static CpeDescription produceDescriptor(XMLInputSource aInput) throws InvalidXMLException
aInput
- identifies the input fileInvalidXMLException
- if the descriptor is invalidpublic static CpeDescription produceDescriptor(InputStream aInput) throws InvalidXMLException
aInput
- identifies the input streamInvalidXMLException
- if the descriptor is invalidpublic static CpeCollectionReader produceCollectionReader(String aCollectionReaderDescriptorPath, CpeDescription aDescriptor) throws CpeDescriptorException
aCollectionReaderDescriptorPath
- a path to the collection reader descriptoraDescriptor
- the descriptor to associate the collection reader withCpeDescriptorException
- if there is a failurepublic static CpeCollectionReader produceCollectionReader(String aCollectionReaderDescriptorPath) throws CpeDescriptorException
CpeDescriptorException
public static CpeCollectionReader produceCollectionReader() throws CpeDescriptorException
CpeDescriptorException
public static CpeCollectionReaderIterator produceCollectionReaderIterator(String aPath) throws CpeDescriptorException
CpeDescriptorException
@Deprecated public static CpeCollectionReaderCasInitializer produceCollectionReaderCasInitializer(String aPath, CpeDescription aDescriptor) throws CpeDescriptorException
aPath
- don't useaDescriptor
- don't useCpeDescriptorException
- passed thru@Deprecated protected static CpeCollectionReaderCasInitializer produceCollectionReaderCasInitializer(String aInitializerDescriptorPath)
aInitializerDescriptorPath
- path to the initializer descriptorpublic static CpeComponentDescriptor produceComponentDescriptor(String aPath)
aPath
- The path to the the CPE component Descriptorpublic static CpeConfiguration produceCpeConfiguration(CpeDescription aDescriptor) throws CpeDescriptorException
aDescriptor
- CPE descriptor to useCpeDescriptorException
- if it failspublic static CpeConfiguration produceCpeConfiguration() throws CpeDescriptorException
CpeDescriptorException
public static CasProcessorRuntimeEnvParam produceRuntimeEnvParam()
public static CasProcessorDeploymentParams produceDeployParams()
public static CasProcessorDeploymentParam produceDeployParam()
public static CpeInclude produceComponentDescriptorInclude()
public static CpeCasProcessors produceCasProcessors(CpeDescription aDescriptor) throws CpeDescriptorException
aDescriptor
- to use to produce the CPE CAS ProcessorsCpeDescriptorException
- if an error occurspublic static CpeCasProcessors produceCasProcessors() throws CpeDescriptorException
CpeDescriptorException
public static CpeCasProcessors produceCasProcessors(int aInputQSize, int aOutputQSize, int aPuCount, CpeDescription aDescriptor) throws CpeDescriptorException
aInputQSize
- the input queue sizeaOutputQSize
- the output queue sizeaPuCount
- the number of processing unitsaDescriptor
- the CPE descriptorCpeDescriptorException
- if an error occurspublic static CpeIntegratedCasProcessor produceCasProcessor(String aName)
public static CpeLocalCasProcessor produceLocalCasProcessor(String aName, String aSoFa) throws CpeDescriptorException
aName
- the processor nameaSoFa
- the processor SofACpeDescriptorException
- if an error occurspublic static CpeRemoteCasProcessor produceRemoteCasProcessor(String aName) throws CpeDescriptorException
aName
- the processor nameCpeDescriptorException
- if an error occurspublic static CpeResourceManagerConfiguration produceResourceManagerConfiguration(String aResourceMgrConfigurationPath, CpeDescription aDescriptor) throws CpeDescriptorException
CpeDescriptorException
public static CpeResourceManagerConfiguration produceResourceManagerConfiguration(String aResourceMgrConfigurationPath) throws CpeDescriptorException
CpeDescriptorException
public static CasProcessorTimeout produceCasProcessorTimeout()
public static CasProcessorMaxRestarts produceCasProcessorMaxRestarts()
public static CasProcessorErrorRateThreshold produceCasProcessorErrorRateThreshold()
public static CasProcessorFilter produceCasProcessorFilter(String aFilter)
aFilter
- the filter stringpublic static CasProcessorErrorHandling produceCasProcessorErrorHandling()
public static CpeCheckpoint produceCpeCheckpoint()
public static CasProcessorDeploymentParams produceCasProcessorDeploymentParams()
public static CasProcessorExecArg produceCasProcessorExecArg()
public static CasProcessorExecutable produceCasProcessorExecutable()
public static CasProcessorRunInSeperateProcess produceRunInSeperateProcess()
public static CasProcessorConfigurationParameterSettings produceCasProcessorConfigurationParameterSettings()
public static NameValuePair produceNameValuePair()
public static CpeSofaMapping produceSofaMapping()
public static CpeSofaMappings produceSofaMappings()
Copyright © 2006–2017 The Apache Software Foundation. All rights reserved.