__init__.py 349 B

123456789101112131415
  1. """
  2. MapReduce 相关模块
  3. 提供多种 MapReduce 作业实现方式:
  4. - Hadoop Streaming: 使用标准输入输出与 Hadoop 交互
  5. - PySpark: 现代、高效的大数据处理框架
  6. """
  7. from .wordcount_streaming import WordCountStreaming
  8. from .wordcount_spark import WordCountSpark
  9. __all__ = [
  10. 'WordCountStreaming',
  11. 'WordCountSpark'
  12. ]