Package org.odpi.openmetadata.frameworks.integration.openlineage

Class OpenLineageIcebergCommitReportOutputDataSetFacet

java.lang.Object

org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageFacet

org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageOutputDataSetOutputFacet

org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageIcebergCommitReportOutputDataSetFacet

public class OpenLineageIcebergCommitReportOutputDataSetFacet
extends OpenLineageOutputDataSetOutputFacet

This class represents the icebergCommitReport output dataset facet registered by Apache Iceberg. It reports the snapshot and commit metrics of a write to an Iceberg table. It follows the OpenLineage facet spec https://openlineage.io/spec/facets/1-0-2/IcebergCommitReportOutputDatasetFacet.json#/$defs/IcebergCommitReportOutputDatasetFacet.

Constructor Summary

Constructors

Constructor	Description
OpenLineageIcebergCommitReportOutputDataSetFacet()	Default constructor

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object objectToCompare)	Compare the values of the supplied object with those stored in the current object.
OpenLineageIcebergCommitReportOutputDataSetFacetMetrics	getCommitMetrics()	Return the commit metrics.
Map<String,Object>	getMetadata()	Return the additional metadata reported with the commit.
String	getOperation()	Return the operation that was performed on the Iceberg table, for example append, overwrite or delete.
Long	getSequenceNumber()	Return the sequence number of the Iceberg table.
Long	getSnapshotId()	Return the snapshot ID of the Iceberg table.
int	hashCode()	Return hash code based on properties.
void	setCommitMetrics(OpenLineageIcebergCommitReportOutputDataSetFacetMetrics commitMetrics)	Set up the commit metrics.
void	setMetadata(Map<String,Object> metadata)	Set up the additional metadata reported with the commit.
void	setOperation(String operation)	Set up the operation that was performed on the Iceberg table, for example append, overwrite or delete.
void	setSequenceNumber(Long sequenceNumber)	Set up the sequence number of the Iceberg table.
void	setSnapshotId(Long snapshotId)	Set up the snapshot ID of the Iceberg table.
String	toString()	Standard toString method.

Methods inherited from class org.odpi.openmetadata.frameworks.integration.openlineage.OpenLineageFacet

get_producer, get_schemaURL, getAdditionalProperties, set_producer, set_schemaURL, setAdditionalProperties, setAdditionalProperty

Methods inherited from class java.lang.Object

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

Constructor Details

OpenLineageIcebergCommitReportOutputDataSetFacet

public OpenLineageIcebergCommitReportOutputDataSetFacet()

Default constructor

Method Details

getSnapshotId

public Long getSnapshotId()

Return the snapshot ID of the Iceberg table.

Returns:

long

setSnapshotId

public void setSnapshotId(Long snapshotId)

Set up the snapshot ID of the Iceberg table.

Parameters:

snapshotId - long

getSequenceNumber

public Long getSequenceNumber()

Return the sequence number of the Iceberg table.

Returns:

long

setSequenceNumber

public void setSequenceNumber(Long sequenceNumber)

Set up the sequence number of the Iceberg table.

Parameters:

sequenceNumber - long

getOperation

public String getOperation()

Return the operation that was performed on the Iceberg table, for example append, overwrite or delete.

Returns:

string

setOperation

public void setOperation(String operation)

Set up the operation that was performed on the Iceberg table, for example append, overwrite or delete.

Parameters:

operation - string

getCommitMetrics

public OpenLineageIcebergCommitReportOutputDataSetFacetMetrics getCommitMetrics()

Return the commit metrics.

Returns:

bean

setCommitMetrics

public void setCommitMetrics(OpenLineageIcebergCommitReportOutputDataSetFacetMetrics commitMetrics)

Set up the commit metrics.

Parameters:

commitMetrics - bean

getMetadata

public Map<String,Object> getMetadata()

Return the additional metadata reported with the commit.

Returns:

map

setMetadata

public void setMetadata(Map<String,Object> metadata)

Set up the additional metadata reported with the commit.

Parameters:

metadata - map

toString

public String toString()

Standard toString method.

Overrides:

toString in class OpenLineageOutputDataSetOutputFacet

Returns:

print out of variables in a JSON-style

equals

public boolean equals(Object objectToCompare)

Compare the values of the supplied object with those stored in the current object.

Overrides:

equals in class OpenLineageFacet

Parameters:

objectToCompare - supplied object

Returns:

boolean result of comparison

hashCode

public int hashCode()

Return hash code based on properties.

Overrides:

hashCode in class OpenLineageFacet

Returns:

int