3 instantiations of Block
Microsoft.ML.Data (3)
DataLoadSave\Binary\BinarySaver.cs (3)
238toWrite.Add(new Block(compressed, block.ColumnIndex, block.BlockIndex, uncompLength), exMarshaller.Token); 608toCompress.Add(new Block(pipes[c].EndBlock(), c, blockIndex), exMarshaller.Token); 620toCompress.Add(new Block(pipes[c].EndBlock(), c, blockIndex), exMarshaller.Token);
8 references to Block
Microsoft.ML.Data (8)
DataLoadSave\Binary\BinarySaver.cs (8)
211private void CompressionWorker(BlockingCollection<Block> toCompress, BlockingCollection<Block> toWrite, int columns, OrderedWaiter waiter, 222foreach (Block block in toCompress.GetConsumingEnumerable(exMarshaller.Token)) 396private void WriteWorker(Stream stream, BlockingCollection<Block> toWrite, ColumnCodec[] activeColumns, 423foreach (Block block in toWrite.GetConsumingEnumerable(exMarshaller.Token)) 570private void FetchWorker(BlockingCollection<Block> toCompress, IDataView data, 655var toWrite = new BlockingCollection<Block>(16); 656var toCompress = new BlockingCollection<Block>(16);