[GitHub] [flink] NicoK commented on pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

Thu, 13 Sep 2018 07:57:47 -0700 

I meant using
```
final RecordWriter<SerializationTestType> writer = isBroadcastEmit ?
                        new RecordWriter<>(partitionWriter) :
                        new RecordWriter<>(partitionWriter, new Broadcast<>());
```
This would also check that `broadcastEmit()` does not rely on a broadcasting 
channel selector.

[ Full content available at: https://github.com/apache/flink/pull/6417 ]
This message was relayed via gitbox.apache.org for [email protected]

Reply via email to