org.apache.flink.streaming.api.operators.async

Interface OperatorActions

All Known Implementing Classes:

AsyncWaitOperator

@Internal
public interface OperatorActions

Interface for StreamOperator actions.

Method Summary

Modifier and Type	Method and Description
void	failOperator(Throwable throwable) Fail the respective stream operator with the given throwable.

Method Detail

failOperator

void failOperator(Throwable throwable)

Fail the respective stream operator with the given throwable.

Parameters:

throwable - to fail the stream operator with