个人中心
文章发布
退出
作者热门文章
- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
25
4
本文整理了Java中org.apache.crunch.types.writable.Writables.doubles()方法的一些代码示例，展示了Writables.doubles()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Writables.doubles()方法的具体详情如下：
包路径：org.apache.crunch.types.writable.Writables
类名称：Writables
方法名：doubles
暂无
代码示例来源：origin: cloudera/crunch
public PType<Double> doubles() {
return Writables.doubles();
}代码示例来源：origin: org.apache.crunch/crunch-core
public PType<Double> doubles() {
return Writables.doubles();
}代码示例来源：origin: org.apache.crunch/crunch
public PType<Double> doubles() {
return Writables.doubles();
}代码示例来源：origin: apache/crunch
public int run(String[] args) throws Exception {
if (args.length != 2) {
System.err.println();
System.err.println("Two and only two arguments are accepted.");
System.err.println("Usage: " + this.getClass().getName() + " [generic options] input output");
System.err.println();
GenericOptionsParser.printGenericCommandUsage(System.err);
return 1;
}
// Create an object to coordinate pipeline creation and execution.
Pipeline pipeline = new MRPipeline(AverageBytesByIP.class, getConf());
// Reference a given text file as a collection of Strings.
PCollection<String> lines = pipeline.readTextFile(args[0]);
// Aggregator used for summing up response size and count
Aggregator<Pair<Long, Long>> agg = pairAggregator(SUM_LONGS(), SUM_LONGS());
// Table of (ip, sum(response size), count)
PTable<String, Pair<Long, Long>> remoteAddrResponseSize = lines
.parallelDo(extractResponseSize,
Writables.tableOf(Writables.strings(), Writables.pairs(Writables.longs(), Writables.longs()))).groupByKey()
.combineValues(agg);
// Calculate average response size by ip address
PTable<String, Double> avgs = remoteAddrResponseSize.parallelDo(calulateAverage,
Writables.tableOf(Writables.strings(), Writables.doubles()));
// write the result to a text file
pipeline.writeTextFile(avgs, args[1]);
// Execute the pipeline as a MapReduce.
PipelineResult result = pipeline.done();
return result.succeeded() ? 0 : 1;
}
0
本文整理了Java中org.apache.crunch.types.writable.Writables.writables()方法的一些代码示例，展示了Writables.writables()的具
本文整理了Java中org.datavec.api.writable.Writable.toInt()方法的一些代码示例，展示了Writable.toInt()的具体用法。这些代码示例主要来源于Git
本文整理了Java中org.datavec.api.writable.Writable.toDouble()方法的一些代码示例，展示了Writable.toDouble()的具体用法。这些代码示例主要
本文整理了Java中org.datavec.api.writable.Writable.toFloat()方法的一些代码示例，展示了Writable.toFloat()的具体用法。这些代码示例主要来源
本文整理了Java中org.datavec.api.writable.Writable.toLong()方法的一些代码示例，展示了Writable.toLong()的具体用法。这些代码示例主要来源于G
本文整理了Java中org.apache.crunch.types.writable.Writables.bytes()方法的一些代码示例，展示了Writables.bytes()的具体用法。这些代码
本文整理了Java中org.apache.crunch.types.writable.Writables.derived()方法的一些代码示例，展示了Writables.derived()的具体用法。
本文整理了Java中org.apache.crunch.types.writable.Writables.booleans()方法的一些代码示例，展示了Writables.booleans()的具体用
本文整理了Java中org.apache.crunch.types.writable.Writables.longs()方法的一些代码示例，展示了Writables.longs()的具体用法。这些代码
本文整理了Java中org.apache.crunch.types.writable.Writables.triples()方法的一些代码示例，展示了Writables.triples()的具体用法。
本文整理了Java中org.apache.crunch.types.writable.Writables.nulls()方法的一些代码示例，展示了Writables.nulls()的具体用法。这些代码
本文整理了Java中org.apache.crunch.types.writable.Writables.records()方法的一些代码示例，展示了Writables.records()的具体用法。
本文整理了Java中org.apache.crunch.types.writable.Writables.collections()方法的一些代码示例，展示了Writables.collections
本文整理了Java中org.apache.crunch.types.writable.Writables.quads()方法的一些代码示例，展示了Writables.quads()的具体用法。这些代码
本文整理了Java中org.apache.crunch.types.writable.Writables.doubles()方法的一些代码示例，展示了Writables.doubles()的具体用法。
本文整理了Java中org.apache.crunch.types.writable.Writables.tableOf()方法的一些代码示例，展示了Writables.tableOf()的具体用法。
本文整理了Java中org.apache.crunch.types.writable.Writables.strings()方法的一些代码示例，展示了Writables.strings()的具体用法。
本文整理了Java中org.apache.crunch.types.writable.Writables.pairs()方法的一些代码示例，展示了Writables.pairs()的具体用法。这些代码
本文整理了Java中org.apache.crunch.types.writable.Writables.tuples()方法的一些代码示例，展示了Writables.tuples()的具体用法。这些
本文整理了Java中org.apache.crunch.types.writable.Writables.floats()方法的一些代码示例，展示了Writables.floats()的具体用法。这些
我是一名优秀的程序员,十分优秀！