FileBasedSink.java 文件源码

@Override
public void addData(CrawleableUri uri, InputStream stream) {
    OutputStream outputStream = getStream(uri);
    if (outputStream != null) {
        try {
            StreamUtils.copy(stream, outputStream);
        } catch (Exception e) {
            LOGGER.error("Exception while writing unstructed data to file.", e);
        }
    }
}