public static interface Sink.InitContext
SinkWriter
.Modifier and Type | Method and Description |
---|---|
Sink.ProcessingTimeService |
getProcessingTimeService()
Returns a
Sink.ProcessingTimeService that can be used to get the current time and
register timers. |
int |
getSubtaskId() |
MetricGroup |
metricGroup() |
Sink.ProcessingTimeService getProcessingTimeService()
Sink.ProcessingTimeService
that can be used to get the current time and
register timers.int getSubtaskId()
MetricGroup metricGroup()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.