public class DefaultAtlasContext extends Object implements io.atlasmap.api.AtlasContext, io.atlasmap.mxbean.AtlasContextMXBean
Modifier and Type | Field and Description |
---|---|
static String |
CONSTANTS_DOCUMENT_ID |
static String |
PROPERTIES_DOCUMENT_ID |
Constructor and Description |
---|
DefaultAtlasContext(DefaultAtlasContextFactory factory,
io.atlasmap.v2.AtlasMapping mapping) |
DefaultAtlasContext(DefaultAtlasContextFactory factory,
URI atlasMappingUri) |
DefaultAtlasContext(URI atlasMappingUri) |
Modifier and Type | Method and Description |
---|---|
io.atlasmap.api.AtlasSession |
createSession() |
io.atlasmap.api.AtlasSession |
createSession(io.atlasmap.v2.AtlasMapping mappingDefinition) |
String |
getClassName() |
io.atlasmap.api.AtlasContextFactory |
getContextFactory() |
protected DefaultAtlasContextFactory |
getDefaultAtlasContextFactory() |
ObjectName |
getJmxObjectName() |
Map<String,io.atlasmap.v2.LookupTable> |
getLookupTables() |
io.atlasmap.v2.AtlasMapping |
getMapping() |
String |
getMappingName() |
String |
getMappingUri() |
Map<String,io.atlasmap.spi.AtlasModule> |
getSourceModules() |
Map<String,io.atlasmap.spi.AtlasModule> |
getTargetModules() |
String |
getThreadName() |
String |
getUuid() |
String |
getVersion() |
protected void |
init()
TODO: For dynamic re-load.
|
void |
process(io.atlasmap.api.AtlasSession userSession)
Process session lifecycle
|
io.atlasmap.v2.Audits |
processPreview(io.atlasmap.v2.Mapping mapping)
Process single mapping entry in preview mode.
|
void |
processValidation(io.atlasmap.api.AtlasSession userSession) |
protected void |
registerJmx(DefaultAtlasContext context) |
protected void |
setDefaultSessionProperties(io.atlasmap.api.AtlasSession session) |
protected void |
setJmxObjectName(ObjectName jmxObjectName) |
void |
setLookupTables(Map<String,io.atlasmap.v2.LookupTable> lookupTables) |
protected void |
setMappingUri(URI atlasMappingUri) |
void |
setSourceModules(Map<String,io.atlasmap.spi.AtlasModule> sourceModules) |
void |
setTargetModules(Map<String,io.atlasmap.spi.AtlasModule> targetModules) |
String |
toString() |
public static final String CONSTANTS_DOCUMENT_ID
public static final String PROPERTIES_DOCUMENT_ID
public DefaultAtlasContext(URI atlasMappingUri)
public DefaultAtlasContext(DefaultAtlasContextFactory factory, URI atlasMappingUri)
public DefaultAtlasContext(DefaultAtlasContextFactory factory, io.atlasmap.v2.AtlasMapping mapping)
protected void init() throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
- failed to initializeprotected void registerJmx(DefaultAtlasContext context)
public io.atlasmap.v2.Audits processPreview(io.atlasmap.v2.Mapping mapping) throws io.atlasmap.api.AtlasException
processPreview
in interface io.atlasmap.api.AtlasContext
mapping
- A @link{Mapping} entry to processio.atlasmap.api.AtlasException
public void process(io.atlasmap.api.AtlasSession userSession) throws io.atlasmap.api.AtlasException
process
in interface io.atlasmap.api.AtlasContext
io.atlasmap.api.AtlasException
public void processValidation(io.atlasmap.api.AtlasSession userSession) throws io.atlasmap.api.AtlasException
processValidation
in interface io.atlasmap.api.AtlasContext
io.atlasmap.api.AtlasException
protected DefaultAtlasContextFactory getDefaultAtlasContextFactory()
public io.atlasmap.api.AtlasContextFactory getContextFactory()
getContextFactory
in interface io.atlasmap.api.AtlasContext
public io.atlasmap.v2.AtlasMapping getMapping()
public io.atlasmap.api.AtlasSession createSession() throws io.atlasmap.api.AtlasException
createSession
in interface io.atlasmap.api.AtlasContext
io.atlasmap.api.AtlasException
public io.atlasmap.api.AtlasSession createSession(io.atlasmap.v2.AtlasMapping mappingDefinition) throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
protected void setDefaultSessionProperties(io.atlasmap.api.AtlasSession session)
public void setSourceModules(Map<String,io.atlasmap.spi.AtlasModule> sourceModules)
public void setTargetModules(Map<String,io.atlasmap.spi.AtlasModule> targetModules)
protected void setJmxObjectName(ObjectName jmxObjectName)
public ObjectName getJmxObjectName()
public String getUuid()
getUuid
in interface io.atlasmap.mxbean.AtlasContextMXBean
public String getVersion()
getVersion
in interface io.atlasmap.mxbean.AtlasContextMXBean
public String getMappingName()
getMappingName
in interface io.atlasmap.mxbean.AtlasContextMXBean
protected void setMappingUri(URI atlasMappingUri)
public String getMappingUri()
getMappingUri
in interface io.atlasmap.mxbean.AtlasContextMXBean
public String getClassName()
getClassName
in interface io.atlasmap.mxbean.AtlasContextMXBean
public String getThreadName()
getThreadName
in interface io.atlasmap.mxbean.AtlasContextMXBean
Copyright © 2020 JBoss by Red Hat. All rights reserved.