Package com.illumon.iris.db.v2.utils

Class TableLogger

java.lang.Object

com.illumon.util.referencecounting.ReferenceCounted

com.illumon.iris.db.util.liveness.ReferenceCountedLivenessNode

com.illumon.iris.db.util.liveness.LivenessArtifact

com.illumon.iris.db.v2.InstrumentedListenerBase

com.illumon.iris.db.v2.InstrumentedListener

com.illumon.iris.db.v2.InstrumentedListenerAdapter

com.illumon.iris.db.v2.utils.TableLogger

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, NotificationQueue.Dependency, LivenessManager, LivenessNode, LivenessReferent, Listener, ListenerBase, Serializable

public class TableLogger
extends InstrumentedListenerAdapter

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	TableLogger.StoreMode

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.InstrumentedListener

InstrumentedListener.Notification

Nested classes/interfaces inherited from class com.illumon.iris.db.v2.InstrumentedListenerBase

InstrumentedListenerBase.ErrorNotification, InstrumentedListenerBase.NotificationBase

Field Summary

Fields inherited from class com.illumon.iris.db.v2.InstrumentedListenerAdapter

source

Constructor Summary

Constructors

Constructor	Description
TableLogger(Database db, String namespace, String tableName, String partColumn, String partitionKey, ReplayerInterface replayer, DynamicTable table, boolean append, TableLogger.StoreMode storeMode, long snapshotIntervalMillis)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()
TableDefinition	getDefinition()
static TableDefinition	getDefinition(Table table, TableLogger.StoreMode storeMode)
void	onUpdate(Index added, Index removed, Index modified)	Process notification of table changes.
void	setReplayer(Replayer replayer)

Methods inherited from class com.illumon.iris.db.v2.InstrumentedListenerAdapter

canExecute, destroy, onFailureInternal

Methods inherited from class com.illumon.iris.db.v2.InstrumentedListener

getNotification, setInitialImage

Methods inherited from class com.illumon.iris.db.v2.InstrumentedListenerBase

append, getEntry, getErrorNotification, onFailure, onFailureInternalWithDependent, satisfied, setVerboseLogging, toString

Methods inherited from class com.illumon.iris.db.util.liveness.LivenessArtifact

manageWithCurrentScope, unmanage, unmanage

Methods inherited from class com.illumon.iris.db.util.liveness.ReferenceCountedLivenessNode

dropReference, getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryRetainReference

Methods inherited from class com.illumon.util.referencecounting.ReferenceCounted

decrementReferenceCount, incrementReferenceCount, resetReferenceCount, tryDecrementReferenceCount, tryIncrementReferenceCount

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.illumon.iris.db.v2.ListenerBase

getErrorNotification, onFailure

Methods inherited from interface com.illumon.iris.db.util.liveness.LivenessManager

manage, tryManage

Methods inherited from interface com.illumon.iris.db.util.liveness.LivenessReferent

dropReference, getReferentDescription, getWeakReference, retainReference, tryRetainReference

Constructor Details

TableLogger

public TableLogger(Database db,
 String namespace,
 String tableName,
 String partColumn,
 String partitionKey,
 ReplayerInterface replayer,
 DynamicTable table,
 boolean append,
 TableLogger.StoreMode storeMode,
 long snapshotIntervalMillis)
            throws IOException

Throws:

IOException

Method Details

getDefinition

public TableDefinition getDefinition()

getDefinition

public static TableDefinition getDefinition(Table table,
 TableLogger.StoreMode storeMode)

setReplayer

public void setReplayer(Replayer replayer)

flush

public void flush()
           throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

onUpdate

public void onUpdate(Index added,
 Index removed,
 Index modified)

Description copied from interface: Listener

Process notification of table changes.

The Listener onUpdate call executes within the LiveTableMonitor refresh loop. Any tables used within the listener's onUpdate call must have already been refreshed. Using the typical pattern of a Listener that is listening to a single table, with DynamicTable.listenForUpdates(Listener), this is trivially true.

When the listener must reference more than just one parent, the tables (or other objects) it references, must be made a NotificationQueue.Dependency of the listener. For listeners that reference multiple ticking tables, a common pattern is to use a MergedListener and collection of ListenerRecorders.

Specified by:

onUpdate in interface Listener

Specified by:

onUpdate in class InstrumentedListenerAdapter

Parameters:

added - rows added

removed - rows removed

modified - rows modified