Skip to content

Commit c0a06bc

Browse files
committed
delete not implemented functions
1 parent f385976 commit c0a06bc

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
@@ -126,14 +126,12 @@ def isMultipbleOf(duration):
126126
Duration._is_duration(duration)
127127
return self._millis % duration._millis == 0
128128

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

0 commit comments

Comments
 (0)