public class AuditQueueCollection
extends com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
Title: Dataspace Framework
Description: Audit Queue collection implementation.
Copyright: Copyright (c) 2010
Company: StreamScape Technologies
AbstractQueueCollection.KeyValue
SchemaObject.ConstraintTypes, SchemaObject.Deferable, SchemaObject.Nullability, SchemaObject.ParameterModes, SchemaObject.ReferentialAction, SchemaObject.ViewCheckModes
ACTOR, ASPECTS, ASSERTION, CATALOG, CHARSET, COLLATION, COLLECTION, COLUMN, CONNECTION_FACTORY, CONSTRAINT, CURSOR, DOMAIN, emptyArray, EVENT_PROTOTYPE, FACETS, FILE_DESCRIPTOR, FULL_TEXT_INDEX, FUNCTION, GRANTEE, INDEX, JOB, LABEL, PARAMETER, PROCEDURE, REFERENCE_LINK, REPLICA, REPLICATION_SOURCE, ROUTINE, SCHEMA, SEMANTIC_TYPE, SEQUENCE, SERVER, SPECIFIC_ROUTINE, SUBQUERY, TABLE, TIMER, TRANSIENT_VAR, TRANSITION, TRIGGER, TYPE, VARIABLE, VIEW, WRAPPER
Constructor and Description |
---|
AuditQueueCollection(DataspaceStore store,
NameManager.ObjectName name,
com.streamscape.ds.core.MemoryModel memoryModel,
boolean isConsumer,
boolean isConsumerAsync) |
Modifier and Type | Method and Description |
---|---|
void |
activateWindow(com.streamscape.ds.session.Session session,
NameManager.ObjectName internalTableName) |
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
void |
compileInternalStatements(com.streamscape.ds.session.Session session) |
boolean |
contains(com.streamscape.ds.session.Session session,
java.lang.Object o) |
boolean |
dropAuditForProcessInstance(com.streamscape.ds.session.Session session,
java.lang.String serviceGroup,
java.lang.String instance) |
boolean |
dropAuditForServiceGroup(com.streamscape.ds.session.Session session,
java.lang.String group) |
com.streamscape.ds.result.Result |
getCollectionProperties(com.streamscape.ds.session.Session session) |
java.lang.String |
getModel() |
com.streamscape.sef.dii.AccessibleObjectProxy |
getProxy() |
AbstractIterator |
iterator(com.streamscape.ds.session.Session session) |
boolean |
retainAll(com.streamscape.ds.session.Session session,
java.util.Collection c) |
close, count, destroy, getCollectionSQL, getConstraintEventId, getEventForTrigger, getEventId, getEvents, getEventScope, getReferences, getSelector, getSourceEvent, getTimeWindowUnit, getTriggerEventId, getWindowCheckInterval, getWindowCheckIntervalUnit, getWindowSize, getWindowType, isConsumer, isStarted, isTriggerEventAutogenerated, onEvent, open, read, read, readAll, readLast, removeWindow, setConstraintEventId, setEventScope, setLastSlidingTimeWindowCheckerTime, setLastSlidingTimeWindowDeletedRows, setNextSlidingTimeWindowCheckerTime, setSelector, setTimeWindowUnit, setWindowCheckInterval, setWindowCheckIntervalUnit, setWindowSize, setWindowType, start, startWindow, stop, unwrapEvent, waitToRead, waitToRead, waitToReadLast, waitToTake, waitToTake, waitToTakeLast, wrapEvent
drain, drainTo, drainTo, drainTo, getDataType, offer, poll, poll, pollLast, put, remainingCapacity, setConstraint, take, take, takeLast
add, addAll, addAll, addRow, addRows, clear, containsAll, containsAll, drainFromQueue, drainRows, drainRowsTo, drainRowsTo, drainToMap, drainToQueue, drainToRowSet, drainToTable, element, element, elementLast, fromMap, fromQueue, fromRowSet, fromTable, getMaxDepth, getName, getQueueName, getSchema, getTableName, isEmpty, offer, peek, peek, peekLast, poll, poll, pollLast, remove, remove, remove, removeAll, removeAll, removeLast, retainAll, size, toArray, toArray, toMap, toMapCollection, toQueue, toQueueCollection, toRowSet, toTable
aggregateStateHolder, checkResultIsData, checkResultNotError, checkUpdateCountIs, count, dropReplicationSource, exposeCollectionState, getBaseTable, getCatalogName, getChangeTimestamp, getCollectionComponents, getCollectionName, getCollectionName, getCollectionType, getCollectionType, getCollectionTypeName, getCollectionTypeNameCamelCase, getComponents, getDataspace, getMemoryModel, getMemoryModel, getObjectName, getObjectType, getOwner, getReplicationSource, getSchemaName, getSQL, getSQL, getSQL, getSQL, getSQLForReplication, getStateHolder, getWindowTriggers, isReplicated, listTriggers, listTriggers, resetBaseTable, setReplicationSource, updateBaseTable, validate, validateTypes
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregateObjectStateHolder, getSQLInSchema, recompileObject
public AuditQueueCollection(DataspaceStore store, NameManager.ObjectName name, com.streamscape.ds.core.MemoryModel memoryModel, boolean isConsumer, boolean isConsumerAsync)
public java.lang.String getModel()
public void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
compile
in interface SchemaObject
compile
in class com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
public void activateWindow(com.streamscape.ds.session.Session session, NameManager.ObjectName internalTableName)
activateWindow
in class com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
public void compileInternalStatements(com.streamscape.ds.session.Session session)
compileInternalStatements
in interface Collection
compileInternalStatements
in class com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
public boolean contains(com.streamscape.ds.session.Session session, java.lang.Object o)
contains
in class com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
public AbstractIterator iterator(com.streamscape.ds.session.Session session)
iterator
in class com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
public boolean retainAll(com.streamscape.ds.session.Session session, java.util.Collection c)
retainAll
in class AbstractQueueCollection
public boolean dropAuditForProcessInstance(com.streamscape.ds.session.Session session, java.lang.String serviceGroup, java.lang.String instance)
public boolean dropAuditForServiceGroup(com.streamscape.ds.session.Session session, java.lang.String group)
public com.streamscape.ds.result.Result getCollectionProperties(com.streamscape.ds.session.Session session)
getCollectionProperties
in interface Collection
getCollectionProperties
in class com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
public com.streamscape.sef.dii.AccessibleObjectProxy getProxy()
getProxy
in interface com.streamscape.sef.dii.AccessibleObject
getProxy
in class com.streamscape.ds.schema.collection.qspace.equeue.EventQueueCollection
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.