From c0a06bc6f293643ffa3a2c6ce7a778d740ff37c7 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 f169228e81868..eb91ad94457fa 100644 --- a/python/pyspark/streaming/jtime.py +++ b/python/pyspark/streaming/jtime.py @@ -126,14 +126,12 @@ def isMultipbleOf(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 +