@PublicEvolving public interface ProcessingTimeServiceAware
StreamOperatorFactory, which enables stream operators to access
For an stream operator, if it needs to access the
ProcessingTimeService, it must be
created through a operator factory that implements
ProcessingTimeServiceAware, and the
operator factory should set the
ProcessingTimeService instance into the stream operator.
void setProcessingTimeService(ProcessingTimeService processingTimeService)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.