Package | Description |
---|---|
org.apache.avro |
Avro kernel classes.
|
org.apache.avro.compiler.specific | |
org.apache.avro.grpc | |
org.apache.avro.ipc |
Support for inter-process calls.
|
org.apache.avro.ipc.generic | |
org.apache.avro.ipc.netty | |
org.apache.avro.ipc.reflect | |
org.apache.avro.ipc.specific | |
org.apache.avro.mapred.tether |
Run Hadoop MapReduce jobs over
Avro data, with map and reduce functions run in a sub-process.
|
org.apache.avro.reflect |
Use Java reflection to generate schemas and protocols for existing
classes.
|
org.apache.avro.specific |
Generate specific Java classes for schemas and protocols.
|
Modifier and Type | Method and Description |
---|---|
static Protocol |
Protocol.parse(File file)
Read a protocol from a Json file.
|
static Protocol |
Protocol.parse(InputStream stream)
Read a protocol from a Json stream.
|
static Protocol |
Protocol.parse(String string)
Read a protocol from a Json string.
|
static Protocol |
Protocol.parse(String string,
String... more)
Read a protocol from one or more json strings
|
Constructor and Description |
---|
Protocol(Protocol p)
Constructs a similar Protocol instance with the same
name ,
doc , and namespace as {code p} has. |
Constructor and Description |
---|
SpecificCompiler(Protocol protocol) |
Modifier and Type | Method and Description |
---|---|
static Protocol |
AvroGrpcUtils.getProtocol(Class iface)
Gets the
Protocol from the Avro Interface. |
Modifier and Type | Method and Description |
---|---|
Protocol |
Responder.getLocal()
Return the local protocol.
|
Protocol |
Requestor.getLocal() |
Protocol |
Transceiver.getRemote()
Returns the protocol passed to
Transceiver.setRemote(Protocol) . |
Protocol |
SocketTransceiver.getRemote()
Deprecated.
|
Protocol |
SaslSocketTransceiver.getRemote() |
static Protocol |
Responder.getRemote()
Return the remote protocol.
|
Protocol |
Requestor.getRemote()
Return the remote protocol.
|
Modifier and Type | Method and Description |
---|---|
void |
Transceiver.setRemote(Protocol protocol)
Called with the remote protocol when a handshake has been completed.
|
void |
SocketTransceiver.setRemote(Protocol remote)
Deprecated.
|
void |
SaslSocketTransceiver.setRemote(Protocol remote) |
Constructor and Description |
---|
Requestor(Protocol local,
Transceiver transceiver) |
Responder(Protocol local) |
Constructor and Description |
---|
GenericRequestor(Protocol protocol,
Transceiver transceiver) |
GenericRequestor(Protocol protocol,
Transceiver transceiver,
GenericData data) |
GenericResponder(Protocol local) |
GenericResponder(Protocol local,
GenericData data) |
Modifier and Type | Method and Description |
---|---|
Protocol |
NettyTransceiver.getRemote() |
Modifier and Type | Method and Description |
---|---|
void |
NettyTransceiver.setRemote(Protocol protocol) |
Constructor and Description |
---|
ReflectRequestor(Protocol protocol,
Transceiver transceiver) |
ReflectRequestor(Protocol protocol,
Transceiver transceiver,
ReflectData data) |
ReflectResponder(Protocol protocol,
Object impl) |
ReflectResponder(Protocol protocol,
Object impl,
ReflectData data) |
Modifier and Type | Method and Description |
---|---|
static Protocol |
SpecificRequestor.getRemote(Object proxy)
Return the remote protocol for a proxy.
|
Constructor and Description |
---|
SpecificRequestor(Protocol protocol,
Transceiver transceiver) |
SpecificRequestor(Protocol protocol,
Transceiver transceiver,
SpecificData data) |
SpecificResponder(Protocol protocol,
Object impl) |
SpecificResponder(Protocol protocol,
Object impl,
SpecificData data) |
Modifier and Type | Field and Description |
---|---|
static Protocol |
OutputProtocol.PROTOCOL |
static Protocol |
OutputProtocol.Callback.PROTOCOL |
static Protocol |
InputProtocol.PROTOCOL |
static Protocol |
InputProtocol.Callback.PROTOCOL |
Modifier and Type | Method and Description |
---|---|
Protocol |
ReflectData.getProtocol(Class iface)
Return the protocol for a Java interface.
|
Modifier and Type | Method and Description |
---|---|
Protocol |
SpecificData.getProtocol(Class iface)
Return the protocol for a Java interface.
|
Copyright © 2009–2022 The Apache Software Foundation. All rights reserved.