From 67473a950c922693a0ca38630f8fa53d4edb9d53 Mon Sep 17 00:00:00 2001 From: giwa Date: Thu, 21 Aug 2014 15:43:57 -0700 Subject: [PATCH] delete not implemented functions --- python/pyspark/streaming/jtime.py | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/python/pyspark/streaming/jtime.py b/python/pyspark/streaming/jtime.py index 02e0e0cf2d17e..801b8871b3879 100644 --- a/python/pyspark/streaming/jtime.py +++ b/python/pyspark/streaming/jtime.py @@ -125,14 +125,12 @@ def isMultipbleOf(self, duration): Duration._is_duration(duration) return self._millis % duration._millis == 0 - def until(time, interval): - raise NotImplementedError - - def to(time, interval): - raise NotImplementedError - @classmethod def _is_time(self, instance): """ is instance Time """ if not isinstance(instance, Time): raise TypeError + +# TODO: implement until +# TODO: implement to +