Package io.openlineage.client

Class OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder

java.lang.Object

io.openlineage.client.OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder

All Implemented Interfaces:

OpenLineage.Builder<OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetrics>

Enclosing class:

OpenLineage

public static final class OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder
extends Object
implements OpenLineage.Builder<OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetrics>

builder class for IcebergCommitReportOutputDatasetFacetCommitMetrics

Constructor Summary

Constructors

Constructor	Description
IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder()

Method Summary

Modifier and Type	Method	Description
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	addedDataFiles(Double addedDataFiles)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	addedDeleteFiles(Double addedDeleteFiles)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	addedDVs(Double addedDVs)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	addedEqualityDeleteFiles(Double addedEqualityDeleteFiles)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	addedEqualityDeletes(Double addedEqualityDeletes)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	addedFilesSizeInBytes(Double addedFilesSizeInBytes)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	addedPositionalDeleteFiles(Double addedPositionalDeleteFiles)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	addedPositionalDeletes(Double addedPositionalDeletes)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	addedRecords(Double addedRecords)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	attempts(Double attempts)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetrics	build()	build an instance of IcebergCommitReportOutputDatasetFacetCommitMetrics from the fields set in the builder
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	removedDataFiles(Double removedDataFiles)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	removedDeleteFiles(Double removedDeleteFiles)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	removedDVs(Double removedDVs)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	removedEqualityDeleteFiles(Double removedEqualityDeleteFiles)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	removedEqualityDeletes(Double removedEqualityDeletes)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	removedFilesSizeInBytes(Double removedFilesSizeInBytes)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	removedPositionalDeleteFiles(Double removedPositionalDeleteFiles)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	removedPositionalDeletes(Double removedPositionalDeletes)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	removedRecords(Double removedRecords)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	totalDataFiles(Double totalDataFiles)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	totalDeleteFiles(Double totalDeleteFiles)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	totalDuration(Double totalDuration)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	totalEqualityDeletes(Double totalEqualityDeletes)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	totalFilesSizeInBytes(Double totalFilesSizeInBytes)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	totalPositionalDeletes(Double totalPositionalDeletes)
OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder	totalRecords(Double totalRecords)

Methods inherited from class java.lang.Object

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

Constructor Details

IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder

public IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder()

Method Details

totalDuration

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder totalDuration(Double totalDuration)

Parameters:

totalDuration - Duration of the commit in MILLISECONDS

Returns:

this

attempts

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder attempts(Double attempts)

Parameters:

attempts - Number of attempts made to commit the iceberg table

Returns:

this

addedDataFiles

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder addedDataFiles(Double addedDataFiles)

Parameters:

addedDataFiles - Number of data files that are added during the commit

Returns:

this

removedDataFiles

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder removedDataFiles(Double removedDataFiles)

Parameters:

removedDataFiles - Number of data files that are removed during the commit

Returns:

this

totalDataFiles

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder totalDataFiles(Double totalDataFiles)

Parameters:

totalDataFiles - Total number of data files that are present in the iceberg table

Returns:

this

addedDeleteFiles

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder addedDeleteFiles(Double addedDeleteFiles)

Parameters:

addedDeleteFiles - Number of delete files that are added during the commit

Returns:

this

addedEqualityDeleteFiles

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder addedEqualityDeleteFiles(Double addedEqualityDeleteFiles)

Parameters:

addedEqualityDeleteFiles - Number of added equality delete files

Returns:

this

addedPositionalDeleteFiles

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder addedPositionalDeleteFiles(Double addedPositionalDeleteFiles)

Parameters:

addedPositionalDeleteFiles - Number of added positional delete files

Returns:

this

addedDVs

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder addedDVs(Double addedDVs)

Parameters:

addedDVs - Number of added DVs

Returns:

this

removedDeleteFiles

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder removedDeleteFiles(Double removedDeleteFiles)

Parameters:

removedDeleteFiles - Number of delete files that are removed during the commit

Returns:

this

removedEqualityDeleteFiles

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder removedEqualityDeleteFiles(Double removedEqualityDeleteFiles)

Parameters:

removedEqualityDeleteFiles - Number of removed equality delete files

Returns:

this

removedPositionalDeleteFiles

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder removedPositionalDeleteFiles(Double removedPositionalDeleteFiles)

Parameters:

removedPositionalDeleteFiles - Number of removed positional delete files

Returns:

this

removedDVs

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder removedDVs(Double removedDVs)

Parameters:

removedDVs - Number of removed DVs

Returns:

this

totalDeleteFiles

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder totalDeleteFiles(Double totalDeleteFiles)

Parameters:

totalDeleteFiles - Total number of temporary delete files that are present in the iceberg table

Returns:

this

addedRecords

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder addedRecords(Double addedRecords)

Parameters:

addedRecords - Number of records that are added during the commit

Returns:

this

removedRecords

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder removedRecords(Double removedRecords)

Parameters:

removedRecords - Number of records that are removed during the commit

Returns:

this

totalRecords

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder totalRecords(Double totalRecords)

Parameters:

totalRecords - Number of records that are present in the iceberg table

Returns:

this

addedFilesSizeInBytes

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder addedFilesSizeInBytes(Double addedFilesSizeInBytes)

Parameters:

addedFilesSizeInBytes - Number of files size in bytes that are added during the commit

Returns:

this

removedFilesSizeInBytes

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder removedFilesSizeInBytes(Double removedFilesSizeInBytes)

Parameters:

removedFilesSizeInBytes - Number of files size in bytes that are removed during the commit

Returns:

this

totalFilesSizeInBytes

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder totalFilesSizeInBytes(Double totalFilesSizeInBytes)

Parameters:

totalFilesSizeInBytes - Number of files size in bytes in the iceberg table

Returns:

this

addedPositionalDeletes

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder addedPositionalDeletes(Double addedPositionalDeletes)

Parameters:

addedPositionalDeletes - Number of positional deletes that are added during the commit

Returns:

this

removedPositionalDeletes

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder removedPositionalDeletes(Double removedPositionalDeletes)

Parameters:

removedPositionalDeletes - Number of positional deletes that are removed during the commit

Returns:

this

totalPositionalDeletes

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder totalPositionalDeletes(Double totalPositionalDeletes)

Parameters:

totalPositionalDeletes - Number of positional deletes that are present in the iceberg table

Returns:

this

addedEqualityDeletes

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder addedEqualityDeletes(Double addedEqualityDeletes)

Parameters:

addedEqualityDeletes - Number of equality deletes that are added during the commit

Returns:

this

removedEqualityDeletes

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder removedEqualityDeletes(Double removedEqualityDeletes)

Parameters:

removedEqualityDeletes - Number of equality deletes that are removed during the commit

Returns:

this

totalEqualityDeletes

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetricsBuilder totalEqualityDeletes(Double totalEqualityDeletes)

Parameters:

totalEqualityDeletes - Number of equality deletes that are present in the iceberg table

Returns:

this

build

public OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetrics build()

build an instance of IcebergCommitReportOutputDatasetFacetCommitMetrics from the fields set in the builder

Specified by:

build in interface OpenLineage.Builder<OpenLineage.IcebergCommitReportOutputDatasetFacetCommitMetrics>

Returns:

the constructed type