Package tutorial.storm.trident.operations

Examples of tutorial.storm.trident.operations.DivideAsDouble

84
85
86
87
88
89
90
91
92
93
94
                .groupBy(new Fields("location"))
                .chainedAgg()
                .aggregate(new Count(), new Fields("count"))
                .aggregate(new Fields("age"), new Sum(), new Fields("sum"))
                .chainEnd()
                .each(new Fields("sum", "count"), new DivideAsDouble(), new Fields("avg"))
                .project(new Fields("location", "count", "avg"))
        ;

        return topology.build();
    }
View Full Code Here
47
48
49
50
51
52
53
54
55
56
57
                .groupBy(new Fields("city"))
                .chainedAgg()
                .aggregate(new Count(), new Fields("count"))
                .aggregate(new Fields("age"), new Sum(), new Fields("age_sum"))
                .chainEnd()
                .each(new Fields("age_sum", "count"), new DivideAsDouble(), new Fields("mean_age"))
                .each(new Fields("city", "mean_age"), new Print())
        ;

        // What if we want to persist results of an aggregation, but want to further process these
        // results? You can use "newValuesStream" for that
View Full Code Here
TOP

Related Classes of tutorial.storm.trident.operations.DivideAsDouble

  • backtype.storm.tuple.Values
  • tutorial.storm.trident.Part03_AdvancedPrimitives2
  • tutorial.storm.trident.Part05_AdvancedStateAndDRPC
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.