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(DefaultAtlasContextFactory factory,
URI atlasMappingUri,
AtlasMappingService.AtlasMappingFormat format) |
DefaultAtlasContext(URI atlasMappingUri) |
Modifier and Type | Method and Description |
---|---|
io.atlasmap.api.AtlasSession |
createSession() |
io.atlasmap.api.AtlasSession |
createSession(io.atlasmap.v2.AtlasMapping mappingDefinition) |
protected List<io.atlasmap.v2.Mapping> |
extractCollectionMappings(DefaultAtlasSession session,
io.atlasmap.v2.BaseMapping baseMapping) |
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, URI atlasMappingUri, AtlasMappingService.AtlasMappingFormat format)
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)
processPreview
in interface io.atlasmap.api.AtlasContext
mapping
- A @link{Mapping} entry to processpublic void process(io.atlasmap.api.AtlasSession userSession) throws io.atlasmap.api.AtlasException
process
in interface io.atlasmap.api.AtlasContext
io.atlasmap.api.AtlasException
protected final List<io.atlasmap.v2.Mapping> extractCollectionMappings(DefaultAtlasSession session, io.atlasmap.v2.BaseMapping baseMapping) throws io.atlasmap.api.AtlasException
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 © 2018 JBoss by Red Hat. All rights reserved.