Package com.atlan.model.assets

Class ColumnProcess.ColumnProcessBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>

java.lang.Object

com.atlan.model.core.AtlanObject.AtlanObjectBuilder<C,B>

com.atlan.model.relations.Reference.ReferenceBuilder<C,B>

com.atlan.model.assets.Asset.AssetBuilder<C,B>

com.atlan.model.assets.ColumnProcess.ColumnProcessBuilder<C,B>

Enclosing class:

ColumnProcess

public abstract static class ColumnProcess.ColumnProcessBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>
extends Asset.AssetBuilder<C,B>

Constructor Summary

Constructors

Constructor	Description
ColumnProcessBuilder()

Method Summary

Modifier and Type	Method	Description
protected B	$fillValuesFrom(C instance)
B	additionalEtlContext(String additionalEtlContext)	Additional Context of the ETL pipeline/notebook which creates the process.
B	adfActivity(IAdfActivity adfActivity)	ADF Activity that is associated with this lineage process.
B	aiDatasetType(AIDatasetType aiDatasetType)	Dataset type for AI Model - dataset process.
B	airflowTask(IAirflowTask airflowTask)
B	airflowTasks(Collection<? extends IAirflowTask> airflowTasks)
B	ast(String ast)	Parsed AST of the code or SQL statements that describe the logic of this process.
B	bigqueryRoutine(IBigqueryRoutine bigqueryRoutine)
B	bigqueryRoutines(Collection<? extends IBigqueryRoutine> bigqueryRoutines)
abstract C	build()
B	clearAirflowTasks()
B	clearBigqueryRoutines()
B	clearColumnProcesses()
B	clearFabricActivities()
B	clearInputs()
B	clearOutputs()
B	clearParentConnectionProcessQualifiedNames()
B	clearSparkJobs()
B	clearSqlProcedures()
B	code(String code)	Code that ran within the process.
B	columnProcess(IColumnProcess columnProcess)
B	columnProcesses(Collection<? extends IColumnProcess> columnProcesses)
B	fabricActivities(Collection<? extends IFabricActivity> fabricActivities)
B	fabricActivity(IFabricActivity fabricActivity)
B	fivetranConnector(IFivetranConnector fivetranConnector)	fivetranConnector in which this process exists.
B	flowOrchestratedBy(IFlowControlOperation flowOrchestratedBy)	Orchestrated control operation that ran these data flows (process).
B	input(ICatalog input)
B	inputs(Collection<? extends ICatalog> inputs)
B	matillionComponent(IMatillionComponent matillionComponent)	Matillion component that contains the logic for this lineage process.
B	output(ICatalog output)
B	outputs(Collection<? extends ICatalog> outputs)
B	parentConnectionProcessQualifiedName(String parentConnectionProcessQualifiedName)
B	parentConnectionProcessQualifiedNames(Collection<? extends String> parentConnectionProcessQualifiedNames)
B	powerBIDataflow(IPowerBIDataflow powerBIDataflow)	PowerBI Dataflow that is associated with this lineage process.
B	process(ILineageProcess process)	Process in which this task exists.
protected abstract B	self()
B	sparkJob(ISparkJob sparkJob)
B	sparkJobs(Collection<? extends ISparkJob> sparkJobs)
B	sql(String sql)	SQL query that ran to produce the outputs.
B	sqlProcedure(IProcedure sqlProcedure)
B	sqlProcedures(Collection<? extends IProcedure> sqlProcedures)
String	toString()
B	typeName(String typeName)	Fixed typeName for ColumnProcesss.

Methods inherited from class com.atlan.model.assets.Asset.AssetBuilder

addStarredBy, adminGroup, adminGroups, adminRole, adminRoles, adminUser, adminUsers, announcementMessage, announcementTitle, announcementType, announcementUpdatedAt, announcementUpdatedBy, anomaloCheck, anomaloChecks, appendAssignedTerm, appendAtlanTag, appendAtlanTag, appendAtlanTags, appendAtlanTags, application, applicationField, applicationFieldQualifiedName, applicationQualifiedName, assetAnomaloAppliedCheckType, assetAnomaloAppliedCheckTypes, assetAnomaloCheckCount, assetAnomaloCheckStatuses, assetAnomaloDQStatus, assetAnomaloFailedCheckCount, assetAnomaloFailedCheckType, assetAnomaloFailedCheckTypes, assetAnomaloLastCheckRunAt, assetAnomaloSourceUrl, assetCoverImage, assetDbtAccountName, assetDbtAlias, assetDbtEnvironmentDbtVersion, assetDbtEnvironmentName, assetDbtJobLastRun, assetDbtJobLastRunArtifactS3Path, assetDbtJobLastRunArtifactsSaved, assetDbtJobLastRunCreatedAt, assetDbtJobLastRunDequedAt, assetDbtJobLastRunExecutedByThreadId, assetDbtJobLastRunGitBranch, assetDbtJobLastRunGitSha, assetDbtJobLastRunHasDocsGenerated, assetDbtJobLastRunHasSourcesGenerated, assetDbtJobLastRunNotificationsSent, assetDbtJobLastRunOwnerThreadId, assetDbtJobLastRunQueuedDuration, assetDbtJobLastRunQueuedDurationHumanized, assetDbtJobLastRunRunDuration, assetDbtJobLastRunRunDurationHumanized, assetDbtJobLastRunStartedAt, assetDbtJobLastRunStatusMessage, assetDbtJobLastRunTotalDuration, assetDbtJobLastRunTotalDurationHumanized, assetDbtJobLastRunUpdatedAt, assetDbtJobLastRunUrl, assetDbtJobName, assetDbtJobNextRun, assetDbtJobNextRunHumanized, assetDbtJobSchedule, assetDbtJobScheduleCronHumanized, assetDbtJobStatus, assetDbtMeta, assetDbtPackageName, assetDbtProjectName, assetDbtSemanticLayerProxyUrl, assetDbtSourceFreshnessCriteria, assetDbtTag, assetDbtTags, assetDbtTestStatus, assetDbtUniqueId, assetDbtWorkflowLastUpdated, assetDQFreshnessExpectation, assetDQFreshnessValue, assetDQResult, assetDQRowScopeFilterColumnQualifiedName, assetDQRuleAttachedDimension, assetDQRuleAttachedDimensions, assetDQRuleAttachedRuleType, assetDQRuleAttachedRuleTypes, assetDQRuleFailedCount, assetDQRuleFailedDimension, assetDQRuleFailedDimensions, assetDQRuleFailedRuleType, assetDQRuleFailedRuleTypes, assetDQRuleLastRunAt, assetDQRulePassedCount, assetDQRulePassedDimension, assetDQRulePassedDimensions, assetDQRulePassedRuleType, assetDQRulePassedRuleTypes, assetDQRuleResultTag, assetDQRuleResultTags, assetDQRuleTotalCount, assetDQScheduleCrontab, assetDQScheduleSourceSyncedAt, assetDQScheduleSourceSyncErrorCode, assetDQScheduleSourceSyncErrorMessage, assetDQScheduleSourceSyncRawError, assetDQScheduleSourceSyncStatus, assetDQScheduleTimeZone, assetDQScheduleType, assetIcon, assetInternalPopularityScore, assetMcAlertQualifiedName, assetMcAlertQualifiedNames, assetMcIncidentName, assetMcIncidentNames, assetMcIncidentPriorities, assetMcIncidentPriority, assetMcIncidentQualifiedName, assetMcIncidentQualifiedNames, assetMcIncidentSeverities, assetMcIncidentSeverity, assetMcIncidentState, assetMcIncidentStates, assetMcIncidentSubType, assetMcIncidentSubTypes, assetMcIncidentType, assetMcIncidentTypes, assetMcIsMonitored, assetMcLastSyncRunAt, assetMcMonitorName, assetMcMonitorNames, assetMcMonitorQualifiedName, assetMcMonitorQualifiedNames, assetMcMonitorScheduleType, assetMcMonitorScheduleTypes, assetMcMonitorStatus, assetMcMonitorStatuses, assetMcMonitorType, assetMcMonitorTypes, assetPoliciesCount, assetPolicyGUID, assetPolicyGUIDs, assetRedirectGUID, assetRedirectGUIDs, assetSodaCheckCount, assetSodaCheckStatuses, assetSodaDQStatus, assetSodaLastScanAt, assetSodaLastSyncRunAt, assetSodaSourceURL, assetSourceReadme, assetSpaceName, assetSpaceQualifiedName, assetTag, assetTags, assetThemeHex, assetUserDefinedType, assignedTerm, assignedTerms, atlanTag, atlanTagName, atlanTagNames, atlanTags, certificateStatus, certificateStatusMessage, certificateUpdatedAt, certificateUpdatedBy, clearAdminGroups, clearAdminRoles, clearAdminUsers, clearAnomaloChecks, clearAssetAnomaloAppliedCheckTypes, clearAssetAnomaloFailedCheckTypes, clearAssetDbtTags, clearAssetDQRuleAttachedDimensions, clearAssetDQRuleAttachedRuleTypes, clearAssetDQRuleFailedDimensions, clearAssetDQRuleFailedRuleTypes, clearAssetDQRulePassedDimensions, clearAssetDQRulePassedRuleTypes, clearAssetDQRuleResultTags, clearAssetMcAlertQualifiedNames, clearAssetMcIncidentNames, clearAssetMcIncidentPriorities, clearAssetMcIncidentQualifiedNames, clearAssetMcIncidentSeverities, clearAssetMcIncidentStates, clearAssetMcIncidentSubTypes, clearAssetMcIncidentTypes, clearAssetMcMonitorNames, clearAssetMcMonitorQualifiedNames, clearAssetMcMonitorScheduleTypes, clearAssetMcMonitorStatuses, clearAssetMcMonitorTypes, clearAssetPolicyGUIDs, clearAssetRedirectGUIDs, clearAssetTags, clearAssignedTerms, clearAtlanTagNames, clearAtlanTags, clearCustomMetadataSets, clearDomainGUIDs, clearDqBaseDatasetRules, clearDqReferenceDatasetRules, clearFiles, clearInputPortDataProducts, clearLinks, clearMcIncidents, clearMcMonitors, clearMeaningNames, clearMeanings, clearMetrics, clearNonCompliantAssetPolicyGUIDs, clearNullFields, clearOutputPortDataProducts, clearOutputProductGUIDs, clearOwnerGroups, clearOwnerUsers, clearPendingTasks, clearProductGUIDs, clearSchemaRegistrySubjects, clearSodaChecks, clearSourceQueryComputeCostRecords, clearSourceQueryComputeCosts, clearSourceReadExpensiveQueryRecords, clearSourceReadPopularQueryRecords, clearSourceReadRecentUserRecords, clearSourceReadRecentUsers, clearSourceReadSlowQueryRecords, clearSourceReadTopUserRecords, clearSourceReadTopUsers, clearStarredBy, clearStarredDetails, clearUserDefRelationshipFroms, clearUserDefRelationshipTos, clearViewerGroups, clearViewerUsers, connectionName, connectionQualifiedName, connectorName, connectorType, createdBy, createTime, customConnectorType, customMetadata, customMetadataSets, dataContractLatest, dataContractLatestCertified, dbtQualifiedName, deleteHandler, depth, description, displayName, domainGUID, domainGUIDs, dqBaseDatasetRule, dqBaseDatasetRules, dqReferenceDatasetRule, dqReferenceDatasetRules, file, files, hasContract, hasLineage, iconUrl, immediateDownstream, immediateUpstream, inputPortDataProduct, inputPortDataProducts, isAIGenerated, isDiscoverable, isEditable, isIncomplete, isPartial, lastRowChangedAt, lastSyncRun, lastSyncRunAt, lastSyncWorkflowName, lexicographicalSortOrder, link, links, mcIncident, mcIncidents, mcMonitor, mcMonitors, meaning, meaningName, meaningNames, meanings, metric, metrics, name, nonCompliantAssetPolicyGUID, nonCompliantAssetPolicyGUIDs, nullField, nullFields, outputPortDataProduct, outputPortDataProducts, outputProductGUID, outputProductGUIDs, ownerGroup, ownerGroups, ownerUser, ownerUsers, pendingTask, pendingTasks, popularityScore, productGUID, productGUIDs, qualifiedName, readme, removeAnnouncement, removeAssignedTerm, removeAssignedTerms, removeAtlanTag, removeAtlanTags, removeAtlanTags, removeCertificate, removeCustomMetadata, removeDescription, removeOwners, removeUserDescription, sampleDataUrl, schemaRegistrySubject, schemaRegistrySubjects, sodaCheck, sodaChecks, sourceCostUnit, sourceCreatedAt, sourceCreatedBy, sourceEmbedURL, sourceLastReadAt, sourceOwners, sourceQueryComputeCost, sourceQueryComputeCostRecord, sourceQueryComputeCostRecords, sourceQueryComputeCosts, sourceReadCount, sourceReadExpensiveQueryRecord, sourceReadExpensiveQueryRecords, sourceReadPopularQueryRecord, sourceReadPopularQueryRecords, sourceReadQueryCost, sourceReadRecentUser, sourceReadRecentUserRecord, sourceReadRecentUserRecords, sourceReadRecentUsers, sourceReadSlowQueryRecord, sourceReadSlowQueryRecords, sourceReadTopUser, sourceReadTopUserRecord, sourceReadTopUserRecords, sourceReadTopUsers, sourceReadUserCount, sourceTotalCost, sourceUpdatedAt, sourceUpdatedBy, sourceURL, starredBy, starredCount, starredDetail, starredDetails, status, subType, tenantId, updatedBy, updateTime, userDefRelationshipFrom, userDefRelationshipFroms, userDefRelationshipTo, userDefRelationshipTos, userDescription, viewerGroup, viewerGroups, viewerUser, viewerUsers, viewScore

Methods inherited from class com.atlan.model.relations.Reference.ReferenceBuilder

clearCustomAttributes, clearLabels, completeObject, customAttribute, customAttributes, displayText, entityStatus, guid, label, labels, relationshipAttributes, relationshipGuid, relationshipStatus, relationshipType, semantic, uniqueAttributes

Methods inherited from class com.atlan.model.core.AtlanObject.AtlanObjectBuilder

rawJsonObject

Methods inherited from class java.lang.Object

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

Constructor Details

ColumnProcessBuilder

public ColumnProcessBuilder()

Method Details

$fillValuesFrom

protected B $fillValuesFrom(C instance)

Overrides:

$fillValuesFrom in class Asset.AssetBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>

typeName

public B typeName(String typeName)

Fixed typeName for ColumnProcesss.

Overrides:

typeName in class Reference.ReferenceBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>

Returns:

this.

additionalEtlContext

public B additionalEtlContext(String additionalEtlContext)

Additional Context of the ETL pipeline/notebook which creates the process.

Returns:

this.

adfActivity

public B adfActivity(IAdfActivity adfActivity)

ADF Activity that is associated with this lineage process.

Returns:

this.

aiDatasetType

public B aiDatasetType(AIDatasetType aiDatasetType)

Dataset type for AI Model - dataset process.

Returns:

this.

airflowTask

public B airflowTask(IAirflowTask airflowTask)

airflowTasks

public B airflowTasks(Collection<? extends IAirflowTask> airflowTasks)

clearAirflowTasks

public B clearAirflowTasks()

ast

public B ast(String ast)

Parsed AST of the code or SQL statements that describe the logic of this process.

Returns:

this.

bigqueryRoutine

public B bigqueryRoutine(IBigqueryRoutine bigqueryRoutine)

bigqueryRoutines

public B bigqueryRoutines(Collection<? extends IBigqueryRoutine> bigqueryRoutines)

clearBigqueryRoutines

public B clearBigqueryRoutines()

code

public B code(String code)

Code that ran within the process.

Returns:

this.

columnProcess

public B columnProcess(IColumnProcess columnProcess)

columnProcesses

public B columnProcesses(Collection<? extends IColumnProcess> columnProcesses)

clearColumnProcesses

public B clearColumnProcesses()

fabricActivity

public B fabricActivity(IFabricActivity fabricActivity)

fabricActivities

public B fabricActivities(Collection<? extends IFabricActivity> fabricActivities)

clearFabricActivities

public B clearFabricActivities()

fivetranConnector

public B fivetranConnector(IFivetranConnector fivetranConnector)

fivetranConnector in which this process exists.

Returns:

this.

flowOrchestratedBy

public B flowOrchestratedBy(IFlowControlOperation flowOrchestratedBy)

Orchestrated control operation that ran these data flows (process).

Returns:

this.

input

public B input(ICatalog input)

inputs

public B inputs(Collection<? extends ICatalog> inputs)

clearInputs

public B clearInputs()

matillionComponent

public B matillionComponent(IMatillionComponent matillionComponent)

Matillion component that contains the logic for this lineage process.

Returns:

this.

output

public B output(ICatalog output)

outputs

public B outputs(Collection<? extends ICatalog> outputs)

clearOutputs

public B clearOutputs()

parentConnectionProcessQualifiedName

public B parentConnectionProcessQualifiedName(String parentConnectionProcessQualifiedName)

parentConnectionProcessQualifiedNames

public B parentConnectionProcessQualifiedNames(Collection<? extends String> parentConnectionProcessQualifiedNames)

clearParentConnectionProcessQualifiedNames

public B clearParentConnectionProcessQualifiedNames()

powerBIDataflow

public B powerBIDataflow(IPowerBIDataflow powerBIDataflow)

PowerBI Dataflow that is associated with this lineage process.

Returns:

this.

process

public B process(ILineageProcess process)

Process in which this task exists.

Returns:

this.

sparkJob

public B sparkJob(ISparkJob sparkJob)

sparkJobs

public B sparkJobs(Collection<? extends ISparkJob> sparkJobs)

clearSparkJobs

public B clearSparkJobs()

sql

public B sql(String sql)

SQL query that ran to produce the outputs.

Returns:

this.

sqlProcedure

public B sqlProcedure(IProcedure sqlProcedure)

sqlProcedures

public B sqlProcedures(Collection<? extends IProcedure> sqlProcedures)

clearSqlProcedures

public B clearSqlProcedures()

self

protected abstract B self()

Specified by:

self in class Asset.AssetBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>

build

public abstract C build()

Specified by:

build in class Asset.AssetBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>

toString

public String toString()

Overrides:

toString in class Asset.AssetBuilder<C extends ColumnProcess,B extends ColumnProcess.ColumnProcessBuilder<C,B>>