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