Skip to content

Commit 67473a9

Browse files
committed
delete not implemented functions
1 parent c97377c commit 67473a9

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

python/pyspark/streaming/jtime.py

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -125,14 +125,12 @@ def isMultipbleOf(self, duration):
125125
Duration._is_duration(duration)
126126
return self._millis % duration._millis == 0
127127

128-
def until(time, interval):
129-
raise NotImplementedError
130-
131-
def to(time, interval):
132-
raise NotImplementedError
133-
134128
@classmethod
135129
def _is_time(self, instance):
136130
""" is instance Time """
137131
if not isinstance(instance, Time):
138132
raise TypeError
133+
134+
# TODO: implement until
135+
# TODO: implement to
136+

0 commit comments

Comments
 (0)