Инициализируйте RDD для очисткиJAVA

Программисты JAVA общаются здесь
Ответить
Гость
 Инициализируйте RDD для очистки

Сообщение Гость »


Мне позвонили из RDD

JavaPairRDDexistentRDD; Теперь мне нужно инициализировать этот existingRDD пустым, чтобы, когда я получу фактические rdd, я мог выполнить объединение с этим existingRDD. Как инициализировать existingRDD пустым RDD, кроме инициализации его нулевым значением? Вот мой код:
JavaPairRDDexistentRDD; если(ai.get()%10==0) { существующийRDD.saveAsNewAPIHadoopFile("s3://manthan-impala-test/kinesis-dump/" + startTime + "/" + k + "/" + System.currentTimeMillis() + "/", NullWritable.class, Text.class, TextOutputFormat.class); //при сбое работника это будет перезаписано } еще { существующийRDD.union(rdd); }
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»