Uses of Class
com.broadleafcommerce.datafeed.service.collector.support.DataFeedCollectionRequest

Packages that use DataFeedCollectionRequest

Package	Description
com.broadleafcommerce.datafeed.service.collector
com.broadleafcommerce.datafeed.service.collector.product
com.broadleafcommerce.datafeed.service.manager

Uses of DataFeedCollectionRequest in com.broadleafcommerce.datafeed.service.collector

Methods in com.broadleafcommerce.datafeed.service.collector with parameters of type DataFeedCollectionRequest

Modifier and Type	Method	Description
protected com.broadleafcommerce.data.tracking.core.context.ContextInfo	AbstractJsonArrayDataFeedCollector.buildContextInfo(DataFeedCollectionRequest request, com.broadleafcommerce.data.tracking.core.type.OperationType operationType)
boolean	CollectedEntityContributor.canHandle(@NonNull Class<?> entityType, @NonNull DataFeedCollectionRequest request, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Indicates if this CollectedEntityContributor can handle the given batch of collected entities.
boolean	DataFeedCollector.canHandle(DataFeedCollectionRequest request)	Indicates if this DataFeedCollector can handle this type of DataFeedProcessExecution, presumably because of an entity type or other feed type indicator.
void	CollectedEntityContributor.contribute(@NonNull List<? extends CollectedEntity<?>> entities, @NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> processState, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Hook point to allow the augmentation or decoration of a batch of entities that have been fetched, but that may need additional data from other sources.
protected Path	AbstractJsonArrayDataFeedCollector.createEmptyLocalCollectedDataFile(DataFeedCollectionRequest request)	Create the local output file that will ultimately be populated with collected data.
protected void	AbstractJsonArrayDataFeedCollector.executeContributors(List<E> records, @NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> processState, com.broadleafcommerce.data.tracking.core.context.ContextInfo readContextInfo)
final DataFeedCollectionResponse	AbstractJsonArrayDataFeedCollector.handle(DataFeedCollectionRequest request)
DataFeedCollectionResponse	DataFeedCollector.handle(DataFeedCollectionRequest request)	This method handles collecting and transforming data of a certain type into a JSON file that will be used to transform and publish to syndicates such as Google or Facebook.
protected abstract List<E>	AbstractJsonArrayDataFeedCollector.readDataFeedRecords(@NonNull DataFeedCollectionRequest request, @NonNull List<ID> idBatch, @NonNull Map<String,Object> collectorProcessState, com.broadleafcommerce.data.tracking.core.context.ContextInfo readContextInfo)
protected abstract List<ID>	AbstractJsonArrayDataFeedCollector.readIdBatchForFullFeed(@NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> collectorProcessState, int batchSize, com.broadleafcommerce.data.tracking.core.context.ContextInfo readContextInfo)	Returns a List that provides a batch of IDs, sorted in ascending order.
protected abstract List<ID>	AbstractJsonArrayDataFeedCollector.readIdBatchForPartialFeed(DataFeedCollectionRequest collectionRequest, @NonNull List<IncrementalDataFeedEntityUpdateRecord> updateRecords, @NonNull Map<String,Object> sharedProcessState, com.broadleafcommerce.data.tracking.core.context.ContextInfo readContextInfo)	IncrementalDataFeedEntityUpdateRecord can have multiple types of pointers to an entity (e.g.
protected Stream<IncrementalDataFeedEntityUpdateRecord>	AbstractJsonArrayDataFeedCollector.readIncrementalUpdateRecords(DataFeedCollectionRequest request, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Returns a Stream containing all records referencing which Entities need to be collected for the given dataFeedProcessExecutionId.

Uses of DataFeedCollectionRequest in com.broadleafcommerce.datafeed.service.collector.product

Methods in com.broadleafcommerce.datafeed.service.collector.product with parameters of type DataFeedCollectionRequest

Modifier and Type	Method	Description
protected void	PricingEntityContributor.assignPriceInfosToProducts(@NonNull List<CollectedProduct> products, @NonNull Map<Object,Set<com.broadleafcommerce.pricing.client.domain.PriceableTarget>> targetsMap, @NonNull List<com.broadleafcommerce.pricing.client.domain.PriceInfo> priceInfos, com.broadleafcommerce.pricing.client.domain.context.PriceContext priceContext, @NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> processState, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
boolean	InventoryEntityContributor.canHandle(@NonNull Class<?> entityType, @NonNull DataFeedCollectionRequest request, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
boolean	PricingEntityContributor.canHandle(@NonNull Class<?> entityType, @NonNull DataFeedCollectionRequest request, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
boolean	ProductDataFeedCollector.canHandle(DataFeedCollectionRequest request)
boolean	RatingsReviewsEntityContributor.canHandle(@NonNull Class<?> entityType, @NonNull DataFeedCollectionRequest request, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
protected com.broadleafcommerce.pricing.client.domain.context.PriceContext	PricingEntityContributor.constructPriceContext(@NonNull List<CollectedProduct> products, @NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> processState, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)	Constructs a PriceContext using the Application associated with the DataFeedProcessExecution.getApplicationId().
protected com.broadleafcommerce.pricing.client.domain.context.PriceInfoContext	PricingEntityContributor.constructPriceInfoContext(@NonNull List<CollectedProduct> products, @NonNull Map<Object,Set<com.broadleafcommerce.pricing.client.domain.PriceableTarget>> targetsMap, @NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> processState, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
void	InventoryEntityContributor.contribute(@NonNull List<? extends CollectedEntity<?>> entities, @NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> processState, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
void	PricingEntityContributor.contribute(@NonNull List<? extends CollectedEntity<?>> entities, @NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> processState, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
void	RatingsReviewsEntityContributor.contribute(@NonNull List<? extends CollectedEntity<?>> entities, @NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> processState, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
protected Map<Object,Set<com.broadleafcommerce.pricing.client.domain.PriceableTarget>>	PricingEntityContributor.createTargetsMap(@NonNull List<CollectedProduct> products, @NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> processState, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
protected List<E>	ProductDataFeedCollector.postProcess(@NonNull DataFeedCollectionRequest request, @NonNull List<E> products, com.broadleafcommerce.data.tracking.core.context.ContextInfo readContextInfo)	Hook point to allow implementors to modify the Product list prior to returning to be written to a file.
protected com.broadleafcommerce.data.tracking.core.tenant.domain.Application	PricingEntityContributor.readApplication(@NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> processState, com.broadleafcommerce.data.tracking.core.context.ContextInfo contextInfo)
protected List<E>	ProductDataFeedCollector.readDataFeedRecords(@NonNull DataFeedCollectionRequest request, @NonNull List<String> idBatch, @NonNull Map<String,Object> collectorProcessState, com.broadleafcommerce.data.tracking.core.context.ContextInfo readContextInfo)
protected List<String>	ProductDataFeedCollector.readIdBatchForFullFeed(@NonNull DataFeedCollectionRequest request, @NonNull Map<String,Object> collectorProcessState, int batchSize, com.broadleafcommerce.data.tracking.core.context.ContextInfo readContextInfo)
protected List<String>	ProductDataFeedCollector.readIdBatchForPartialFeed(DataFeedCollectionRequest collectionRequest, @NonNull List<IncrementalDataFeedEntityUpdateRecord> updateRecords, @NonNull Map<String,Object> sharedProcessState, com.broadleafcommerce.data.tracking.core.context.ContextInfo readContextInfo)	Given a list of IncrementalDataFeedEntityUpdateRecords, we need to determine the Product IDs.

Uses of DataFeedCollectionRequest in com.broadleafcommerce.datafeed.service.manager

Methods in com.broadleafcommerce.datafeed.service.manager that return DataFeedCollectionRequest

Modifier and Type	Method	Description
protected DataFeedCollectionRequest	DataFeedProcessExecutionManager.prepareCollectionRequest(DataFeedProcessExecution execution, String tenantId)

Methods in com.broadleafcommerce.datafeed.service.manager with parameters of type DataFeedCollectionRequest

Modifier and Type	Method	Description
protected Optional<DataFeedCollector>	DataFeedProcessExecutionManager.findDataFeedCollector(DataFeedCollectionRequest request)