이것은 클러스터를 통해 스트림을 처리하기 위해 정당화 된 처리에 튜플을 생성하는 데 필요한 입력 포트의 코드 스 니펫입니다. 문제는 BlockingQueue가 InterruptedException을 던지고 있다는 것입니다. 비동기 인터럽트 루프 -가 가 가 가 java.lang.InterruptedException10930 [스레드 (20)] 정보는 bac
Storm (IDE가 아닌 실시간 프레임 워크)을 사용하여 웹 크롤러를 작성하려고하고 있습니다. My Spout은 PHP로 작성된 첫 번째 Bolt에서 호출되고 검색되어야하는 URI 스트림을 전달합니다. node.js 배경에서 오는대로 콜백을 사용하여 비 차단 방식으로 이러한 기능을 구현할 수 있음을 알고 있습니다. 내 순진한 생각은 그 볼트에 대한 많은
나는 폭풍 - 시동기의 예를 가지고 Storm에 대해 읽고 계속 놀았습니다. 나는 개념을 가지고 있다고 생각하며 많은 경우에 매우 잘 적용됩니다. 나는 이것에 대해 더 많은 것을 배우기 위해하고 싶은 테스트 프로젝트를 가지고 있지만 Storm이 실제로 이것에 적합한 지 궁금합니다. 내가 가진 개념적 문제는 '스트리밍'정의입니다. Storms는 스트림을 구독