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