100644 blob 3f9471bf72172ecb84111bd27c28a5dcfaacab71	OWNERS
100644 blob 4945da97d90f33b629305b9ccfd0d27b3da2509f	__init__.py
100644 blob 45a619c19bbb6e3dd7993b75052c0ae2b7e8591e	avroio.py
100644 blob 2cb5c5cfae8cd768754e07fea69d9c994d4e8a46	avroio_test.py
040000 tree ffcdb40468d76189090874e82e2f0b9f6f998719	aws
040000 tree e4085f8bb1293b62a93a407183f0212313b17154	azure
100644 blob 3872ccbe01ae5955c8c1f47dfb4a0b17ca0e2496	concat_source.py
100644 blob efa24b3975fcd52b4056fc9b86f709bca671c024	concat_source_test.py
100644 blob e598b97d4526d69003bb5901a213c7f27042638d	debezium.py
040000 tree fb9f896a078e8e6513621e7bf40ede33c69e7818	external
100644 blob cae317493d5ea6e0d17f1ef4c23caf406eab081d	filebasedsink.py
100644 blob c75958ce744e59f6e2a99bf575e0cd061c98506f	filebasedsink_test.py
100644 blob 38830e73fbc518ce4a73afff28193d457133c48c	filebasedsource.py
100644 blob e68d2afbac9db1c92db5a2a21a4683bb16009d51	filebasedsource_test.py
100644 blob 8c990b1146975db57ed8a3f2211ee75106e50b2c	fileio.py
100644 blob 90086c967364280e15730264a93d137d2c52ebe4	fileio_test.py
100644 blob 687ab043b1dc4055e49e7440b7f42cb9f4e9c659	filesystem.py
100644 blob 83453a96d24726a154989bd8bfb5215cdb3a2bcf	filesystem_test.py
100644 blob 70f39daf661c77766890464a66e68409dc8a9a81	filesystemio.py
100644 blob cbf9449e78d1b7cce7a6626addae2b3765d481a4	filesystemio_test.py
100644 blob 4683d2bb5f1180669fedd8b16a1044f939d875a4	filesystems.py
100644 blob 1083499b4e2b68c34bf5eaeea702bb4426c6883a	filesystems_test.py
040000 tree 6131919268eb76d415e74150dc0d8d18c3e2a0d3	flink
040000 tree f358fb9072439489f46181c8587f25d870701d98	gcp
100644 blob 041b9c54cb0d73931958d583ab40e943cc3de857	hadoopfilesystem.py
100644 blob ed56927cec0eb134f7d27bf2917c7fc10ce98880	hadoopfilesystem_test.py
040000 tree 8faa94adfd964a3dba60d51641e0384643caa342	hdfs_integration_test
100644 blob 8e81da31fb5b0fbe7b140ead4936adb55ae873fc	iobase.py
100644 blob bde05664e3804508311307b088ef5fb1e0c42b2a	iobase_test.py
100644 blob 060a4d8d177a8c5d84511707751abda986a69a43	jdbc.py
100644 blob 3e28cfe59839f1e53a903c84bef1ddf740cc1919	kafka.py
100644 blob 4a70f76d83d185fb076a03901198ea282daf3248	kinesis.py
100644 blob 56668aa895290f0eb875ef7a16f17fa504d44ee9	localfilesystem.py
100644 blob 84455c28f4cdb3db108a6b521e4ab104e2095561	localfilesystem_test.py
100644 blob c6f7d97f4705407e9881fa20255b57894781ba27	mongodbio.py
100644 blob dfbc9e65305bc674a0d5399d23d19c764a2f14e2	mongodbio_it_test.py
100644 blob 150eac2d5437b9b5e01cca71fe56d6b2496440ae	mongodbio_test.py
100644 blob 188aab7ce83db624fc97a7bd68e79edd9bb8e65f	parquetio.py
100644 blob 0d3cd0d653137ae2b6f2cf6b1dc724b6697b9c2c	parquetio_it_test.py
100644 blob 0232bac45e06d85aeb3f7d870bf37245b8b7f704	parquetio_test.py
100644 blob 33b15d5ecfa2943c78690ad8be98f6421d055c4b	range_trackers.py
100644 blob 0bf37997f2cec1404193ee54fbbe39ffba8b5e3f	range_trackers_test.py
100644 blob f2b3e1d03d2fe5b8429077623494efe0707e1392	restriction_trackers.py
100644 blob 0d3eee18036e87030d243b15c7a5ec3652a08fd6	restriction_trackers_test.py
100644 blob 9331aeac02bd714586ecb8a9a165511e5b50d7ae	snowflake.py
100644 blob b40f70604c4228f5c5c796b518e720810e46cac0	source_test_utils.py
100644 blob 6d3f2e3a4a852cbd6b3858336dde6be139217abe	source_test_utils_test.py
100644 blob f75e4fdafff0f00738d567ca25113467fa3f7e22	sources_test.py
100644 blob 277b993aabe73dc97b143065a445c6180f1493a4	textio.py
100644 blob 6be4370547803913ee135c61be2361a9cd19f1b4	textio_test.py
100644 blob e699756360e045f90a74b0411f413f3eaaee3e11	tfrecordio.py
100644 blob a867c0212ad3deae1098e701ccf113c53023fe0e	tfrecordio_test.py
100644 blob 0d1f52f35f2b2fe04e0d26d854b6127d555cd40d	utils.py
100644 blob 76ed9969f9957423d8a22a7610c566390935030c	utils_test.py
100644 blob be91ffb9c751da703362b5bb80cb4bf1fc3d0f6b	watermark_estimators.py
100644 blob 322217c3aa44b47f9a860cd79651266db8b7a1c3	watermark_estimators_test.py