org.archive.cdxserver.processor

Class LastNLineProcessor

java.lang.Object

org.archive.cdxserver.processor.WrappedProcessor

org.archive.cdxserver.processor.LastNLineProcessor

All Implemented Interfaces:

BaseProcessor

public class LastNLineProcessor
extends WrappedProcessor

Field Summary

Fields

Modifier and Type	Field and Description
protected int	limit
protected LinkedList<org.archive.format.cdx.CDXLine>	lines

Fields inherited from class org.archive.cdxserver.processor.WrappedProcessor

inner

Constructor Summary

Constructors

Constructor and Description
LastNLineProcessor(BaseProcessor output, int limit)

Method Summary

Methods

Modifier and Type	Method and Description
void	end() Called at the end.
protected void	flush()
int	writeLine(org.archive.format.cdx.CDXLine line) Process line.
void	writeResumeKey(String resumeKey) Write resumption key.

Methods inherited from class org.archive.cdxserver.processor.WrappedProcessor

begin, modifyOutputFormat, trackLine

Methods inherited from class java.lang.Object

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

Field Detail

lines

protected LinkedList<org.archive.format.cdx.CDXLine> lines

limit

protected int limit

Constructor Detail

LastNLineProcessor

public LastNLineProcessor(BaseProcessor output,
                  int limit)

Method Detail

writeLine

public int writeLine(org.archive.format.cdx.CDXLine line)

Description copied from interface: BaseProcessor

Process line.

Specified by:

writeLine in interface BaseProcessor

Overrides:

writeLine in class WrappedProcessor

Parameters:

line - CDXLine

Returns:

1 if line is sent to output, 0 otherwise.

flush

protected void flush()

writeResumeKey

public void writeResumeKey(String resumeKey)

Description copied from interface: BaseProcessor

Write resumption key. Only the final CDXWriter should do actual work. All intermediaries shall simply call writeResumeKey(resumeKey) on nested processor.

Specified by:

writeResumeKey in interface BaseProcessor

Overrides:

writeResumeKey in class WrappedProcessor

end

public void end()

Description copied from interface: BaseProcessor

Called at the end. Perform any clean ups / finalizations here. Intermediaries processor should call end() on nested processor.

Specified by:

end in interface BaseProcessor

Overrides:

end in class WrappedProcessor