Class FederatedWorkerHandler
- java.lang.Object
- 
- io.netty.channel.ChannelHandlerAdapter
- 
- io.netty.channel.ChannelInboundHandlerAdapter
- 
- org.apache.sysds.runtime.controlprogram.federated.FederatedWorkerHandler
 
 
 
- 
- All Implemented Interfaces:
- io.netty.channel.ChannelHandler,- io.netty.channel.ChannelInboundHandler
 
 public class FederatedWorkerHandler extends io.netty.channel.ChannelInboundHandlerAdapterNote: federated worker handler created for every command; and concurrent parfor threads at coordinator need separate execution contexts at the federated sites too
- 
- 
Constructor SummaryConstructors Constructor Description FederatedWorkerHandler(FederatedLookupTable flt, FederatedReadCache frc, FederatedWorkloadAnalyzer fan)Create a Federated Worker Handler.FederatedWorkerHandler(FederatedLookupTable flt, FederatedReadCache frc, FederatedWorkloadAnalyzer fan, Timing timing)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description voidchannelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)voidexceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)- 
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapterchannelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
 - 
Methods inherited from class io.netty.channel.ChannelHandlerAdapterhandlerAdded, handlerRemoved, isSharable
 
- 
 
- 
- 
- 
Constructor Detail- 
FederatedWorkerHandlerpublic FederatedWorkerHandler(FederatedLookupTable flt, FederatedReadCache frc, FederatedWorkloadAnalyzer fan) Create a Federated Worker Handler. Note: federated worker handler created for every command; and concurrent parfor threads at coordinator need separate execution contexts at the federated sites too- Parameters:
- flt- The Federated Lookup Table of the current Federated Worker.
- frc- Read cache shared by all worker handlers.
- fan- A Workload analyzer object (should be null if not used).
 
 - 
FederatedWorkerHandlerpublic FederatedWorkerHandler(FederatedLookupTable flt, FederatedReadCache frc, FederatedWorkloadAnalyzer fan, Timing timing) 
 
- 
 - 
Method Detail- 
channelReadpublic void channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)- Specified by:
- channelReadin interface- io.netty.channel.ChannelInboundHandler
- Overrides:
- channelReadin class- io.netty.channel.ChannelInboundHandlerAdapter
 
 - 
exceptionCaughtpublic void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)- Specified by:
- exceptionCaughtin interface- io.netty.channel.ChannelHandler
- Specified by:
- exceptionCaughtin interface- io.netty.channel.ChannelInboundHandler
- Overrides:
- exceptionCaughtin class- io.netty.channel.ChannelInboundHandlerAdapter
 
 
- 
 
-