@Test public void testQuery() throws IOException { createWebPageData(webPageStore); webPageStore.close(); webPageStore.setInputPath(webPageStore.getOutputPath()); testQueryWebPages(webPageStore); }
@Override public void close() throws IOException { super.close(); if(encoder != null) { encoder.flush(); } encoder = null; decoder = null; }
AvroStore extends FileBackedDataStoreBase<K, T> implements Configurable { @Override public void close() throws IOException { super.close(); if(encoder != null) { encoder.flush(); } encoder = null; decoder = null; } }
AvroStore extends FileBackedDataStoreBase<K, T> implements Configurable { @Override public void close() throws IOException { super.close(); if(encoder != null) { encoder.flush(); } encoder = null; decoder = null; }  }
AvroStore extends FileBackedDataStoreBase<K, T> implements Configurable { @Override public void close() throws IOException { super.close(); if(encoder != null) { encoder.flush(); } encoder = null; decoder = null; }  @Override void initialize(Class<K> keyClass, Class<T> persistentClass,
      Properties properties); void setCodecType(CodecType codecType); void setEncoder(Encoder encoder); void setDecoder(Decoder decoder); void setDatumReader(DatumReader<T> datumReader); void setDatumWriter(DatumWriter<T> datumWriter); @Override void close(); @Override boolean delete(K key); @Override long deleteByQuery(Query<K, T> query); @Override void flush(); @Override T get(K key, String[] fields); @Override AvroQuery<K,T> newQuery(); @Override void put(K key, T obj); Encoder getEncoder(); Decoder getDecoder(); DatumReader<T> getDatumReader(); DatumWriter<T> getDatumWriter(); @Override Configuration getConf(); @Override void write(DataOutput out); @Override void readFields(DataInput in); @Override String getSchemaName(); }
AvroStore extends FileBackedDataStoreBase<K, T> implements Configurable { @Override public void close() throws IOException { super.close(); if(encoder != null) { encoder.flush(); } encoder = null; decoder = null; }  @Override void initialize(Class<K> keyClass, Class<T> persistentClass,
      Properties properties); void setCodecType(CodecType codecType); void setEncoder(Encoder encoder); void setDecoder(Decoder decoder); void setDatumReader(DatumReader<T> datumReader); void setDatumWriter(DatumWriter<T> datumWriter); @Override void close(); @Override boolean delete(K key); @Override long deleteByQuery(Query<K, T> query); @Override void flush(); @Override T get(K key, String[] fields); @Override AvroQuery<K,T> newQuery(); @Override void put(K key, T obj); Encoder getEncoder(); Decoder getDecoder(); DatumReader<T> getDatumReader(); DatumWriter<T> getDatumWriter(); @Override Configuration getConf(); @Override void write(DataOutput out); @Override void readFields(DataInput in); @Override String getSchemaName(); static final String CODEC_TYPE_KEY; }