关键词: 车联网, 流式系统, 不活跃对象, 生命周期管理, 数据驱动模型

Abstract: In the practice of Internet of vehicles, people run several computing applications in streaming systems to   analyze GPS/OBD data collected from vehicles. These applications have some common requirements and features, which are long-cycle running, low processing delay, and the need for keeping states in memory. However, after a long time running, such kind of streaming job needs to keep a lot of computation parameters, status and other data in memory, and large numbers of data objects are not active among them. If let them occupy memory, it will cause a great waste of system resource. This paper proposes a data object managing method for stream tasks, and hopes to optimize the memory use of streaming system to solve the according problem. This paper establishes lifecycle model for streaming data object (SDO), and uses application-driven, data-driven method to achieve appropriate expire-parameters for SDO. Finally, this paper tests the proposed method in applications of Internet of vehicles. Experiments show that the proposed method can effectively reduce inactive SDO number and improve resource utilization while ensuring the processing delay can be accepted by users.

Key words: Internet of vehicles, streaming system, inactive object, lifecycle management, data-driven model