基于InfoSphere Streams的流數(shù)據(jù)分析及應(yīng)用.pdf

1、當前，一種被稱為流數(shù)據(jù)的新數(shù)據(jù)形態(tài)在越來越多的應(yīng)用領(lǐng)域內(nèi)出現(xiàn)，與傳統(tǒng)的靜態(tài)數(shù)據(jù)不同，流數(shù)據(jù)具有持續(xù)性、海量性、高時效性的特點。若使用傳統(tǒng)數(shù)據(jù)處理方法則會導致處理延遲太高無法滿足實時性的要求，同時嘗試將分布式計算引入流數(shù)據(jù)處理領(lǐng)域也是不可行的，需要尋找一種新的數(shù)據(jù)處理方法來支持流數(shù)據(jù)的處理，這種方法就是流計算。
　　現(xiàn)在對智能交通領(lǐng)域的海量實時流數(shù)據(jù)的處理還主要采用的是傳統(tǒng)數(shù)據(jù)處理方法，這已經(jīng)逐漸無法滿足現(xiàn)實需要。本文提出了一種將流

2、計算和流計算平臺引入智能交通領(lǐng)域的海量實時流數(shù)據(jù)處理的方案，提高處理速度，降低處理延遲，以滿足日漸增長的實時性要求。并深入分析了流計算和InfoSphere Streams平臺的工作原理，在此基礎(chǔ)上設(shè)計并實現(xiàn)了基于InfoSphere Streams的實時路況監(jiān)測系統(tǒng)。
　　為了驗證新方案的優(yōu)勢，在本文的研究工作中，分別使用傳統(tǒng)數(shù)據(jù)處理方法、單條流水線的流計算方法和多流水線的流計算方法實現(xiàn)相同業(yè)務(wù)功能的應(yīng)用，并對三個案例的實際性能