@PublicEvolving public class AlertSink extends Object implements SinkFunction<Alert>
SinkFunction.Context
Constructor and Description |
---|
AlertSink() |
Modifier and Type | Method and Description |
---|---|
void |
invoke(Alert value,
SinkFunction.Context context)
Writes the given value to the sink.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
finish, invoke, writeWatermark
public void invoke(Alert value, SinkFunction.Context context)
SinkFunction
You have to override this method when implementing a SinkFunction
, this is a
default
method for backward compatibility with the old-style method only.
invoke
in interface SinkFunction<Alert>
value
- The input record.context
- Additional context about the input record.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.