Constructor and Description |
---|
SinkContextUtil() |
Modifier and Type | Method and Description |
---|---|
static <T> SinkFunction.Context<T> |
forTimestamp(long timestamp)
Creates a
SinkFunction.Context that
throws an exception when trying to access the current watermark or processing time. |
public static <T> SinkFunction.Context<T> forTimestamp(long timestamp)
SinkFunction.Context
that
throws an exception when trying to access the current watermark or processing time.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.