public class JournalFileTableCollection extends FileTableCollection implements com.streamscape.ds.utils.SourceEventFlowData
Title: Dataspace Framework
Description: Journal file table collection.
Copyright: Copyright (c) 2016
Company: StreamScape Technologies
Modifier and Type | Class and Description |
---|---|
static class |
JournalFileTableCollection.ProcessingStrategy |
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 |
---|
JournalFileTableCollection(DataspaceStore database,
NameManager.ObjectName name) |
Modifier and Type | Method and Description |
---|---|
void |
addJftSpecificColumns() |
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
void |
destroy(com.streamscape.ds.session.Session session) |
void |
fireNewRowIndexedTrigger(com.streamscape.ds.session.Session session,
java.lang.Object[] data) |
long |
getCheckInterval(com.streamscape.ds.session.Session session) |
com.streamscape.ds.result.Result |
getCollectionProperties(com.streamscape.ds.session.Session session) |
java.lang.String |
getDataSource(com.streamscape.ds.session.Session session) |
EventFlowEntity |
getEntity() |
java.lang.String |
getEntityName() |
java.util.HashMap |
getEntityParameters() |
EventScope |
getEntityScope() |
JournalFileTableCollection.ProcessingStrategy |
getProcessingStrategy() |
JournalFileTableCollection.ProcessingStrategy |
getProcessingStrategy(com.streamscape.ds.session.Session session) |
com.streamscape.sef.dii.AccessibleObjectProxy |
getProxy() |
java.lang.String |
getSQL() |
void |
initSeqId(com.streamscape.ds.session.Session session) |
boolean |
isIgnoreMalformedSeqIdOnDelete() |
boolean |
isIgnoreMalformedSeqIdOnInsert() |
boolean |
isIgnoreMalformedSeqIdOnUpdate() |
boolean |
isNoCreateFile() |
boolean |
isPositionAfterStart() |
boolean |
isStarted(com.streamscape.ds.session.Session session) |
static java.util.List |
listSpecificJftColumns() |
void |
onTruncate(com.streamscape.ds.session.Session session) |
void |
raiseJournalFileTableStateChangeAdvisory(JournalFileTableStateChangeAdvisory.JFTState state,
java.lang.Exception exception) |
void |
setCheckInterval(com.streamscape.ds.session.Session session,
java.lang.Long checkInterval) |
void |
setDataSource(com.streamscape.ds.session.Session session,
java.lang.String filename) |
void |
setDataSource(com.streamscape.ds.session.Session session,
java.lang.String sourceFileName,
boolean createIfNotExist,
boolean init) |
void |
setIgnoreMalformedSeqIdOnDelete(boolean ignoreMalformedSeqIdOnDelete) |
void |
setIgnoreMalformedSeqIdOnInsert(boolean ignoreMalformedSeqIdOnInsert) |
void |
setIgnoreMalformedSeqIdOnUpdate(boolean ignoreMalformedSeqIdOnUpdate) |
JournalFileTableCollection |
setNoCreateFile(boolean noCreateFile) |
void |
setProcessingStrategy(com.streamscape.ds.session.Session session,
JournalFileTableCollection.ProcessingStrategy processingStrategy,
long startSeqId,
long startTimestamp) |
void |
start(com.streamscape.ds.session.Session session) |
void |
stop(com.streamscape.ds.session.Session session) |
checkFileTableAndGetRecord, checkStatements, checkTuplesAndDescriptorInSync, close, compress, createRowParser, decompress, getAppendableStatistics, getFileTable, getNextRowForStream, getReferences, handleRecordTypeDefinition, initForStreaming, initParserWithRow, isDescriptorInSync, isLinked, isLinked, isSuspendOnFail, isSuspendOnFail, isTuplesAndDescriptorInSync, link, linkDataSource, log, logDebug, logError, logInfo, materializeRowForStream, resume, setFileDescriptorName, setFileServer, setRecordTypes, setSuspendOnFail, setTypesOnly, startAppendableFileTableReader, truncate, unlink
clear, clear, compileColumnNames, compileInternalStatements, containsPrimarykey, delete, delete, deleteAll, drainFromQueue, fromMap, fromQueue, fromRowSet, fromTable, getEvents, getRow, getSQL, getSQLForReplication, hasForeignKey, hasPrimaryKey, insert, insert, insert, insert, insertAll, insertAll, isEmpty, primaryKeySet, rowSet, select, size, toMap, toMapCollection, toQueue, toQueueCollection, toRowSet, toTableCollection, update, update, update, upsert, upsert
aggregateStateHolder, checkResultIsData, checkResultNotError, checkUpdateCountIs, count, dropReplicationSource, exposeCollectionState, getBaseTable, getCatalogName, getChangeTimestamp, getCollectionComponents, getCollectionName, getCollectionName, getCollectionType, getCollectionType, getCollectionTypeName, getCollectionTypeNameCamelCase, getComponents, getDataspace, getEventForTrigger, getMemoryModel, getMemoryModel, getObjectName, getObjectType, getOwner, getReplicationSource, getSchemaName, getSQL, getSQL, getStateHolder, getTriggerEventId, getWindowTriggers, isReplicated, isTriggerEventAutogenerated, listTriggers, listTriggers, open, resetBaseTable, setReplicationSource, unwrapEvent, updateBaseTable, validate, validateTypes, wrapEvent
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregateObjectStateHolder, getSQLInSchema, recompileObject
public JournalFileTableCollection(DataspaceStore database, NameManager.ObjectName name)
public void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
compile
in interface SchemaObject
compile
in class FileTableCollection
public void addJftSpecificColumns()
public static java.util.List listSpecificJftColumns()
public java.lang.String getSQL()
getSQL
in interface SchemaObject
getSQL
in class FileTableCollection
public void setDataSource(com.streamscape.ds.session.Session session, java.lang.String filename)
public void setDataSource(com.streamscape.ds.session.Session session, java.lang.String sourceFileName, boolean createIfNotExist, boolean init)
public java.lang.String getDataSource(com.streamscape.ds.session.Session session)
getDataSource
in class FileTableCollection
public long getCheckInterval(com.streamscape.ds.session.Session session)
public boolean isStarted(com.streamscape.ds.session.Session session)
public void setProcessingStrategy(com.streamscape.ds.session.Session session, JournalFileTableCollection.ProcessingStrategy processingStrategy, long startSeqId, long startTimestamp)
public JournalFileTableCollection.ProcessingStrategy getProcessingStrategy(com.streamscape.ds.session.Session session)
public JournalFileTableCollection.ProcessingStrategy getProcessingStrategy()
public void start(com.streamscape.ds.session.Session session)
public void stop(com.streamscape.ds.session.Session session)
public void setCheckInterval(com.streamscape.ds.session.Session session, java.lang.Long checkInterval)
public com.streamscape.sef.dii.AccessibleObjectProxy getProxy()
getProxy
in interface com.streamscape.sef.dii.AccessibleObject
getProxy
in class FileTableCollection
public void fireNewRowIndexedTrigger(com.streamscape.ds.session.Session session, java.lang.Object[] data)
fireNewRowIndexedTrigger
in class FileTableCollection
public void destroy(com.streamscape.ds.session.Session session)
destroy
in interface Collection
destroy
in class AbstractCollection
public void initSeqId(com.streamscape.ds.session.Session session)
public com.streamscape.ds.result.Result getCollectionProperties(com.streamscape.ds.session.Session session)
getCollectionProperties
in interface Collection
getCollectionProperties
in class FileTableCollection
public void onTruncate(com.streamscape.ds.session.Session session)
public void raiseJournalFileTableStateChangeAdvisory(JournalFileTableStateChangeAdvisory.JFTState state, java.lang.Exception exception)
public EventFlowEntity getEntity()
getEntity
in interface com.streamscape.ds.utils.SourceEventFlowData
public java.lang.String getEntityName()
getEntityName
in interface com.streamscape.ds.utils.SourceEventFlowData
public EventScope getEntityScope()
getEntityScope
in interface com.streamscape.ds.utils.SourceEventFlowData
public java.util.HashMap getEntityParameters()
getEntityParameters
in interface com.streamscape.ds.utils.SourceEventFlowData
public boolean isNoCreateFile()
public JournalFileTableCollection setNoCreateFile(boolean noCreateFile)
public boolean isPositionAfterStart()
public void setIgnoreMalformedSeqIdOnInsert(boolean ignoreMalformedSeqIdOnInsert)
public boolean isIgnoreMalformedSeqIdOnInsert()
public void setIgnoreMalformedSeqIdOnUpdate(boolean ignoreMalformedSeqIdOnUpdate)
public boolean isIgnoreMalformedSeqIdOnUpdate()
public void setIgnoreMalformedSeqIdOnDelete(boolean ignoreMalformedSeqIdOnDelete)
public boolean isIgnoreMalformedSeqIdOnDelete()
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.