src/main/java/cn/ac/iie/utils/TupleUtils.java


1
2
3
4
5
6
7
8
9
10
11
12
13

package cn.ac.iie.utils;

import org.apache.storm.Constants;
import org.apache.storm.tuple.Tuple;

public final class TupleUtils {
	//判断是否系统自动发送的Tuple  
	public static boolean isTick(Tuple tuple) {
		return tuple != null  
				&& Constants.SYSTEM_COMPONENT_ID.equals(tuple.getSourceComponent())  
				&& Constants.SYSTEM_TICK_STREAM_ID.equals(tuple.getSourceStreamId());
	}
}