Perpustakaan Digital ITB

Pengolahan data stream menjadi sebuah fenomena yang sedang menjadi tren dalam akhir-akhir ini. Telah banyak mesin pengolahan data stream yang beredar di masyarakat. Meskipun demikian, pengembangan aplikasi di atas mesin pengolahan data stream masih lambat dan banyak terjadi penulisan kode ulang dalam mengembangkan aplikasi berbeda. Selain itu, mesin pengolahan data stream yang beredar umumnya dapat melakukan komputasi terdistribusi. Komputasi terdistribusi membutuhkan program dikompilasi sebelum dijalankan pada mesin lain. Akibatnya adalah ketika terjadi kesalahan, seluruh program harus dikompilasi ulang sebelum dijalankan kembali. Berdasarkan permasalahan ini, telah dikembangkan sebuah application framework yang mampu mempermudah pengguna dalam mengembangkan aplikasi pengolahan data stream di atas Apache Flink. Framework ini dapat dikonfigurasi dengan membaca sebuah berkas eksternal saja. Melalui berkas eksternal tersebut, aplikasi yang dibangun di atas application framework dapat melakukan pengolahan data sesuai dengan opsi yang disediakan. Application framework ini dapat melakukan filterisasi pada data, melakukan agregasi pada data dari sumber berbeda, dan membagi-bagi data ke dalam jendela pengolahan. Selain itu, framework juga menyediakan cara bagi pengguna untuk mengembangkan plugin yang dapat digunakan khusus pada kasus pengolahan data stream yang diinginkan. Dengan menggunakan application framework ini, pengguna tidak perlu menulis banyak kode untuk mengembangkan aplikasi pengolahan data. Pengguna juga dapat menghemat jumlah dokumen yang ditulis untuk mengembangkan sebuah aplikasi. Dalam membuat sebuah aplikasi, Pengguna cukup mengganti konfigurasi yang ada di dalam berkas konfigurasi dan membuat plugin pengolahan data saja.