100644 blob 7dce27abe126476716e95ab777dd81ebd0dd90bf	OWNERS
100644 blob 6569e3fe5de4d1e0bffad7083f704fb756938c06	__init__.py
100644 blob f877aafebceb4b1b13163a24bdc029b43d205097	avro_bitcoin.py
040000 tree edb80c8e7419f688e94adfeccb65160d086b9f83	complete
040000 tree 2c590bc5d848b12aafa0bfd8943980bd4bf5e870	cookbook
100644 blob d4aca2ce654312f6859d6a3aa89c77a35e2e278a	fastavro_it_test.py
040000 tree 01d9b689dcdc15248d39da446e0d8bc69057636a	flink
040000 tree e887c6c2e3caf4dad5ced7313264722eb928f5d6	kafkataxi
040000 tree 2a1c55e2e71f9a312009f5851bf0e6c9e88654b5	snippets
100644 blob a64fda5f6b3dca6a9c76127d05d5cd308fc086a8	streaming_wordcount.py
100644 blob 28d9df9de5838b832829bd4a14d41d9e80e9af6f	streaming_wordcount_debugging.py
100644 blob 526863d47b66844796013da62d9adf32144f629c	streaming_wordcount_debugging_it_test.py
100644 blob 1210c480a7bf5e8930382149317f518abde67ca3	streaming_wordcount_debugging_test.py
100644 blob cd79ddfef48612a7394540c5628b7bafa29fe0a1	streaming_wordcount_it_test.py
100644 blob a93c0759d83fe5c0191565b980d2a392b29e1d76	windowed_wordcount.py
100644 blob 6732568d0543b2cd11d106908bd5e532a5bf9b47	wordcount.py
100644 blob 19f511e73e88f9c17b26c85effc5c8e9a7440f53	wordcount_debugging.py
100644 blob c92df6df772d8dab90d32c9f8d19b479202fc7c6	wordcount_debugging_test.py
100644 blob c7cb415465b7b442d363ac961bd5e81626d413e9	wordcount_it_test.py
100644 blob a4f7057d7ba486c4c10e19b95c822e49d0299c35	wordcount_minimal.py
100644 blob a966401204f02230e185ce8623ff6d45a769cb9a	wordcount_minimal_test.py
100644 blob 51c0bc4efdb5f5d87b4e4f3fd91fca5ec4431490	wordcount_test.py
100644 blob 88690e7b507498a13026344a142e7cd623e84b29	wordcount_xlang.py
100644 blob 28f58a372852dfe79c54347fb2eaad55d7e11c33	wordcount_xlang_sql.py