Class SparkTimeseriesDataSet

    • Method Detail

      • of

        public static TimeseriesDataSet of​(Variable variable,
                                           org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset)
      • ofFundamentals

        public static TimeseriesDataSet ofFundamentals​(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset)
      • ofDataDistribution

        public static TimeseriesDataSet ofDataDistribution​(Variable variable,
                                                           org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset)
      • ofSorted

        public static TimeseriesDataSet ofSorted​(Variable variable,
                                                 org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset)
      • ofAggregated

        public static TimeseriesDataSet ofAggregated​(Variable variable,
                                                     org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset)
      • getTimeseriesData

        public TimeseriesData getTimeseriesData​(int index)
        Specified by:
        getTimeseriesData in interface TimeseriesDataSet
        Parameters:
        index - - the index in this TimeseriesDataSet for which TimeseriesData should be returned.
        Returns:
        - TimeseriesData at the given index within this TimeseriesDataSet
      • getVariableName

        public java.lang.String getVariableName()
        Specified by:
        getVariableName in interface TimeseriesDataSet
        Returns:
        - the name of the Variable to which this TimeseriesData belongs
      • getTimeseriesDataOrLast

        public TimeseriesData getTimeseriesDataOrLast​(java.sql.Timestamp timestamp)
        Description copied from interface: TimeseriesDataSet
        Returns the data at the given timestamp or repeat the last value if there is no value found at the given timestamp If there is no value before that time, null is returned
        Specified by:
        getTimeseriesDataOrLast in interface TimeseriesDataSet
        Parameters:
        timestamp - - The given timestamp
        Returns:
        - The data at the given timestamp or just before
      • addTimeseriesData

        @Deprecated
        public void addTimeseriesData​(TimeseriesData data)
        Deprecated.
        (never use, major performance hit, could have led to unpredictable states)
        Specified by:
        addTimeseriesData in interface TimeseriesDataSet
        Parameters:
        data - - the TimeseriesData to be added to this TimeseriesDataSet
      • append

        @Deprecated
        public void append​(TimeseriesDataSet data)
        Deprecated.
        (never use, major performance hit, could have led to unpredictable states)
        Description copied from interface: TimeseriesDataSet
        Appends a Timeseries Data Set to the end of the current data set
        Specified by:
        append in interface TimeseriesDataSet
        Parameters:
        data - The data set to be appended
      • add

        @Deprecated
        public boolean add​(TimeseriesData data)
        Deprecated.
        (never use, major performance hit, could have led to unpredictable states)
        Specified by:
        add in interface java.util.Collection<TimeseriesData>
        Specified by:
        add in interface java.util.List<TimeseriesData>
        Overrides:
        add in class java.util.ArrayList<TimeseriesData>
      • remove

        @Deprecated
        public boolean remove​(java.lang.Object o)
        Deprecated.
        (never use, major performance hit, could have led to unpredictable states)
        Specified by:
        remove in interface java.util.Collection<TimeseriesData>
        Specified by:
        remove in interface java.util.List<TimeseriesData>
        Overrides:
        remove in class java.util.ArrayList<TimeseriesData>
      • addAll

        @Deprecated
        public boolean addAll​(java.util.Collection<? extends TimeseriesData> c)
        Deprecated.
        (never use, major performance hit, could have led to unpredictable states)
        Specified by:
        addAll in interface java.util.Collection<TimeseriesData>
        Specified by:
        addAll in interface java.util.List<TimeseriesData>
        Overrides:
        addAll in class java.util.ArrayList<TimeseriesData>
      • removeAll

        @Deprecated
        public boolean removeAll​(java.util.Collection<?> c)
        Deprecated.
        (never use, major performance hit, could have led to unpredictable states)
        Specified by:
        removeAll in interface java.util.Collection<TimeseriesData>
        Specified by:
        removeAll in interface java.util.List<TimeseriesData>
        Overrides:
        removeAll in class java.util.ArrayList<TimeseriesData>
      • retainAll

        @Deprecated
        public boolean retainAll​(java.util.Collection<?> c)
        Deprecated.
        (never use, major performance hit, could have led to unpredictable states)
        Specified by:
        retainAll in interface java.util.Collection<TimeseriesData>
        Specified by:
        retainAll in interface java.util.List<TimeseriesData>
        Overrides:
        retainAll in class java.util.ArrayList<TimeseriesData>
      • clear

        @Deprecated
        public void clear()
        Deprecated.
        (never use, major performance hit, could have led to unpredictable states)
        Specified by:
        clear in interface java.util.Collection<TimeseriesData>
        Specified by:
        clear in interface java.util.List<TimeseriesData>
        Overrides:
        clear in class java.util.ArrayList<TimeseriesData>
      • getMinStamp

        public java.sql.Timestamp getMinStamp()
        Specified by:
        getMinStamp in interface TimeseriesDataSet
        Returns:
        - the smallest timestamp in the timeseries data set
      • getMaxStamp

        public java.sql.Timestamp getMaxStamp()
        Specified by:
        getMaxStamp in interface TimeseriesDataSet
        Returns:
        - the highest timestamp in the timeseries data set.
      • equals

        public boolean equals​(java.lang.Object o)
        Specified by:
        equals in interface java.util.Collection<TimeseriesData>
        Specified by:
        equals in interface java.util.List<TimeseriesData>
        Overrides:
        equals in class java.util.ArrayList<TimeseriesData>
      • canEqual

        protected boolean canEqual​(java.lang.Object other)
      • hashCode

        public int hashCode()
        Specified by:
        hashCode in interface java.util.Collection<TimeseriesData>
        Specified by:
        hashCode in interface java.util.List<TimeseriesData>
        Overrides:
        hashCode in class java.util.ArrayList<TimeseriesData>