org.apache.beam.sdk.extensions.gcp.util

Class LatencyRecordingHttpRequestInitializer

java.lang.Object

org.apache.beam.sdk.extensions.gcp.util.LatencyRecordingHttpRequestInitializer

All Implemented Interfaces:

com.google.api.client.http.HttpRequestInitializer

public class LatencyRecordingHttpRequestInitializer
extends java.lang.Object
implements com.google.api.client.http.HttpRequestInitializer

HttpRequestInitializer for recording request to response latency of Http-based API calls.

Constructor Summary

Constructors

Constructor and Description
LatencyRecordingHttpRequestInitializer(org.apache.beam.sdk.util.Histogram requestLatencies)

Method Summary

Modifier and Type	Method and Description
void	initialize(com.google.api.client.http.HttpRequest request)

Methods inherited from class java.lang.Object

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

Constructor Detail

LatencyRecordingHttpRequestInitializer

public LatencyRecordingHttpRequestInitializer(org.apache.beam.sdk.util.Histogram requestLatencies)

Method Detail

initialize

public void initialize(com.google.api.client.http.HttpRequest request)
                throws java.io.IOException

Specified by:

initialize in interface com.google.api.client.http.HttpRequestInitializer

Throws:

java.io.IOException