THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Follow the Beam approach and use the binary representation of the key to perform sorting/grouping. This comes with additional requirements. For example, the binary representation of key types has to be deterministic/stable. PREFERRED OPTION
- Support only keys that we can create a TypeComparator for. (For GenericTypeInfo they must implement Comparable) in batch style execution (fail hard if that's not the case)
...
3. Built-in sorting into org.apache.flink.streaming.runtime.io.PushingAsyncDataInput.DataOutput PREFERRED OPTION
Pros:
- involves the least virtual calls
- no topology changes
...