Package org.apache.calcite.avatica.remote

Class MockProtobufService

java.lang.Object

org.apache.calcite.avatica.remote.AbstractService

org.apache.calcite.avatica.remote.ProtobufService

org.apache.calcite.avatica.remote.MockProtobufService

All Implemented Interfaces:

Service

public class MockProtobufService
extends ProtobufService

A mock implementation of ProtobufService for testing.

It performs no serialization of requests and responses.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MockProtobufService.MockProtobufServiceFactory	A factory that instantiates the mock protobuf service.

Nested classes/interfaces inherited from class org.apache.calcite.avatica.remote.AbstractService

AbstractService.SerializationType

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 java.lang.String	connectionId
private java.util.Map<Service.Request,Service.Response>	mapping

Constructor Summary

Constructors

Constructor	Description
MockProtobufService(java.lang.String connectionId)

Method Summary

Modifier and Type	Method	Description
Service.Response	_apply(Service.Request request)	Derived class should implement this method to transport requests and responses to and from the peer service.
private java.util.Map<Service.Request,Service.Response>	createMapping()
private Service.Response	dispatch(Service.Request request)	Fetches the static response for the given request.

Methods inherited from class org.apache.calcite.avatica.remote.ProtobufService

apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, apply, castProtobufMessage, getSerializationType

Methods inherited from class org.apache.calcite.avatica.remote.AbstractService

finagle, finagle, finagle, finagle, finagle, finagle, setRpcMetadata

Methods inherited from class java.lang.Object

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

Field Detail

connectionId

private final java.lang.String connectionId

mapping

private final java.util.Map<Service.Request,Service.Response> mapping

Constructor Detail

MockProtobufService

public MockProtobufService(java.lang.String connectionId)

Method Detail

createMapping

private java.util.Map<Service.Request,Service.Response> createMapping()

_apply

public Service.Response _apply(Service.Request request)

Description copied from class: ProtobufService

Derived class should implement this method to transport requests and responses to and from the peer service.

Specified by:

_apply in class ProtobufService

dispatch

private Service.Response dispatch(Service.Request request)

Fetches the static response for the given request.

Parameters:

request - the client's request

Returns:

the appropriate response

Throws:

java.lang.RuntimeException - if no mapping is found for the request