Type Alias DataTaskDatasetState

type DataTaskDatasetState = {
    cdcStatus?: {
        ddlCount?: number;
        deleteCount?: number;
        insertCount?: number;
        lastProcessed?: string;
        message?: string;
        state?:
            | "QUEUED"
            | "PROCESSING"
            | "ACCUMULATING_CHANGES"
            | "COMPLETED"
            | "ERROR";
        totalProcessedCount?: number;
        updateCount?: number;
    };
    dataReadiness?: "READY"
    | "NOT_READY"
    | "ERROR";
    datasetId?: string;
    fullLoad?: {
        cachedChangesCount?: number;
        duration?: string;
        endTime?: string;
        failedRecordsCount?: number;
        fileStats?: FileStatistics;
        message?: string;
        startTime?: string;
        state?: "QUEUED" | "LOADING" | "COMPLETED" | "ERROR";
        totalProcessedCount?: number;
    };
    lastBatchOfChanges?: {
        duration?: string;
        endTime?: string;
        fileStats?: FileStatistics;
        message?: string;
        operationStats?: OperationStatistics;
        startTime?: string;
        state?: "QUEUED"
        | "PROCESSING"
        | "COMPLETED"
        | "ERROR";
        throughputInRecordsPerSecond?: number;
        totalProcessedCount?: number;
    };
    name?: string;
    sourceName?: string;
    streaming?: {
        lastProcessed?: string;
        message?: string;
        parseIssueCount?: number;
        recordsFilteredCount?: number;
        recordsWrittenCount?: number;
        state?: "QUEUED"
        | "RUNNING"
        | "ERROR";
        totalProcessedCount?: number;
        unoptimizedRecordsCount?: number;
    };
}
Index

Properties

cdcStatus? dataReadiness? datasetId? fullLoad? lastBatchOfChanges? name? sourceName? streaming?

Properties

cdcStatus?: {
    ddlCount?: number;
    deleteCount?: number;
    insertCount?: number;
    lastProcessed?: string;
    message?: string;
    state?:
        | "QUEUED"
        | "PROCESSING"
        | "ACCUMULATING_CHANGES"
        | "COMPLETED"
        | "ERROR";
    totalProcessedCount?: number;
    updateCount?: number;
}

Type Declaration

  • OptionalddlCount?: number

    Number of DDL statements executed during the last run

  • OptionaldeleteCount?: number
  • OptionalinsertCount?: number
  • OptionallastProcessed?: string
  • Optionalmessage?: string
  • Optionalstate?: "QUEUED" | "PROCESSING" | "ACCUMULATING_CHANGES" | "COMPLETED" | "ERROR"
  • OptionaltotalProcessedCount?: number
  • OptionalupdateCount?: number
dataReadiness?: "READY" | "NOT_READY" | "ERROR"
datasetId?: string
fullLoad?: {
    cachedChangesCount?: number;
    duration?: string;
    endTime?: string;
    failedRecordsCount?: number;
    fileStats?: FileStatistics;
    message?: string;
    startTime?: string;
    state?: "QUEUED" | "LOADING" | "COMPLETED" | "ERROR";
    totalProcessedCount?: number;
}

Type Declaration

  • OptionalcachedChangesCount?: number

    Number of changes captured and cached during full load (CDC landing/replication tasks only)

  • Optionalduration?: string
  • OptionalendTime?: string
  • OptionalfailedRecordsCount?: number
  • OptionalfileStats?: FileStatistics
  • Optionalmessage?: string
  • OptionalstartTime?: string
  • Optionalstate?: "QUEUED" | "LOADING" | "COMPLETED" | "ERROR"
  • OptionaltotalProcessedCount?: number
lastBatchOfChanges?: {
    duration?: string;
    endTime?: string;
    fileStats?: FileStatistics;
    message?: string;
    operationStats?: OperationStatistics;
    startTime?: string;
    state?: "QUEUED" | "PROCESSING" | "COMPLETED" | "ERROR";
    throughputInRecordsPerSecond?: number;
    totalProcessedCount?: number;
}

Type Declaration

  • Optionalduration?: string

    Duration in HH:MM:SS format (hours:minutes:seconds)

  • OptionalendTime?: string
  • OptionalfileStats?: FileStatistics
  • Optionalmessage?: string
  • OptionaloperationStats?: OperationStatistics
  • OptionalstartTime?: string
  • Optionalstate?: "QUEUED" | "PROCESSING" | "COMPLETED" | "ERROR"
  • OptionalthroughputInRecordsPerSecond?: number
  • OptionaltotalProcessedCount?: number
name?: string
sourceName?: string
streaming?: {
    lastProcessed?: string;
    message?: string;
    parseIssueCount?: number;
    recordsFilteredCount?: number;
    recordsWrittenCount?: number;
    state?: "QUEUED" | "RUNNING" | "ERROR";
    totalProcessedCount?: number;
    unoptimizedRecordsCount?: number;
}

Type Declaration

  • OptionallastProcessed?: string

    Timestamp of the latest source record inserted into the target dataset.

  • Optionalmessage?: string
  • OptionalparseIssueCount?: number
  • OptionalrecordsFilteredCount?: number
  • OptionalrecordsWrittenCount?: number
  • Optionalstate?: "QUEUED" | "RUNNING" | "ERROR"
  • OptionaltotalProcessedCount?: number
  • OptionalunoptimizedRecordsCount?: number

Settings

Member Visibility

On This Page

Properties