public class TopologyBuilder extends Object
Constructor and Description |
---|
TopologyBuilder() |
TopologyBuilder(ComponentFactory theFactory) |
public TopologyBuilder()
public TopologyBuilder(ComponentFactory theFactory)
public void initTopology(String topologyName)
topologyName
- public void initTopology(String topologyName, int delay)
topologyName
- delay
- delay between injections of two instances from source (in milliseconds)public Topology build()
public ProcessingItem addProcessor(Processor processor, int parallelism)
public ProcessingItem addProcessor(Processor processor)
public ProcessingItem connectInputShuffleStream(Stream inputStream, Processor processor)
public ProcessingItem connectInputKeyStream(Stream inputStream, Processor processor)
public ProcessingItem connectInputAllStream(Stream inputStream, Processor processor)
public Stream createInputShuffleStream(Processor processor, Processor dest)
public EntranceProcessingItem addEntranceProcessor(EntranceProcessor entranceProcessor)
public ProcessingItem getProcessingItem(Processor processor)
Copyright © 2013–2015 The Apache Software Foundation. All rights reserved.