Skip Navigation Links | |
Exit Print View | |
Oracle Java CAPS Intelligent Event Processor (IEP) User's Guide Java CAPS Documentation |
Designing Intelligent Event Processor (IEP) Projects
Intelligent Event Processor Overview
Complex Event Processing and Event Stream Processing
IEP Design-Time and Runtime Components
Creating an Intelligent Event Processing Module Project
To Create an Intelligent Event Processing Module Project
To Add an Event Processor to the Project
Adding and Configuring IEP Operators
To Add IEP Operators to an Event Processor
To Configure IEP Operators in an Event Processor
Disabling the Generation of Bindings and Services
To Disable the Generation of Bindings and Services
Creating and Deploying the Composite Application Project
To Create a Composite Application Project
To Add the IEP Module Project to the Composite Application Project
To Define the Binding Components and Connections
To Deploy the Composite Application Project
IEP Operator Inputs and Outputs
To Create a Relation Aggregator Operator
To Create a Time Based Aggregator Operator
To Create a Tuple Based Aggregator Operator
Correlation and Filter Operators
To Create a Relation Map Operator
To Create a Stream Projection and Filter Operator
To Create a Tuple Serial Correlation Operator
To Create an External Table Polling Stream Operator
To Create a Replay Stream Operator
To Create a Stream Input Operator
To Create a Table Input Operator
To Create a Batched Stream Output Operator
To Create an Invoke Stream Operator
To Create a Relation Output Operator
To Enable the Save Stream Operator Dynamically at Runtime
To Disable the Save Stream Operator Dynamically at Runtime
To Create a Stream Output Operator
To Create a Table Output Operator
To Create a Delete Stream Operator
To Create an Insert Stream Operator
To Create a Notification Stream Operator
To Create a Relation Stream Operator
To Create an Intersect Operator
To Create a Union All Operator
To Create a Contiguous Order Operator:
To Create a Gap Window Operator:
To Create an Attribute Based Window Operator
To Create a Partitioned Window Operator
WSDL Documents in IEP Module Projects
Data Types in the WSDL Document
Message Objects in the WSDL Document
Bindings and Services in the WSDL Document
Generating Concrete WSDL Documents
Generating Abstract WSDL Documents
Understanding the IEP Database
Configuring the IEP Database to Use Oracle
To Create the IEP User in the Oracle Database
To Install the Oracle Database Driver in the Application Server
To Create the Non-XA Connection Pool
To Create the Non-XA JDBC Resource
To Create the XA Connection Pool
To Create the XA JDBC Resource
To Enable Automatic Recovery of XA Transactions
To Configure the IEP Service Engine to Use the JDBC Resources
To Restart the IEP Service Engine and Create the Database Tables
Configuring the IEP Database to Use MySQL
To Create the IEP User in the MySQL Database
To Install the MySQL Database Driver in the Application Server
To Create the Non-XA Connection Pool
To Create the Non-XA JDBC Resource
To Create the XA Connection Pool
To Create the XA JDBC Resource
To Enable Automatic Recovery of XA Transactions
To Configure the IEP Service Engine to Use the JDBC Resources
To Restart the IEP Service Engine and Create the Database Tables
IEP Service Engine-Specific Database Tables
Event Process-Specific Database Tables
Operator-Specific Database Tables
Configuring Message Reliability in an IEP Module Project
Stream Converter operators convert stream data formats into other formats, and can perform additional processing.
The following table lists the input and output for each operator.
|
The Attribute Based Window operator converts an input stream to a relation based on a specified attribute and a size that defines the range of values for the attribute.
Assume that you select an attribute that has the INTEGER data type and that you set the size to 10. If the most recently received event has a value of 50 for the attribute, then the relation consists of all events that have a value of between 40 and 50 for the attribute.
The following data types are supported: INTEGER, BIGINT, DOUBLE, DATE, and TIMESTAMP. You cannot select an attribute that has the VARCHAR data type.
The input to the Attribute Based Window operator is a stream.
The output from the Attribute Based Window operator is a relation.
The property editor opens. The attributes of the input schema are displayed in read-only mode.
The operator determines the lowest value of the range by subtracting the size from the attribute value of the most recently received event.
For attributes with the DATE data type, the size represents the number of days.
For attributes with the TIMESTAMP data type, the size represents the number of seconds.
The Partitioned Window operator converts an input stream to a relation based on one or more attributes that serve as the partition key.
Assume that you have the following scenario:
The input stream contains census data.
You select the LastName attribute.
You set the number of events to 2.
Each relation will consist of the last two events that contain the LastName attribute.
The input to the Partitioned Window operator is a stream.
The output from the Partitioned Window operator is a relation.
The property editor opens. The attributes of the input schema are displayed in read-only mode.
The Time Based Window operator converts an input stream to a relation based on a specified period of time.
Assume that you set the period of time to five seconds. Each relation will consist of all events that arrived in the last five seconds.
The input to the Time Based Window operator is a stream.
The output from the Time Based Window operator is a relation.
You can combine the Time Based Window operator with a subsequent Relation Output operator to provide a timestamp record for the records retained.
The property editor opens. The attributes of the input schema are displayed in read-only mode.
The Tuple Based Window operator converts an input stream to a relation based on a specified number of events.
Assume that you set the number of events to two. Each relation will consist of the most recent two events.
The input to the Tuple Based Window operator is a stream.
The output from the Tuple Based Window operator is a relation.
The property editor opens. The attributes of the input schema are displayed in read-only mode.