PubSubBulkReader

java.lang.Object
- cz.o2.proxima.core.storage.AbstractStorage
- - cz.o2.proxima.direct.io.pubsub.AbstractPubSubReader
  - - cz.o2.proxima.direct.io.pubsub.PubSubBulkReader

All Implemented Interfaces:: CommitLogReader

public class PubSubBulkReader
extends AbstractPubSubReader
implements CommitLogReader

Nested Class Summary
- Nested classes/interfaces inherited from class cz.o2.proxima.core.storage.AbstractStorage
  AbstractStorage.SerializableAbstractStorage
- Nested classes/interfaces inherited from interface cz.o2.proxima.direct.core.commitlog.CommitLogReader
  CommitLogReader.Factory<T extends CommitLogReader>

Field Summary
- Fields inherited from class cz.o2.proxima.direct.io.pubsub.AbstractPubSubReader
  accessor, context, maxAckDeadline, project, subscriptionAckDeadline, subscriptionAutoCreate, topic, watermarkFactory

Constructor Summary

Constructors
Constructor Description

PubSubBulkReader(PubSubAccessor accessor, Context context)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`CommitLogReader.Factory<?>`	`asFactory()`	Convert instance of this reader to `CommitLogReader.Factory` suitable for serialization.
`protected java.util.List<StreamElement>`	`parseElements(com.google.pubsub.v1.PubsubMessage m)`

Methods inherited from class cz.o2.proxima.direct.io.pubsub.AbstractPubSubReader
getPartitions, hasExternalizableOffsets, observe, observeBulk, observeBulkOffsets, observeBulkPartitions, observePartitions

Methods inherited from class cz.o2.proxima.core.storage.AbstractStorage
equals, hashCode

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cz.o2.proxima.direct.core.commitlog.CommitLogReader
fetchOffsets, getOffsetExternalizer, getPartitions, getUri, hasExternalizableOffsets, observe, observe, observeBulk, observeBulk, observeBulk, observeBulkOffsets, observeBulkOffsets, observeBulkPartitions, observeBulkPartitions, observeBulkPartitions, observeBulkPartitions, observePartitions, observePartitions, observePartitions, observePartitions, restoresSequentialIds

- Constructor Detail
  - PubSubBulkReader
```
public PubSubBulkReader(PubSubAccessor accessor,
                        Context context)
```
- Method Detail
  - parseElements
```
protected java.util.List<StreamElement> parseElements(com.google.pubsub.v1.PubsubMessage m)
```
    Specified by:
    
    parseElements in class AbstractPubSubReader
  - asFactory
```
public CommitLogReader.Factory<?> asFactory()
```
    Description copied from interface: CommitLogReader
    
    Convert instance of this reader to CommitLogReader.Factory suitable for serialization.
    
    Specified by:
    
    asFactory in interface CommitLogReader
    
    Returns:
    
    the CommitLogReader.Factory representing this reader