public class StateCleaningCountTrigger$ extends Object implements scala.Serializable
Modifier and Type | Field and Description |
---|---|
static StateCleaningCountTrigger$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
StateCleaningCountTrigger$() |
Modifier and Type | Method and Description |
---|---|
StateCleaningCountTrigger |
of(StreamQueryConfig queryConfig,
long maxCount)
Create a
StateCleaningCountTrigger instance. |
public static final StateCleaningCountTrigger$ MODULE$
public StateCleaningCountTrigger of(StreamQueryConfig queryConfig, long maxCount)
StateCleaningCountTrigger
instance.
queryConfig
- query configuration.maxCount
- The count of elements at which to fire.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.