org.apache.flink.api.java org.apache.flink.api.java.aggregation org.apache.flink.api.java.functions org.apache.flink.api.java.hadoop.common org.apache.flink.api.java.hadoop.mapred org.apache.flink.api.java.hadoop.mapred.utils org.apache.flink.api.java.hadoop.mapred.wrapper org.apache.flink.api.java.hadoop.mapreduce org.apache.flink.api.java.hadoop.mapreduce.utils org.apache.flink.api.java.hadoop.mapreduce.wrapper org.apache.flink.api.java.io org.apache.flink.api.java.operators org.apache.flink.api.java.operators.join org.apache.flink.api.java.operators.translation org.apache.flink.api.java.record.functions org.apache.flink.api.java.record.io org.apache.flink.api.java.record.operators org.apache.flink.api.java.sampling org.apache.flink.api.java.sca org.apache.flink.api.java.tuple org.apache.flink.api.java.tuple.builder org.apache.flink.api.java.typeutils org.apache.flink.api.java.typeutils.runtime org.apache.flink.api.java.typeutils.runtime.kryo org.apache.flink.api.java.utils