databricks-logo

TWS Python Top K

(Python)

TWS Python Top K

2

Collecting dbldatagen Using cached dbldatagen-0.4.0.post1-py3-none-any.whl.metadata (9.9 kB) Using cached dbldatagen-0.4.0.post1-py3-none-any.whl (122 kB) Installing collected packages: dbldatagen Successfully installed dbldatagen-0.4.0.post1 [notice] A new release of pip is available: 24.0 -> 25.0.1 [notice] To update, run: pip install --upgrade pip
4

synthetic_data_1739563009

Define output schema

6

Define stateful processor

8

9

10

2b2017a6-4fef-4c3b-9258-5a555312982a
Last updated: 153 days ago

(Optional) Drop the test table and delete output/ckp path

12

    DataFrame[]
    13

      True
      ;