Package cern.nxcals.api.extraction.data.builders

Class ParameterDataQuery

java.lang.Object

cern.nxcals.api.extraction.data.builders.ParameterDataQuery

public class ParameterDataQuery
extends java.lang.Object

Method Summary

Modifier and Type	Method	Description
static SystemStage<DeviceStage<org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>>,org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>>	builder(org.apache.spark.sql.SparkSession session)
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	getFor(@NonNull org.apache.spark.sql.SparkSession sparkSession, @NonNull TimeWindow timeWindow, @NonNull java.lang.String system, @NonNull java.lang.String device, @NonNull java.lang.String property)	Search for given device/property in given system within time window.
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	getFor(@NonNull org.apache.spark.sql.SparkSession sparkSession, @NonNull java.lang.String system, @NonNull java.lang.String parameter, @NonNull TimeWindow timeWindow)	Query for given parameter and return result dataset
static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	getFor(@NonNull org.apache.spark.sql.SparkSession sparkSession, @NonNull java.lang.String system, @NonNull java.lang.String device, @NonNull java.lang.String property, @NonNull TimeWindow timeWindow)	Search for given device/property in given system within time window.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

builder

public static SystemStage<DeviceStage<org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>>,org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>> builder(org.apache.spark.sql.SparkSession session)

getFor

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> getFor(@NonNull
                                                                            @NonNull org.apache.spark.sql.SparkSession sparkSession,
                                                                            @NonNull
                                                                            @NonNull TimeWindow timeWindow,
                                                                            @NonNull
                                                                            @NonNull java.lang.String system,
                                                                            @NonNull
                                                                            @NonNull java.lang.String device,
                                                                            @NonNull
                                                                            @NonNull java.lang.String property)

Search for given device/property in given system within time window.

Parameters:

sparkSession - spark session

timeWindow - time window to query for

system - system name (CMW, PM ...)

device - device name

property - property name

Returns:

Dataset with result in Row

getFor

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> getFor(@NonNull
                                                                            @NonNull org.apache.spark.sql.SparkSession sparkSession,
                                                                            @NonNull
                                                                            @NonNull java.lang.String system,
                                                                            @NonNull
                                                                            @NonNull java.lang.String device,
                                                                            @NonNull
                                                                            @NonNull java.lang.String property,
                                                                            @NonNull
                                                                            @NonNull TimeWindow timeWindow)

Search for given device/property in given system within time window.

Parameters:

sparkSession - spark session

system - system name (CMW, PM ...)

device - device name

property - property name

timeWindow - time window to query for

Returns:

Dataset with result in Row

getFor

public static org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> getFor(@NonNull
                                                                            @NonNull org.apache.spark.sql.SparkSession sparkSession,
                                                                            @NonNull
                                                                            @NonNull java.lang.String system,
                                                                            @NonNull
                                                                            @NonNull java.lang.String parameter,
                                                                            @NonNull
                                                                            @NonNull TimeWindow timeWindow)

Query for given parameter and return result dataset

Parameters:

sparkSession - spark session

system - system name

parameter - in form device/property

timeWindow - time window for query

Returns:

result dataset