StreamInputProcessor (Flink : Streaming Java 1.19.2-cp2 API)

All Superinterfaces:

AutoCloseable, org.apache.flink.runtime.io.AvailabilityProvider, Closeable

All Known Implementing Classes:

StreamMultipleInputProcessor, StreamOneInputProcessor
```
@Internal
public interface StreamInputProcessor
extends org.apache.flink.runtime.io.AvailabilityProvider, Closeable
```
Interface for processing records by StreamTask.

Nested Class Summary
- Nested classes/interfaces inherited from interface org.apache.flink.runtime.io.AvailabilityProvider
  org.apache.flink.runtime.io.AvailabilityProvider.AvailabilityHelper

Field Summary
- Fields inherited from interface org.apache.flink.runtime.io.AvailabilityProvider
  AVAILABLE

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`CompletableFuture<Void>`	`prepareSnapshot(org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter channelStateWriter, long checkpointId)`
`DataInputStatus`	`processInput()`	In case of two and more input processors this method must call `InputSelectable.nextSelection()` to choose which input to consume from next.

Methods inherited from interface org.apache.flink.runtime.io.AvailabilityProvider
getAvailableFuture, isApproximatelyAvailable, isAvailable

Methods inherited from interface java.io.Closeable
close

- Method Detail
  - processInput
```
DataInputStatus processInput()
                      throws Exception
```
    In case of two and more input processors this method must call InputSelectable.nextSelection() to choose which input to consume from next.
    
    Returns:
    
    input status to estimate whether more records can be processed immediately or not. If there are no more records available at the moment and the caller should check finished state and/or AvailabilityProvider.getAvailableFuture().
    
    Throws:
    
    Exception
  - prepareSnapshot
```
CompletableFuture<Void> prepareSnapshot(org.apache.flink.runtime.checkpoint.channel.ChannelStateWriter channelStateWriter,
                                        long checkpointId)
                                 throws org.apache.flink.runtime.checkpoint.CheckpointException
```
    Throws:
    
    org.apache.flink.runtime.checkpoint.CheckpointException