org.terrier.realtime.incremental

Class IncrementalFlushPolicy

java.lang.Object

org.terrier.realtime.incremental.IncrementalFlushPolicy

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

IncrementalFlushDocs, IncrementalFlushMemory, IncrementalFlushTime

public class IncrementalFlushPolicy
extends Object
implements Runnable

Policy for flushing out documents in an index to disks

Since:

4.0

Author:

Richard McCreadie, Stuart Mackie

Constructor Summary

Constructors

Constructor and Description
IncrementalFlushPolicy(IncrementalIndex index)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	flushCheck() Never flush.
boolean	flushPolicy() No flush.
static IncrementalFlushPolicy	get(String policy, List<Index> indices, IncrementalIndex index) Create a new flush thread.
void	run() Flush contents of in-memory index to disk.

Methods inherited from class java.lang.Object

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

Constructor Detail

IncrementalFlushPolicy

public IncrementalFlushPolicy(IncrementalIndex index)

Method Detail

get

public static IncrementalFlushPolicy get(String policy,
                         List<Index> indices,
                         IncrementalIndex index)

Create a new flush thread.

flushPolicy

public boolean flushPolicy()

No flush.

flushCheck

public boolean flushCheck()

Never flush.

run

public void run()

Flush contents of in-memory index to disk.

Specified by:

run in interface Runnable