|
Oracle Fusion Middleware Java API Reference for Oracle Event Processing 11g Release 1 (11.1.1.7) E14303-11 |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
A event channel is a conduit for events. Event channels support two types of modeling, streams and relations. Streams are append-only, that is, events are always appended to the end of the stream. Relations support events that insert, delete, and update its content. Events send to channels must have non-decreasing time-stamps.
Method Summary | |
java.lang.String |
getEventType() Only events of this event type are allowed to pass through this event channel. |
java.lang.String |
getId() Returns the event channel identity |
java.lang.Integer |
getPartitionOrderCapacity() The capacity (i.e.number of buckets) of partition used for partition-ordered sources (e.g. relation/stream). |
java.util.List |
getPrimaryKey() Returns primary key of relation, or an empty list for streams. |
java.lang.String |
getTimestampExpression() Returns expression used to calculate the application timestamp. |
boolean |
isApplicationTimestamped() Returns if channel is application timestamped, that is, application is responsible for assigning a timestamp to each event. |
boolean |
isBatchEvents() Returns if channel is batching over timestamp |
boolean |
isRelation() Returns if event channel is carrying relations, instead of streams. |
boolean |
isSystemTimestamped() Returns if channel is system timestamped, that is, the system is responsible for assigning a timestamp to each event. |
boolean |
isTotalOrder() Returns if application time published is always strictly greater than the last value used. |
Methods inherited from interface com.bea.wlevs.ede.api.EventQueue |
getCurrentSize, getMaxSize, getMaxThreads, getOfferTimeout, isFailWhenRejected, setFailWhenRejected, setMaxSize, setMaxThreads, setOfferTimeout |
Methods inherited from interface com.bea.wlevs.ede.api.HeartbeatAware |
onHeartbeat |
Methods inherited from interface com.bea.wlevs.ede.api.BatchRelationSink |
onEvents |
Methods inherited from interface com.bea.wlevs.ede.api.BatchStreamSink |
onInsertEvents |
Methods inherited from interface com.bea.wlevs.ede.api.EventSender |
sendEvent |
Methods inherited from interface com.bea.wlevs.ede.api.BatchRelationSender |
sendEvents |
Methods inherited from interface com.bea.wlevs.ede.api.BatchStreamSender |
sendInsertEvents |
Methods inherited from interface com.bea.wlevs.ede.api.RelationSender |
sendDeleteEvent, sendUpdateEvent |
Methods inherited from interface com.bea.wlevs.ede.api.RelationSink |
onDeleteEvent, onUpdateEvent |
Method Detail |
public java.lang.String getId()
public java.lang.String getEventType()
public java.lang.String getTimestampExpression()
expression
- public boolean isRelation()
public java.util.List getPrimaryKey()
public boolean isTotalOrder()
public boolean isSystemTimestamped()
System.nanoTime()
.public boolean isApplicationTimestamped()
public boolean isBatchEvents()
public java.lang.Integer getPartitionOrderCapacity()
|
Copyright © 2007, 2013 Oracle and/or its affiliates. All rights reserved. | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |