Uber永世定位体系及时数据说明进程实践！

Spark KMeansModel类用于加载k-means模子，该模子安装在汗青uber行程数据上，然后生涯到MapR-XD集群。接下来，建设集群中心ID和位置数据集，以便稍后与Uber观光位置毗连。

集群中心下方表现在Zeppelin notebook中的Google舆图上：

从Kafka的topic中读取数据

为了从Kafka读取，我们必需起首指定流名目，topic和偏移选项。有关设置参数的具体信息，请参阅MapR Streams文档。

这将返回具有以下架构的DataFrame：

下一步是将二进制值列理会并转换为Uber工具的数据集。

将动静值理会为Uber工具的数据集

Scala Uber案例类界说与CSV记录对应的架构，parseUber函数将逗号脱离值字符串理会为Uber工具。

（编辑：湖南网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!