sima naderi

در این پست میخواهم درباره 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