Package com.evolveum.midpoint.repo.sqale.mapping

Interface PartitionManager<M>

All Known Implementing Classes:

ShadowPartitionManager

public interface PartitionManager<M>

Method Summary

Modifier and Type	Method	Description
void	createMissingPartitions(OperationResult parentResult)	Analyze existing records,creates partitions for them and migrates them from default partitions to specific partition.
void	ensurePartitionExists(M row, JdbcSession jdbcSession)	Ensures that partition for particular row exists (creates partition if it missing)
static <R> void	ensurePartitionExistsBeforeAdd(SqaleTableMapping<?,?,R> table, R row, JdbcSession jdbcSession)
default void	ensurePartitionExistsBeforeAdd(M row, JdbcSession jdbcSession)	If partitioning before add is enabled ensures that partition for particular row exists (creates partition if it missing)
boolean	isPartitionCreationOnAdd()
void	setPartitionCreationOnAdd(boolean value)

Method Details

isPartitionCreationOnAdd

boolean isPartitionCreationOnAdd()

setPartitionCreationOnAdd

void setPartitionCreationOnAdd(boolean value)

ensurePartitionExistsBeforeAdd

default void ensurePartitionExistsBeforeAdd(M row,
 JdbcSession jdbcSession)

If partitioning before add is enabled ensures that partition for particular row exists (creates partition if it missing)

Parameters:

row - row object, which must at least contain all partitioning keys

jdbcSession -

ensurePartitionExists

void ensurePartitionExists(M row,
 JdbcSession jdbcSession)

Ensures that partition for particular row exists (creates partition if it missing)

Parameters:

row - row object, which must at least contain all partitioning keys

jdbcSession -

createMissingPartitions

void createMissingPartitions(OperationResult parentResult)

Analyze existing records,creates partitions for them and migrates them from default partitions to specific partition.

Parameters:

parentResult -

ensurePartitionExistsBeforeAdd

static <R> void ensurePartitionExistsBeforeAdd(SqaleTableMapping<?,?,R> table,
 R row,
 JdbcSession jdbcSession)