public void execute(TridentTuple tuple, TridentCollector collector) {
        	LOGGER.info("Executed!!!!!!!!!!!!!!!!!!!!!!!!!");
        	if(tuple==null) return;
        	TransObj obj = null;
        	long beginTime = System.currentTimeMillis();
        	if(tuple.get(0)!=null && tuple.get(0) instanceof TransObj)
        	{
        		obj = (TransObj) tuple.get(0);
        		System.out.println("ExeLatency: " + (beginTime -obj.getInitTime()));
        	}
        	if(obj==null) return;
        	if(batch)
        	{
        		synchronized (list) {
            		if(list.size()>=MAX_SIZE)
            		{
            			insertData();
            			list.clear();
            		}else
            		{
            			/*String dml = String.format(INSERT_STRING, obj.getSeq(),obj.getInitTime(),System.currentTimeMillis());
            			list.add(dml);*/
            			list.add(obj);
            		}
    			}
        	}else
        	{
        		insertImmediately(obj);
        	}
        	
        	System.out.println("Latency2: " + (System.currentTimeMillis()-beginTime));
        	System.out.println("TotalLatency: " + (System.currentTimeMillis()-obj.getInitTime()));
            collector.emit(new Values(obj));
        }