文件名称：dse_accelerometer:dse_accelerometer
文件大小：972KB
文件格式：ZIP
更新时间：2024-06-07 22:08:43
Java
DSE加速度计 该项目当前代表以下数据管道： android->播放-> akka-> kafka->火花流-> cassandra 它由以下模块组成： AccelerometerAndroidApp-基本的Android App收集加速度计数据并将其以JSON格式发送到其余端点。 SensorRestServer-执行以下操作的Play服务器 其余端点接收加速度计数据并解析json 接收到数据后，将其发送到Akka进行异步处理。 Akka目前仅使用Kafka Producer将数据存储在Kafka中 SensorAnalyzer-当前，这只是一个Java Main，用于启动本地Spark上下文。 它执行以下操作 使用Kafka接收器启动Spark Streaming 解析来自Spark Streaming的输入 将输入保存到Cassandra
【文件预览】：
dse_accelerometer-master
----SensorAnalyzer()
--------project()
--------LICENSE.txt(10KB)
--------src()
--------words(2KB)
--------build.sbt(2KB)
--------README.md(4KB)
--------.gitignore(867B)
----ActivityTracker()
--------gradlew(5KB)
--------settings.gradle(15B)
--------gradle()
--------README.md(2KB)
--------gradlew.bat(2KB)
--------gradle.properties(855B)
--------.gitignore(87B)
--------app()
--------build.gradle(436B)
----README.md(851B)
----.gitignore(867B)
----SensorRestServer()
--------conf()
--------project()
--------public()
--------LICENSE(591B)
--------build.sbt(707B)
--------.gitignore(867B)
--------app()
--------README(742B)