내 Datastax Solr 인스턴스에서 Stats Component을 사용하려고합니다. 이 같은 모습에 대한 통계를 얻으려고 스키마의 일부 그러나 <field name="foo" type="tuple" indexed="true" stored="true"/>
<field name="foo.start" type="bigint" indexed="false"
Spark와 관련된 몇 가지 기본적인 질문이 있습니다. 우리는 처리 작업의 맥락에서만 스파크를 사용할 수 있습니까? 우리의 유스 케이스에서는 우리가 정련하고 캐논 드리 테이블에 저장할 수있는 포지톤 및 모션 데이터 스트림이 있습니다. 그것은 카프카 및 스파크 스트리밍으로 수행됩니다. 그러나 웹 사용자 일부 검색 기준으로 일부 보고서를보고 싶다면 Spark
opscenter 5.2.4을 사용 (DSE 4.8.8을 실행하는) 하나 개 또는 여러 노드에서 정리를 시작하려고 할 때, 나는 다음과 같은 오류 얻을 : 2016-06-06 07:44:33+0000 [Live] WARN: Marking request '172.31.62.218: /ops/cleanup' (739eb503-01c5-436f-950c-e4c0
3 개의 노드가 모두 Spark를 실행하는 Analytical 노드 인 3 개의 m3.large 인스턴스를 사용하여 AWS에 Datastax Enterprise 클러스터를 만들었습니다. 3m3. 큰 아마존 인스턴스에는 각각 2 개의 코어가 있으므로 총 6 개의 코어가 있습니다. Spark Master 웹에서는 각각의 작업자 노드의 웹 UI에서 총 3 개의
누구나 spark sql의 합성 기본 키를 사용하여 Java에서 예제를 공유하여 Cassandra에 데이터를 저장할 수 있습니다. CQL을 사용하면 쉽게 할 수 있습니다. 하지만 내가하고있는 일은 카프카 (Kafka) 스트림의 시계열 데이터를 스트림으로 보내 캐스 산드라 (curandandra)에 원시 데이터로 저장하는 스파크 작업의 내부입니다. 그런 다음