flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Saliya Ekanayake <esal...@gmail.com>
Subject Reading Binary Data (Matrix) with Flink
Date Wed, 20 Jan 2016 05:45:37 GMT

I am trying to use Flink perform a parallel batch operation on a NxN matrix
represented as a binary file. Each (i,j) element is stored as a Java Short
value. In a typical MapReduce programming with Hadoop, each map task will
read a block of rows of this matrix and perform computation on that block
and emit result to the reducer.

How is this done in Flink? I am new to Flink and couldn't find a binary
reader so far. Any help is greatly appreciated.

Thank you,

Saliya Ekanayake
Ph.D. Candidate | Research Assistant
School of Informatics and Computing | Digital Science Center
Indiana University, Bloomington
Cell 812-391-4914

View raw message