Package cern.nxcals.api.backport.domain.util

Class FundamentalUtils

java.lang.Object

cern.nxcals.api.backport.domain.util.FundamentalUtils

public final class FundamentalUtils
extends java.lang.Object

Method Summary

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()