|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Schema | |
---|---|
org.apache.avro | Avro kernel classes. |
org.apache.avro.file | A container file for Avro data. |
org.apache.avro.generic | A generic representation for Avro data. |
org.apache.avro.io | Input/output utilities. |
org.apache.avro.io.parsing | Implementation of Avro schemas as LL(1) grammars. |
org.apache.avro.ipc | Support for inter-process calls. |
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. |
Uses of Schema in org.apache.avro |
---|
Fields in org.apache.avro declared as Schema | |
---|---|
static Schema |
Protocol.SYSTEM_ERROR
An error that can be thrown by any message. |
static Schema |
Protocol.SYSTEM_ERRORS
Union type for generating system errors. |
Methods in org.apache.avro that return Schema | |
---|---|
static Schema |
Schema.create(Schema.Type type)
Create a schema for a primitive type. |
static Schema |
Schema.createArray(Schema elementType)
Create an array schema. |
static Schema |
Schema.createEnum(String name,
String namespace,
List<String> values)
Create an enum schema. |
static Schema |
Schema.createFixed(String name,
String space,
int size)
Create a union schema. |
static Schema |
Schema.createMap(Schema valueType)
Create a map schema. |
static Schema |
Schema.createRecord(LinkedHashMap<String,Schema.Field> fields)
Create an anonymous record schema. |
static Schema |
Schema.createRecord(String name,
String namespace,
boolean isError)
Create a named record schema. |
static Schema |
Schema.createUnion(List<Schema> types)
Create a union schema. |
Schema |
Schema.getElementType()
If this is an array, returns its element type. |
Schema |
Protocol.Message.getErrors()
Errors that might be thrown. |
Schema |
Protocol.Message.getRequest()
The parameters of this message. |
Schema |
Protocol.Message.getResponse()
The returned data. |
Schema |
Schema.getValueType()
If this is a map, returns its value type. |
static Schema |
Schema.parse(File file)
|
static Schema |
Schema.parse(String jsonSchema)
Construct a schema from JSON text. |
Schema |
Schema.Field.schema()
This field's Schema . |
Methods in org.apache.avro that return types with arguments of type Schema | |
---|---|
Iterable<Map.Entry<String,Schema>> |
Schema.getFieldSchemas()
If this is a record, enumerate its field names and their schemas. |
List<Schema> |
Schema.getTypes()
If this is a union, returns its types. |
LinkedHashMap<String,Schema> |
Protocol.getTypes()
The types of this protocol. |
Methods in org.apache.avro with parameters of type Schema | |
---|---|
static Schema |
Schema.createArray(Schema elementType)
Create an array schema. |
static Schema |
Schema.createMap(Schema valueType)
Create a map schema. |
Protocol.Message |
Protocol.createMessage(String name,
Schema request,
Schema response,
Schema errors)
|
Method parameters in org.apache.avro with type arguments of type Schema | |
---|---|
static Schema |
Schema.createUnion(List<Schema> types)
Create a union schema. |
Constructors in org.apache.avro with parameters of type Schema | |
---|---|
Schema.Field(Schema schema,
JsonNode defaultValue)
|
|
Schema.Field(Schema schema,
JsonNode defaultValue,
Schema.Field.Order order)
|
Uses of Schema in org.apache.avro.file |
---|
Methods in org.apache.avro.file with parameters of type Schema | |
---|---|
void |
DataFileWriter.addSchema(Schema branch)
If the schema for this file is a union, add a branch to it. |
Constructors in org.apache.avro.file with parameters of type Schema | |
---|---|
DataFileWriter(Schema schema,
OutputStream outs,
DatumWriter<D> dout)
Construct a writer to a file for data matching a schema. |
Uses of Schema in org.apache.avro.generic |
---|
Methods in org.apache.avro.generic that return Schema | |
---|---|
protected Schema |
GenericData.getRecordSchema(Object record)
Called to obtain the schema of a record. |
Schema |
GenericData.Record.getSchema()
|
Schema |
GenericData.Array.getSchema()
|
Schema |
GenericContainer.getSchema()
The schema of this instance. |
Schema |
GenericData.induce(Object datum)
Create a schema given an example datum. |
Methods in org.apache.avro.generic with parameters of type Schema | |
---|---|
int |
GenericData.compare(Object o1,
Object o2,
Schema s)
Compare objects according to their schema. |
protected Object |
GenericDatumReader.createEnum(String symbol,
Schema schema)
Called to create an enum value. |
protected Object |
GenericDatumReader.createFixed(Object old,
byte[] bytes,
Schema schema)
Called to create an fixed value. |
protected Object |
GenericDatumReader.createFixed(Object old,
Schema schema)
Called to create an fixed value. |
protected Object |
GenericDatumReader.defaultFieldValue(Object old,
Schema schema,
JsonNode json)
Called by the default implementation of GenericDatumReader.readRecord(java.lang.Object, org.apache.avro.Schema, org.apache.avro.Schema, org.apache.avro.io.Decoder) to construct
a default value for a field. |
protected boolean |
GenericData.instanceOf(Schema schema,
Object datum)
Called by GenericData.resolveUnion(Schema,Object) . |
protected Object |
GenericDatumReader.newArray(Object old,
int size,
Schema schema)
Called to create new array instances. |
protected Object |
GenericDatumReader.newRecord(Object old,
Schema schema)
Called to create new record instances. |
protected Object |
GenericDatumReader.read(Object old,
Schema actual,
Schema expected,
Decoder in)
Called to read data. |
protected Object |
GenericDatumReader.readArray(Object old,
Schema actual,
Schema expected,
Decoder in)
Called to read an array instance. |
protected Object |
GenericDatumReader.readEnum(Schema actual,
Schema expected,
Decoder in)
Called to read an enum value. |
AvroRemoteException |
GenericRequestor.readError(Schema schema,
Decoder in)
|
protected Object |
GenericDatumReader.readFixed(Object old,
Schema actual,
Schema expected,
Decoder in)
Called to read a fixed value. |
protected Object |
GenericDatumReader.readMap(Object old,
Schema actual,
Schema expected,
Decoder in)
Called to read a map instance. |
protected Object |
GenericDatumReader.readRecord(Object old,
Schema actual,
Schema expected,
Decoder in)
Called to read a record instance. |
Object |
GenericResponder.readRequest(Schema schema,
Decoder in)
Reads a request message. |
Object |
GenericRequestor.readResponse(Schema schema,
Decoder in)
|
int |
GenericData.resolveUnion(Schema union,
Object datum)
Return the index for a datum within a union. |
void |
GenericDatumReader.setSchema(Schema actual)
|
void |
GenericDatumWriter.setSchema(Schema root)
|
static void |
GenericDatumReader.skip(Schema schema,
Decoder in)
Skip an instance of a schema. |
boolean |
GenericData.validate(Schema schema,
Object datum)
Returns true if a Java datum matches a schema. |
protected void |
GenericDatumWriter.write(Schema schema,
Object datum,
Encoder out)
Called to write data. |
protected void |
GenericDatumWriter.writeArray(Schema schema,
Object datum,
Encoder out)
Called to write a array. |
protected void |
GenericDatumWriter.writeEnum(Schema schema,
Object datum,
Encoder out)
Called to write an enum value. |
void |
GenericResponder.writeError(Schema schema,
AvroRemoteException error,
Encoder out)
Writes an error message. |
protected void |
GenericDatumWriter.writeFixed(Schema schema,
Object datum,
Encoder out)
Called to write a fixed value. |
protected void |
GenericDatumWriter.writeMap(Schema schema,
Object datum,
Encoder out)
Called to write a map. |
protected void |
GenericDatumWriter.writeRecord(Schema schema,
Object datum,
Encoder out)
Called to write a record. |
void |
GenericRequestor.writeRequest(Schema schema,
Object request,
Encoder out)
|
void |
GenericResponder.writeResponse(Schema schema,
Object response,
Encoder out)
Writes a response message. |
Constructors in org.apache.avro.generic with parameters of type Schema | |
---|---|
GenericData.Array(int capacity,
Schema schema)
|
|
GenericData.Fixed(Schema schema)
|
|
GenericData.Record(Schema schema)
|
|
GenericDatumReader(Schema actual)
|
|
GenericDatumReader(Schema actual,
Schema expected)
|
|
GenericDatumWriter(Schema root)
|
|
GenericDatumWriter(Schema root,
GenericData data)
|
Uses of Schema in org.apache.avro.io |
---|
Methods in org.apache.avro.io with parameters of type Schema | |
---|---|
static int |
BinaryData.compare(byte[] b1,
int s1,
byte[] b2,
int s2,
Schema schema)
Compare binary encoded data. |
void |
DatumWriter.setSchema(Schema schema)
Set the schema. |
void |
DatumReader.setSchema(Schema schema)
Set the schema. |
Constructors in org.apache.avro.io with parameters of type Schema | |
---|---|
JsonDecoder(Schema schema,
InputStream in)
|
|
JsonEncoder(Schema sc,
JsonGenerator out)
|
|
JsonEncoder(Schema sc,
OutputStream out)
|
|
ResolvingDecoder(Schema writer,
Schema reader,
Decoder in)
|
|
ValidatingDecoder(Schema schema,
Decoder in)
|
|
ValidatingEncoder(Schema schema,
Encoder in)
|
Uses of Schema in org.apache.avro.io.parsing |
---|
Methods in org.apache.avro.io.parsing with parameters of type Schema | |
---|---|
Symbol |
ValidatingGrammarGenerator.generate(Schema schema)
Returns the non-terminal that is the start symbol for the grammar for the given schema sc. |
Symbol |
JsonGrammarGenerator.generate(Schema schema)
Returns the non-terminal that is the start symbol for the grammar for the grammar for the given schema sc. |
Symbol |
ValidatingGrammarGenerator.generate(Schema sc,
Map<org.apache.avro.io.parsing.ValidatingGrammarGenerator.LitS,Symbol> seen)
Returns the non-terminal that is the start symbol for the grammar for the given schema sc. |
Symbol |
JsonGrammarGenerator.generate(Schema sc,
Map<org.apache.avro.io.parsing.ValidatingGrammarGenerator.LitS,Symbol> seen)
Returns the non-terminal that is the start symbol for grammar of the given schema sc. |
Symbol |
ResolvingGrammarGenerator.generate(Schema writer,
Schema reader)
Resolves the writer schema writer and the reader schema reader and returns the start symbol for the grammar generated. |
Symbol |
ResolvingGrammarGenerator.generate(Schema writer,
Schema reader,
Map<org.apache.avro.io.parsing.ValidatingGrammarGenerator.LitS,Symbol> seen)
Resolves the writer schema writer and the reader schema reader and returns the start symbol for the grammar generated. |
Uses of Schema in org.apache.avro.ipc |
---|
Methods in org.apache.avro.ipc with parameters of type Schema | |
---|---|
abstract AvroRemoteException |
Requestor.readError(Schema schema,
Decoder in)
Reads an error message. |
abstract Object |
Responder.readRequest(Schema schema,
Decoder in)
Reads a request message. |
abstract Object |
Requestor.readResponse(Schema schema,
Decoder in)
Reads a response message. |
abstract void |
Responder.writeError(Schema schema,
AvroRemoteException error,
Encoder out)
Writes an error message. |
abstract void |
Requestor.writeRequest(Schema schema,
Object request,
Encoder out)
Writes a request message. |
abstract void |
Responder.writeResponse(Schema schema,
Object response,
Encoder out)
Writes a response message. |
Uses of Schema in org.apache.avro.reflect |
---|
Methods in org.apache.avro.reflect that return Schema | |
---|---|
protected Schema |
ReflectData.createFieldSchema(Field field,
Map<String,Schema> names)
Create a schema for a field. |
protected Schema |
ReflectData.AllowNull.createFieldSchema(Field field,
Map<String,Schema> names)
|
protected Schema |
ReflectData.createSchema(Type type,
Map<String,Schema> names)
Create a schema for a type and it's fields. |
protected Schema |
ReflectData.getRecordSchema(Object record)
|
Schema |
ReflectData.getSchema(Type type)
Generate a schema for a Java type. |
Methods in org.apache.avro.reflect with parameters of type Schema | |
---|---|
protected Object |
ReflectDatumReader.createEnum(String symbol,
Schema schema)
|
protected Object |
ReflectDatumReader.createFixed(Object old,
Schema schema)
|
protected DatumReader<Object> |
ReflectResponder.getDatumReader(Schema schema)
|
protected DatumReader<Object> |
ReflectRequestor.getDatumReader(Schema schema)
|
protected DatumWriter<Object> |
ReflectResponder.getDatumWriter(Schema schema)
|
protected DatumWriter<Object> |
ReflectRequestor.getDatumWriter(Schema schema)
|
protected Object |
ReflectDatumReader.newRecord(Object old,
Schema schema)
|
AvroRemoteException |
ReflectRequestor.readError(Schema schema,
Decoder in)
|
Object |
ReflectResponder.readRequest(Schema schema,
Decoder in)
Reads a request message. |
Object |
ReflectRequestor.readResponse(Schema schema,
Decoder in)
|
boolean |
ReflectData.validate(Schema schema,
Object datum)
Returns true if an object matches a schema. |
protected void |
ReflectDatumWriter.writeEnum(Schema schema,
Object datum,
Encoder out)
|
void |
ReflectResponder.writeError(Schema schema,
AvroRemoteException error,
Encoder out)
Writes an error message. |
void |
ReflectRequestor.writeRequest(Schema schema,
Object request,
Encoder out)
|
void |
ReflectResponder.writeResponse(Schema schema,
Object response,
Encoder out)
Writes a response message. |
Method parameters in org.apache.avro.reflect with type arguments of type Schema | |
---|---|
protected Schema |
ReflectData.createFieldSchema(Field field,
Map<String,Schema> names)
Create a schema for a field. |
protected Schema |
ReflectData.AllowNull.createFieldSchema(Field field,
Map<String,Schema> names)
|
protected Schema |
ReflectData.createSchema(Type type,
Map<String,Schema> names)
Create a schema for a type and it's fields. |
Constructors in org.apache.avro.reflect with parameters of type Schema | |
---|---|
ReflectDatumReader(Schema root,
String packageName)
|
|
ReflectDatumWriter(Schema root)
|
|
ReflectDatumWriter(Schema root,
ReflectData reflectData)
|
Uses of Schema in org.apache.avro.specific |
---|
Methods in org.apache.avro.specific that return Schema | |
---|---|
protected Schema |
SpecificData.getRecordSchema(Object record)
|
abstract Schema |
SpecificExceptionBase.getSchema()
|
abstract Schema |
SpecificRecordBase.getSchema()
|
Methods in org.apache.avro.specific with parameters of type Schema | |
---|---|
int |
SpecificData.compare(Object o1,
Object o2,
Schema s)
|
protected DatumReader<Object> |
SpecificRequestor.getDatumReader(Schema schema)
|
protected DatumReader<Object> |
SpecificResponder.getDatumReader(Schema schema)
|
protected DatumWriter<Object> |
SpecificRequestor.getDatumWriter(Schema schema)
|
protected DatumWriter<Object> |
SpecificResponder.getDatumWriter(Schema schema)
|
Constructors in org.apache.avro.specific with parameters of type Schema | |
---|---|
SpecificDatumReader(Schema root)
|
|
SpecificDatumReader(Schema root,
String packageName)
|
|
SpecificDatumWriter(Schema root)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |