Package com.attivio.connector
Interface ConcurrentScannerDocFetcherState
-
- All Known Implementing Classes:
ConcurrentDocumentFetcherImpl
public interface ConcurrentScannerDocFetcherStateAn interface for observing the state of the concurrent document fetcher
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.Map<ConcurrentScannerDocFetcherTask.TaskState,java.lang.Long>countByState()State: Get the count for eachConcurrentScannerDocFetcherTask.TaskState.java.util.List<ConcurrentScannerDocFetcherTask.TaskInfo>getFetcherStates(java.util.List<java.lang.String> uids)Get detailedConcurrentScannerDocFetcherTask.TaskInfoinformation for this list of task uuidjava.util.stream.Stream<java.lang.String>getList(ConcurrentScannerDocFetcherTask.TaskState state)Details: Get a stream of task UUID for thisConcurrentScannerDocFetcherTask.TaskStatestate.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).booleanscannerIsDoneQueuing()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 eachConcurrentScannerDocFetcherTask.TaskState.- 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 thisConcurrentScannerDocFetcherTask.TaskStatestate.- Parameters:
state-- Returns:
- task uuid stream
-
getFetcherStates
java.util.List<ConcurrentScannerDocFetcherTask.TaskInfo> getFetcherStates(java.util.List<java.lang.String> uids)
Get detailedConcurrentScannerDocFetcherTask.TaskInfoinformation for this list of task uuid- Parameters:
uids-- Returns:
- task details
-
-