public class InitialLoadService extends AbstractService implements IInitialLoadService
| Modifier and Type | Field and Description |
|---|---|
protected ISymmetricEngine |
engine |
protected IExtensionService |
extensionService |
protected int |
lastLoadCountToProcess |
protected org.slf4j.Logger |
log |
protected boolean |
syncTriggersBeforeInitialLoadAttempted |
parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
InitialLoadService(ISymmetricEngine engine) |
| Modifier and Type | Method and Description |
|---|---|
void |
cancelLoad(TableReloadStatus status) |
protected java.util.List<NodeSecurity> |
findNodesThatAreReadyForInitialLoad() |
protected java.util.List<TriggerRouter> |
getTriggerRoutersForNodeGroup(java.util.Map<java.lang.String,java.util.List<TriggerRouter>> triggerRoutersByNodeGroup,
java.lang.String nodeGroupId) |
protected boolean |
isValidLoadTarget(java.lang.String targetNodeId) |
protected void |
logActiveLoadCount(int activeLoadCount,
int loadCountToProcess) |
void |
processInitialLoadEnabledFlag(Node identity,
ProcessInfo processInfo)
If a load has been queued up by setting the initial load enabled or reverse
initial load enabled flags, then the router service will insert the reload
events.
|
protected void |
processTableRequestLoads(Node source,
ProcessInfo processInfo) |
void |
queueLoads(boolean force) |
assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdsprotected final org.slf4j.Logger log
protected ISymmetricEngine engine
protected IExtensionService extensionService
protected boolean syncTriggersBeforeInitialLoadAttempted
protected int lastLoadCountToProcess
public InitialLoadService(ISymmetricEngine engine)
public void queueLoads(boolean force)
queueLoads in interface IInitialLoadServicepublic void cancelLoad(TableReloadStatus status)
cancelLoad in interface IInitialLoadServicepublic void processInitialLoadEnabledFlag(Node identity, ProcessInfo processInfo)
protected void processTableRequestLoads(Node source, ProcessInfo processInfo)
protected void logActiveLoadCount(int activeLoadCount,
int loadCountToProcess)
protected java.util.List<TriggerRouter> getTriggerRoutersForNodeGroup(java.util.Map<java.lang.String,java.util.List<TriggerRouter>> triggerRoutersByNodeGroup, java.lang.String nodeGroupId)
protected java.util.List<NodeSecurity> findNodesThatAreReadyForInitialLoad()
protected boolean isValidLoadTarget(java.lang.String targetNodeId)