25
4
Tôi đang học HBase. Tôi biết cách viết chương trình Java bằng Hadoop MapReduce và ghi kết quả đầu ra vào HDFS; nhưng bây giờ tôi muốn ghi kết quả đầu ra tương tự vào HBase thay vì HDFS. Nó phải có một số mã tương tự như những gì tôi đã làm trước đây trong HDFS:
Trung tâm cá nhân
Điều phát hành
từ bỏbối cảnh.write (khóa, giá trị);
Bất cứ ai có thể cho tôi một ví dụ để thực hiện điều này?
câu trả lời hay nhất
Đây là một cách:
lớp tĩnh công khai MyMapper mở rộng TableMapper {
bản đồ void công khai (hàng ImmutableBytesWritable, Giá trị kết quả, Bối cảnh bối cảnh) ném IOException, InterruptedException {
// ví dụ này chỉ sao chép dữ liệu từ bảng nguồn...
context.write(row, resultToPut(row,value));
}
tĩnh riêng Đặt resultToPut(Khóa ImmutableBytesWritable, Kết quả kết quả) ném IOException {
Put put = new Put(key.get());
cho (KeyValue kv : result.raw()) {
put.add(kv);
}
trả lại đặt;
}
}
Bạn có thể đọc về nó ở đây Trình ánh xạ bảng 的信息
Về java - Giảm ánh xạ HBase: ghi vào HBase trong Giảm tốc, chúng tôi tìm thấy một câu hỏi tương tự trên Stack Overflow: https://stackoverflow.com/questions/18603031/
25
4
0
Tôi không biết cách truy cập cờ isLoading của giá trị bool từ bộ giảm tốc của bộ giảm tốcForm.js trong bộ giảm tốcRegister.js. Tôi đã sử dụng CombineReducers() và
Tôi đang cố gắng tìm một cách lý tưởng để cập nhật một số trường cấp cao nhất trên cây trạng thái của mình trong khi vẫn duy trì bộ giảm phân chia. Đây là một giải pháp đơn giản mà tôi đã nghĩ ra. trạng thái var = { fileOrder: [0],
Nếu chúng ta muốn nhóm theo cùng một khóa (đầu ra của bộ giảm tốc đầu tiên), có thể gửi trực tiếp đầu ra của bộ giảm tốc sang một bộ giảm tốc khác Đôi khi trong khi liên kết, tôi thấy rằng tôi đang sử dụng một trình ánh xạ để đọc đầu vào và sao chép nó để xuất ra. Vì vậy tôi nghĩ
Tôi có một bộ giảm tốc như thế này: const Chart = CombineReducers({ data,fetchProgress,fetchError,
Khi có nhiều bộ giảm tốc trong mã Map Giảm, không có bất kỳ hình thức liên lạc nào giữa chúng. Tuy nhiên, khi thực hiện các hoạt động như tổng hợp, tất cả các bộ giảm đều tạo ra một đầu ra cuối cùng duy nhất. Việc tổng hợp diễn ra như thế nào khi không có sự giao tiếp giữa chúng? Có phải bằng cách viết vào bối cảnh?
Tôi có một bảng trong tổ ong mà tôi muốn lấy tất cả dữ liệu. Vấn đề là: select * from tbl; cho tôi kết quả rất khác so với: select count(*) from tbl; thứ hai
Giả sử tôi có một ứng dụng có hai bộ giảm tốc - bảng và chân trang được kết hợp bằng cách sử dụng CombineReducers(). Khi tôi bấm vào một nút, hai hành động sẽ được gửi đi - một
Tôi đang tìm hiểu thêm về redux và tôi gặp một số khó khăn khi xử lý các bộ giảm bậc cao hơn. Tôi đang cố gắng hiểu cách hoạt động của nó bằng một ví dụ phân trang đơn giản. Lưu ý: Đoạn mã sau chỉ là lối tắt cho redux trong ngữ cảnh của Nodejs
Tôi gọi nguồn cấp RSS và phân tích nó bằng trình phân tích cú pháp. Tôi nhận được một mảng. Bây giờ tôi muốn tạo một đối tượng ở cuối trông như thế này: { "2019-06-13": { "rates": { "usd":
Tôi có một danh sách học sinh và ứng dụng của tôi luôn hiển thị một học sinh vào thời điểm đó, activePupil. Cho đến nay tôi có hai bộ giảm tốc. Một trong số chúng chứa và theo mặc định trả về danh sách tất cả các phần tử con (dưới dạng một mảng): [ { id:
Tôi có một bộ giảm tính năng (bộ giảm lát) được gọi là động vật. Tôi muốn chia những bộ giảm tốc này thành động vật có vú, chim, cá, v.v. Phần này rất dễ vì tôi có thể chỉ cần sử dụng ActionReducerMap. Bây giờ giả sử cho con bú
Một cách giảm đơn giản đối với một mảng trống sẽ đưa ra: Ngoại lệ trong luồng "chính" java.lang.UnsupportedOperationException: Không thể giảm một lần lặp trống. Ngoại lệ tương tự khi liên kết: val a
Tôi có một số tài liệu 25k (4 GB ở dạng json thô) dữ liệu mà tôi muốn thực hiện một số thao tác javascript để giúp người tiêu dùng dữ liệu cuối (R) của tôi dễ truy cập hơn và tôi muốn chuyển một thay đổi cho mỗi tài liệu Thêm bộ sưu tập mới ĐẾN
Tôi chỉ muốn xác minh sự hiểu biết của mình về các thông số này và mối quan hệ của chúng, vui lòng cho tôi biết nếu tôi sai. mapreduce.reduce.shuffle.input.buffer.percent cho biết nội dung của toàn bộ giai đoạn xáo trộn được gán cho bộ giảm tốc.
Tôi muốn chuyển giá trị của trạng thái redux từ bộ giảm tốc sang bộ giảm tốc khác. Trong trường hợp của tôi, tôi muốn chuyển giá trị của các nhóm từ trạng thái trong groupReducer.js sang ScheduleReducer
Vì vậy, tôi có một ứng dụng có nhiều bộ giảm tốc và do đó có nhiều người tạo Hành động được liên kết. Tại một thời điểm, một trong các bộ giảm tốc của tôi đã cập nhật trạng thái (do chỉnh sửa), vì vậy tôi phải đảm bảo rằng các bộ giảm tốc khác nhìn thấy điều này
Tôi có một bộ giảm tốc giúp điều chỉnh lại trạng thái thích hợp khi một hoạt động được lên lịch. Bây giờ tôi đang gọi API thường xuyên để kết quả sẽ kích hoạt hành động này nhiều lần. Vì vậy, điều tôi muốn là nếu trạng thái bộ giảm tốc đã có dữ liệu thì một bộ giảm tốc khác
Khi tôi cố gắng thực hiện giảm DISTINCT từ đây, tôi gặp lỗi. Tôi đã sao chép lỗi này trên thùng mẫu bia, vì vậy lỗi này sẽ dễ tái tạo. Tôi không có tệp trong mapreduce_errors.txt
Trong phân tích cú pháp ưu tiên đơn giản (phân tách) của ngữ pháp sau đây, chúng ta có xung đột dịch chuyển-giảm và giảm-giảm. X là ký hiệu bắt đầu, X'-->$X$ là quy tắc cộng. Ngoài ra, ký hiệu + và thấp hơn là ký hiệu đầu cuối. X'-->$X
Tôi cần viết chương trình Mapreduce gọi liên tục hai bộ giảm tốc. Nghĩa là đầu ra của bộ giảm tốc thứ nhất sẽ là đầu vào của bộ giảm tốc thứ hai. Làm thế nào để tôi đạt được điều này? Những gì tôi đã tìm thấy cho đến nay gợi ý rằng tôi cần thực hiện việc này trong trình điều khiển của mình
Tôi là một lập trình viên xuất sắc, rất giỏi!