HadoopBulkAttributeWriter

java.lang.Object
- cz.o2.proxima.core.storage.AbstractStorage
- - cz.o2.proxima.direct.core.AbstractAttributeWriter
  - - cz.o2.proxima.direct.core.AbstractBulkAttributeWriter
    - - cz.o2.proxima.direct.io.bulkfs.AbstractBulkFileSystemAttributeWriter
      - cz.o2.proxima.direct.io.hadoop.HadoopBulkAttributeWriter

All Implemented Interfaces:

AttributeWriterBase, BulkAttributeWriter, java.lang.AutoCloseable
```
public class HadoopBulkAttributeWriter
extends AbstractBulkFileSystemAttributeWriter
```
Bulk attribute writer to Hadoop FileSystem.

Nested Class Summary
- Nested classes/interfaces inherited from class cz.o2.proxima.direct.io.bulkfs.AbstractBulkFileSystemAttributeWriter
  AbstractBulkFileSystemAttributeWriter.Bulk
- 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.AttributeWriterBase
  AttributeWriterBase.Factory<W extends AttributeWriterBase>, AttributeWriterBase.Type
- Nested classes/interfaces inherited from interface cz.o2.proxima.direct.core.BulkAttributeWriter
  BulkAttributeWriter.Factory<T extends BulkAttributeWriter>

Constructor Summary

Constructors
Constructor Description

HadoopBulkAttributeWriter(HadoopDataAccessor accessor, Context context)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`BulkAttributeWriter.Factory<?>`	`asFactory()`	Convert instance of this writer to `AttributeWriterBase.Factory` suitable for serialization.
`protected void`	`flush(AbstractBulkFileSystemAttributeWriter.Bulk bulk)`	Flush given `AbstractBulkFileSystemAttributeWriter.Bulk` to final output.
`java.net.URI`	`getUri()`	Retrieve URI of this writer.

Methods inherited from class cz.o2.proxima.direct.io.bulkfs.AbstractBulkFileSystemAttributeWriter
close, handleLateData, rollback, updateWatermark, write

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.AttributeWriterBase
bulk, online

Methods inherited from interface cz.o2.proxima.direct.core.BulkAttributeWriter
getType

- Constructor Detail
  - HadoopBulkAttributeWriter
```
public HadoopBulkAttributeWriter(HadoopDataAccessor accessor,
                                 Context context)
```
- Method Detail
  - getUri
```
public java.net.URI getUri()
```
    Description copied from interface: AttributeWriterBase
    
    Retrieve URI of this writer.
    
    Returns:
    
    URI of this writer
  - flush
```
protected void flush(AbstractBulkFileSystemAttributeWriter.Bulk bulk)
```
    Description copied from class: AbstractBulkFileSystemAttributeWriter
    
    Flush given AbstractBulkFileSystemAttributeWriter.Bulk to final output.
    
    Specified by:
    
    flush in class AbstractBulkFileSystemAttributeWriter
    
    Parameters:
    
    bulk - the bulk to flush
  - asFactory
```
public BulkAttributeWriter.Factory<?> asFactory()
```
    Description copied from interface: AttributeWriterBase
    
    Convert instance of this writer to AttributeWriterBase.Factory suitable for serialization.
    
    Returns:
    
    the AttributeWriterBase.Factory representing this reader