InMemorySink.java 文件源码

@Override
public void addData(CrawleableUri uri, InputStream stream) {
    try {
        addData(uri, StreamUtils.getBytes(stream));
    } catch (IOException e) {
        LOGGER.error("Error while reading data from stream. The data won't be stored.", e);
    }
}