Hi, AFAIK this will Force runners to use Streaming execution Mode even though they would not have to.
Aljoscha On Thu, Aug 11, 2016, 21:55 amir bahmanyari <[email protected]> wrote: > Hi Colleagues, > Is *bounded *KafkaIO().withMaxNumRecords(finite-number) essentially the > same as TextIO().read_from_a_finite_records data file? > In neither case we are Streaming, right? No on-going streaming data mode > in both since "reading" will halt at some point by design: *bounded*. > What difference is setting options.setStreaming(*true*); to true making > here? > Thanks >
