public class StreamScopeSetup extends java.lang.Object
This class is not thread safe.
|Modifier and Type||Method and Description|
Add StreamScope instances to the topology
Perform the registrations needed to use the streamscope package.
public static void register(ServiceContainer services)
Typically called during
services- ServiceContainer to register with.
public static void addStreamScopes(Topology t)
Instrument the topology by adding StreamScope peekers to the
topology's streams. At topology submission time, StreamScopes
register themselves with the topology's
StreamScopeRegistry runtime service.
Copyright © 2017 The Apache Software Foundation. All Rights Reserved - 4744f56-20170226-1707