tloubrieu-jpl commented on a change in pull request #104:
URL:
https://github.com/apache/incubator-sdap-nexus/pull/104#discussion_r451853844
##########
File path: analysis/webservice/algorithms_spark/NexusCalcSparkHandler.py
##########
@@ -0,0 +1,359 @@
+import logging
+
+import numpy as np
+from netCDF4._netCDF4 import Dataset
+from webservice.algorithms.NexusCalcHandler import NexusCalcHandler
+from webservice.metrics import MetricsRecord, SparkAccumulatorMetricsField,
NumberMetricsField
+from webservice.webmodel import NexusProcessingException
+
+
+class NexusCalcSkarkHandler(NexusCalcHandler):
Review comment:
updated
##########
File path: analysis/webservice/algorithms_spark/TimeAvgMapSpark.py
##########
@@ -21,15 +21,18 @@
import shapely.geometry
from nexustiles.nexustiles import NexusTileService
from pytz import timezone
-from webservice.NexusHandler import nexus_handler, SparkHandler
+from webservice.NexusHandler import nexus_handler
+from webservice.algorithms_spark.NexusCalcSparkHandler import
NexusCalcSkarkHandler
from webservice.webmodel import NexusResults, NexusProcessingException,
NoDataException
EPOCH = timezone('UTC').localize(datetime(1970, 1, 1))
ISO_8601 = '%Y-%m-%dT%H:%M:%S%z'
@nexus_handler
-class TimeAvgMapSparkHandlerImpl(SparkHandler):
+class TimeAvgMapNexusSkarkHandlerImpl(NexusCalcSkarkHandler):
Review comment:
updated
##########
File path: analysis/webservice/algorithms_spark/TimeSeriesSpark.py
##########
@@ -42,7 +43,7 @@
@nexus_handler
-class TimeSeriesHandlerImpl(SparkHandler):
+class TimeSeriesSkarkHandlerImpl(NexusCalcSkarkHandler):
Review comment:
updated
##########
File path: analysis/webservice/algorithms_spark/VarianceSpark.py
##########
@@ -23,15 +23,16 @@
from nexustiles.nexustiles import NexusTileService
from pytz import timezone
-from webservice.NexusHandler import nexus_handler, SparkHandler
+from webservice.NexusHandler import nexus_handler
+from webservice.algorithms_spark.NexusCalcSparkHandler import
NexusCalcSkarkHandler
from webservice.webmodel import NexusResults, NexusProcessingException,
NoDataException
EPOCH = timezone('UTC').localize(datetime(1970, 1, 1))
ISO_8601 = '%Y-%m-%dT%H:%M:%S%z'
@nexus_handler
-class VarianceSparkHandlerImpl(SparkHandler):
+class VarianceNexusSkarkHandlerImpl(NexusCalcSkarkHandler):
Review comment:
updated
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
