Package com.atlan.model.assets

Class FlowFieldOperation

java.lang.Object

com.atlan.model.core.AtlanObject

com.atlan.model.relations.Reference

com.atlan.model.assets.Asset

com.atlan.model.assets.FlowFieldOperation

All Implemented Interfaces:

IAsset, IColumnProcess, IFlow, IFlowFieldOperation, ILineageProcess, IReferenceable, AuditDetail, Serializable, Comparable<Reference>

@Generated("com.atlan.generators.ModelGeneratorV2")
public class FlowFieldOperation
extends Asset
implements IFlowFieldOperation, IColumnProcess, IFlow, ILineageProcess, IAsset, IReferenceable

A nested field-level operation that uses at least one ephemeral field as either an input or output.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FlowFieldOperation.FlowFieldOperationBuilder<C extends FlowFieldOperation,B extends FlowFieldOperation.FlowFieldOperationBuilder<C,B>>

Nested classes/interfaces inherited from class com.atlan.model.assets.Asset

Asset.AssetBuilder<C extends Asset,B extends Asset.AssetBuilder<C,B>>

Nested classes/interfaces inherited from class com.atlan.model.relations.Reference

Reference.ReferenceBuilder<C extends Reference,B extends Reference.ReferenceBuilder<C,B>>, Reference.SaveSemantic

Nested classes/interfaces inherited from class com.atlan.model.core.AtlanObject

AtlanObject.AtlanObjectBuilder<C extends AtlanObject,B extends AtlanObject.AtlanObjectBuilder<C,B>>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TYPE_NAME

Fields inherited from class com.atlan.model.core.AtlanObject

rawJsonObject

Fields inherited from interface com.atlan.model.assets.IAsset

ADMIN_GROUPS, ADMIN_ROLES, ADMIN_USERS, ANNOUNCEMENT_MESSAGE, ANNOUNCEMENT_TITLE, ANNOUNCEMENT_TYPE, ANNOUNCEMENT_UPDATED_AT, ANNOUNCEMENT_UPDATED_BY, ANOMALO_CHECKS, APPLICATION, APPLICATION_FIELD, APPLICATION_FIELD_QUALIFIED_NAME, APPLICATION_QUALIFIED_NAME, ASSET_ANOMALO_APPLIED_CHECK_TYPES, ASSET_ANOMALO_CHECK_COUNT, ASSET_ANOMALO_CHECK_STATUSES, ASSET_ANOMALO_DQ_STATUS, ASSET_ANOMALO_FAILED_CHECK_COUNT, ASSET_ANOMALO_FAILED_CHECK_TYPES, ASSET_ANOMALO_LAST_CHECK_RUN_AT, ASSET_ANOMALO_SOURCE_URL, ASSET_COVER_IMAGE, ASSET_DBT_ACCOUNT_NAME, ASSET_DBT_ALIAS, ASSET_DBT_ENVIRONMENT_DBT_VERSION, ASSET_DBT_ENVIRONMENT_NAME, ASSET_DBT_JOB_LAST_RUN, ASSET_DBT_JOB_LAST_RUN_ARTIFACT_S3PATH, ASSET_DBT_JOB_LAST_RUN_ARTIFACTS_SAVED, ASSET_DBT_JOB_LAST_RUN_CREATED_AT, ASSET_DBT_JOB_LAST_RUN_DEQUED_AT, ASSET_DBT_JOB_LAST_RUN_EXECUTED_BY_THREAD_ID, ASSET_DBT_JOB_LAST_RUN_GIT_BRANCH, ASSET_DBT_JOB_LAST_RUN_GIT_SHA, ASSET_DBT_JOB_LAST_RUN_HAS_DOCS_GENERATED, ASSET_DBT_JOB_LAST_RUN_HAS_SOURCES_GENERATED, ASSET_DBT_JOB_LAST_RUN_NOTIFICATIONS_SENT, ASSET_DBT_JOB_LAST_RUN_OWNER_THREAD_ID, ASSET_DBT_JOB_LAST_RUN_QUEUED_DURATION, ASSET_DBT_JOB_LAST_RUN_QUEUED_DURATION_HUMANIZED, ASSET_DBT_JOB_LAST_RUN_RUN_DURATION, ASSET_DBT_JOB_LAST_RUN_RUN_DURATION_HUMANIZED, ASSET_DBT_JOB_LAST_RUN_STARTED_AT, ASSET_DBT_JOB_LAST_RUN_STATUS_MESSAGE, ASSET_DBT_JOB_LAST_RUN_TOTAL_DURATION, ASSET_DBT_JOB_LAST_RUN_TOTAL_DURATION_HUMANIZED, ASSET_DBT_JOB_LAST_RUN_UPDATED_AT, ASSET_DBT_JOB_LAST_RUN_URL, ASSET_DBT_JOB_NAME, ASSET_DBT_JOB_NEXT_RUN, ASSET_DBT_JOB_NEXT_RUN_HUMANIZED, ASSET_DBT_JOB_SCHEDULE, ASSET_DBT_JOB_SCHEDULE_CRON_HUMANIZED, ASSET_DBT_JOB_STATUS, ASSET_DBT_META, ASSET_DBT_PACKAGE_NAME, ASSET_DBT_PROJECT_NAME, ASSET_DBT_SEMANTIC_LAYER_PROXY_URL, ASSET_DBT_SOURCE_FRESHNESS_CRITERIA, ASSET_DBT_TAGS, ASSET_DBT_TEST_STATUS, ASSET_DBT_UNIQUE_ID, ASSET_DBT_WORKFLOW_LAST_UPDATED, ASSET_ICON, ASSET_INTERNAL_POPULARITY_SCORE, ASSET_MC_ALERT_QUALIFIED_NAMES, ASSET_MC_INCIDENT_NAMES, ASSET_MC_INCIDENT_PRIORITIES, ASSET_MC_INCIDENT_QUALIFIED_NAMES, ASSET_MC_INCIDENT_SEVERITIES, ASSET_MC_INCIDENT_STATES, ASSET_MC_INCIDENT_SUB_TYPES, ASSET_MC_INCIDENT_TYPES, ASSET_MC_IS_MONITORED, ASSET_MC_LAST_SYNC_RUN_AT, ASSET_MC_MONITOR_NAMES, ASSET_MC_MONITOR_QUALIFIED_NAMES, ASSET_MC_MONITOR_SCHEDULE_TYPES, ASSET_MC_MONITOR_STATUSES, ASSET_MC_MONITOR_TYPES, ASSET_POLICIES_COUNT, ASSET_POLICY_GUIDS, ASSET_REDIRECT_GUIDS, ASSET_SODA_CHECK_COUNT, ASSET_SODA_CHECK_STATUSES, ASSET_SODA_DQ_STATUS, ASSET_SODA_LAST_SCAN_AT, ASSET_SODA_LAST_SYNC_RUN_AT, ASSET_SODA_SOURCE_URL, ASSET_SOURCE_README, ASSET_TAGS, ASSET_THEME_HEX, ASSET_USER_DEFINED_TYPE, CERTIFICATE_STATUS, CERTIFICATE_STATUS_MESSAGE, CERTIFICATE_UPDATED_AT, CERTIFICATE_UPDATED_BY, CONNECTION_NAME, CONNECTION_QUALIFIED_NAME, CONNECTOR_NAME, CONNECTOR_TYPE, CUSTOM_CONNECTOR_TYPE, DATA_CONTRACT_LATEST, DATA_CONTRACT_LATEST_CERTIFIED, DBT_QUALIFIED_NAME, DESCRIPTION, DISPLAY_NAME, DOMAIN_GUIDS, FILES, HAS_CONTRACT, HAS_LINEAGE, INPUT_PORT_DATA_PRODUCTS, IS_AI_GENERATED, IS_DISCOVERABLE, IS_EDITABLE, IS_PARTIAL, LAST_ROW_CHANGED_AT, LAST_SYNC_RUN, LAST_SYNC_RUN_AT, LAST_SYNC_WORKFLOW_NAME, LEXICOGRAPHICAL_SORT_ORDER, LINKS, MC_INCIDENTS, MC_MONITORS, METRICS, NAME, NON_COMPLIANT_ASSET_POLICY_GUIDS, OUTPUT_PORT_DATA_PRODUCTS, OUTPUT_PRODUCT_GUIDS, OWNER_GROUPS, OWNER_USERS, POPULARITY_SCORE, PRODUCT_GUIDS, QUALIFIED_NAME, README, SAMPLE_DATA_URL, SCHEMA_REGISTRY_SUBJECTS, SODA_CHECKS, SOURCE_COST_UNIT, SOURCE_CREATED_AT, SOURCE_CREATED_BY, SOURCE_EMBED_URL, SOURCE_LAST_READ_AT, SOURCE_OWNERS, SOURCE_QUERY_COMPUTE_COST_RECORDS, SOURCE_QUERY_COMPUTE_COSTS, SOURCE_READ_COUNT, SOURCE_READ_EXPENSIVE_QUERY_RECORDS, SOURCE_READ_POPULAR_QUERY_RECORDS, SOURCE_READ_QUERY_COST, SOURCE_READ_RECENT_USER_RECORDS, SOURCE_READ_RECENT_USERS, SOURCE_READ_SLOW_QUERY_RECORDS, SOURCE_READ_TOP_USER_RECORDS, SOURCE_READ_TOP_USERS, SOURCE_READ_USER_COUNT, SOURCE_TOTAL_COST, SOURCE_UPDATED_AT, SOURCE_UPDATED_BY, SOURCE_URL, STARRED_BY, STARRED_COUNT, STARRED_DETAILS, SUB_TYPE, TENANT_ID, USER_DEF_RELATIONSHIP_FROMS, USER_DEF_RELATIONSHIP_TOS, USER_DESCRIPTION, VIEW_SCORE, VIEWER_GROUPS, VIEWER_USERS

Fields inherited from interface com.atlan.model.assets.IColumnProcess

PROCESS

Fields inherited from interface com.atlan.model.assets.IFlow

FLOW_ERROR_MESSAGE, FLOW_FINISHED_AT, FLOW_FOLDER_NAME, FLOW_FOLDER_QUALIFIED_NAME, FLOW_ID, FLOW_INPUT_PARAMETERS, FLOW_PROJECT_NAME, FLOW_PROJECT_QUALIFIED_NAME, FLOW_REUSABLE_UNIT_NAME, FLOW_REUSABLE_UNIT_QUALIFIED_NAME, FLOW_RUN_ID, FLOW_SCHEDULE, FLOW_STARTED_AT, FLOW_STATUS

Fields inherited from interface com.atlan.model.assets.ILineageProcess

ADDITIONAL_ETL_CONTEXT, ADF_ACTIVITY, AI_DATASET_TYPE, AIRFLOW_TASKS, AST, CODE, COLUMN_PROCESSES, FIVETRAN_CONNECTOR, FLOW_ORCHESTRATED_BY, INPUTS, MATILLION_COMPONENT, OUTPUTS, PARENT_CONNECTION_PROCESS_QUALIFIED_NAMES, POWER_BI_DATAFLOW, SPARK_JOBS, SQL

Fields inherited from interface com.atlan.model.assets.IReferenceable

ASSIGNED_TERMS, ATLAN_TAGS, CREATE_TIME, CREATED_BY, CUSTOM_ATTRIBUTES, GUID, PROPAGATED_ATLAN_TAGS, STATUS, SUPER_TYPE_NAMES, UPDATE_TIME, UPDATED_BY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FlowFieldOperation(FlowFieldOperation.FlowFieldOperationBuilder<?,?> b)

Method Summary

Modifier and Type	Method	Description
static FlowFieldOperation.FlowFieldOperationBuilder<?,?>	_internal()
static FlowFieldOperation	appendAtlanTags(AtlanClient client, String qualifiedName, List<String> atlanTagNames)	Deprecated. see Asset.AssetBuilder.appendAtlanTags(List)
static FlowFieldOperation	appendAtlanTags(AtlanClient client, String qualifiedName, List<String> atlanTagNames, boolean propagate, boolean removePropagationsOnDelete, boolean restrictLineagePropagation)	Deprecated. see Asset.AssetBuilder.appendAtlanTags(List, boolean, boolean, boolean, boolean)
static FlowFieldOperation	appendTerms(AtlanClient client, String qualifiedName, List<IGlossaryTerm> terms)	Deprecated. see Asset.AssetBuilder.appendAssignedTerm(GlossaryTerm)
protected boolean	canEqual(Object other)
boolean	equals(Object o)
static FlowFieldOperation	get(AtlanClient client, String id)	Retrieves a FlowFieldOperation by one of its identifiers, complete with all of its relationships.
static FlowFieldOperation	get(AtlanClient client, String id, boolean includeAllRelationships)	Retrieves a FlowFieldOperation by one of its identifiers, optionally complete with all of its relationships.
static FlowFieldOperation	get(AtlanClient client, String id, Collection<AtlanField> attributes)	Retrieves a FlowFieldOperation by one of its identifiers, with only the requested attributes (and relationships).
static FlowFieldOperation	get(AtlanClient client, String id, Collection<AtlanField> attributes, Collection<AtlanField> attributesOnRelated)	Retrieves a FlowFieldOperation by one of its identifiers, with only the requested attributes (and relationships).
String	getAdditionalEtlContext()	Additional Context of the ETL pipeline/notebook which creates the process.
IAdfActivity	getAdfActivity()	ADF Activity that is associated with this lineage process.
AIDatasetType	getAiDatasetType()	Dataset type for AI Model - dataset process.
SortedSet<IAirflowTask>	getAirflowTasks()	Tasks that exist within this process.
String	getAst()	Parsed AST of the code or SQL statements that describe the logic of this process.
String	getCode()	Code that ran within the process.
SortedSet<IColumnProcess>	getColumnProcesses()	Processes that detail column-level lineage for this process.
IFivetranConnector	getFivetranConnector()	fivetranConnector in which this process exists.
String	getFlowErrorMessage()	Optional error message of the flow run.
Long	getFlowFinishedAt()	Date and time at which this point in the data processing or orchestration finished.
String	getFlowFolderName()	Simple name of the folder in which this asset is contained.
String	getFlowFolderQualifiedName()	Unique name of the folder in which this asset is contained.
String	getFlowId()	Unique ID for this flow asset, which will remain constant throughout the lifecycle of the asset.
Map<String,String>	getFlowInputParameters()	Input parameters for the flow run.
IFlowControlOperation	getFlowOrchestratedBy()	Orchestrated control operation that ran these data flows (process).
String	getFlowProjectName()	Simple name of the project in which this asset is contained.
String	getFlowProjectQualifiedName()	Unique name of the project in which this asset is contained.
String	getFlowReusableUnitName()	Simple name of the reusable grouping of operations in which this ephemeral data is contained.
String	getFlowReusableUnitQualifiedName()	Unique name of the reusable grouping of operations in which this ephemeral data is contained.
String	getFlowRunId()	Unique ID of the flow run, which could change on subsequent runs of the same flow.
String	getFlowSchedule()	Schedule for this point in the data processing or orchestration.
Long	getFlowStartedAt()	Date and time at which this point in the data processing or orchestration started.
String	getFlowStatus()	Overall status of this point in the data processing or orchestration.
SortedSet<ICatalog>	getInputs()	Assets that are inputs to this process.
IMatillionComponent	getMatillionComponent()	Matillion component that contains the logic for this lineage process.
SortedSet<ICatalog>	getOutputs()	Assets that are outputs from this process.
SortedSet<String>	getParentConnectionProcessQualifiedNames()	TBC
IPowerBIDataflow	getPowerBIDataflow()	PowerBI Dataflow that is associated with this lineage process.
ILineageProcess	getProcess()	Process in which this task exists.
SortedSet<ISparkJob>	getSparkJobs()	TBC
String	getSql()	SQL query that ran to produce the outputs.
String	getTypeName()	Fixed typeName for FlowFieldOperations.
int	hashCode()
static FlowFieldOperation	refByGuid(String guid)	Reference to a FlowFieldOperation by GUID.
static FlowFieldOperation	refByGuid(String guid, Reference.SaveSemantic semantic)	Reference to a FlowFieldOperation by GUID.
static FlowFieldOperation	refByQualifiedName(String qualifiedName)	Reference to a FlowFieldOperation by qualifiedName.
static FlowFieldOperation	refByQualifiedName(String qualifiedName, Reference.SaveSemantic semantic)	Reference to a FlowFieldOperation by qualifiedName.
static FlowFieldOperation	removeAnnouncement(AtlanClient client, String qualifiedName, String name)	Remove the announcement from a FlowFieldOperation.
static void	removeAtlanTag(AtlanClient client, String qualifiedName, String atlanTagName)	Deprecated. see Asset.AssetBuilder.removeAtlanTag(String)
static FlowFieldOperation	removeCertificate(AtlanClient client, String qualifiedName, String name)	Remove the certificate from a FlowFieldOperation.
static FlowFieldOperation	removeDescription(AtlanClient client, String qualifiedName, String name)	Remove the system description from a FlowFieldOperation.
static FlowFieldOperation	removeOwners(AtlanClient client, String qualifiedName, String name)	Remove the owners from a FlowFieldOperation.
static FlowFieldOperation	removeTerms(AtlanClient client, String qualifiedName, List<IGlossaryTerm> terms)	Deprecated. see Asset.AssetBuilder.removeAssignedTerm(GlossaryTerm)
static FlowFieldOperation	removeUserDescription(AtlanClient client, String qualifiedName, String name)	Remove the user's description from a FlowFieldOperation.
static FlowFieldOperation	replaceTerms(AtlanClient client, String qualifiedName, String name, List<IGlossaryTerm> terms)	Replace the terms linked to the FlowFieldOperation.
static boolean	restore(AtlanClient client, String qualifiedName)	Restore the archived (soft-deleted) FlowFieldOperation to active.
static FluentSearch.FluentSearchBuilder<?,?>	select(AtlanClient client)	Start a fluent search that will return all FlowFieldOperation assets.
static FluentSearch.FluentSearchBuilder<?,?>	select(AtlanClient client, boolean includeArchived)	Start a fluent search that will return all FlowFieldOperation assets.
FlowFieldOperation.FlowFieldOperationBuilder<?,?>	toBuilder()
String	toString()
FlowFieldOperation	trimToReference()	Builds the minimal object necessary to create a relationship to a FlowFieldOperation, from a potentially more-complete FlowFieldOperation object.
FlowFieldOperation.FlowFieldOperationBuilder<?,?>	trimToRequired()	Builds the minimal object necessary to apply an update to a FlowFieldOperation, from a potentially more-complete FlowFieldOperation object.
static FlowFieldOperation	updateAnnouncement(AtlanClient client, String qualifiedName, AtlanAnnouncementType type, String title, String message)	Update the announcement on a FlowFieldOperation.
static FlowFieldOperation	updateCertificate(AtlanClient client, String qualifiedName, CertificateStatus certificate, String message)	Update the certificate on a FlowFieldOperation.
static FlowFieldOperation.FlowFieldOperationBuilder<?,?>	updater(String qualifiedName, String name)	Builds the minimal object necessary to update a FlowFieldOperation.

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

addApiTokenAsAdmin, appendAtlanTags, appendAtlanTags, appendTerms, delete, get, getAdminGroups, getAdminRoles, getAdminUsers, getAnnouncementMessage, getAnnouncementTitle, getAnnouncementType, getAnnouncementUpdatedAt, getAnnouncementUpdatedBy, getAnomaloChecks, getApplication, getApplicationField, getApplicationFieldQualifiedName, getApplicationQualifiedName, getAssetAnomaloAppliedCheckTypes, getAssetAnomaloCheckCount, getAssetAnomaloCheckStatuses, getAssetAnomaloDQStatus, getAssetAnomaloFailedCheckCount, getAssetAnomaloFailedCheckTypes, getAssetAnomaloLastCheckRunAt, getAssetAnomaloSourceUrl, getAssetCoverImage, getAssetDbtAccountName, getAssetDbtAlias, getAssetDbtEnvironmentDbtVersion, getAssetDbtEnvironmentName, getAssetDbtJobLastRun, getAssetDbtJobLastRunArtifactS3Path, getAssetDbtJobLastRunArtifactsSaved, getAssetDbtJobLastRunCreatedAt, getAssetDbtJobLastRunDequedAt, getAssetDbtJobLastRunExecutedByThreadId, getAssetDbtJobLastRunGitBranch, getAssetDbtJobLastRunGitSha, getAssetDbtJobLastRunHasDocsGenerated, getAssetDbtJobLastRunHasSourcesGenerated, getAssetDbtJobLastRunNotificationsSent, getAssetDbtJobLastRunOwnerThreadId, getAssetDbtJobLastRunQueuedDuration, getAssetDbtJobLastRunQueuedDurationHumanized, getAssetDbtJobLastRunRunDuration, getAssetDbtJobLastRunRunDurationHumanized, getAssetDbtJobLastRunStartedAt, getAssetDbtJobLastRunStatusMessage, getAssetDbtJobLastRunTotalDuration, getAssetDbtJobLastRunTotalDurationHumanized, getAssetDbtJobLastRunUpdatedAt, getAssetDbtJobLastRunUrl, getAssetDbtJobName, getAssetDbtJobNextRun, getAssetDbtJobNextRunHumanized, getAssetDbtJobSchedule, getAssetDbtJobScheduleCronHumanized, getAssetDbtJobStatus, getAssetDbtMeta, getAssetDbtPackageName, getAssetDbtProjectName, getAssetDbtSemanticLayerProxyUrl, getAssetDbtSourceFreshnessCriteria, getAssetDbtTags, getAssetDbtTestStatus, getAssetDbtUniqueId, getAssetDbtWorkflowLastUpdated, getAssetIcon, getAssetInternalPopularityScore, getAssetMcAlertQualifiedNames, getAssetMcIncidentNames, getAssetMcIncidentPriorities, getAssetMcIncidentQualifiedNames, getAssetMcIncidentSeverities, getAssetMcIncidentStates, getAssetMcIncidentSubTypes, getAssetMcIncidentTypes, getAssetMcIsMonitored, getAssetMcLastSyncRunAt, getAssetMcMonitorNames, getAssetMcMonitorQualifiedNames, getAssetMcMonitorScheduleTypes, getAssetMcMonitorStatuses, getAssetMcMonitorTypes, getAssetPoliciesCount, getAssetPolicyGUIDs, getAssetRedirectGUIDs, getAssetSodaCheckCount, getAssetSodaCheckStatuses, getAssetSodaDQStatus, getAssetSodaLastScanAt, getAssetSodaLastSyncRunAt, getAssetSodaSourceURL, getAssetSourceReadme, getAssetTags, getAssetThemeHex, getAssetUserDefinedType, getAssignedTerms, getAtlanTagNames, getAtlanTags, getCertificateStatus, getCertificateStatusMessage, getCertificateUpdatedAt, getCertificateUpdatedBy, getConnectionName, getConnectionQualifiedName, getConnectorName, getConnectorType, getCreatedBy, getCreateTime, getCustomConnectorType, getCustomMetadata, getCustomMetadataSets, getDataContractLatest, getDataContractLatestCertified, getDbtQualifiedName, getDeleteHandler, getDepth, getDescription, getDisplayName, getDomainGUIDs, getFiles, getHasContract, getHasLineage, getIconUrl, getImmediateDownstream, getImmediateUpstream, getInputPortDataProducts, getIsAIGenerated, getIsDiscoverable, getIsEditable, getIsIncomplete, getIsPartial, getLastRowChangedAt, getLastSyncRun, getLastSyncRunAt, getLastSyncWorkflowName, getLexicographicalSortOrder, getLinks, getMcIncidents, getMcMonitors, getMeaningNames, getMeanings, getMetrics, getName, getNonCompliantAssetPolicyGUIDs, getNullFields, getOutputPortDataProducts, getOutputProductGUIDs, getOwnerGroups, getOwnerUsers, getPendingTasks, getPopularityScore, getProductGUIDs, getQualifiedName, getReadme, getSampleDataUrl, getSchemaRegistrySubjects, getSodaChecks, getSourceCostUnit, getSourceCreatedAt, getSourceCreatedBy, getSourceEmbedURL, getSourceLastReadAt, getSourceOwners, getSourceQueryComputeCostRecords, getSourceQueryComputeCosts, getSourceReadCount, getSourceReadExpensiveQueryRecords, getSourceReadPopularQueryRecords, getSourceReadQueryCost, getSourceReadRecentUserRecords, getSourceReadRecentUsers, getSourceReadSlowQueryRecords, getSourceReadTopUserRecords, getSourceReadTopUsers, getSourceReadUserCount, getSourceTotalCost, getSourceUpdatedAt, getSourceUpdatedBy, getSourceURL, getStarredBy, getStarredCount, getStarredDetails, getStatus, getSubType, getTenantId, getUpdatedBy, getUpdateTime, getUserDefRelationshipFroms, getUserDefRelationshipTos, getUserDescription, getViewerGroups, getViewerUsers, getViewScore, lineage, lineage, purge, removeAnnouncement, removeAtlanTag, removeCertificate, removeCustomMetadata, removeDescription, removeOwners, removeTerms, removeUserDescription, replaceCustomMetadata, replaceTerms, requestLineage, restore, save, save, saveMergingCM, saveMergingCM, saveReplacingCM, saveReplacingCM, updateAnnouncement, updateAnnouncement, updateCertificate, updateCertificate, updateCustomMetadataAttributes, updateMergingCM, updateMergingCM, updateReplacingCM, updateReplacingCM

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

builder, by, compareTo, getCompleteObject, getCustomAttributes, getDisplayText, getEntityStatus, getGuid, getLabels, getRelationshipAttributes, getRelationshipGuid, getRelationshipStatus, getRelationshipType, getSemantic, getUniqueAttributes, isComplete, isValidReference, isValidReferenceByGuid, isValidReferenceByQualifiedName, setCompleteObject, to, validateRelationship, validateRequired

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

getRawJsonObject, setRawJsonObject, toJson

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.atlan.model.search.AuditDetail

getRawJsonObject, setRawJsonObject

Methods inherited from interface com.atlan.model.assets.IAsset

getAdminGroups, getAdminRoles, getAdminUsers, getAnnouncementMessage, getAnnouncementTitle, getAnnouncementType, getAnnouncementUpdatedAt, getAnnouncementUpdatedBy, getAnomaloChecks, getApplication, getApplicationField, getApplicationFieldQualifiedName, getApplicationQualifiedName, getAssetAnomaloAppliedCheckTypes, getAssetAnomaloCheckCount, getAssetAnomaloCheckStatuses, getAssetAnomaloDQStatus, getAssetAnomaloFailedCheckCount, getAssetAnomaloFailedCheckTypes, getAssetAnomaloLastCheckRunAt, getAssetAnomaloSourceUrl, getAssetCoverImage, getAssetDbtAccountName, getAssetDbtAlias, getAssetDbtEnvironmentDbtVersion, getAssetDbtEnvironmentName, getAssetDbtJobLastRun, getAssetDbtJobLastRunArtifactS3Path, getAssetDbtJobLastRunArtifactsSaved, getAssetDbtJobLastRunCreatedAt, getAssetDbtJobLastRunDequedAt, getAssetDbtJobLastRunExecutedByThreadId, getAssetDbtJobLastRunGitBranch, getAssetDbtJobLastRunGitSha, getAssetDbtJobLastRunHasDocsGenerated, getAssetDbtJobLastRunHasSourcesGenerated, getAssetDbtJobLastRunNotificationsSent, getAssetDbtJobLastRunOwnerThreadId, getAssetDbtJobLastRunQueuedDuration, getAssetDbtJobLastRunQueuedDurationHumanized, getAssetDbtJobLastRunRunDuration, getAssetDbtJobLastRunRunDurationHumanized, getAssetDbtJobLastRunStartedAt, getAssetDbtJobLastRunStatusMessage, getAssetDbtJobLastRunTotalDuration, getAssetDbtJobLastRunTotalDurationHumanized, getAssetDbtJobLastRunUpdatedAt, getAssetDbtJobLastRunUrl, getAssetDbtJobName, getAssetDbtJobNextRun, getAssetDbtJobNextRunHumanized, getAssetDbtJobSchedule, getAssetDbtJobScheduleCronHumanized, getAssetDbtJobStatus, getAssetDbtMeta, getAssetDbtPackageName, getAssetDbtProjectName, getAssetDbtSemanticLayerProxyUrl, getAssetDbtSourceFreshnessCriteria, getAssetDbtTags, getAssetDbtTestStatus, getAssetDbtUniqueId, getAssetDbtWorkflowLastUpdated, getAssetIcon, getAssetInternalPopularityScore, getAssetMcAlertQualifiedNames, getAssetMcIncidentNames, getAssetMcIncidentPriorities, getAssetMcIncidentQualifiedNames, getAssetMcIncidentSeverities, getAssetMcIncidentStates, getAssetMcIncidentSubTypes, getAssetMcIncidentTypes, getAssetMcIsMonitored, getAssetMcLastSyncRunAt, getAssetMcMonitorNames, getAssetMcMonitorQualifiedNames, getAssetMcMonitorScheduleTypes, getAssetMcMonitorStatuses, getAssetMcMonitorTypes, getAssetPoliciesCount, getAssetPolicyGUIDs, getAssetRedirectGUIDs, getAssetSodaCheckCount, getAssetSodaCheckStatuses, getAssetSodaDQStatus, getAssetSodaLastScanAt, getAssetSodaLastSyncRunAt, getAssetSodaSourceURL, getAssetSourceReadme, getAssetTags, getAssetThemeHex, getAssetUserDefinedType, getAssignedTerms, getCertificateStatus, getCertificateStatusMessage, getCertificateUpdatedAt, getCertificateUpdatedBy, getConnectionName, getConnectionQualifiedName, getConnectorName, getConnectorType, getCustomConnectorType, getDataContractLatest, getDataContractLatestCertified, getDbtQualifiedName, getDescription, getDisplayName, getDisplayText, getDomainGUIDs, getEntityStatus, getFiles, getGuid, getHasContract, getHasLineage, getIconUrl, getInputPortDataProducts, getIsAIGenerated, getIsDiscoverable, getIsEditable, getIsPartial, getLastRowChangedAt, getLastSyncRun, getLastSyncRunAt, getLastSyncWorkflowName, getLexicographicalSortOrder, getLinks, getMcIncidents, getMcMonitors, getMetrics, getName, getNonCompliantAssetPolicyGUIDs, getOutputPortDataProducts, getOutputProductGUIDs, getOwnerGroups, getOwnerUsers, getPopularityScore, getProductGUIDs, getQualifiedName, getReadme, getRelationshipAttributes, getRelationshipGuid, getRelationshipStatus, getRelationshipType, getSampleDataUrl, getSchemaRegistrySubjects, getSodaChecks, getSourceCostUnit, getSourceCreatedAt, getSourceCreatedBy, getSourceEmbedURL, getSourceLastReadAt, getSourceOwners, getSourceQueryComputeCostRecords, getSourceQueryComputeCosts, getSourceReadCount, getSourceReadExpensiveQueryRecords, getSourceReadPopularQueryRecords, getSourceReadQueryCost, getSourceReadRecentUserRecords, getSourceReadRecentUsers, getSourceReadSlowQueryRecords, getSourceReadTopUserRecords, getSourceReadTopUsers, getSourceReadUserCount, getSourceTotalCost, getSourceUpdatedAt, getSourceUpdatedBy, getSourceURL, getStarredBy, getStarredCount, getStarredDetails, getSubType, getTenantId, getUniqueAttributes, getUserDefRelationshipFroms, getUserDefRelationshipTos, getUserDescription, getViewerGroups, getViewerUsers, getViewScore, isComplete, isValidReferenceByGuid, isValidReferenceByQualifiedName

Methods inherited from interface com.atlan.model.assets.IColumnProcess

getAdminGroups, getAdminRoles, getAdminUsers, getAnnouncementMessage, getAnnouncementTitle, getAnnouncementType, getAnnouncementUpdatedAt, getAnnouncementUpdatedBy, getAnomaloChecks, getApplication, getApplicationField, getApplicationFieldQualifiedName, getApplicationQualifiedName, getAssetAnomaloAppliedCheckTypes, getAssetAnomaloCheckCount, getAssetAnomaloCheckStatuses, getAssetAnomaloDQStatus, getAssetAnomaloFailedCheckCount, getAssetAnomaloFailedCheckTypes, getAssetAnomaloLastCheckRunAt, getAssetAnomaloSourceUrl, getAssetCoverImage, getAssetDbtAccountName, getAssetDbtAlias, getAssetDbtEnvironmentDbtVersion, getAssetDbtEnvironmentName, getAssetDbtJobLastRun, getAssetDbtJobLastRunArtifactS3Path, getAssetDbtJobLastRunArtifactsSaved, getAssetDbtJobLastRunCreatedAt, getAssetDbtJobLastRunDequedAt, getAssetDbtJobLastRunExecutedByThreadId, getAssetDbtJobLastRunGitBranch, getAssetDbtJobLastRunGitSha, getAssetDbtJobLastRunHasDocsGenerated, getAssetDbtJobLastRunHasSourcesGenerated, getAssetDbtJobLastRunNotificationsSent, getAssetDbtJobLastRunOwnerThreadId, getAssetDbtJobLastRunQueuedDuration, getAssetDbtJobLastRunQueuedDurationHumanized, getAssetDbtJobLastRunRunDuration, getAssetDbtJobLastRunRunDurationHumanized, getAssetDbtJobLastRunStartedAt, getAssetDbtJobLastRunStatusMessage, getAssetDbtJobLastRunTotalDuration, getAssetDbtJobLastRunTotalDurationHumanized, getAssetDbtJobLastRunUpdatedAt, getAssetDbtJobLastRunUrl, getAssetDbtJobName, getAssetDbtJobNextRun, getAssetDbtJobNextRunHumanized, getAssetDbtJobSchedule, getAssetDbtJobScheduleCronHumanized, getAssetDbtJobStatus, getAssetDbtMeta, getAssetDbtPackageName, getAssetDbtProjectName, getAssetDbtSemanticLayerProxyUrl, getAssetDbtSourceFreshnessCriteria, getAssetDbtTags, getAssetDbtTestStatus, getAssetDbtUniqueId, getAssetDbtWorkflowLastUpdated, getAssetIcon, getAssetInternalPopularityScore, getAssetMcAlertQualifiedNames, getAssetMcIncidentNames, getAssetMcIncidentPriorities, getAssetMcIncidentQualifiedNames, getAssetMcIncidentSeverities, getAssetMcIncidentStates, getAssetMcIncidentSubTypes, getAssetMcIncidentTypes, getAssetMcIsMonitored, getAssetMcLastSyncRunAt, getAssetMcMonitorNames, getAssetMcMonitorQualifiedNames, getAssetMcMonitorScheduleTypes, getAssetMcMonitorStatuses, getAssetMcMonitorTypes, getAssetPoliciesCount, getAssetPolicyGUIDs, getAssetRedirectGUIDs, getAssetSodaCheckCount, getAssetSodaCheckStatuses, getAssetSodaDQStatus, getAssetSodaLastScanAt, getAssetSodaLastSyncRunAt, getAssetSodaSourceURL, getAssetSourceReadme, getAssetTags, getAssetThemeHex, getAssetUserDefinedType, getAssignedTerms, getCertificateStatus, getCertificateStatusMessage, getCertificateUpdatedAt, getCertificateUpdatedBy, getConnectionName, getConnectionQualifiedName, getConnectorName, getConnectorType, getCustomConnectorType, getDataContractLatest, getDataContractLatestCertified, getDbtQualifiedName, getDescription, getDisplayName, getDisplayText, getDomainGUIDs, getEntityStatus, getFiles, getGuid, getHasContract, getHasLineage, getIconUrl, getInputPortDataProducts, getIsAIGenerated, getIsDiscoverable, getIsEditable, getIsPartial, getLastRowChangedAt, getLastSyncRun, getLastSyncRunAt, getLastSyncWorkflowName, getLexicographicalSortOrder, getLinks, getMcIncidents, getMcMonitors, getMetrics, getName, getNonCompliantAssetPolicyGUIDs, getOutputPortDataProducts, getOutputProductGUIDs, getOwnerGroups, getOwnerUsers, getPopularityScore, getProductGUIDs, getQualifiedName, getReadme, getRelationshipAttributes, getRelationshipGuid, getRelationshipStatus, getRelationshipType, getSampleDataUrl, getSchemaRegistrySubjects, getSodaChecks, getSourceCostUnit, getSourceCreatedAt, getSourceCreatedBy, getSourceEmbedURL, getSourceLastReadAt, getSourceOwners, getSourceQueryComputeCostRecords, getSourceQueryComputeCosts, getSourceReadCount, getSourceReadExpensiveQueryRecords, getSourceReadPopularQueryRecords, getSourceReadQueryCost, getSourceReadRecentUserRecords, getSourceReadRecentUsers, getSourceReadSlowQueryRecords, getSourceReadTopUserRecords, getSourceReadTopUsers, getSourceReadUserCount, getSourceTotalCost, getSourceUpdatedAt, getSourceUpdatedBy, getSourceURL, getStarredBy, getStarredCount, getStarredDetails, getSubType, getTenantId, getUniqueAttributes, getUserDefRelationshipFroms, getUserDefRelationshipTos, getUserDescription, getViewerGroups, getViewerUsers, getViewScore, isComplete, isValidReferenceByGuid, isValidReferenceByQualifiedName

Methods inherited from interface com.atlan.model.assets.IFlow

getAdminGroups, getAdminRoles, getAdminUsers, getAnnouncementMessage, getAnnouncementTitle, getAnnouncementType, getAnnouncementUpdatedAt, getAnnouncementUpdatedBy, getAnomaloChecks, getApplication, getApplicationField, getApplicationFieldQualifiedName, getApplicationQualifiedName, getAssetAnomaloAppliedCheckTypes, getAssetAnomaloCheckCount, getAssetAnomaloCheckStatuses, getAssetAnomaloDQStatus, getAssetAnomaloFailedCheckCount, getAssetAnomaloFailedCheckTypes, getAssetAnomaloLastCheckRunAt, getAssetAnomaloSourceUrl, getAssetCoverImage, getAssetDbtAccountName, getAssetDbtAlias, getAssetDbtEnvironmentDbtVersion, getAssetDbtEnvironmentName, getAssetDbtJobLastRun, getAssetDbtJobLastRunArtifactS3Path, getAssetDbtJobLastRunArtifactsSaved, getAssetDbtJobLastRunCreatedAt, getAssetDbtJobLastRunDequedAt, getAssetDbtJobLastRunExecutedByThreadId, getAssetDbtJobLastRunGitBranch, getAssetDbtJobLastRunGitSha, getAssetDbtJobLastRunHasDocsGenerated, getAssetDbtJobLastRunHasSourcesGenerated, getAssetDbtJobLastRunNotificationsSent, getAssetDbtJobLastRunOwnerThreadId, getAssetDbtJobLastRunQueuedDuration, getAssetDbtJobLastRunQueuedDurationHumanized, getAssetDbtJobLastRunRunDuration, getAssetDbtJobLastRunRunDurationHumanized, getAssetDbtJobLastRunStartedAt, getAssetDbtJobLastRunStatusMessage, getAssetDbtJobLastRunTotalDuration, getAssetDbtJobLastRunTotalDurationHumanized, getAssetDbtJobLastRunUpdatedAt, getAssetDbtJobLastRunUrl, getAssetDbtJobName, getAssetDbtJobNextRun, getAssetDbtJobNextRunHumanized, getAssetDbtJobSchedule, getAssetDbtJobScheduleCronHumanized, getAssetDbtJobStatus, getAssetDbtMeta, getAssetDbtPackageName, getAssetDbtProjectName, getAssetDbtSemanticLayerProxyUrl, getAssetDbtSourceFreshnessCriteria, getAssetDbtTags, getAssetDbtTestStatus, getAssetDbtUniqueId, getAssetDbtWorkflowLastUpdated, getAssetIcon, getAssetInternalPopularityScore, getAssetMcAlertQualifiedNames, getAssetMcIncidentNames, getAssetMcIncidentPriorities, getAssetMcIncidentQualifiedNames, getAssetMcIncidentSeverities, getAssetMcIncidentStates, getAssetMcIncidentSubTypes, getAssetMcIncidentTypes, getAssetMcIsMonitored, getAssetMcLastSyncRunAt, getAssetMcMonitorNames, getAssetMcMonitorQualifiedNames, getAssetMcMonitorScheduleTypes, getAssetMcMonitorStatuses, getAssetMcMonitorTypes, getAssetPoliciesCount, getAssetPolicyGUIDs, getAssetRedirectGUIDs, getAssetSodaCheckCount, getAssetSodaCheckStatuses, getAssetSodaDQStatus, getAssetSodaLastScanAt, getAssetSodaLastSyncRunAt, getAssetSodaSourceURL, getAssetSourceReadme, getAssetTags, getAssetThemeHex, getAssetUserDefinedType, getAssignedTerms, getCertificateStatus, getCertificateStatusMessage, getCertificateUpdatedAt, getCertificateUpdatedBy, getConnectionName, getConnectionQualifiedName, getConnectorName, getConnectorType, getCustomConnectorType, getDataContractLatest, getDataContractLatestCertified, getDbtQualifiedName, getDescription, getDisplayName, getDisplayText, getDomainGUIDs, getEntityStatus, getFiles, getGuid, getHasContract, getHasLineage, getIconUrl, getInputPortDataProducts, getIsAIGenerated, getIsDiscoverable, getIsEditable, getIsPartial, getLastRowChangedAt, getLastSyncRun, getLastSyncRunAt, getLastSyncWorkflowName, getLexicographicalSortOrder, getLinks, getMcIncidents, getMcMonitors, getMetrics, getName, getNonCompliantAssetPolicyGUIDs, getOutputPortDataProducts, getOutputProductGUIDs, getOwnerGroups, getOwnerUsers, getPopularityScore, getProductGUIDs, getQualifiedName, getReadme, getRelationshipAttributes, getRelationshipGuid, getRelationshipStatus, getRelationshipType, getSampleDataUrl, getSchemaRegistrySubjects, getSodaChecks, getSourceCostUnit, getSourceCreatedAt, getSourceCreatedBy, getSourceEmbedURL, getSourceLastReadAt, getSourceOwners, getSourceQueryComputeCostRecords, getSourceQueryComputeCosts, getSourceReadCount, getSourceReadExpensiveQueryRecords, getSourceReadPopularQueryRecords, getSourceReadQueryCost, getSourceReadRecentUserRecords, getSourceReadRecentUsers, getSourceReadSlowQueryRecords, getSourceReadTopUserRecords, getSourceReadTopUsers, getSourceReadUserCount, getSourceTotalCost, getSourceUpdatedAt, getSourceUpdatedBy, getSourceURL, getStarredBy, getStarredCount, getStarredDetails, getSubType, getTenantId, getUniqueAttributes, getUserDefRelationshipFroms, getUserDefRelationshipTos, getUserDescription, getViewerGroups, getViewerUsers, getViewScore, isComplete, isValidReferenceByGuid, isValidReferenceByQualifiedName

Methods inherited from interface com.atlan.model.assets.IFlowFieldOperation

getAdminGroups, getAdminRoles, getAdminUsers, getAnnouncementMessage, getAnnouncementTitle, getAnnouncementType, getAnnouncementUpdatedAt, getAnnouncementUpdatedBy, getAnomaloChecks, getApplication, getApplicationField, getApplicationFieldQualifiedName, getApplicationQualifiedName, getAssetAnomaloAppliedCheckTypes, getAssetAnomaloCheckCount, getAssetAnomaloCheckStatuses, getAssetAnomaloDQStatus, getAssetAnomaloFailedCheckCount, getAssetAnomaloFailedCheckTypes, getAssetAnomaloLastCheckRunAt, getAssetAnomaloSourceUrl, getAssetCoverImage, getAssetDbtAccountName, getAssetDbtAlias, getAssetDbtEnvironmentDbtVersion, getAssetDbtEnvironmentName, getAssetDbtJobLastRun, getAssetDbtJobLastRunArtifactS3Path, getAssetDbtJobLastRunArtifactsSaved, getAssetDbtJobLastRunCreatedAt, getAssetDbtJobLastRunDequedAt, getAssetDbtJobLastRunExecutedByThreadId, getAssetDbtJobLastRunGitBranch, getAssetDbtJobLastRunGitSha, getAssetDbtJobLastRunHasDocsGenerated, getAssetDbtJobLastRunHasSourcesGenerated, getAssetDbtJobLastRunNotificationsSent, getAssetDbtJobLastRunOwnerThreadId, getAssetDbtJobLastRunQueuedDuration, getAssetDbtJobLastRunQueuedDurationHumanized, getAssetDbtJobLastRunRunDuration, getAssetDbtJobLastRunRunDurationHumanized, getAssetDbtJobLastRunStartedAt, getAssetDbtJobLastRunStatusMessage, getAssetDbtJobLastRunTotalDuration, getAssetDbtJobLastRunTotalDurationHumanized, getAssetDbtJobLastRunUpdatedAt, getAssetDbtJobLastRunUrl, getAssetDbtJobName, getAssetDbtJobNextRun, getAssetDbtJobNextRunHumanized, getAssetDbtJobSchedule, getAssetDbtJobScheduleCronHumanized, getAssetDbtJobStatus, getAssetDbtMeta, getAssetDbtPackageName, getAssetDbtProjectName, getAssetDbtSemanticLayerProxyUrl, getAssetDbtSourceFreshnessCriteria, getAssetDbtTags, getAssetDbtTestStatus, getAssetDbtUniqueId, getAssetDbtWorkflowLastUpdated, getAssetIcon, getAssetInternalPopularityScore, getAssetMcAlertQualifiedNames, getAssetMcIncidentNames, getAssetMcIncidentPriorities, getAssetMcIncidentQualifiedNames, getAssetMcIncidentSeverities, getAssetMcIncidentStates, getAssetMcIncidentSubTypes, getAssetMcIncidentTypes, getAssetMcIsMonitored, getAssetMcLastSyncRunAt, getAssetMcMonitorNames, getAssetMcMonitorQualifiedNames, getAssetMcMonitorScheduleTypes, getAssetMcMonitorStatuses, getAssetMcMonitorTypes, getAssetPoliciesCount, getAssetPolicyGUIDs, getAssetRedirectGUIDs, getAssetSodaCheckCount, getAssetSodaCheckStatuses, getAssetSodaDQStatus, getAssetSodaLastScanAt, getAssetSodaLastSyncRunAt, getAssetSodaSourceURL, getAssetSourceReadme, getAssetTags, getAssetThemeHex, getAssetUserDefinedType, getAssignedTerms, getCertificateStatus, getCertificateStatusMessage, getCertificateUpdatedAt, getCertificateUpdatedBy, getConnectionName, getConnectionQualifiedName, getConnectorName, getConnectorType, getCustomConnectorType, getDataContractLatest, getDataContractLatestCertified, getDbtQualifiedName, getDescription, getDisplayName, getDisplayText, getDomainGUIDs, getEntityStatus, getFiles, getGuid, getHasContract, getHasLineage, getIconUrl, getInputPortDataProducts, getIsAIGenerated, getIsDiscoverable, getIsEditable, getIsPartial, getLastRowChangedAt, getLastSyncRun, getLastSyncRunAt, getLastSyncWorkflowName, getLexicographicalSortOrder, getLinks, getMcIncidents, getMcMonitors, getMetrics, getName, getNonCompliantAssetPolicyGUIDs, getOutputPortDataProducts, getOutputProductGUIDs, getOwnerGroups, getOwnerUsers, getPopularityScore, getProductGUIDs, getQualifiedName, getReadme, getRelationshipAttributes, getRelationshipGuid, getRelationshipStatus, getRelationshipType, getSampleDataUrl, getSchemaRegistrySubjects, getSodaChecks, getSourceCostUnit, getSourceCreatedAt, getSourceCreatedBy, getSourceEmbedURL, getSourceLastReadAt, getSourceOwners, getSourceQueryComputeCostRecords, getSourceQueryComputeCosts, getSourceReadCount, getSourceReadExpensiveQueryRecords, getSourceReadPopularQueryRecords, getSourceReadQueryCost, getSourceReadRecentUserRecords, getSourceReadRecentUsers, getSourceReadSlowQueryRecords, getSourceReadTopUserRecords, getSourceReadTopUsers, getSourceReadUserCount, getSourceTotalCost, getSourceUpdatedAt, getSourceUpdatedBy, getSourceURL, getStarredBy, getStarredCount, getStarredDetails, getSubType, getTenantId, getUniqueAttributes, getUserDefRelationshipFroms, getUserDefRelationshipTos, getUserDescription, getViewerGroups, getViewerUsers, getViewScore, isComplete, isValidReferenceByGuid, isValidReferenceByQualifiedName

Methods inherited from interface com.atlan.model.assets.ILineageProcess

getAdminGroups, getAdminRoles, getAdminUsers, getAnnouncementMessage, getAnnouncementTitle, getAnnouncementType, getAnnouncementUpdatedAt, getAnnouncementUpdatedBy, getAnomaloChecks, getApplication, getApplicationField, getApplicationFieldQualifiedName, getApplicationQualifiedName, getAssetAnomaloAppliedCheckTypes, getAssetAnomaloCheckCount, getAssetAnomaloCheckStatuses, getAssetAnomaloDQStatus, getAssetAnomaloFailedCheckCount, getAssetAnomaloFailedCheckTypes, getAssetAnomaloLastCheckRunAt, getAssetAnomaloSourceUrl, getAssetCoverImage, getAssetDbtAccountName, getAssetDbtAlias, getAssetDbtEnvironmentDbtVersion, getAssetDbtEnvironmentName, getAssetDbtJobLastRun, getAssetDbtJobLastRunArtifactS3Path, getAssetDbtJobLastRunArtifactsSaved, getAssetDbtJobLastRunCreatedAt, getAssetDbtJobLastRunDequedAt, getAssetDbtJobLastRunExecutedByThreadId, getAssetDbtJobLastRunGitBranch, getAssetDbtJobLastRunGitSha, getAssetDbtJobLastRunHasDocsGenerated, getAssetDbtJobLastRunHasSourcesGenerated, getAssetDbtJobLastRunNotificationsSent, getAssetDbtJobLastRunOwnerThreadId, getAssetDbtJobLastRunQueuedDuration, getAssetDbtJobLastRunQueuedDurationHumanized, getAssetDbtJobLastRunRunDuration, getAssetDbtJobLastRunRunDurationHumanized, getAssetDbtJobLastRunStartedAt, getAssetDbtJobLastRunStatusMessage, getAssetDbtJobLastRunTotalDuration, getAssetDbtJobLastRunTotalDurationHumanized, getAssetDbtJobLastRunUpdatedAt, getAssetDbtJobLastRunUrl, getAssetDbtJobName, getAssetDbtJobNextRun, getAssetDbtJobNextRunHumanized, getAssetDbtJobSchedule, getAssetDbtJobScheduleCronHumanized, getAssetDbtJobStatus, getAssetDbtMeta, getAssetDbtPackageName, getAssetDbtProjectName, getAssetDbtSemanticLayerProxyUrl, getAssetDbtSourceFreshnessCriteria, getAssetDbtTags, getAssetDbtTestStatus, getAssetDbtUniqueId, getAssetDbtWorkflowLastUpdated, getAssetIcon, getAssetInternalPopularityScore, getAssetMcAlertQualifiedNames, getAssetMcIncidentNames, getAssetMcIncidentPriorities, getAssetMcIncidentQualifiedNames, getAssetMcIncidentSeverities, getAssetMcIncidentStates, getAssetMcIncidentSubTypes, getAssetMcIncidentTypes, getAssetMcIsMonitored, getAssetMcLastSyncRunAt, getAssetMcMonitorNames, getAssetMcMonitorQualifiedNames, getAssetMcMonitorScheduleTypes, getAssetMcMonitorStatuses, getAssetMcMonitorTypes, getAssetPoliciesCount, getAssetPolicyGUIDs, getAssetRedirectGUIDs, getAssetSodaCheckCount, getAssetSodaCheckStatuses, getAssetSodaDQStatus, getAssetSodaLastScanAt, getAssetSodaLastSyncRunAt, getAssetSodaSourceURL, getAssetSourceReadme, getAssetTags, getAssetThemeHex, getAssetUserDefinedType, getAssignedTerms, getCertificateStatus, getCertificateStatusMessage, getCertificateUpdatedAt, getCertificateUpdatedBy, getConnectionName, getConnectionQualifiedName, getConnectorName, getConnectorType, getCustomConnectorType, getDataContractLatest, getDataContractLatestCertified, getDbtQualifiedName, getDescription, getDisplayName, getDisplayText, getDomainGUIDs, getEntityStatus, getFiles, getGuid, getHasContract, getHasLineage, getIconUrl, getInputPortDataProducts, getIsAIGenerated, getIsDiscoverable, getIsEditable, getIsPartial, getLastRowChangedAt, getLastSyncRun, getLastSyncRunAt, getLastSyncWorkflowName, getLexicographicalSortOrder, getLinks, getMcIncidents, getMcMonitors, getMetrics, getName, getNonCompliantAssetPolicyGUIDs, getOutputPortDataProducts, getOutputProductGUIDs, getOwnerGroups, getOwnerUsers, getPopularityScore, getProductGUIDs, getQualifiedName, getReadme, getRelationshipAttributes, getRelationshipGuid, getRelationshipStatus, getRelationshipType, getSampleDataUrl, getSchemaRegistrySubjects, getSodaChecks, getSourceCostUnit, getSourceCreatedAt, getSourceCreatedBy, getSourceEmbedURL, getSourceLastReadAt, getSourceOwners, getSourceQueryComputeCostRecords, getSourceQueryComputeCosts, getSourceReadCount, getSourceReadExpensiveQueryRecords, getSourceReadPopularQueryRecords, getSourceReadQueryCost, getSourceReadRecentUserRecords, getSourceReadRecentUsers, getSourceReadSlowQueryRecords, getSourceReadTopUserRecords, getSourceReadTopUsers, getSourceReadUserCount, getSourceTotalCost, getSourceUpdatedAt, getSourceUpdatedBy, getSourceURL, getStarredBy, getStarredCount, getStarredDetails, getSubType, getTenantId, getUniqueAttributes, getUserDefRelationshipFroms, getUserDefRelationshipTos, getUserDescription, getViewerGroups, getViewerUsers, getViewScore, isComplete, isValidReferenceByGuid, isValidReferenceByQualifiedName

Methods inherited from interface com.atlan.model.assets.IReferenceable

getAtlanTagNames, getAtlanTags, getCreatedBy, getCreateTime, getCustomMetadataSets, getDeleteHandler, getGuid, getIsIncomplete, getMeaningNames, getMeanings, getPendingTasks, getQualifiedName, getStatus, getUpdatedBy, getUpdateTime

Field Details

TYPE_NAME

public static final String TYPE_NAME

See Also:

• Constant Field Values

Constructor Details

FlowFieldOperation

protected FlowFieldOperation(FlowFieldOperation.FlowFieldOperationBuilder<?,?> b)

Method Details

trimToReference

public FlowFieldOperation trimToReference()
                                   throws InvalidRequestException

Builds the minimal object necessary to create a relationship to a FlowFieldOperation, from a potentially more-complete FlowFieldOperation object.

Overrides:

trimToReference in class Asset

Returns:

the minimal object necessary to relate to the FlowFieldOperation

Throws:

InvalidRequestException - if any of the minimal set of required properties for a FlowFieldOperation relationship are not found in the initial object

select

public static FluentSearch.FluentSearchBuilder<?,?> select(AtlanClient client)

Start a fluent search that will return all FlowFieldOperation assets. Additional conditions can be chained onto the returned search before any asset retrieval is attempted, ensuring all conditions are pushed-down for optimal retrieval. Only active (non-archived) FlowFieldOperation assets will be included.

Parameters:

client - connectivity to the Atlan tenant from which to retrieve the assets

Returns:

a fluent search that includes all FlowFieldOperation assets

select

public static FluentSearch.FluentSearchBuilder<?,?> select(AtlanClient client,
 boolean includeArchived)

Start a fluent search that will return all FlowFieldOperation assets. Additional conditions can be chained onto the returned search before any asset retrieval is attempted, ensuring all conditions are pushed-down for optimal retrieval.

Parameters:

client - connectivity to the Atlan tenant from which to retrieve the assets

includeArchived - when true, archived (soft-deleted) FlowFieldOperations will be included

Returns:

a fluent search that includes all FlowFieldOperation assets

refByGuid

public static FlowFieldOperation refByGuid(String guid)

Reference to a FlowFieldOperation by GUID. Use this to create a relationship to this FlowFieldOperation, where the relationship should be replaced.

Parameters:

guid - the GUID of the FlowFieldOperation to reference

Returns:

reference to a FlowFieldOperation that can be used for defining a relationship to a FlowFieldOperation

refByGuid

public static FlowFieldOperation refByGuid(String guid,
 Reference.SaveSemantic semantic)

Reference to a FlowFieldOperation by GUID. Use this to create a relationship to this FlowFieldOperation, where you want to further control how that relationship should be updated (i.e. replaced, appended, or removed).

Parameters:

guid - the GUID of the FlowFieldOperation to reference

semantic - how to save this relationship (replace all with this, append it, or remove it)

Returns:

reference to a FlowFieldOperation that can be used for defining a relationship to a FlowFieldOperation

refByQualifiedName

public static FlowFieldOperation refByQualifiedName(String qualifiedName)

Reference to a FlowFieldOperation by qualifiedName. Use this to create a relationship to this FlowFieldOperation, where the relationship should be replaced.

Parameters:

qualifiedName - the qualifiedName of the FlowFieldOperation to reference

Returns:

reference to a FlowFieldOperation that can be used for defining a relationship to a FlowFieldOperation

refByQualifiedName

public static FlowFieldOperation refByQualifiedName(String qualifiedName,
 Reference.SaveSemantic semantic)

Reference to a FlowFieldOperation by qualifiedName. Use this to create a relationship to this FlowFieldOperation, where you want to further control how that relationship should be updated (i.e. replaced, appended, or removed).

Parameters:

qualifiedName - the qualifiedName of the FlowFieldOperation to reference

semantic - how to save this relationship (replace all with this, append it, or remove it)

Returns:

reference to a FlowFieldOperation that can be used for defining a relationship to a FlowFieldOperation

get

public static FlowFieldOperation get(AtlanClient client,
 String id)
                              throws AtlanException

Retrieves a FlowFieldOperation by one of its identifiers, complete with all of its relationships.

Parameters:

client - connectivity to the Atlan tenant from which to retrieve the asset

id - of the FlowFieldOperation to retrieve, either its GUID or its full qualifiedName

Returns:

the requested full FlowFieldOperation, complete with all of its relationships

Throws:

AtlanException - on any error during the API invocation, such as the NotFoundException if the FlowFieldOperation does not exist or the provided GUID is not a FlowFieldOperation

get

public static FlowFieldOperation get(AtlanClient client,
 String id,
 boolean includeAllRelationships)
                              throws AtlanException

Retrieves a FlowFieldOperation by one of its identifiers, optionally complete with all of its relationships.

Parameters:

client - connectivity to the Atlan tenant from which to retrieve the asset

id - of the FlowFieldOperation to retrieve, either its GUID or its full qualifiedName

includeAllRelationships - if true, all the asset's relationships will also be retrieved; if false, no relationships will be retrieved

Returns:

the requested full FlowFieldOperation, optionally complete with all of its relationships

Throws:

AtlanException - on any error during the API invocation, such as the NotFoundException if the FlowFieldOperation does not exist or the provided GUID is not a FlowFieldOperation

get

public static FlowFieldOperation get(AtlanClient client,
 String id,
 Collection<AtlanField> attributes)
                              throws AtlanException

Retrieves a FlowFieldOperation by one of its identifiers, with only the requested attributes (and relationships).

Parameters:

client - connectivity to the Atlan tenant from which to retrieve the asset

id - of the FlowFieldOperation to retrieve, either its GUID or its full qualifiedName

attributes - to retrieve for the FlowFieldOperation, including any relationships

Returns:

the requested FlowFieldOperation, with only its minimal information and the requested attributes (and relationships)

Throws:

AtlanException - on any error during the API invocation, such as the NotFoundException if the FlowFieldOperation does not exist or the provided GUID is not a FlowFieldOperation

get

public static FlowFieldOperation get(AtlanClient client,
 String id,
 Collection<AtlanField> attributes,
 Collection<AtlanField> attributesOnRelated)
                              throws AtlanException

Retrieves a FlowFieldOperation by one of its identifiers, with only the requested attributes (and relationships).

Parameters:

client - connectivity to the Atlan tenant from which to retrieve the asset

id - of the FlowFieldOperation to retrieve, either its GUID or its full qualifiedName

attributes - to retrieve for the FlowFieldOperation, including any relationships

attributesOnRelated - to retrieve on each relationship retrieved for the FlowFieldOperation

Returns:

the requested FlowFieldOperation, with only its minimal information and the requested attributes (and relationships)

Throws:

AtlanException - on any error during the API invocation, such as the NotFoundException if the FlowFieldOperation does not exist or the provided GUID is not a FlowFieldOperation

restore

public static boolean restore(AtlanClient client,
 String qualifiedName)
                       throws AtlanException

Restore the archived (soft-deleted) FlowFieldOperation to active.

Parameters:

client - connectivity to the Atlan tenant on which to restore the asset

qualifiedName - for the FlowFieldOperation

Returns:

true if the FlowFieldOperation is now active, and false otherwise

Throws:

AtlanException - on any API problems

updater

public static FlowFieldOperation.FlowFieldOperationBuilder<?,?> updater(String qualifiedName,
 String name)

Builds the minimal object necessary to update a FlowFieldOperation.

Parameters:

qualifiedName - of the FlowFieldOperation

name - of the FlowFieldOperation

Returns:

the minimal request necessary to update the FlowFieldOperation, as a builder

trimToRequired

public FlowFieldOperation.FlowFieldOperationBuilder<?,?> trimToRequired()
                                                                 throws InvalidRequestException

Builds the minimal object necessary to apply an update to a FlowFieldOperation, from a potentially more-complete FlowFieldOperation object.

Overrides:

trimToRequired in class Asset

Returns:

the minimal object necessary to update the FlowFieldOperation, as a builder

Throws:

InvalidRequestException - if any of the minimal set of required properties for FlowFieldOperation are not found in the initial object

removeDescription

public static FlowFieldOperation removeDescription(AtlanClient client,
 String qualifiedName,
 String name)
                                            throws AtlanException

Remove the system description from a FlowFieldOperation.

Parameters:

client - connectivity to the Atlan tenant on which to remove the asset's description

qualifiedName - of the FlowFieldOperation

name - of the FlowFieldOperation

Returns:

the updated FlowFieldOperation, or null if the removal failed

Throws:

AtlanException - on any API problems

removeUserDescription

public static FlowFieldOperation removeUserDescription(AtlanClient client,
 String qualifiedName,
 String name)
                                                throws AtlanException

Remove the user's description from a FlowFieldOperation.

Parameters:

client - connectivity to the Atlan tenant on which to remove the asset's description

qualifiedName - of the FlowFieldOperation

name - of the FlowFieldOperation

Returns:

the updated FlowFieldOperation, or null if the removal failed

Throws:

AtlanException - on any API problems

removeOwners

public static FlowFieldOperation removeOwners(AtlanClient client,
 String qualifiedName,
 String name)
                                       throws AtlanException

Remove the owners from a FlowFieldOperation.

Parameters:

client - connectivity to the Atlan tenant from which to remove the FlowFieldOperation's owners

qualifiedName - of the FlowFieldOperation

name - of the FlowFieldOperation

Returns:

the updated FlowFieldOperation, or null if the removal failed

Throws:

AtlanException - on any API problems

updateCertificate

public static FlowFieldOperation updateCertificate(AtlanClient client,
 String qualifiedName,
 CertificateStatus certificate,
 String message)
                                            throws AtlanException

Update the certificate on a FlowFieldOperation.

Parameters:

client - connectivity to the Atlan tenant on which to update the FlowFieldOperation's certificate

qualifiedName - of the FlowFieldOperation

certificate - to use

message - (optional) message, or null if no message

Returns:

the updated FlowFieldOperation, or null if the update failed

Throws:

AtlanException - on any API problems

removeCertificate

public static FlowFieldOperation removeCertificate(AtlanClient client,
 String qualifiedName,
 String name)
                                            throws AtlanException

Remove the certificate from a FlowFieldOperation.

Parameters:

client - connectivity to the Atlan tenant from which to remove the FlowFieldOperation's certificate

qualifiedName - of the FlowFieldOperation

name - of the FlowFieldOperation

Returns:

the updated FlowFieldOperation, or null if the removal failed

Throws:

AtlanException - on any API problems

updateAnnouncement

public static FlowFieldOperation updateAnnouncement(AtlanClient client,
 String qualifiedName,
 AtlanAnnouncementType type,
 String title,
 String message)
                                             throws AtlanException

Update the announcement on a FlowFieldOperation.

Parameters:

client - connectivity to the Atlan tenant on which to update the FlowFieldOperation's announcement

qualifiedName - of the FlowFieldOperation

type - type of announcement to set

title - (optional) title of the announcement to set (or null for no title)

message - (optional) message of the announcement to set (or null for no message)

Returns:

the result of the update, or null if the update failed

Throws:

AtlanException - on any API problems

removeAnnouncement

public static FlowFieldOperation removeAnnouncement(AtlanClient client,
 String qualifiedName,
 String name)
                                             throws AtlanException

Remove the announcement from a FlowFieldOperation.

Parameters:

client - connectivity to the Atlan client from which to remove the FlowFieldOperation's announcement

qualifiedName - of the FlowFieldOperation

name - of the FlowFieldOperation

Returns:

the updated FlowFieldOperation, or null if the removal failed

Throws:

AtlanException - on any API problems

replaceTerms

public static FlowFieldOperation replaceTerms(AtlanClient client,
 String qualifiedName,
 String name,
 List<IGlossaryTerm> terms)
                                       throws AtlanException

Replace the terms linked to the FlowFieldOperation.

Parameters:

client - connectivity to the Atlan tenant on which to replace the FlowFieldOperation's assigned terms

qualifiedName - for the FlowFieldOperation

name - human-readable name of the FlowFieldOperation

terms - the list of terms to replace on the FlowFieldOperation, or null to remove all terms from the FlowFieldOperation

Returns:

the FlowFieldOperation that was updated (note that it will NOT contain details of the replaced terms)

Throws:

AtlanException - on any API problems

appendTerms

@Deprecated
public static FlowFieldOperation appendTerms(AtlanClient client,
 String qualifiedName,
 List<IGlossaryTerm> terms)
                                      throws AtlanException

Deprecated.

see Asset.AssetBuilder.appendAssignedTerm(GlossaryTerm)

Link additional terms to the FlowFieldOperation, without replacing existing terms linked to the FlowFieldOperation. Note: this operation must make two API calls — one to retrieve the FlowFieldOperation's existing terms, and a second to append the new terms.

Parameters:

client - connectivity to the Atlan tenant on which to append terms to the FlowFieldOperation

qualifiedName - for the FlowFieldOperation

terms - the list of terms to append to the FlowFieldOperation

Returns:

the FlowFieldOperation that was updated (note that it will NOT contain details of the appended terms)

Throws:

AtlanException - on any API problems

removeTerms

@Deprecated
public static FlowFieldOperation removeTerms(AtlanClient client,
 String qualifiedName,
 List<IGlossaryTerm> terms)
                                      throws AtlanException

Deprecated.

see Asset.AssetBuilder.removeAssignedTerm(GlossaryTerm)

Remove terms from a FlowFieldOperation, without replacing all existing terms linked to the FlowFieldOperation. Note: this operation must make two API calls — one to retrieve the FlowFieldOperation's existing terms, and a second to remove the provided terms.

Parameters:

client - connectivity to the Atlan tenant from which to remove terms from the FlowFieldOperation

qualifiedName - for the FlowFieldOperation

terms - the list of terms to remove from the FlowFieldOperation, which must be referenced by GUID

Returns:

the FlowFieldOperation that was updated (note that it will NOT contain details of the resulting terms)

Throws:

AtlanException - on any API problems

appendAtlanTags

@Deprecated
public static FlowFieldOperation appendAtlanTags(AtlanClient client,
 String qualifiedName,
 List<String> atlanTagNames)
                                          throws AtlanException

Deprecated.

see Asset.AssetBuilder.appendAtlanTags(List)

Add Atlan tags to a FlowFieldOperation, without replacing existing Atlan tags linked to the FlowFieldOperation. Note: this operation must make two API calls — one to retrieve the FlowFieldOperation's existing Atlan tags, and a second to append the new Atlan tags.

Parameters:

client - connectivity to the Atlan tenant on which to append Atlan tags to the FlowFieldOperation

qualifiedName - of the FlowFieldOperation

atlanTagNames - human-readable names of the Atlan tags to add

Returns:

the updated FlowFieldOperation

Throws:

AtlanException - on any API problems

appendAtlanTags

@Deprecated
public static FlowFieldOperation appendAtlanTags(AtlanClient client,
 String qualifiedName,
 List<String> atlanTagNames,
 boolean propagate,
 boolean removePropagationsOnDelete,
 boolean restrictLineagePropagation)
                                          throws AtlanException

Deprecated.

see Asset.AssetBuilder.appendAtlanTags(List, boolean, boolean, boolean, boolean)

Add Atlan tags to a FlowFieldOperation, without replacing existing Atlan tags linked to the FlowFieldOperation. Note: this operation must make two API calls — one to retrieve the FlowFieldOperation's existing Atlan tags, and a second to append the new Atlan tags.

Parameters:

client - connectivity to the Atlan tenant on which to append Atlan tags to the FlowFieldOperation

qualifiedName - of the FlowFieldOperation

atlanTagNames - human-readable names of the Atlan tags to add

propagate - whether to propagate the Atlan tag (true) or not (false)

removePropagationsOnDelete - whether to remove the propagated Atlan tags when the Atlan tag is removed from this asset (true) or not (false)

restrictLineagePropagation - whether to avoid propagating through lineage (true) or do propagate through lineage (false)

Returns:

the updated FlowFieldOperation

Throws:

AtlanException - on any API problems

removeAtlanTag

@Deprecated
public static void removeAtlanTag(AtlanClient client,
 String qualifiedName,
 String atlanTagName)
                           throws AtlanException

Deprecated.

see Asset.AssetBuilder.removeAtlanTag(String)

Remove an Atlan tag from a FlowFieldOperation.

Parameters:

client - connectivity to the Atlan tenant from which to remove an Atlan tag from a FlowFieldOperation

qualifiedName - of the FlowFieldOperation

atlanTagName - human-readable name of the Atlan tag to remove

Throws:

AtlanException - on any API problems, or if the Atlan tag does not exist on the FlowFieldOperation

_internal

public static FlowFieldOperation.FlowFieldOperationBuilder<?,?> _internal()

toBuilder

public FlowFieldOperation.FlowFieldOperationBuilder<?,?> toBuilder()

Overrides:

toBuilder in class Reference

getAdditionalEtlContext

public String getAdditionalEtlContext()

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

Specified by:

getAdditionalEtlContext in interface IColumnProcess

Specified by:

getAdditionalEtlContext in interface IFlowFieldOperation

Specified by:

getAdditionalEtlContext in interface ILineageProcess

getAdfActivity

public IAdfActivity getAdfActivity()

ADF Activity that is associated with this lineage process.

Specified by:

getAdfActivity in interface IColumnProcess

Specified by:

getAdfActivity in interface IFlowFieldOperation

Specified by:

getAdfActivity in interface ILineageProcess

getAiDatasetType

public AIDatasetType getAiDatasetType()

Dataset type for AI Model - dataset process.

Specified by:

getAiDatasetType in interface IColumnProcess

Specified by:

getAiDatasetType in interface IFlowFieldOperation

Specified by:

getAiDatasetType in interface ILineageProcess

getAirflowTasks

public SortedSet<IAirflowTask> getAirflowTasks()

Tasks that exist within this process.

Specified by:

getAirflowTasks in interface IColumnProcess

Specified by:

getAirflowTasks in interface IFlowFieldOperation

Specified by:

getAirflowTasks in interface ILineageProcess

getAst

public String getAst()

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

Specified by:

getAst in interface IColumnProcess

Specified by:

getAst in interface IFlowFieldOperation

Specified by:

getAst in interface ILineageProcess

getCode

public String getCode()

Code that ran within the process.

Specified by:

getCode in interface IColumnProcess

Specified by:

getCode in interface IFlowFieldOperation

Specified by:

getCode in interface ILineageProcess

getColumnProcesses

public SortedSet<IColumnProcess> getColumnProcesses()

Processes that detail column-level lineage for this process.

Specified by:

getColumnProcesses in interface IColumnProcess

Specified by:

getColumnProcesses in interface IFlowFieldOperation

Specified by:

getColumnProcesses in interface ILineageProcess

getFivetranConnector

public IFivetranConnector getFivetranConnector()

fivetranConnector in which this process exists.

Specified by:

getFivetranConnector in interface IColumnProcess

Specified by:

getFivetranConnector in interface IFlowFieldOperation

Specified by:

getFivetranConnector in interface ILineageProcess

getFlowErrorMessage

public String getFlowErrorMessage()

Optional error message of the flow run.

Specified by:

getFlowErrorMessage in interface IFlow

Specified by:

getFlowErrorMessage in interface IFlowFieldOperation

getFlowFinishedAt

public Long getFlowFinishedAt()

Date and time at which this point in the data processing or orchestration finished.

Specified by:

getFlowFinishedAt in interface IFlow

Specified by:

getFlowFinishedAt in interface IFlowFieldOperation

getFlowFolderName

public String getFlowFolderName()

Simple name of the folder in which this asset is contained.

Specified by:

getFlowFolderName in interface IFlow

Specified by:

getFlowFolderName in interface IFlowFieldOperation

getFlowFolderQualifiedName

public String getFlowFolderQualifiedName()

Unique name of the folder in which this asset is contained.

Specified by:

getFlowFolderQualifiedName in interface IFlow

Specified by:

getFlowFolderQualifiedName in interface IFlowFieldOperation

getFlowId

public String getFlowId()

Unique ID for this flow asset, which will remain constant throughout the lifecycle of the asset.

Specified by:

getFlowId in interface IFlow

Specified by:

getFlowId in interface IFlowFieldOperation

getFlowInputParameters

public Map<String,String> getFlowInputParameters()

Input parameters for the flow run.

Specified by:

getFlowInputParameters in interface IFlow

Specified by:

getFlowInputParameters in interface IFlowFieldOperation

getFlowOrchestratedBy

public IFlowControlOperation getFlowOrchestratedBy()

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

Specified by:

getFlowOrchestratedBy in interface IColumnProcess

Specified by:

getFlowOrchestratedBy in interface IFlowFieldOperation

Specified by:

getFlowOrchestratedBy in interface ILineageProcess

getFlowProjectName

public String getFlowProjectName()

Simple name of the project in which this asset is contained.

Specified by:

getFlowProjectName in interface IFlow

Specified by:

getFlowProjectName in interface IFlowFieldOperation

getFlowProjectQualifiedName

public String getFlowProjectQualifiedName()

Unique name of the project in which this asset is contained.

Specified by:

getFlowProjectQualifiedName in interface IFlow

Specified by:

getFlowProjectQualifiedName in interface IFlowFieldOperation

getFlowReusableUnitName

public String getFlowReusableUnitName()

Simple name of the reusable grouping of operations in which this ephemeral data is contained.

Specified by:

getFlowReusableUnitName in interface IFlow

Specified by:

getFlowReusableUnitName in interface IFlowFieldOperation

getFlowReusableUnitQualifiedName

public String getFlowReusableUnitQualifiedName()

Unique name of the reusable grouping of operations in which this ephemeral data is contained.

Specified by:

getFlowReusableUnitQualifiedName in interface IFlow

Specified by:

getFlowReusableUnitQualifiedName in interface IFlowFieldOperation

getFlowRunId

public String getFlowRunId()

Unique ID of the flow run, which could change on subsequent runs of the same flow.

Specified by:

getFlowRunId in interface IFlow

Specified by:

getFlowRunId in interface IFlowFieldOperation

getFlowSchedule

public String getFlowSchedule()

Schedule for this point in the data processing or orchestration.

Specified by:

getFlowSchedule in interface IFlow

Specified by:

getFlowSchedule in interface IFlowFieldOperation

getFlowStartedAt

public Long getFlowStartedAt()

Date and time at which this point in the data processing or orchestration started.

Specified by:

getFlowStartedAt in interface IFlow

Specified by:

getFlowStartedAt in interface IFlowFieldOperation

getFlowStatus

public String getFlowStatus()

Overall status of this point in the data processing or orchestration.

Specified by:

getFlowStatus in interface IFlow

Specified by:

getFlowStatus in interface IFlowFieldOperation

getInputs

public SortedSet<ICatalog> getInputs()

Assets that are inputs to this process.

Specified by:

getInputs in interface IColumnProcess

Specified by:

getInputs in interface IFlowFieldOperation

Specified by:

getInputs in interface ILineageProcess

getMatillionComponent

public IMatillionComponent getMatillionComponent()

Matillion component that contains the logic for this lineage process.

Specified by:

getMatillionComponent in interface IColumnProcess

Specified by:

getMatillionComponent in interface IFlowFieldOperation

Specified by:

getMatillionComponent in interface ILineageProcess

getOutputs

public SortedSet<ICatalog> getOutputs()

Assets that are outputs from this process.

Specified by:

getOutputs in interface IColumnProcess

Specified by:

getOutputs in interface IFlowFieldOperation

Specified by:

getOutputs in interface ILineageProcess

getParentConnectionProcessQualifiedNames

public SortedSet<String> getParentConnectionProcessQualifiedNames()

TBC

Specified by:

getParentConnectionProcessQualifiedNames in interface IColumnProcess

Specified by:

getParentConnectionProcessQualifiedNames in interface IFlowFieldOperation

Specified by:

getParentConnectionProcessQualifiedNames in interface ILineageProcess

getPowerBIDataflow

public IPowerBIDataflow getPowerBIDataflow()

PowerBI Dataflow that is associated with this lineage process.

Specified by:

getPowerBIDataflow in interface IColumnProcess

Specified by:

getPowerBIDataflow in interface IFlowFieldOperation

Specified by:

getPowerBIDataflow in interface ILineageProcess

getProcess

public ILineageProcess getProcess()

Process in which this task exists.

Specified by:

getProcess in interface IColumnProcess

Specified by:

getProcess in interface IFlowFieldOperation

getSparkJobs

public SortedSet<ISparkJob> getSparkJobs()

TBC

Specified by:

getSparkJobs in interface IColumnProcess

Specified by:

getSparkJobs in interface IFlowFieldOperation

Specified by:

getSparkJobs in interface ILineageProcess

getSql

public String getSql()

SQL query that ran to produce the outputs.

Specified by:

getSql in interface IColumnProcess

Specified by:

getSql in interface IFlowFieldOperation

Specified by:

getSql in interface ILineageProcess

equals

public boolean equals(Object o)

Overrides:

equals in class Asset

canEqual

protected boolean canEqual(Object other)

Overrides:

canEqual in class Asset

hashCode

public int hashCode()

Overrides:

hashCode in class Asset

toString

public String toString()

Description copied from class: AtlanObject

Overrides:

toString in class Asset

getTypeName

public String getTypeName()

Fixed typeName for FlowFieldOperations.

Specified by:

getTypeName in interface AuditDetail

Specified by:

getTypeName in interface IAsset

Specified by:

getTypeName in interface IColumnProcess

Specified by:

getTypeName in interface IFlow

Specified by:

getTypeName in interface IFlowFieldOperation

Specified by:

getTypeName in interface ILineageProcess

Specified by:

getTypeName in interface IReferenceable

Overrides:

getTypeName in class Reference