[BEAM-158] add support for bounded sources in streaming - #104

Closed

mxm wants to merge 4 commits into

apache:masterfrom

Commits on Mar 31, 2016

[flink] improve InputFormat wrapper and ReadSourceITCase
mxm
committed
f26674e
[flink] improvements to UnboundedSource translation
mxm
committed
03404c7
[BEAM-158] add support for bounded sources in streaming
mxm
committed
de57413

Commits on Apr 6, 2016

address pull requests comments
mxm
committed
f83c149