@Test public void testReaderSchema() throws IOException { List<Document> documents = DataStoreExamples.getDocument(); FileSystemPath path = new FileSystemPath(new File(tempDir, "doc")); DataStore.create(documents, path); List<DocumentWithoutTitle> documentsWithoutTitle = DataStoreExamples.getDocumentWithoutTitle(); TestsIOUtils.assertEqualSets(documentsWithoutTitle, new AvroDataStoreReader<DocumentWithoutTitle>( path, DocumentWithoutTitle.SCHEMA$)); }
public static <T> DataFileWriter<T> create( FileSystemPath path, Schema schema) throws IOException{ return create(path, schema, singleDataStoreFileName); }
DataStore { public static <T> DataFileWriter<T> create( FileSystemPath path, Schema schema) throws IOException{ return create(path, schema, singleDataStoreFileName); } }
DataStore { public static <T> DataFileWriter<T> create( FileSystemPath path, Schema schema) throws IOException{ return create(path, schema, singleDataStoreFileName); } private  DataStore(); }
DataStore { public static <T> DataFileWriter<T> create( FileSystemPath path, Schema schema) throws IOException{ return create(path, schema, singleDataStoreFileName); } private  DataStore(); static DataFileWriter<T> create(
			FileSystemPath path, Schema schema); static DataFileWriter<T> create(
            FileSystemPath path, Schema schema, String dataStoreFileName); static CloseableIterator<T> getReader(FileSystemPath path); static CloseableIterator<T> getReader(
			FileSystemPath path, Schema readerSchema); static List<T> read(FileSystemPath path); static List<T> read(FileSystemPath path, Schema readerSchema); static void create(
			List<T> elements, FileSystemPath path); static void create(
			List<T> elements, FileSystemPath path, Schema schema); static DataFileWriter<T> createSingleFile(
			FileSystemPath path, Schema schema); static String generateFileName(int fileNo); }
DataStore { public static <T> DataFileWriter<T> create( FileSystemPath path, Schema schema) throws IOException{ return create(path, schema, singleDataStoreFileName); } private  DataStore(); static DataFileWriter<T> create(
			FileSystemPath path, Schema schema); static DataFileWriter<T> create(
            FileSystemPath path, Schema schema, String dataStoreFileName); static CloseableIterator<T> getReader(FileSystemPath path); static CloseableIterator<T> getReader(
			FileSystemPath path, Schema readerSchema); static List<T> read(FileSystemPath path); static List<T> read(FileSystemPath path, Schema readerSchema); static void create(
			List<T> elements, FileSystemPath path); static void create(
			List<T> elements, FileSystemPath path, Schema schema); static DataFileWriter<T> createSingleFile(
			FileSystemPath path, Schema schema); static String generateFileName(int fileNo); static final String AVRO_FILE_EXT; }