Skip to content
Snippets Groups Projects

Resolve NXCALS-7480 "Fix empty datasets"

Merged Rafal Mucha requested to merge NXCALS-7480-fix-empty-datasets into develop
All threads resolved!
@@ -4,10 +4,11 @@
package cern.nxcals.api.extraction.data.demo;
import cern.nxcals.api.backport.client.service.LHCFillDataService;
import cern.nxcals.api.backport.client.service.ServiceBuilder;
import cern.nxcals.api.config.SparkContext;
import cern.nxcals.api.extraction.data.builders.DataQuery;
import io.netty.util.internal.PlatformDependent;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -59,9 +60,17 @@ public class Application {
ConfigurableApplicationContext context = SpringApplication.run(Application.class, args);
SparkSession sparkSession = context.getBean(SparkSession.class);
LHCFillDataService fillDataService = ServiceBuilder.getInstance(sparkSession).createLHCFillService();
fillDataService.getLastCompletedLHCFillAndBeamModes();
Dataset<Row> dataset = DataQuery.builder(sparkSession)
.byEntities()
.system("MOCK-SYSTEM")
.startTime("2021-11-23 10:00:00.0")
.endTime("2021-11-23 10:00:59.999999999")
.entity().keyValue("device", "NXCALS_MONITORING_DEV1")
.build()
.where("`special-character`='test'")
.where("longField2 < 10000");
dataset.show();
// Random rand = new Random();
// ExecutorService executorService = Executors.newFixedThreadPool(5);
Loading