public abstract class BaseAtlasModule extends Object implements io.atlasmap.spi.AtlasModule, io.atlasmap.mxbean.AtlasModuleMXBean
Constructor and Description |
---|
BaseAtlasModule() |
Modifier and Type | Method and Description |
---|---|
protected io.atlasmap.v2.Field |
applySourceFieldActions(io.atlasmap.spi.AtlasInternalSession session) |
protected io.atlasmap.v2.Field |
applyTargetFieldActions(io.atlasmap.spi.AtlasInternalSession session) |
void |
destroy() |
ClassLoader |
getClassLoader() |
String |
getClassName() |
io.atlasmap.spi.AtlasConversionService |
getConversionService() |
String[] |
getDataFormats() |
String |
getDocId() |
io.atlasmap.spi.AtlasFieldActionService |
getFieldActionService() |
io.atlasmap.spi.AtlasModuleMode |
getMode() |
String |
getModeName() |
String |
getName() |
String[] |
getPackageNames() |
long |
getSourceCount() |
long |
getSourceErrorCount() |
long |
getSourceMaxExecutionTime() |
long |
getSourceMinExecutionTime() |
long |
getSourceSuccessCount() |
long |
getSourceTotalExecutionTime() |
long |
getTargetCount() |
long |
getTargetErrorCount() |
long |
getTargetMaxExecutionTime() |
long |
getTargetMinExecutionTime() |
long |
getTargetSuccessCount() |
long |
getTargetTotalExecutionTime() |
String |
getUri() |
String |
getUuid() |
String |
getVersion() |
void |
init() |
boolean |
isAutomaticallyProcessOutputFieldActions() |
boolean |
isSourceSupported() |
Boolean |
isStatisticsEnabled() |
Boolean |
isStatisticsSupported() |
Boolean |
isSupportedField(io.atlasmap.v2.Field field) |
boolean |
isTargetSupported() |
List<io.atlasmap.spi.AtlasModuleMode> |
listSupportedModes() |
void |
populateTargetField(io.atlasmap.spi.AtlasInternalSession session) |
protected void |
processLookupField(io.atlasmap.spi.AtlasInternalSession session,
io.atlasmap.v2.LookupTable lookupTable,
Object sourceValue,
io.atlasmap.v2.Field targetField) |
void |
processPostValidation(io.atlasmap.spi.AtlasInternalSession session) |
TabularData |
readAndResetStatistics() |
void |
setAutomaticallyProcessOutputFieldActions(boolean automaticallyProcessOutputFieldActions) |
void |
setClassLoader(ClassLoader classLoader) |
void |
setConversionService(io.atlasmap.spi.AtlasConversionService atlasConversionService) |
void |
setDocId(String docId) |
void |
setFieldActionService(io.atlasmap.spi.AtlasFieldActionService atlasFieldActionService) |
void |
setMode(io.atlasmap.spi.AtlasModuleMode atlasModuleMode) |
void |
setStatisticsEnabled(boolean enabled) |
void |
setUri(String uri) |
public void init()
init
in interface io.atlasmap.spi.AtlasModule
public void destroy()
destroy
in interface io.atlasmap.spi.AtlasModule
public void setClassLoader(ClassLoader classLoader)
setClassLoader
in interface io.atlasmap.spi.AtlasModule
public ClassLoader getClassLoader()
getClassLoader
in interface io.atlasmap.spi.AtlasModule
public void processPostValidation(io.atlasmap.spi.AtlasInternalSession session) throws io.atlasmap.api.AtlasException
processPostValidation
in interface io.atlasmap.spi.AtlasModule
io.atlasmap.api.AtlasException
public void populateTargetField(io.atlasmap.spi.AtlasInternalSession session) throws io.atlasmap.api.AtlasException
populateTargetField
in interface io.atlasmap.spi.AtlasModule
io.atlasmap.api.AtlasException
protected void processLookupField(io.atlasmap.spi.AtlasInternalSession session, io.atlasmap.v2.LookupTable lookupTable, Object sourceValue, io.atlasmap.v2.Field targetField) throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
protected io.atlasmap.v2.Field applyTargetFieldActions(io.atlasmap.spi.AtlasInternalSession session) throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
protected io.atlasmap.v2.Field applySourceFieldActions(io.atlasmap.spi.AtlasInternalSession session) throws io.atlasmap.api.AtlasException
io.atlasmap.api.AtlasException
public io.atlasmap.spi.AtlasModuleMode getMode()
getMode
in interface io.atlasmap.spi.AtlasModule
public void setMode(io.atlasmap.spi.AtlasModuleMode atlasModuleMode)
setMode
in interface io.atlasmap.spi.AtlasModule
public Boolean isStatisticsSupported()
isStatisticsSupported
in interface io.atlasmap.spi.AtlasModule
public Boolean isStatisticsEnabled()
isStatisticsEnabled
in interface io.atlasmap.mxbean.AtlasModuleMXBean
isStatisticsEnabled
in interface io.atlasmap.spi.AtlasModule
public List<io.atlasmap.spi.AtlasModuleMode> listSupportedModes()
listSupportedModes
in interface io.atlasmap.spi.AtlasModule
public io.atlasmap.spi.AtlasConversionService getConversionService()
getConversionService
in interface io.atlasmap.spi.AtlasModule
public String getDocId()
getDocId
in interface io.atlasmap.spi.AtlasModule
public void setDocId(String docId)
setDocId
in interface io.atlasmap.spi.AtlasModule
public String getUri()
getUri
in interface io.atlasmap.spi.AtlasModule
public void setUri(String uri)
setUri
in interface io.atlasmap.spi.AtlasModule
public void setConversionService(io.atlasmap.spi.AtlasConversionService atlasConversionService)
setConversionService
in interface io.atlasmap.spi.AtlasModule
public io.atlasmap.spi.AtlasFieldActionService getFieldActionService()
getFieldActionService
in interface io.atlasmap.spi.AtlasModule
public void setFieldActionService(io.atlasmap.spi.AtlasFieldActionService atlasFieldActionService)
setFieldActionService
in interface io.atlasmap.spi.AtlasModule
public boolean isAutomaticallyProcessOutputFieldActions()
public void setAutomaticallyProcessOutputFieldActions(boolean automaticallyProcessOutputFieldActions)
public boolean isSourceSupported()
isSourceSupported
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public boolean isTargetSupported()
isTargetSupported
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public String getClassName()
getClassName
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public String[] getDataFormats()
getDataFormats
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public String getModeName()
getModeName
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public String getName()
getName
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public String[] getPackageNames()
getPackageNames
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getSourceErrorCount()
getSourceErrorCount
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getSourceCount()
getSourceCount
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getSourceMaxExecutionTime()
getSourceMaxExecutionTime
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getSourceMinExecutionTime()
getSourceMinExecutionTime
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getSourceSuccessCount()
getSourceSuccessCount
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getSourceTotalExecutionTime()
getSourceTotalExecutionTime
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getTargetCount()
getTargetCount
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getTargetErrorCount()
getTargetErrorCount
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getTargetMaxExecutionTime()
getTargetMaxExecutionTime
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getTargetMinExecutionTime()
getTargetMinExecutionTime
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getTargetSuccessCount()
getTargetSuccessCount
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public long getTargetTotalExecutionTime()
getTargetTotalExecutionTime
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public String getUuid()
getUuid
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public String getVersion()
getVersion
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public TabularData readAndResetStatistics()
readAndResetStatistics
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public void setStatisticsEnabled(boolean enabled)
setStatisticsEnabled
in interface io.atlasmap.mxbean.AtlasModuleMXBean
public Boolean isSupportedField(io.atlasmap.v2.Field field)
isSupportedField
in interface io.atlasmap.spi.AtlasModule
Copyright © 2019 JBoss by Red Hat. All rights reserved.