Uses of Class
org.apache.nemo.common.exception.BlockWriteException
-
Packages that use BlockWriteException Package Description org.apache.nemo.runtime.executor.data.block org.apache.nemo.runtime.executor.data.stores -
-
Uses of BlockWriteException in org.apache.nemo.runtime.executor.data.block
Methods in org.apache.nemo.runtime.executor.data.block that throw BlockWriteException Modifier and Type Method Description void
NonSerializedMemoryBlock. commitPartitions()
Commits all un-committed partitions.void
NonSerializedMemoryBlock. write(K key, java.lang.Object element)
Writes an element to non-committed block.void
NonSerializedMemoryBlock. writePartitions(java.lang.Iterable<NonSerializedPartition<K>> partitions)
StoresNonSerializedPartition
s to this block.void
NonSerializedMemoryBlock. writeSerializedPartitions(java.lang.Iterable<SerializedPartition<K>> partitions)
StoresSerializedPartition
s to this block. -
Uses of BlockWriteException in org.apache.nemo.runtime.executor.data.stores
Methods in org.apache.nemo.runtime.executor.data.stores that throw BlockWriteException Modifier and Type Method Description Block
BlockStore. createBlock(java.lang.String blockId)
Creates a new block.void
BlockStore. writeBlock(Block block)
Writes a committed block to this store.
-