Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
LocalInputChannel#getNextBuffer de-serialises all incoming events on the lookout for an EndOfPartitionEvent.
Some buffer code de-serialises all incoming events on the lookout for an EndOfPartitionEvent
(now applies to PartitionRequestQueue#isEndOfPartitionEvent()).
Instead, if EventSerializer offered a function to check for an event type only without de-serialising the whole event, we could save some resources.
Attachments
Issue Links
- links to