Package org.terrier.realtime.incremental

Class IncrementalFlushDocs

java.lang.Object

org.terrier.realtime.incremental.IncrementalFlushPolicy

org.terrier.realtime.incremental.IncrementalFlushDocs

All Implemented Interfaces:

java.lang.Runnable

public class IncrementalFlushDocs
extends IncrementalFlushPolicy

An IncrementalFlushPolicy that will flush an index to disk after a fixed number of documents have been emitted.

Since:

4.0

Author:

Richard McCreadie, Stuart Mackie

Constructor Summary

Constructors

Constructor	Description
IncrementalFlushDocs(IncrementalIndex index)	Get max docs from terrier.properties.

Method Summary

Modifier and Type	Method	Description
boolean	flushCheck()	Is flushing required?
boolean	flushPolicy()	Is flushing configured?

Methods inherited from class org.terrier.realtime.incremental.IncrementalFlushPolicy

get, run

Methods inherited from class java.lang.Object

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

Constructor Detail

IncrementalFlushDocs

public IncrementalFlushDocs(IncrementalIndex index)

Get max docs from terrier.properties.

Method Detail

flushPolicy

public boolean flushPolicy()

Is flushing configured?

Overrides:

flushPolicy in class IncrementalFlushPolicy

flushCheck

public boolean flushCheck()

Is flushing required?

Overrides:

flushCheck in class IncrementalFlushPolicy