stream-processing

2열

1답변

이벤트 처리 도메인을 처음 사용했습니다. 내 요구 사항에 대한 자바 기반 이벤트 처리 프레임 워크를 찾고있다. 아파치 스톰 (Apache Storm), 아파치 카프카 (Apache Kafka), 래빗 맥스 (RabbitMQ)와 같은 전통적인 이벤트 중개인들과 같은 Myriad 프레임 워크에서 문서 및 튜토리얼 미로를 살펴 보았습니다. 나는 더 현명하지 않다

0열

1답변

데이터 분석 스트림 처리 (스톰) 및 복잡한 이벤트 처리

복잡한 이벤트 처리와 결합 된 스트림 처리에 대한 연구를하고 있습니다. 오픈 소스 소프트웨어를 사용하여 Apache Storm에서 작업하고 싶습니다. Esper와 같은 CEP 엔진을 발견했습니다. , Siddhi, Sase +하지만 Apache-Storm에서 특별히 작업 할 무언가를 찾고 있습니다. Storm에서 완벽하게 조정할 수있는 CEP 엔진이 있습니

1열

1답변

backtype.storm 및 org.apache.storm 및 com.twitter.heron 패키지의 클래스 간 차이점

아파치 왜가리 용 사용자 정의 스케줄러를 작성하고 싶습니다. 소스 코드를 조금 깊숙이 살펴보고 싶습니다. 헤론 소스 코드에는 유사한 클래스를 가진 몇 개의 패키지가 있다는 것을 알았습니다. 예를 들어, 대부분의 클래스는 backtype.storm & org.apache.storm과 매우 유사합니다 (내부 코드가 완전히 같음). 이 두 패키지 사이에는 유사한

3열

1답변

디버깅 아파치 헤론 sccheduler

아파치 스톰과 비교했을 때 아파치 헤론의 가장 큰 장점 중 하나는 debug-ability이며 여러 가지 태스크를 번들로 묶는 대신 각 스파우트/볼트 작업을 하나의 헤론 인스턴스 (JVM 프로세스)로 옮기는 방식으로 이루어집니다. 한명의 JMV (폭풍우가 그것을 어떻게했는지). 이 접근법은 토폴로지 디버깅에 도움이됩니다. 하지만 제 질문은 어떻게 스케줄러

2열

1답변

Apache Apex 응용 프로그램을 다시 시작하는 방법은 무엇입니까?

apex documentation에서 apache apex로 시작된 앱은 kill-app & shutdown-app 명령을 사용하여 종료하거나 종료 할 수 있습니다. 그러나 응용 프로그램을 종료 (종료/종료) 할 때 이전 상태에서 다시 시작하는 방법은 무엇입니까?

1열

1답변

spring xd jms 소스의 Activemq 와일드 카드 지원?

I ', 스프링 xd 1.1과 함께 activemq 5.9 사용. 나는 activemq 주제를 구독하고 싶다. 그래서 jms 소스를 사용하고 있습니다. Activemq는 *,>와 같은 와일드 카드를 지원합니다. >은이 이름에서 시작하는 대상을 재귀 적으로 일치시키는 데 사용됩니다. 다음과 같이 jms 소스를 구독하는 동안이 와일드 카드를 사용하려고합니다.

1열

1답변

상태 변경 이벤트를 기반으로 분산 된 방식으로 얼마나 많은 "클라이언트"가 플립크 상태에 있는지를 계산하는 방법은 무엇입니까? 상태 유지 객체가 필요합니다.

나는 kafka -> flink -> elastic search를 사용하여 java에서 poc 프로젝트를 진행하고 있습니다. On 카프카에서는 특정 주제와 같이 0에서 최대 수천 회의 이벤트까지 예측할 수없는 이벤트가 생성됩니다. 나는 10 개 주를 {"stateA":54, "stateB":100, ... "stateJ":34} : [Created, .

1열

1답변

사용자 변환을 위해 Kafka 스트림 사용하기

저는 Apache Kafka를 사용하여 ETL 데이터 파이프 라인을 구현했습니다. 나는 Kafka Connect를 추출 및 적재에 사용했습니다. Connect는 원본 데이터를 읽고 카프카 주제의 실제 데이터를 JSON 형식으로 작성합니다. 변환 단계에서 카프카 항목에서 JSON 데이터를 읽고 싶습니다. 그런 다음 일부 맞춤 비즈니스 로직을 기반으로 SQL

0열

1답변

Elasticsearch에서 공간을 절약하기 위해 오래된 데이터를 병합하는 방법

나는 이것에 대한 정보를 찾으려고했지만 내가 찾고있는 것을 찾지 못했습니다. 나는 매분마다 Elasticsearch 데이터베이스에 메트릭을 저장합니다. 제 아이디어는 빈도가 단기간에 중요하다는 것입니다. 예를 들어 지난 주에 매분마다 측정 항목을 갖기를 원하지만 지난 주마다 하나의 측정 항목 문서 만 갖기 위해 이러한 측정 항목을 병합하고 싶습니다. 따라서

-1열

2답변

모든 컬렉션 또는 데이터 구조가 Java에서 블로킹되지 않습니다.

이벤트 처리에서 함수는 값을 콜렉션에 넣고 다른 하나는 동일한 콜렉션에서 제거합니다. 항목은 원본 (소켓)에서받은 순서대로 컬렉션 내부에 배치하고 동일한 방식으로 읽어야합니다. 그렇지 않으면 결과가 변경됩니다. 대기열은 대부분의 사람이 추천하는 컬렉션이지만 항목이 추가 될 때 대기열이 차단되므로 추가가 완료 될 때까지 기다려야 비효율적이며 작업 대기 시간이