Versions in this module Expand all Collapse all v0 v0.1.3 Mar 3, 2024 v0.1.2 Nov 8, 2023 v0.1.1 Oct 1, 2023 Changes in this version + type DirectUpload struct + func NewDirectUpload(ctx context.Context, task *types.Task) *DirectUpload + func (d *DirectUpload) Finish() + func (d *DirectUpload) Push(records *types.Data2Starrocks) int + func (d *DirectUpload) StreamUpload() (count int, err error)