tumbling -> window namespace

sqlflow/serde.py

@@ -2,8 +2,6 @@
 from abc import ABC, abstractmethod
 
 
-
-
 class Serializer(ABC):
     @abstractmethod
     def encode(self, d: object) -> bytes:

sqlflow/sql.py

@@ -6,7 +6,7 @@
 
 from confluent_kafka import Consumer, KafkaError, KafkaException, Producer
 
-from sqlflow.window import handlers
+from sqlflow import window
 from sqlflow.outputs import ConsoleWriter, Writer, KafkaWriter
 
 
@@ -117,9 +117,9 @@ def handle_tables(conn, tables):
         if table.window.type != 'tumbling':
             raise NotImplementedError('only tumbling window is supported')
 
-        h = handlers.Tumbling(
+        h = window.Tumbling(
             conn=conn,
-            table=handlers.Table(
+            table=window.Table(
                 name=table.name,
                 time_field=table.window.time_field,
             ),

sqlflow/window/__init__.py

@@ -0,0 +1 @@
+from .handlers import Tumbling