class StormTuple implements backtype.storm.tuple.Tuple {

	@Override
	public String getSourceStreamId() {
		return this.producerStreamId;
	}

	public  StormTuple(final IN flinkTuple, final Fields schema, final int producerTaskId, final String producerStreamId, final String producerComponentId, final MessageId messageId);

}