take

    Take的操作主要用于取出前n条数据的操作, 这个操作中首先从第一个partition中去找,如果第一个partition中无法取出前n条数据时,再接下来从后面的partition中接着去找.直到取到n条数据或者说partition中都已经找完.

    1,如果take的操作是0,那么直接返回,job都不启动.这里面好像没有对值是负数的判断.

    1. if (num == 0) {
    2. new Array[T](0)
    3. }

    2,如果take的操作要返回的值是不一个不是0的值,这个地方准确的说是一个大于0的值.
    先生成一个用于存储结果的buffer

    1. val buf = new ArrayBuffer[T]

    [

    ](https://blog.csdn.net/u014393917/article/details/50606949)