StreamProcessor (Nuxeo ECM Projects 9.10 API)

All Known Implementing Classes:

LogStreamProcessor
```
public interface StreamProcessor
```
Run a topology of computations according to some settings.

Since:

9.3

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`boolean`	`drainAndStop(Duration timeout)` Stop computations when input streams are empty.
`long`	`getLowWatermark()` Return the low watermark for all the computations of the topology.
`long`	`getLowWatermark(String computationName)` Return the low watermark for the computation.
`StreamProcessor`	`init(Topology topology, Settings settings)` Initialize streams, but don't run the computations
`boolean`	`isDone(long timestamp)` Returns true if all messages with a lower timestamp has been processed by the topology.
`void`	`shutdown()` Shutdown immediately.
`void`	`start()` Run the initialized computations.
`boolean`	`stop(Duration timeout)` Try to stop computations gracefully after processing a record or a timer within the timeout duration.
`boolean`	`waitForAssignments(Duration timeout)` Wait for the computations to have assigned partitions ready to process records.

- Method Detail
  - init
```
StreamProcessor init(Topology topology,
                     Settings settings)
```
    Initialize streams, but don't run the computations
  - start
```
void start()
```
    Run the initialized computations.
  - stop
```
boolean stop(Duration timeout)
```
    Try to stop computations gracefully after processing a record or a timer within the timeout duration. If this can not be done within the timeout, shutdown and returns false.
  - drainAndStop
```
boolean drainAndStop(Duration timeout)
```
    Stop computations when input streams are empty. The timeout is applied for each computation, the total duration can be up to nb computations * timeout
    Returns true if computations are stopped during the timeout delay.
  - shutdown
```
void shutdown()
```
    Shutdown immediately.
  - getLowWatermark
```
long getLowWatermark(String computationName)
```
    Return the low watermark for the computation. Any message with an offset below the low watermark has been processed by this computation and its ancestors..
  - getLowWatermark
```
long getLowWatermark()
```
    Return the low watermark for all the computations of the topology. Any message with an offset below the low watermark has been processed.
  - isDone
```
boolean isDone(long timestamp)
```
    Returns true if all messages with a lower timestamp has been processed by the topology.
  - waitForAssignments
```
boolean waitForAssignments(Duration timeout)
                    throws InterruptedException
```
    Wait for the computations to have assigned partitions ready to process records. The processor must be started. This is useful for writing unit test.
    Returns true if all computations have assigned partitions during the timeout delay.
    
    Throws:
    
    InterruptedException

Interface StreamProcessor

Method Summary

Method Detail

init

start

stop

drainAndStop

shutdown

getLowWatermark

getLowWatermark

isDone

waitForAssignments