Package org.apache.hadoop.ozone.container.common.transport.server.ratis

Class DispatcherContext

java.lang.Object

org.apache.hadoop.ozone.container.common.transport.server.ratis.DispatcherContext

@Private
@Evolving
public final class DispatcherContext
extends Object

DispatcherContext class holds transport protocol specific context info required for execution of container commands over the container dispatcher.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	DispatcherContext.Builder	Builder class for building DispatcherContext.
static enum	DispatcherContext.Op	Operation types.
static enum	DispatcherContext.WriteChunkStage	Determines which stage of writeChunk a write chunk request is for.

Method Summary

Modifier and Type	Method	Description
Map<Long,Long>	getContainer2BCSIDMap()
static DispatcherContext	getHandleGetSmallFile()
static DispatcherContext	getHandlePutSmallFile()
static DispatcherContext	getHandleReadChunk()
static DispatcherContext	getHandleWriteChunk()
long	getLogIndex()
DispatcherContext.WriteChunkStage	getStage()
long	getStartTime()
long	getTerm()
boolean	isReleaseSupported()
static DispatcherContext.Builder	newBuilder(DispatcherContext.Op op)
static DispatcherContext.Op	op(DispatcherContext context)
void	release()
void	setReleaseMethod(Runnable releaseMethod)
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

getHandleReadChunk

public static DispatcherContext getHandleReadChunk()

getHandleWriteChunk

public static DispatcherContext getHandleWriteChunk()

getHandleGetSmallFile

public static DispatcherContext getHandleGetSmallFile()

getHandlePutSmallFile

public static DispatcherContext getHandlePutSmallFile()

op

public static DispatcherContext.Op op(DispatcherContext context)

getLogIndex

public long getLogIndex()

getTerm

public long getTerm()

getStage

public DispatcherContext.WriteChunkStage getStage()

getContainer2BCSIDMap

public Map<Long,Long> getContainer2BCSIDMap()

getStartTime

public long getStartTime()

isReleaseSupported

public boolean isReleaseSupported()

setReleaseMethod

public void setReleaseMethod(Runnable releaseMethod)

release

public void release()

toString

public String toString()

Overrides:

toString in class Object

newBuilder

public static DispatcherContext.Builder newBuilder(DispatcherContext.Op op)