Package org.apache.nemo.runtime.executor.transfer

Class ByteOutputContext

java.lang.Object

org.apache.nemo.runtime.executor.transfer.ByteTransferContext

org.apache.nemo.runtime.executor.transfer.ByteOutputContext

All Implemented Interfaces:

java.lang.AutoCloseable, OutputContext

public class ByteOutputContext
extends ByteTransferContext
implements OutputContext

Container for multiple output streams. Represents a transfer context on sender-side.

Public methods are thread safe, although the execution order may not be linearized if they were called from different threads.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	ByteOutputContext.ByteOutputStream	An OutputStream implementation which buffers data to ByteBufs.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this stream.
ByteOutputContext.ByteOutputStream	newOutputStream()	Closes existing sub-stream (if any) and create a new sub-stream.
void	onChannelError(java.lang.Throwable cause)	Handles exception.

Methods inherited from class org.apache.nemo.runtime.executor.transfer.ByteTransferContext

deregister, getContextDescriptor, getContextId, getException, getRemoteExecutorId, hasException, setChannelError, toString

Methods inherited from class java.lang.Object

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

Method Detail

newOutputStream

public final ByteOutputContext.ByteOutputStream newOutputStream()
                                                         throws java.io.IOException

Closes existing sub-stream (if any) and create a new sub-stream.

Specified by:

newOutputStream in interface OutputContext

Returns:

new ByteOutputContext.ByteOutputStream

Throws:

java.io.IOException - if an exception was set or this context was closed.

close

public final void close()
                 throws java.io.IOException

Closes this stream.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface OutputContext

Throws:

java.io.IOException - if an exception was set

onChannelError

public final void onChannelError(@Nullable
                                 java.lang.Throwable cause)

Description copied from class: ByteTransferContext

Handles exception.

Specified by:

onChannelError in class ByteTransferContext

Parameters:

cause - the cause of exception handling