| Package | Description |
|---|---|
| org.finra.herd.dao | |
| org.finra.herd.dao.impl | |
| org.finra.herd.model.jpa | |
| org.finra.herd.service.helper |
| Modifier and Type | Method and Description |
|---|---|
StorageEntity |
StorageDao.getStorageByName(String storageName)
Gets a storage by it's name.
|
| Modifier and Type | Method and Description |
|---|---|
StorageUnitEntity |
StorageUnitDao.getStorageUnitByBusinessObjectDataAndStorage(BusinessObjectDataEntity businessObjectDataEntity,
StorageEntity storageEntity)
Gets a storage unit identified by the given business object data entity and storage entity.
|
List<StorageUnitEntity> |
StorageUnitDao.getStorageUnitsByStorageAndBusinessObjectData(StorageEntity storageEntity,
List<BusinessObjectDataEntity> businessObjectDataEntities)
Retrieves a list of storage units that belong to the specified storage for the specified business object data.
|
| Modifier and Type | Method and Description |
|---|---|
StorageEntity |
StorageDaoImpl.getStorageByName(String storageName) |
| Modifier and Type | Method and Description |
|---|---|
StorageUnitEntity |
StorageUnitDaoImpl.getStorageUnitByBusinessObjectDataAndStorage(BusinessObjectDataEntity businessObjectDataEntity,
StorageEntity storageEntity) |
List<StorageUnitEntity> |
StorageUnitDaoImpl.getStorageUnitsByStorageAndBusinessObjectData(StorageEntity storageEntity,
List<BusinessObjectDataEntity> businessObjectDataEntities) |
| Modifier and Type | Method and Description |
|---|---|
protected javax.persistence.criteria.Predicate |
AbstractHerdDao.getQueryRestrictionOnStorage(javax.persistence.criteria.CriteriaBuilder builder,
javax.persistence.criteria.From<?,StorageEntity> storageEntity,
javax.persistence.criteria.From<?,StoragePlatformEntity> storagePlatformEntity,
List<String> storageNames,
String storagePlatformType,
String excludedStoragePlatformType)
Builds a query restriction predicate for the storage.
|
| Modifier and Type | Field and Description |
|---|---|
static javax.persistence.metamodel.CollectionAttribute<StorageEntity,StorageAttributeEntity> |
StorageEntity_.attributes |
static javax.persistence.metamodel.SingularAttribute<StoragePolicyEntity,StorageEntity> |
StoragePolicyEntity_.destinationStorage |
static javax.persistence.metamodel.SingularAttribute<StorageEntity,String> |
StorageEntity_.name |
static javax.persistence.metamodel.SingularAttribute<BusinessObjectDefinitionSampleDataFileEntity,StorageEntity> |
BusinessObjectDefinitionSampleDataFileEntity_.storage |
static javax.persistence.metamodel.SingularAttribute<StorageAttributeEntity,StorageEntity> |
StorageAttributeEntity_.storage |
static javax.persistence.metamodel.SingularAttribute<BusinessObjectDataNotificationRegistrationEntity,StorageEntity> |
BusinessObjectDataNotificationRegistrationEntity_.storage |
static javax.persistence.metamodel.SingularAttribute<StoragePolicyEntity,StorageEntity> |
StoragePolicyEntity_.storage |
static javax.persistence.metamodel.SingularAttribute<StorageUnitNotificationRegistrationEntity,StorageEntity> |
StorageUnitNotificationRegistrationEntity_.storage |
static javax.persistence.metamodel.SingularAttribute<StorageUnitEntity,StorageEntity> |
StorageUnitEntity_.storage |
static javax.persistence.metamodel.SingularAttribute<StorageEntity,StoragePlatformEntity> |
StorageEntity_.storagePlatform |
| Modifier and Type | Method and Description |
|---|---|
StorageEntity |
StoragePolicyEntity.getDestinationStorage() |
StorageEntity |
BusinessObjectDataNotificationRegistrationEntity.getStorage() |
StorageEntity |
BusinessObjectDefinitionSampleDataFileEntity.getStorage() |
StorageEntity |
StorageAttributeEntity.getStorage() |
StorageEntity |
StoragePolicyEntity.getStorage() |
StorageEntity |
StorageUnitEntity.getStorage() |
StorageEntity |
StorageUnitNotificationRegistrationEntity.getStorage() |
| Modifier and Type | Method and Description |
|---|---|
void |
StoragePolicyEntity.setDestinationStorage(StorageEntity destinationStorage) |
void |
BusinessObjectDataNotificationRegistrationEntity.setStorage(StorageEntity storage) |
void |
BusinessObjectDefinitionSampleDataFileEntity.setStorage(StorageEntity storage) |
void |
StorageAttributeEntity.setStorage(StorageEntity storage) |
void |
StoragePolicyEntity.setStorage(StorageEntity storage) |
void |
StorageUnitEntity.setStorage(StorageEntity storage) |
void |
StorageUnitNotificationRegistrationEntity.setStorage(StorageEntity storage) |
| Modifier and Type | Method and Description |
|---|---|
StorageEntity |
StorageDaoHelper.getStorageEntity(StorageAlternateKeyDto storageAlternateKey)
Gets a storage entity based on the alternate key and makes sure that it exists.
|
StorageEntity |
StorageDaoHelper.getStorageEntity(String storageName)
Gets a storage entity based on the storage name and makes sure that it exists.
|
| Modifier and Type | Method and Description |
|---|---|
String |
S3KeyPrefixHelper.buildS3KeyPrefix(StorageEntity storageEntity,
BusinessObjectDefinitionKey businessObjectDefinitionKey)
Build S3 key prefix for business object definition key
|
String |
S3KeyPrefixHelper.buildS3KeyPrefix(StorageEntity storageEntity,
BusinessObjectFormatEntity businessObjectFormatEntity,
BusinessObjectDataKey businessObjectDataKey)
Returns the S3 object key prefix based on the given storage, business object format and business object data key.
|
BusinessObjectDataCreateRequest |
BusinessObjectDataHelper.createBusinessObjectDataCreateRequest(BusinessObjectFormatEntity businessObjectFormatEntity,
String uuid,
String businessObjectDataStatus,
List<Attribute> attributes,
StorageEntity storageEntity,
String storageDirectoryPath,
String storageFilePath,
Long storageFileSizeBytes,
Long storageFileRowCount)
Validates the upload single initiation request.
|
boolean |
StorageHelper.getBooleanStorageAttributeValueByName(String attributeName,
StorageEntity storageEntity,
boolean attributeRequired,
boolean attributeValueRequiredIfExists)
Gets attribute value by name from the storage entity and returns it as a boolean.
|
S3FileTransferRequestParamsDto |
StorageHelper.getS3BucketAccessParams(StorageEntity storageEntity)
Returns a new instance of S3FileTransferRequestParamsDto populated with all parameters, required to access an S3 bucket.
|
Integer |
StorageHelper.getStorageAttributeIntegerValueByName(String attributeName,
StorageEntity storageEntity,
boolean attributeRequired,
boolean attributeValueRequiredIfExists)
Gets a storage attribute value by name.
|
Integer |
StorageHelper.getStorageAttributeIntegerValueByName(String attributeName,
StorageEntity storageEntity,
Integer defaultValue)
Gets a storage attribute value by name.
|
String |
StorageHelper.getStorageAttributeValueByName(String attributeName,
StorageEntity storageEntity,
boolean attributeValueRequired)
Gets attribute value by name from the storage entity while specifying whether the attribute value is required (i.e.
|
String |
StorageHelper.getStorageAttributeValueByName(String attributeName,
StorageEntity storageEntity,
boolean attributeRequired,
boolean attributeValueRequiredIfExists)
Gets attribute value by name from the storage entity while specifying whether the attribute is required and whether the attribute value is required.
|
String |
StorageHelper.getStorageBucketName(StorageEntity storageEntity)
Gets the storage's bucket name.
|
String |
StorageHelper.getStorageKmsKeyId(StorageEntity storageEntity)
Gets the storage's KMS key ID.
|
void |
StoragePolicyDaoHelper.validateDestinationStorage(StorageEntity storageEntity)
Validates the destination storage.
|
void |
StoragePolicyDaoHelper.validateSourceStorage(StorageEntity storageEntity)
Validates the source storage.
|
| Modifier and Type | Method and Description |
|---|---|
protected List<StorageUnitEntity> |
Hive13DdlGenerator.excludeDuplicateBusinessObjectData(List<StorageUnitEntity> storageUnitEntities,
List<String> storageNames,
List<StorageEntity> storageEntities)
Eliminate storage units that belong to the same business object data by picking storage unit registered in a storage listed earlier in the list of
storage names specified in the request.
|
abstract String |
DdlGenerator.generateCreateTableDdl(BusinessObjectDataDdlRequest request,
BusinessObjectFormatEntity businessObjectFormatEntity,
CustomDdlEntity customDdlEntity,
List<String> storageNames,
List<StorageEntity> storageEntities,
Map<StorageEntity,String> s3BucketNames)
This method generates the create table DDL as per specified business object data DDL request.
|
abstract String |
DdlGenerator.generateCreateTableDdl(BusinessObjectDataDdlRequest request,
BusinessObjectFormatEntity businessObjectFormatEntity,
CustomDdlEntity customDdlEntity,
List<String> storageNames,
List<StorageEntity> storageEntities,
Map<StorageEntity,String> s3BucketNames)
This method generates the create table DDL as per specified business object data DDL request.
|
String |
Hive13DdlGenerator.generateCreateTableDdl(BusinessObjectDataDdlRequest request,
BusinessObjectFormatEntity businessObjectFormatEntity,
CustomDdlEntity customDdlEntity,
List<String> storageNames,
List<StorageEntity> storageEntities,
Map<StorageEntity,String> s3BucketNames)
Generates the create table Hive 13 DDL as per specified business object data DDL request.
|
String |
Hive13DdlGenerator.generateCreateTableDdl(BusinessObjectDataDdlRequest request,
BusinessObjectFormatEntity businessObjectFormatEntity,
CustomDdlEntity customDdlEntity,
List<String> storageNames,
List<StorageEntity> storageEntities,
Map<StorageEntity,String> s3BucketNames)
Generates the create table Hive 13 DDL as per specified business object data DDL request.
|
Copyright © 2017. All rights reserved.