Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MutableBlockNode ¶
type MutableBlockNode struct {
buffer.Node
TableData iface.ITableData
Meta *metadata.Block
File *dataio.TransientBlockFile
Data batch.IBatch
Flusher mb.BlockFlusher
Stale *atomic.Value
// contains filtered or unexported fields
}
func NewMutableBlockNode ¶
func NewMutableBlockNode(mgr base.INodeManager, file *dataio.TransientBlockFile, tabledata iface.ITableData, meta *metadata.Block, flusher mb.BlockFlusher, initSize uint64) *MutableBlockNode
func (*MutableBlockNode) Flush ¶
func (n *MutableBlockNode) Flush() error
func (*MutableBlockNode) GetData ¶
func (n *MutableBlockNode) GetData() batch.IBatch
func (*MutableBlockNode) GetFile ¶
func (n *MutableBlockNode) GetFile() *dataio.TransientBlockFile
func (*MutableBlockNode) GetMeta ¶
func (n *MutableBlockNode) GetMeta() *metadata.Block
func (*MutableBlockNode) SetStale ¶
func (n *MutableBlockNode) SetStale()
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.