2013-03-05 180 views
1

嗨,我很新的HBase数据库。我下载了一些Twitter数据并存储到MongoDB中。现在我需要将这些数据转换为HBase来加速Hadoop处理。但我无法创建它的方案。在这里,我有twitter数据转换为JSON格式 -从MongoDB迁移到HBase

{ 
"_id" : ObjectId("512b71e6e4b02a4322d1c0b0"), 
"id" : NumberLong("306044618179506176"), 
"source" : "<a href=\"http://www.facebook.com/twitter\" rel=\"nofollow\">Facebook</a>", 
"user" : { 
    "name" : "Dada Bhagwan", 
    "location" : "India", 
    "url" : "http://www.dadabhagwan.org", 
    "id" : 191724440, 
    "protected" : false, 
    "timeZone" : null, 
    "description" : "Founder of Akram Vignan - Practical Spiritual Science of Self Realization", 
    "screenName" : "dadabhagwan", 
    "geoEnabled" : false, 
    "profileImageURL" : "http://a0.twimg.com/profile_images/1647956820/M_DSC_0034_normal.jpg", 
    "biggerProfileImageURL" : "http://a0.twimg.com/profile_images/1647956820/M_DSC_0034_bigger.jpg", 
    "profileImageUrlHttps" : "https://si0.twimg.com/profile_images/1647956820/M_DSC_0034_normal.jpg", 
    "profileImageURLHttps" : "https://si0.twimg.com/profile_images/1647956820/M_DSC_0034_normal.jpg", 
    "biggerProfileImageURLHttps" : "https://si0.twimg.com/profile_images/1647956820/M_DSC_0034_bigger.jpg", 
    "miniProfileImageURLHttps" : "https://si0.twimg.com/profile_images/1647956820/M_DSC_0034_mini.jpg", 
    "originalProfileImageURLHttps" : "https://si0.twimg.com/profile_images/1647956820/M_DSC_0034.jpg", 
    "followersCount" : 499, 
    "profileBackgroundColor" : "EEE4C1", 
    "profileTextColor" : "333333", 
    "profileLinkColor" : "990000", 
    "lang" : "en", 
    "profileSidebarFillColor" : "FCF9EC", 
    "profileSidebarBorderColor" : "CBC09A", 
    "profileUseBackgroundImage" : true, 
    "showAllInlineMedia" : false, 
    "friendsCount" : 1, 
    "favouritesCount" : 0, 
    "profileBackgroundImageUrl" : "http://a0.twimg.com/profile_background_images/396759326/dadabhagwan-twitter.jpg", 
    "profileBackgroundImageURL" : "http://a0.twimg.com/profile_background_images/396759326/dadabhagwan-twitter.jpg", 
    "profileBackgroundImageUrlHttps" : "https://si0.twimg.com/profile_background_images/396759326/dadabhagwan-twitter.jpg", 
    "profileBannerURL" : null, 
    "profileBannerRetinaURL" : null, 
    "profileBannerIPadURL" : null, 
    "profileBannerIPadRetinaURL" : null, 
    "miniProfileImageURL" : "http://a0.twimg.com/profile_images/1647956820/M_DSC_0034_mini.jpg", 
    "originalProfileImageURL" : "http://a0.twimg.com/profile_images/1647956820/M_DSC_0034.jpg", 
    "utcOffset" : -1, 
    "contributorsEnabled" : false, 
    "status" : null, 
    "createdAt" : NumberLong("1284700143000"), 
    "profileBannerMobileURL" : null, 
    "profileBannerMobileRetinaURL" : null, 
    "profileBackgroundTiled" : false, 
    "statusesCount" : 1713, 
    "verified" : false, 
    "translator" : false, 
    "listedCount" : 6, 
    "followRequestSent" : false, 
    "descriptionURLEntities" : [ ], 
    "urlentity" : { 
     "url" : "http://www.dadabhagwan.org", 
     "start" : 0, 
     "end" : 26, 
     "expandedURL" : "http://www.dadabhagwan.org", 
     "displayURL" : "http://www.dadabhagwan.org" 
    }, 
    "rateLimitStatus" : null, 
    "accessLevel" : 0 
}, 
"contributors" : [ ], 
"geoLocation" : null, 
"place" : null, 
"favorited" : false, 
"retweet" : false, 
"retweetedStatus" : null, 
"retweetCount" : 0, 
"userMentionEntities" : [ ], 
"retweetedByMe" : false, 
"currentUserRetweetId" : -1, 
"possiblySensitive" : false, 
"urlentities" : [ 
    { 
     "url" : "http://t.co/gR1GohGjaj", 
     "start" : 113, 
     "end" : 135, 
     "expandedURL" : "http://fb.me/2j2HKHJrM", 
     "displayURL" : "fb.me/2j2HKHJrM" 
    } 
], 
"hashtagEntities" : [ ], 
"mediaEntities" : [ ], 
"truncated" : false, 
"inReplyToStatusId" : -1, 
"text" : "Spiritual Quote of the Day :\n\n‘I am Chandubhai’ is an illusion itself and from that are \nkarmas charged. When... http://t.co/gR1GohGjaj", 
"inReplyToUserId" : -1, 
"inReplyToScreenName" : null, 
"createdAt" : NumberLong("1361801697000"), 
"rateLimitStatus" : null, 
"accessLevel" : 0 
} 

这里如何将数据划分为列和列族?我想做一个"twitter" column-family,其中包含source, getlocation, place, retweet etc...和另一个"user" column-family和包含name, location etc...(用户的数据)。即每个内部子文档的新列家族。

这种方法是否正确?现在我怎么区分urlentity"user" column-family"twitter" column-family

,以及如何处理那些包含子文件(如urlentity)的列表键

回答

3

有很多方法在HBase的模型此范围从单一的列存储都具有用于每个不同的表子实体与其他几个表进行“索引”。

一般来说,您基于读取和写入访问模式基于hbase中的数据建模。对于示例列族而言,它们存储在磁盘上的不同文件中。将数据划分为两列的原因在于是否存在大量需要来自一个数据库而不是另一个数据库的情况。等

有关于HBase的架构设计好介绍伊恩·瓦利从HBaseCon 2012,您可以找到幻灯片here和视频here