1 files changed, 13 insertions, 0 deletions
diff --git a/src/main/java/cn/ac/iie/utils/TupleUtils.java b/src/main/java/cn/ac/iie/utils/TupleUtils.java
new file mode 100644
index 0000000..1a5889a
--- /dev/null
+++ b/src/main/java/cn/ac/iie/utils/TupleUtils.java
@@ -0,0 +1,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());
+	}
+}