Skip to content

Commit

Permalink
delete not implemented functions
Browse files Browse the repository at this point in the history
  • Loading branch information
giwa committed Sep 20, 2014
1 parent f385976 commit c0a06bc
Showing 1 changed file with 4 additions and 6 deletions.
10 changes: 4 additions & 6 deletions python/pyspark/streaming/jtime.py
Original file line number Diff line number Diff line change
Expand Up @@ -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

0 comments on commit c0a06bc

Please sign in to comment.