"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "plugins/repository-azure/src/main/java/org/elasticsearch/repositories/azure/AzureRepository.java" between
elasticsearch-6.8.2-src.tar.gz and elasticsearch-6.8.3-src.tar.gz

About: elasticsearch is a Distributed, RESTful, Search Engine built on top of Apache Lucene. Source package (GitHub).

AzureRepository.java  (elasticsearch-6.8.2-src):AzureRepository.java  (elasticsearch-6.8.3-src)
skipping to change at line 28 skipping to change at line 28
*/ */
package org.elasticsearch.repositories.azure; package org.elasticsearch.repositories.azure;
import org.apache.logging.log4j.message.ParameterizedMessage; import org.apache.logging.log4j.message.ParameterizedMessage;
import com.microsoft.azure.storage.LocationMode; import com.microsoft.azure.storage.LocationMode;
import com.microsoft.azure.storage.StorageException; import com.microsoft.azure.storage.StorageException;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.elasticsearch.cluster.metadata.MetaData;
import org.elasticsearch.cluster.metadata.RepositoryMetaData; import org.elasticsearch.cluster.metadata.RepositoryMetaData;
import org.elasticsearch.common.Strings; import org.elasticsearch.common.Strings;
import org.elasticsearch.common.blobstore.BlobPath; import org.elasticsearch.common.blobstore.BlobPath;
import org.elasticsearch.common.blobstore.BlobStore; import org.elasticsearch.common.blobstore.BlobStore;
import org.elasticsearch.common.settings.Setting; import org.elasticsearch.common.settings.Setting;
import org.elasticsearch.common.settings.Setting.Property; import org.elasticsearch.common.settings.Setting.Property;
import org.elasticsearch.common.unit.ByteSizeValue; import org.elasticsearch.common.unit.ByteSizeValue;
import org.elasticsearch.common.xcontent.NamedXContentRegistry; import org.elasticsearch.common.xcontent.NamedXContentRegistry;
import org.elasticsearch.env.Environment; import org.elasticsearch.env.Environment;
import org.elasticsearch.repositories.IndexId;
import org.elasticsearch.repositories.blobstore.BlobStoreRepository; import org.elasticsearch.repositories.blobstore.BlobStoreRepository;
import org.elasticsearch.snapshots.SnapshotCreationException;
import org.elasticsearch.snapshots.SnapshotId;
import java.net.URISyntaxException; import java.net.URISyntaxException;
import java.util.List;
import java.util.Locale; import java.util.Locale;
import java.util.function.Function; import java.util.function.Function;
import static org.elasticsearch.repositories.azure.AzureStorageService.MAX_CHUNK _SIZE; import static org.elasticsearch.repositories.azure.AzureStorageService.MAX_CHUNK _SIZE;
import static org.elasticsearch.repositories.azure.AzureStorageService.MIN_CHUNK _SIZE; import static org.elasticsearch.repositories.azure.AzureStorageService.MIN_CHUNK _SIZE;
/** /**
* Azure file system implementation of the BlobStoreRepository * Azure file system implementation of the BlobStoreRepository
* <p> * <p>
* Azure file system repository supports the following settings: * Azure file system repository supports the following settings:
skipping to change at line 161 skipping to change at line 156
/** /**
* {@inheritDoc} * {@inheritDoc}
*/ */
@Override @Override
protected ByteSizeValue chunkSize() { protected ByteSizeValue chunkSize() {
return chunkSize; return chunkSize;
} }
@Override @Override
public void initializeSnapshot(SnapshotId snapshotId, List<IndexId> indices,
MetaData clusterMetadata) {
try {
final AzureBlobStore blobStore = (AzureBlobStore) blobStore();
if (blobStore.containerExist() == false) {
throw new IllegalArgumentException("The bucket [" + blobStore +
"] does not exist. Please create it before "
+ " creating an azure snapshot repository backed by it."
);
}
} catch (URISyntaxException | StorageException e) {
throw new SnapshotCreationException(metadata.name(), snapshotId, e);
}
super.initializeSnapshot(snapshotId, indices, clusterMetadata);
}
@Override
public boolean isReadOnly() { public boolean isReadOnly() {
return readonly; return readonly;
} }
} }
 End of changes. 5 change blocks. 
22 lines changed or deleted 0 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)