Index
All Classes and Interfaces|All Packages|Serialized Form
A
- addRPCPlugin(RPCPlugin) - Method in class org.apache.avro.ipc.Requestor
-
Adds a new plugin to manipulate RPC metadata.
- addRPCPlugin(RPCPlugin) - Method in class org.apache.avro.ipc.Responder
-
Adds a new plugin to manipulate per-call metadata.
- await() - Method in class org.apache.avro.ipc.CallFuture
-
Waits for the CallFuture to complete without returning the result.
- await(long, TimeUnit) - Method in class org.apache.avro.ipc.CallFuture
-
Waits for the CallFuture to complete without returning the result.
B
- BOTH - Enum constant in enum org.apache.avro.ipc.HandshakeMatch
- build() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
- build() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
C
- Callback<T> - Interface in org.apache.avro.ipc
-
Interface for receiving asynchronous callbacks.
- CallFuture<T> - Class in org.apache.avro.ipc
-
A Future implementation for RPCs.
- CallFuture() - Constructor for class org.apache.avro.ipc.CallFuture
-
Creates a CallFuture.
- CallFuture(Callback<T>) - Constructor for class org.apache.avro.ipc.CallFuture
-
Creates a CallFuture with a chained Callback which will be invoked when this CallFuture's Callback methods are invoked.
- cancel(boolean) - Method in class org.apache.avro.ipc.CallFuture
- charts - Variable in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
- clearClientHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Clears the value of the 'clientHash' field.
- clearClientProtocol() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Clears the value of the 'clientProtocol' field.
- clearMatch() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Clears the value of the 'match' field.
- clearMeta() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Clears the value of the 'meta' field.
- clearMeta() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Clears the value of the 'meta' field.
- clearServerHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Clears the value of the 'serverHash' field.
- clearServerHash() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Clears the value of the 'serverHash' field.
- clearServerProtocol() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Clears the value of the 'serverProtocol' field.
- CLIENT - Enum constant in enum org.apache.avro.ipc.HandshakeMatch
- clientFinishConnect(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
-
Called on the client after the initial RPC handshake
- clientReceiveResponse(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
-
This method is invoked at the client after the call is executed, and after the client receives the response
- clientReceiveResponse(RPCContext) - Method in class org.apache.avro.ipc.stats.StatsPlugin
- clientSendRequest(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
-
This method is invoked at the client before it issues the RPC call.
- clientSendRequest(RPCContext) - Method in class org.apache.avro.ipc.stats.StatsPlugin
- clientStartConnect(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
-
Called on the client before the initial RPC handshake to setup any handshake metadata for this plugin
- close() - Method in class org.apache.avro.ipc.DatagramServer
- close() - Method in class org.apache.avro.ipc.SaslSocketTransceiver
- close() - Method in interface org.apache.avro.ipc.Server
-
Stop this server.
- close() - Method in class org.apache.avro.ipc.SocketServer
-
Deprecated.
- close() - Method in class org.apache.avro.ipc.SocketTransceiver
-
Deprecated.
- close() - Method in class org.apache.avro.ipc.Transceiver
- createDecoder(SchemaStore) - Static method in class org.apache.avro.ipc.HandshakeRequest
-
Create a new BinaryMessageDecoder instance for this class that uses the specified
SchemaStore. - createDecoder(SchemaStore) - Static method in class org.apache.avro.ipc.HandshakeResponse
-
Create a new BinaryMessageDecoder instance for this class that uses the specified
SchemaStore. - createServer(Responder, URI) - Static method in class org.apache.avro.ipc.Ipc
-
Create a
Serverlistening at the named URI using the provided responder. - createTransceiver(URI) - Static method in class org.apache.avro.ipc.Ipc
-
Create a client
Transceiverconnecting to the provided URI. - customDecode(ResolvingDecoder) - Method in class org.apache.avro.ipc.HandshakeRequest
- customDecode(ResolvingDecoder) - Method in class org.apache.avro.ipc.HandshakeResponse
- customEncode(Encoder) - Method in class org.apache.avro.ipc.HandshakeRequest
- customEncode(Encoder) - Method in class org.apache.avro.ipc.HandshakeResponse
D
- DatagramServer - Class in org.apache.avro.ipc
-
A datagram-based server implementation.
- DatagramServer(Responder, SocketAddress) - Constructor for class org.apache.avro.ipc.DatagramServer
- DatagramTransceiver - Class in org.apache.avro.ipc
-
A datagram-based
Transceiverimplementation. - DatagramTransceiver(SocketAddress) - Constructor for class org.apache.avro.ipc.DatagramTransceiver
- DatagramTransceiver(DatagramChannel) - Constructor for class org.apache.avro.ipc.DatagramTransceiver
- doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.avro.ipc.stats.StatsServlet
- doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.avro.ipc.ResponderServlet
E
- error - Variable in class org.apache.avro.ipc.RPCContext
- error() - Method in class org.apache.avro.ipc.RPCContext
-
The exception generated at the server, or null if no such exception has occurred
- escapeStringArray(List<String>) - Static method in class org.apache.avro.ipc.stats.StatsServlet
F
- fromByteBuffer(ByteBuffer) - Static method in class org.apache.avro.ipc.HandshakeRequest
-
Deserializes a HandshakeRequest from a ByteBuffer.
- fromByteBuffer(ByteBuffer) - Static method in class org.apache.avro.ipc.HandshakeResponse
-
Deserializes a HandshakeResponse from a ByteBuffer.
G
- GenericRequestor - Class in org.apache.avro.ipc.generic
-
Requestorimplementation for generic Java data. - GenericRequestor(Protocol, Transceiver) - Constructor for class org.apache.avro.ipc.generic.GenericRequestor
- GenericRequestor(Protocol, Transceiver, GenericData) - Constructor for class org.apache.avro.ipc.generic.GenericRequestor
- GenericResponder - Class in org.apache.avro.ipc.generic
-
Responderimplementation for generic Java data. - GenericResponder(Protocol) - Constructor for class org.apache.avro.ipc.generic.GenericResponder
- GenericResponder(Protocol, GenericData) - Constructor for class org.apache.avro.ipc.generic.GenericResponder
- get() - Method in class org.apache.avro.ipc.CallFuture
- get(int) - Method in class org.apache.avro.ipc.HandshakeRequest
- get(int) - Method in class org.apache.avro.ipc.HandshakeResponse
- get(long, TimeUnit) - Method in class org.apache.avro.ipc.CallFuture
- getCharts() - Method in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
- getClassSchema() - Static method in enum org.apache.avro.ipc.HandshakeMatch
- getClassSchema() - Static method in class org.apache.avro.ipc.HandshakeRequest
- getClassSchema() - Static method in class org.apache.avro.ipc.HandshakeResponse
- getClassSchema() - Static method in class org.apache.avro.ipc.MD5
- getClient(Class<T>, ReflectRequestor) - Static method in class org.apache.avro.ipc.reflect.ReflectRequestor
-
Create a proxy instance whose methods invoke RPCs.
- getClient(Class<T>, SpecificRequestor) - Static method in class org.apache.avro.ipc.specific.SpecificRequestor
-
Create a proxy instance whose methods invoke RPCs.
- getClient(Class<T>, Transceiver) - Static method in class org.apache.avro.ipc.reflect.ReflectRequestor
-
Create a proxy instance whose methods invoke RPCs.
- getClient(Class<T>, Transceiver) - Static method in class org.apache.avro.ipc.specific.SpecificRequestor
-
Create a proxy instance whose methods invoke RPCs.
- getClient(Class<T>, Transceiver, ReflectData) - Static method in class org.apache.avro.ipc.reflect.ReflectRequestor
-
Create a proxy instance whose methods invoke RPCs.
- getClient(Class<T>, Transceiver, SpecificData) - Static method in class org.apache.avro.ipc.specific.SpecificRequestor
-
Create a proxy instance whose methods invoke RPCs.
- getClientHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Gets the value of the 'clientHash' field.
- getClientHash() - Method in class org.apache.avro.ipc.HandshakeRequest
-
Gets the value of the 'clientHash' field.
- getClientProtocol() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Gets the value of the 'clientProtocol' field.
- getClientProtocol() - Method in class org.apache.avro.ipc.HandshakeRequest
-
Gets the value of the 'clientProtocol' field.
- getDatumReader(Schema) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
-
Deprecated.
- getDatumReader(Schema, Schema) - Method in class org.apache.avro.ipc.generic.GenericResponder
- getDatumReader(Schema, Schema) - Method in class org.apache.avro.ipc.reflect.ReflectRequestor
- getDatumReader(Schema, Schema) - Method in class org.apache.avro.ipc.reflect.ReflectResponder
- getDatumReader(Schema, Schema) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
- getDatumReader(Schema, Schema) - Method in class org.apache.avro.ipc.specific.SpecificResponder
- getDatumWriter(Schema) - Method in class org.apache.avro.ipc.generic.GenericResponder
- getDatumWriter(Schema) - Method in class org.apache.avro.ipc.reflect.ReflectRequestor
- getDatumWriter(Schema) - Method in class org.apache.avro.ipc.reflect.ReflectResponder
- getDatumWriter(Schema) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
- getDatumWriter(Schema) - Method in class org.apache.avro.ipc.specific.SpecificResponder
- getDecoder() - Static method in class org.apache.avro.ipc.HandshakeRequest
-
Return the BinaryMessageDecoder instance used by this class.
- getDecoder() - Static method in class org.apache.avro.ipc.HandshakeResponse
-
Return the BinaryMessageDecoder instance used by this class.
- getEncoder() - Static method in class org.apache.avro.ipc.HandshakeRequest
-
Return the BinaryMessageEncoder instance used by this class.
- getEncoder() - Static method in class org.apache.avro.ipc.HandshakeResponse
-
Return the BinaryMessageEncoder instance used by this class.
- getError() - Method in class org.apache.avro.ipc.CallFuture
-
Gets the error that was thrown during RPC execution.
- getGenericData() - Method in class org.apache.avro.ipc.generic.GenericRequestor
- getGenericData() - Method in class org.apache.avro.ipc.generic.GenericResponder
- getHandshakeRequest() - Method in class org.apache.avro.ipc.RPCContext
-
Get the handshake request of this RPC.
- getHandshakeResponse() - Method in class org.apache.avro.ipc.RPCContext
-
Get the handshake response of this RPC.
- getLocal() - Method in class org.apache.avro.ipc.Requestor
- getLocal() - Method in class org.apache.avro.ipc.Responder
-
Return the local protocol.
- getMatch() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Gets the value of the 'match' field.
- getMatch() - Method in class org.apache.avro.ipc.HandshakeResponse
-
Gets the value of the 'match' field.
- getMessage() - Method in class org.apache.avro.ipc.RPCContext
-
Returns the
Protocol.Messagecorresponding to this RPC - getMeta() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Gets the value of the 'meta' field.
- getMeta() - Method in class org.apache.avro.ipc.HandshakeRequest
-
Gets the value of the 'meta' field.
- getMeta() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Gets the value of the 'meta' field.
- getMeta() - Method in class org.apache.avro.ipc.HandshakeResponse
-
Gets the value of the 'meta' field.
- getname() - Method in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
- getNumCalls() - Method in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
- getOptionalClientHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Gets the value of the 'clientHash' field as an Optional<org.apache.avro.ipc.MD5>.
- getOptionalClientHash() - Method in class org.apache.avro.ipc.HandshakeRequest
-
Gets the value of the 'clientHash' field as an Optional<org.apache.avro.ipc.MD5>.
- getOptionalClientProtocol() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Gets the value of the 'clientProtocol' field as an Optional<java.lang.String>.
- getOptionalClientProtocol() - Method in class org.apache.avro.ipc.HandshakeRequest
-
Gets the value of the 'clientProtocol' field as an Optional<java.lang.String>.
- getOptionalMatch() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Gets the value of the 'match' field as an Optional<org.apache.avro.ipc.HandshakeMatch>.
- getOptionalMatch() - Method in class org.apache.avro.ipc.HandshakeResponse
-
Gets the value of the 'match' field as an Optional<org.apache.avro.ipc.HandshakeMatch>.
- getOptionalMeta() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Gets the value of the 'meta' field as an Optional<java.util.Map<java.lang.String,java.nio.ByteBuffer>>.
- getOptionalMeta() - Method in class org.apache.avro.ipc.HandshakeRequest
-
Gets the value of the 'meta' field as an Optional<java.util.Map<java.lang.String,java.nio.ByteBuffer>>.
- getOptionalMeta() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Gets the value of the 'meta' field as an Optional<java.util.Map<java.lang.String,java.nio.ByteBuffer>>.
- getOptionalMeta() - Method in class org.apache.avro.ipc.HandshakeResponse
-
Gets the value of the 'meta' field as an Optional<java.util.Map<java.lang.String,java.nio.ByteBuffer>>.
- getOptionalServerHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Gets the value of the 'serverHash' field as an Optional<org.apache.avro.ipc.MD5>.
- getOptionalServerHash() - Method in class org.apache.avro.ipc.HandshakeRequest
-
Gets the value of the 'serverHash' field as an Optional<org.apache.avro.ipc.MD5>.
- getOptionalServerHash() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Gets the value of the 'serverHash' field as an Optional<org.apache.avro.ipc.MD5>.
- getOptionalServerHash() - Method in class org.apache.avro.ipc.HandshakeResponse
-
Gets the value of the 'serverHash' field as an Optional<org.apache.avro.ipc.MD5>.
- getOptionalServerProtocol() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Gets the value of the 'serverProtocol' field as an Optional<java.lang.String>.
- getOptionalServerProtocol() - Method in class org.apache.avro.ipc.HandshakeResponse
-
Gets the value of the 'serverProtocol' field as an Optional<java.lang.String>.
- getPort() - Method in class org.apache.avro.ipc.DatagramServer
- getPort() - Method in interface org.apache.avro.ipc.Server
-
The port this server runs on.
- getPort() - Method in class org.apache.avro.ipc.SocketServer
-
Deprecated.
- getReflectData() - Method in class org.apache.avro.ipc.reflect.ReflectRequestor
- getReflectData() - Method in class org.apache.avro.ipc.reflect.ReflectResponder
- getRemote() - Method in class org.apache.avro.ipc.Requestor
-
Return the remote protocol.
- getRemote() - Static method in class org.apache.avro.ipc.Responder
-
Return the remote protocol.
- getRemote() - Method in class org.apache.avro.ipc.SaslSocketTransceiver
- getRemote() - Method in class org.apache.avro.ipc.SocketTransceiver
-
Deprecated.
- getRemote() - Method in class org.apache.avro.ipc.Transceiver
-
Returns the protocol passed to
Transceiver.setRemote(Protocol). - getRemote(Object) - Static method in class org.apache.avro.ipc.specific.SpecificRequestor
-
Return the remote protocol for a proxy.
- getRemoteName() - Method in class org.apache.avro.ipc.DatagramTransceiver
- getRemoteName() - Method in class org.apache.avro.ipc.HttpTransceiver
- getRemoteName() - Method in class org.apache.avro.ipc.LocalTransceiver
- getRemoteName() - Method in class org.apache.avro.ipc.SaslSocketTransceiver
- getRemoteName() - Method in class org.apache.avro.ipc.SocketTransceiver
-
Deprecated.
- getRemoteName() - Method in class org.apache.avro.ipc.Transceiver
- getRequestPayload() - Method in class org.apache.avro.ipc.RPCContext
-
Returns the serialized payload of the request in this RPC.
- getResponsePayload() - Method in class org.apache.avro.ipc.RPCContext
-
Returns the serialized payload of the response in this RPC.
- getResult() - Method in class org.apache.avro.ipc.CallFuture
-
Gets the value of the RPC result without blocking.
- getSchema() - Method in enum org.apache.avro.ipc.HandshakeMatch
- getSchema() - Method in class org.apache.avro.ipc.HandshakeRequest
- getSchema() - Method in class org.apache.avro.ipc.HandshakeResponse
- getSchema() - Method in class org.apache.avro.ipc.MD5
- getServerHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Gets the value of the 'serverHash' field.
- getServerHash() - Method in class org.apache.avro.ipc.HandshakeRequest
-
Gets the value of the 'serverHash' field.
- getServerHash() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Gets the value of the 'serverHash' field.
- getServerHash() - Method in class org.apache.avro.ipc.HandshakeResponse
-
Gets the value of the 'serverHash' field.
- getServerProtocol() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Gets the value of the 'serverProtocol' field.
- getServerProtocol() - Method in class org.apache.avro.ipc.HandshakeResponse
-
Gets the value of the 'serverProtocol' field.
- getSpecificData() - Method in class org.apache.avro.ipc.HandshakeRequest
- getSpecificData() - Method in class org.apache.avro.ipc.HandshakeResponse
- getSpecificData() - Method in class org.apache.avro.ipc.specific.SpecificRequestor
- getSpecificData() - Method in class org.apache.avro.ipc.specific.SpecificResponder
- getTransceiver() - Method in class org.apache.avro.ipc.Requestor
- getTransceiver(SocketChannel) - Method in class org.apache.avro.ipc.SaslSocketServer
- getTransceiver(SocketChannel) - Method in class org.apache.avro.ipc.SocketServer
-
Deprecated.Creates an appropriate
Transceiverfor this server.
H
- handleError(Throwable) - Method in interface org.apache.avro.ipc.Callback
-
Receives an error.
- handleError(Throwable) - Method in class org.apache.avro.ipc.CallFuture
-
Sets an error thrown during RPC execution, and unblocks all threads waiting on
CallFuture.get()orCallFuture.get(long, TimeUnit). - handleError(Throwable) - Method in class org.apache.avro.ipc.Requestor.TransceiverCallback
- handleResult(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Requestor.TransceiverCallback
- handleResult(T) - Method in interface org.apache.avro.ipc.Callback
-
Receives a callback result.
- handleResult(T) - Method in class org.apache.avro.ipc.CallFuture
-
Sets the RPC response, and unblocks all threads waiting on
CallFuture.get()orCallFuture.get(long, TimeUnit). - HandshakeMatch - Enum in org.apache.avro.ipc
- HandshakeRequest - Class in org.apache.avro.ipc
- HandshakeRequest() - Constructor for class org.apache.avro.ipc.HandshakeRequest
-
Default constructor.
- HandshakeRequest(MD5, String, MD5, Map<String, ByteBuffer>) - Constructor for class org.apache.avro.ipc.HandshakeRequest
-
All-args constructor.
- HandshakeRequest.Builder - Class in org.apache.avro.ipc
-
RecordBuilder for HandshakeRequest instances.
- HandshakeResponse - Class in org.apache.avro.ipc
- HandshakeResponse() - Constructor for class org.apache.avro.ipc.HandshakeResponse
-
Default constructor.
- HandshakeResponse(HandshakeMatch, String, MD5, Map<String, ByteBuffer>) - Constructor for class org.apache.avro.ipc.HandshakeResponse
-
All-args constructor.
- HandshakeResponse.Builder - Class in org.apache.avro.ipc
-
RecordBuilder for HandshakeResponse instances.
- hasClientHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Checks whether the 'clientHash' field has been set.
- hasClientProtocol() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Checks whether the 'clientProtocol' field has been set.
- hasCustomCoders() - Method in class org.apache.avro.ipc.HandshakeRequest
- hasCustomCoders() - Method in class org.apache.avro.ipc.HandshakeResponse
- hasMatch() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Checks whether the 'match' field has been set.
- hasMeta() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Checks whether the 'meta' field has been set.
- hasMeta() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Checks whether the 'meta' field has been set.
- hasServerHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Checks whether the 'serverHash' field has been set.
- hasServerHash() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Checks whether the 'serverHash' field has been set.
- hasServerProtocol() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Checks whether the 'serverProtocol' field has been set.
- HttpTransceiver - Class in org.apache.avro.ipc
-
An HTTP-based
Transceiverimplementation. - HttpTransceiver(URL) - Constructor for class org.apache.avro.ipc.HttpTransceiver
- HttpTransceiver(URL, Proxy) - Constructor for class org.apache.avro.ipc.HttpTransceiver
I
- invoke(Object, Method, Object[]) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
- Ipc - Class in org.apache.avro.ipc
-
IPC utilities, including client and server factories.
- isCancelled() - Method in class org.apache.avro.ipc.CallFuture
- isConnected() - Method in class org.apache.avro.ipc.SaslSocketTransceiver
- isConnected() - Method in class org.apache.avro.ipc.SocketTransceiver
-
Deprecated.
- isConnected() - Method in class org.apache.avro.ipc.Transceiver
-
True if a handshake has been completed for this connection.
- isDone() - Method in class org.apache.avro.ipc.CallFuture
- isError() - Method in class org.apache.avro.ipc.RPCContext
-
Indicates whether an exception was generated at the server
J
L
- LATENCY_SEGMENTER - Static variable in class org.apache.avro.ipc.stats.StatsPlugin
-
Static declaration of histogram buckets.
- LocalTransceiver - Class in org.apache.avro.ipc
-
Implementation of IPC that remains in process.
- LocalTransceiver(Responder) - Constructor for class org.apache.avro.ipc.LocalTransceiver
- lockChannel() - Method in class org.apache.avro.ipc.Transceiver
-
Acquires an exclusive lock on the transceiver's channel.
M
- main(String[]) - Static method in class org.apache.avro.ipc.DatagramServer
- main(String[]) - Static method in class org.apache.avro.ipc.SocketServer
-
Deprecated.
- MD5 - Class in org.apache.avro.ipc
- MD5() - Constructor for class org.apache.avro.ipc.MD5
-
Creates a new MD5
- MD5(byte[]) - Constructor for class org.apache.avro.ipc.MD5
-
Creates a new MD5 with the given bytes.
N
- name - Variable in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
- newBuilder() - Static method in class org.apache.avro.ipc.HandshakeRequest
-
Creates a new HandshakeRequest RecordBuilder.
- newBuilder() - Static method in class org.apache.avro.ipc.HandshakeResponse
-
Creates a new HandshakeResponse RecordBuilder.
- newBuilder(HandshakeRequest) - Static method in class org.apache.avro.ipc.HandshakeRequest
-
Creates a new HandshakeRequest RecordBuilder by copying an existing HandshakeRequest instance.
- newBuilder(HandshakeRequest.Builder) - Static method in class org.apache.avro.ipc.HandshakeRequest
-
Creates a new HandshakeRequest RecordBuilder by copying an existing Builder.
- newBuilder(HandshakeResponse) - Static method in class org.apache.avro.ipc.HandshakeResponse
-
Creates a new HandshakeResponse RecordBuilder by copying an existing HandshakeResponse instance.
- newBuilder(HandshakeResponse.Builder) - Static method in class org.apache.avro.ipc.HandshakeResponse
-
Creates a new HandshakeResponse RecordBuilder by copying an existing Builder.
- NONE - Enum constant in enum org.apache.avro.ipc.HandshakeMatch
- numCalls - Variable in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
O
- org.apache.avro.ipc - package org.apache.avro.ipc
-
Support for inter-process calls.
- org.apache.avro.ipc.generic - package org.apache.avro.ipc.generic
- org.apache.avro.ipc.reflect - package org.apache.avro.ipc.reflect
- org.apache.avro.ipc.specific - package org.apache.avro.ipc.specific
- org.apache.avro.ipc.stats - package org.apache.avro.ipc.stats
-
Utilities to collect and display IPC statistics.
P
- PAYLOAD_SEGMENTER - Static variable in class org.apache.avro.ipc.stats.StatsPlugin
- put(int, Object) - Method in class org.apache.avro.ipc.HandshakeRequest
- put(int, Object) - Method in class org.apache.avro.ipc.HandshakeResponse
R
- readBuffers() - Method in class org.apache.avro.ipc.DatagramTransceiver
- readBuffers() - Method in class org.apache.avro.ipc.HttpTransceiver
- readBuffers() - Method in class org.apache.avro.ipc.LocalTransceiver
- readBuffers() - Method in class org.apache.avro.ipc.SaslSocketTransceiver
- readBuffers() - Method in class org.apache.avro.ipc.SocketTransceiver
-
Deprecated.
- readBuffers() - Method in class org.apache.avro.ipc.Transceiver
-
Called by the default definition of
Transceiver.transceive(List). - readError(Schema, Decoder) - Method in class org.apache.avro.ipc.Requestor
-
Deprecated.
- readError(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.generic.GenericRequestor
- readError(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.Requestor
-
Reads an error message.
- readError(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
- readExternal(ObjectInput) - Method in class org.apache.avro.ipc.HandshakeRequest
- readExternal(ObjectInput) - Method in class org.apache.avro.ipc.HandshakeResponse
- readExternal(ObjectInput) - Method in class org.apache.avro.ipc.MD5
- readRequest(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.generic.GenericResponder
- readRequest(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.Responder
-
Reads a request message.
- readResponse(Schema, Decoder) - Method in class org.apache.avro.ipc.Requestor
-
Deprecated.
- readResponse(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.generic.GenericRequestor
- readResponse(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.Requestor
-
Reads a response message.
- readResponse(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
- ReflectRequestor - Class in org.apache.avro.ipc.reflect
-
A
Requestorfor existing interfaces. - ReflectRequestor(Class<?>, Transceiver) - Constructor for class org.apache.avro.ipc.reflect.ReflectRequestor
- ReflectRequestor(Class<?>, Transceiver, ReflectData) - Constructor for class org.apache.avro.ipc.reflect.ReflectRequestor
- ReflectRequestor(Protocol, Transceiver) - Constructor for class org.apache.avro.ipc.reflect.ReflectRequestor
- ReflectRequestor(Protocol, Transceiver, ReflectData) - Constructor for class org.apache.avro.ipc.reflect.ReflectRequestor
- ReflectResponder - Class in org.apache.avro.ipc.reflect
-
Responderfor existing interfaces. - ReflectResponder(Class, Object) - Constructor for class org.apache.avro.ipc.reflect.ReflectResponder
- ReflectResponder(Class, Object, ReflectData) - Constructor for class org.apache.avro.ipc.reflect.ReflectResponder
- ReflectResponder(Protocol, Object) - Constructor for class org.apache.avro.ipc.reflect.ReflectResponder
- ReflectResponder(Protocol, Object, ReflectData) - Constructor for class org.apache.avro.ipc.reflect.ReflectResponder
- RenderableMessage(String) - Constructor for class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
- request(String, Object) - Method in class org.apache.avro.ipc.Requestor
-
Writes a request message and reads a response or error message.
- request(String, Object, Callback<T>) - Method in class org.apache.avro.ipc.Requestor
-
Writes a request message and returns the result through a Callback.
- requestCallMeta - Variable in class org.apache.avro.ipc.RPCContext
- requestCallMeta() - Method in class org.apache.avro.ipc.RPCContext
-
This is an access method for the per-call state provided by the client to the server.
- requestHandshakeMeta() - Method in class org.apache.avro.ipc.RPCContext
-
This is an access method for the handshake state provided by the client to the server.
- Requestor - Class in org.apache.avro.ipc
-
Base class for the client side of a protocol interaction.
- Requestor(Protocol, Transceiver) - Constructor for class org.apache.avro.ipc.Requestor
- Requestor.TransceiverCallback<T> - Class in org.apache.avro.ipc
-
Handles callbacks from transceiver invocations.
- respond(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Responder
-
Called by a server to deserialize a request, compute and serialize a response or error.
- respond(List<ByteBuffer>, Transceiver) - Method in class org.apache.avro.ipc.Responder
-
Called by a server to deserialize a request, compute and serialize a response or error.
- respond(Protocol.Message, Object) - Method in class org.apache.avro.ipc.Responder
-
Computes the response for a message.
- respond(Protocol.Message, Object) - Method in class org.apache.avro.ipc.specific.SpecificResponder
- Responder - Class in org.apache.avro.ipc
-
Base class for the server side of a protocol interaction.
- Responder(Protocol) - Constructor for class org.apache.avro.ipc.Responder
- ResponderServlet - Class in org.apache.avro.ipc
-
An
HttpServletthat responds to Avro RPC requests. - ResponderServlet(Responder) - Constructor for class org.apache.avro.ipc.ResponderServlet
- response - Variable in class org.apache.avro.ipc.RPCContext
- response() - Method in class org.apache.avro.ipc.RPCContext
-
The response object generated at the server, if it exists.
- responseCallMeta - Variable in class org.apache.avro.ipc.RPCContext
- responseCallMeta() - Method in class org.apache.avro.ipc.RPCContext
-
This is an access method for the per-call state provided by the server back to the client.
- responseHandshakeMeta() - Method in class org.apache.avro.ipc.RPCContext
-
This is an access method for the handshake state provided by the server back to the client
- RPCContext - Class in org.apache.avro.ipc
-
This class represents the context of an RPC call or RPC handshake.
- RPCContext() - Constructor for class org.apache.avro.ipc.RPCContext
- rpcMetaPlugins - Variable in class org.apache.avro.ipc.Requestor
- rpcMetaPlugins - Variable in class org.apache.avro.ipc.Responder
- RPCPlugin - Class in org.apache.avro.ipc
-
An instrumentation API for RPC metadata.
- RPCPlugin() - Constructor for class org.apache.avro.ipc.RPCPlugin
- run() - Method in class org.apache.avro.ipc.DatagramServer
- run() - Method in class org.apache.avro.ipc.SocketServer
-
Deprecated.
S
- SaslSocketServer - Class in org.apache.avro.ipc
-
A
Serverthat usesjavax.security.saslfor authentication and encryption. - SaslSocketServer(Responder, SocketAddress) - Constructor for class org.apache.avro.ipc.SaslSocketServer
-
Create using SASL's anonymous (RFC 2245) mechanism.
- SaslSocketServer(Responder, SocketAddress, String, String, String, Map<String, ?>, CallbackHandler) - Constructor for class org.apache.avro.ipc.SaslSocketServer
-
Create using the specified
SaslServerparameters. - SaslSocketTransceiver - Class in org.apache.avro.ipc
-
A
Transceiverthat usesjavax.security.saslfor authentication and encryption. - SaslSocketTransceiver(SocketAddress) - Constructor for class org.apache.avro.ipc.SaslSocketTransceiver
-
Create using SASL's anonymous (RFC 2245) mechanism.
- SaslSocketTransceiver(SocketAddress, SaslClient) - Constructor for class org.apache.avro.ipc.SaslSocketTransceiver
-
Create using the specified
SaslClient. - SaslSocketTransceiver(SocketChannel, SaslServer) - Constructor for class org.apache.avro.ipc.SaslSocketTransceiver
-
Create using the specified
SaslServer. - SCHEMA$ - Static variable in enum org.apache.avro.ipc.HandshakeMatch
- SCHEMA$ - Static variable in class org.apache.avro.ipc.HandshakeRequest
- SCHEMA$ - Static variable in class org.apache.avro.ipc.HandshakeResponse
- SCHEMA$ - Static variable in class org.apache.avro.ipc.MD5
- Server - Interface in org.apache.avro.ipc
-
A server listening on a port.
- serverConnecting(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
-
Called on the server during the RPC handshake
- serverReceiveRequest(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
-
This method is invoked at the RPC server when the request is received, but before the call itself is executed
- serverReceiveRequest(RPCContext) - Method in class org.apache.avro.ipc.stats.StatsPlugin
- serverSendResponse(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
-
This method is invoked at the server before the response is executed, but before the response has been formulated
- serverSendResponse(RPCContext) - Method in class org.apache.avro.ipc.stats.StatsPlugin
- setClientHash(MD5) - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Sets the value of the 'clientHash' field.
- setClientHash(MD5) - Method in class org.apache.avro.ipc.HandshakeRequest
-
Sets the value of the 'clientHash' field.
- setClientProtocol(String) - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Sets the value of the 'clientProtocol' field.
- setClientProtocol(String) - Method in class org.apache.avro.ipc.HandshakeRequest
-
Sets the value of the 'clientProtocol' field.
- setHandshakeRequest(HandshakeRequest) - Method in class org.apache.avro.ipc.RPCContext
-
Set the handshake request of this RPC.
- setHandshakeResponse(HandshakeResponse) - Method in class org.apache.avro.ipc.RPCContext
-
Set the handshake response of this RPC.
- setMatch(HandshakeMatch) - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Sets the value of the 'match' field.
- setMatch(HandshakeMatch) - Method in class org.apache.avro.ipc.HandshakeResponse
-
Sets the value of the 'match' field.
- setMessage(Protocol.Message) - Method in class org.apache.avro.ipc.RPCContext
-
Sets the
Protocol.Messagecorresponding to this RPC - setMeta(Map<String, ByteBuffer>) - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Sets the value of the 'meta' field.
- setMeta(Map<String, ByteBuffer>) - Method in class org.apache.avro.ipc.HandshakeRequest
-
Sets the value of the 'meta' field.
- setMeta(Map<String, ByteBuffer>) - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Sets the value of the 'meta' field.
- setMeta(Map<String, ByteBuffer>) - Method in class org.apache.avro.ipc.HandshakeResponse
-
Sets the value of the 'meta' field.
- setRemote(Protocol) - Method in class org.apache.avro.ipc.SaslSocketTransceiver
- setRemote(Protocol) - Method in class org.apache.avro.ipc.SocketTransceiver
-
Deprecated.
- setRemote(Protocol) - Method in class org.apache.avro.ipc.Transceiver
-
Called with the remote protocol when a handshake has been completed.
- setRequestPayload(List<ByteBuffer>) - Method in class org.apache.avro.ipc.RPCContext
-
Sets the serialized payload of the request in this RPC.
- setResponsePayload(List<ByteBuffer>) - Method in class org.apache.avro.ipc.RPCContext
-
Sets the serialized payload of the response in this RPC.
- setServerHash(MD5) - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
-
Sets the value of the 'serverHash' field.
- setServerHash(MD5) - Method in class org.apache.avro.ipc.HandshakeRequest
-
Sets the value of the 'serverHash' field.
- setServerHash(MD5) - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Sets the value of the 'serverHash' field.
- setServerHash(MD5) - Method in class org.apache.avro.ipc.HandshakeResponse
-
Sets the value of the 'serverHash' field.
- setServerProtocol(String) - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
-
Sets the value of the 'serverProtocol' field.
- setServerProtocol(String) - Method in class org.apache.avro.ipc.HandshakeResponse
-
Sets the value of the 'serverProtocol' field.
- setTimeout(int) - Method in class org.apache.avro.ipc.HttpTransceiver
-
Set the connect and read timeouts, in milliseconds.
- SocketServer - Class in org.apache.avro.ipc
-
Deprecated.
- SocketServer(Responder, SocketAddress) - Constructor for class org.apache.avro.ipc.SocketServer
-
Deprecated.
- SocketTransceiver - Class in org.apache.avro.ipc
-
Deprecated.use
SaslSocketTransceiverinstead. - SocketTransceiver(SocketAddress) - Constructor for class org.apache.avro.ipc.SocketTransceiver
-
Deprecated.
- SocketTransceiver(SocketChannel) - Constructor for class org.apache.avro.ipc.SocketTransceiver
-
Deprecated.
- SpecificRequestor - Class in org.apache.avro.ipc.specific
-
Requestorfor generated interfaces. - SpecificRequestor(Class<?>, Transceiver) - Constructor for class org.apache.avro.ipc.specific.SpecificRequestor
- SpecificRequestor(Class<?>, Transceiver, SpecificData) - Constructor for class org.apache.avro.ipc.specific.SpecificRequestor
- SpecificRequestor(Protocol, Transceiver) - Constructor for class org.apache.avro.ipc.specific.SpecificRequestor
- SpecificRequestor(Protocol, Transceiver, SpecificData) - Constructor for class org.apache.avro.ipc.specific.SpecificRequestor
- SpecificResponder - Class in org.apache.avro.ipc.specific
-
Responderfor generated interfaces. - SpecificResponder(Class, Object) - Constructor for class org.apache.avro.ipc.specific.SpecificResponder
- SpecificResponder(Class, Object, SpecificData) - Constructor for class org.apache.avro.ipc.specific.SpecificResponder
- SpecificResponder(Protocol, Object) - Constructor for class org.apache.avro.ipc.specific.SpecificResponder
- SpecificResponder(Protocol, Object, SpecificData) - Constructor for class org.apache.avro.ipc.specific.SpecificResponder
- start() - Method in interface org.apache.avro.ipc.Server
-
Start this server.
- startupTime - Variable in class org.apache.avro.ipc.stats.StatsPlugin
-
How long I've been alive
- StatsPlugin - Class in org.apache.avro.ipc.stats
-
Collects count and latency statistics about RPC calls.
- StatsPlugin() - Constructor for class org.apache.avro.ipc.stats.StatsPlugin
-
Construct a plugin with default (system) ticks, and default histogram segmentation.
- StatsPlugin(Stopwatch.Ticks, Histogram.Segmenter<?, Float>, Histogram.Segmenter<?, Integer>) - Constructor for class org.apache.avro.ipc.stats.StatsPlugin
-
Construct a plugin with custom Ticks and Segmenter implementations.
- StatsServlet - Class in org.apache.avro.ipc.stats
-
Exposes information provided by a StatsPlugin as a web page.
- StatsServlet(StatsPlugin) - Constructor for class org.apache.avro.ipc.stats.StatsServlet
- StatsServlet.RenderableMessage - Class in org.apache.avro.ipc.stats
T
- toByteBuffer() - Method in class org.apache.avro.ipc.HandshakeRequest
-
Serializes this HandshakeRequest to a ByteBuffer.
- toByteBuffer() - Method in class org.apache.avro.ipc.HandshakeResponse
-
Serializes this HandshakeResponse to a ByteBuffer.
- transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.LocalTransceiver
- transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.SaslSocketTransceiver
- transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Transceiver
-
Called by
Requestor.request(String,Object)for two-way messages. - transceive(List<ByteBuffer>, Callback<List<ByteBuffer>>) - Method in class org.apache.avro.ipc.Transceiver
-
Called by
Requestor.request(String,Object,Callback)for two-way messages using callbacks. - Transceiver - Class in org.apache.avro.ipc
-
Base transport class used by
Requestor. - Transceiver() - Constructor for class org.apache.avro.ipc.Transceiver
- TransceiverCallback(Requestor.Request, Callback<T>) - Constructor for class org.apache.avro.ipc.Requestor.TransceiverCallback
-
Creates a TransceiverCallback.
U
- unlockChannel() - Method in class org.apache.avro.ipc.Transceiver
-
Releases the lock on the transceiver's channel if held by the calling thread.
V
- valueOf(String) - Static method in enum org.apache.avro.ipc.HandshakeMatch
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.apache.avro.ipc.HandshakeMatch
-
Returns an array containing the constants of this enum type, in the order they are declared.
W
- writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.DatagramTransceiver
- writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.HttpTransceiver
- writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.LocalTransceiver
- writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.SaslSocketTransceiver
- writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.SocketTransceiver
-
Deprecated.
- writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Transceiver
-
Called by
Requestor.request(String,Object)for one-way messages. - writeError(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.generic.GenericResponder
- writeError(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.reflect.ReflectResponder
- writeError(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.Responder
-
Writes an error message.
- writeError(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.specific.SpecificResponder
- writeExternal(ObjectOutput) - Method in class org.apache.avro.ipc.HandshakeRequest
- writeExternal(ObjectOutput) - Method in class org.apache.avro.ipc.HandshakeResponse
- writeExternal(ObjectOutput) - Method in class org.apache.avro.ipc.MD5
- writeRequest(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.generic.GenericRequestor
- writeRequest(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.Requestor
-
Writes a request message.
- writeRequest(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
- writeResponse(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.generic.GenericResponder
- writeResponse(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.Responder
-
Writes a response message.
- writeStats(Writer) - Method in class org.apache.avro.ipc.stats.StatsServlet
All Classes and Interfaces|All Packages|Serialized Form
SaslSocketServerinstead.