assertTrue(AvroIODatumReader::schemasMatch( AvroSchema::parse($writers_schema), AvroSchema::parse($readers_schema))); } public function test_aliased() { $writers_schema = AvroSchema::parse(<<writeData($writers_schema, ['field1' => 1], new AvroIOBinaryEncoder($io)); $bin = $io->string(); $reader = new AvroIODatumReader(); $record = $reader->readRecord( $writers_schema, $readers_schema, new AvroIOBinaryDecoder(new AvroStringIO($bin)) ); $this->assertEquals(['field2' => 1], $record); } public function testRecordNullField() { $schema_json = <<<_JSON {"name":"member", "type":"record", "fields":[{"name":"one", "type":"int"}, {"name":"two", "type":["null", "string"]} ]} _JSON; $schema = AvroSchema::parse($schema_json); $datum = array("one" => 1); $io = new AvroStringIO(); $writer = new AvroIODatumWriter($schema); $encoder = new AvroIOBinaryEncoder($io); $writer->write($datum, $encoder); $bin = $io->string(); $this->assertSame('0200', bin2hex($bin)); } }