org.apache.reef.io.watcher.util

Class WatcherAvroUtil

java.lang.Object

org.apache.reef.io.watcher.util.WatcherAvroUtil

public final class WatcherAvroUtil
extends Object

Method Summary

Methods

Modifier and Type	Method and Description
static AvroActiveContext	toAvroActiveContext(ActiveContext activeContext)
static AvroAllocatedEvaluator	toAvroAllocatedEvaluator(AllocatedEvaluator allocatedEvaluator)
static AvroClosedContext	toAvroClosedContext(ClosedContext closedContext)
static AvroCompletedEvaluator	toAvroCompletedEvaluator(CompletedEvaluator completedEvaluator)
static AvroCompletedTask	toAvroCompletedTask(CompletedTask completedTask)
static AvroContextBase	toAvroContextBase(ContextBase contextBase)
static AvroEvaluatorDescriptor	toAvroEvaluatorDescriptor(EvaluatorDescriptor evaluatorDescriptor)
static AvroEvaluatorProcess	toAvroEvaluatorProcess(EvaluatorProcess evaluatorProcess)
static AvroEvaluatorType	toAvroEvaluatorType(EvaluatorType evaluatorType)
static AvroFailedContext	toAvroFailedContext(FailedContext failedContext)
static AvroFailedEvaluator	toAvroFailedEvaluator(FailedEvaluator failedEvaluator)
static AvroFailedTask	toAvroFailedTask(FailedTask failedTask)
static AvroFailure	toAvroFailure(Failure failure)
static AvroNodeDescriptor	toAvroNodeDescriptor(NodeDescriptor nodeDescriptor)
static AvroNodeDescriptorInRackDescriptor	toAvroNodeDescriptorInRackDescriptor(String id, String name, InetSocketAddress inetSocketAddress)
static AvroRackDescriptor	toAvroRackDescriptor(RackDescriptor rackDescriptor)
static AvroRunningTask	toAvroRunningTask(RunningTask runningTask)
static AvroRuntimeStart	toAvroRuntimeStart(RuntimeStart runtimeStart)
static AvroRuntimeStop	toAvroRuntimeStop(RuntimeStop runtimeStop)
static AvroStartTime	toAvroStartTime(StartTime startTime)
static AvroStopTime	toAvroStopTime(StopTime stopTime)
static AvroSuspendedTask	toAvroSuspendedTask(SuspendedTask suspendedTask)
static AvroTaskMessage	toAvroTaskMessage(TaskMessage taskMessage)
static String	toString(org.apache.avro.specific.SpecificRecord record)

Methods inherited from class java.lang.Object

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

Method Detail

toAvroFailure

public static AvroFailure toAvroFailure(Failure failure)

toAvroNodeDescriptorInRackDescriptor

public static AvroNodeDescriptorInRackDescriptor toAvroNodeDescriptorInRackDescriptor(String id,
                                                                      String name,
                                                                      InetSocketAddress inetSocketAddress)

toAvroRackDescriptor

public static AvroRackDescriptor toAvroRackDescriptor(RackDescriptor rackDescriptor)

toAvroNodeDescriptor

public static AvroNodeDescriptor toAvroNodeDescriptor(NodeDescriptor nodeDescriptor)

toAvroEvaluatorType

public static AvroEvaluatorType toAvroEvaluatorType(EvaluatorType evaluatorType)

toAvroEvaluatorProcess

public static AvroEvaluatorProcess toAvroEvaluatorProcess(EvaluatorProcess evaluatorProcess)

toAvroEvaluatorDescriptor

public static AvroEvaluatorDescriptor toAvroEvaluatorDescriptor(EvaluatorDescriptor evaluatorDescriptor)

toAvroRuntimeStart

public static AvroRuntimeStart toAvroRuntimeStart(RuntimeStart runtimeStart)

toAvroStartTime

public static AvroStartTime toAvroStartTime(StartTime startTime)

toAvroStopTime

public static AvroStopTime toAvroStopTime(StopTime stopTime)

toAvroRuntimeStop

public static AvroRuntimeStop toAvroRuntimeStop(RuntimeStop runtimeStop)

toAvroContextBase

public static AvroContextBase toAvroContextBase(ContextBase contextBase)

toAvroActiveContext

public static AvroActiveContext toAvroActiveContext(ActiveContext activeContext)

toAvroClosedContext

public static AvroClosedContext toAvroClosedContext(ClosedContext closedContext)

toAvroFailedContext

public static AvroFailedContext toAvroFailedContext(FailedContext failedContext)

toAvroCompletedTask

public static AvroCompletedTask toAvroCompletedTask(CompletedTask completedTask)

toAvroFailedTask

public static AvroFailedTask toAvroFailedTask(FailedTask failedTask)

toAvroRunningTask

public static AvroRunningTask toAvroRunningTask(RunningTask runningTask)

toAvroTaskMessage

public static AvroTaskMessage toAvroTaskMessage(TaskMessage taskMessage)

toAvroSuspendedTask

public static AvroSuspendedTask toAvroSuspendedTask(SuspendedTask suspendedTask)

toAvroAllocatedEvaluator

public static AvroAllocatedEvaluator toAvroAllocatedEvaluator(AllocatedEvaluator allocatedEvaluator)

toAvroFailedEvaluator

public static AvroFailedEvaluator toAvroFailedEvaluator(FailedEvaluator failedEvaluator)

toAvroCompletedEvaluator

public static AvroCompletedEvaluator toAvroCompletedEvaluator(CompletedEvaluator completedEvaluator)

toString

public static String toString(org.apache.avro.specific.SpecificRecord record)