final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        
        //指定使用eventTime作为时间标准
        env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);

        //1590894238,江西,高安,100 
        //仅提取时间字段，不改变数据样式
        SingleOutputStreamOperator<String> lines = env.socketTextStream("192.168.1.33", 9999)
                .assignTimestampsAndWatermarks(new BoundedOutOfOrdernessTimestampExtractor<String>(Time.seconds(0)) {
                    //将数据中的时间字段提取出来，转成Long类型,不改变输入的数据样式
                    @Override
                    public long extractTimestamp(String line) {
                        String[] fileds = line.split(",");
                        return Long.parseLong(fileds[0]);
                    }
                });