nxcals.api.extraction.data.builders.DataQuery.getAsPivot

static DataQuery.getAsPivot(spark: SparkSession, start_time: str | datetime | datetime64 | timedelta | int | int64, end_time: str | datetime | datetime64 | timedelta | int | int64, variables: Iterable[Any] = (), system: str | None = None, variable_names: Iterable[str] = ()) → DataFrame

/** Create a dataset with variable names as columns. Values are joined on timestamps. Experimental, may be changed in the future. :param spark: spark session :param start_time: begin of extraction time window :param end_time: end of extraction time window :param variables: iterable, which contains Variable objects (JavaObject). If not specified, then system and variable_names are used. :param system: system name, where variables will be searched from variable_names :param variable_names: iterable containing variable names, which must be registered in system :return: PySpark DataFrame, with one column “nxcals_timestamp” and other columns named after variables, e.g. “nxcals_timestamp”, “BLM1:arr”, “BLM2:voltage”.