org.apache.beam.sdk.io.gcp.bigquery

Class StreamingInsertsMetrics.NoOpStreamingInsertsMetrics

java.lang.Object

org.apache.beam.sdk.io.gcp.bigquery.StreamingInsertsMetrics.NoOpStreamingInsertsMetrics

All Implemented Interfaces:

StreamingInsertsMetrics

Enclosing interface:

StreamingInsertsMetrics

public static class StreamingInsertsMetrics.NoOpStreamingInsertsMetrics
extends java.lang.Object
implements StreamingInsertsMetrics

No-op implementation of StreamingInsertsResults.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.io.gcp.bigquery.StreamingInsertsMetrics

StreamingInsertsMetrics.NoOpStreamingInsertsMetrics, StreamingInsertsMetrics.StreamingInsertsMetricsImpl

Method Summary

Modifier and Type	Method and Description
void	updateFailedRpcMetrics(java.time.Instant start, java.time.Instant end, java.lang.String status)
void	updateRetriedRowsWithStatus(java.lang.String status, int retriedRows)
void	updateStreamingInsertsMetrics(TableReference tableRef, int totalRows, int failedRows)
void	updateSuccessfulRpcMetrics(java.time.Instant start, java.time.Instant end)

Methods inherited from class java.lang.Object

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

Method Detail

updateRetriedRowsWithStatus

public void updateRetriedRowsWithStatus(java.lang.String status,
                                        int retriedRows)

Specified by:

updateRetriedRowsWithStatus in interface StreamingInsertsMetrics

updateFailedRpcMetrics

public void updateFailedRpcMetrics(java.time.Instant start,
                                   java.time.Instant end,
                                   java.lang.String status)

Specified by:

updateFailedRpcMetrics in interface StreamingInsertsMetrics

updateSuccessfulRpcMetrics

public void updateSuccessfulRpcMetrics(java.time.Instant start,
                                       java.time.Instant end)

Specified by:

updateSuccessfulRpcMetrics in interface StreamingInsertsMetrics

updateStreamingInsertsMetrics

public void updateStreamingInsertsMetrics(@Nullable
                                          TableReference tableRef,
                                          int totalRows,
                                          int failedRows)

Specified by:

updateStreamingInsertsMetrics in interface StreamingInsertsMetrics