public class StreamSourceContexts extends Object
Constructor and Description |
---|
StreamSourceContexts() |
Modifier and Type | Method and Description |
---|---|
static <OUT> SourceFunction.SourceContext<OUT> |
getSourceContext(TimeCharacteristic timeCharacteristic,
ProcessingTimeService processingTimeService,
Object checkpointLock,
StreamStatusMaintainer streamStatusMaintainer,
Output<StreamRecord<OUT>> output,
long watermarkInterval,
long idleTimeout)
Depending on the
TimeCharacteristic , this method will return the adequate SourceFunction.SourceContext . |
public static <OUT> SourceFunction.SourceContext<OUT> getSourceContext(TimeCharacteristic timeCharacteristic, ProcessingTimeService processingTimeService, Object checkpointLock, StreamStatusMaintainer streamStatusMaintainer, Output<StreamRecord<OUT>> output, long watermarkInterval, long idleTimeout)
TimeCharacteristic
, this method will return the adequate SourceFunction.SourceContext
. That is:
TimeCharacteristic.IngestionTime
= AutomaticWatermarkContext
TimeCharacteristic.ProcessingTime
= NonTimestampContext
TimeCharacteristic.EventTime
= ManualWatermarkContext
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.