Class LocalService
- java.lang.Object
-
- org.apache.calcite.avatica.remote.LocalService
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.calcite.avatica.remote.Service
Service.Base, Service.CatalogsRequest, Service.CloseConnectionRequest, Service.CloseConnectionResponse, Service.CloseStatementRequest, Service.CloseStatementResponse, Service.ColumnsRequest, Service.CommitRequest, Service.CommitResponse, Service.ConnectionSyncRequest, Service.ConnectionSyncResponse, Service.CreateStatementRequest, Service.CreateStatementResponse, Service.DatabasePropertyRequest, Service.DatabasePropertyResponse, Service.ErrorResponse, Service.ExecuteBatchRequest, Service.ExecuteBatchResponse, Service.ExecuteRequest, Service.ExecuteResponse, Service.Factory, Service.FetchRequest, Service.FetchResponse, Service.OpenConnectionRequest, Service.OpenConnectionResponse, Service.PrepareAndExecuteBatchRequest, Service.PrepareAndExecuteRequest, Service.PrepareRequest, Service.PrepareResponse, Service.Request, Service.Response, Service.ResultSetResponse, Service.RollbackRequest, Service.RollbackResponse, Service.RpcMetadataResponse, Service.SchemasRequest, Service.SyncResultsRequest, Service.SyncResultsResponse, Service.TablesRequest, Service.TableTypesRequest, Service.TypeInfoRequest
-
-
Field Summary
Fields Modifier and Type Field Description private org.apache.calcite.avatica.metrics.TimercommitTimerprivate org.apache.calcite.avatica.metrics.TimerconnectionSyncTimerprivate org.apache.calcite.avatica.metrics.TimerexecuteTimer(package private) Metameta(package private) org.apache.calcite.avatica.metrics.MetricsSystemmetricsprivate org.apache.calcite.avatica.metrics.TimerprepareAndExecuteTimerprivate org.apache.calcite.avatica.metrics.TimerprepareTimerprivate Service.RpcMetadataResponseserverLevelRpcMetadata
-
Constructor Summary
Constructors Constructor Description LocalService(Meta meta)LocalService(Meta meta, org.apache.calcite.avatica.metrics.MetricsSystem metrics)
-
Method Summary
-
-
-
Field Detail
-
meta
final Meta meta
-
metrics
final org.apache.calcite.avatica.metrics.MetricsSystem metrics
-
executeTimer
private final org.apache.calcite.avatica.metrics.Timer executeTimer
-
commitTimer
private final org.apache.calcite.avatica.metrics.Timer commitTimer
-
prepareTimer
private final org.apache.calcite.avatica.metrics.Timer prepareTimer
-
prepareAndExecuteTimer
private final org.apache.calcite.avatica.metrics.Timer prepareAndExecuteTimer
-
connectionSyncTimer
private final org.apache.calcite.avatica.metrics.Timer connectionSyncTimer
-
serverLevelRpcMetadata
private Service.RpcMetadataResponse serverLevelRpcMetadata
-
-
Method Detail
-
name
private static java.lang.String name(java.lang.String timer)
-
setRpcMetadata
public void setRpcMetadata(Service.RpcMetadataResponse serverLevelRpcMetadata)
Description copied from interface:ServiceSets server-level metadata for RPCs. This includes information that is static across all RPCs.- Specified by:
setRpcMetadatain interfaceService- Parameters:
serverLevelRpcMetadata- The server-level metadata.
-
list
private static <E> java.util.List<E> list(java.lang.Iterable<E> iterable)
-
toResponse
public Service.ResultSetResponse toResponse(Meta.MetaResultSet resultSet)
Converts a result set (not serializable) into a serializable response.
-
apply
public Service.ResultSetResponse apply(Service.CatalogsRequest request)
-
apply
public Service.ResultSetResponse apply(Service.SchemasRequest request)
-
apply
public Service.ResultSetResponse apply(Service.TablesRequest request)
-
apply
public Service.ResultSetResponse apply(Service.TableTypesRequest request)
-
apply
public Service.ResultSetResponse apply(Service.TypeInfoRequest request)
-
apply
public Service.ResultSetResponse apply(Service.ColumnsRequest request)
-
apply
public Service.PrepareResponse apply(Service.PrepareRequest request)
-
apply
public Service.ExecuteResponse apply(Service.PrepareAndExecuteRequest request)
-
apply
public Service.FetchResponse apply(Service.FetchRequest request)
-
apply
public Service.ExecuteResponse apply(Service.ExecuteRequest request)
-
apply
public Service.CreateStatementResponse apply(Service.CreateStatementRequest request)
-
apply
public Service.CloseStatementResponse apply(Service.CloseStatementRequest request)
-
apply
public Service.OpenConnectionResponse apply(Service.OpenConnectionRequest request)
-
apply
public Service.CloseConnectionResponse apply(Service.CloseConnectionRequest request)
-
apply
public Service.ConnectionSyncResponse apply(Service.ConnectionSyncRequest request)
-
apply
public Service.DatabasePropertyResponse apply(Service.DatabasePropertyRequest request)
-
apply
public Service.SyncResultsResponse apply(Service.SyncResultsRequest request)
-
apply
public Service.CommitResponse apply(Service.CommitRequest request)
-
apply
public Service.RollbackResponse apply(Service.RollbackRequest request)
-
apply
public Service.ExecuteBatchResponse apply(Service.PrepareAndExecuteBatchRequest request)
-
apply
public Service.ExecuteBatchResponse apply(Service.ExecuteBatchRequest request)
-
-