Package com.snowflake.connectors.application.observability

Class IngestionRun

java.lang.Object

com.snowflake.connectors.application.observability.IngestionRun

public class IngestionRun
extends Object

Representation of an ingestion run.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	IngestionRun.IngestionStatus	Ingestion run status.

Constructor Summary

Constructors

Constructor	Description
IngestionRun(String id, String ingestionDefinitionId, String ingestionConfigurationId, IngestionRun.IngestionStatus status, Instant startedAt, Instant completedAt, long ingestedRows, Instant updatedAt, String ingestionProcessId, Variant metadata)	Creates a new IngestionRun.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Instant	getCompletedAt()	Returns the timestamp of the ingestion run end.
String	getId()	Returns the id of this ingestion run.
Long	getIngestedRows()	Returns the number of ingested rows.
String	getIngestionConfigurationId()	Returns the ingestion configuration id.
String	getIngestionDefinitionId()	Returns the resource ingestion definition id.
String	getIngestionProcessId()	Returns the ingestion process id.
Variant	getMetadata()	Returns the ingestion run metadata.
Instant	getStartedAt()	Returns the timestamp of the ingestion run start.
IngestionRun.IngestionStatus	getStatus()	Returns the ingestion status.
Instant	getUpdatedAt()	Returns the timestamp of the last ingestion run update.
int	hashCode()

Methods inherited from class java.lang.Object

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

Constructor Detail

IngestionRun

public IngestionRun(String id,
                    String ingestionDefinitionId,
                    String ingestionConfigurationId,
                    IngestionRun.IngestionStatus status,
                    Instant startedAt,
                    Instant completedAt,
                    long ingestedRows,
                    Instant updatedAt,
                    String ingestionProcessId,
                    Variant metadata)

Creates a new IngestionRun.

Parameters:

id - ingestion run id

ingestionDefinitionId - resource ingestion definition id

ingestionConfigurationId - ingestion configuration id

status - ingestion status

startedAt - timestamp of the ingestion run start

completedAt - timestamp of the ingestion run end

ingestedRows - number of ingested rows

updatedAt - timestamp of the last ingestion run update

ingestionProcessId - ingestion process id

metadata - ingestion run metadata

Method Detail

getId

public String getId()

Returns the id of this ingestion run.

Returns:

id of this ingestion run

getIngestionDefinitionId

public String getIngestionDefinitionId()

Returns the resource ingestion definition id.

Returns:

resource ingestion definition id

getIngestionConfigurationId

public String getIngestionConfigurationId()

Returns the ingestion configuration id.

Returns:

ingestion configuration id

getStatus

public IngestionRun.IngestionStatus getStatus()

Returns the ingestion status.

Returns:

ingestion status

getStartedAt

public Instant getStartedAt()

Returns the timestamp of the ingestion run start.

Returns:

timestamp of the ingestion run start

getCompletedAt

public Instant getCompletedAt()

Returns the timestamp of the ingestion run end.

Returns:

timestamp of the ingestion run end

getIngestedRows

public Long getIngestedRows()

Returns the number of ingested rows.

Returns:

number of ingested rows

getUpdatedAt

public Instant getUpdatedAt()

Returns the timestamp of the last ingestion run update.

Returns:

timestamp of the last ingestion run update

getIngestionProcessId

public String getIngestionProcessId()

Returns the ingestion process id.

Returns:

ingestion process id

getMetadata

public Variant getMetadata()

Returns the ingestion run metadata.

Returns:

ingestion run metadata

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object