PubSubDataAccessorFactory

java.lang.Object
- cz.o2.proxima.beam.io.pubsub.PubSubDataAccessorFactory

All Implemented Interfaces:

DataAccessorFactory, AbstractDataAccessorFactory<BeamDataOperator,DataAccessor>, java.io.Serializable
```
@AutoService(DataAccessorFactory.class)
public class PubSubDataAccessorFactory
extends java.lang.Object
implements DataAccessorFactory
```
DataAccessorFactory for PubSub URLs.

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

PubSubDataAccessorFactory()

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(BeamDataOperator op, AttributeFamilyDescriptor family)`	Create the accessor for give `AttributeFamilyDescriptor`.

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

- Constructor Detail
  - PubSubDataAccessorFactory
```
public PubSubDataAccessorFactory()
```
- Method Detail
  - 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 interface AbstractDataAccessorFactory<BeamDataOperator,DataAccessor>
    
    Parameters:
    
    uri - the URI to create accessor for
    
    Returns:
    
    acception mark
  - createAccessor
```
public DataAccessor createAccessor(BeamDataOperator op,
                                   AttributeFamilyDescriptor family)
```
    Description copied from interface: AbstractDataAccessorFactory
    
    Create the accessor for give AttributeFamilyDescriptor.
    
    Specified by:
    
    createAccessor in interface AbstractDataAccessorFactory<BeamDataOperator,DataAccessor>
    
    Parameters:
    
    op - operator to create the accessor for
    
    family - attribute family descriptor
    
    Returns:
    
    AbstractDataAccessor for given operator and family