Class DataStoreUtils


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

      • DataStoreUtils

        public DataStoreUtils()
    • Method Detail

      • isS3DataStore

        public static boolean isS3DataStore​(String dsName)
      • isAzureDataStore

        public static boolean isAzureDataStore​(String dsName)
      • cleanup

        public static void cleanup​(File storeDir,
                                   Map<String,​?> config,
                                   String bucket)
                            throws 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:
        Exception