Uses of Class
org.apache.nemo.runtime.executor.transfer.ByteOutputContext
-
Packages that use ByteOutputContext Package Description org.apache.nemo.runtime.executor.data org.apache.nemo.runtime.executor.transfer Responsible for transferring block content from one executor to another. -
-
Uses of ByteOutputContext in org.apache.nemo.runtime.executor.data
Methods in org.apache.nemo.runtime.executor.data with parameters of type ByteOutputContext Modifier and Type Method Description void
BlockManagerWorker. onOutputContext(ByteOutputContext outputContext)
Respond to a block request by another executor.void
PipeManagerWorker. onOutputContext(ByteOutputContext outputContext)
(SYNCHRONIZATION) Called by network threads. -
Uses of ByteOutputContext in org.apache.nemo.runtime.executor.transfer
Methods in org.apache.nemo.runtime.executor.transfer that return types with arguments of type ByteOutputContext Modifier and Type Method Description java.util.concurrent.CompletableFuture<ByteOutputContext>
ByteTransfer. newOutputContext(java.lang.String executorId, byte[] contextDescriptor, boolean isPipe)
Initiate a transfer context to send data.
-