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
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
To Create a Time Based Window Operator
To Create a Tuple Based 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
The IEP operators enable you to define the logic in an event processor.
Most of the IEP operators take a stream or a relation as input and produce a stream or a relation as output.
A schema defines the types of information that a set of data contains. A schema consists of one or more attributes. Each attribute is identified by a name and has a data type that specifies the allowed values.
For example, a schema could consist of the following attributes:
An attribute called Symbol that allows character values of between 1 and 10 characters
An attribute called Price that allows floating-point values
A stream is a series of timestamped events that have the same schema.
Assume that a stream has the following characteristics:
Each event represents a stock transaction.
The schema consists of the stock symbol and the stock price.
The following table shows an example of the events in the stream during a brief interval of time.
|
A relation is a collection of events that match a user-defined condition at a point in time.
You can define the condition in various ways. For example:
All events that arrived in the last five seconds
All events that arrived in the last five hours
The most recent two events
Assume that you define the condition as all events that arrived in the last five seconds. For the example in Understanding Streams, the relation at time 2008-12-15-T10:35:00:000-05.00 would consist of the following events.
|
Let's move forward one second in time. The relation at time 2008-12-15-T10:36:00:000-05.00 would consist of the following events. Compared with the previous relation, one event has dropped out and one event has been added.
|
The relation at time 2008-12-15-T10:37:00:000-05.00 would consist of the following events. This relation has the same events as the previous relation.
|
The relation at time 2008-12-15-T10:38:00:000-05.00 would consist of the following events. Compared with the previous relation, one event has dropped out.
|
The relation at time 2008-12-15-T10:39:00:000-05.00 would consist of the following events. Compared with the previous relation, one event has been added.
|
A relation can be empty. For the example in Understanding Streams, the relation at time 2008-12-15-T10:45:00:000-05.00 would not contain any events because none of the events arrived in the last five seconds.
In the property editor of an IEP operator, you can assign any of the following data types to an attribute:
INTEGER
BIGINT
DOUBLE
VARCHAR
DATE
TIMESTAMP
The Size and Scale columns are disabled for the DATE and TIMESTAMP data types.
You must ensure that input and output data types are appropriately matched.
You can categorize the IEP operators by their input and outputs.
Stream to Relation. Operators that take a stream as input, and produce a relation as output with the same schema as the stream.
Relation to Stream. Operators that take a relation as input, and produce a stream as output with the same schema as the relation.
Relation to Relation. Operators that take one or more relations as input, and produce a relation as output.
Stream to Stream. Operators that take a stream as input, and produce a stream as output. The input stream and the output stream can have different schemas.
Relation to Table. Operators that take a relation as input, and produce a table as output.
For specific information about each IEP operator, see the following topics: