100644 blob 00944f188f77278f62def03ceb4dd11c1784ad73	__init__.py
100644 blob 000b824d0ed0fe22a7e3208e3d0c749bd9d7fe5c	avroio.py
100644 blob 80c245ad3db478c6c7f7c413708121dce05768c0	avroio_test.py
040000 tree 788e2fe07483dee2cacbd3be9cba2af078e1c90d	aws
040000 tree d7ae402517fa5b57670fed995999dca6f16bbbcc	azure
040000 tree 05ef046cdb81c895e9556de32c21b24e3cf6ba0a	components
100644 blob 35ae6fe273174f6edeaff259cd37bbeaf82c1d1c	concat_source.py
100644 blob efa24b3975fcd52b4056fc9b86f709bca671c024	concat_source_test.py
100644 blob 5b5efe86fba9a33608e23f971952d05e7ac51ecb	debezium.py
040000 tree 3089731055159a8957beed5c7f69dfe862cfeef2	external
100644 blob 75ed67313a415b081d9e7bca9afa4ff2f18515dc	filebasedio_perf_test.py
100644 blob 8e0b39e1ac38041dbe35ff689c83715284be94ea	filebasedsink.py
100644 blob 121bc479200fe282169f6255312367f0b6e1ffcc	filebasedsink_test.py
100644 blob a766f0554ea27d1f0fedec2275be951c0ffb84f6	filebasedsource.py
100644 blob 2728d2f91e0f03a56713ef445c75dd7f043cf018	filebasedsource_test.py
100644 blob fcce83fa59ec507d6e66b7933dc5b20f4ee049e8	fileio.py
100644 blob 1c650653804cd3d4dea117ae38aa350c95397ccf	fileio_test.py
100644 blob bfddb42dd91225220e968154422ec10577cbf341	filesystem.py
100644 blob fa68bc5ef6dfadf9a4fa70eb6401d7e2e0fd52d1	filesystem_test.py
100644 blob daa02e5860122e0611a1efc6525bdff30aa0834e	filesystemio.py
100644 blob cbf9449e78d1b7cce7a6626addae2b3765d481a4	filesystemio_test.py
100644 blob 8edd6bef790501166d15ecc9d52ae8d8c382e1bc	filesystems.py
100644 blob e4818d9a935a40cb1e3d4fcc75abf534c2180f0c	filesystems_test.py
040000 tree 29d5e14193db1198cab404736eaa6a0e7fa4fc02	flink
040000 tree 3549770d691dd3771d5f51f85425370d0e771438	gcp
100644 blob 3287644eed8c872cf1d507fa987145e548ce1734	hadoopfilesystem.py
100644 blob eb0925224dd31a65b6dfd054fb8e858f7d7c5108	hadoopfilesystem_test.py
040000 tree 6a812006eb2fea91ae64f3cc11cfb031efee992b	hdfs_integration_test
100644 blob 34ee781d87a11c99dc32d31fe6f88cf9d3a66fa6	iobase.py
100644 blob acb44f4085bc2cf7436006def1f86311a1e2e879	iobase_it_test.py
100644 blob 4621fa45bb151d688a970ad255c40255c2b513ac	iobase_test.py
100644 blob d3b8761c78294c9a45d418ffbfda486904d1d225	jdbc.py
100644 blob f7cdd7f7b8765f5389cd6e0cbbc3a81daa133650	kafka.py
100644 blob b4c939703f94b6bcb2f86ed6bc6ffae746c36c8d	kinesis.py
100644 blob 5936702b321a19023108688d2b467ef070c75638	localfilesystem.py
100644 blob c3bccd0dfcb8ddba8f9593c924e8ec95ddbdd3e3	localfilesystem_test.py
100644 blob aede27674f8f315dc2142b1f448dce13cfa1e8dc	mongodbio.py
100644 blob dfbc9e65305bc674a0d5399d23d19c764a2f14e2	mongodbio_it_test.py
100644 blob d9f630d01861215dcfe129fd857b75f99491e60a	mongodbio_test.py
100644 blob e5dce15e71efa4040a914f27edf675706031f2fb	parquetio.py
100644 blob b06e7268fec483bb844ab4cc5e5bd38949f4de96	parquetio_it_test.py
100644 blob c7bf687f12cddf26c06f9604c1c2bbd1751e89de	parquetio_test.py
100644 blob 7f6b535028867ec9f105364f48a727295c5d638b	range_trackers.py
100644 blob 8b829616bf52cf72c57e249d669a0153ce75a697	range_trackers_test.py
100644 blob ef570f4d855653b9bd2978580c83cb3e21d6c1f6	requestresponse.py
100644 blob 072a1dc27b9ffcd80caab48d60ded0976eab97a2	requestresponse_it_test.py
100644 blob 7d4d6b4caf38a222f9aa227742c45cb26731df14	requestresponse_test.py
100644 blob 7f4cf14747fa83e901488667ef716e6135606544	restriction_trackers.py
100644 blob 0d3eee18036e87030d243b15c7a5ec3652a08fd6	restriction_trackers_test.py
100644 blob 7f85af5ac6913b2ac9502b81c24a65b89504d3af	snowflake.py
100644 blob 1b3aeb4744625b2aa877e92221eb8cce339beb28	source_test_utils.py
100644 blob 081a6fcb60ca6a3fd60a535d078d81fc58946fd8	source_test_utils_test.py
100644 blob f75e4fdafff0f00738d567ca25113467fa3f7e22	sources_test.py
100644 blob a2af75f89d1b63e0bfab93ecc2f501946e4cae07	textio.py
100644 blob b67b1b3f0e6a4fba0a30f320555f359e69e45dd5	textio_test.py
100644 blob faa925d2f1e86ada16af07c8ad738dc7a60aa0c2	tfrecordio.py
100644 blob e88ed1778633bc9857f7e8a9c3df6359605be2e7	tfrecordio_test.py
100644 blob 99e987522f56c396d7f88010787021c5357e7409	unbounded_source.py
100644 blob d4646e94de59fc552a995947c6ec26c67d576da7	unbounded_source_test.py
100644 blob 0d1f52f35f2b2fe04e0d26d854b6127d555cd40d	utils.py
100644 blob 76ed9969f9957423d8a22a7610c566390935030c	utils_test.py
100644 blob 70adaa44417828d9335e3b8ec5fa1b6b2ce763a6	watch.py
100644 blob a44428af5923f16aa705154b742d3778f89a49da	watch_test.py
100644 blob ea68608c821a0eb285fca2925cf58a3fbdc368a8	watermark_estimators.py
100644 blob 6fd1e463ddaf3ea7bbe1d01d1b9c763bf15b651b	watermark_estimators_test.py