public class DirectTopology extends GraphTopology<org.apache.edgent.providers.direct.DirectTester>
GraphTopologythat is executed in threads in the current virtual machine.
The topology is backed by a
DirectGraph and its
execution is controlled and monitored by a
|Modifier and Type||Method and Description|
Return a function that at execution time will return a
Get the underlying graph.
events, poll, source, sourceStream
collection, generate, getName, getTester, of, strings, topology
public Graph graph()
public Supplier<RuntimeServices> getRuntimeServiceSupplier()
RuntimeServicesinstance a stream function can use.
Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.