Class TupleImpl

storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:20–272

import org.apache.storm.task.GeneralTopologyContext;

public class TupleImpl implements Tuple {
    private final String srcComponent;
    private List<Object> values;
    private int taskId;
    private String streamId;
    private GeneralTopologyContext context;
    private MessageId id;
    private Long processSampleStartTime;
    private Long executeSampleStartTime;
    private long outAckVal = 0;

    public TupleImpl(Tuple t) {
        this.values = t.getValues();
        this.taskId = t.getSourceTask();
        this.streamId = t.getSourceStreamId();
        this.id = t.getMessageId();
        this.context = t.getContext();
        this.srcComponent = t.getSourceComponent();
        try {
            TupleImpl ti = (TupleImpl) t;
            this.processSampleStartTime = ti.processSampleStartTime;
            this.executeSampleStartTime = ti.executeSampleStartTime;
            this.outAckVal = ti.outAckVal;
        } catch (ClassCastException e) {
            // ignore ... if t is not a TupleImpl type .. faster than checking and then casting
        }
    }

    public TupleImpl(GeneralTopologyContext context, List<Object> values, String srcComponent, int taskId, String streamId, MessageId id) {
        this.values = context.doSanityCheck() ? Collections.unmodifiableList(values) : values;
        this.taskId = taskId;
        this.streamId = streamId;
        this.id = id;
        this.context = context;
        this.srcComponent = srcComponent;

        if (context.doSanityCheck()) {
            String componentId = context.getComponentId(taskId);
            Fields schema = context.getComponentOutputFields(componentId, streamId);
            if (values.size() != schema.size()) {
                throw new IllegalArgumentException("Tuple created with wrong number of fields. Expected " + schema.size()
                                                   + " fields but got " + values.size() + " fields");
            }
        }
    }

    public TupleImpl(GeneralTopologyContext context, List<Object> values, String srcComponent, int taskId, String streamId) {
        this(context, values, srcComponent, taskId, streamId, MessageId.makeUnanchored());
    }

    public Long getProcessSampleStartTime() {
        return processSampleStartTime;
    }

    public void setProcessSampleStartTime(long ms) {
        processSampleStartTime = ms;
    }