Package com.nt.udc.flexibleAggregator.table

Class FlexibleTableFlush

java.lang.Object

com.nt.udc.flexibleAggregator.table.FlexibleTableFlush

public class FlexibleTableFlush
extends Object

This class handles basic flushing-related functionality. Complicated flushing procedures should go in separate classes that are specifically written for their needs. All and any flushing-related capabilities do not necessarily belong in here.

Constructor Summary

Constructors

Constructor	Description
FlexibleTableFlush(LoggerIfc logger, FlexibleAggrTable table, DCStreamHandler streamHandler, String nodeID, int nodeType, boolean performInitialFlush, boolean performWriteOnFlush)
FlexibleTableFlush(LoggerIfc logger, FlexibleAggrTable table, DCStreamHandler streamHandler, String nodeID, int nodeType, boolean performInitialFlush, boolean performWriteOnFlush, File file)

Method Summary

Modifier and Type	Method	Description
void	completeFlush()	Flushes the complete table.
void	flushRecord(NAR nar)	Flushes the given record to the next node.
void	flushRecordAndRemove(NAR nar, FlexibleNARKey key)	Flushes the given record to the next node, and removes all traces of it from the table.
void	flushRecords(NAR[] nars)	Flushes the given set of records to the next node.
void	flushTableRecord(FlexibleNARKey key)	Flushes the given record to the next node, after removing it from the table.
void	flushTableRecords(FlexibleNARKey[] keys)	Flushes the set of records to the next node, after removing it from the table.
void	initialFlush()	Flushes the table based on whether the "FlushOnStartup" configuration setting is set to true.
void	removeTableRecord(FlexibleNARKey key)	Flushed out the record by removing it.
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Details

FlexibleTableFlush

public FlexibleTableFlush(LoggerIfc logger,
 FlexibleAggrTable table,
 DCStreamHandler streamHandler,
 String nodeID,
 int nodeType,
 boolean performInitialFlush,
 boolean performWriteOnFlush,
 File file)

FlexibleTableFlush

public FlexibleTableFlush(LoggerIfc logger,
 FlexibleAggrTable table,
 DCStreamHandler streamHandler,
 String nodeID,
 int nodeType,
 boolean performInitialFlush,
 boolean performWriteOnFlush)

Method Details

shutdown

public void shutdown()

flushRecord

public void flushRecord(NAR nar)

Flushes the given record to the next node.

Parameters:

nar - NAR to flush to the next node

flushRecordAndRemove

public void flushRecordAndRemove(NAR nar,
 FlexibleNARKey key)

Flushes the given record to the next node, and removes all traces of it from the table. Note that this method exists because of the side effect of using a disk-based table. It is possible to have a different record in memory than on disk, even if the records have the same key. Therefore, if you have a record in memory that you want flushed, but also want it removed from the table (and NOT have that version flushed), use this method. This method is equivalent to: - table.remove(key); - flushRecord(nar);

Parameters:

nar - Record to flush to next node

key - Key of element to remove from table (but NOT flush to next node)

flushRecords

public void flushRecords(NAR[] nars)

Flushes the given set of records to the next node.

Parameters:

nars - NARs to flush to the next node

flushTableRecord

public void flushTableRecord(FlexibleNARKey key)

Flushes the given record to the next node, after removing it from the table. If the record doesn't exist in the table, nothing happens.

Parameters:

key - key of the NAR in the table

removeTableRecord

public void removeTableRecord(FlexibleNARKey key)

Flushed out the record by removing it. Nothing gets written to the output in this case.

flushTableRecords

public void flushTableRecords(FlexibleNARKey[] keys)

Flushes the set of records to the next node, after removing it from the table. If the record doesn't exist in the table, nothing happens.

Parameters:

keys - keys of the NARs in the table

initialFlush

public void initialFlush()

Flushes the table based on whether the "FlushOnStartup" configuration setting is set to true.

completeFlush

public void completeFlush()

Flushes the complete table.