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