Package io.jmix.search.index.queue.impl

Class OrderBasedEntityIdsLoader

java.lang.Object

io.jmix.search.index.queue.impl.OrderBasedEntityIdsLoader

All Implemented Interfaces:

EntityIdsLoader

Direct Known Subclasses:

CommonJpaEntityIdsLoader, OracleEntityIdsLoader

public abstract class OrderBasedEntityIdsLoader
extends Object
implements EntityIdsLoader

Loads data using ordering property.

Nested Class Summary

Nested classes/interfaces inherited from interface io.jmix.search.index.queue.EntityIdsLoader

EntityIdsLoader.ResultHolder

Field Summary

Fields

Modifier and Type	Field	Description
protected DataManager	dataManager
protected Metadata	metadata
protected MetadataTools	metadataTools
protected StoreAwareLocator	storeAwareLocator

Constructor Summary

Constructors

Constructor	Description
OrderBasedEntityIdsLoader()

Method Summary

Modifier and Type	Method	Description
protected Object	convertRawValue(MetaProperty orderingProperty, String rawValue)
protected ValueLoadContext	createValueLoadContext(MetaClass entityClass, String pkProperty, String orderingProperty, Object orderingValue, int batchSize)
protected EntityIdsLoader.ResultHolder	loadAllInMemory(MetaClass entityClass)
EntityIdsLoader.ResultHolder	loadNextIds(EnqueueingSession session, int batchSize)	Loads next batch of instances related to provided session.
protected abstract List<KeyValueEntity>	loadValues(ValueLoadContext valueLoadContext)
protected Object	resolveLastLoadedOrderingValue(List<KeyValueEntity> loadedValues, String primaryKeyProperty, String orderingProperty)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

dataManager

@Autowired
protected DataManager dataManager

metadata

@Autowired
protected Metadata metadata

metadataTools

@Autowired
protected MetadataTools metadataTools

storeAwareLocator

@Autowired
protected StoreAwareLocator storeAwareLocator

Constructor Details

OrderBasedEntityIdsLoader

public OrderBasedEntityIdsLoader()

Method Details

loadNextIds

public EntityIdsLoader.ResultHolder loadNextIds(EnqueueingSession session,
 int batchSize)

Description copied from interface: EntityIdsLoader

Loads next batch of instances related to provided session.

Specified by:

loadNextIds in interface EntityIdsLoader

Parameters:

session - enqueueing session

batchSize - batch size

Returns:

loading result

loadValues

protected abstract List<KeyValueEntity> loadValues(ValueLoadContext valueLoadContext)

createValueLoadContext

protected ValueLoadContext createValueLoadContext(MetaClass entityClass,
 String pkProperty,
 String orderingProperty,
 @Nullable
 Object orderingValue,
 int batchSize)

resolveLastLoadedOrderingValue

@Nullable
protected Object resolveLastLoadedOrderingValue(List<KeyValueEntity> loadedValues,
 String primaryKeyProperty,
 String orderingProperty)

loadAllInMemory

protected EntityIdsLoader.ResultHolder loadAllInMemory(MetaClass entityClass)

convertRawValue

@Nullable
protected Object convertRawValue(MetaProperty orderingProperty,
 @Nullable
 String rawValue)