Package com.attivio.connector

Interface ConcurrentScannerDocFetcherState

All Known Implementing Classes:

ConcurrentDocumentFetcherImpl

public interface ConcurrentScannerDocFetcherState

An interface for observing the state of the concurrent document fetcher

Method Summary

Modifier and Type	Method	Description
java.util.Map<ConcurrentScannerDocFetcherTask.TaskState,java.lang.Long>	countByState()	State: Get the count for each ConcurrentScannerDocFetcherTask.TaskState.
java.util.List<ConcurrentScannerDocFetcherTask.TaskInfo>	getFetcherStates(java.util.List<java.lang.String> uids)	Get detailed ConcurrentScannerDocFetcherTask.TaskInfo information for this list of task uuid
java.util.stream.Stream<java.lang.String>	getList(ConcurrentScannerDocFetcherTask.TaskState state)	Details: Get a stream of task UUID for this ConcurrentScannerDocFetcherTask.TaskState state.
java.util.Map<ConcurrentScannerTaskExecuter.ConcurrentExecutionMetrics,ConcurrentScannerPerformanceAlert>	getPerformanceMetrics()	Throughput: Returns the frequency of events over a period of time (e.g over the last 5 minutes).
boolean	scannerIsDoneQueuing()	Returns true if the scanner told the document fetcher that it's done queuing tasks by calling doneQueuing or by calling stop

Method Detail

scannerIsDoneQueuing

boolean scannerIsDoneQueuing()

Returns true if the scanner told the document fetcher that it's done queuing tasks by calling doneQueuing or by calling stop

Returns:

countByState

java.util.Map<ConcurrentScannerDocFetcherTask.TaskState,java.lang.Long> countByState()

State: Get the count for each ConcurrentScannerDocFetcherTask.TaskState.

Parameters:

states -

Returns:

state count map

getPerformanceMetrics

java.util.Map<ConcurrentScannerTaskExecuter.ConcurrentExecutionMetrics,ConcurrentScannerPerformanceAlert> getPerformanceMetrics()

Throughput: Returns the frequency of events over a period of time (e.g over the last 5 minutes). Low queuing frequency, for example, could indicate the need to add more work threads.

Returns:

frequency map

getList

java.util.stream.Stream<java.lang.String> getList(ConcurrentScannerDocFetcherTask.TaskState state)

Details: Get a stream of task UUID for this ConcurrentScannerDocFetcherTask.TaskState state.

Parameters:

state -

Returns:

task uuid stream

getFetcherStates

java.util.List<ConcurrentScannerDocFetcherTask.TaskInfo> getFetcherStates(java.util.List<java.lang.String> uids)

Get detailed ConcurrentScannerDocFetcherTask.TaskInfo information for this list of task uuid

Parameters:

uids -

Returns:

task details