__init__.py 659 B

123456789101112131415161718192021222324252627
  1. """
  2. Hadoop Tools - Python 版本
  3. 提供 Hadoop 数据分析能力,包括:
  4. - HDFS 文件系统操作
  5. - MapReduce 作业执行
  6. - 大数据处理工具
  7. 模块结构:
  8. - hdfs_operations: HDFS 文件系统操作
  9. - mapreduce: MapReduce 作业实现
  10. - wordcount_streaming: Hadoop Streaming 方式的词频统计
  11. - wordcount_spark: PySpark 方式的词频统计
  12. - utils: 工具函数
  13. """
  14. from .hdfs_operations import HDFSOperations
  15. from .mapreduce.wordcount_streaming import WordCountStreaming
  16. from .mapreduce.wordcount_spark import WordCountSpark
  17. __all__ = [
  18. 'HDFSOperations',
  19. 'WordCountStreaming',
  20. 'WordCountSpark'
  21. ]
  22. __version__ = '0.1.0'