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

Interface StreamingInsertsMetrics

All Known Implementing Classes:

StreamingInsertsMetrics.NoOpStreamingInsertsMetrics, StreamingInsertsMetrics.StreamingInsertsMetricsImpl

public interface StreamingInsertsMetrics

Stores and exports metrics for a batch of Streaming Inserts RPCs.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	StreamingInsertsMetrics.NoOpStreamingInsertsMetrics No-op implementation of StreamingInsertsResults.
static class	StreamingInsertsMetrics.StreamingInsertsMetricsImpl Metrics of a batch of InsertAll RPCs.

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)

Method Detail

updateRetriedRowsWithStatus

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

updateFailedRpcMetrics

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

updateSuccessfulRpcMetrics

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

updateStreamingInsertsMetrics

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