We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c97377c commit 67473a9Copy full SHA for 67473a9
1 file changed
python/pyspark/streaming/jtime.py
@@ -125,14 +125,12 @@ def isMultipbleOf(self, duration):
125
Duration._is_duration(duration)
126
return self._millis % duration._millis == 0
127
128
- def until(time, interval):
129
- raise NotImplementedError
130
-
131
- def to(time, interval):
132
133
134
@classmethod
135
def _is_time(self, instance):
136
""" is instance Time """
137
if not isinstance(instance, Time):
138
raise TypeError
+
+# TODO: implement until
+# TODO: implement to
0 commit comments