100644 blob 3f9471bf72172ecb84111bd27c28a5dcfaacab71	OWNERS
100644 blob 4945da97d90f33b629305b9ccfd0d27b3da2509f	__init__.py
100644 blob d86f59e3a4111df8bd9258df9656f98715ecf0be	avroio.py
100644 blob ba35cf5846c0514ef8116b0c03457d8d07a84ad2	avroio_test.py
040000 tree 9e048d0c14261bde3a0a496318ace916b520d0ff	aws
040000 tree b2ae06e23e62edf927ae64c8cbe8fefbef793684	azure
100644 blob 35ae6fe273174f6edeaff259cd37bbeaf82c1d1c	concat_source.py
100644 blob efa24b3975fcd52b4056fc9b86f709bca671c024	concat_source_test.py
100644 blob ada25760c27a2533f3064d5eab64808372ea604b	debezium.py
040000 tree a3c9e8f06b18784541790fc6e9da6ae0b6743abe	external
100644 blob 78a390d9bed4ed083b8bd1e2e4712195ad0fea37	filebasedio_perf_test.py
100644 blob 816de9d33a054f013999a2ba1e4ba6af382d21a8	filebasedsink.py
100644 blob 121bc479200fe282169f6255312367f0b6e1ffcc	filebasedsink_test.py
100644 blob 240fc65c52b3d509b94af0e36af3120cdfea5903	filebasedsource.py
100644 blob e68d2afbac9db1c92db5a2a21a4683bb16009d51	filebasedsource_test.py
100644 blob da6e86e2cf343d6d1dc89f3534234f4d37b228ac	fileio.py
100644 blob ff4be9d3d7cc3f0063da16b73a83fbf8621b6810	fileio_test.py
100644 blob fa1f67ac03fd763d2976ebf47c41440abee37fe9	filesystem.py
100644 blob 0b1827f9f7d87b0d95dd817b9d03ab87a842da99	filesystem_test.py
100644 blob 571d1f2d2699a3ff933bf26b2560495753222db3	filesystemio.py
100644 blob cbf9449e78d1b7cce7a6626addae2b3765d481a4	filesystemio_test.py
100644 blob 4683d2bb5f1180669fedd8b16a1044f939d875a4	filesystems.py
100644 blob 1ea7c34d9f4f3de0c3fc774af86916d218a6d39c	filesystems_test.py
040000 tree 6131919268eb76d415e74150dc0d8d18c3e2a0d3	flink
040000 tree 9f54911c385e7873c94fd50c11d56e133d91d803	gcp
100644 blob c47a66c0f10506ca70c59a517a85a26af43888e0	hadoopfilesystem.py
100644 blob 8c21effc882394bc955d87135cb4a2c0d4ee953d	hadoopfilesystem_test.py
040000 tree 8faa94adfd964a3dba60d51641e0384643caa342	hdfs_integration_test
100644 blob 6d75d520af55b92929500f5aa4fe1fb94369ba45	iobase.py
100644 blob eb9617cfae3499798343d6cff54fd4950b2103f5	iobase_test.py
100644 blob 85b80fdea0e47f6d83e4e94d0e695485c17532b9	jdbc.py
100644 blob eaabaf363638d2f23e72eba2c625a533f6cdc639	kafka.py
100644 blob bc5e1fa787b451b57eb9e944dab45f300270d6a6	kinesis.py
100644 blob 3580b79ea56ffe04ecd09164286a676427c4ecd3	localfilesystem.py
100644 blob 1370790970e9a0dfcb0bdc9188cdf108e9ca6d4f	localfilesystem_test.py
100644 blob f6c1bdf445f3b5a594d92f79576c45069bcb2e18	mongodbio.py
100644 blob dfbc9e65305bc674a0d5399d23d19c764a2f14e2	mongodbio_it_test.py
100644 blob 150eac2d5437b9b5e01cca71fe56d6b2496440ae	mongodbio_test.py
100644 blob dfcc1abec29a0c964d4a4d827ec385ee9963a0ab	parquetio.py
100644 blob 052b54f3ebfbb3a24b0cf606761d7d934536dc80	parquetio_it_test.py
100644 blob df018a3a776f76fc0db77a807790ee77dfbb315c	parquetio_test.py
100644 blob adadc1a7ae41e0e5f5ad3267f4ec2ea809aaf01c	range_trackers.py
100644 blob 0bf37997f2cec1404193ee54fbbe39ffba8b5e3f	range_trackers_test.py
100644 blob 06b06fa1ed34dc04e2494fa07a41343bda4eb302	restriction_trackers.py
100644 blob 0d3eee18036e87030d243b15c7a5ec3652a08fd6	restriction_trackers_test.py
100644 blob d789a72001df20b1e9f44b1ce764f5f42b620983	snowflake.py
100644 blob b40f70604c4228f5c5c796b518e720810e46cac0	source_test_utils.py
100644 blob 081a6fcb60ca6a3fd60a535d078d81fc58946fd8	source_test_utils_test.py
100644 blob f75e4fdafff0f00738d567ca25113467fa3f7e22	sources_test.py
100644 blob 289c91e23b0adde32311148f2f5b4b7fa9ac910d	textio.py
100644 blob 6fb8d6ccb362d9d7d944cbfb3bb5d97ef58c67ac	textio_test.py
100644 blob d3bb0f8acf3f291a51b708566f65d0e77dac2f6c	tfrecordio.py
100644 blob a867c0212ad3deae1098e701ccf113c53023fe0e	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