
2.概述
我们接着往高层抽象走,刚刚提到了最底层内存抽象是MemorySegment,用于数据传输的是Buffer,那么,承上启下对接从Java对象转为Buffer的中间对象是什么呢?是
StreamRecord
。
从
StreamRecord
这个类名字就可以看出来,这个类就是个wrap,里面保存了原始的Java对象。另外,StreamRecord还保存了一个timestamp。
那么这个对象是怎么变成LocalBufferPool内存池里的一个大号字节数组的呢?借助了
StreamWriter
这个类。
我们直接来看把数据序列化交出去的方法:
首先是ChannelSelectorRecordWriter一个常规的面向记录的运行时结果编写器。
@Override
public void emit(T