Value Members

1.  final def != ( arg0: Any ) : Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def == ( arg0: Any ) : Boolean

   Definition Classes

   AnyRef → Any

4.  final def asInstanceOf [ T0] : T0

   Definition Classes

   Any

5.  def clone () : AnyRef

   Attributes

   protected[ lang]

   Definition Classes

   AnyRef

   Annotations

   @throws ( ... ) @native ()

6.  def create [ S] ( optionalState: Optional[ S], timeoutConf: GroupStateTimeout , batchProcessingTimeMs: Long , eventTimeWatermarkMs: Optional[ Long], hasTimedOut: Boolean ) : TestGroupState[ S]

   Creates TestGroupState instances for general testing purposes.

   Creates TestGroupState instances for general testing purposes.

   optionalState

   Optional value of the state.

   timeoutConf

   Type of timeout configured. Based on this, different operations will be supported.

   batchProcessingTimeMs

   Processing time of current batch, used to calculate timestamp for processing time timeouts.

   eventTimeWatermarkMs

   Optional value of event time watermark in ms. Set as Optional.empty if watermark is not present. Otherwise, event time watermark should be a positive long and the timestampMs set through setTimeoutTimestamp() cannot be less than eventTimeWatermarkMs.

   hasTimedOut

   Whether the key for which this state wrapped is being created is getting timed out or not.

   returns

   a TestGroupState instance built with the user specified configs.

   Annotations

   @throws ( ... ) @throws ( ... ) @throws ( ... )

7.  final def eq ( arg0: AnyRef ) : Boolean

   Definition Classes

   AnyRef

8.  def equals ( arg0: Any ) : Boolean

   Definition Classes

   AnyRef → Any

9.  def finalize () : Unit

   Attributes

   protected[ lang]

   Definition Classes

   AnyRef

   Annotations

   @throws ( classOf[java.lang.Throwable] )

10.  final def getClass () : Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native ()

11.  def hashCode () : Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native ()

12.  final def isInstanceOf [ T0] : Boolean

    Definition Classes

    Any

13.  final def ne ( arg0: AnyRef ) : Boolean

    Definition Classes

    AnyRef

14.  final def notify () : Unit

    Definition Classes

    AnyRef

    Annotations

    @native ()

15.  final def notifyAll () : Unit

    Definition Classes

    AnyRef

    Annotations

    @native ()

16.  final def synchronized [ T0] ( arg0: ⇒ T0 ) : T0

    Definition Classes

    AnyRef

17.  def toString () : String

    Definition Classes

    AnyRef → Any

18.  final def wait () : Unit

    Definition Classes

    AnyRef

    Annotations

    @throws ( ... )

19.  final def wait ( arg0: Long , arg1: Int ) : Unit

    Definition Classes

    AnyRef

    Annotations

    @throws ( ... )

20.  final def wait ( arg0: Long ) : Unit

    Definition Classes

    AnyRef

    Annotations

    @throws ( ... ) @native ()