|
@@ -20,7 +20,7 @@ public class VideoCleanODPSToHDFS {
|
|
|
JavaSparkContext jsc = new JavaSparkContext(sparkConf);
|
|
|
|
|
|
ODPSService odpsService = new ODPSService();
|
|
|
- JavaRDD<Map<String, String>> record = odpsService.read(jsc, "loghubods", "not_active_videos", "all", 90);
|
|
|
+ JavaRDD<Map<String, String>> record = odpsService.read(jsc, "loghubods", "not_active_videos", null, 90);
|
|
|
|
|
|
JavaRDD<String> data = record.map(r -> {
|
|
|
StringBuilder sb = new StringBuilder();
|