withNewInputAggBufferOffset
CollectLimitedList
withNewMutableAggBufferOffset
CollectLimitedList
writer
SparkPythonRunner