Packages

c

com.linkedin.feathr.swj

SlidingWindowFeature

case class SlidingWindowFeature(name: String, agg: AggregationSpec, windowSpec: WindowSpec, filterCondition: Option[String] = None, groupBy: Option[GroupBySpec] = None, lateralView: Option[LateralViewParams] = None) extends Serializable with Product

Defines a sliding window aggregated feature

name

Name of the feature. Used to uniquely identify a column in the DataFrame

agg

An AggregationSpec for the sliding window aggregated feature

windowSpec

A WindowSpec for the sliding window aggregated feature

filterCondition

Filter condition to determine if a given record should be considered in the sliding window aggregation. The String value should represent a Spark SQL column expression

groupBy

An optional GroupBySpec for the sliding window aggregated feature

Linear Supertypes
Product, Equals, Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SlidingWindowFeature
  2. Product
  3. Equals
  4. Serializable
  5. Serializable
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SlidingWindowFeature(name: String, agg: AggregationSpec, windowSpec: WindowSpec, filterCondition: Option[String] = None, groupBy: Option[GroupBySpec] = None, lateralView: Option[LateralViewParams] = None)

    name

    Name of the feature. Used to uniquely identify a column in the DataFrame

    agg

    An AggregationSpec for the sliding window aggregated feature

    windowSpec

    A WindowSpec for the sliding window aggregated feature

    filterCondition

    Filter condition to determine if a given record should be considered in the sliding window aggregation. The String value should represent a Spark SQL column expression

    groupBy

    An optional GroupBySpec for the sliding window aggregated feature

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. val agg: AggregationSpec
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. val filterCondition: Option[String]
  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. val groupBy: Option[GroupBySpec]
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. val lateralView: Option[LateralViewParams]
  14. val name: String
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  19. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  20. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  21. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  22. val windowSpec: WindowSpec

Inherited from Product

Inherited from Equals

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped