java - 创建一个 backtype.storm.tuple.Tuple 用于测试目的？

Question

我是 Storm 的新手并且我正在尝试找出如何编写一个 bolt 测试来测试子类 BaseRichBolt 中的 execute(Tuple tuple) 方法。

问题是 Tuple 似乎是不可变的，我没有看到任何方法或构建器来创建新的 Tuple。如何创建自己的元组，或者如何使用测试输入测试 bolt ？

我实际上使用的是 Scala，而不是 Java，但答案应该很容易翻译。

Answer 1

模拟 Tuple 对象是来自 storm-starter project 的一个很好的解决方案.很简单:

package storm.starter.tools;

import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
import backtype.storm.Constants;
import backtype.storm.tuple.Tuple;

public final class MockTupleHelpers {

    private MockTupleHelpers() {
    }

    public static Tuple mockTickTuple() {
        return mockTuple(Constants.SYSTEM_COMPONENT_ID, Constants.SYSTEM_TICK_STREAM_ID);
    }

    public static Tuple mockTuple(String componentId, String streamId) {
        Tuple tuple = mock(Tuple.class);
        when(tuple.getSourceComponent()).thenReturn(componentId);
        when(tuple.getSourceStreamId()).thenReturn(streamId);
        return tuple;
    }
}