package cai.flow.collector;

import java.util.Enumeration;
import java.util.Vector;

import cai.flow.packets.FlowPacket;
import cai.flow.struct.Scheme_DataSrcAS;
import cai.sql.SQL;
/**
 * 一種歸并模式
 * @author CaiMao
 *
 */
public class Scheme_AggregatorSrcAS extends Scheme_Aggregator {
	/**
	 * 
	 */
	private static final long serialVersionUID = -7313307991038642118L;

	public Scheme_AggregatorSrcAS(SQL sql, long interval) {
		super(sql, "SrcAS", interval);//入庫線程已經(jīng)創(chuàng)建
	}

	public void add(FlowPacket packet) {
		Vector v = packet.getSrcASVector();

		if (v == null)
			return;

		for (Enumeration f = v.elements(); f.hasMoreElements();)
			add(new Scheme_ItemSrcAS((Scheme_DataSrcAS) f.nextElement()));
	}

}