100644 blob cce3acad34a49511f09625f0f965df4ab3ea9e66	__init__.py
040000 tree 3530155c73ba32e054849ace53bc7bbdfec16d5b	gcp
100644 blob 1f94a8d1d9e969b79b11ade66211813c6760e3a6	generate_sequence.py
100644 blob d44fd363b95a3cccb5b4327bb49101128a4a7d8d	generate_sequence_test.py
100644 blob ca577844f0eebebbea83d4df6f55830249dfe9ca	kafka.py
100644 blob cf3aedc0685628dae36dc28c23a676d07d4d0866	snowflake.py
100644 blob d659d57aad90f3645ec4893e5ff61147e08118c8	xlang_bigqueryio_it_test.py
100644 blob d20a64466323324598873e479354cc444b96ae2f	xlang_debeziumio_it_test.py
100644 blob 069f13e11bfb3129eb6a494261db845c2b4de286	xlang_jdbcio_it_test.py
100644 blob 23178b0ee36367b4412be8b538e9c9f020a963fb	xlang_kafkaio_it_test.py
100644 blob 50703144d109ff4797bef1dd03581be23cc154fa	xlang_kafkaio_perf_test.py
100644 blob 6a86248571e33f6a4c15caacf28ccdfb09d88839	xlang_kinesisio_it_test.py
100644 blob b4074d156ce7cf8c5cfbd427b0589620367ffefa	xlang_parquetio_test.py
100644 blob f78175a8696d211982800d87cc17cdd171b42e44	xlang_snowflakeio_it_test.py