Xuzhengz commented on issue #8004: URL: https://github.com/apache/seatunnel/issues/8004#issuecomment-2467067839
> I am not get your question. The lifecycle is source -> transform -> sink > > Only source can generate data, transform only receive the data from source. > > > How does Transform know if the source has been executed? > > When transfrom recived data, it means sourcce has been executed. My requirement is to customize a tansform component for grouping aggregation. Aggregate operations will be carried out after each row of data comes in, and the aggregate results will be output to sink after the source is completed -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
