com.exalead.papi.helper.pipe.buffered

Class BufferedPushAPI.TBuffer

java.lang.Object

com.exalead.papi.helper.pipe.buffered.BufferedPushAPI.TBuffer

Enclosing class:

BufferedPushAPI

protected static class BufferedPushAPI.TBuffer
extends java.lang.Object

Class aimed to buffer a generic operation (add, delete..) Upper-level synchronization is necessary.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	BufferedPushAPI.TBuffer.Arrays<T> Replaces java.lang.Arrays.copyOf() (java 1.5)

Field Summary

Fields

Modifier and Type	Field and Description
protected long	currentBytes
protected int	currentIndex
protected Document[]	documents
protected java.lang.String[][]	fields
protected long	maxBytes
protected MetaContainer[]	metaContainers
protected int	size
protected java.lang.String[]	stamps
protected java.lang.String[]	uris
protected java.util.HashSet<java.lang.String>	urisSeen

Constructor Summary

Constructors

Constructor and Description
TBuffer(int size, long maxBytes) Constructor

Method Summary

Modifier and Type	Method and Description
protected void	clear() Clear the buffer content.
protected static long	documentSize(Document document) Get a Document estimated size.
void	executeAddDocument(PushAPI parent) Flush all add commands to the upstream Push API
void	executeDeleteDocument(PushAPI parent) Flush all delete commands to the upstream Push API
void	executeUpdateDocument(PushAPI parent) Flush all update commands to the upstream Push API
void	executeUpdateDocumentMetas(PushAPI parent) Deprecated.
int	getCount() Return the number of cached operations
protected void	init() Initialize internal fields.
boolean	isEmpty() Is the buffer empty ?
boolean	isFull() Is the buffer now full ? Calling this method is mandatory after a push*() function has been called
boolean	pushAddDocument(Document document) Push an add command
protected boolean	pushCommand() Take in account new command.
boolean	pushDeleteDocument(java.lang.String uri) Push a delete command
boolean	pushUpdateDocument(Document doc, java.lang.String[] fields) Push an update command
boolean	pushUpdateDocumentMetas(java.lang.String uri, java.lang.String stamp, MetaContainer metaContainer) Push an update metas command
protected void	recordUri(java.lang.String uri) Record an URI as "seen".
boolean	seenUri(java.lang.String uri) Is the given URI in the buffer ?

Methods inherited from class java.lang.Object

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

Field Detail

documents

protected Document[] documents

uris

protected java.lang.String[] uris

fields

protected java.lang.String[][] fields

stamps

protected java.lang.String[] stamps

metaContainers

protected MetaContainer[] metaContainers

size

protected final int size

maxBytes

protected final long maxBytes

currentIndex

protected int currentIndex

currentBytes

protected long currentBytes

urisSeen

protected java.util.HashSet<java.lang.String> urisSeen

Constructor Detail

TBuffer

public TBuffer(int size,
               long maxBytes)

Constructor

Method Detail

init

protected void init()

Initialize internal fields.

clear

protected void clear()

Clear the buffer content.

recordUri

protected void recordUri(java.lang.String uri)

Record an URI as "seen".

seenUri

public boolean seenUri(java.lang.String uri)

Is the given URI in the buffer ?

isEmpty

public boolean isEmpty()

Is the buffer empty ?

isFull

public boolean isFull()

Is the buffer now full ? Calling this method is mandatory after a push*() function has been called

getCount

public int getCount()

Return the number of cached operations

documentSize

protected static long documentSize(Document document)

Get a Document estimated size.

pushCommand

protected boolean pushCommand()

Take in account new command. Returns true if the buffer is full.

pushAddDocument

public boolean pushAddDocument(Document document)

Push an add command

pushUpdateDocument

public boolean pushUpdateDocument(Document doc,
                                  java.lang.String[] fields)

Push an update command

pushUpdateDocumentMetas

public boolean pushUpdateDocumentMetas(java.lang.String uri,
                                       java.lang.String stamp,
                                       MetaContainer metaContainer)

Push an update metas command

pushDeleteDocument

public boolean pushDeleteDocument(java.lang.String uri)

Push a delete command

executeAddDocument

public void executeAddDocument(PushAPI parent)
                        throws PushAPIException

Flush all add commands to the upstream Push API

Throws:

PushAPIException

executeUpdateDocument

public void executeUpdateDocument(PushAPI parent)
                           throws PushAPIException

Flush all update commands to the upstream Push API

Throws:

PushAPIException

executeUpdateDocumentMetas

@Deprecated
public void executeUpdateDocumentMetas(PushAPI parent)
                                            throws PushAPIException

Deprecated.

Flush all update metas commands to the upstream Push API

Throws:

PushAPIException

executeDeleteDocument

public void executeDeleteDocument(PushAPI parent)
                           throws PushAPIException

Flush all delete commands to the upstream Push API

Throws:

PushAPIException