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_KEY
inputPath, inputSize, inputStream, outputPath, outputStream
autoCreateSchema, 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, write
createInputStream, createOutputStream, createSchema, deleteSchema, execute, getInputPath, getInputStream, getOrCreateInputStream, getOrCreateOutputStream, getOutputPath, getOutputStream, getPartitions, schemaExists, setInputPath, setInputStream, setOutputPath, setOutputStream
equals, get, getBeanFactory, getFields, getFieldsToQuery, getKeyClass, getOrCreateConf, getPersistentClass, getSchemaName, newKey, newPersistent, setBeanFactory, setConf, setKeyClass, setPersistentClass, truncateSchema
clone, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
get, getBeanFactory, getKeyClass, getPersistentClass, newKey, newPersistent, setBeanFactory, setKeyClass, setPersistentClass, truncateSchema
public T get(K key, String[] fields)
DataStore
get
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)
DataStore
put
in interface DataStore<K,T extends PersistentBase>
put
in class AvroStore<K,T extends PersistentBase>
protected Result<K,T> executeQuery(Query<K,T> query)
AvroStore
executeQuery
in class AvroStore<K,T extends PersistentBase>
protected Result<K,T> executePartial(FileSplitPartitionQuery<K,T> query)
AvroStore
executePartial
in class AvroStore<K,T extends PersistentBase>
public void flush()
DataStore
flush
in interface DataStore<K,T extends PersistentBase>
flush
in class AvroStore<K,T extends PersistentBase>
public void close()
DataStore
close
in interface Closeable
close
in interface AutoCloseable
close
in interface DataStore<K,T extends PersistentBase>
close
in class AvroStore<K,T extends PersistentBase>
Copyright © 2010-2014 The Apache Software Foundation. All Rights Reserved.