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 05aac94b24fb0b0927b2c04e21397d659a27d5a0	cookbook
040000 tree df90bfeb48f19ae80e8a62b52983d535919cb0fa	dataframe
100644 blob f37656e897bde41b1756f55043ff58945acad0b5	fastavro_it_test.py
040000 tree 276bdbb69b5d591fdf61ec7fe6ffe4cb00adaafa	flink
040000 tree f3e917f8a6296ce4bacacc500122bdaf0772099a	inference
040000 tree e713393360ab094379ca9c3598556b438787d76d	kafkataxi
100644 blob cc9a06790e88fbbd46250d5d097223a0f4cee3c3	matrix_power.py
100644 blob b824ba7e24c2558f21ec7ca3af3f0cdfca0e8bb7	matrix_power_test.py
040000 tree d2e02485ed5fecfbbd7d672c47a37748442784f6	ml-orchestration
040000 tree cd3c67300b591c682aaf6ea068ee52328c5f5234	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 232f1295e06ce4aabb17d5d355c3b778066bfda2	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
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 3d708eacbdc3e3b5aa2006c369ac84a4afc4731d	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