完整过程 1.观察数据，并开发一个初始化schema拿到数据集观察样例数据指定模型2.在janus里定义schema3.import data and 遍历图去确定数据模型的...
发简信
IP属地：内蒙古
完整过程 1.观察数据，并开发一个初始化schema拿到数据集观察样例数据指定模型2.在janus里定义schema3.import data and 遍历图去确定数据模型的...
工业场景的操作：ID特征新出现哪个1，给它分配一个列向量就好了，也就是embedding look-up table的操作，并不存在一个真正的one-hot特征，更不存在从o...
水位线 是数据流中插入的一个标记，用来表示事件时间的进展，它会随着数据一起在任务间传递。 可以实现WatermarkStrategy接口自定义生成水位线 为数据流中的元素分配...
事务 Redis的事务和Mysql等关系型数据库不太愿意，没有ACID特性。 它先以MULTI开始一个事务， 然后将多个命令入队到事务中， 最后由EXEC命令触发事务， 一并...
写在前面 当在10亿数据进行不到30次比较就能查找到目标时，不禁感叹编程之魅力！人类之伟大呀！ —— 学红黑树有感。 终于，在学习了几天的红黑树相关的知识后，我想把我所学所想...
前言 这是一道面试题,主要考察的是linux和网络协议相关基础知识.如何标识一个TCP连接在确定最大连接数之前,先来看看系统如何标识一个tcp连接.系统用一个四元组来唯一标识...
有个疑问，hbase不支持事务吧，写入的时候怎么保证事务的呀？
（基于最新的Kafka version 0.10.2 new consumer API ）想要Spark Streaming精确一次消费Topic？拿去不谢，记得点赞和分享！本文基于Spark2.1.0、Kafka 0.10.2、Scala 2.11.8版本 背景： Kafka做为一款流行的分布式发布订阅消息系统，以高吞吐、低延时、高可靠的特点著...
支持作者，好文不容易，评论+点赞，希望作者能多发好文
（基于最新的Kafka version 0.10.2 new consumer API ）想要Spark Streaming精确一次消费Topic？拿去不谢，记得点赞和分享！本文基于Spark2.1.0、Kafka 0.10.2、Scala 2.11.8版本 背景： Kafka做为一款流行的分布式发布订阅消息系统，以高吞吐、低延时、高可靠的特点著...
本文基于Spark2.1.0、Kafka 0.10.2、Scala 2.11.8版本 背景： Kafka做为一款流行的分布式发布订阅消息系统，以高吞吐、低延时、高可靠的特点著...
我携四月打湘南走过，步履蹒跚，忐忑不安。行走在四月的怀抱中，她给的是一丝温暖，但时而也会感到冰冷，四月的心情是难以琢磨，她愿以这种隐晦的方式来表达自己的情感，有些人懂...
心情，伴随着沉重的呼吸，随着微风四处漂浮，它愿找到一处合宜的位置，落地而消。 浅夏，初雨淅淅沥沥，温柔的敲打在窗框上，唤醒了谁的流年。抬头已是深夜，月亮也生怕淋湿了衣服，躲了...
心情，伴随着沉重的呼吸，随着微风四处漂浮，它愿找到一处合宜的位置，落地而消。 浅夏，初雨淅淅沥沥，温柔的敲打在窗框上，唤醒了谁的流年。抬头已是深夜，月亮也生怕淋湿了衣服，躲了...
你来我往皆天意、阿其所好是人心。 在一条看不见尽头的柏油路，旁边是白杨，正值秋季，叶子是金黄色的，微风一吹便着地几片，也许是几十片。 在这里，原本是他和她相遇的地方，九年前，...
你来我往皆天意、阿其所好是人心。 在一条看不见尽头的柏油路，旁边是白杨，正值秋季，叶子是金黄色的，微风一吹便着地几片，也许是几十片。 在这里，原本是他和她相遇的地方，九年前，...
等到我们白发苍苍的时候，也许我们不能再敲打着键盘，不能用文字交流我们的真情，那时候，回忆起网络里的一段偶然相遇、相识、相知，这一段深情的友谊，你是否还会有一种深深的眷恋......
白驹过隙，时间流逝，悄无声息。回首过往，是后悔、瞻望未来，是迷茫。把握现在，颠扑不破！ 把握现在，是个老生常谈的话题，对于一些人，却总是缺少一些实际的方法来做到。我曾经看过一...
两年后，我还是去了那个地方。别的依旧，熟悉的人、熟悉的场所，不同的只是我的心，比往年来的沉重。 他们还是那一副令人讨厌的嘴脸，似乎都不能询问他们任何问题，在沉寂了几秒之后。终...
