code: private static BlockInStream createGrpcBlockInStream(FileSystemContext context,
        WorkerNetAddress address, BlockInStreamSource blockSource,
        ReadRequest readRequestPartial, long blockSize, InStreamOptions options) {
      ReadRequest.Builder readRequestBuilder = readRequestPartial.toBuilder();
      long chunkSize = context.getClusterConf().getBytes(
          PropertyKey.USER_NETWORK_READER_CHUNK_SIZE_BYTES);
      readRequestBuilder.setChunkSize(chunkSize);
      DataReader.Factory factory =
          new GrpcDataReader.Factory(context, address, readRequestBuilder.build());
      return new BlockInStream(factory, address, blockSource, readRequestPartial.getBlockId(),
          blockSize);
    }
docs: Creates a {@link BlockInStream} to read from a gRPC data server.
  
  @param context the file system context
  @param address the address of the gRPC data server
  @param blockSource the source location of the block
  @param blockSize the block size
  @param readRequestPartial the partial read request
  @return the {@link BlockInStream} created