pipeline

Documentation

Index

• func ArraySource(a ...int) <-chan int
• func InMemSort(in <-chan int) <-chan int
• func Init()
• func Merge(in1, in2 <-chan int) <-chan int
• func MergeN(inputs ...<-chan int) <-chan int
• func NetworkSink(addr string, in <-chan int)
• func NetworkSource(addr string) <-chan int
• func RandomSource(count int) <-chan int
• func ReaderSource(reader io.Reader, chunkSize int) <-chan int
• func WirterSink(writer io.Writer, in <-chan int)

Functions

func ArraySource

func ArraySource(a ...int) <-chan int

可变长参数 对于用的人来说，只能拿东西

func InMemSort

func InMemSort(in <-chan int) <-chan int

in 是节点的一个输入，方向是从 channel 进到我们里面来（只进不出） return的 <-chan int 是一个输出，相对于使用它的人来说，只能从它收东西（只出不进) InMemSort只能发东西

func Init

func Init()

func Merge

func Merge(in1, in2 <-chan int) <-chan int

func MergeN

func MergeN(inputs ...<-chan int) <-chan int

func NetworkSink

func NetworkSink(addr string, in <-chan int)

func NetworkSource

func NetworkSource(addr string) <-chan int

func RandomSource

func RandomSource(count int) <-chan int

func ReaderSource

func ReaderSource(reader io.Reader, chunkSize int) <-chan int

chunkSize 不能一直读，要分块

func WirterSink

func WirterSink(writer io.Writer, in <-chan int)