Method EndDataStream

be/src/runtime/data-stream-test.cc:143–146

  }

  virtual void EndDataStream(const EndDataStreamRequestPB* request,
      EndDataStreamResponsePB* response, RpcContext* rpc_context) {
    stream_mgr_->CloseSender(request, response, rpc_context);
  }

  virtual void UpdateFilter(
      const UpdateFilterParamsPB* req, UpdateFilterResultPB* resp, RpcContext* context) {}