100644 blob cce3acad34a49511f09625f0f965df4ab3ea9e66	__init__.py
100644 blob bc36c8c2ff1780c8cf5ac25abd59d3a1946fff4b	avro_nyc_trips.py
100644 blob 55b3ba1695a480b88c0c96a5b43c94f89d3bd3e0	avro_nyc_trips_it_test.py
100644 blob 0dd31962a2f40f9043e3bc0fc090064bfe20d6c1	avro_nyc_trips_test.py
100644 blob 78afa1482b371c1040f9cd57007a1f2222335152	california_housing_clustering.py
040000 tree a431f1a303fb7a3f5d8f3734fe124a41c07581d2	complete
040000 tree f1af7b042bf7f522d561b46cfbd11e53ff45ced1	cookbook
040000 tree df90bfeb48f19ae80e8a62b52983d535919cb0fa	dataframe
100644 blob f37656e897bde41b1756f55043ff58945acad0b5	fastavro_it_test.py
040000 tree 276bdbb69b5d591fdf61ec7fe6ffe4cb00adaafa	flink
040000 tree f8683ac540092cfa92cc80bbe16b04a06ced09e5	inference
040000 tree f080ef7f7fd2120c62c64694df8817fbb8d84df1	kafkataxi
100644 blob cc9a06790e88fbbd46250d5d097223a0f4cee3c3	matrix_power.py
100644 blob ff17ca5ff123905f89377017cd7c21a48677116b	matrix_power_test.py
040000 tree 42deb9dcf256d0f7a2119864b3f7386b742aa83f	ml-orchestration
040000 tree b99c78de8b6ffccbe066346b04de9ac37a2f72c6	ml_transform
100644 blob 40076c5d986eaf049b02d152e8ddf62a527189dd	online_clustering.py
100644 blob e2b267492b2732b748e8655a37a8e71ef5a0a239	per_entity_training.py
100644 blob 00c0a34c377578513abb3112f4fdf1777d2c9777	rate_limiter_simple.py
040000 tree 7d0c2a3bc5d1850730507a99dea7584e69648f5f	sinks
040000 tree 5760836aebb203a8e5414a3c0e08ce4034fe8089	snippets
100644 blob 9cee37305f687e72486f0646b35cda050a075beb	sql_taxi.py
100644 blob 9ae763df81a5e0d1122d11b5dac58cbf6646d6cd	streaming_wordcount.py
100644 blob af99a4ab537dae27865f2c81bdf6c3aab181294b	streaming_wordcount_debugging.py
100644 blob f3460ec24f1acdb87cbd1a55d759d9be51d74e93	streaming_wordcount_debugging_it_test.py
100644 blob 2ab80993080cfa19169496a57161a5441d2df80e	streaming_wordcount_debugging_test.py
100644 blob 9ed27a500a7abcd6ac8cb39370f33a08b2a033bc	streaming_wordcount_it_test.py
040000 tree c44af14339bbb5c867e4e6a1b43ba33fde88c965	timestamp_buffer
100644 blob 7889f61b9a6257ee96b54aa81d4ec54d0c9b98ef	windowed_wordcount.py
100644 blob a9138647581cdc9d87fc3b78476852231e687acb	wordcount.py
100644 blob b6517fce76bd30180c23d7f32ead4b59c5b29dc8	wordcount_dataframe.py
100644 blob 581bbd3adc1bdee133b55cc323df2aafeed6faf5	wordcount_debugging.py
100644 blob 8a19bce777add0e62f35c1ae28a0a57c7df13a02	wordcount_debugging_test.py
100644 blob 63f661dba212eb98fae4371bb10a5efdc6fbe354	wordcount_it_test.py
100644 blob edd532b87a3d2d212777e1c504cb3c2c55a6bcb0	wordcount_minimal.py
100644 blob 68b4ddd7ce1aabea9962df4b7723fda234729c25	wordcount_minimal_test.py
040000 tree 72bcbd3763799cd5513c74803abba8cb042f2bfa	wordcount_rust
100644 blob cea0ce368e5559c7bb57d6a2d2e35b051bde551b	wordcount_test.py
100644 blob f575a8d7fbba8beb2157e30012726d36db1c763b	wordcount_with_metrics.py
100644 blob 80a0c8fe7a4f6b84d61415635aed636bdccbc3b8	wordcount_xlang.py
100644 blob 632e90303010e1bd17addad134a0a6b41dfe4390	wordcount_xlang_sql.py