public final class WatcherAvroUtil extends Object
public static AvroFailure toAvroFailure(Failure failure)
public static AvroNodeDescriptorInRackDescriptor toAvroNodeDescriptorInRackDescriptor(String id, String name, InetSocketAddress inetSocketAddress)
public static AvroRackDescriptor toAvroRackDescriptor(RackDescriptor rackDescriptor)
public static AvroNodeDescriptor toAvroNodeDescriptor(NodeDescriptor nodeDescriptor)
public static AvroEvaluatorType toAvroEvaluatorType(EvaluatorType evaluatorType)
public static AvroEvaluatorProcess toAvroEvaluatorProcess(EvaluatorProcess evaluatorProcess)
public static AvroEvaluatorDescriptor toAvroEvaluatorDescriptor(EvaluatorDescriptor evaluatorDescriptor)
public static AvroRuntimeStart toAvroRuntimeStart(RuntimeStart runtimeStart)
public static AvroStartTime toAvroStartTime(StartTime startTime)
public static AvroStopTime toAvroStopTime(StopTime stopTime)
public static AvroRuntimeStop toAvroRuntimeStop(RuntimeStop runtimeStop)
public static AvroContextBase toAvroContextBase(ContextBase contextBase)
public static AvroActiveContext toAvroActiveContext(ActiveContext activeContext)
public static AvroClosedContext toAvroClosedContext(ClosedContext closedContext)
public static AvroFailedContext toAvroFailedContext(FailedContext failedContext)
public static AvroCompletedTask toAvroCompletedTask(CompletedTask completedTask)
public static AvroFailedTask toAvroFailedTask(FailedTask failedTask)
public static AvroRunningTask toAvroRunningTask(RunningTask runningTask)
public static AvroTaskMessage toAvroTaskMessage(TaskMessage taskMessage)
public static AvroSuspendedTask toAvroSuspendedTask(SuspendedTask suspendedTask)
public static AvroAllocatedEvaluator toAvroAllocatedEvaluator(AllocatedEvaluator allocatedEvaluator)
public static AvroFailedEvaluator toAvroFailedEvaluator(FailedEvaluator failedEvaluator)
public static AvroCompletedEvaluator toAvroCompletedEvaluator(CompletedEvaluator completedEvaluator)
Copyright © 2017 The Apache Software Foundation. All rights reserved.