Package com.norconex.committer.core.impl

Class MemoryCommitter

java.lang.Object

com.norconex.committer.core.AbstractCommitter<MemoryCommitterConfig>

com.norconex.committer.core.impl.MemoryCommitter

All Implemented Interfaces:

Committer, Configurable<MemoryCommitterConfig>, AutoCloseable

public class MemoryCommitter
extends AbstractCommitter<MemoryCommitterConfig>

WARNING: Not intended for production use.

A Committer that stores every document received into memory. This can be useful for testing or troubleshooting applications using Committers.

Given this committer can eat up memory pretty quickly, its use is strongly discouraged for regular production use.

Field Summary

Fields inherited from interface com.norconex.commons.lang.config.Configurable

PROPERTY

Constructor Summary

Constructors

Constructor	Description
MemoryCommitter()

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(Object other)
protected void	doClean()
protected void	doClose()	Subclasses can perform additional closing logic by overriding this method.
protected void	doDelete(DeleteRequest deleteRequest)
protected void	doInit()	Subclasses can perform additional initialization by overriding this method.
protected void	doUpsert(UpsertRequest upsertRequest)
boolean	equals(Object o)
List<CommitterRequest>	getAllRequests()
MemoryCommitterConfig	getConfiguration()
int	getDeleteCount()
List<DeleteRequest>	getDeleteRequests()
int	getRequestCount()
int	getUpsertCount()
List<UpsertRequest>	getUpsertRequests()
int	hashCode()
boolean	isClosed()
boolean	removeRequest(CommitterRequest req)
void	setClosed(boolean closed)
String	toString()

Methods inherited from class com.norconex.committer.core.AbstractCommitter

accept, applyFieldMappings, clean, close, delete, fireDebug, fireDebug, fireError, fireError, fireInfo, fireInfo, getCommitterContext, init, upsert

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

MemoryCommitter

public MemoryCommitter()

Method Details

getConfiguration

public MemoryCommitterConfig getConfiguration()

doInit

protected void doInit()

Description copied from class: AbstractCommitter

Subclasses can perform additional initialization by overriding this method. Default implementation does nothing. The CommitterContext will be initialized when invoking AbstractCommitter.getCommitterContext()

Specified by:

doInit in class AbstractCommitter<MemoryCommitterConfig>

removeRequest

public boolean removeRequest(CommitterRequest req)

getAllRequests

public List<CommitterRequest> getAllRequests()

getUpsertRequests

public List<UpsertRequest> getUpsertRequests()

getDeleteRequests

public List<DeleteRequest> getDeleteRequests()

getUpsertCount

public int getUpsertCount()

getDeleteCount

public int getDeleteCount()

getRequestCount

public int getRequestCount()

doUpsert

protected void doUpsert(UpsertRequest upsertRequest)
                 throws CommitterException

Specified by:

doUpsert in class AbstractCommitter<MemoryCommitterConfig>

Throws:

CommitterException

doDelete

protected void doDelete(DeleteRequest deleteRequest)

Specified by:

doDelete in class AbstractCommitter<MemoryCommitterConfig>

doClose

protected void doClose()
                throws CommitterException

Description copied from class: AbstractCommitter

Subclasses can perform additional closing logic by overriding this method. Default implementation does nothing.

Specified by:

doClose in class AbstractCommitter<MemoryCommitterConfig>

Throws:

CommitterException - error closing committer

doClean

protected void doClean()
                throws CommitterException

Specified by:

doClean in class AbstractCommitter<MemoryCommitterConfig>

Throws:

CommitterException

toString

public String toString()

Overrides:

toString in class AbstractCommitter<MemoryCommitterConfig>

equals

public boolean equals(Object o)

Overrides:

equals in class AbstractCommitter<MemoryCommitterConfig>

canEqual

protected boolean canEqual(Object other)

Overrides:

canEqual in class AbstractCommitter<MemoryCommitterConfig>

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractCommitter<MemoryCommitterConfig>

isClosed

public boolean isClosed()

setClosed

public void setClosed(boolean closed)