public class DataFileAvroStore<K,T extends PersistentBase> extends AvroStore<K,T>
AvroStore.CodecType| Modifier and Type | Field and Description |
|---|---|
static org.slf4j.Logger |
LOG |
CODEC_TYPE_KEYinputPath, inputSize, inputStream, outputPath, outputStreamautoCreateSchema, beanFactory, conf, fieldMap, keyClass, persistentClass, properties, schema| Constructor and Description |
|---|
DataFileAvroStore() |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close the DataStore.
|
protected Result<K,T> |
executePartial(FileSplitPartitionQuery<K,T> query)
Executes a PartitialQuery, reading the data between start and end.
|
protected Result<K,T> |
executeQuery(Query<K,T> query)
Executes a normal Query reading the whole data.
|
void |
flush()
Forces the write caches to be flushed.
|
T |
get(K key,
String[] fields)
Returns the object corresponding to the given key.
|
void |
put(K key,
T obj)
Inserts the persistent object with the given key.
|
createDatumReader, createDatumWriter, createDecoder, createEncoder, delete, deleteByQuery, getConf, getDatumReader, getDatumWriter, getDecoder, getEncoder, getSchemaName, initialize, newQuery, readFields, setCodecType, setDatumReader, setDatumWriter, setDecoder, setEncoder, writecreateInputStream, createOutputStream, createSchema, deleteSchema, execute, getInputPath, getInputStream, getOrCreateInputStream, getOrCreateOutputStream, getOutputPath, getOutputStream, getPartitions, schemaExists, setInputPath, setInputStream, setOutputPath, setOutputStreamequals, get, getBeanFactory, getFields, getFieldsToQuery, getKeyClass, getOrCreateConf, getPersistentClass, getSchemaName, newKey, newPersistent, setBeanFactory, setConf, setKeyClass, setPersistentClass, truncateSchemaclone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitget, getBeanFactory, getKeyClass, getPersistentClass, newKey, newPersistent, setBeanFactory, setKeyClass, setPersistentClass, truncateSchemapublic T get(K key, String[] fields)
DataStoreget in interface DataStore<K,T extends PersistentBase>get in class AvroStore<K,T extends PersistentBase>key - the key of the objectfields - the fields required in the object. Pass null, to retrieve all fieldspublic void put(K key, T obj)
DataStoreput in interface DataStore<K,T extends PersistentBase>put in class AvroStore<K,T extends PersistentBase>protected Result<K,T> executeQuery(Query<K,T> query)
AvroStoreexecuteQuery in class AvroStore<K,T extends PersistentBase>protected Result<K,T> executePartial(FileSplitPartitionQuery<K,T> query)
AvroStoreexecutePartial in class AvroStore<K,T extends PersistentBase>public void flush()
DataStoreflush in interface DataStore<K,T extends PersistentBase>flush in class AvroStore<K,T extends PersistentBase>public void close()
DataStoreclose in interface Closeableclose in interface AutoCloseableclose in interface DataStore<K,T extends PersistentBase>close in class AvroStore<K,T extends PersistentBase>Copyright © 2010-2017 The Apache Software Foundation. All Rights Reserved.