public class LookupTableDataRouter extends AbstractDataRouter implements IDataRouter, org.jumpmind.extension.IBuiltInExtensionPoint
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
PARAM_ALL_NODES_VALUE |
static java.lang.String |
PARAM_EXTERNAL_ID_COLUMN |
static java.lang.String |
PARAM_KEY_COLUMN |
static java.lang.String |
PARAM_LOOKUP_TABLE |
static java.lang.String |
PARAM_MAPPED_KEY_COLUMN |
| Constructor and Description |
|---|
LookupTableDataRouter() |
LookupTableDataRouter(ISymmetricDialect symmetricDialect) |
| Modifier and Type | Method and Description |
|---|---|
protected java.util.Map<java.lang.String,java.util.Set<java.lang.String>> |
getLookupTable(java.util.Map<java.lang.String,java.lang.String> params,
Router router,
SimpleRouterContext routingContext) |
protected java.util.Map<java.lang.String,java.lang.String> |
getParams(Router router,
SimpleRouterContext routingContext)
Cache parsed expressions in the context to minimize the amount of parsing
we have to do when we have lots of throughput.
|
java.util.Map<java.lang.String,java.lang.String> |
parse(java.lang.String routerExpression) |
java.util.Set<java.lang.String> |
routeToNodes(SimpleRouterContext routingContext,
DataMetaData dataMetaData,
java.util.Set<Node> nodes,
boolean initialLoad,
boolean initialLoadSelectUsed,
TriggerRouter triggerRouter) |
addNodeId, completeBatch, contextCommitted, getDataAsObject, getDataAsString, getDataMap, getDataObjectMap, getNewDataAsObject, getNewDataAsString, getNullData, getOldDataAsObject, getOldDataAsString, getPkDataAsObject, getPkDataAsString, isConfigurable, testColumnNamesMatchValues, toExternalIds, toNodeIdsclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcompleteBatch, contextCommitted, isConfigurablepublic static final java.lang.String PARAM_LOOKUP_TABLE
public static final java.lang.String PARAM_KEY_COLUMN
public static final java.lang.String PARAM_MAPPED_KEY_COLUMN
public static final java.lang.String PARAM_EXTERNAL_ID_COLUMN
public static final java.lang.String PARAM_ALL_NODES_VALUE
public LookupTableDataRouter(ISymmetricDialect symmetricDialect)
public LookupTableDataRouter()
public java.util.Set<java.lang.String> routeToNodes(SimpleRouterContext routingContext, DataMetaData dataMetaData, java.util.Set<Node> nodes, boolean initialLoad, boolean initialLoadSelectUsed, TriggerRouter triggerRouter)
routeToNodes in interface IDataRouterprotected java.util.Map<java.lang.String,java.lang.String> getParams(Router router, SimpleRouterContext routingContext)
public java.util.Map<java.lang.String,java.lang.String> parse(java.lang.String routerExpression)
throws SyntaxParsingException
SyntaxParsingExceptionprotected java.util.Map<java.lang.String,java.util.Set<java.lang.String>> getLookupTable(java.util.Map<java.lang.String,java.lang.String> params,
Router router,
SimpleRouterContext routingContext)