Package org.apache.flink.walkthrough.common.sink

Class AlertSink

java.lang.Object

org.apache.flink.walkthrough.common.sink.AlertSink

All Implemented Interfaces:

Serializable, Function, SinkFunction<Alert>

@PublicEvolving
@Deprecated
public class AlertSink
extends Object
implements SinkFunction<Alert>

Deprecated.

A sink for outputting alerts.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction

SinkFunction.Context

Constructor Summary

Constructors

Constructor	Description
AlertSink()	Deprecated.

Method Summary

Modifier and Type	Method	Description
void	invoke(Alert value, SinkFunction.Context context)	Deprecated. Writes the given value to the sink.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction

finish, invoke, writeWatermark

Constructor Detail

AlertSink

public AlertSink()

Deprecated.

Method Detail

invoke

public void invoke(Alert value,
                   SinkFunction.Context context)

Deprecated.

Description copied from interface: SinkFunction

Writes the given value to the sink. This function is called for every record.

You have to override this method when implementing a SinkFunction, this is a default method for backward compatibility with the old-style method only.

Specified by:

invoke in interface SinkFunction<Alert>

Parameters:

value - The input record.

context - Additional context about the input record.