60_尚硅谷_HBase案例_谷粒微博（关注用户第二部分代码实现）

那接下来呢，我们把这个代码来完成一下啊，来完成一下第一个这个好写吧。点get table。Table name.value of内容表，那就是constant点。Content table对吧？啊VCT标啊，看table第二个创建一个收件相表的put啊，而且这个rookie是不是我们所说的A呀，传进来的方法就是UID了啊是谁操作的啊，你有一个这个put啊，你有一个put，这个是best.to啊，这个UID。给它扔进来啊，看到加B，你看这把它就是是不是两个都替换，那我们只替换当前的吧，替换当前的把它改成in box不等对吧，啊两个这样的然混了把换一个好，这个循环体是不是要换一下。我们说的对于attempt进行循环嘛，那就是attempt点。说好加了这个循环，这个括号是不是去掉对吧，刚才是一对一的嘛，把这个括号去掉，那这个括号去掉之后，是不是把这些东西给他。

放在这里边吧，啊，这个刚才我们写的循环里边的一个注释，没问题吧，啊这个放进来，那第一个获取当前被关注者近期发布的微博，那先不考虑近期所有的微博全部拿到，对吧？啊，所有的微博全部拿到，那这个地方我们怎么写？一个。干呢，这个时候要注意，要传大的肉吧，叫best.to还记得我们说大的怎么写的，加下划线吧，应该是加上什么下划线没问题吧？好，第二部分就是点To Best，然后是attend，是不是我们所说的那个B加什么竖划线啊，加竖划线它然后加杯得到一个项。那接下来拿着内容表点盖的。

Scanner，把这个SC传进去好，得到的是不是我们要的？Scanner对吧，刚才我们说了不就是为了获得这个scanner吗？对吧，我把这个这样好看一点，这个就整了一行。我们现在得到这个scanner。那现在是不是要便利于它呀，对吧，啊便利它，它怎么便利呀。Scan的点。循环吗？循环。来，注意，有同学提到了点，还再一次负循环，需要吗？来想一下我们为了拿什么东西？是不是为了拿这个rookie啊，我不是为了拿里面内容啊，Rookie跟result是一一对应的关系吧，所以通过result这个地方，我们就可以直接拿到什么。

是不是可以拿到，OK，因为既然你是一一对应的关系，我是不是可以直接通过你来拿到呀，所以呢，就不用说再去变于result了，所以我这块只写了什么一层循环。如果说你要拿里边的内容的话，你里边是不是还要签到一层对吧？啊还要先当一层，但是呢，我们不拿具体的内容，我们只是拿RP对吧，那我把这个注释是不是CTRX给它拿上来。对吧，这是便利嘛，好，接下来把它是不是应该挪到这个循环里边，然后这个做循环只是为了做注释用的，是不是把它可以干掉了，对吧？啊注意代码做了接修改就不要win啊，因为刚才我说了for呢，只是说告诉我将来这是一个循环，对吧？啊是这样做的，好，那给它赋值。怎么来？前面有一个的点爱靠拢啊，第一个in box的列组好写吧。

因为我们知道这是in box表，所以说cos看点in box的列足好列呢。ABC列其实就是BCD，那在代码里边其实就是谁啊，是不是当前这个对吧，不就BCD吗？啊把这个attend a。看到我们写一下。最后这个值呢，哎，这个最后要一个直接数组，我直接给点什么改。嗯。直接点开，因为它就是要一个直接数五对吧？啊，我就要的就是这个B下划线加那个什么时间戳的那个东西啊，那直接放进去就行了，好，那接下来我们讨论一下这个问题，就是说三条这个问题。

对吧，好，那这样我们这样写，将来你会拿三条拿多吗？来看一下，我们这样写刚好。全放进去，为什么呢，来看。便利的时候，它是不是按照入K的顺序进行便利了。对吧，假如说你B这个人在一时间，B这个人二时间，B这个人在三时间，我发布了五条微博，这个时间就是从小到大的12345，就是这个时间中OK吗？好，那接下来便利的时候是不是他先出来。来，他先出来，我是不是把它先放到里面了？将来他放进放到in box表里边，是不是它的时间桌应该是什么？对，小的最小的。而这一条将会在这儿。第二大的对吧，那第三条在这儿，第四条呢。在这第五条呢。

在这最上面吗。刚好你版本不是说限定三个吗。我把所有的都扔进去，最后返回，不就是刚好最大的三个。能不能明白这个事儿？来注意一下啊，就是因为你在编译这个数据的时候，你B发布了五条微博，是不是B发布的B1也就实践中最小的那个微博最先出来。最先被你拿到嘛，因为便利的时候大家关注到对吧，它是数据从小到大来了吧，第一条拿到的是什么？最小的，你拿到最小的之后。你拿到最小的之后，先把它放在这个列里边，这个时间戳是不是自己系统添加的。对吧，系统添加的那就有好处诶。你后来的不就更大吗？那你B2。

在这个列里边，就是对于当前in box做的这个内容来说，它的列足是不是CFCF里边是一个音符吧，列是不是B，这个都一样吧，那你B1这个是B2这两个时间中谁的。是不是必要的，那同理，是不是B5最大？对吧，它是B5最大，你刚好直接用这种方式给它铺的进去，最后顺序正好倒过来了，是不是它自己互相去覆盖，把最大的三条最终给我们返回。对吧，这个可以实现业务逻辑，但是呢，有同学可能发现了问题。如果说这个人你关注的这个人发布微博过多的话，你将来就是插入了大量的无用的数据。对吧，你你为了得三条数据来做了一个插入了100条数据的一个操作，这个需求是能完成吧，先把这个逻辑给捋捋一下啊好，那接下来我们想改一下，因为刚才说的它不好，对吧。

他是不是不好对吧，但是他能完成的不好，如果说我想改一下怎么改呢。有同学说负A。负A，不好意思，你放的是最小的三角。你从最后开始数最后。怎么从最后不好意思，这是特殊的迭代，之前就说过了，而且呢，他是慢慢的拿数据了，他最后一次才能拿到最大的。就是说前面可能拿了100条，这100条是最小的100条，第二次又拿100条，这中间100条，最后拿了100条，你要的数据在这个100条里面。有同学想着这个能不能倒着，电力不能。啊，其实有一个方法可以解决，但是涉及到改以前的代码，怎么做呢？是这样的来。

对，有同学能想到这个问题是吗？我发布的时候。发布的时候，这个时候就读过来，如果说它发布的时间越早，我读的过来的时候越晚，是不是是不是这样就用Y就可以了，那怎么能实现这个功能呢。来。时间多少倍？时间是多少倍啊？13位多少倍啊？13位吧，我不管，假如说是13位，OK吧，我在发布微博，这这不是获取当前时间中吗？我在前面定一个全球变量，13倍的九。发布微博，你这个时间桌，我用九减一下这个时间桌，把这个东西作为r key的一个东西拼接进去。那你先发的微博最后就怎么样了？最大了。值是不是最大的，能听懂吗？哎，做一个时间中的翻出来就OK了，相当于能听懂那个逻辑能听懂对吧？啊，但是呢，这样的话，你只要把前面的代码叫全新干什么去改一下，跟大家说一下这种思路，因为我们的目标就在这儿，是不是为了拿三条数据啊，因为拿三条这种循环体验是可以实现需求，但是呢，它有一个问题就在于你每一次把所有的数据都发过来了，那我们就想了这个循环啊，我不要这样，我用负A去循环，但是负A呢。

你起码得用这个东西反转之后才能。是不是才可以有效果啊，你把最大的先出来了，但是按照人家整个h base的一个。比较规则来说，不好意思，人家最小的先出来。对吧，那你这个东西又不能反转，那我们这存的时候就让它是反着存的不就完了吗？对吧？所以第一个全举的什么九九，假如13位9999，然后减去当年的石家庄传进去，你发布的越早，你减的那个值是不是越大？

那将来读出来的顺序是不是在最后面，最小的在最后面嘛，那我们可不可以用负来控制啊。对吧，啊，那就改前面的一个业务逻辑代码了。这个地方我就不改了，就这样，但是就这样的话，里边还有一个问题。啊，这个是比较坑的一个点，就是你会发现有一个人呢，A关注了BB，发布了五条微博，一看时间量表里面只有一条，为什么呢？因为当前这个时间戳。系统传导，大家添加的都一样。时间中完全一样了。他只能读到一条。只能读到一条。能听懂吗？因为这个循环之前跟他说了这个循环，你之前循环十次，还记得循环100次那个毫秒，我们在那个R那做的测试，十秒十十条数据循环的时候都同一毫秒了，对吧，所以说这个东西时间不一样的，那这个时间戳你还不能这样传，你得手动传。

怎么传呢，我们在这儿啊定义。对吧，时间戳啊，就是为了控制一下这个内容啊时间戳。他对吧，得到这个TS。得到这个TS，好，那这个TS。我们给他干什么？CTRLD看一下这个地方是不是有一个加时间戳的这个对吧，在这个地方吗。我TS。能理解这个事这样是不是保证了每一条数据，它的一个时间说都不一样了，对吧，因为都是加加进来的吧，啊加进来了你第一条是时间周为一，第二条就是二，第三条是三嘛，啊做这个事那保证时间周不统一啊，做时间周不统一，有没有人想到这个问题来，我这样不行。我直接我不要这个，我在这里面呢，点有没有是这种想法。

有没有那种想法吧，但不好意思，不对。因为你这个地方睡一毫秒，只是客户端睡了一毫秒。他这个我们当时带着大家看看STEP1STEP2STEP3他认哪给是间说复制的。在服务端。能懂吗？当你把三个列全部添加完成了，都没有时间多传到服务端的时候，他把这个时间中才加进去，那个时候统一加，大家加了又什么又一样了啊，所以呢，如果你想用这个方法，这是最好的，就是在外面第一个时间桌获取当前时间桌，然后把什么。时间中手动的加加的方式给它传进去，能懂意思啊，这样就OK了啊，这样就OK了，那正好它是，而且我们说了它是从小到大放进去的，如果说这个数据编辑出来是从大到小就好了，对吧，我们就可以直接负A是吧？啊限制它的一个三条插三条进去啊是这个意思，所以呢，这里边这个地方是比较坑的一个地方。

啊，有同学今天测试的时候又漏了这一步，漏了这一步之后发现呢，数据只能查到一条，诶我明明B发了五条微博，最后传一条，因为你这五条微博C都塞进去了，但是呢，时间说大家一样了。对吧，啊，时间戳大家都一样了啊，只能给你返回一条这意思好，那接下来这个是不是所有的值都付完了。付完之后这个地方应该怎么写，叫in库的点is Emily，对吧，然后我们的逻辑是非空是不是进来啊，对吧，啊飞空进来好，那这个地方呢，应该是connection.get table。Table name.value off这个地方呢，获取的是收件箱表，对吧，叫in box table，然后叫叫in box。Table啊，然后插入数据。In box table点。Put把in box put给它连进去了，最后呢，在这里边把in box table进行一个关闭，对吧？啊进行一个关闭，关闭之后呢，其他的资源要关闭，是不是有一个关系表，还有一个什么内容表啊。

还有一个连接对吧，啊连啊连接也给它关闭掉啊，这样就OK了啊整个这个内容。啊，整个那个内容，因为这块这个逻辑要涉及到回去改之前逻辑，大家自己在写代法的时候，可以尝试一下我们的内容。说吧啊直接呢，给他做一个反转啊，做个反转就自己还没敲的时候对吧。这个是第二部分的一个代码的。