Package org.apache.calcite.avatica.remote

Class ProtobufTranslationImpl

java.lang.Object

org.apache.calcite.avatica.remote.ProtobufTranslationImpl

All Implemented Interfaces:

ProtobufTranslation

public class ProtobufTranslationImpl
extends java.lang.Object
implements ProtobufTranslation

Implementation of ProtobufTranslationImpl that translates protobuf requests to POJO requests.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	ProtobufTranslationImpl.RequestTranslator	Encapsulate the logic of transforming a protobuf Request message into the Avatica POJO request.
(package private) static class	ProtobufTranslationImpl.ResponseTranslator	Encapsulate the logic of transforming a protobuf Response message into the Avatica POJO Response.

Field Summary

Fields

Modifier and Type	Field	Description
private static org.slf4j.Logger	LOG
private static java.util.Map<java.lang.Class<?>,com.google.protobuf.ByteString>	MESSAGE_CLASSES
private static java.util.Map<java.lang.String,ProtobufTranslationImpl.RequestTranslator>	REQUEST_PARSERS
private static java.util.Map<java.lang.String,ProtobufTranslationImpl.ResponseTranslator>	RESPONSE_PARSERS
private java.lang.ThreadLocal<UnsynchronizedBuffer>	threadLocalBuffer

Constructor Summary

Constructors

Constructor	Description
ProtobufTranslationImpl()

Method Summary

Modifier and Type	Method	Description
private static java.util.List<java.lang.Class<?>>	getAllMessageClasses()
(package private) com.google.protobuf.ByteString	getClassNameBytes(java.lang.Class<?> clz)
static ProtobufTranslationImpl.RequestTranslator	getParserForRequest(java.lang.String className)	Fetches the concrete message's Parser implementation.
static ProtobufTranslationImpl.ResponseTranslator	getParserForResponse(java.lang.String className)	Fetches the concrete message's Parser implementation.
Service.Request	parseRequest(byte[] bytes)	Parses a serialized protocol buffer request into a Service.Request.
Service.Response	parseResponse(byte[] bytes)	Parses a serialized protocol buffer response into a Service.Response.
(package private) void	serializeMessage(java.io.OutputStream out, com.google.protobuf.Message msg)
byte[]	serializeRequest(Service.Request request)	Serializes a Service.Request as a protocol buffer.
byte[]	serializeResponse(Service.Response response)	Serializes a Service.Response as a protocol buffer.
private static com.google.protobuf.ByteString	wrapClassName(java.lang.Class<?> clz)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

REQUEST_PARSERS

private static final java.util.Map<java.lang.String,ProtobufTranslationImpl.RequestTranslator> REQUEST_PARSERS

RESPONSE_PARSERS

private static final java.util.Map<java.lang.String,ProtobufTranslationImpl.ResponseTranslator> RESPONSE_PARSERS

MESSAGE_CLASSES

private static final java.util.Map<java.lang.Class<?>,com.google.protobuf.ByteString> MESSAGE_CLASSES

threadLocalBuffer

private final java.lang.ThreadLocal<UnsynchronizedBuffer> threadLocalBuffer

Constructor Detail

ProtobufTranslationImpl

public ProtobufTranslationImpl()

Method Detail

getAllMessageClasses

private static java.util.List<java.lang.Class<?>> getAllMessageClasses()

wrapClassName

private static com.google.protobuf.ByteString wrapClassName(java.lang.Class<?> clz)

getParserForRequest

public static ProtobufTranslationImpl.RequestTranslator getParserForRequest(java.lang.String className)

Fetches the concrete message's Parser implementation.

Parameters:

className - The protocol buffer class name

Returns:

The Parser for the class

Throws:

java.lang.IllegalArgumentException - If the argument is null or if a Parser for the given class name is not found.

getParserForResponse

public static ProtobufTranslationImpl.ResponseTranslator getParserForResponse(java.lang.String className)

Fetches the concrete message's Parser implementation.

Parameters:

className - The protocol buffer class name

Returns:

The Parser for the class

Throws:

java.lang.IllegalArgumentException - If the argument is null or if a Parser for the given class name is not found.

serializeResponse

public byte[] serializeResponse(Service.Response response)
                         throws java.io.IOException

Description copied from interface: ProtobufTranslation

Serializes a Service.Response as a protocol buffer.

Specified by:

serializeResponse in interface ProtobufTranslation

Parameters:

response - The response to serialize

Throws:

java.io.IOException - If there are errors during serialization

serializeRequest

public byte[] serializeRequest(Service.Request request)
                        throws java.io.IOException

Description copied from interface: ProtobufTranslation

Serializes a Service.Request as a protocol buffer.

Specified by:

serializeRequest in interface ProtobufTranslation

Parameters:

request - The request to serialize

Throws:

java.io.IOException - If there are errors during serialization

serializeMessage

void serializeMessage(java.io.OutputStream out,
                      com.google.protobuf.Message msg)
               throws java.io.IOException

Throws:

java.io.IOException

getClassNameBytes

com.google.protobuf.ByteString getClassNameBytes(java.lang.Class<?> clz)

parseRequest

public Service.Request parseRequest(byte[] bytes)
                             throws java.io.IOException

Description copied from interface: ProtobufTranslation

Parses a serialized protocol buffer request into a Service.Request.

Specified by:

parseRequest in interface ProtobufTranslation

Parameters:

bytes - Serialized protocol buffer request from client

Returns:

A Request object for the given bytes

Throws:

java.io.IOException - If the protocol buffer cannot be deserialized

parseResponse

public Service.Response parseResponse(byte[] bytes)
                               throws java.io.IOException

Description copied from interface: ProtobufTranslation

Parses a serialized protocol buffer response into a Service.Response.

Specified by:

parseResponse in interface ProtobufTranslation

Parameters:

bytes - Serialized protocol buffer request from server

Returns:

The Response object for the given bytes

Throws:

java.io.IOException - If the protocol buffer cannot be deserialized