Examples of FragmentRecordBatch

Examples of org.apache.drill.exec.proto.BitData.FragmentRecordBatch

100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
  @Override
  protected void handle(BitServerConnection connection, int rpcType, ByteBuf pBody, ByteBuf body, ResponseSender sender) throws RpcException {
    assert rpcType == RpcType.REQ_RECORD_BATCH_VALUE;

    FragmentRecordBatch fragmentBatch = get(pBody, FragmentRecordBatch.PARSER);
    FragmentHandle handle = fragmentBatch.getHandle();

    try {
      FragmentManager manager = workBus.getOrCreateFragmentManager(fragmentBatch.getHandle());
      if (manager == null) {
        if (body != null) {
          body.release();
        }
      }
View Full Code Here

Examples of org.apache.drill.exec.proto.BitData.FragmentRecordBatch

58
59
60
61
62
63
64
65
66
67
68
69
      throw new RuntimeException("Attempted to enqueue batch after finished");
    }
    if (batch.getHeader().getIsOutOfMemory()) {
      logger.debug("Setting autoread false");
      RawFragmentBatch firstBatch = buffer.peekFirst();
      FragmentRecordBatch header = firstBatch == null ? null :firstBatch.getHeader();
      if (!outOfMemory.get() && !(header == null) && header.getIsOutOfMemory()) {
        buffer.addFirst(batch);
      }
      outOfMemory.set(true);
      return;
    }
View Full Code Here

Examples of org.apache.drill.exec.proto.BitData.FragmentRecordBatch

102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
  @Override
  protected void handle(BitServerConnection connection, int rpcType, ByteBuf pBody, ByteBuf body, ResponseSender sender) throws RpcException {
    assert rpcType == RpcType.REQ_RECORD_BATCH_VALUE;

    FragmentRecordBatch fragmentBatch = get(pBody, FragmentRecordBatch.PARSER);
    FragmentHandle handle = fragmentBatch.getHandle();

    try {
      FragmentManager manager = workBus.getFragmentManager(fragmentBatch.getHandle());
      if (manager == null) {
        if (body != null) {
          body.release();
        }
      }
View Full Code Here

Examples of org.apache.drill.exec.proto.BitData.FragmentRecordBatch

100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
  @Override
  protected void handle(BitServerConnection connection, int rpcType, ByteBuf pBody, ByteBuf body, ResponseSender sender) throws RpcException {
    assert rpcType == RpcType.REQ_RECORD_BATCH_VALUE;

    FragmentRecordBatch fragmentBatch = get(pBody, FragmentRecordBatch.PARSER);
    FragmentHandle handle = fragmentBatch.getHandle();

    try {
      FragmentManager manager = workBus.getOrCreateFragmentManager(fragmentBatch.getHandle());
      if (manager == null) {
        if (body != null) {
          body.release();
        }
      }
View Full Code Here

Examples of org.apache.drill.exec.proto.BitData.FragmentRecordBatch

59
60
61
62
63
64
65
66
67
68
69
70
      throw new RuntimeException("Attempted to enqueue batch after finished");
    }
    if (batch.getHeader().getIsOutOfMemory()) {
      logger.debug("Setting autoread false");
      RawFragmentBatch firstBatch = buffer.peekFirst();
      FragmentRecordBatch header = firstBatch == null ? null :firstBatch.getHeader();
      if (!outOfMemory.get() && !(header == null) && header.getIsOutOfMemory()) {
        buffer.addFirst(batch);
      }
      outOfMemory.set(true);
      return;
    }
View Full Code Here

Examples of org.apache.drill.exec.proto.ExecProtos.FragmentRecordBatch

88
89
90
91
92
93
94
95
96
97
98
      startNewRemoteFragment(fragment);
      return BitRpcConfig.OK;
     
    case RpcType.REQ_RECORD_BATCH_VALUE:
      try {
        FragmentRecordBatch header = get(pBody, FragmentRecordBatch.PARSER);
        incomingRecordBatch(connection, header, dBody);
        return BitRpcConfig.OK;
      } catch (FragmentSetupException e) {
        throw new RpcException("Failure receiving record batch.", e);
      }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.