100644 blob 3f9471bf72172ecb84111bd27c28a5dcfaacab71	OWNERS
100644 blob f730bcb2483c07c6b27c50e0f64f975de88ddef7	__init__.py
100644 blob b1cf6bd062d69d6a644ad595c26656bafc344938	avroio.py
100644 blob 049159e4c1fc97813f19e46e8d4d26dce443bfb3	avroio_test.py
100644 blob ddf3a77745ee9b5a2e1e070755eca876ef914400	concat_source.py
100644 blob 8a5b0fa5af3e268e53799af4c4209293c08af1ab	concat_source_test.py
040000 tree 6c7bf5c8d790f6d9a590117a3e1e2fde8f63e295	external
100644 blob 3e914707820383d295135b438c42f617b0e1e737	filebasedsink.py
100644 blob 666bc9cb899e8cb3714627d25fc79924b8404212	filebasedsink_test.py
100644 blob ec16b060c329dc8e117dae2a277d71b74cb92be7	filebasedsource.py
100644 blob 5f969d890a2717f30ede910455669c988b572714	filebasedsource_test.py
100644 blob a1a7a589ca84a011ea9550bdcc7b9bbb5f7e64c2	fileio.py
100644 blob 8c02dcf02bbc75837c5e6ecfe1d360023557bd07	fileio_test.py
100644 blob 4df3e01a934e0bd35738dd05dc57c934c4cd3be2	filesystem.py
100644 blob fbc094fd890d7fcb8489ef881a449924a94e75df	filesystem_test.py
100644 blob b2d74c1eab8fd15b9411f7e9062de3b20082b544	filesystemio.py
100644 blob 72e7f0d0aae69c796295d8e90df940a4f0733e75	filesystemio_test.py
100644 blob d8b3a4a545423eb38b7ecfbe9b4994d942e35242	filesystems.py
100644 blob 383eb40ea07240935b8accfffffe2a489a4ee17d	filesystems_test.py
040000 tree 596538d936f94e1110a0ea04f9b5643a2212bf08	flink
040000 tree 7e84a5142d597c8a0f5e63aac0aae77a20ec6117	gcp
100644 blob 71d74e893497c09ba13a8fd33feab257a80bb4a9	hadoopfilesystem.py
100644 blob 06d9fa92129312ac82cbb1a29090670c546278ea	hadoopfilesystem_test.py
040000 tree 122464d42c8a5de9cc2aa254aa0900ac9184b434	hdfs_integration_test
100644 blob 605c1bf0984dd146baf3439ff7193ff679c6e787	iobase.py
100644 blob c7d165677f55140fa91dd4174be38d0dc45458eb	iobase_test.py
100644 blob 20748a2ff6bebe08a044af3cafdc479b72a2eb4a	localfilesystem.py
100644 blob 43f64f7959ed6e5a93be874c60b7d07a99cf3bdc	localfilesystem_test.py
100644 blob 6004ca1a026eb294bb0142dbccac1d77cfd0f716	mongodbio.py
100644 blob bfc60995b57a08b09a19e8c045bf62b5fe449619	mongodbio_it_test.py
100644 blob 3f07ec17aa69a3fafef54c04851010cea825aec2	mongodbio_test.py
100644 blob a4e894cdaee55f3e5650c596d8f1a6a4a35c1beb	parquetio.py
100644 blob 0b58f47e4aced710450577a2919352131950339d	parquetio_it_test.py
100644 blob d9b488de23302b1f59a26a01b11ddbdb5176f103	parquetio_test.py
100644 blob c46f801035c9f1bc7f5eef525b30e97383d3afbe	range_trackers.py
100644 blob e80401f2218d7577eb7576e20d9d54f2b50d51f6	range_trackers_test.py
100644 blob 0ba5b23550c953a521adaa4c9419ba245470c7c7	restriction_trackers.py
100644 blob 459b03978e9f5657ba19fd5413ef639ce5c1c0f6	restriction_trackers_test.py
100644 blob d90d2455a52f44be4668a295b7052bd1a23cae30	source_test_utils.py
100644 blob a8c3d82f0bbbdb147bd7f2cab015dfd80164654e	source_test_utils_test.py
100644 blob 8908681c86047f0e9bf1fe94a99cdf951b19d2e4	sources_test.py
100644 blob 340449f8896e4d9d5729f2a1469eadab813a3957	textio.py
100644 blob fc6da454e9ac06445aff024653b9ee465a65b422	textio_test.py
100644 blob a07878e2ef71ff0b60251af31d6898b3da9783d0	tfrecordio.py
100644 blob c0a3c2dca446fd7212bc6d911a22b6f0cbd724a8	tfrecordio_test.py
100644 blob d5912ae8c38444a5b57b9ddd73e5589d164bf510	utils.py
100644 blob 3d571b31f6d50cbca2a422119b841da2a71532c5	utils_test.py
100644 blob 2a13bf8a6bf00d536a83349d334713dff2f82458	vcfio.py
100644 blob 9a4b793e08c6e509a891edbfca56e9ea16d3158c	vcfio_test.py