com.edmunds.rest.databricks.restclient

Class AbstractDatabricksRestClientImpl

java.lang.Object

com.edmunds.rest.databricks.restclient.AbstractDatabricksRestClientImpl

All Implemented Interfaces:

DatabricksRestClient

Direct Known Subclasses:

DatabricksRestClientImpl

public abstract class AbstractDatabricksRestClientImpl
extends Object
implements DatabricksRestClient

This is the abstract databricks rest client that contains base functionality.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	apiVersion
protected org.apache.http.client.HttpClient	client
protected String	host
protected com.fasterxml.jackson.databind.ObjectMapper	mapper
protected String	url

Constructor Summary

Constructors

Constructor and Description
AbstractDatabricksRestClientImpl(String host, String apiVersion) Creates a rest client.

Method Summary

Modifier and Type	Method and Description
protected byte[]	extractContent(org.apache.http.HttpResponse httpResponse)
String	getHost() Returns the host string.
protected String	makeCommands(Map<String,Object> data)
protected org.apache.http.client.methods.HttpDelete	makeDeleteMethod(String path)
protected org.apache.http.client.methods.HttpGet	makeGetMethod(String path, Map<String,Object> data)
protected org.apache.http.client.methods.HttpRequestBase	makeHttpMethod(RequestMethod requestMethod, String path, Map<String,Object> data)
protected org.apache.http.client.methods.HttpPatch	makePatchMethod(String path, Map<String,Object> data)
protected org.apache.http.client.methods.HttpPost	makePostMethod(String path, Map<String,Object> data)
protected org.apache.http.client.methods.HttpPut	makePutMethod(String path, Map<String,Object> data)
protected org.apache.http.entity.StringEntity	makeStringRequestEntity(Map<String,Object> data)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.edmunds.rest.databricks.restclient.DatabricksRestClient

performQuery, performQuery

Field Detail

apiVersion

protected final String apiVersion

host

protected final String host

url

protected String url

mapper

protected com.fasterxml.jackson.databind.ObjectMapper mapper

client

protected org.apache.http.client.HttpClient client

Constructor Detail

AbstractDatabricksRestClientImpl

public AbstractDatabricksRestClientImpl(String host,
                                        String apiVersion)

Creates a rest client.

Parameters:

host - databricks host

apiVersion - databricks api version

Method Detail

extractContent

protected byte[] extractContent(org.apache.http.HttpResponse httpResponse)
                         throws IOException,
                                DatabricksRestException

Throws:

IOException

DatabricksRestException

getHost

public String getHost()

Description copied from interface: DatabricksRestClient

Returns the host string.

Specified by:

getHost in interface DatabricksRestClient

Returns:

Host string.

makeHttpMethod

protected org.apache.http.client.methods.HttpRequestBase makeHttpMethod(RequestMethod requestMethod,
                                                                        String path,
                                                                        Map<String,Object> data)
                                                                 throws UnsupportedEncodingException,
                                                                        com.fasterxml.jackson.core.JsonProcessingException

Throws:

UnsupportedEncodingException

com.fasterxml.jackson.core.JsonProcessingException

makeGetMethod

protected org.apache.http.client.methods.HttpGet makeGetMethod(String path,
                                                               Map<String,Object> data)

makeDeleteMethod

protected org.apache.http.client.methods.HttpDelete makeDeleteMethod(String path)

makePatchMethod

protected org.apache.http.client.methods.HttpPatch makePatchMethod(String path,
                                                                   Map<String,Object> data)
                                                            throws UnsupportedEncodingException,
                                                                   com.fasterxml.jackson.core.JsonProcessingException

Throws:

UnsupportedEncodingException

com.fasterxml.jackson.core.JsonProcessingException

makeCommands

protected String makeCommands(Map<String,Object> data)

makePostMethod

protected org.apache.http.client.methods.HttpPost makePostMethod(String path,
                                                                 Map<String,Object> data)
                                                          throws UnsupportedEncodingException,
                                                                 com.fasterxml.jackson.core.JsonProcessingException

Throws:

UnsupportedEncodingException

com.fasterxml.jackson.core.JsonProcessingException

makePutMethod

protected org.apache.http.client.methods.HttpPut makePutMethod(String path,
                                                               Map<String,Object> data)
                                                        throws UnsupportedEncodingException,
                                                               com.fasterxml.jackson.core.JsonProcessingException

Throws:

UnsupportedEncodingException

com.fasterxml.jackson.core.JsonProcessingException

makeStringRequestEntity

protected org.apache.http.entity.StringEntity makeStringRequestEntity(Map<String,Object> data)
                                                               throws UnsupportedEncodingException,
                                                                      com.fasterxml.jackson.core.JsonProcessingException

Throws:

UnsupportedEncodingException

com.fasterxml.jackson.core.JsonProcessingException