com.nt.udc.processor.enhancer.dupremover

Class DuplicateKeyTableFlush

java.lang.Object

com.nt.udc.processor.enhancer.dupremover.DuplicateKeyTableFlush

All Implemented Interfaces:

FlushHandler

public class DuplicateKeyTableFlush
extends java.lang.Object
implements FlushHandler

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 and Description
DuplicateKeyTableFlush(ConfigIfc config, LoggerIfc logger, DuplicateKeyTable table)

Method Summary

Methods

Modifier and Type	Method and Description
void	completeFlush() Flushes the complete table.
void	flushRecord(java.lang.Object obj) Flushes the given key from the table.
protected void	getConfigData()
void	initialFlush() Flushes the table based on whether the "FlushOnStartup" configuration setting is set to true.
int[]	recordInitFields() Returns the fields that should be stored in a newly created record entry.

Methods inherited from class java.lang.Object

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

Constructor Detail

DuplicateKeyTableFlush

public DuplicateKeyTableFlush(ConfigIfc config,
                      LoggerIfc logger,
                      DuplicateKeyTable table)

Method Detail

recordInitFields

public int[] recordInitFields()

Returns the fields that should be stored in a newly created record entry. The fields returned are those that this object uses/knows about.

Returns:

Array of integers, representing the fields to initialize.

flushRecord

public void flushRecord(java.lang.Object obj)

Flushes the given key from the table.

Specified by:

flushRecord in interface FlushHandler

Parameters:

nar - NAR to flush to the next node

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.

getConfigData

protected void getConfigData()