org.jumpmind.symmetric.route

Class LookupTableDataRouter

java.lang.Object

org.jumpmind.symmetric.route.AbstractDataRouter

org.jumpmind.symmetric.route.LookupTableDataRouter

All Implemented Interfaces:

org.jumpmind.extension.IBuiltInExtensionPoint, org.jumpmind.extension.IExtensionPoint, IDataRouter

public class LookupTableDataRouter
extends AbstractDataRouter
implements IDataRouter, org.jumpmind.extension.IBuiltInExtensionPoint

A data router that uses a lookup table to map data to nodes

Field Summary

Fields

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 Summary

Constructors

Constructor and Description
LookupTableDataRouter()
LookupTableDataRouter(ISymmetricDialect symmetricDialect)

Method Summary

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)

Methods inherited from class org.jumpmind.symmetric.route.AbstractDataRouter

addNodeId, completeBatch, contextCommitted, getDataAsObject, getDataAsString, getDataMap, getDataObjectMap, getNewDataAsObject, getNewDataAsString, getNullData, getOldDataAsObject, getOldDataAsString, getPkDataAsObject, getPkDataAsString, isConfigurable, testColumnNamesMatchValues, toExternalIds, toNodeIds

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jumpmind.symmetric.route.IDataRouter

completeBatch, contextCommitted, isConfigurable

Field Detail

PARAM_LOOKUP_TABLE

public static final java.lang.String PARAM_LOOKUP_TABLE

See Also:

Constant Field Values

PARAM_KEY_COLUMN

public static final java.lang.String PARAM_KEY_COLUMN

See Also:

Constant Field Values

PARAM_MAPPED_KEY_COLUMN

public static final java.lang.String PARAM_MAPPED_KEY_COLUMN

See Also:

Constant Field Values

PARAM_EXTERNAL_ID_COLUMN

public static final java.lang.String PARAM_EXTERNAL_ID_COLUMN

See Also:

Constant Field Values

PARAM_ALL_NODES_VALUE

public static final java.lang.String PARAM_ALL_NODES_VALUE

See Also:

Constant Field Values

Constructor Detail

LookupTableDataRouter

public LookupTableDataRouter(ISymmetricDialect symmetricDialect)

LookupTableDataRouter

public LookupTableDataRouter()

Method Detail

routeToNodes

public java.util.Set<java.lang.String> routeToNodes(SimpleRouterContext routingContext,
                                                    DataMetaData dataMetaData,
                                                    java.util.Set<Node> nodes,
                                                    boolean initialLoad,
                                                    boolean initialLoadSelectUsed,
                                                    TriggerRouter triggerRouter)

Specified by:

routeToNodes in interface IDataRouter

getParams

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.

parse

public java.util.Map<java.lang.String,java.lang.String> parse(java.lang.String routerExpression)
                                                       throws SyntaxParsingException

Throws:

SyntaxParsingException

getLookupTable

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)