草庐IT

existingRDD

全部标签

java - 初始化一个RDD为空

我有一个RDD叫做JavaPairRDD>existingRDD;现在我需要将这个existingRDD初始化为空,这样当我得到实际的rdd时,我可以与这个existingRDD进行联合。如何将existingRDD初始化为空RDD,除非将其初始化为null?这是我的代码:JavaPairRDD>existingRDD;if(ai.get()%10==0){existingRDD.saveAsNewAPIHadoopFile("s3://manthan-impala-test/kinesis-dump/"+startTime+"/"+k+"/"+System.currentTimeMi