Index
All Classes and Interfaces|All Packages
A
- AvroGrpcClient - Class in org.apache.avro.grpc
-
Component that sets up a gRPC client for Avro's IDL and Serialization.
- AvroGrpcServer - Class in org.apache.avro.grpc
-
Provides components to set up a gRPC Server for Avro's IDL and serialization.
- AvroGrpcUtils - Class in org.apache.avro.grpc
-
Utility methods for using Avro IDL and serialization with gRPC.
- AvroInputStream - Class in org.apache.avro.grpc
-
An
InputStream
backed by Avro RPC request/response that can drained to aOutputStream
. - AvroInputStream() - Constructor for class org.apache.avro.grpc.AvroInputStream
- AvroInputStream.CountingOutputStream - Class in org.apache.avro.grpc
-
An
OutputStream
that writes to a targetOutputStream
and provides total number of bytes written to it. - AvroRequestMarshaller - Class in org.apache.avro.grpc
-
Marshaller for Avro RPC request.
- AvroRequestMarshaller(Protocol.Message) - Constructor for class org.apache.avro.grpc.AvroRequestMarshaller
- AvroResponseMarshaller - Class in org.apache.avro.grpc
-
Marshaller for Avro RPC response.
- AvroResponseMarshaller(Protocol.Message) - Constructor for class org.apache.avro.grpc.AvroResponseMarshaller
C
- close() - Method in class org.apache.avro.grpc.AvroInputStream.CountingOutputStream
- CountingOutputStream(OutputStream) - Constructor for class org.apache.avro.grpc.AvroInputStream.CountingOutputStream
- create(Channel, Class<T>) - Static method in class org.apache.avro.grpc.AvroGrpcClient
-
Creates a gRPC client for Avro's interface with default
CallOptions
. - create(Channel, Class<T>, CallOptions) - Static method in class org.apache.avro.grpc.AvroGrpcClient
-
Creates a gRPC client for Avro's interface with provided
CallOptions
. - createServiceDefinition(Class, Object) - Static method in class org.apache.avro.grpc.AvroGrpcServer
-
Creates a
ServerServiceDefinition
for Avro Interface and its implementation that can be passed a gRPC Server.
F
- flush() - Method in class org.apache.avro.grpc.AvroInputStream.CountingOutputStream
G
- getPartial() - Method in class org.apache.avro.grpc.AvroInputStream
- getProtocol(Class) - Static method in class org.apache.avro.grpc.AvroGrpcUtils
-
Gets the
Protocol
from the Avro Interface. - getServiceName(Class) - Static method in class org.apache.avro.grpc.AvroGrpcUtils
-
Provides a a unique gRPC service name for Avro RPC interface or its subclass Callback Interface.
- getWrittenCount() - Method in class org.apache.avro.grpc.AvroInputStream.CountingOutputStream
O
- org.apache.avro.grpc - package org.apache.avro.grpc
P
- parse(InputStream) - Method in class org.apache.avro.grpc.AvroRequestMarshaller
- parse(InputStream) - Method in class org.apache.avro.grpc.AvroResponseMarshaller
R
- read() - Method in class org.apache.avro.grpc.AvroInputStream
- read(byte[], int, int) - Method in class org.apache.avro.grpc.AvroInputStream
S
- stream(Object) - Method in class org.apache.avro.grpc.AvroResponseMarshaller
- stream(Object[]) - Method in class org.apache.avro.grpc.AvroRequestMarshaller
W
- write(byte[], int, int) - Method in class org.apache.avro.grpc.AvroInputStream.CountingOutputStream
- write(int) - Method in class org.apache.avro.grpc.AvroInputStream.CountingOutputStream
All Classes and Interfaces|All Packages