# Functions
No description provided by the author
NewDataForward creates a sink data forwarder.
WithCallbackUploader sets the callback uploader for the vertex.
WithFbSinkWriter sets the fallback sink writer.
WithLogger is used to return logger information.
WithReadBatchSize sets the read batch size.
WithSinkConcurrency sets concurrency for processing.
# Structs
DataForward forwards the data from previous vertex to sinker.
Shutdown tracks and enforces the shutdown activity.
# Type aliases
No description provided by the author