public class LogFileTableCollection extends TableCollection implements com.streamscape.sef.dii.AccessibleObject, com.streamscape.tools.tailer.FileTailerStringListener, com.streamscape.tools.tailer.FileTailerStateListener, com.streamscape.ds.utils.SourceEventFlowData
Modifier and Type | Class and Description |
---|---|
static class |
LogFileTableCollection.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 |
---|
LogFileTableCollection(DataspaceStore store,
NameManager.ObjectName name) |
Modifier and Type | Method and Description |
---|---|
static void |
checkConstrainedByEventId(java.lang.String constrainedByEventId) |
static void |
checkMapperFunction(com.streamscape.ds.session.Session session,
NameManager.ObjectName name) |
void |
compile(com.streamscape.ds.session.Session session,
SchemaObject parentObject) |
com.streamscape.ds.result.Result |
getCollectionProperties(com.streamscape.ds.session.Session session) |
java.lang.String |
getConstrainedByEventId() |
EventFlowEntity |
getEntity() |
java.lang.String |
getEntityName() |
java.util.HashMap |
getEntityParameters() |
EventScope |
getEntityScope() |
long |
getLastInsertedRecordOffset() |
NameManager.ObjectName |
getMapperFunctionName() |
com.streamscape.ds.lib.OrderedHashSet |
getReferences() |
java.lang.String |
getSourceFileName() |
java.lang.String |
getSQL() |
java.lang.String[] |
getSQLForLogDDL() |
java.lang.String |
getStartLogFileTableSQL() |
long |
getStartRecordOffset() |
void |
initRecordOffset(com.streamscape.ds.session.Session session) |
boolean |
isStarted() |
boolean |
isSuspended() |
static void |
log(Trace.Level level,
com.streamscape.ds.AbstractDataspace dataspace,
NameManager.ObjectName objectName,
java.lang.String message) |
void |
logDebug(java.lang.String message) |
void |
logError(java.lang.String message) |
void |
logInfo(java.lang.String message) |
static java.lang.String |
logRecordMatcherToString(LogRecordMatcher matcher) |
void |
onException(java.lang.Exception exception) |
void |
onFileFound(java.lang.String filename)
This method is invoked each time when the
File Tailer performs a successful read operation. |
void |
onFileNotFound(java.lang.String filename)
This method is invoked each time when the
File Tailer cannot find the file during a read operation. |
void |
onFileRotated(java.lang.String oldFilename,
java.lang.String newFilename) |
void |
onFileTruncated(java.lang.String filename) |
void |
onNewBlock(java.lang.String block,
long offset) |
void |
open(com.streamscape.ds.session.Session session) |
void |
raiseLogFileTableStateChangeAdvisory(LogFileTableStateChangeAdvisory.LFTState state,
java.lang.Exception exception,
java.lang.String filename) |
void |
resume(com.streamscape.ds.session.Session session) |
void |
setCheckInterval(com.streamscape.ds.session.Session session,
long checkInterval) |
void |
setConstrainedByEventId(java.lang.String constrainedByEventId) |
void |
setCreateIfNotExist(boolean createIfNotExist) |
void |
setDataSource(com.streamscape.ds.session.Session session,
java.lang.String sourceFileName) |
void |
setDataSource(com.streamscape.ds.session.Session session,
java.lang.String sourceFileName,
boolean createIfNotExist,
boolean init) |
void |
setFileServer(FileServerObject fileServer) |
void |
setInit(boolean init) |
void |
setLogFileTableProperties(long lastProcessedLineOffset,
long lastProcessedTimestamp,
boolean skipFirstLine) |
void |
setLogRecordMatcher(LogRecordMatcher logRecordMatcher) |
void |
setMapperFunctionName(NameManager.ObjectName mapperFunctionName) |
void |
setMapperFunctionNameNameSchema(java.lang.String mapperFunctionNameName,
java.lang.String mapperFunctionNameSchema) |
void |
setMaxDepth(long maxDepth) |
void |
setNeedToStart(boolean needToStart) |
void |
setProcessingStrategy(com.streamscape.ds.session.Session session,
LogFileTableCollection.ProcessingStrategy processingStrategy,
long startRecordOffset,
long startRecordTimestamp) |
void |
setRotationFileRegexp(java.lang.String rotationFileRegexp) |
void |
setSuspendOnFail(com.streamscape.ds.session.Session session,
java.lang.Boolean suspendOnFail) |
void |
start(com.streamscape.ds.session.Session session) |
void |
stop(com.streamscape.ds.session.Session session) |
clear, clear, compileColumnNames, compileInternalStatements, containsPrimarykey, delete, delete, deleteAll, drainFromQueue, fromMap, fromQueue, fromRowSet, fromTable, getEvents, getProxy, 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, close, count, destroy, 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, resetBaseTable, setReplicationSource, unwrapEvent, updateBaseTable, validate, validateTypes, wrapEvent
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aggregateObjectStateHolder, getSQLInSchema, recompileObject
public LogFileTableCollection(DataspaceStore store, NameManager.ObjectName name)
public void compile(com.streamscape.ds.session.Session session, SchemaObject parentObject)
compile
in interface SchemaObject
compile
in class TableCollection
public void open(com.streamscape.ds.session.Session session)
open
in interface Collection
open
in class AbstractCollection
public void setLogFileTableProperties(long lastProcessedLineOffset, long lastProcessedTimestamp, boolean skipFirstLine)
public void setFileServer(FileServerObject fileServer)
public void setDataSource(com.streamscape.ds.session.Session session, java.lang.String sourceFileName)
public java.lang.String getSourceFileName()
public void setDataSource(com.streamscape.ds.session.Session session, java.lang.String sourceFileName, boolean createIfNotExist, boolean init)
public void setNeedToStart(boolean needToStart)
public void setMaxDepth(long maxDepth)
public void setRotationFileRegexp(java.lang.String rotationFileRegexp)
public void setCheckInterval(com.streamscape.ds.session.Session session, long checkInterval)
public void setProcessingStrategy(com.streamscape.ds.session.Session session, LogFileTableCollection.ProcessingStrategy processingStrategy, long startRecordOffset, long startRecordTimestamp)
public void setSuspendOnFail(com.streamscape.ds.session.Session session, java.lang.Boolean suspendOnFail)
public void setCreateIfNotExist(boolean createIfNotExist)
public void setInit(boolean init)
public void setLogRecordMatcher(LogRecordMatcher logRecordMatcher)
public void setConstrainedByEventId(java.lang.String constrainedByEventId)
public java.lang.String getConstrainedByEventId()
public void setMapperFunctionName(NameManager.ObjectName mapperFunctionName)
public NameManager.ObjectName getMapperFunctionName()
public void setMapperFunctionNameNameSchema(java.lang.String mapperFunctionNameName, java.lang.String mapperFunctionNameSchema)
public boolean isSuspended()
public void resume(com.streamscape.ds.session.Session session)
public long getStartRecordOffset()
public long getLastInsertedRecordOffset()
public static void checkConstrainedByEventId(java.lang.String constrainedByEventId)
public static void checkMapperFunction(com.streamscape.ds.session.Session session, NameManager.ObjectName name)
public void start(com.streamscape.ds.session.Session session)
public void stop(com.streamscape.ds.session.Session session)
public boolean isStarted()
public void initRecordOffset(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 AbstractCollection
public java.lang.String getSQL()
getSQL
in interface SchemaObject
getSQL
in class TableCollection
public static java.lang.String logRecordMatcherToString(LogRecordMatcher matcher)
public void onFileNotFound(java.lang.String filename)
com.streamscape.tools.tailer.FileTailerStateListener
File Tailer
cannot find the file during a read operation.
onFileNotFound
in interface com.streamscape.tools.tailer.FileTailerStateListener
filename
- the name of the file being monitored.public void onFileFound(java.lang.String filename)
com.streamscape.tools.tailer.FileTailerStateListener
File Tailer
performs a successful read operation.
onFileFound
in interface com.streamscape.tools.tailer.FileTailerStateListener
filename
- the name of the file being monitored.public void onFileRotated(java.lang.String oldFilename, java.lang.String newFilename)
onFileRotated
in interface com.streamscape.tools.tailer.FileTailerStateListener
public void onFileTruncated(java.lang.String filename)
onFileTruncated
in interface com.streamscape.tools.tailer.FileTailerStateListener
public void onException(java.lang.Exception exception)
onException
in interface com.streamscape.tools.tailer.FileTailerStateListener
public void onNewBlock(java.lang.String block, long offset)
onNewBlock
in interface com.streamscape.tools.tailer.FileTailerStringListener
public java.lang.String getStartLogFileTableSQL()
public java.lang.String[] getSQLForLogDDL()
public void logInfo(java.lang.String message)
public void logError(java.lang.String message)
public void logDebug(java.lang.String message)
public static void log(Trace.Level level, com.streamscape.ds.AbstractDataspace dataspace, NameManager.ObjectName objectName, java.lang.String message)
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 void raiseLogFileTableStateChangeAdvisory(LogFileTableStateChangeAdvisory.LFTState state, java.lang.Exception exception, java.lang.String filename)
public com.streamscape.ds.lib.OrderedHashSet getReferences()
getReferences
in interface SchemaObject
getReferences
in class AbstractCollection
Copyright © 2015-2024 StreamScape Technologies. All rights reserved.