Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion sdk/src/main/java/com/atlan/model/assets/BIProcess.java
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ public class BIProcess extends Asset implements IBIProcess, ILineageProcess, IAs
@Singular
SortedSet<IFabricActivity> fabricActivities;

/** fivetranConnector in which this process exists. */
/** Fivetran connector in which this process exists. */
@Attribute
IFivetranConnector fivetranConnector;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ public class ColumnProcess extends Asset implements IColumnProcess, ILineageProc
@Singular
SortedSet<IFabricActivity> fabricActivities;

/** fivetranConnector in which this process exists. */
/** Fivetran connector in which this process exists. */
@Attribute
IFivetranConnector fivetranConnector;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ public class ConnectionProcess extends Asset implements IConnectionProcess, ILin
@Singular
SortedSet<IFabricActivity> fabricActivities;

/** fivetranConnector in which this process exists. */
/** Fivetran connector in which this process exists. */
@Attribute
IFivetranConnector fivetranConnector;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -181,7 +181,7 @@ public class DbtColumnProcess extends Asset
@Singular
SortedSet<IFabricActivity> fabricActivities;

/** fivetranConnector in which this process exists. */
/** Fivetran connector in which this process exists. */
@Attribute
IFivetranConnector fivetranConnector;

Expand Down
2 changes: 1 addition & 1 deletion sdk/src/main/java/com/atlan/model/assets/DbtProcess.java
Original file line number Diff line number Diff line change
Expand Up @@ -186,7 +186,7 @@ public class DbtProcess extends Asset implements IDbtProcess, ILineageProcess, I
@Singular
SortedSet<IFabricActivity> fabricActivities;

/** fivetranConnector in which this process exists. */
/** Fivetran connector in which this process exists. */
@Attribute
IFivetranConnector fivetranConnector;

Expand Down
90 changes: 53 additions & 37 deletions sdk/src/main/java/com/atlan/model/assets/FivetranConnector.java
Original file line number Diff line number Diff line change
Expand Up @@ -54,171 +54,187 @@ public class FivetranConnector extends Asset
@Attribute
String catalogDatasetGuid;

/** Total credits used by this destination */
/** Total credits used by this destination. */
@Attribute
Double fivetranConnectorCreditsUsed;

/** Destination name added by the user on Fivetran */
/** Destination name added by the user on Fivetran. */
@Attribute
String fivetranConnectorDestinationName;

/** Type of destination on Fivetran. Eg: redshift, bigquery etc. */
@Attribute
String fivetranConnectorDestinationType;

/** URL to open the destination details on Fivetran */
/** URL to open the destination details on Fivetran. */
@Attribute
String fivetranConnectorDestinationURL;

/** Extract time in seconds in the latest sync on fivetran */
/** Extract time in seconds in the latest sync on fivetran. */
@Attribute
Double fivetranConnectorLastSyncExtractTimeSeconds;

/** Extracted data volume in metabytes in the latest sync on Fivetran */
/** Extracted data volume in metabytes in the latest sync on Fivetran. */
@Attribute
Double fivetranConnectorLastSyncExtractVolumeMegabytes;

/** Timestamp (epoch) when the latest sync finished on Fivetran, in milliseconds */
/** Timestamp (epoch) when the latest sync finished on Fivetran, in milliseconds. */
@Attribute
@Date
Long fivetranConnectorLastSyncFinishedAt;

/** ID of the latest sync */
/** ID of the latest sync. */
@Attribute
String fivetranConnectorLastSyncId;

/** Load time in seconds in the latest sync on Fivetran */
/** Load time in seconds in the latest sync on Fivetran. */
@Attribute
Double fivetranConnectorLastSyncLoadTimeSeconds;

/** Loaded data volume in metabytes in the latest sync on Fivetran */
/** Loaded data volume in metabytes in the latest sync on Fivetran. */
@Attribute
Double fivetranConnectorLastSyncLoadVolumeMegabytes;

/** Process time in seconds in the latest sync on Fivetran */
/** Process time in seconds in the latest sync on Fivetran. */
@Attribute
Double fivetranConnectorLastSyncProcessTimeSeconds;

/** Process volume in metabytes in the latest sync on Fivetran */
/** Process volume in metabytes in the latest sync on Fivetran. */
@Attribute
Double fivetranConnectorLastSyncProcessVolumeMegabytes;

/** Failure reason for the latest sync on Fivetran. If status is FAILURE, this is the description of the reason why the sync failed. If status is FAILURE_WITH_TASK, this is the description of the Error. If status is RESCHEDULED, this is the description of the reason why the sync is rescheduled. */
@Attribute
String fivetranConnectorLastSyncReason;

/** Timestamp (epoch) at which the latest sync is rescheduled at on Fivetran */
/** Timestamp (epoch) at which the latest sync is rescheduled at on Fivetran. */
@Attribute
@Date
Long fivetranConnectorLastSyncRescheduledAt;

/** Timestamp (epoch) when the latest sync started on Fivetran, in milliseconds */
/** Timestamp (epoch) when the latest sync started on Fivetran, in milliseconds. */
@Attribute
@Date
Long fivetranConnectorLastSyncStartedAt;

/** Number of tables synced in the latest sync on Fivetran */
/** Number of tables synced in the latest sync on Fivetran. */
@Attribute
Long fivetranConnectorLastSyncTablesSynced;

/** Failure task type for the latest sync on Fivetran. If status is FAILURE_WITH_TASK or RESCHEDULED, this field displays the type of the Error that caused the failure or rescheduling, respectively, e.g., reconnect, update_service_account, etc. */
@Attribute
String fivetranConnectorLastSyncTaskType;

/** Total sync time in seconds in the latest sync on Fivetran */
/** Total sync time in seconds in the latest sync on Fivetran. */
@Attribute
Double fivetranConnectorLastSyncTotalTimeSeconds;

/** Increase in the percentage of free MAR compared to the previous month */
/** Increase in the percentage of free MAR compared to the previous month. */
@Attribute
Double fivetranConnectorMonthlyActiveRowsChangePercentageFree;

/** Increase in the percentage of paid MAR compared to the previous month */
/** Increase in the percentage of paid MAR compared to the previous month. */
@Attribute
Double fivetranConnectorMonthlyActiveRowsChangePercentagePaid;

/** Increase in the percentage of total MAR compared to the previous month */
/** Increase in the percentage of total MAR compared to the previous month. */
@Attribute
Double fivetranConnectorMonthlyActiveRowsChangePercentageTotal;

/** Free Monthly Active Rows used by the connector in the past month */
/** Free Monthly Active Rows used by the connector in the past month. */
@Attribute
Long fivetranConnectorMonthlyActiveRowsFree;

/** Percentage of the account's total free MAR used by this connector */
/** Percentage of the account's total free MAR used by this connector. */
@Attribute
Double fivetranConnectorMonthlyActiveRowsFreePercentageOfAccount;

/** Paid Monthly Active Rows used by the connector in the past month */
/** Paid Monthly Active Rows used by the connector in the past month. */
@Attribute
Long fivetranConnectorMonthlyActiveRowsPaid;

/** Percentage of the account's total paid MAR used by this connector */
/** Percentage of the account's total paid MAR used by this connector. */
@Attribute
Double fivetranConnectorMonthlyActiveRowsPaidPercentageOfAccount;

/** Total Monthly Active Rows used by the connector in the past month */
/** Total Monthly Active Rows used by the connector in the past month. */
@Attribute
Long fivetranConnectorMonthlyActiveRowsTotal;

/** Percentage of the account's total MAR used by this connector */
/** Percentage of the account's total MAR used by this connector. */
@Attribute
Double fivetranConnectorMonthlyActiveRowsTotalPercentageOfAccount;

/** Connector name added by the user on Fivetran */
/** Connector name added by the user on Fivetran. */
@Attribute
String fivetranConnectorName;

/** Sync frequency for the connector in number of hours. Eg: Every 6 hours */
/** Database of the source system this connector reads from. */
@Attribute
String fivetranConnectorSourceDatabase;

/** Host of the source system (database or SFTP/FTP server) this connector reads from. */
@Attribute
String fivetranConnectorSourceHost;

/** Location of the source data: folder URL, bucket, storage account/container, or instance URL. */
@Attribute
String fivetranConnectorSourceLocation;

/** Folder prefix inside the source location. */
@Attribute
String fivetranConnectorSourcePath;

/** Sync frequency for the connector in number of hours. Eg: Every 6 hours. */
@Attribute
String fivetranConnectorSyncFrequency;

/** Boolean to indicate whether the sync for this connector is paused or not */
/** Boolean to indicate whether the sync for this connector is paused or not. */
@Attribute
Boolean fivetranConnectorSyncPaused;

/** Timestamp (epoch) on which the connector was setup on Fivetran, in milliseconds */
/** Timestamp (epoch) on which the connector was setup on Fivetran, in milliseconds. */
@Attribute
@Date
Long fivetranConnectorSyncSetupOn;

/** Email ID of the user who setpu the connector on Fivetran */
/** Email ID of the user who setpu the connector on Fivetran. */
@Attribute
String fivetranConnectorSyncSetupUserEmail;

/** Full name of the user who setup the connector on Fivetran */
/** Full name of the user who setup the connector on Fivetran. */
@Attribute
String fivetranConnectorSyncSetupUserFullName;

/** Total five tables sorted by MAR synced by this connector */
/** Total five tables sorted by MAR synced by this connector. */
@Attribute
String fivetranConnectorTopTablesByMAR;

/** Total number of tables synced by this connector */
/** Total number of tables synced by this connector. */
@Attribute
Long fivetranConnectorTotalTablesSynced;

/** Type of connector on Fivetran. Eg: snowflake, google_analytics, notion etc. */
@Attribute
String fivetranConnectorType;

/** URL to open the connector details on Fivetran */
/** URL to open the connector details on Fivetran. */
@Attribute
String fivetranConnectorURL;

/** Total usage cost by this destination */
/** Total usage cost by this destination. */
@Attribute
Double fivetranConnectorUsageCost;

/** Number of records updated in the latest sync on Fivetran */
/** Number of records updated in the latest sync on Fivetran. */
@Attribute
Long fivetranLastSyncRecordsUpdated;

/** Status of the latest sync on Fivetran. */
@Attribute
FivetranConnectorStatus fivetranLastSyncStatus;

/** Name of the atlan fivetran workflow that updated this asset */
/** Name of the atlan fivetran workflow that updated this asset. */
@Attribute
String fivetranWorkflowName;

Expand Down Expand Up @@ -272,7 +288,7 @@ public class FivetranConnector extends Asset
@Singular
SortedSet<IPartialObject> partialChildObjects;

/** Processes related to this Fivetran connector */
/** Processes related to this Fivetran connector. */
@Attribute
@Singular
SortedSet<ILineageProcess> processes;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ public class FlowDatasetOperation extends Asset
@Singular
SortedSet<IFabricActivity> fabricActivities;

/** fivetranConnector in which this process exists. */
/** Fivetran connector in which this process exists. */
@Attribute
IFivetranConnector fivetranConnector;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ public class FlowFieldOperation extends Asset
@Singular
SortedSet<IFabricActivity> fabricActivities;

/** fivetranConnector in which this process exists. */
/** Fivetran connector in which this process exists. */
@Attribute
IFivetranConnector fivetranConnector;

Expand Down
6 changes: 6 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/ICatalog.java
Original file line number Diff line number Diff line change
Expand Up @@ -931,6 +931,12 @@ public static ICatalog getLineageReference(String typeName, String qualifiedName
case SapErpComponent.TYPE_NAME:
ref = SapErpComponent.refByQualifiedName(qualifiedName);
break;
case SapErpDataSource.TYPE_NAME:
ref = SapErpDataSource.refByQualifiedName(qualifiedName);
break;
case SapErpDataSourceField.TYPE_NAME:
ref = SapErpDataSourceField.refByQualifiedName(qualifiedName);
break;
case SapErpFioriApp.TYPE_NAME:
ref = SapErpFioriApp.refByQualifiedName(qualifiedName);
break;
Expand Down
8 changes: 4 additions & 4 deletions sdk/src/main/java/com/atlan/model/assets/IFivetran.java
Original file line number Diff line number Diff line change
Expand Up @@ -43,14 +43,14 @@ public interface IFivetran {

public static final String TYPE_NAME = "Fivetran";

/** Number of records updated in the latest sync on Fivetran */
/** Number of records updated in the latest sync on Fivetran. */
NumericField FIVETRAN_LAST_SYNC_RECORDS_UPDATED =
new NumericField("fivetranLastSyncRecordsUpdated", "fivetranLastSyncRecordsUpdated");

/** Status of the latest sync on Fivetran. */
KeywordField FIVETRAN_LAST_SYNC_STATUS = new KeywordField("fivetranLastSyncStatus", "fivetranLastSyncStatus");

/** Name of the atlan fivetran workflow that updated this asset */
/** Name of the atlan fivetran workflow that updated this asset. */
KeywordField FIVETRAN_WORKFLOW_NAME = new KeywordField("fivetranWorkflowName", "fivetranWorkflowName");

/** List of groups who administer this asset. (This is only used for certain asset types.) */
Expand Down Expand Up @@ -557,13 +557,13 @@ default SortedSet<IFile> getFiles() {
return null;
}

/** Number of records updated in the latest sync on Fivetran */
/** Number of records updated in the latest sync on Fivetran. */
Long getFivetranLastSyncRecordsUpdated();

/** Status of the latest sync on Fivetran. */
FivetranConnectorStatus getFivetranLastSyncStatus();

/** Name of the atlan fivetran workflow that updated this asset */
/** Name of the atlan fivetran workflow that updated this asset. */
String getFivetranWorkflowName();

/** Whether this asset has contract (true) or not (false). */
Expand Down
Loading
Loading