MapReduce API基本概念 序列化,Reporter参数,回调机制


这些概念相信很多码农都了解,可以直接跳过。

1、序列化

概念:将结构化的对象转为字节流 ; 目的是为了网络传输和持久化存储。

相应的反序列化就是倒过来。

在MR中作用:永久存储和进程间通信。

实现Writable  接口 可以序列化;实现Comparable 接口可以对key对象排序。


2、Reporter参数

应用程序可以用Reporter来实现 progress(报告完成进度)、setStatus(设定状态消息)、incrCounter(更新计数器)


3、回调机制

我理解为反射,不知道对不对。

概念:将工作流内的某个功能按照约定的接口暴露给外部使用者,为外部使用者提供数据,或要求外部使用者提供数据。

举例子就是:在写程序时,实现的Mapper中,重写的map函数,hadoop回自动调用。

相关内容