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:
  • Field Details

    • commitStream

      public GlobalStreamId commitStream
    • expectedTaskReports

      public int expectedTaskReports
  • Constructor Details

    • CoordCondition

      public CoordCondition()
  • Method Details