in src/main/java/org/elasticsearch/aliyun/oss/blobstore/OssBlobContainer.java [81:93]
public void writeBlob(String blobName, InputStream inputStream, long blobSize, boolean failIfAlreadyExists)
throws IOException {
if (blobExists(blobName)) {
if (failIfAlreadyExists) {
throw new FileAlreadyExistsException(
"blob [" + blobName + "] already exists, cannot overwrite");
} else {
deleteBlobIgnoringIfNotExists(blobName);
}
}
logger.trace("writeBlob({}, stream, {})", blobName, blobSize);
blobStore.writeBlob(buildKey(blobName), inputStream, blobSize);
}