Package cern.nxcals.api.extraction.data.spark

Class SparkExtractionTaskExecutor

java.lang.Object

cern.nxcals.api.extraction.data.spark.SparkExtractionTaskExecutor

public class SparkExtractionTaskExecutor
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
SparkExtractionTaskExecutor(org.apache.spark.sql.SparkSession session)

Method Summary

Modifier and Type	Method	Description
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>	execute(cern.nxcals.common.domain.ExtractionUnit unit)
java.util.List<org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>>	executeExpanded(cern.nxcals.common.domain.ExtractionUnit unit)

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkExtractionTaskExecutor

public SparkExtractionTaskExecutor(org.apache.spark.sql.SparkSession session)

Method Detail

execute

public org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> execute(cern.nxcals.common.domain.ExtractionUnit unit)

executeExpanded

@Experimental
public java.util.List<org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>> executeExpanded(cern.nxcals.common.domain.ExtractionUnit unit)