Class DataStoreUtils


  • public class DataStoreUtils
    extends java.lang.Object
    Extension to DataStoreUtils to enable S3 / AzureBlob extensions for cleaning and initialization.
    • Constructor Summary

      Constructors 
      Constructor Description
      DataStoreUtils()  
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void cleanup​(java.io.File storeDir, java.util.Map<java.lang.String,​?> config, java.lang.String bucket)
      Clean directory and if S3 bucket/Azure container is configured delete that.
      static DataStore configureIfCloudDataStore​(java.lang.String className, DataStore ds, java.util.Map<java.lang.String,​?> config, java.lang.String bucket, StatisticsProvider statisticsProvider)  
      static void deleteAzureContainer​(java.util.Map<java.lang.String,​?> config, java.lang.String containerName)  
      static void deleteBucket​(java.lang.String bucket, java.util.Map<java.lang.String,​?> map, java.util.Date date)  
      static boolean isAzureDataStore​(java.lang.String dsName)  
      static boolean isS3DataStore​(java.lang.String dsName)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • DataStoreUtils

        public DataStoreUtils()
    • Method Detail

      • isS3DataStore

        public static boolean isS3DataStore​(java.lang.String dsName)
      • isAzureDataStore

        public static boolean isAzureDataStore​(java.lang.String dsName)
      • configureIfCloudDataStore

        public static DataStore configureIfCloudDataStore​(java.lang.String className,
                                                          DataStore ds,
                                                          java.util.Map<java.lang.String,​?> config,
                                                          java.lang.String bucket,
                                                          StatisticsProvider statisticsProvider)
                                                   throws java.lang.Exception
        Throws:
        java.lang.Exception
      • cleanup

        public static void cleanup​(java.io.File storeDir,
                                   java.util.Map<java.lang.String,​?> config,
                                   java.lang.String bucket)
                            throws java.lang.Exception
        Clean directory and if S3 bucket/Azure container is configured delete that.
        Parameters:
        storeDir - the local directory
        config - the datastore config
        bucket - the S3 bucket name / Azure container name
        Throws:
        java.lang.Exception
      • deleteBucket

        public static void deleteBucket​(java.lang.String bucket,
                                        java.util.Map<java.lang.String,​?> map,
                                        java.util.Date date)
                                 throws java.lang.Exception
        Throws:
        java.lang.Exception
      • deleteAzureContainer

        public static void deleteAzureContainer​(java.util.Map<java.lang.String,​?> config,
                                                java.lang.String containerName)
                                         throws java.lang.Exception
        Throws:
        java.lang.Exception