RecordEvaluator (Flink : Connectors : Base 2.1.1-cp1 API)

All Superinterfaces:

Serializable

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
```
@PublicEvolving
@FunctionalInterface
public interface RecordEvaluator<T>
extends Serializable
```
An interface that evaluates whether a de-serialized record should trigger certain control-flow operations (e.g. end of stream).

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`boolean`	`isEndOfStream(T record)`	Determines whether a record should trigger the end of stream for its split.

- Method Detail
  - isEndOfStream
```
boolean isEndOfStream(T record)
```
    Determines whether a record should trigger the end of stream for its split. The given record wouldn't be emitted from the source if the returned result is true.
    
    Parameters:
    
    record - a de-serialized record from the split.
    
    Returns:
    
    a boolean indicating whether the split has reached end of stream.