Struct IngestionParentItem

pub struct IngestionParentItem {
    pub attempt_number: Option<f64>,
    pub completion_timestamp: f64,
    pub creation_timestamp: Value,
    pub error_message: Option<String>,
    pub execution_type: IngestionChildExecutionType,
    pub ingestion_execution_id: String,
    pub ingestion_name: String,
    pub ingestion_status: Option<IngestionStatus>,
    pub latest_checkpoint_timestamp: Option<f64>,
    pub parent_item_id: String,
    pub row_count: Option<f64>,
    pub start_timestamp: f64,
}

An ingestion parent item and its execution state (either full or incremental).

JSON schema

{
 "description": "An ingestion parent item and its execution state
(either full or incremental).",
 "type": "object",
 "required": [
   "completionTimestamp",
   "creationTimestamp",
   "errorMessage",
   "executionType",
   "ingestionExecutionId",
   "ingestionName",
   "parentItemId",
   "startTimestamp"
 ],
 "properties": {
   "attemptNumber": {
     "description": "The attempt number of the ingestion child
execution.",
     "type": "number"
   },
   "completionTimestamp": {
     "description": "Completion time of the ingestion child execution in
seconds since epoch.",
     "type": "number"
   },
   "errorMessage": {
     "type": [
       "string",
       "null"
     ]
   },
   "executionType": {
     "$ref": "#/components/schemas/IngestionChildExecutionType"
   },
   "ingestionExecutionId": {
     "description": "The ID of the ingestion child execution.",
     "type": "string"
   },
   "ingestionName": {
     "description": "The name of the ingestion child execution.",
     "type": "string"
   },
   "ingestionStatus": {
     "$ref": "#/components/schemas/IngestionStatus"
   },
   "latestCheckpointTimestamp": {
     "description": "The timestamp of the latest checkpoint of the
ingestion child execution.",
     "type": "number"
   },
   "parentItemId": {
     "description": "The ID of the parent item.",
     "type": "string"
   },
   "rowCount": {
     "description": "The number of rows processed in the ingestion child
execution.",
     "type": "number"
   },
   "startTimestamp": {
     "description": "Start time of the ingestion child execution in
seconds since epoch.",
     "type": "number"
   }
 },
 "additionalProperties": false,
 "x-schema-name": "IngestionParentItem"
}

Fields

attempt_number: Option<f64>

completion_timestamp: f64

creation_timestamp: Value

error_message: Option<String>

execution_type: IngestionChildExecutionType

ingestion_execution_id: String

The ID of the ingestion child execution.

ingestion_name: String

The name of the ingestion child execution.

ingestion_status: Option<IngestionStatus>

latest_checkpoint_timestamp: Option<f64>

parent_item_id: String

The ID of the parent item.

row_count: Option<f64>

start_timestamp: f64

Trait Implementations

impl Clone for IngestionParentItem

fn clone(&self) -> IngestionParentItem

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for IngestionParentItem

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for IngestionParentItem

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<&IngestionParentItem> for IngestionParentItem

fn from(value: &IngestionParentItem) -> Self

Converts to this type from the input type.

impl Serialize for IngestionParentItem

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.