| Modifier and Type | Method and Description |
|---|---|
ItemChangeDTO |
ChangeDetectionService.getChangeForExistingItem(ItemModel item,
java.lang.String streamId)
Detects change for a given existing item and stream.
|
ItemChangeDTO |
ChangeDetectionService.getChangeForRemovedItem(PK pk,
java.lang.String streamId)
Detects potential change for a an not existing item - (change type 'DELETED'), stored under
ItemVersionMarker referencing given item pk.
|
ItemChangeDTO |
ItemChangeDTO.withVersionValue(java.lang.String versionValue) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<ItemChangeDTO> |
ChangeDetectionService.getChangesForRemovedItems(java.lang.String streamId)
Detects changes for all items, which doesn't exist anymore (change type 'DELETED'), stored under
ItemVersionMarker referencing the not existing item pks.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
ChangesCollector.collect(ItemChangeDTO change)
Collects the given change in a specified way.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ChangeDetectionService.consumeChanges(java.util.List<ItemChangeDTO> changes)
Consumes all given changes.
|
| Modifier and Type | Method and Description |
|---|---|
ItemChangeDTO |
DefaultChangeDetectionService.getChangeForExistingItem(ItemModel item,
java.lang.String streamId) |
ItemChangeDTO |
DefaultChangeDetectionService.getChangeForRemovedItem(PK pk,
java.lang.String streamId) |
protected ItemChangeDTO |
DefaultChangeDetectionService.getChangeFromRow(java.util.List<java.lang.Object> row,
java.lang.String streamId) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<ItemChangeDTO> |
InMemoryChangesCollector.getChanges() |
java.util.List<ItemChangeDTO> |
DefaultChangeDetectionService.getChangesForRemovedItems(java.lang.String streamId) |
protected java.util.Map<java.lang.String,java.util.List<java.util.List<ItemChangeDTO>>> |
DefaultChangeDetectionService.getPartitionedBatchChangesByStreamId(java.util.List<ItemChangeDTO> allChanges) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
InMemoryChangesCollector.collect(ItemChangeDTO change) |
boolean |
CsvReportChangesCollector.collect(ItemChangeDTO change) |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultChangeDetectionService.consumeChanges(java.util.List<ItemChangeDTO> allChanges) |
protected int |
DefaultChangeDetectionService.consumeChangesBatch(java.util.List<ItemChangeDTO> changes,
java.lang.String streamId) |
protected java.util.concurrent.Callable<java.lang.Integer> |
DefaultChangeDetectionService.createConsumeBatchCallable(java.lang.String streamId,
java.util.List<ItemChangeDTO> changes,
int maxRetries) |
protected java.util.Map<java.lang.String,java.util.List<java.util.List<ItemChangeDTO>>> |
DefaultChangeDetectionService.getPartitionedBatchChangesByStreamId(java.util.List<ItemChangeDTO> allChanges) |
protected java.util.Map<java.lang.Long,ItemVersionMarkerModel> |
DefaultChangeDetectionService.preloadVersionMarkers(java.util.List<ItemChangeDTO> changes,
java.lang.String streamId) |
protected java.util.List<java.util.concurrent.Callable<java.lang.Integer>> |
DefaultChangeDetectionService.prepareBatchExecutionCallables(java.util.List<ItemChangeDTO> allChanges) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
DefaultC4CAggregatingCollectorIntegrationTest.dump(java.util.List<ItemChangeDTO> items) |
protected C4CAggregatingCollector |
DefaultC4CAggregatingCollectorIntegrationTest.getDeltaCollector(java.util.List<ItemChangeDTO> receivers) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
C4CBatchingCollector.collect(ItemChangeDTO change) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
DefaultC4CAggregatingCollector.collect(ItemChangeDTO itemChangeDTO) |
protected void |
DefaultC4CAggregatingCollector.collectAddressesOf(ItemChangeDTO customer)
Fetches addresses owned by the customer.
|
protected void |
DefaultC4CAggregatingCollector.fetchAllDependenciesOf(ItemChangeDTO itemChangeDTO)
For customer pulls in all dependent addresses.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
ItemTypeGroupingCollectorWithBatching.collect(ItemChangeDTO change) |
boolean |
MediaBatchingCollector.collect(ItemChangeDTO change) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<ItemChangeDTO> |
TaskContext.getChanges() |
| Constructor and Description |
|---|
ExportScriptCreator(java.lang.String impExHeader,
java.lang.String typeCode,
java.util.Collection<ItemChangeDTO> changes) |
Copyright © 2018 SAP SE. All Rights Reserved.