@Override
    public long extractTimestamp(Row row) {
        try {
            Timestamp time = (Timestamp) row.getField(pos);
            long extractTime=time.getTime();
            return getExtractTimestamp(extractTime);
        } catch (RuntimeException e) {
            logger.error("", e);
        }
        return lastTime;
    }
Custom watermark --- for eventtime
Date: 2017/12/28
Company: www.dtstack.com
@author xuchao
core/src/main/java/com/dtstack/flink/sql/watermarker/CustomerWaterMarkerForTimeStamp.java