public class DefaultAtlasContext extends Object implements io.atlasmap.api.AtlasContext, io.atlasmap.mxbean.AtlasContextMXBean
Constructor and Description |
---|
DefaultAtlasContext(DefaultAtlasContextFactory factory,
io.atlasmap.api.AtlasContextFactory.Format format,
InputStream stream) |
DefaultAtlasContext(DefaultAtlasContextFactory factory,
io.atlasmap.v2.AtlasMapping mapping) |
DefaultAtlasContext(DefaultAtlasContextFactory factory,
URI atlasMappingUri) |
DefaultAtlasContext(URI atlasMappingUri) |
Modifier and Type | Method and Description |
---|---|
protected io.atlasmap.v2.Field |
applyFieldActions(DefaultAtlasSession session,
io.atlasmap.v2.Field field) |
io.atlasmap.api.AtlasSession |
createSession() |
io.atlasmap.api.AtlasSession |
createSession(io.atlasmap.v2.AtlasMapping mappingDefinition) |
ADMArchiveHandler |
getADMArchiveHandler() |
String |
getClassName() |
DefaultAtlasContextFactory |
getContextFactory() |
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.
|
protected io.atlasmap.v2.Field |
processCombineField(DefaultAtlasSession session,
io.atlasmap.v2.Mapping mapping,
List<io.atlasmap.v2.Field> sourceFields,
io.atlasmap.v2.Field targetField) |
io.atlasmap.v2.Audits |
processPreview(io.atlasmap.v2.Mapping mapping)
Deprecated.
Use
AtlasPreviewContext#processPreview(Mapping) |
protected List<io.atlasmap.v2.Field> |
processSeparateField(DefaultAtlasSession session,
io.atlasmap.v2.Mapping mapping,
io.atlasmap.v2.Field sourceField) |
protected void |
processSourceFieldMapping(DefaultAtlasSession session) |
void |
processValidation(io.atlasmap.api.AtlasSession userSession) |
protected void |
registerJmx(DefaultAtlasContext context) |
protected io.atlasmap.spi.AtlasModule |
resolveModule(io.atlasmap.spi.FieldDirection direction,
io.atlasmap.v2.Field field) |
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 DefaultAtlasContext(URI atlasMappingUri)
public DefaultAtlasContext(DefaultAtlasContextFactory factory, URI atlasMappingUri)
public DefaultAtlasContext(DefaultAtlasContextFactory factory, io.atlasmap.v2.AtlasMapping mapping)
public DefaultAtlasContext(DefaultAtlasContextFactory factory, io.atlasmap.api.AtlasContextFactory.Format format, InputStream stream) throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
protected void init() throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
- failed to initializeprotected void registerJmx(DefaultAtlasContext context)
@Deprecated public io.atlasmap.v2.Audits processPreview(io.atlasmap.v2.Mapping mapping) throws io.atlasmap.api.AtlasException
AtlasPreviewContext#processPreview(Mapping)
processPreview
in interface io.atlasmap.api.AtlasContext
mapping
- A @link{Mapping} entry to processio.atlasmap.api.AtlasException
protected io.atlasmap.v2.Field applyFieldActions(DefaultAtlasSession session, io.atlasmap.v2.Field field)
public void process(io.atlasmap.api.AtlasSession userSession) throws io.atlasmap.api.AtlasException
process
in interface io.atlasmap.api.AtlasContext
io.atlasmap.api.AtlasException
protected void processSourceFieldMapping(DefaultAtlasSession session)
protected io.atlasmap.spi.AtlasModule resolveModule(io.atlasmap.spi.FieldDirection direction, io.atlasmap.v2.Field field)
protected io.atlasmap.v2.Field processCombineField(DefaultAtlasSession session, io.atlasmap.v2.Mapping mapping, List<io.atlasmap.v2.Field> sourceFields, io.atlasmap.v2.Field targetField)
protected List<io.atlasmap.v2.Field> processSeparateField(DefaultAtlasSession session, io.atlasmap.v2.Mapping mapping, io.atlasmap.v2.Field sourceField) 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
public DefaultAtlasContextFactory 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
public ADMArchiveHandler getADMArchiveHandler()
Copyright © 2017–2021 Red Hat, Inc.. All rights reserved.