Uses of Class
org.apache.nemo.runtime.executor.transfer.ByteInputContext
-
Packages that use ByteInputContext 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 ByteInputContext in org.apache.nemo.runtime.executor.data
Methods in org.apache.nemo.runtime.executor.data with parameters of type ByteInputContext Modifier and Type Method Description void
BlockManagerWorker. onInputContext(ByteInputContext inputContext)
Respond to a block notification by another executor.void
PipeManagerWorker. onInputContext(ByteInputContext inputContext)
-
Uses of ByteInputContext in org.apache.nemo.runtime.executor.transfer
Methods in org.apache.nemo.runtime.executor.transfer that return types with arguments of type ByteInputContext Modifier and Type Method Description java.util.concurrent.CompletableFuture<ByteInputContext>
ByteTransfer. newInputContext(java.lang.String executorId, byte[] contextDescriptor, boolean isPipe)
Initiate a transfer context to receive data.
-