com.databricks.sdk.core

Class ApiClient

java.lang.Object

com.databricks.sdk.core.ApiClient

public class ApiClient
extends Object

Simplified REST API client with retries, JSON POJO SerDe through Jackson and exception POJO guessing

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ApiClient.Builder

Constructor Summary

Constructors

Constructor and Description
ApiClient()
ApiClient(DatabricksConfig config)
ApiClient(DatabricksConfig config, Timer timer)

Method Summary

Modifier and Type	Method and Description
String	configuredAccountID()
<T> T	deserialize(InputStream body, com.fasterxml.jackson.databind.JavaType target)
<T> T	deserialize(Response response, Class<T> target)
<T> void	deserialize(Response response, T object)
<T> T	execute(Request in, Class<T> target) Executes HTTP request with retries and converts it to proper POJO.
<T> T	execute(Request in, Class<T> target, RequestOptions options) Executes HTTP request with retries and converts it to proper POJO, using custom request options.
static Optional<Long>	getBackoffFromRetryAfterHeader(Response response)
long	getBackoffMillis(Response response, int attemptNumber)
<O> Collection<O>	getCollection(Request req, Class<O> element)
HttpClient	getHttpClient()
Map<String,String>	getStringMap(Request req)
String	serialize(Object body)
static <I> void	setQuery(Request in, I entity)
protected <I,O> O	withJavaType(Request request, com.fasterxml.jackson.databind.JavaType javaType)

Methods inherited from class java.lang.Object

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

Constructor Detail

ApiClient

public ApiClient()

ApiClient

public ApiClient(DatabricksConfig config)

ApiClient

public ApiClient(DatabricksConfig config,
                 Timer timer)

Method Detail

configuredAccountID

public String configuredAccountID()

setQuery

public static <I> void setQuery(Request in,
                                I entity)

getCollection

public <O> Collection<O> getCollection(Request req,
                                       Class<O> element)

getStringMap

public Map<String,String> getStringMap(Request req)

withJavaType

protected <I,O> O withJavaType(Request request,
                               com.fasterxml.jackson.databind.JavaType javaType)

execute

public <T> T execute(Request in,
                     Class<T> target)
              throws IOException

Executes HTTP request with retries and converts it to proper POJO.

Parameters:

in - Commons HTTP request

target - Expected pojo type

Returns:

POJO of requested type

Throws:

IOException

execute

public <T> T execute(Request in,
                     Class<T> target,
                     RequestOptions options)
              throws IOException

Executes HTTP request with retries and converts it to proper POJO, using custom request options.

Parameters:

in - Commons HTTP request

target - Expected pojo type

options - Optional request options to customize request behavior

Returns:

POJO of requested type

Throws:

IOException

getBackoffMillis

public long getBackoffMillis(Response response,
                             int attemptNumber)

getBackoffFromRetryAfterHeader

public static Optional<Long> getBackoffFromRetryAfterHeader(Response response)

deserialize

public <T> T deserialize(Response response,
                         Class<T> target)
                  throws IOException

Throws:

IOException

deserialize

public <T> T deserialize(InputStream body,
                         com.fasterxml.jackson.databind.JavaType target)
                  throws IOException

Throws:

IOException

deserialize

public <T> void deserialize(Response response,
                            T object)
                     throws IOException

Throws:

IOException

serialize

public String serialize(Object body)
                 throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

getHttpClient

public HttpClient getHttpClient()