Package io.atlasmap.core

Class DefaultAtlasContext

java.lang.Object

io.atlasmap.core.DefaultAtlasContext

All Implemented Interfaces:

AtlasContext, AtlasContextMXBean

public class DefaultAtlasContext
extends Object
implements AtlasContext, AtlasContextMXBean

Constructor Summary

Constructors

Constructor	Description
DefaultAtlasContext(DefaultAtlasContextFactory factory, AtlasContextFactory.Format format, InputStream stream)
DefaultAtlasContext(DefaultAtlasContextFactory factory, AtlasMapping mapping)
DefaultAtlasContext(DefaultAtlasContextFactory factory, URI atlasMappingUri)
DefaultAtlasContext(URI atlasMappingUri)

Method Summary

Modifier and Type	Method	Description
protected Field	applyFieldActions(DefaultAtlasSession session, Field field)
AtlasSession	createSession()
AtlasSession	createSession(AtlasMapping mappingDefinition)
ADMArchiveHandler	getADMArchiveHandler()
String	getClassName()
DefaultAtlasContextFactory	getContextFactory()
ObjectName	getJmxObjectName()
Map<String,LookupTable>	getLookupTables()
AtlasMapping	getMapping()
String	getMappingName()
String	getMappingUri()
Map<String,AtlasModule>	getSourceModules()
Map<String,AtlasModule>	getTargetModules()
String	getThreadName()
String	getUuid()
String	getVersion()
protected void	init()	TODO: For dynamic re-load.
void	process(AtlasSession userSession)	Process session lifecycle.
protected Field	processCombineField(DefaultAtlasSession session, Mapping mapping, List<Field> sourceFields, Field targetField)
Audits	processPreview(Mapping mapping)	Deprecated. Use AtlasPreviewContext#processPreview(Mapping)
protected List<Field>	processSeparateField(DefaultAtlasSession session, Mapping mapping, Field sourceField)
protected void	processSourceFieldMapping(DefaultAtlasSession session)
void	processValidation(AtlasSession userSession)
protected void	registerJmx(DefaultAtlasContext context)
protected AtlasModule	resolveModule(FieldDirection direction, Field field)
protected void	setDefaultSessionProperties(AtlasSession session)
protected void	setJmxObjectName(ObjectName jmxObjectName)
void	setLookupTables(Map<String,LookupTable> lookupTables)
protected void	setMappingUri(URI atlasMappingUri)
void	setSourceModules(Map<String,AtlasModule> sourceModules)
void	setTargetModules(Map<String,AtlasModule> targetModules)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultAtlasContext

public DefaultAtlasContext(URI atlasMappingUri)

DefaultAtlasContext

public DefaultAtlasContext(DefaultAtlasContextFactory factory,
 URI atlasMappingUri)

DefaultAtlasContext

public DefaultAtlasContext(DefaultAtlasContextFactory factory,
 AtlasMapping mapping)

DefaultAtlasContext

public DefaultAtlasContext(DefaultAtlasContextFactory factory,
 AtlasContextFactory.Format format,
 InputStream stream)
                    throws AtlasException

Throws:

AtlasException

Method Details

init

protected void init()
             throws AtlasException

TODO: For dynamic re-load. This needs lock()

Throws:

AtlasException - failed to initialize

registerJmx

protected void registerJmx(DefaultAtlasContext context)

processPreview

@Deprecated
public Audits processPreview(Mapping mapping)
                      throws AtlasException

Deprecated.

Use AtlasPreviewContext#processPreview(Mapping)

Process single mapping entry in preview mode. Since modules don't participate in preview mode, any document format specific function won't be applied.

Specified by:

processPreview in interface AtlasContext

Parameters:

mapping - A @link{Mapping} entry to process

Returns:

A list of audit log

Throws:

AtlasException

applyFieldActions

protected Field applyFieldActions(DefaultAtlasSession session,
 Field field)

process

public void process(AtlasSession userSession)
             throws AtlasException

Process session lifecycle.

Specified by:

process in interface AtlasContext

Throws:

AtlasException

processSourceFieldMapping

protected void processSourceFieldMapping(DefaultAtlasSession session)

resolveModule

protected AtlasModule resolveModule(FieldDirection direction,
 Field field)

processCombineField

protected Field processCombineField(DefaultAtlasSession session,
 Mapping mapping,
 List<Field> sourceFields,
 Field targetField)

processSeparateField

protected List<Field> processSeparateField(DefaultAtlasSession session,
 Mapping mapping,
 Field sourceField)
                                    throws AtlasException

Throws:

AtlasException

processValidation

public void processValidation(AtlasSession userSession)
                       throws AtlasException

Specified by:

processValidation in interface AtlasContext

Throws:

AtlasException

getContextFactory

public DefaultAtlasContextFactory getContextFactory()

Specified by:

getContextFactory in interface AtlasContext

getMapping

public AtlasMapping getMapping()

createSession

public AtlasSession createSession()
                           throws AtlasException

Specified by:

createSession in interface AtlasContext

Throws:

AtlasException

createSession

public AtlasSession createSession(AtlasMapping mappingDefinition)
                           throws AtlasException

Throws:

AtlasException

setDefaultSessionProperties

protected void setDefaultSessionProperties(AtlasSession session)

getSourceModules

public Map<String,AtlasModule> getSourceModules()

setSourceModules

public void setSourceModules(Map<String,AtlasModule> sourceModules)

getTargetModules

public Map<String,AtlasModule> getTargetModules()

setTargetModules

public void setTargetModules(Map<String,AtlasModule> targetModules)

getLookupTables

public Map<String,LookupTable> getLookupTables()

setLookupTables

public void setLookupTables(Map<String,LookupTable> lookupTables)

setJmxObjectName

protected void setJmxObjectName(ObjectName jmxObjectName)

getJmxObjectName

public ObjectName getJmxObjectName()

getUuid

public String getUuid()

Specified by:

getUuid in interface AtlasContextMXBean

getVersion

public String getVersion()

Specified by:

getVersion in interface AtlasContextMXBean

getMappingName

public String getMappingName()

Specified by:

getMappingName in interface AtlasContextMXBean

setMappingUri

protected void setMappingUri(URI atlasMappingUri)

getMappingUri

public String getMappingUri()

Specified by:

getMappingUri in interface AtlasContextMXBean

getClassName

public String getClassName()

Specified by:

getClassName in interface AtlasContextMXBean

getThreadName

public String getThreadName()

Specified by:

getThreadName in interface AtlasContextMXBean

toString

public String toString()

Overrides:

toString in class Object

getADMArchiveHandler

public ADMArchiveHandler getADMArchiveHandler()