Java ReturnResults类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中backtype.storm.drpc.ReturnResults类的典型用法代码示例。如果您正苦于以下问题：Java ReturnResults类的具体用法？Java ReturnResults怎么用？Java ReturnResults使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

ReturnResults类属于backtype.storm.drpc包，在下文中一共展示了ReturnResults类的4个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: main

import backtype.storm.drpc.ReturnResults; //导入依赖的package包/类
public static void main(String[] args) {
  TopologyBuilder builder = new TopologyBuilder();
  LocalDRPC drpc = new LocalDRPC();

  DRPCSpout spout = new DRPCSpout("exclamation", drpc);
  builder.setSpout("drpc", spout);
  builder.setBolt("exclaim", new ExclamationBolt(), 3).shuffleGrouping("drpc");
  builder.setBolt("return", new ReturnResults(), 3).shuffleGrouping("exclaim");

  LocalCluster cluster = new LocalCluster();
  Config conf = new Config();
  cluster.submitTopology("exclaim", conf, builder.createTopology());

  System.out.println(drpc.execute("exclamation", "aaa"));
  System.out.println(drpc.execute("exclamation", "bbb"));

}

开发者ID:luozhaoyu，项目名称:big-data-system，代码行数:18，代码来源:ManualDRPC.java

示例2: main

import backtype.storm.drpc.ReturnResults; //导入依赖的package包/类
public static void main(String[] args) {
    TopologyBuilder builder = new TopologyBuilder();
    LocalDRPC drpc = new LocalDRPC();
    
    DRPCSpout spout = new DRPCSpout("exclamation", drpc);
    builder.setSpout("drpc", spout);
    builder.setBolt("exclaim", new ExclamationBolt(), 3)
            .shuffleGrouping("drpc");
    builder.setBolt("return", new ReturnResults(), 3)
            .shuffleGrouping("exclaim");
    
    LocalCluster cluster = new LocalCluster();
    Config conf = new Config();
    cluster.submitTopology("exclaim", conf, builder.createTopology());
    
    System.out.println(drpc.execute("exclamation", "aaa"));
    System.out.println(drpc.execute("exclamation", "bbb"));
    
}

开发者ID:adarshms，项目名称:sentweet，代码行数:20，代码来源:ManualDRPC.java

示例3: testDrpc

import backtype.storm.drpc.ReturnResults; //导入依赖的package包/类
public static void testDrpc() {
    TopologyBuilder builder = new TopologyBuilder();
    LocalDRPC drpc = new LocalDRPC();
    
    DRPCSpout spout = new DRPCSpout("exclamation", drpc);
    builder.setSpout("drpc", spout);
    builder.setBolt("exclaim", new ExclamationBolt(), 3).shuffleGrouping("drpc");
    builder.setBolt("return", new ReturnResults(), 3).shuffleGrouping("exclaim");
    
    LocalCluster cluster = new LocalCluster();
    Config conf = new Config();
    cluster.submitTopology("exclaim", conf, builder.createTopology());
    
    JStormUtils.sleepMs(30 * 1000);
    
    try {
        System.out.println(drpc.execute("exclamation", "aaa"));
        System.out.println(drpc.execute("exclamation", "bbb"));
    } catch (Exception e) {
        Assert.fail("Failed to test drpc");
    }
    
    drpc.shutdown();
    cluster.shutdown();
}

开发者ID:alibaba，项目名称:jstorm，代码行数:26，代码来源:ManualDRPC.java

示例4: createBuilder

import backtype.storm.drpc.ReturnResults; //导入依赖的package包/类
@Override
public TopologyBuilder createBuilder(){
	TopologyBuilder builder = super.initBuilder();
	//设置预处理步骤
	builder.setBolt(this.prepareId, new PrepareRequest()).noneGrouping(spoutId);
	AbstractDrpcBolt lastBolt = setBolt(builder, this.prepareId);
	
	OutputFieldsGetter getter = new OutputFieldsGetter();
       lastBolt.declareOutputFields(getter);
       Map<String, StreamInfo> streams = getter.getFieldsDeclaration();
       if(streams.size()!=1) {
           throw new RuntimeException("Must declare exactly one stream from last bolt in LinearDRPCTopology");
       }
       String outputStream = streams.keySet().iterator().next();
       List<String> fields = streams.get(outputStream).get_output_fields();
       if(fields.size()!=2) {
           throw new RuntimeException("Output stream of last component in LinearDRPCTopology must contain exactly two fields. The first should be the request id, and the second should be the result.");
       }
	
       //合并步骤
	builder.setBolt(this.joinId, new JoinResult(this.prepareId))
       .fieldsGrouping(lastBolt.getBoltName(), outputStream, new Fields(fields.get(0)))
       .fieldsGrouping(this.prepareId, PrepareRequest.RETURN_STREAM, new Fields("request"));
	//return步骤
	builder.setBolt(returnId, new ReturnResults()).noneGrouping(this.joinId);
	return builder;
}

开发者ID:yiyongfei，项目名称:jea，代码行数:28，代码来源:AbstractDRPCTopology.java

注：本文中的backtype.storm.drpc.ReturnResults类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。