com.snowplowanalytics.snowplow.sources.EventProcessingConfig
TimedWindows
Companion object TimedWindows
case class TimedWindows(duration: FiniteDuration, firstWindowScaling: Double) extends Windowing with Product with Serializable
Configures windows e.g. for Transformer
- duration
The base level duration between windows
- firstWindowScaling
A random factor to adjust the size of the first window. This addresses the situation where several parallel instances of the app all start at the same time. All instances in the group should end windows at slightly different times, so that downstream gets a more steady flow of completed batches.
- Alphabetic
- By Inheritance
- TimedWindows
- Serializable
- Product
- Equals
- Windowing
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new TimedWindows(duration: FiniteDuration, firstWindowScaling: Double)
- duration
The base level duration between windows
- firstWindowScaling
A random factor to adjust the size of the first window. This addresses the situation where several parallel instances of the app all start at the same time. All instances in the group should end windows at slightly different times, so that downstream gets a more steady flow of completed batches.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- val duration: FiniteDuration
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- val firstWindowScaling: Double
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])