public class TridentState extends Object
| Modifier | Constructor and Description |
|---|---|
protected |
TridentState(TridentTopology topology,
Node node) |
protected TridentState(TridentTopology topology, Node node)
public Stream newValuesStream()
public TridentState parallelismHint(int parallelism)
Copyright © 2015. All rights reserved.