org.finra.herd.dao

Interface StorageUnitDao

All Superinterfaces:

BaseJpaDao

All Known Implementing Classes:

StorageUnitDaoImpl

public interface StorageUnitDao
extends BaseJpaDao

Method Summary

Modifier and Type	Method and Description
List<StorageUnitEntity>	getGlacierStorageUnitsToRestore(int maxResult) Retrieves a list of storage units that belong to GLACIER storage and have the origin S3 storage unit in RESTORING state.
StorageUnitEntity	getStorageUnitByBusinessObjectDataAndStorage(BusinessObjectDataEntity businessObjectDataEntity, StorageEntity storageEntity) Gets a storage unit identified by the given business object data entity and storage entity.
StorageUnitEntity	getStorageUnitByBusinessObjectDataAndStorageName(BusinessObjectDataEntity businessObjectDataEntity, String storageName) Gets a storage unit identified by the given business object data entity and storage name.
StorageUnitEntity	getStorageUnitByStorageNameAndDirectoryPath(String storageName, String directoryPath) Returns a first discovered storage unit in the specified storage that overlaps with the directory path.
List<StorageUnitEntity>	getStorageUnitsByPartitionFiltersAndStorages(BusinessObjectFormatKey businessObjectFormatKey, List<List<String>> partitionFilters, Integer businessObjectDataVersion, String businessObjectDataStatus, List<String> storageNames, String storagePlatformType, String excludedStoragePlatformType, boolean selectOnlyAvailableStorageUnits) Retrieves a list of storage unit entities per specified parameters.
List<StorageUnitEntity>	getStorageUnitsByStorageAndBusinessObjectData(StorageEntity storageEntity, List<BusinessObjectDataEntity> businessObjectDataEntities) Retrieves a list of storage units that belong to the specified storage for the specified business object data.
List<StorageUnitEntity>	getStorageUnitsByStoragePlatformAndBusinessObjectData(String storagePlatform, BusinessObjectDataEntity businessObjectDataEntity) Retrieves a list of storage units that belong to storage of the specified storage platform for the specified business object data.

Methods inherited from interface org.finra.herd.dao.BaseJpaDao

delete, detach, findAll, findById, findByNamedProperties, findUniqueByNamedProperties, getCurrentTimestamp, getEntityManager, query, queryByNamedParams, save, saveAndRefresh

Method Detail

getGlacierStorageUnitsToRestore

List<StorageUnitEntity> getGlacierStorageUnitsToRestore(int maxResult)

Retrieves a list of storage units that belong to GLACIER storage and have the origin S3 storage unit in RESTORING state. The returned list is ordered by the "updated on" timestamp of the origin S3 storage units, starting with an S3 storage unit that has the RESTORING status the longest.

Parameters:

maxResult - the maximum number of results to retrieve

Returns:

the list of storage unit entities

getStorageUnitByBusinessObjectDataAndStorage

StorageUnitEntity getStorageUnitByBusinessObjectDataAndStorage(BusinessObjectDataEntity businessObjectDataEntity,
                                                               StorageEntity storageEntity)

Gets a storage unit identified by the given business object data entity and storage entity. Returns null if storage unit entity does not exist.

Parameters:

businessObjectDataEntity - the business object data entity

storageEntity - the storage entity

Returns:

StorageUnitEntity or null

getStorageUnitByBusinessObjectDataAndStorageName

StorageUnitEntity getStorageUnitByBusinessObjectDataAndStorageName(BusinessObjectDataEntity businessObjectDataEntity,
                                                                   String storageName)

Gets a storage unit identified by the given business object data entity and storage name. Returns null if storage does not exist.

Parameters:

businessObjectDataEntity - the business object data entity

storageName - the storage name (case-insensitive)

Returns:

StorageUnitEntity or null

getStorageUnitByStorageNameAndDirectoryPath

StorageUnitEntity getStorageUnitByStorageNameAndDirectoryPath(String storageName,
                                                              String directoryPath)

Returns a first discovered storage unit in the specified storage that overlaps with the directory path.

Parameters:

storageName - the storage name (case-insensitive)

directoryPath - the directory path

Returns:

the first found storage unit in the specified storage that overlaps with the directory path or null if none were found

getStorageUnitsByStorageAndBusinessObjectData

List<StorageUnitEntity> getStorageUnitsByStorageAndBusinessObjectData(StorageEntity storageEntity,
                                                                      List<BusinessObjectDataEntity> businessObjectDataEntities)

Retrieves a list of storage units that belong to the specified storage for the specified business object data.

Parameters:

storageEntity - the storage entity

businessObjectDataEntities - the list of business object data entities

Returns:

the list of storage unit entities

getStorageUnitsByStoragePlatformAndBusinessObjectData

List<StorageUnitEntity> getStorageUnitsByStoragePlatformAndBusinessObjectData(String storagePlatform,
                                                                              BusinessObjectDataEntity businessObjectDataEntity)

Retrieves a list of storage units that belong to storage of the specified storage platform for the specified business object data.

Parameters:

storagePlatform - the storage platform

businessObjectDataEntity - the business object data entity

Returns:

the list of storage unit entities

getStorageUnitsByPartitionFiltersAndStorages

List<StorageUnitEntity> getStorageUnitsByPartitionFiltersAndStorages(BusinessObjectFormatKey businessObjectFormatKey,
                                                                     List<List<String>> partitionFilters,
                                                                     Integer businessObjectDataVersion,
                                                                     String businessObjectDataStatus,
                                                                     List<String> storageNames,
                                                                     String storagePlatformType,
                                                                     String excludedStoragePlatformType,
                                                                     boolean selectOnlyAvailableStorageUnits)

Retrieves a list of storage unit entities per specified parameters.

Parameters:

businessObjectFormatKey - the business object format key (case-insensitive). If a business object format version isn't specified, the latest available format version for each partition value will be used.

partitionFilters - the list of partition filter to be used to select business object data instances. Each partition filter contains a list of primary and sub-partition values in the right order up to the maximum partition levels allowed by business object data registration - with partition values for the relative partitions not to be used for selection passed as nulls.

businessObjectDataVersion - the business object data version. If a business object data version isn't specified, the latest data version based on the specified business object data status is returned.

businessObjectDataStatus - the business object data status. This parameter is ignored when the business object data version is specified. When business object data version and business object data status both are not specified, the latest data version for each set of partition values will be used regardless of the status.

storageNames - the optional list of storage names where the business object data storage units should be looked for (case-insensitive)

storagePlatformType - the optional storage platform type, e.g. S3 for Hive DDL. It is ignored when the list of storages is not empty

excludedStoragePlatformType - the optional storage platform type to be excluded from search. It is ignored when the list of storages is not empty or the storage platform type is specified

selectOnlyAvailableStorageUnits - specifies if only available storage units will be selected or any storage units regardless of their status

Returns:

the list of storage unit entities sorted by partition values and storage names