org.nuxeo.ecm.core.api

Class CursorService<C,O,R>

java.lang.Object

org.nuxeo.ecm.core.api.CursorService<C,O,R>

Type Parameters:

C - The cursor type.

O - The cursor item type.

R - The result type.

public class CursorService<C,O,R>
extends Object

A cursor service which holds cursors on DB in order to perform scroll operations.

Since:

9.1

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,CursorResult<C,O>>	cursorResults
protected Function<O,R>	extractor

Constructor Summary

Constructors

Constructor and Description
CursorService(Function<O,R> extractor)

Method Summary

Modifier and Type	Method and Description
void	checkForTimedOutScroll()
void	clear() Clear and close all cursors owned by this service.
protected boolean	isScrollTimedOut(String scrollId, CursorResult<C,O> cursorResult)
String	registerCursor(C cursor, int batchSize, int keepAliveSeconds) Registers the input C and generates a new scrollId to associate with.
String	registerCursor(String scrollId, C cursor, int batchSize, int keepAliveSeconds) Registers the input C associated to the input scrollId.
String	registerCursorResult(CursorResult<C,O> cursorResult) Registers the input CursorResult and generates a new scrollId to associate with.
String	registerCursorResult(String scrollId, CursorResult<C,O> cursorResult) Registers the input CursorResult associated to the input scrollId.
ScrollResult<R>	scroll(String scrollId)
boolean	unregisterCursor(String scrollId) Unregisters cursor associated to the input scrollId.

Methods inherited from class java.lang.Object

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

Field Detail

cursorResults

protected final Map<String,CursorResult<C,O>> cursorResults

extractor

protected final Function<O,R> extractor

Constructor Detail

CursorService

public CursorService(Function<O,R> extractor)

Method Detail

checkForTimedOutScroll

public void checkForTimedOutScroll()

isScrollTimedOut

protected boolean isScrollTimedOut(String scrollId,
                                   CursorResult<C,O> cursorResult)

registerCursor

public String registerCursor(C cursor,
                             int batchSize,
                             int keepAliveSeconds)

Registers the input C and generates a new scrollId to associate with.

Returns:

the scrollId associated to the cursor.

registerCursor

public String registerCursor(String scrollId,
                             C cursor,
                             int batchSize,
                             int keepAliveSeconds)

Registers the input C associated to the input scrollId.

Returns:

the scrollId associated to the cursor.

registerCursorResult

public String registerCursorResult(CursorResult<C,O> cursorResult)

Registers the input CursorResult and generates a new scrollId to associate with.

Returns:

the scrollId associated to the cursor result.

registerCursorResult

public String registerCursorResult(String scrollId,
                                   CursorResult<C,O> cursorResult)

Registers the input CursorResult associated to the input scrollId.

Returns:

the scrollId associated to the cursor result.

unregisterCursor

public boolean unregisterCursor(String scrollId)

Unregisters cursor associated to the input scrollId.

Parameters:

scrollId - The scoll id of CursorResult to unregister

Returns:

Whether or not the cursor was unregistered.

scroll

public ScrollResult<R> scroll(String scrollId)

Returns:

the next batch of cursor associated to the input scrollId

clear

public void clear()

Clear and close all cursors owned by this service.