Contents:

• Welcome to Avro’s Python documentation!
• SchemaCompatibilityType
• SchemaIncompatibilityType
• SchemaType
• merge()
• DataFileReader
  • DataFileReader.close()
  • DataFileReader.determine_file_length()
• DataFileWriter
  • DataFileWriter.append()
  • DataFileWriter.close()
  • DataFileWriter.flush()
  • DataFileWriter.sync()
• HeaderType
• BaseRequestor
  • BaseRequestor.read_call_response()
  • BaseRequestor.request()
  • BaseRequestor.write_call_request()
• FramedReader
• FramedWriter
• HTTPTransceiver
• Requestor
• Responder
  • Responder.invoke()
  • Responder.respond()
• Message
• MessageObject
• Protocol
• ProtocolObject
• make_avpr_object()
• parse()
• BZip2Codec
  • BZip2Codec.compress()
  • BZip2Codec.decompress()
• Codec
  • Codec.compress()
  • Codec.decompress()
• DeflateCodec
  • DeflateCodec.compress()
  • DeflateCodec.decompress()
• NullCodec
  • NullCodec.compress()
  • NullCodec.decompress()
• Components
  • Nodes
  • Iterators
  • Validators
• BinaryDecoder
  • BinaryDecoder.read()
  • BinaryDecoder.read_boolean()
  • BinaryDecoder.read_bytes()
  • BinaryDecoder.read_date_from_int()
  • BinaryDecoder.read_decimal_from_bytes()
  • BinaryDecoder.read_decimal_from_fixed()
  • BinaryDecoder.read_double()
  • BinaryDecoder.read_float()
  • BinaryDecoder.read_int()
  • BinaryDecoder.read_long()
  • BinaryDecoder.read_null()
  • BinaryDecoder.read_time_micros_from_long()
  • BinaryDecoder.read_time_millis_from_int()
  • BinaryDecoder.read_timestamp_micros_from_long()
  • BinaryDecoder.read_timestamp_millis_from_long()
  • BinaryDecoder.read_utf8()
• BinaryEncoder
  • BinaryEncoder.write()
  • BinaryEncoder.write_boolean()
  • BinaryEncoder.write_bytes()
  • BinaryEncoder.write_date_int()
  • BinaryEncoder.write_decimal_bytes()
  • BinaryEncoder.write_decimal_fixed()
  • BinaryEncoder.write_double()
  • BinaryEncoder.write_float()
  • BinaryEncoder.write_int()
  • BinaryEncoder.write_long()
  • BinaryEncoder.write_null()
  • BinaryEncoder.write_time_micros_long()
  • BinaryEncoder.write_time_millis_int()
  • BinaryEncoder.write_timestamp_micros_long()
  • BinaryEncoder.write_timestamp_millis_long()
  • BinaryEncoder.write_utf8()
• DatumReader
  • DatumReader.read_array()
  • DatumReader.read_enum()
  • DatumReader.read_fixed()
  • DatumReader.read_map()
  • DatumReader.read_record()
  • DatumReader.read_union()
• DatumWriter
  • DatumWriter.write_array()
  • DatumWriter.write_enum()
  • DatumWriter.write_fixed()
  • DatumWriter.write_map()
  • DatumWriter.write_record()
  • DatumWriter.write_union()
• ValidationNode
  • ValidationNode.datum
  • ValidationNode.name
  • ValidationNode.schema
• validate()
• HTTPRequestor
• TaskRunner
  • TaskRunner.close()
  • TaskRunner.start()
• TetherTask
  • TetherTask.complete()
  • TetherTask.configure()
  • TetherTask.count()
  • TetherTask.fail()
  • TetherTask.input()
  • TetherTask.map()
  • TetherTask.open()
  • TetherTask.partitions
  • TetherTask.reduce()
  • TetherTask.reduceFlush()
  • TetherTask.status()
• find_port()
• TaskRunner
  • TaskRunner.close()
  • TaskRunner.start()
• find_port()
• HTTPRequestor
• TetherTask
  • TetherTask.complete()
  • TetherTask.configure()
  • TetherTask.count()
  • TetherTask.fail()
  • TetherTask.input()
  • TetherTask.map()
  • TetherTask.open()
  • TetherTask.partitions
  • TetherTask.reduce()
  • TetherTask.reduceFlush()
  • TetherTask.status()
• TypedDict()
• randbytes()
• AvroException
• AvroOutOfScaleException
• AvroRemoteException
• AvroRuntimeException
• AvroTypeException
• AvroWarning
• ConnectionClosedException
• DataFileException
• IONotReadyException
• IgnoredLogicalType
• InvalidAvroBinaryEncoding
• InvalidDefault
• InvalidDefaultException
• InvalidName
• ProtocolParseException
• SchemaParseException
• SchemaResolutionException
• UnknownFingerprintAlgorithmException
• UnsupportedCodec
• UsageError
• Name
  • Name.space
• Names
  • Names.add_name()
  • Names.prune_namespace()
• validate_basename()
• GenericHandler
• GenericResponder
  • GenericResponder.invoke()
• TSTTzinfo
  • TSTTzinfo.dst()
  • TSTTzinfo.tzname()
  • TSTTzinfo.utcoffset()
• UTCTzinfo
  • UTCTzinfo.dst()
  • UTCTzinfo.tzname()
  • UTCTzinfo.utcoffset()
• print_json_pretty()
• ArraySchema
  • ArraySchema.match()
  • ArraySchema.to_canonical_json()
  • ArraySchema.to_json()
  • ArraySchema.validate()
• BytesDecimalSchema
  • BytesDecimalSchema.to_json()
  • BytesDecimalSchema.validate()
• CanonicalPropertiesMixin
• DateSchema
  • DateSchema.to_json()
  • DateSchema.validate()
• EnumSchema
  • EnumSchema.match()
  • EnumSchema.to_canonical_json()
  • EnumSchema.to_json()
  • EnumSchema.validate()
• EqualByJsonMixin
• EqualByPropsMixin
• ErrorUnionSchema
  • ErrorUnionSchema.to_json()
• Field
• FixedDecimalSchema
  • FixedDecimalSchema.to_json()
  • FixedDecimalSchema.validate()
• FixedSchema
  • FixedSchema.match()
  • FixedSchema.to_canonical_json()
  • FixedSchema.to_json()
  • FixedSchema.validate()
• MapSchema
  • MapSchema.match()
  • MapSchema.to_canonical_json()
  • MapSchema.to_json()
  • MapSchema.validate()
• NamedSchema
• PrimitiveSchema
  • PrimitiveSchema.match()
  • PrimitiveSchema.to_canonical_json()
  • PrimitiveSchema.to_json()
  • PrimitiveSchema.validate()
• PropertiesMixin
  • PropertiesMixin.check_props()
  • PropertiesMixin.other_props
• RecordSchema
  • RecordSchema.make_field_objects()
  • RecordSchema.match()
  • RecordSchema.to_canonical_json()
  • RecordSchema.to_json()
  • RecordSchema.validate()
• Schema
  • Schema.fingerprint()
  • Schema.match()
  • Schema.to_canonical_json()
  • Schema.to_json()
  • Schema.validate()
• TimeMicrosSchema
  • TimeMicrosSchema.to_json()
  • TimeMicrosSchema.validate()
• TimeMillisSchema
  • TimeMillisSchema.to_json()
  • TimeMillisSchema.validate()
• TimestampMicrosSchema
  • TimestampMicrosSchema.to_json()
  • TimestampMicrosSchema.validate()
• TimestampMillisSchema
  • TimestampMillisSchema.to_json()
  • TimestampMillisSchema.validate()
• UUIDSchema
  • UUIDSchema.to_json()
  • UUIDSchema.validate()
• UnionSchema
  • UnionSchema.match()
  • UnionSchema.to_canonical_json()
  • UnionSchema.to_json()
  • UnionSchema.validate()
• from_path()
• get_other_props()
• make_avsc_object()
• make_bytes_decimal_schema()
• make_logical_schema()
• parse()

Indices and tables

• Index

• Module Index

• Search Page