Package cz.o2.proxima.direct.io.hadoop
Class HadoopStorage
- java.lang.Object
-
- cz.o2.proxima.direct.io.hadoop.HadoopStorage
-
- All Implemented Interfaces:
AbstractDataAccessorFactory<DirectDataOperator,DataAccessor>
,DataAccessorFactory
,java.io.Serializable
@AutoService(DataAccessorFactory.class) public class HadoopStorage extends java.lang.Object implements DataAccessorFactory
Writer to HDFS.- 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 HadoopStorage()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AbstractDataAccessorFactory.Accept
accepts(java.net.URI uri)
Check if this factory can create accessors for given URI.DataAccessor
createAccessor(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:AbstractDataAccessorFactory
Create the accessor for giveAttributeFamilyDescriptor
.- Specified by:
createAccessor
in interfaceAbstractDataAccessorFactory<DirectDataOperator,DataAccessor>
- Parameters:
operator
- operator to create the accessor forfamilyDescriptor
- attribute family descriptor- Returns:
AbstractDataAccessor
for given operator and family
-
accepts
public AbstractDataAccessorFactory.Accept accepts(java.net.URI uri)
Description copied from interface:AbstractDataAccessorFactory
Check if this factory can create accessors for given URI.- Specified by:
accepts
in interfaceAbstractDataAccessorFactory<DirectDataOperator,DataAccessor>
- Parameters:
uri
- the URI to create accessor for- Returns:
- acception mark
-
-