100644 blob 00944f188f77278f62def03ceb4dd11c1784ad73	__init__.py
100644 blob da904bf6fb55b395b9a3df95aabf1e443f6d7bf4	avroio.py
100644 blob 6669b6fb8abff0546cb8ec2225412806432f62a5	avroio_test.py
040000 tree 791d157865b61ba6b2a3200586c3102d3c2e1f11	aws
040000 tree a92a4aab289c0d6edc7b0f5d5d47ace98f17f774	azure
040000 tree 9f337f5a1818a071a74ed4de74e8739446942e3a	components
100644 blob 35ae6fe273174f6edeaff259cd37bbeaf82c1d1c	concat_source.py
100644 blob efa24b3975fcd52b4056fc9b86f709bca671c024	concat_source_test.py
100644 blob 26516fa4e4b730c663fc071360a3bed8209d4a8e	debezium.py
040000 tree f3e968c8ef22076292a4987b6c7115f71a2efd13	external
100644 blob 78a390d9bed4ed083b8bd1e2e4712195ad0fea37	filebasedio_perf_test.py
100644 blob 8e0b39e1ac38041dbe35ff689c83715284be94ea	filebasedsink.py
100644 blob 121bc479200fe282169f6255312367f0b6e1ffcc	filebasedsink_test.py
100644 blob b80e4fb8a84110090dd10905c13254e3772837c1	filebasedsource.py
100644 blob 2728d2f91e0f03a56713ef445c75dd7f043cf018	filebasedsource_test.py
100644 blob 3251e567763fa04d5d609b4a21dd983b79f8c356	fileio.py
100644 blob ce535265ef2fbd91683eb66120c058f202b2f0a2	fileio_test.py
100644 blob e67337cf65ee71dd709919bed2bfecf5871493f8	filesystem.py
100644 blob fa68bc5ef6dfadf9a4fa70eb6401d7e2e0fd52d1	filesystem_test.py
100644 blob 571d1f2d2699a3ff933bf26b2560495753222db3	filesystemio.py
100644 blob cbf9449e78d1b7cce7a6626addae2b3765d481a4	filesystemio_test.py
100644 blob 8edd6bef790501166d15ecc9d52ae8d8c382e1bc	filesystems.py
100644 blob 1ea7c34d9f4f3de0c3fc774af86916d218a6d39c	filesystems_test.py
040000 tree 38e94e19c89db5f4427e61be03afd1972cbd32eb	flink
040000 tree 3af478cec6b620442cc90a65679eb70f94462431	gcp
100644 blob 3287644eed8c872cf1d507fa987145e548ce1734	hadoopfilesystem.py
100644 blob eb0925224dd31a65b6dfd054fb8e858f7d7c5108	hadoopfilesystem_test.py
040000 tree 6a812006eb2fea91ae64f3cc11cfb031efee992b	hdfs_integration_test
100644 blob 67d6cd358a07753b3812d885459530e899cebbf3	iobase.py
100644 blob acb44f4085bc2cf7436006def1f86311a1e2e879	iobase_it_test.py
100644 blob eb9617cfae3499798343d6cff54fd4950b2103f5	iobase_test.py
100644 blob df5d7f21a343169dc97cb74cb8d0f684b4c1a052	jdbc.py
100644 blob b633663932525c397a14f1d4de906bdc3860af75	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 78d1db4cc7c2049a05e3b24cfd0309c772e4be6a	parquetio_test.py
100644 blob 626564b00948930641608ef5dd22d6a02ac98af6	range_trackers.py
100644 blob 0bf37997f2cec1404193ee54fbbe39ffba8b5e3f	range_trackers_test.py
100644 blob e53fa07471afd8d88a9ddb50157791b749321b1d	requestresponse.py
100644 blob 8703653b266e03ff741e7f0c25f644ab38d8610f	requestresponse_it_test.py
100644 blob f88df9657dae79578f294dde3a48df7bbbc8410e	requestresponse_test.py
100644 blob 4b819e87a8d6828f2da963158b32e5574c301a52	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 ba28fc608a0cba651b8ed6d04d5cb9c8a574d3d2	textio.py
100644 blob 3854a22640a9116226b52acd0680863fbb7c447c	textio_test.py
100644 blob 073cbc1d211bd847ea8ba79a9ae106fe430c7244	tfrecordio.py
100644 blob e88ed1778633bc9857f7e8a9c3df6359605be2e7	tfrecordio_test.py
100644 blob 0d1f52f35f2b2fe04e0d26d854b6127d555cd40d	utils.py
100644 blob 76ed9969f9957423d8a22a7610c566390935030c	utils_test.py
100644 blob ea68608c821a0eb285fca2925cf58a3fbdc368a8	watermark_estimators.py
100644 blob 6fd1e463ddaf3ea7bbe1d01d1b9c763bf15b651b	watermark_estimators_test.py