Package cz.o2.proxima.direct.io.bigtable
Class BigTableStorage
- java.lang.Object
-
- cz.o2.proxima.direct.io.bigtable.BigTableStorage
-
- All Implemented Interfaces:
AbstractDataAccessorFactory<DirectDataOperator,DataAccessor>,DataAccessorFactory,java.io.Serializable
@AutoService(DataAccessorFactory.class) public class BigTableStorage extends java.lang.Object implements DataAccessorFactory
Storage descriptor for bigtable:// URIs.BigTable storage uses URIs in the form of
bigtable://<project>:<instance>/<table>?family=<family>and stores data using HBase client in BigTable instanceinstanceof projectprojectin table namedtablein familyfamily.An optional parameter in URI called
vcan be used to distinguish two serialization versions of data in BigTable cell:v=1(default) stores the serialized bytes of a value in a cell directlyv=2uses protobuffer to store more metadata into the value
v=2serialization format is required to support transactions on top of BigTable, because the metadata preserves sequentialId (stored inStreamElement#getSequentialId).- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface cz.o2.proxima.core.storage.internal.AbstractDataAccessorFactory
AbstractDataAccessorFactory.Accept
-
-
Constructor Summary
Constructors Constructor Description BigTableStorage()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AbstractDataAccessorFactory.Acceptaccepts(java.net.URI uri)Check if this factory can create accessors for given URI.DataAccessorcreateAccessor(DirectDataOperator operator, AttributeFamilyDescriptor familyDescriptor)Create the accessor for giveAttributeFamilyDescriptor.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface cz.o2.proxima.core.storage.internal.AbstractDataAccessorFactory
setup
-
-
-
-
Method Detail
-
createAccessor
public DataAccessor createAccessor(DirectDataOperator operator, AttributeFamilyDescriptor familyDescriptor)
Description copied from interface:AbstractDataAccessorFactoryCreate the accessor for giveAttributeFamilyDescriptor.- Specified by:
createAccessorin interfaceAbstractDataAccessorFactory<DirectDataOperator,DataAccessor>- Parameters:
operator- operator to create the accessor forfamilyDescriptor- attribute family descriptor- Returns:
AbstractDataAccessorfor given operator and family
-
accepts
public AbstractDataAccessorFactory.Accept accepts(java.net.URI uri)
Description copied from interface:AbstractDataAccessorFactoryCheck if this factory can create accessors for given URI.- Specified by:
acceptsin interfaceAbstractDataAccessorFactory<DirectDataOperator,DataAccessor>- Parameters:
uri- the URI to create accessor for- Returns:
- acception mark
-
-