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

Class UploadIdResponseInterceptor

java.lang.Object

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

All Implemented Interfaces:

com.google.api.client.http.HttpResponseInterceptor

public class UploadIdResponseInterceptor
extends Object
implements com.google.api.client.http.HttpResponseInterceptor

Implements a response intercepter that logs the upload id if the upload id header exists and it is the first request (does not have upload_id parameter in the request). Only logs if debug level is enabled.

Constructor Summary

Constructors

Constructor	Description
UploadIdResponseInterceptor()

Method Summary

Modifier and Type	Method	Description
void	interceptResponse(com.google.api.client.http.HttpResponse response)

Methods inherited from class java.lang.Object

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

Constructor Details

UploadIdResponseInterceptor

public UploadIdResponseInterceptor()

Method Details

interceptResponse

public void interceptResponse(com.google.api.client.http.HttpResponse response)
                       throws IOException

Specified by:

interceptResponse in interface com.google.api.client.http.HttpResponseInterceptor

Throws:

IOException