Package com.atlan.model.assets

Class AtlanQuery.AtlanQueryBuilder<C extends AtlanQuery,B extends AtlanQuery.AtlanQueryBuilder<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.AtlanQuery.AtlanQueryBuilder<C,B>

Enclosing class:

AtlanQuery

public abstract static class AtlanQuery.AtlanQueryBuilder<C extends AtlanQuery,B extends AtlanQuery.AtlanQueryBuilder<C,B>>
extends Asset.AssetBuilder<C,B>

Constructor Summary

Constructors

Constructor	Description
AtlanQueryBuilder()

Method Summary

Modifier and Type	Method	Description
protected B	$fillValuesFrom(C instance)
B	applicationContainer(IApplicationContainer applicationContainer)	TBC
B	assetApplicationQualifiedName(String assetApplicationQualifiedName)	TBC
abstract C	build()
B	calculationViewName(String calculationViewName)	TBC
B	calculationViewQualifiedName(String calculationViewQualifiedName)	TBC
B	clearColumns()
B	clearDbtModels()
B	clearDbtSources()
B	clearDbtTests()
B	clearInputToAirflowTasks()
B	clearInputToProcesses()
B	clearInputToSparkJobs()
B	clearModelImplementedEntities()
B	clearOutputFromAirflowTasks()
B	clearOutputFromProcesses()
B	clearOutputFromSparkJobs()
B	clearQueryUserMap()
B	clearSqlDbtModels()
B	clearSqlDBTSources()
B	clearTables()
B	clearViews()
B	collectionQualifiedName(String collectionQualifiedName)	TBC
B	column(IColumn column)
B	columns(Collection<? extends IColumn> columns)
B	databaseName(String databaseName)	TBC
B	databaseQualifiedName(String databaseQualifiedName)	TBC
B	dbtModel(IDbtModel dbtModel)
B	dbtModels(Collection<? extends IDbtModel> dbtModels)
B	dbtSource(IDbtSource dbtSource)
B	dbtSources(Collection<? extends IDbtSource> dbtSources)
B	dbtTest(IDbtTest dbtTest)
B	dbtTests(Collection<? extends IDbtTest> dbtTests)
B	defaultDatabaseQualifiedName(String defaultDatabaseQualifiedName)	TBC
B	defaultSchemaQualifiedName(String defaultSchemaQualifiedName)	TBC
B	inputToAirflowTask(IAirflowTask inputToAirflowTask)
B	inputToAirflowTasks(Collection<? extends IAirflowTask> inputToAirflowTasks)
B	inputToProcess(ILineageProcess inputToProcess)
B	inputToProcesses(Collection<? extends ILineageProcess> inputToProcesses)
B	inputToSparkJob(ISparkJob inputToSparkJob)
B	inputToSparkJobs(Collection<? extends ISparkJob> inputToSparkJobs)
B	isPrivate(Boolean isPrivate)	TBC
B	isProfiled(Boolean isProfiled)	TBC
B	isSqlSnippet(Boolean isSqlSnippet)	TBC
B	isVisualQuery(Boolean isVisualQuery)	TBC
B	lastProfiledAt(Long lastProfiledAt)	TBC
B	longRawQuery(String longRawQuery)	TBC
B	modelImplementedEntities(Collection<? extends IModelEntity> modelImplementedEntities)
B	modelImplementedEntity(IModelEntity modelImplementedEntity)
B	outputFromAirflowTask(IAirflowTask outputFromAirflowTask)
B	outputFromAirflowTasks(Collection<? extends IAirflowTask> outputFromAirflowTasks)
B	outputFromProcess(ILineageProcess outputFromProcess)
B	outputFromProcesses(Collection<? extends ILineageProcess> outputFromProcesses)
B	outputFromSparkJob(ISparkJob outputFromSparkJob)
B	outputFromSparkJobs(Collection<? extends ISparkJob> outputFromSparkJobs)
B	parent(INamespace parent)	TBC
B	parentQualifiedName(String parentQualifiedName)	TBC
B	putQueryUserMap(String putQueryUserMapKey, Long putQueryUserMapValue)
B	queryCount(Long queryCount)	TBC
B	queryCountUpdatedAt(Long queryCountUpdatedAt)	TBC
B	queryUserCount(Long queryUserCount)	TBC
B	queryUserMap(Map<? extends String,? extends Long> queryUserMap)
B	rawQuery(String rawQuery)	TBC
B	rawQueryText(String rawQueryText)	TBC
B	schemaName(String schemaName)	TBC
B	schemaQualifiedName(String schemaQualifiedName)	TBC
protected abstract B	self()
B	sqlDbtModel(IDbtModel sqlDbtModel)
B	sqlDbtModels(Collection<? extends IDbtModel> sqlDbtModels)
B	sqlDBTSource(IDbtSource sqlDBTSource)
B	sqlDBTSources(Collection<? extends IDbtSource> sqlDBTSources)
B	table(ITable table)
B	tableName(String tableName)	TBC
B	tableQualifiedName(String tableQualifiedName)	TBC
B	tables(Collection<? extends ITable> tables)
String	toString()
B	typeName(String typeName)	Fixed typeName for AtlanQuerys.
B	variablesSchemaBase64(String variablesSchemaBase64)	TBC
B	view(IView view)
B	viewName(String viewName)	TBC
B	viewQualifiedName(String viewQualifiedName)	TBC
B	views(Collection<? extends IView> views)
B	visualBuilderSchemaBase64(String visualBuilderSchemaBase64)	TBC
B	withRawQuery(String schemaQualifiedName, String query)

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

addStarredBy, adminGroup, adminGroups, adminRole, adminRoles, adminUser, adminUsers, announcementMessage, announcementTitle, announcementType, announcementUpdatedAt, announcementUpdatedBy, anomaloCheck, anomaloChecks, 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, assetIcon, assetMcAlertQualifiedName, assetMcAlertQualifiedNames, assetMcIncidentName, assetMcIncidentNames, assetMcIncidentPriorities, assetMcIncidentPriority, assetMcIncidentQualifiedName, assetMcIncidentQualifiedNames, assetMcIncidentSeverities, assetMcIncidentSeverity, assetMcIncidentState, assetMcIncidentStates, assetMcIncidentSubType, assetMcIncidentSubTypes, assetMcIncidentType, assetMcIncidentTypes, assetMcLastSyncRunAt, assetMcMonitorName, assetMcMonitorNames, assetMcMonitorQualifiedName, assetMcMonitorQualifiedNames, assetMcMonitorScheduleType, assetMcMonitorScheduleTypes, assetMcMonitorStatus, assetMcMonitorStatuses, assetMcMonitorType, assetMcMonitorTypes, assetPoliciesCount, assetPolicyGUID, assetPolicyGUIDs, assetSodaCheckCount, assetSodaCheckStatuses, assetSodaDQStatus, assetSodaLastScanAt, assetSodaLastSyncRunAt, assetSodaSourceURL, assetTag, assetTags, assetThemeHex, assignedTerm, assignedTerms, atlanTag, atlanTagName, atlanTagNames, atlanTags, certificateStatus, certificateStatusMessage, certificateUpdatedAt, certificateUpdatedBy, clearAdminGroups, clearAdminRoles, clearAdminUsers, clearAnomaloChecks, clearAssetAnomaloAppliedCheckTypes, clearAssetAnomaloFailedCheckTypes, clearAssetDbtTags, clearAssetMcAlertQualifiedNames, clearAssetMcIncidentNames, clearAssetMcIncidentPriorities, clearAssetMcIncidentQualifiedNames, clearAssetMcIncidentSeverities, clearAssetMcIncidentStates, clearAssetMcIncidentSubTypes, clearAssetMcIncidentTypes, clearAssetMcMonitorNames, clearAssetMcMonitorQualifiedNames, clearAssetMcMonitorScheduleTypes, clearAssetMcMonitorStatuses, clearAssetMcMonitorTypes, clearAssetPolicyGUIDs, clearAssetTags, clearAssignedTerms, clearAtlanTagNames, clearAtlanTags, clearCustomMetadataSets, clearDomainGUIDs, clearFiles, clearInputPortDataProducts, clearLinks, clearMcIncidents, clearMcMonitors, clearMeaningNames, clearMeanings, clearMetrics, clearNonCompliantAssetPolicyGUIDs, clearNullFields, clearOutputPortDataProducts, clearOwnerGroups, clearOwnerUsers, clearPendingTasks, clearSchemaRegistrySubjects, clearSodaChecks, clearSourceQueryComputeCostRecords, clearSourceQueryComputeCosts, clearSourceReadExpensiveQueryRecords, clearSourceReadPopularQueryRecords, clearSourceReadRecentUserRecords, clearSourceReadRecentUsers, clearSourceReadSlowQueryRecords, clearSourceReadTopUserRecords, clearSourceReadTopUsers, clearStarredBy, clearStarredDetails, clearUserDefRelationshipFroms, clearUserDefRelationshipTos, clearViewerGroups, clearViewerUsers, connectionName, connectionQualifiedName, connectorType, createdBy, createTime, customMetadata, customMetadataSets, dataContractLatest, dataContractLatestCertified, dbtQualifiedName, deleteHandler, depth, description, displayName, domainGUID, domainGUIDs, file, files, hasContract, hasLineage, 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, ownerGroup, ownerGroups, ownerUser, ownerUsers, pendingTask, pendingTasks, popularityScore, qualifiedName, readme, removeAnnouncement, removeAssignedTerms, 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

AtlanQueryBuilder

public AtlanQueryBuilder()

Method Details

withRawQuery

public B withRawQuery(String schemaQualifiedName,
 String query)

$fillValuesFrom

protected B $fillValuesFrom(C instance)

Overrides:

$fillValuesFrom in class Asset.AssetBuilder<C extends AtlanQuery,B extends AtlanQuery.AtlanQueryBuilder<C,B>>

typeName

public B typeName(String typeName)

Fixed typeName for AtlanQuerys.

Overrides:

typeName in class Reference.ReferenceBuilder<C extends AtlanQuery,B extends AtlanQuery.AtlanQueryBuilder<C,B>>

Returns:

this.

applicationContainer

public B applicationContainer(IApplicationContainer applicationContainer)

TBC

Returns:

this.

assetApplicationQualifiedName

public B assetApplicationQualifiedName(String assetApplicationQualifiedName)

TBC

Returns:

this.

calculationViewName

public B calculationViewName(String calculationViewName)

TBC

Returns:

this.

calculationViewQualifiedName

public B calculationViewQualifiedName(String calculationViewQualifiedName)

TBC

Returns:

this.

collectionQualifiedName

public B collectionQualifiedName(String collectionQualifiedName)

TBC

Returns:

this.

column

public B column(IColumn column)

columns

public B columns(Collection<? extends IColumn> columns)

clearColumns

public B clearColumns()

databaseName

public B databaseName(String databaseName)

TBC

Returns:

this.

databaseQualifiedName

public B databaseQualifiedName(String databaseQualifiedName)

TBC

Returns:

this.

dbtModel

public B dbtModel(IDbtModel dbtModel)

dbtModels

public B dbtModels(Collection<? extends IDbtModel> dbtModels)

clearDbtModels

public B clearDbtModels()

dbtSource

public B dbtSource(IDbtSource dbtSource)

dbtSources

public B dbtSources(Collection<? extends IDbtSource> dbtSources)

clearDbtSources

public B clearDbtSources()

dbtTest

public B dbtTest(IDbtTest dbtTest)

dbtTests

public B dbtTests(Collection<? extends IDbtTest> dbtTests)

clearDbtTests

public B clearDbtTests()

defaultDatabaseQualifiedName

public B defaultDatabaseQualifiedName(String defaultDatabaseQualifiedName)

TBC

Returns:

this.

defaultSchemaQualifiedName

public B defaultSchemaQualifiedName(String defaultSchemaQualifiedName)

TBC

Returns:

this.

inputToAirflowTask

public B inputToAirflowTask(IAirflowTask inputToAirflowTask)

inputToAirflowTasks

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

clearInputToAirflowTasks

public B clearInputToAirflowTasks()

inputToProcess

public B inputToProcess(ILineageProcess inputToProcess)

inputToProcesses

public B inputToProcesses(Collection<? extends ILineageProcess> inputToProcesses)

clearInputToProcesses

public B clearInputToProcesses()

inputToSparkJob

public B inputToSparkJob(ISparkJob inputToSparkJob)

inputToSparkJobs

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

clearInputToSparkJobs

public B clearInputToSparkJobs()

isPrivate

public B isPrivate(Boolean isPrivate)

TBC

Returns:

this.

isProfiled

public B isProfiled(Boolean isProfiled)

TBC

Returns:

this.

isSqlSnippet

public B isSqlSnippet(Boolean isSqlSnippet)

TBC

Returns:

this.

isVisualQuery

public B isVisualQuery(Boolean isVisualQuery)

TBC

Returns:

this.

lastProfiledAt

public B lastProfiledAt(Long lastProfiledAt)

TBC

Returns:

this.

longRawQuery

public B longRawQuery(String longRawQuery)

TBC

Returns:

this.

modelImplementedEntity

public B modelImplementedEntity(IModelEntity modelImplementedEntity)

modelImplementedEntities

public B modelImplementedEntities(Collection<? extends IModelEntity> modelImplementedEntities)

clearModelImplementedEntities

public B clearModelImplementedEntities()

outputFromAirflowTask

public B outputFromAirflowTask(IAirflowTask outputFromAirflowTask)

outputFromAirflowTasks

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

clearOutputFromAirflowTasks

public B clearOutputFromAirflowTasks()

outputFromProcess

public B outputFromProcess(ILineageProcess outputFromProcess)

outputFromProcesses

public B outputFromProcesses(Collection<? extends ILineageProcess> outputFromProcesses)

clearOutputFromProcesses

public B clearOutputFromProcesses()

outputFromSparkJob

public B outputFromSparkJob(ISparkJob outputFromSparkJob)

outputFromSparkJobs

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

clearOutputFromSparkJobs

public B clearOutputFromSparkJobs()

parent

public B parent(INamespace parent)

TBC

Returns:

this.

parentQualifiedName

public B parentQualifiedName(String parentQualifiedName)

TBC

Returns:

this.

queryCount

public B queryCount(Long queryCount)

TBC

Returns:

this.

queryCountUpdatedAt

public B queryCountUpdatedAt(Long queryCountUpdatedAt)

TBC

Returns:

this.

queryUserCount

public B queryUserCount(Long queryUserCount)

TBC

Returns:

this.

putQueryUserMap

public B putQueryUserMap(String putQueryUserMapKey,
 Long putQueryUserMapValue)

queryUserMap

public B queryUserMap(Map<? extends String,? extends Long> queryUserMap)

clearQueryUserMap

public B clearQueryUserMap()

rawQuery

public B rawQuery(String rawQuery)

TBC

Returns:

this.

rawQueryText

public B rawQueryText(String rawQueryText)

TBC

Returns:

this.

schemaName

public B schemaName(String schemaName)

TBC

Returns:

this.

schemaQualifiedName

public B schemaQualifiedName(String schemaQualifiedName)

TBC

Returns:

this.

sqlDBTSource

public B sqlDBTSource(IDbtSource sqlDBTSource)

sqlDBTSources

public B sqlDBTSources(Collection<? extends IDbtSource> sqlDBTSources)

clearSqlDBTSources

public B clearSqlDBTSources()

sqlDbtModel

public B sqlDbtModel(IDbtModel sqlDbtModel)

sqlDbtModels

public B sqlDbtModels(Collection<? extends IDbtModel> sqlDbtModels)

clearSqlDbtModels

public B clearSqlDbtModels()

tableName

public B tableName(String tableName)

TBC

Returns:

this.

tableQualifiedName

public B tableQualifiedName(String tableQualifiedName)

TBC

Returns:

this.

table

public B table(ITable table)

tables

public B tables(Collection<? extends ITable> tables)

clearTables

public B clearTables()

variablesSchemaBase64

public B variablesSchemaBase64(String variablesSchemaBase64)

TBC

Returns:

this.

viewName

public B viewName(String viewName)

TBC

Returns:

this.

viewQualifiedName

public B viewQualifiedName(String viewQualifiedName)

TBC

Returns:

this.

view

public B view(IView view)

views

public B views(Collection<? extends IView> views)

clearViews

public B clearViews()

visualBuilderSchemaBase64

public B visualBuilderSchemaBase64(String visualBuilderSchemaBase64)

TBC

Returns:

this.

self

protected abstract B self()

Specified by:

self in class Asset.AssetBuilder<C extends AtlanQuery,B extends AtlanQuery.AtlanQueryBuilder<C,B>>

build

public abstract C build()

Specified by:

build in class Asset.AssetBuilder<C extends AtlanQuery,B extends AtlanQuery.AtlanQueryBuilder<C,B>>

toString

public String toString()

Overrides:

toString in class Asset.AssetBuilder<C extends AtlanQuery,B extends AtlanQuery.AtlanQueryBuilder<C,B>>