Class FundamentalUtils


  • public final class FundamentalUtils
    extends java.lang.Object
    • Method Summary

      All Methods Static Methods Concrete Methods Deprecated Methods 
      Modifier and Type Method Description
      static org.apache.spark.sql.Column concatColumnsToFundamentalVariableName()  
      static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> createDatasetFromFundamentals​(@NonNull java.sql.Timestamp startTime, @NonNull java.sql.Timestamp endTime, @NonNull VariableSet virtualFundamentals, @NonNull DataQuery builder)
      Deprecated.
      (always pass SparkSession parameter instead of DataQuery builder, additional validation can be performed)
      static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> createDatasetFromFundamentals​(@NonNull java.sql.Timestamp startTime, @NonNull java.sql.Timestamp endTime, @NonNull VariableSet virtualFundamentals, @NonNull org.apache.spark.sql.SparkSession sparkSession)
      The idea here is to convert a virtual fundamental(s) (created by the MetaDataService) that has a name of ACC:LSA_CYCLE:TIMING_USER to the where condition that is used on the real fundamental.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • createDatasetFromFundamentals

        public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> createDatasetFromFundamentals​(@NonNull
                                                                                                           @NonNull java.sql.Timestamp startTime,
                                                                                                           @NonNull
                                                                                                           @NonNull java.sql.Timestamp endTime,
                                                                                                           @NonNull
                                                                                                           @NonNull VariableSet virtualFundamentals,
                                                                                                           @NonNull
                                                                                                           @NonNull org.apache.spark.sql.SparkSession sparkSession)
        The idea here is to convert a virtual fundamental(s) (created by the MetaDataService) that has a name of ACC:LSA_CYCLE:TIMING_USER to the where condition that is used on the real fundamental. Each virtual fundamental creates such a where condition and all of them are OR-ed for the final query.
        Parameters:
        startTime -
        endTime -
        virtualFundamentals -
        Returns:
      • createDatasetFromFundamentals

        @Deprecated
        public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> createDatasetFromFundamentals​(@NonNull
                                                                                                           @NonNull java.sql.Timestamp startTime,
                                                                                                           @NonNull
                                                                                                           @NonNull java.sql.Timestamp endTime,
                                                                                                           @NonNull
                                                                                                           @NonNull VariableSet virtualFundamentals,
                                                                                                           @NonNull
                                                                                                           @NonNull DataQuery builder)
        Deprecated.
        (always pass SparkSession parameter instead of DataQuery builder, additional validation can be performed)
      • concatColumnsToFundamentalVariableName

        public static org.apache.spark.sql.Column concatColumnsToFundamentalVariableName()