问答 2017-10-24 来自:开发者社区

MaxCompute用户指南:MapReduce:Java SDK:兼容版本SDK概述

MaxCompute 兼容版本的 MapReduce 与 Hadoop MapReduce 兼容性的详细列表,如下表所示: 类型接口是否兼容Mappervoid map(KEYIN key, VALUEIN value, org.apache.hadoop.mapreduce.Mapper.Context context)是Mappervoid run(org.apache.hadoop.map....

问答 2017-10-24 来自:开发者社区

MaxCompute用户指南:MapReduce:Java SDK:原生SDK概述

本文将会为您介绍较为常用的 MapReduce 核心接口。如果您使用 Maven,可以从 Maven 库 中搜索“odps-sdk-mapred”获取不同版本的 Java SDK,相关配置信息如下:     com.aliyun.odps    odps-sdk-mapred   &nbs...

问答 2017-10-23 来自:开发者社区

MaxCompute用户指南:MapReduce:示例程序:Pipeline示例

测试准备 准备好测试程序的 Jar包,假设名字为 mapreduce-examples.jar,本地存放路径为 data\resources。准备好 Pipeline 的测试表和资源。 创建测试表。create table wc_in (key string, value string);create table wc_out(key string, cnt bigint); 添加测试资...

问答 2017-10-23 来自:开发者社区

MaxCompute用户指南:MapReduce:示例程序:分区表输入示例

本文将为您介绍两个把 Partition 作为输入输出的示例,仅供参考。 示例一:      public static void main(String[] args) throws Exception {     JobConf job = new JobConf();    ...

问答 2017-10-23 来自:开发者社区

MaxCompute用户指南:MapReduce:示例程序:Sort示例

测试准备 准备好测试程序的 Jar 包,假设名字为 mapreduce-examples.jar,本地存放路径为 data\resources。准备好 Sort 的测试表和资源。 创建测试表。create table ss_in(key bigint, value bigint);create table ss_out(key bigint, value bigint); 添加测试资源。...

问答 2017-10-23 来自:开发者社区

MaxCompute用户指南:MapReduce:示例程序:Unique示例

测试准备 准备好测试程序的 Jar 包,假设名字为 mapreduce-examples.jar,本地存放路径为 data\resources。准备好 Unique 的测试表和资源。 创建测试表。create table ss_in(key bigint, value bigint);create table ss_out(key bigint, value bigint); 添加测试资...

问答 2017-10-23 来自:开发者社区

MaxCompute用户指南:MapReduce:示例程序:Sleep示例

测试准备 准备好测试程序的 Jar 包,假设名字为 mapreduce-examples.jar,本地存放路径为 data\resources。准备好 SleepJob 的测试资源。add jar data\resources\mapreduce-examples.jar -f; 测试步骤 在 odpscmd 中执行 Sleep,如下所示:   jar -resources m...

问答 2017-10-23 来自:开发者社区

MaxCompute用户指南:MapReduce:示例程序:Join示例

MaxCompute MapReduce 框架自身并不支持 Join 逻辑,但您可以在自己的 Map/Reduce 函数中实现数据的 Join,当然这需要您做一些额外的工作。 假设需要 Join 两张表 mr_Join_src1(key bigint, value string) 和mr_Join_src2(key bigint, value string),输出表是 mr_Join_out(k....

问答 2017-10-23 来自:开发者社区

MaxCompute用户指南:MapReduce:示例程序:Grep示例

测试准备 准备好测试程序的 Jar 包,假设名字为 mapreduce-examples.jar,本地存放路径为 data\resources。准备好 Grep 测试表和资源。 创建测试表。create table mr_src(key string, value string); create table mr_grep_tmp (key string, cnt bigint); cr...

问答 2017-10-23 来自:开发者社区

MaxCompute用户指南:MapReduce:示例程序:使用Counter示例

本示例中定义了三个 Counter:map_outputs,reduce_outputs 和 global_counts。您可以在Map/Reduce 的 setup,map/reduce 及 cleanup 接口中,获取任意自定义 Counter,并进行操作。 测试准备 准备好测试程序的 Jar 包,假设名字为 mapreduce-examples.jar,本地存放路径为 data\r...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

云原生大数据计算服务 MaxCompute您可能感兴趣

产品推荐

大数据计算 MaxCompute

MaxCompute(原ODPS)是一项面向分析的大数据计算服务,它以Serverless架构提供快速、全托管的在线数据仓库服务,消除传统数据平台在资源扩展性和弹性方面的限制,最小化用户运维投入,使您经济并高效的分析处理海量数据。

+关注