in main.go [367:375]
func createStreamLoad(report *report.Reporter, queues []chan []byte) *loader.StreamLoad {
// create StreamLoadOption && StreamLoad from flags
streamLoadOption := loader.StreamLoadOption{
Compress: compress,
CheckUTF8: checkUTF8,
Timeout: timeout,
}
return loader.NewStreamLoad(url, dbName, tableName, userName, password, headers, queues, &bufferPool, streamLoadOption, report, loadResp)
}