alluxio.client.block.stream

Interface DataWriter

All Superinterfaces:

AutoCloseable, Cancelable, Closeable

All Known Implementing Classes:

BlockWorkerDataWriter, GrpcDataWriter, LocalFileDataWriter, UfsFallbackLocalFileDataWriter

public interface DataWriter
extends Closeable, Cancelable

The interface to write data.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	DataWriter.Factory Factory for DataWriter.

Method Summary

Modifier and Type	Method and Description
int	chunkSize()
void	flush() Flushes all the pending chunks.
Optional<String>	getUfsContentHash()
long	pos()
void	writeChunk(io.netty.buffer.ByteBuf chunk) Writes a chunk.

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface alluxio.client.Cancelable

cancel

Method Detail

getUfsContentHash

Optional<String> getUfsContentHash()

Returns:

the content hash of the file if it is written to the UFS. Will only return a non-empty value after the data writer has been closed.

writeChunk

void writeChunk(io.netty.buffer.ByteBuf chunk)
         throws IOException

Writes a chunk. This method takes the ownership of this chunk even if it fails to write the chunk.

Parameters:

chunk - the chunk

Throws:

IOException

flush

void flush()
    throws IOException

Flushes all the pending chunks.

Throws:

IOException

chunkSize

int chunkSize()

Returns:

the chunk size in bytes used

pos

long pos()

Returns:

the current pos which is the same as the totally number of bytes written so far