public class QdsClientImpl extends Object implements QdsClient
Constructor and Description |
---|
QdsClientImpl(QdsConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
ClusterApi |
cluster()
Return cluster api factory
|
CommandApi |
command()
Return command api factory
|
DbTapApi |
dbTaps()
Return DbTaps api factory
|
HiveMetadataApi |
hiveMetadata()
Return hive metadata api factory
|
protected <T> Future<T> |
invokePreparedRequest(RequestDetails entity,
Class<T> responseType,
javax.ws.rs.client.AsyncInvoker invoker) |
protected <T> Future<T> |
invokePreparedRequest(RequestDetails entity,
javax.ws.rs.core.GenericType<T> responseType,
javax.ws.rs.client.AsyncInvoker invoker) |
protected <T> Future<T> |
invokePreparedRequest(RequestDetails entity,
javax.ws.rs.client.InvocationCallback<T> callback,
javax.ws.rs.client.AsyncInvoker invoker) |
<T> Future<T> |
invokeRequest(ForPage forPage,
RequestDetails requestDetails,
Class<T> responseType,
String... additionalPaths)
Low-level request invoker.
|
<T> Future<T> |
invokeRequest(ForPage forPage,
RequestDetails requestDetails,
javax.ws.rs.core.GenericType<T> responseType,
String... additionalPaths)
Low-level request invoker.
|
<T> Future<T> |
invokeRequest(ForPage forPage,
RequestDetails requestDetails,
javax.ws.rs.client.InvocationCallback<T> callback,
String... additionalPaths)
Low-level request invoker.
|
NotebookAPI |
notebook()
Return notebook api factory
|
protected javax.ws.rs.client.WebTarget |
prepareTarget(ForPage forPage,
RequestDetails entity,
String[] additionalPaths) |
ReportApi |
report()
Return report api factory
|
SchedulerApi |
scheduler()
Return scheduler api factory
|
AppApi |
sparkJobServerApp()
Return spark job server apps api factory
|
public QdsClientImpl(QdsConfiguration configuration)
public ClusterApi cluster()
QdsClient
public CommandApi command()
QdsClient
public HiveMetadataApi hiveMetadata()
QdsClient
hiveMetadata
in interface QdsClient
public DbTapApi dbTaps()
QdsClient
public ReportApi report()
QdsClient
public SchedulerApi scheduler()
QdsClient
public AppApi sparkJobServerApp()
QdsClient
sparkJobServerApp
in interface QdsClient
public <T> Future<T> invokeRequest(ForPage forPage, RequestDetails requestDetails, Class<T> responseType, String... additionalPaths)
QdsClient
invokeRequest
in interface QdsClient
forPage
- paging info or nullrequestDetails
- request entity or nullresponseType
- type of the responseadditionalPaths
- additional path componentspublic <T> Future<T> invokeRequest(ForPage forPage, RequestDetails requestDetails, javax.ws.rs.core.GenericType<T> responseType, String... additionalPaths)
QdsClient
invokeRequest
in interface QdsClient
forPage
- paging info or nullrequestDetails
- request entity or nullresponseType
- type of the responseadditionalPaths
- additional path componentspublic <T> Future<T> invokeRequest(ForPage forPage, RequestDetails requestDetails, javax.ws.rs.client.InvocationCallback<T> callback, String... additionalPaths)
QdsClient
invokeRequest
in interface QdsClient
forPage
- paging info or nullrequestDetails
- request entity or nullcallback
- response callbackadditionalPaths
- additional path componentsprotected <T> Future<T> invokePreparedRequest(RequestDetails entity, javax.ws.rs.client.InvocationCallback<T> callback, javax.ws.rs.client.AsyncInvoker invoker)
protected <T> Future<T> invokePreparedRequest(RequestDetails entity, Class<T> responseType, javax.ws.rs.client.AsyncInvoker invoker)
protected <T> Future<T> invokePreparedRequest(RequestDetails entity, javax.ws.rs.core.GenericType<T> responseType, javax.ws.rs.client.AsyncInvoker invoker)
protected javax.ws.rs.client.WebTarget prepareTarget(ForPage forPage, RequestDetails entity, String[] additionalPaths)
public void close()
public NotebookAPI notebook()
QdsClient
Copyright © 2020. All rights reserved.