59_尚硅谷_HBase案例_谷粒微博（关注用户第二部分分析）

好，那接下来我们要写第二部分代码了吧？第二部分代码最核心的是不是它？最核心的就是往这里面要放数据了。对吧，放数据了，好，这里边我们想一下未来要放的特别对象有几个。对吧，我们先思考这个问题，因为涉及到我们要不要在中间加一个集合的问题了，对吧？如果说有多个的话，是不是要有集合，如果说不用多个的话，我还非得用那个集合吗？有几个对象吧，一个一个吧，啊一个对象，一个对象呢，有三个列，每一个列里面呢，有多个版本对吧，但是呢，它属于同一个下的，这没问题吧啊OK，那好，那我们应该先去把它的一个负的对象给它构建出来。然后。是不是应该便利我们BCD，也就是ten吧，便利BCD分别去拿一下这里面的值，然后把它赋值给A，也就循环题里边去复制A对吧？对BCD分别进行并例，那并列到B的时候，把B这个东西呢，去构建一个什么内容，去微博内容表里拿一个数据拿过来是不是给A对吧？那第二个便利的时候是不是写一个C，然后去便利，然后拿过来D，一样的道理吧，啊最后要注意的一个点。

当前我关注的BCD，我同时我四个人同时注册的。就是BCD都没有什么发布过微博，有没有可能？有吧，有可能，那你put对象之后，循环体，我们是不是说了在循环里边给put去ADD family at column等等，就是赋值操作是不是在循环里边。没问题吧，在循环经里边，在这个时候有问题，如果说你关注的BCD都没有数据，那你这个循环点也就一个列的问题量，对吧。

一个那个没添加的时候，你直接去往里边。就是你用表去调用库的方法，它会报错。他说你没有指定列足。就是说如果你单独的你有了一个put对象，就put对象里面是不是单独的一个rookie啊，你没有写put.at没有写这个代码，直接调用table.put它会报错，报错说你没有指定列足。所以同样道理，为了这种情况，我们还是要判断一下这些人有没有发微博吧，其实有一个很简单的方式啊，就是之前大家其实也看到过，但是没有去专门的讲，因为铺的方法铺的。Is em是否为空，这个为空不是说它有没有rookie rookie1定有，因为它构造方法里面是不是要传rookie啊，Rookie也有，就是判断有没有传列图列等等这些内容啊，那我们最后你也不用管，我们就通常用负循环，就往里面添加数据，最后。

再做一个判断对吧，如果它为空的话，我们就直接去关闭其他的资源，如果不为空，是不是获取in box table，然后把它插入进去，然后把in Bo table给它关掉，跟我们上面这个。这步操作是不是一样的，只不过说上面，因为你是一个集合，你可以通过集合的size来做，但是现在你是单一的一个put呀。对吧，负的它更好做，因为它里边有一个判空的方法啊，有一个判空的方法啊，所以呢，我们要注意一下，那接下来我们还是同样的道理，把它的核心逻辑去写。第一步，是不是应该去获取什么？链接。链接我们已经获取过了，对吧，那可以直接获取叫微博。是不是内容表的对象？因为你要去读这个数据有没有值，你都得去获取一下才知道有没有知道对吧？啊，那它这个对象呢，无论怎么样都要获取到这个没问题吧，啊第二步应该去创建一个。

In box表的一个put对象对吧，好创建。叫诶。创建叫收。见相表的库的对象啊，这是第二步，第三步应该做什么事呢？是不是按道理来说，你创建完库的对象之后，应该给它赋值啊？但是这个复制还有点麻烦，你先要去内容表里面去拿一下，对吧，而且拿你能说BCD3个人同时拿吗。是一个一个拿呀，对吧，所以说这块应该是循环。这个对吧。呃，获取每个叫被。关注者的近期发。

的。微博对吧，这块呢，我还是写一个负I，因为里边还要写注释对吧，还要写注释啊，还是用负I来代替一下，这个没问题吧，反正最后我们还是同样的用那个点做这个增强负循环嘛，啊在这里边好，这个里边应该要做什么事。第四步。是不是要这样获取？当前。被关注者的就当前就是因为我这个是循环嘛，对吧，啊，那这个就是第一次循环是不是B进来了。并加之后你要去获取B的所有的微博，近期发布的，先不说近期发布的微博，那今天发布的微博，因为他是按照那个时间顺序道具的，对吧，那我们要干啥呢。用get还是用盖呢？对吧，因为获取的方式我们是不是两种啊，对吧，Get和盖，那这一块应该用什么呢。只能用盖，对不对，牛盖能取到。

你干的是不是一定要指道指定U啊，那你在关注的时候，你知道那个人里边那个时间戳吗。不知道吧，所以这块只能用什么SKY，而且我们要想一下这个问题了，用SKY，那这些东西应该怎么写呢？对吧，先我们不考虑获取近期啊，先考虑后续所有的。可以怎么做，我可不可用？大肉都不。你不能全表扫描吧。因为你只要获取这一个人的微博吧，你不能做全秒扫描吧，用start行不行，想一下这个问题。那怎么写怎么写。大写UID。

下划线。就到这后面不写了，因为在微博那个内容表里面，是不是后面拼接时间啊，对吧，OK，我就写UID加上反。是不是所有的关于假如说我写的是B划线，是不是所有B发布的微博的那个rie都比这个大。没问题吧，啊，还有一个问题就是这个地方它会把其他的数据都包裹进来。也不会有吧啊，你写的B加下划线了。啊，因为你大家的UIB不同，前面应该不一样嘛，对吧，啊不一样已经比较这大小，不会比较到这个下划线的一步，好这个就搞定了，那stop中的。我避数吧你。可以吧，我写一个B加竖杠。因为我之前说过竖杠比下划线要怎么。要大要大，那这样是不是能完全的把我B所有的内容给他。搂过来啊，搂过来之后你再去考虑什么，前三后三的问题吧，啊再考虑这个问题，那我们就用四盖啊这种思路呢，稍微捋一下，稍微捋一下好，那这个也就是说它获取出来的内容是不是一个。

集合。你用扫描出来的是不是获取到的是一个什么，是不是scanner，是不是类似于一个一个集合多个吧，所以接下来应该又有一个什么。是不是又有一个负循环了？有没有问题啊，因为你获取的这个值好，第五步应该对。获取的值进行编利，假如说我们把它逻辑简单一点，我们就将所有的数据都放在那个里边，啊后这三条这个问题呢，我们后期再考虑OK吧，啊先去做这个事，是不是对获取到值进行便利。注意这块呢，获取到的是一个什么it result CA，哎呀result scanner吧，是这个集合吧，啊，那要便利它啊，便利它在这个便利里边，你是不是就能拿到每一个U了。

对吧，啊，那这个在这个循环里边第六步就可以给我们这个什么收件箱表的铺的对象。复职了。是不是一定要在这个第二层做循环里面才能复水，想一下。捋一下啊，我没有写一个代码，只是带着大家梳理一个思路，对吧，那你看啊，现在来捋一下，因为两层循环了，有的同学可能比较晕，第一次循环是不是对于ten循环是不是拿到的是B，第一次进来的时候B好。B，这个数据近期发布的微博是不是有B_1B下划键2B下关键三多个呀，但是你拿到的是一个结果提示scanner，这没问题吧，因为SC扫描是不是without scanner对吧，无论你是不是用这个stop，一定是用without scanner，那接下来我们循环的就B1 B2b3，把这个B1 B2b3是不是要塞到这个负的对量里边。

你不就是为了拿这个rookie吗？但是你关注的时候，你是不是只有被这个人UID拿到ID啊，你能拿到。B这个人的具体的发布微博的那个时间嘛，拿不到，只能去微博内容表里面查出来了。到这一步应该没问题吧，啊这个是OK的，好那两次负循环结束之后，是不是所有的值都已经复制完了，对吧，这里边我们还要解决那个什么三条的问题吧，啊等会再解决，就是如果说再考虑这个问题就太复杂了啊，太复杂了，好在第一层负循环结束之后，等于负值结束，负值结束我们就可以做什么事了。是不是判断呀，刚才说了判断。当前的put的对象是否为空对吧？那这块就写一个啊，我们先写一下if，我们写的这个地方逻辑我们可以先写啊if，哎，这个我们没有这个复镜像对吧，那就是if这个逻辑写在这。

嗯，我们写一下。写一个处啊，写个处就这样，它虽然标黄有几个，但是呢，它不至于错对吧？啊，就等于这个衣服跟没写一样啊，但是呢，这确实里边有一个布尔类型的表达式对吧？啊表尔类型的表达式OK，那这样判断是否为空，那最后如果说它为空，我们就直接写下面的嘛，对吧，就是关闭资源对吧？啊就是最后呢，这个关闭资源又是两部分统一的是不是。叫关闭资源啊，叫关闭资源，那中间的如果说它不为空，我们是不是就获取。叫收件箱表对象。然后。还有数据。之后呢？关闭收件箱对吧，连接对吧，啊还是做这个事啊，做这个事的也就这个意思。

那这个是我们梳理的一个整个的一个思路啊，整个思路其实你对着这个来看也比较清楚一点，对吧，就是说刚才我们所理的思路当中呢，首先我们所说的是不是先获取。这个表对象。没问题吧，好，然后建创建一个A这个人的什么in box这张表的一个库的对象。目的，创建这个put对象是不是为了给BCD这三个内容添加具体的内容啊？但这个内容哪来啊？是不是内容表里边取啊，啊内容表面取好，那取的时候BCD这三个人能同时取到吗？不行，所以这块我们第一层做循环，循环的是BCD。对吧，好，B进来了，是不是拿着B用stop把B所有的微博全部拿过来。对吧，因为前三条我们可以进来筛选，等会儿判断时间中啊，或者这种这这种东西可以可以再做处理，对吧？啊再做处理，OK，那往这一扔。

好，第二次循环的时候，是不是C又过来了，D又过来了，等所有的这个值全部放完之后，是不是可以写到这张表里边啊，我们核心的逻辑就在这儿啊，这是逻辑啊，那我们把它呢写一下。