Ai đó có thể giải thích cách MapReduce hoạt động với Cassandra .6? Tôi đã đọc qua ví dụ đếm từ, nhưng tôi không hoàn toàn theo dõi những gì đang xảy ra ở đầu Cassandra so với kết thúc "khách hàng".Làm thế nào để sử dụng Bản đồ của Cassandra Giảm với hoặc w/o Lợn?
https://svn.apache.org/repos/asf/cassandra/trunk/contrib/word_count/
Ví dụ, giả sử tôi đang sử dụng Python và Pycassa, thế nào tôi sẽ được tải trong một bản đồ mới giảm chức năng, và sau đó gọi nó? Chức năng giảm bản đồ của tôi có phải là java được cài đặt trên máy chủ cassandra không? Nếu vậy, làm thế nào để tôi gọi nó từ Pycassa?
Ngoài ra còn có đề cập đến Pig làm cho tất cả điều này dễ dàng hơn, nhưng tôi là một Hadoo noob hoàn chỉnh, vì vậy mà không thực sự giúp đỡ.
Câu trả lời của bạn có thể sử dụng Tiết kiệm hoặc bất cứ điều gì, tôi vừa đề cập Pycassa để biểu thị phía máy khách. Tôi chỉ cố gắng để hiểu sự khác biệt giữa những gì chạy trong cụm Cassandra so với máy chủ thực tế làm cho các yêu cầu.
Vì vậy, các nút Cassandra không làm bản đồ giảm, bất cứ nơi nào Java của bạn đang chạy là? – UltimateBrent
Có, bộ công việc Hadoop chạy các công việc m/r. – jbellis
vì vậy không phải là điểm của bản đồ giảm mà nó được phân phối? Nếu nó không chạy trên các nút cassandra, thì vấn đề là gì? – UltimateBrent