hbase

Published on 07/04,2017

در این پست میخواهم درباره hbase که باید داده های ورودی را از آن بخوانم صحبت کنم
ابتدا hbase را راه اندازی کرده سپس با استفاده از کد زیر یک جدول در ان ایجاد میکنم
Configuration config = HBaseConfiguration.create();
HTable hTable = new HTable(config, "BTC" );
سپس با استفاده از کد زیر برای هر ردیف جدول یک کلید انتخاب می کنم
Put p = new Put(Bytes.toBytes(split[0]));
 با استفاده از کد زیر به ستون خانواده ranking به ستون subject آن یک داده اضافه میکنم.
Bytes.toBytes("subject" ),Bytes.toBytes(split[0]));
 
 درلینک زیر کد کامل قرار داده شده است که داده ها رو از فایل ورودی BTC میگیرد و درجدولhbase قرار می دهد.
https://fumdrive.um.ac.ir/index.php/s/e5ZXUTsZJd4zIRs
 


Comments

Leave a Reply

Add comment
Info

unmoderate_note

Comments are moderated to prevent spam. This may cause a delay before your post appears.

 authimage