com.cloudera.sparkts.api.java

JavaTimeSeries

class JavaTimeSeries[K] extends Serializable

Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. JavaTimeSeries
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new JavaTimeSeries(index: DateTimeIndex, data: DenseMatrix, keys: List[K])(implicit kClassTag: ClassTag[K])

  2. new JavaTimeSeries(index: DateTimeIndex, data: DenseMatrix, keys: List[K])(implicit kClassTag: ClassTag[K])

  3. new JavaTimeSeries(index: DateTimeIndex, data: DenseMatrix, keys: Array[K])(implicit kClassTag: ClassTag[K])

  4. new JavaTimeSeries(ts: TimeSeries[K])(implicit kClassTag: ClassTag[K])

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  8. def data: DenseMatrix

  9. def dataAsArray: Array[Double]

  10. def differences(): JavaTimeSeries[K]

    Returns a TimeSeries where each time series is differenced with order 1.

    Returns a TimeSeries where each time series is differenced with order 1. The new TimeSeries will be missing the first date-time.

  11. def differences(lag: Int): JavaTimeSeries[K]

    Returns a TimeSeries where each time series is differenced with the given order.

    Returns a TimeSeries where each time series is differenced with the given order. The new TimeSeries will be missing the first n date-times.

  12. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  13. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  14. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  15. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  16. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  17. def head(): (K, Vector)

    Gets the first univariate series and its key.

  18. def index: DateTimeIndex

  19. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  20. implicit val kClassTag: ClassTag[K]

  21. def keys: Array[K]

  22. def lags[U >: (K, Integer)](lagsPerCol: Map[K, (Boolean, Integer)]): JavaTimeSeries[(K, Integer)]

    This is equivalent to lags(lagsPerCol, new JavaTimeSeries.

    This is equivalent to lags(lagsPerCol, new JavaTimeSeries.laggedPairKey()). It returns JavaTimeSeries with a new key that is a pair of (original key, lag order).

  23. def lags[U](lagsPerCol: Map[K, (Boolean, Integer)], laggedKey: Function2[K, Integer, U]): JavaTimeSeries[U]

    IMPORTANT: this function assumes that the DateTimeIndex is a UniformDateTimeIndex, not an Irregular one.

    IMPORTANT: this function assumes that the DateTimeIndex is a UniformDateTimeIndex, not an Irregular one.

    Lags the specified individual time series of the TimeSeries instance by up to their matching lag amount. Each time series can be indicated to either retain the original value, or drop it.

    In other words, the lagsPerCol has the following structure:

    ("variableName1" -> (keepOriginalValue, maxLag), "variableName2" -> (keepOriginalValue, maxLag), ...)

    See description of the above lags function for an example of the lagging process.

  24. def lags[U >: (K, Integer)](maxLag: Int, includeOriginals: Boolean): JavaTimeSeries[(K, Integer)]

    This is equivalent to lags(maxLag, includeOriginals, new JavaTimeSeries.

    This is equivalent to lags(maxLag, includeOriginals, new JavaTimeSeries.laggedPairKey()). It returns JavaTimeSeries with a new key that is a pair of (original key, lag order).

  25. def lags[U](maxLag: Int, includeOriginals: Boolean, laggedKey: Function2[K, Integer, U]): JavaTimeSeries[U]

    IMPORTANT: this function assumes that the DateTimeIndex is a UniformDateTimeIndex, not an Irregular one.

    IMPORTANT: this function assumes that the DateTimeIndex is a UniformDateTimeIndex, not an Irregular one.

    Lags all individual time series of the JavaTimeSeries instance by up to maxLag amount. The lagged time series has its keys generated by the laggedKey function which takes two input parameters: the original key and the lag order, and should return a corresponding lagged key.

    Example input TimeSeries: time a b 4 pm 1 6 5 pm 2 7 6 pm 3 8 7 pm 4 9 8 pm 5 10

    With maxLag 2 and includeOriginals = true, and JavaTimeSeries.laggedStringKey, we would get: time a lag1(a) lag2(a) b lag1(b) lag2(b) 6 pm 3 2 1 8 7 6 7 pm 4 3 2 9 8 7 8 pm 5 4 3 10 9 8

  26. def mapSeries(newIndex: DateTimeIndex, f: Function[Vector, Vector]): JavaTimeSeries[K]

    Applies a transformation to each series such that the resulting series align with the given time index.

  27. def mapSeries(f: Function[Vector, Vector]): JavaTimeSeries[K]

    Applies a transformation to each series that preserves the time index.

  28. def mapSeriesWithKey(f: Function2[K, Vector, Vector]): JavaTimeSeries[K]

    Applies a transformation to each series that preserves the time index.

    Applies a transformation to each series that preserves the time index. Passes the key along with each series.

  29. def mapValues[U](f: Function[Vector, U]): List[(K, U)]

  30. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  31. final def notify(): Unit

    Definition Classes
    AnyRef
  32. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  33. def price2ret(): JavaTimeSeries[K]

    Returns a return series for each time series.

    Returns a return series for each time series. Assumes periodic (as opposed to continuously compounded) returns.

  34. def quotients(): JavaTimeSeries[K]

    Returns a TimeSeries where each time series is quotiented with order 1.

    Returns a TimeSeries where each time series is quotiented with order 1. The new TimeSeries will be missing the first date-time.

  35. def quotients(lag: Int): JavaTimeSeries[K]

    Returns a TimeSeries where each time series is quotiented with the given order.

    Returns a TimeSeries where each time series is quotiented with the given order. The new TimeSeries will be missing the first n date-times.

  36. def slice(range: Range): JavaTimeSeries[K]

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

    Definition Classes
    AnyRef
  38. def toInstants(): List[(ZonedDateTime, Vector)]

  39. def toString(): String

    Definition Classes
    AnyRef → Any
  40. val ts: TimeSeries[K]

  41. def union(vec: Vector, key: K): JavaTimeSeries[K]

  42. def univariateKeyAndSeriesIterator(): Iterator[(K, Vector)]

  43. def univariateSeriesIterator(): Iterator[Vector]

  44. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  45. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  46. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped