Uses of Interface
org.apache.nemo.runtime.executor.data.block.Block
-
Packages that use Block Package Description org.apache.nemo.runtime.executor.data org.apache.nemo.runtime.executor.data.block org.apache.nemo.runtime.executor.data.stores -
-
Uses of Block in org.apache.nemo.runtime.executor.data
Methods in org.apache.nemo.runtime.executor.data that return Block Modifier and Type Method Description Block
BlockManagerWorker. createBlock(java.lang.String blockId, DataStoreProperty.Value blockStore)
Creates a new block.Methods in org.apache.nemo.runtime.executor.data with parameters of type Block Modifier and Type Method Description void
BlockManagerWorker. writeBlock(Block block, DataStoreProperty.Value blockStore, int expectedReadTotal, DataPersistenceProperty.Value persistence)
Writes a block to a store. -
Uses of Block in org.apache.nemo.runtime.executor.data.block
Classes in org.apache.nemo.runtime.executor.data.block that implement Block Modifier and Type Class Description class
FileBlock<K extends java.io.Serializable>
This class represents a block which is stored in (local or remote) file.class
NonSerializedMemoryBlock<K extends java.io.Serializable>
This class represents a block which is stored in local memory and not serialized.class
SerializedMemoryBlock<K extends java.io.Serializable>
This class represents a block which is serialized and stored in local memory. -
Uses of Block in org.apache.nemo.runtime.executor.data.stores
Methods in org.apache.nemo.runtime.executor.data.stores that return Block Modifier and Type Method Description Block
BlockStore. createBlock(java.lang.String blockId)
Creates a new block.Block
GlusterFileStore. createBlock(java.lang.String blockId)
Block
LocalFileStore. createBlock(java.lang.String blockId)
Block
SerializedMemoryStore. createBlock(java.lang.String blockId)
Methods in org.apache.nemo.runtime.executor.data.stores that return types with arguments of type Block Modifier and Type Method Description protected java.util.Map<java.lang.String,Block>
LocalBlockStore. getBlockMap()
java.util.Optional<Block>
BlockStore. readBlock(java.lang.String blockId)
Reads a committed block from this store.java.util.Optional<Block>
GlusterFileStore. readBlock(java.lang.String blockId)
Reads a committed block from this store.java.util.Optional<Block>
LocalBlockStore. readBlock(java.lang.String blockId)
Reads a committed block from this store.Methods in org.apache.nemo.runtime.executor.data.stores with parameters of type Block Modifier and Type Method Description void
BlockStore. writeBlock(Block block)
Writes a committed block to this store.void
GlusterFileStore. writeBlock(Block block)
Writes a committed block to this store.void
LocalFileStore. writeBlock(Block block)
Writes a committed block to this store.void
MemoryStore. writeBlock(Block block)
Writes a committed block to this store.void
SerializedMemoryStore. writeBlock(Block block)
Writes a committed block to this store.
-