public abstract class ProtobufService extends AbstractService
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
Constructor and Description |
---|
ProtobufService() |
setRpcMetadata
public abstract Service.Response _apply(Service.Request request)
public Service.ResultSetResponse apply(Service.CatalogsRequest request)
public Service.ResultSetResponse apply(Service.SchemasRequest request)
public Service.ResultSetResponse apply(Service.TablesRequest request)
public Service.ResultSetResponse apply(Service.TableTypesRequest request)
public Service.ResultSetResponse apply(Service.TypeInfoRequest request)
public Service.ResultSetResponse apply(Service.ColumnsRequest request)
public Service.PrepareResponse apply(Service.PrepareRequest request)
public Service.ExecuteResponse apply(Service.PrepareAndExecuteRequest request)
public Service.FetchResponse apply(Service.FetchRequest request)
public Service.CreateStatementResponse apply(Service.CreateStatementRequest request)
public Service.CloseStatementResponse apply(Service.CloseStatementRequest request)
public Service.OpenConnectionResponse apply(Service.OpenConnectionRequest request)
public Service.CloseConnectionResponse apply(Service.CloseConnectionRequest request)
public Service.ConnectionSyncResponse apply(Service.ConnectionSyncRequest request)
public Service.DatabasePropertyResponse apply(Service.DatabasePropertyRequest request)
public Service.ExecuteResponse apply(Service.ExecuteRequest request)
public Service.SyncResultsResponse apply(Service.SyncResultsRequest request)
public Service.CommitResponse apply(Service.CommitRequest request)
public Service.RollbackResponse apply(Service.RollbackRequest request)
public Service.ExecuteBatchResponse apply(Service.PrepareAndExecuteBatchRequest request)
public Service.ExecuteBatchResponse apply(Service.ExecuteBatchRequest request)
public static <T extends com.google.protobuf.Message> T castProtobufMessage(com.google.protobuf.Message msg, Class<T> expectedType)
Message
is an instance of the Class given by
expectedType
. Throws an IllegalArgumentException if the message is not of the
expected type, otherwise, it returns the message cast as the expected type.msg
- A Protocol Buffer message.expectedType
- The expected type of the Protocol Buffer message.IllegalArgumentException
- If the type of the message is not the expectedType.Copyright © 2012–2018 The Apache Software Foundation. All rights reserved.