Resultados de la búsqueda a petición "dstream"
No puede persistir el DStream para su uso en el próximo lote
JavaRDD<String> history_ = sc.emptyRDD(); java.util.Queue<JavaRDD<String> > queue = new LinkedList<JavaRDD<String>>(); queue.add(history_); JavaDStream<String> history_dstream = ssc.queueStream(queue); JavaPairDStream<String,ArrayList<String>> ...
Cómo usar la extracción de características con DStream en Apache Spark
Tengo datos que llegan de Kafka a través de DStream. Quiero realizar una extracción de características para obtener algunas palabras clave. No quiero esperar la llegada de todos los datos (ya que está destinado a ser un flujo continuo que ...