Package com.atlan.samples.loaders.models

Class LineageDetails

java.lang.Object

com.atlan.samples.loaders.models.AssetDetails

com.atlan.samples.loaders.models.LineageDetails

public class LineageDetails
extends AssetDetails

Utility class for capturing the full details provided about a column.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LineageDetails.AssetHeader
static class	LineageDetails.LineageDetailsBuilder<C extends LineageDetails,B extends LineageDetails.LineageDetailsBuilder<C,B>>

Nested classes/interfaces inherited from class com.atlan.samples.loaders.models.AssetDetails

AssetDetails.AssetDetailsBuilder<C extends AssetDetails,B extends AssetDetails.AssetDetailsBuilder<C,B>>

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	COL_ORCHESTRATOR
static java.lang.String	COL_PROCESS_ID
static java.lang.String	COL_PROCESS_TYPE
static java.lang.String	COL_PROCESS_URL
static java.lang.String	COL_S_ASSET
static java.lang.String	COL_S_ASSET_TYPE
static java.lang.String	COL_S_CONNECTION
static java.lang.String	COL_S_CONNECTOR
static java.lang.String	COL_SQL_CODE
static java.lang.String	COL_T_ASSET
static java.lang.String	COL_T_ASSET_TYPE
static java.lang.String	COL_T_CONNECTION
static java.lang.String	COL_T_CONNECTOR

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	LineageDetails(LineageDetails.LineageDetailsBuilder<?,?> b)

Method Summary

Modifier and Type	Method	Description
static LineageDetails.LineageDetailsBuilder<?,?>	builder()
protected boolean	canEqual(java.lang.Object other)
boolean	equals(java.lang.Object o)
static LineageDetails	getFromRow(java.util.Map<ConnectionDetails,java.lang.String> connectionCache, java.util.Map<java.lang.String,java.lang.String> row, java.lang.String delim)	Build up details about the lineage on the provided row.
java.lang.String	getIdentity()	Retrieve the unique identity of this asset for deduplication across rows.
static ConnectionDetails	getOrchestratorFromRow(java.util.Map<java.lang.String,java.lang.String> row)	Retrieve the orchestrator details from the provided row.
java.lang.String	getProcessConnectionQualifiedName()
java.lang.String	getProcessId()
java.lang.String	getProcessUrl()
LineageDetails.AssetHeader	getSourceAsset()
static ConnectionDetails	getSourceConnectionFromRow(java.util.Map<java.lang.String,java.lang.String> row)	Retrieve the source connection details from the provided row.
java.lang.String	getSqlCode()
LineageDetails.AssetHeader	getTargetAsset()
static ConnectionDetails	getTargetConnectionFromRow(java.util.Map<java.lang.String,java.lang.String> row)	Retrieve the target connection details from the provided row.
int	hashCode()
java.lang.String	toString()
static void	upsert(java.util.Map<java.lang.String,java.util.Set<LineageDetails>> processes, int batchSize)	Create lineage processes in bulk, if they do not exist, or update them if they do (idempotent).

Methods inherited from class com.atlan.samples.loaders.models.AssetDetails

appendAtlanTags, getAnnouncementMessage, getAnnouncementTitle, getAnnouncementType, getAtlanTags, getBoolean, getCertificate, getCertificateStatusMessage, getDescription, getFromRow, getMissingFields, getMultiValuedList, getOwnerGroups, getOwnerUsers, getRequiredEmptyFields, isStub, selectivelyUpdateCustomMetadata

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

COL_S_CONNECTOR

public static final java.lang.String COL_S_CONNECTOR

See Also:

Constant Field Values

COL_S_CONNECTION

public static final java.lang.String COL_S_CONNECTION

See Also:

Constant Field Values

COL_S_ASSET_TYPE

public static final java.lang.String COL_S_ASSET_TYPE

See Also:

Constant Field Values

COL_S_ASSET

public static final java.lang.String COL_S_ASSET

See Also:

Constant Field Values

COL_ORCHESTRATOR

public static final java.lang.String COL_ORCHESTRATOR

See Also:

Constant Field Values

COL_PROCESS_ID

public static final java.lang.String COL_PROCESS_ID

See Also:

Constant Field Values

COL_PROCESS_TYPE

public static final java.lang.String COL_PROCESS_TYPE

See Also:

Constant Field Values

COL_T_ASSET

public static final java.lang.String COL_T_ASSET

See Also:

Constant Field Values

COL_T_ASSET_TYPE

public static final java.lang.String COL_T_ASSET_TYPE

See Also:

Constant Field Values

COL_T_CONNECTOR

public static final java.lang.String COL_T_CONNECTOR

See Also:

Constant Field Values

COL_T_CONNECTION

public static final java.lang.String COL_T_CONNECTION

See Also:

Constant Field Values

COL_SQL_CODE

public static final java.lang.String COL_SQL_CODE

See Also:

Constant Field Values

COL_PROCESS_URL

public static final java.lang.String COL_PROCESS_URL

See Also:

Constant Field Values

Constructor Detail

LineageDetails

protected LineageDetails(LineageDetails.LineageDetailsBuilder<?,?> b)

Method Detail

getIdentity

public java.lang.String getIdentity()

Retrieve the unique identity of this asset for deduplication across rows.

Specified by:

getIdentity in class AssetDetails

Returns:

String giving the unique identity of the asset

getOrchestratorFromRow

public static ConnectionDetails getOrchestratorFromRow(java.util.Map<java.lang.String,java.lang.String> row)

Retrieve the orchestrator details from the provided row.

Parameters:

row - of data

Returns:

the connection details for the orchestrator for that row

getSourceConnectionFromRow

public static ConnectionDetails getSourceConnectionFromRow(java.util.Map<java.lang.String,java.lang.String> row)

Retrieve the source connection details from the provided row.

Parameters:

row - of data

Returns:

the connection details for the source asset on that row

getTargetConnectionFromRow

public static ConnectionDetails getTargetConnectionFromRow(java.util.Map<java.lang.String,java.lang.String> row)

Retrieve the target connection details from the provided row.

Parameters:

row - of data

Returns:

the connection details for the target asset on that row

getFromRow

public static LineageDetails getFromRow(java.util.Map<ConnectionDetails,java.lang.String> connectionCache,
                                        java.util.Map<java.lang.String,java.lang.String> row,
                                        java.lang.String delim)

Build up details about the lineage on the provided row.

Parameters:

connectionCache - a cache of connections that have first been resolved across the spreadsheet

row - a row of data from the spreadsheet, as a map from column name to value

delim - delimiter used in cells that can contain multiple values

Returns:

the lineage details for that row

upsert

public static void upsert(java.util.Map<java.lang.String,java.util.Set<LineageDetails>> processes,
                          int batchSize)

Create lineage processes in bulk, if they do not exist, or update them if they do (idempotent).

Parameters:

processes - the map of processes to ensure exist, keyed by processQualifiedName

batchSize - maximum number of processes to create per batch

builder

public static LineageDetails.LineageDetailsBuilder<?,?> builder()

getSourceAsset

public LineageDetails.AssetHeader getSourceAsset()

getProcessConnectionQualifiedName

public java.lang.String getProcessConnectionQualifiedName()

getProcessId

public java.lang.String getProcessId()

getTargetAsset

public LineageDetails.AssetHeader getTargetAsset()

getSqlCode

public java.lang.String getSqlCode()

getProcessUrl

public java.lang.String getProcessUrl()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class AssetDetails

canEqual

protected boolean canEqual(java.lang.Object other)

Overrides:

canEqual in class AssetDetails

hashCode

public int hashCode()

Overrides:

hashCode in class AssetDetails

toString

public java.lang.String toString()

Overrides:

toString in class AssetDetails