Class GetDataFrameOfElementsHandler
- java.lang.Object
-
- uk.gov.gchq.gaffer.sparkaccumulo.operation.handler.dataframe.GetDataFrameOfElementsHandler
-
- All Implemented Interfaces:
OperationHandler<GetDataFrameOfElements>
,OutputOperationHandler<GetDataFrameOfElements,org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>>
public class GetDataFrameOfElementsHandler extends Object implements OutputOperationHandler<GetDataFrameOfElements,org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>>
-
-
Constructor Summary
Constructors Constructor Description GetDataFrameOfElementsHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
doOperation(GetDataFrameOfElements operation, Context context, AccumuloStore store)
org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>
doOperation(GetDataFrameOfElements operation, Context context, Store store)
Execute the givenOutput
operation.
-
-
-
Method Detail
-
doOperation
public org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> doOperation(GetDataFrameOfElements operation, Context context, Store store) throws OperationException
Description copied from interface:OutputOperationHandler
Execute the givenOutput
operation.- Specified by:
doOperation
in interfaceOperationHandler<GetDataFrameOfElements>
- Specified by:
doOperation
in interfaceOutputOperationHandler<GetDataFrameOfElements,org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>>
- Parameters:
operation
- theOutput
operation to be executedcontext
- the operation chain context, containing the user who executed the operationstore
- theStore
the operation should be run on- Returns:
- the output for the operation.
- Throws:
OperationException
- thrown if the operation fails
-
doOperation
public org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> doOperation(GetDataFrameOfElements operation, Context context, AccumuloStore store) throws OperationException
- Throws:
OperationException
-
-