public class EventProcessorCmdImpl extends ControllerCommandImpl implements EventProcessorCmd
Analytics Event Configuration
component is enabled, 200
events are fetched and updated from 'process' state (default -10) to
'inProcess' state (default -15). Any qualifying analytics events (events for
stores that are enabled, with the correct type, transport and channel ID's)
in this batch are transformed and then transmitted to the analytics system,
and then updated to purge state. Any non-qualifying events in this batch are
updated to purge state (default -20). This process of fetching and processing
200 events is repeated until the maxBatchSize
analytics events
are processed. If maxBatchSize
is set to -1, then the batching
will continue until all the events in the BUSEVENT table are processed. Analytics Event Configuration
component is disabled or stores
is disabled, up to getMaxEventsToPurge()
(default 500,000)
events in the process state (-10) are deleted from the BUSEVENT table in
batches of 5000. Modifier and Type | Field and Description |
---|---|
static java.lang.String |
COPYRIGHT
IBM Copyright
|
static java.lang.String |
OUTPUT_NONE
The output format for no output, or silent operation.
|
static java.lang.String |
OUTPUT_XML
The output format for an XML result.
|
defaultCommandClassName, NAME, PARAMETER_MAXEVENTS, PARAMETER_OUTPUT, PARAMETER_STOREID
Constructor and Description |
---|
EventProcessorCmdImpl()
Creates an instance of the event processor.
|
Modifier and Type | Method and Description |
---|---|
void |
performExecute()
If
Analytics Event Configuration component is enabled, 200
events are fetched and updated from 'process' state (default -10) to
'inProcess' state (default -15). |
static void |
purgeEvents(int numEventsToPurge,
int processState,
int purgeState)
Updates the CHECKED state of the specified number of events in the BUSEVENT table from 'process' to 'purge'.
|
void |
setMaxEvents(int max)
Sets the maximum number of analytics events to process in this run.
|
void |
setOutput(java.lang.String format)
Sets the output format.
|
void |
setRequestProperties(TypedProperty reqParms)
Gets and stores the command variables by extracting the maximum events,
store identifier and output format from the specified request properties
|
void |
setStoreId(java.lang.Integer storeId)
Sets the ID of the store of which events will be processed
|
checkPermission, fulfills, getForUserId, getGeneric, getOwner, getRequestProperties, getResolvedRequestProperties, getResourceOwners, getResponseProperties, getRetriable, getViewInputProperties, isGeneric, isRetriable, mergeProperties, setForUserId, setGeneric, setOwner, setResponseProperties, setRetriable, setViewInputProperties
accessControlCheck, checkIsAllowed, checkResourcePermission, createCommandExecutionEvent, execute, getAccCheck, getCommandContext, getCommandIfName, getCommandName, getCommandStoreId, getDefaultProperties, getExceptionInvokeParameters, getObjectSize, getPostInvokeParameters, getPreInvokeParameters, getResources, getStoreId, getUser, getUserId, isReadyToCallExecute, reset, setAccCheck, setCommandContext, setCommandIfName, setCommandStoreId, setDefaultProperties, validateParameters
executeFromCache, getCaller, getEntryInfo, getId, getSharingPolicy, postExecute, preExecute, setCaller, setObjectSize, unionDependencies, updateCache
getCommandTarget, getCommandTargetName, getTargetPolicy, hasOutputProperties, setCommandTarget, setCommandTargetName, setHasOutputProperties, setOutputProperties, setTargetPolicy
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
checkPermission, execute, getGeneric, getRequestProperties, getResolvedRequestProperties, getResponseProperties, getRetriable, getViewInputProperties, isGeneric, isRetriable, mergeProperties, setGeneric, setRetriable, setViewInputProperties
executeFromCache, getCaller, getEntryInfo, getId, getSharingPolicy, postExecute, preExecute, setCaller, updateCache
getCommandTarget, getCommandTargetName, hasOutputProperties, setCommandTarget, setCommandTargetName, setOutputProperties
accessControlCheck, getAccCheck, getForUserId, getResourceOwners, setAccCheck, setForUserId, setOwner
checkIsAllowed, checkResourcePermission, createCommandExecutionEvent, getCommandContext, getCommandIfName, getCommandName, getCommandStoreId, getDefaultProperties, getExceptionInvokeParameters, getPostInvokeParameters, getPreInvokeParameters, getResources, getStoreId, getUser, getUserId, setCommandContext, setCommandIfName, setCommandStoreId, setDefaultProperties, validateParameters
fulfills, getOwner
public static final java.lang.String COPYRIGHT
public static final java.lang.String OUTPUT_XML
public static final java.lang.String OUTPUT_NONE
public EventProcessorCmdImpl()
public void setMaxEvents(int max)
setMaxEvents
in interface EventProcessorCmd
max
- the maximum number of events to processpublic void setOutput(java.lang.String format)
setOutput
in interface EventProcessorCmd
format
- One of OUTPUT_XML or OUTPUT_NONE.public void setStoreId(java.lang.Integer storeId)
setStoreId
in interface EventProcessorCmd
storeId
- the ID of the store of which events will be processedpublic void setRequestProperties(TypedProperty reqParms)
setRequestProperties
in interface ControllerCommand
setRequestProperties
in class ControllerCommandImpl
reqParms
- The request properties of the request.ControllerCommand.setRequestProperties(com.ibm.commerce.datatype.TypedProperty)
public void performExecute() throws ECException
Analytics Event Configuration
component is enabled, 200
events are fetched and updated from 'process' state (default -10) to
'inProcess' state (default -15). Any qualifying analytics events (events
for stores that are enabled, with the correct type, transport and channel
ID's) in this batch are transformed and then transmitted to the analytics
system, and then updated to purge state. Any non-qualifying events in
this batch are updated to purge state (default -20). This process of
fetching and processing 200 events is repeated until the
maxBatchSize
analytics events are processed. If
maxBatchSize
is set to -1, then the batching will continue
until all the events in the BUSEVENT table are processed. Analytics Event Configuration
component is disabled or
stores is disabled, up to getMaxEventsToPurge()
(default
500,000) events in the process state (-10) are deleted from the BUSEVENT
table in batches of 5000. performExecute
in interface ECCommand
performExecute
in interface com.ibm.websphere.command.TargetableCommand
performExecute
in class AbstractECTargetableCommand
ECException
public static void purgeEvents(int numEventsToPurge, int processState, int purgeState) throws ECApplicationException
numEventsToPurge
- The maximum number of events to purgeprocessState
- The integer value which represents the process state of an event, by default -10.purgeState
- The integer value which represents the purge state of an event, by default -20.ECApplicationException