Class TridentBoltExecutor.CoordCondition
- java.lang.Object
-
- org.apache.storm.trident.topology.TridentBoltExecutor.CoordCondition
-
- All Implemented Interfaces:
Serializable
- Enclosing class:
- TridentBoltExecutor
public static class TridentBoltExecutor.CoordCondition extends Object implements Serializable
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description GlobalStreamId
commitStream
int
expectedTaskReports
-
Constructor Summary
Constructors Constructor Description CoordCondition()
-
-
-
Field Detail
-
commitStream
public GlobalStreamId commitStream
-
expectedTaskReports
public int expectedTaskReports
-
-