alluxio.worker.block.io

Class StoreBlockWriter

java.lang.Object

alluxio.worker.block.io.BlockClient

alluxio.worker.block.io.BlockWriter

alluxio.worker.block.io.LocalFileBlockWriter

alluxio.worker.block.io.StoreBlockWriter

All Implemented Interfaces:

Closeable, AutoCloseable

public class StoreBlockWriter
extends LocalFileBlockWriter

A local block writer used by block store. It provides integration with the BlockStreamTracker.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.worker.block.io.BlockClient

BlockClient.Type

Field Summary

Fields

Modifier and Type	Field and Description
protected TempBlockMeta	mBlockMeta Temp block meta for the writer.

Constructor Summary

Constructors

Constructor and Description
StoreBlockWriter(TempBlockMeta blockMeta) Creates new block writer for block store.

Method Summary

Modifier and Type	Method and Description
void	close()

Methods inherited from class alluxio.worker.block.io.LocalFileBlockWriter

append, append, append, getChannel, getPosition

Methods inherited from class alluxio.worker.block.io.BlockClient

toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

mBlockMeta

protected final TempBlockMeta mBlockMeta

Temp block meta for the writer.

Constructor Detail

StoreBlockWriter

public StoreBlockWriter(TempBlockMeta blockMeta)
                 throws IOException

Creates new block writer for block store.

Parameters:

blockMeta - temp block meta

Throws:

IOException

Method Detail

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class LocalFileBlockWriter

Throws:

IOException