Package org.apache.flink.runtime.io.network

Examples of org.apache.flink.runtime.io.network.Buffer


            return null;
          }
        }

        if (!isAsyncRequest) {
          return new Buffer(this.buffers.poll(), minBufferSize, this.recycler);
        }
      }
    }
  }
View Full Code Here


        if (this.numRequestedBuffers > this.numDesignatedBuffers) {
          this.globalBufferPool.returnBuffer(buffer);
          this.numRequestedBuffers--;

        } else if (!this.listeners.isEmpty()) {
          Buffer availableBuffer = new Buffer(buffer, buffer.size(), this.recycler);
          try {
            this.listeners.poll().bufferAvailable(availableBuffer);
          } catch (Exception e) {
            this.buffers.add(buffer);
            this.buffers.notify();
View Full Code Here

TOP

Related Classes of org.apache.flink.runtime.io.network.Buffer

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.