Google Git
Sign in
apache / beam / fd4190df0cdb39244ee43950ab3f3727b6352954 / . / sdks / python / apache_beam / io
tree: b38e41d900d1115faedc94d785f238be02bcef79 [path history] [tgz]
  1. aws/
  2. azure/
  3. external/
  4. flink/
  5. gcp/
  6. hdfs_integration_test/
  7. __init__.py
  8. avroio.py
  9. avroio_test.py
  10. concat_source.py
  11. concat_source_test.py
  12. filebasedsink.py
  13. filebasedsink_test.py
  14. filebasedsource.py
  15. filebasedsource_test.py
  16. fileio.py
  17. fileio_test.py
  18. filesystem.py
  19. filesystem_test.py
  20. filesystemio.py
  21. filesystemio_test.py
  22. filesystems.py
  23. filesystems_test.py
  24. hadoopfilesystem.py
  25. hadoopfilesystem_test.py
  26. iobase.py
  27. iobase_test.py
  28. jdbc.py
  29. kafka.py
  30. kinesis.py
  31. localfilesystem.py
  32. localfilesystem_test.py
  33. mongodbio.py
  34. mongodbio_it_test.py
  35. mongodbio_test.py
  36. OWNERS
  37. parquetio.py
  38. parquetio_it_test.py
  39. parquetio_test.py
  40. range_trackers.py
  41. range_trackers_test.py
  42. restriction_trackers.py
  43. restriction_trackers_test.py
  44. snowflake.py
  45. source_test_utils.py
  46. source_test_utils_test.py
  47. sources_test.py
  48. textio.py
  49. textio_test.py
  50. tfrecordio.py
  51. tfrecordio_test.py
  52. utils.py
  53. utils_test.py
  54. vcfio.py
  55. vcfio_test.py
  56. watermark_estimators.py
  57. watermark_estimators_test.py