@Test (groups = "deserializationTest") public void testIsSupportedForFastGenericDatumReader() { Schema testWriterSchema = Schema.parse("{\"type\": \"record\", \"name\": \"test_record\", \"fields\":[]}"); Schema testReaderSchema = Schema.parse("{\"type\": \"record\", \"name\": \"test_record\", \"fields\":[]}"); FastGenericDatumReader fastReader = FastDatumReaderWriterUtil.getFastGenericDatumReader(testWriterSchema, testReaderSchema); Assert.assertNotNull(fastReader); FastGenericDatumReader newFastReader = FastDatumReaderWriterUtil.getFastGenericDatumReader(testWriterSchema, testReaderSchema); Assert.assertSame(fastReader, newFastReader); }
public static <T> FastGenericDatumReader<T> getFastGenericDatumReader(Schema schema) { return (FastGenericDatumReader<T>) getFastGenericDatumReader(schema, schema); }
FastDatumReaderWriterUtil { public static <T> FastGenericDatumReader<T> getFastGenericDatumReader(Schema schema) { return (FastGenericDatumReader<T>) getFastGenericDatumReader(schema, schema); } }
FastDatumReaderWriterUtil { public static <T> FastGenericDatumReader<T> getFastGenericDatumReader(Schema schema) { return (FastGenericDatumReader<T>) getFastGenericDatumReader(schema, schema); } private  FastDatumReaderWriterUtil(); }
FastDatumReaderWriterUtil { public static <T> FastGenericDatumReader<T> getFastGenericDatumReader(Schema schema) { return (FastGenericDatumReader<T>) getFastGenericDatumReader(schema, schema); } private  FastDatumReaderWriterUtil(); static FastGenericDatumReader<T> getFastGenericDatumReader(Schema schema); static FastGenericDatumReader<T> getFastGenericDatumReader(Schema writerSchema, Schema readerSchema); static FastGenericDatumWriter<T> getFastGenericDatumWriter(Schema writerSchema); static FastSpecificDatumReader<T> getFastSpecificDatumReader(Schema schema); static FastSpecificDatumReader<T> getFastSpecificDatumReader(Schema writerSchema, Schema readerSchema); static FastSpecificDatumWriter<T> getFastSpecificDatumWriter(Schema writerSchema); }
FastDatumReaderWriterUtil { public static <T> FastGenericDatumReader<T> getFastGenericDatumReader(Schema schema) { return (FastGenericDatumReader<T>) getFastGenericDatumReader(schema, schema); } private  FastDatumReaderWriterUtil(); static FastGenericDatumReader<T> getFastGenericDatumReader(Schema schema); static FastGenericDatumReader<T> getFastGenericDatumReader(Schema writerSchema, Schema readerSchema); static FastGenericDatumWriter<T> getFastGenericDatumWriter(Schema writerSchema); static FastSpecificDatumReader<T> getFastSpecificDatumReader(Schema schema); static FastSpecificDatumReader<T> getFastSpecificDatumReader(Schema writerSchema, Schema readerSchema); static FastSpecificDatumWriter<T> getFastSpecificDatumWriter(Schema writerSchema);  }