I che costruisce un'applicazione che riceve DStreams da Twitter, l'unico modo per interrompere il contesto Streaming è interrompere l'esecuzione. Mi chiedo se c'è un modo per impostare un tempo e terminare il socket di streaming senza interrompere l'intera applicazione?Interrompe il contesto di streaming in Spark Streaming dopo un periodo di tempo
8
A
risposta
5
È possibile utilizzare uno
awaitTerminationOrTimeout(long)
Come accennato nella risposta precedente, oppure è possibile interrompere il contesto in streaming manualmente dal altro thread:
// in the main thread
awaitTermination(); // will wait forever or until the context is stopped
// in another thread
streamingContext.stop();
1
È possibile utilizzare il metodo awaitTermination() sull'oggetto streamingContext per attendere un intervallo di tempo specificato. Fare riferimento this
Eclipse mi dà questo indicatore, la metodo awaitTermination (long) dal tipo JavaStreamingContext è deprecato! Spark 1.4.0. Ho usato awaitTerminationOrTimeout (Long), ancora non funziona. Continua a stampare. –
public void awaitTermination (long timeout) Obsoleto. A partire da 1.3.0, sostituito da awaitTerminationOrTimeout (Long). Attendi che l'esecuzione si fermi. Qualsiasi eccezione che si verifica durante l'esecuzione verrà generata in questo thread. Parametri: timeout: tempo di attesa in millisecondi – urug