Dừng luồng bối cảnh Spark streaming sau một khoảng thời gian

Question

tôi xây dựng một ứng dụng mà nhận DStreams từ Twitter, cách duy nhất để ngăn chặn các bối cảnh Streaming là bởi stoping thực hiện. Tôi tự hỏi nếu có một cách để thiết lập một thời gian và chấm dứt các ổ cắm trực tuyến mà không cần stoping toàn bộ ứng dụng?

Answer 1

Bạn có thể sử dụng một trong hai

awaitTerminationOrTimeout(long) 

như đã đề cập trong các câu trả lời trước, hoặc bạn có thể ngăn chặn các bối cảnh luồng bằng tay từ chủ đề khác của bạn:

// in the main thread 
    awaitTermination(); // will wait forever or until the context is stopped 

    // in another thread 
    streamingContext.stop(); 

Answer 2

Bạn có thể sử dụng phương pháp awaitTermination() trên đối tượng streamingContext phải chờ một thời gian nhất định. Tham khảo this