SourceFunction
API, which is due to be
removed. Use the new Source
API instead.@Deprecated public class StreamSourceContexts extends Object
Constructor and Description |
---|
StreamSourceContexts()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static <OUT> SourceFunction.SourceContext<OUT> |
getSourceContext(TimeCharacteristic timeCharacteristic,
ProcessingTimeService processingTimeService,
Object checkpointLock,
Output<StreamRecord<OUT>> output,
long watermarkInterval,
long idleTimeout,
boolean emitProgressiveWatermarks)
Deprecated.
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, Output<StreamRecord<OUT>> output, long watermarkInterval, long idleTimeout, boolean emitProgressiveWatermarks)
TimeCharacteristic
, this method will return the adequate SourceFunction.SourceContext
. That is:
TimeCharacteristic.IngestionTime
= AutomaticWatermarkContext
TimeCharacteristic.ProcessingTime
= NonTimestampContext
TimeCharacteristic.EventTime
= ManualWatermarkContext
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.