카프카에서 읽어야 할 자바 응용 프로그램이있어서 마법을 부르고 데이터를 드루이드에게 보냅니다. 나는 Kafka에서 데이터를 소비하고 결국 Truquility를 사용하여 Druid에게 보내는 Kafka 작업자 스레드 (주제 당 약 15 개)가 있습니다. 이 문제는 다음과 같습니다. 하나의 스레드로 작업하면 모두 정상입니다. 둘 이상으로 일하면 예외가 생깁니다
카프카에 특정 형식의 메시지가 있습니다. 그들은 캐럿 분리되어 있습니다. 지금 평온을 사용하여 이것을 구문 분석하려면 아래 구문 분석 스펙을 사용하고 있습니다. "parser" : {
"type" : "string",
"parseSpec" : {
"timestampSpec" : {
"column" :
나는 Druid에 대해 꽤 새로운데 ElasticSearch와의 비교에 대한 내 답변을 얻지 못했습니다. 이 링크를 발견 : druid vs Elasticsearch하지만 차이점과 장점을주지 않습니다. 누구든지 나를 설명하거나 Google에서 찾지 못한 링크를 제공 할 수 있습니까? 미리 감사드립니다. J
나는 rabbitmq의 파이어 호스와 함께 작동하도록 설정 드루이드하려고하지만, java.lang.IllegalArgumentException가 평온에서 다음과 같은 오류를 받고 있어요 클래스 io.druid.data.input.FirehoseFactory] 나는 한 다음 1. 설치 드루이드 2. 다운로드 확장 드루이드 - rabbitmq 3. 드루이드 확
광고 로그 데이터가 있으며이를 실시간으로 Druid 서버로 보내려고합니다. 그러나 문제는 Tranquility와 Kafka 사이입니다. 데이터를 실시간으로 수집하는 가장 좋은 방법은 무엇입니까? 왜냐하면, 카프카를 사용할 때 그것은 오류 묶음을 만들기 때문입니다. 나는 평온을 사용하려고합니다. 이 문제에 경험이있는 사람이면 누구에게 도움이됩니까? 고마워.
druid segmentMetadata metdata 쿼리에서 모든 열의 특정 식별자를 검색하는 방법. 결과에 카디널리티와 크기 만 포함될 것으로 예상했지만 모든 분석이 반환되었습니다. {
"queryType":"segmentMetadata",
"dataSource":"wikiticker",
"intervals":["2015-09
우리는 1,800 억 개의 행과 100 개 이상의 열이있는 OLAP 테이블을 보유하고 있으며 하이브에서는 볼륨이 8TB에 가깝습니다. 대부분의 열은 측정 기준이며 또한 측정 항목 열도 거의 없습니다. 대시 보드 애플리케이션을 실행하기위한 실시간 시스템 지원 임시 쿼리를 구축하고 싶습니다. 쿼리는 대기 시간이 10 초 미만으로 실행되어야합니다. 우리는 이러한
애들 아 나는 드루이드로 graylog2 서버에서 데이터를 얻을 필요 (예 : CPU, 메모리, 여러 시스템의 디스크 사용률). 나는 graylog 마켓 플레이스 및 평온 문서에서 플러그인을 검색했으며, graylog2에서 데이터를 검색하는 솔루션을 찾지 못했습니다. 나는 graylog2에서 REST API를 사용하는 것이 해결책이라고 생각하지만, 이것을
쿼리를 빠르게 수행 할 수있는 데이터베이스에 로그를 저장하는 솔루션이 필요합니다 (예 : 10 개 표준 포맷 중 하나를 따르는 것이 좋음). 다양한 유선 쿼리에 대한 결과를 쉽게 제공하십시오. 예 : 텍스트 본문에서 키워드를 찾는 쿼리, 여러 테이블과 관련된 쿼리 내게 권장되는 솔루션은 MetaMarket이었습니다. 매우 훌륭한 쿼리 시스템으로 실시간 로깅