org.apache.flink.streaming.runtime.tasks

Interface StreamTask.CanEmitBatchOfRecordsChecker

Enclosing class:

StreamTask<OUT,OP extends StreamOperator<OUT>>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface StreamTask.CanEmitBatchOfRecordsChecker

Check whether records can be emitted in batch.

Method Summary

Modifier and Type	Method and Description
boolean	check()

Method Detail

check

boolean check()