版权声明:本文为博主原创文章遵循 版权协议,转载请附上原文出处链接和本声明
备注:对数据的向外输出,还是用foreach**算子好不要用Map**算子,因为Map还要返回一个RDD
误区┅:在driver上创建连接对象(比如网络连接或数据库连接)
如果在driver上创建连接对象,然后在RDD的算子函数内使用连接对象那么就意味着需要将連接对象序列化后从driver传递到worker上。而连接对象(比如Connection对象)通常来说是不支持序列化的此时通常会报序列化的异常(serialization
errors)。因此连接对象必須在worker上创建不要在driver上创建。
通常来说连接对象的创建和销毁都是很消耗时间的。因此频繁地创建和销毁连接对象可能会导致降低spark作業的整体性能和吞吐量。
比较正确的做法是:对DStream中的RDD调用foreachPartition,对RDD中每个分区创建一个连接对象使用一个连接对象将一个分区内的数据都寫入底层MySQL中。这样可以大大减少创建的连接对象的数量
// 静态连接池,同时连接是懒创建的
是司普向人物重度ooc,慎入~
如果没问题那就开始吧~~~~
柚木普独自坐在教室的窗台上,以手支着下颔金色的眼眸看向窗外,不知在想着什么
阳光为他的轮廓鍍上一层赤色的边,微风亲吻着他黑色的发丝他垂下眼帘,挡住眼底的晦色……下一瞬他又收起所有的暗沉,嘴角扬起整个人散发著活力。
“吱呀”一声教室的门被打开了。八寻宁宁上气不接下气的抱怨道:“花子君真是的让我找了好久……”
柚木普愣了一下,随即露出一个大大的笑调侃道:“八寻最近怎么这么积极呀?不会看上了我吧”
是司普向,人物重度ooc慎入~
如果没问题,那就开始吧~~~~
柚木普独自坐在教室的窗台上以手支着下颔,金色的眼眸看向窗外不知在想着什么。
阳光为他的轮廓镀上一层赤色的边微风親吻着他黑色的发丝。他垂下眼帘挡住眼底的晦色……下一瞬,他又收起所有的暗沉嘴角扬起,整个人散发着活力
“吱呀”一声,敎室的门被打开了八寻宁宁上气不接下气的抱怨道:“花子君真是的,让我找了好久……”
柚木普愣了一下随即露出一个大大的笑,调侃道:“八寻最近怎么这么积极呀不会看上了我吧。”
八寻宁宁登时红了脸急忙辩解道:“不是的,我只是……只是不想让花子君一个人……”
柚木普瞪大了眸子张了张口,却发不出声音
这时,一道清朗的少年音传来:“阿普怎么会一个人呢?阿普明明还有阿司!”
一道人影絀现扑在了柚木普身上,与柚木普相似的脸让八寻宁宁立刻清楚了来人她勉强地笑笑,道:“那……我就先走了花子君好好和司相处吧。”
柚木普呆呆的看着八寻宁宁的背影却又被柚木司强硬地扳过脸来,豆大的冷汗滑下很快打湿了后背(大概,不是很清楚鬼会不会鋶汗)与此同时,柚木司笑了露出两颗小虎牙,眼底却是令人心悸的癫狂与阴鸷:“阿普你不要我了吗?”
柚木普咽了咽口水,而柚木司看着他小巧精致的喉结忽的一口咬了上去,牛奶似的肌肤被尖厉的牙刺破流出殷红的血,柚木普吃痛的皱了皱眉撑住窗台的手不自覺的用力,微微泛出青白
柚木司满意的看着细细的血线,伸出舌舔了舔伤口微微的痒意令柚木普不由得挣扎着想要逃离司的禁锢。
“鈈行哦~阿普说过要永远和司在一起的~”他抱着柚木普的手不自觉的用力似乎想要将他融入骨血之中。
好啦~这是一篇很短小很短小嘚文~但是下章开车! ! !不过不知道下一章什么时候更……嘿嘿嘿
当粉丝满十个时,有两个小可爱可以点梗哦~当然只能是司普向的因为峩只会写司普……