org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication

Class HadoopMarshallerFilter

java.lang.Object

org.apache.ignite.internal.util.nio.GridNioFilterAdapter

org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMarshallerFilter

All Implemented Interfaces:

GridNioFilter

public class HadoopMarshallerFilter
extends GridNioFilterAdapter

Serialization filter.

Field Summary

Fields inherited from class org.apache.ignite.internal.util.nio.GridNioFilterAdapter

nextFilter, prevFilter

Constructor Summary

Constructors

Constructor and Description
HadoopMarshallerFilter(Marshaller marsh)

Method Summary

Modifier and Type	Method and Description
void	onExceptionCaught(GridNioSession ses, IgniteCheckedException ex)
void	onMessageReceived(GridNioSession ses, Object msg)
GridNioFuture<Boolean>	onSessionClose(GridNioSession ses)
void	onSessionClosed(GridNioSession ses)
void	onSessionIdleTimeout(GridNioSession ses)
void	onSessionOpened(GridNioSession ses)
GridNioFuture<?>	onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)
void	onSessionWriteTimeout(GridNioSession ses)

Methods inherited from class org.apache.ignite.internal.util.nio.GridNioFilterAdapter

nextFilter, nextFilter, onPauseReads, onResumeReads, previousFilter, previousFilter, proceedExceptionCaught, proceedMessageReceived, proceedPauseReads, proceedResumeReads, proceedSessionClose, proceedSessionClosed, proceedSessionIdleTimeout, proceedSessionOpened, proceedSessionWrite, proceedSessionWriteTimeout, start, stop, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopMarshallerFilter

public HadoopMarshallerFilter(Marshaller marsh)

Parameters:

marsh - Marshaller to use.

Method Detail

onSessionOpened

public void onSessionOpened(GridNioSession ses)
                     throws IgniteCheckedException

Throws:

IgniteCheckedException

onSessionClosed

public void onSessionClosed(GridNioSession ses)
                     throws IgniteCheckedException

Throws:

IgniteCheckedException

onExceptionCaught

public void onExceptionCaught(GridNioSession ses,
                              IgniteCheckedException ex)
                       throws IgniteCheckedException

Throws:

IgniteCheckedException

onSessionWrite

public GridNioFuture<?> onSessionWrite(GridNioSession ses,
                                       Object msg,
                                       boolean fut,
                                       IgniteInClosure<IgniteException> ackC)
                                throws IgniteCheckedException

Throws:

IgniteCheckedException

onMessageReceived

public void onMessageReceived(GridNioSession ses,
                              Object msg)
                       throws IgniteCheckedException

Throws:

IgniteCheckedException

onSessionClose

public GridNioFuture<Boolean> onSessionClose(GridNioSession ses)
                                      throws IgniteCheckedException

Throws:

IgniteCheckedException

onSessionIdleTimeout

public void onSessionIdleTimeout(GridNioSession ses)
                          throws IgniteCheckedException

Throws:

IgniteCheckedException

onSessionWriteTimeout

public void onSessionWriteTimeout(GridNioSession ses)
                           throws IgniteCheckedException

Throws:

IgniteCheckedException