public abstract class DefaultAtlasMappingBuilder extends Object implements io.atlasmap.api.AtlasMappingBuilder
AtlasMappingBuilder
with some common utility methods.
In most cases user can extend this class and just implement processMapping()
.AtlasField
Constructor and Description |
---|
DefaultAtlasMappingBuilder() |
Modifier and Type | Method and Description |
---|---|
void |
addAudit(Exception e) |
io.atlasmap.api.AtlasSession |
getAtlasSession()
Get
DefaultAtlasSession . |
void |
process() |
abstract void |
processMapping()
Define custom mapping logic.
|
AtlasField |
read(String docId,
String path) |
AtlasField |
readConstant(String name) |
AtlasField |
readProperty(String scope,
String name) |
void |
setAtlasSession(io.atlasmap.api.AtlasSession session) |
void |
write(String docId,
String path,
Object value) |
public AtlasField read(String docId, String path) throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
public AtlasField readConstant(String name) throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
public AtlasField readProperty(String scope, String name) throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
public void write(String docId, String path, Object value) throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
public void process()
process
in interface io.atlasmap.api.AtlasMappingBuilder
public abstract void processMapping() throws Exception
process()
and added as an Audit.Exception
- Indicate mapping error to be recorded as an Auditpublic void setAtlasSession(io.atlasmap.api.AtlasSession session) throws io.atlasmap.api.AtlasException
setAtlasSession
in interface io.atlasmap.api.AtlasMappingBuilder
io.atlasmap.api.AtlasException
public io.atlasmap.api.AtlasSession getAtlasSession()
DefaultAtlasSession
.AtlasSession
.public void addAudit(Exception e)
Copyright © 2017–2021 Red Hat, Inc.. All rights reserved.