首页 \ 问答 \ 如何为风暴计算提供价值(How to provide values to storm for calculation)

如何为风暴计算提供价值(How to provide values to storm for calculation)

我很难理解如何为暴风雨提供价值,因为我是暴风雨的新手。

我从入门套件开始。 我浏览了TestWordSpout ,以下代码提供了新值

public void nextTuple() {
    Utils.sleep(100);
    final String[] words = new String[] {"nathan", "mike", "jackson", "golda", "bertels"};
    final Random rand = new Random();
    final String word = words[rand.nextInt(words.length)];
    _collector.emit(new Values(word));
}

所以我看到它一次_collector.emit(new Values(word));一个字_collector.emit(new Values(word));

我怎样才能直接提供一系列单词。这可能吗?

TestWordSpout.java

当我从nextTuple中调用一个新单词时,我的意思是从列表中随机选择并发出。 在某个时间间隔之后,随机列表可能看起来像这样

@100ms: nathan
@200ms: golda
@300ms: golda
@400ms: jackson
@500ms: mike
@600ms: nathan
@700ms: bertels

如果我已经拥有此列表的集合并将其提供给风暴,该怎么办?


I have a hard time understanding how to provide values to storm since i am a newbie to storm.

I started with the starter kit. I went through the TestWordSpout and in that the following code provides new values

public void nextTuple() {
    Utils.sleep(100);
    final String[] words = new String[] {"nathan", "mike", "jackson", "golda", "bertels"};
    final Random rand = new Random();
    final String word = words[rand.nextInt(words.length)];
    _collector.emit(new Values(word));
}

So i see it's taking one word at a time _collector.emit(new Values(word));

How i can provide a collection of words directly.Is this possible?

TestWordSpout.java

What I mean when nextTuple is called a new words is selected at random from the list and emitted. The random list may look like this after certain time interval

@100ms: nathan
@200ms: golda
@300ms: golda
@400ms: jackson
@500ms: mike
@600ms: nathan
@700ms: bertels

What if i already have a collection of this list and just feed it to storm.


原文:https://stackoverflow.com/questions/22012008
更新时间:2022-10-21 07:10

最满意答案

很少有事情需要修复或添加(在您的案例中不确定,因为有些零件丢失)

资源:让我自己去测试,因为你的东西缺少一些物品

@Path("/")
public class AccountResource {
    @GET
    @Path("/account") // route to a specific method.re
    @Produces(MediaType.APPLICATION_JSON)
    public Response saveDataIntoHash() {
        List<Account> accounts = new ArrayList<Account>();
        accounts.add(new Account("Stack", "Savings"));
        accounts.add(new Account("Overflow", "Checkings"));
        GenericEntity generic = new GenericEntity<List<Account>>(accounts){};
        return Response.status(201).entity(generic).build();
    }
}

假设你有这种依赖性:

<dependency>
    <groupId>com.sun.jersey</groupId>
    <artifactId>jersey-json</artifactId>
    <version>${jersey-version}</version>
</dependency>

测试用例:注意客户端配置。 这是必要的。

public void testMyResource() {
    ClientConfig config = new DefaultClientConfig();
    config.getClasses().add(JacksonJaxbJsonProvider.class);
    config.getFeatures().put(JSONConfiguration.FEATURE_POJO_MAPPING, Boolean.TRUE);

    Client c = Client.create(config);

    WebResource resource = c.resource(Main.BASE_URI);
    ClientResponse response = resource.path("account")
            .accept("application/json").get(ClientResponse.class);

    List<Account> accounts
                = response.getEntity(new GenericType<List<Account>>(){});

    StringBuilder builder = new StringBuilder("=== Accounts ===\n");
    for (Account account: accounts) {
        builder.append("Name: ").append(account.getName()).append(", ")
                .append("Type: ").append(account.getType()).append("\n");          
    }
    builder.append("==================");
    System.out.println(builder.toString());    
}

帐户(客户)类缺少一个注释。 当您使用字段注释时,它是必需的。 另一个选择是为id添加一个getter和setter

@XmlRootElement  
@XmlAccessorType(XmlAccessType.FIELD)  // <======= This Here
public class Account {
    // added toString for testing
    @Override
    public String toString() {
        return "Account{" + "name=" + name 
                          + ", type=" + type 
                          + ", id=" + id + '}';
    }
}

测试结果

=== Accounts ===
Name: Stack, Type: Savings
Name: Overflow, Type: Checkings
==================

注意:此测试基于服务器端没有任何问题的假设。


Few things either need to be fixed or added (not sure in your case as some parts are missing)

Resource: Made my own to test, as yours was missing a few items

@Path("/")
public class AccountResource {
    @GET
    @Path("/account") // route to a specific method.re
    @Produces(MediaType.APPLICATION_JSON)
    public Response saveDataIntoHash() {
        List<Account> accounts = new ArrayList<Account>();
        accounts.add(new Account("Stack", "Savings"));
        accounts.add(new Account("Overflow", "Checkings"));
        GenericEntity generic = new GenericEntity<List<Account>>(accounts){};
        return Response.status(201).entity(generic).build();
    }
}

Assumed you have this dependency:

<dependency>
    <groupId>com.sun.jersey</groupId>
    <artifactId>jersey-json</artifactId>
    <version>${jersey-version}</version>
</dependency>

Test case: Notice the client configuration. This is needed.

public void testMyResource() {
    ClientConfig config = new DefaultClientConfig();
    config.getClasses().add(JacksonJaxbJsonProvider.class);
    config.getFeatures().put(JSONConfiguration.FEATURE_POJO_MAPPING, Boolean.TRUE);

    Client c = Client.create(config);

    WebResource resource = c.resource(Main.BASE_URI);
    ClientResponse response = resource.path("account")
            .accept("application/json").get(ClientResponse.class);

    List<Account> accounts
                = response.getEntity(new GenericType<List<Account>>(){});

    StringBuilder builder = new StringBuilder("=== Accounts ===\n");
    for (Account account: accounts) {
        builder.append("Name: ").append(account.getName()).append(", ")
                .append("Type: ").append(account.getType()).append("\n");          
    }
    builder.append("==================");
    System.out.println(builder.toString());    
}

Account (client) class is missing one annotation. It is required as you are using field annotations. Another option is to add a getter and setter for the id

@XmlRootElement  
@XmlAccessorType(XmlAccessType.FIELD)  // <======= This Here
public class Account {
    // added toString for testing
    @Override
    public String toString() {
        return "Account{" + "name=" + name 
                          + ", type=" + type 
                          + ", id=" + id + '}';
    }
}

Result from test:

=== Accounts ===
Name: Stack, Type: Savings
Name: Overflow, Type: Checkings
==================

Note: this test is based on the assumption that nothing is wrong on your server side.

相关问答

更多

相关文章

更多

最新问答

更多
  • 获取MVC 4使用的DisplayMode后缀(Get the DisplayMode Suffix being used by MVC 4)
  • 如何通过引用返回对象?(How is returning an object by reference possible?)
  • 矩阵如何存储在内存中?(How are matrices stored in memory?)
  • 每个请求的Java新会话?(Java New Session For Each Request?)
  • css:浮动div中重叠的标题h1(css: overlapping headlines h1 in floated divs)
  • 无论图像如何,Caffe预测同一类(Caffe predicts same class regardless of image)
  • xcode语法颜色编码解释?(xcode syntax color coding explained?)
  • 在Access 2010 Runtime中使用Office 2000校对工具(Use Office 2000 proofing tools in Access 2010 Runtime)
  • 从单独的Web主机将图像传输到服务器上(Getting images onto server from separate web host)
  • 从旧版本复制文件并保留它们(旧/新版本)(Copy a file from old revision and keep both of them (old / new revision))
  • 西安哪有PLC可控制编程的培训
  • 在Entity Framework中选择基类(Select base class in Entity Framework)
  • 在Android中出现错误“数据集和渲染器应该不为null,并且应该具有相同数量的系列”(Error “Dataset and renderer should be not null and should have the same number of series” in Android)
  • 电脑二级VF有什么用
  • Datamapper Ruby如何添加Hook方法(Datamapper Ruby How to add Hook Method)
  • 金华英语角.
  • 手机软件如何制作
  • 用于Android webview中图像保存的上下文菜单(Context Menu for Image Saving in an Android webview)
  • 注意:未定义的偏移量:PHP(Notice: Undefined offset: PHP)
  • 如何读R中的大数据集[复制](How to read large dataset in R [duplicate])
  • Unity 5 Heighmap与地形宽度/地形长度的分辨率关系?(Unity 5 Heighmap Resolution relationship to terrain width / terrain length?)
  • 如何通知PipedOutputStream线程写入最后一个字节的PipedInputStream线程?(How to notify PipedInputStream thread that PipedOutputStream thread has written last byte?)
  • python的访问器方法有哪些
  • DeviceNetworkInformation:哪个是哪个?(DeviceNetworkInformation: Which is which?)
  • 在Ruby中对组合进行排序(Sorting a combination in Ruby)
  • 网站开发的流程?
  • 使用Zend Framework 2中的JOIN sql检索数据(Retrieve data using JOIN sql in Zend Framework 2)
  • 条带格式类型格式模式编号无法正常工作(Stripes format type format pattern number not working properly)
  • 透明度错误IE11(Transparency bug IE11)
  • linux的基本操作命令。。。