org.apache.tez.runtime.library.processor
Class SleepProcessor.SleepProcessorConfig

java.lang.Object
  org.apache.tez.runtime.library.processor.SleepProcessor.SleepProcessorConfig

Enclosing class:

SleepProcessor

public static class SleepProcessor.SleepProcessorConfig
extends Object

Configuration for the Sleep Processor. Only configuration option is time to sleep in milliseconds.

Constructor Summary

SleepProcessor.SleepProcessorConfig()

SleepProcessor.SleepProcessorConfig(int timeToSleepMS)

Method Summary

void	fromUserPayload(byte[] userPayload)
int	getTimeToSleepMS()
byte[]	toUserPayload()

Methods inherited from class java.lang.Object

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

Constructor Detail

SleepProcessor.SleepProcessorConfig

public SleepProcessor.SleepProcessorConfig()

SleepProcessor.SleepProcessorConfig

public SleepProcessor.SleepProcessorConfig(int timeToSleepMS)

Parameters:

timeToSleepMS - Time to sleep in milliseconds

Method Detail

toUserPayload

public byte[] toUserPayload()

fromUserPayload

public void fromUserPayload(byte[] userPayload)

getTimeToSleepMS

public int getTimeToSleepMS()