Versions Compared

Old Version 27

changes.mady.by.user Xuannan Su

Saved on

compared with

New Version 28

changes.mady.by.user Xuannan Su

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

1) Update OperatorChain to take advantage of the isObjectReuseCompliant isOutputStreamRecordValueStored and isInputStreamRecordStored attribute.

Currently, the OperatorChain only considers the global execution configuration pipeline.object-reuse to determine whether to enable object-reuse for data transfer between chained operators.

...

Migration plan: users are recommended to update their existing operator/function implementation to override the i sObjectReuseCompliantisOutputStreamRecordValueStored() API if their operator/function does not store and access reference to the records StreamRecord#value that it has already emitted. And override the isInputStreamRecordStored() API if their operator does not store and access the input StreamRecord instance. We plan to write blogs to promote the new API.

...