code: @SuppressWarnings({ "rawtypes", "unchecked" })
  	public void collectBuffer(Collector<OUT> c, int bufferSize) throws IOException {
  		fileBuffer.position(0);
  
  		while (fileBuffer.position() < bufferSize) {
  			c.collect(deserializer.deserialize());
  		}
  	}
docs: Reads a buffer of the given size from the memory-mapped file, and collects all records contained. This method
  assumes that all values in the buffer are of the same type. This method does NOT take care of synchronization.
  The user must guarantee that the buffer was completely written before calling this method.
  
  @param c Collector to collect records
  @param bufferSize size of the buffer
  @throws IOException