Package org.apache.flink.streaming.api.functions.sink

Class SinkContextUtil

java.lang.Object

org.apache.flink.streaming.api.functions.sink.SinkContextUtil

@Internal
public class SinkContextUtil
extends Object

Utility for creating Sink Contexts.

Constructor Summary

Constructors

Constructor	Description
SinkContextUtil()

Method Summary

Modifier and Type	Method	Description
static SinkFunction.Context	forTimestamp(long timestamp)	Creates a SinkFunction.Context that throws an exception when trying to access the current watermark or processing time.

Methods inherited from class java.lang.Object

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

Constructor Detail

SinkContextUtil

public SinkContextUtil()

Method Detail

forTimestamp

public static SinkFunction.Context forTimestamp(long timestamp)

Creates a SinkFunction.Context that throws an exception when trying to access the current watermark or processing time.