Stream

1 write to Stream

Microsoft.ML.Core (1)

Data\Repository.cs (1)

66Stream = stream;

41 references to Stream

Microsoft.ML.Core (17)

Data\ModelLoadContext.cs (1)

87Reader = new BinaryReader(ent.Stream, Encoding.UTF8, leaveOpen: true);

Data\ModelLoading.cs (8)

93env.Assert(ent.Stream.Position == 0); 103env.Assert(ent.Stream.Position == 0); 104LoadModel<TRes, TSig>(env, out result, ent.Stream, extra); 160long fp = ent.Stream.Position; 169Contracts.Assert(fp == ent.Stream.Position); 316_ectx.Assert(ent.Stream.Position == 0); 337using (var reader = new BinaryReader(ent.Stream, Encoding.UTF8, leaveOpen: true)) 358using (var reader = new StreamReader(ent.Stream))

Data\ModelSaveContext.cs (3)

100Writer = new BinaryWriter(_ent.Stream, Encoding.UTF8, leaveOpen: true); 164using (var writer = Utils.OpenWriter(ent.Stream)) 180using (var writer = new BinaryWriter(ent.Stream, Encoding.UTF8, leaveOpen: true))

Data\ModelSaving.cs (1)

50using (var writer = new BinaryWriter(ent.Stream, Encoding.UTF8, leaveOpen: true))

Data\Repository.cs (4)

298using (var writer = Utils.OpenWriter(ent.Stream)) 344_closed.Enqueue(new KeyValuePair<string, Stream>(ent.Path, ent.Stream)); 346ent.Stream.CloseEx(); 555ent.Stream.CloseEx();

Microsoft.ML.Data (21)

Commands\TrainCommand.cs (1)

374using (var writer = Utils.OpenWriter(ent.Stream))

Model\ModelOperationsCatalog.cs (2)

134DataSaverUtils.SaveDataView(ch, saver, new EmptyDataView(_env, inputSchema), entry.Stream, keepHidden: true); 161var loader = new BinaryLoader(_env, new BinaryLoader.Arguments(), entry.Stream);

Utilities\ModelFileUtils.cs (18)

73var loader = new BinaryLoader(env, new BinaryLoader.Arguments(), entry.Stream); 81env.Assert(ent.Stream.Position == 0); 197env.Assert(ent.Stream.Position == 0); 262saver.SaveData(entry.Stream, view, Utils.GetIdentityPermutation(view.Schema.Count)); 409return _entry.Stream.CanRead; 418return _entry.Stream.CanSeek; 427return _entry.Stream.CanWrite; 436return _entry.Stream.Length; 445return _entry.Stream.Position; 451_entry.Stream.Position = value; 458Contracts.CheckValue(entry.Stream, nameof(entry.Stream)); 465_entry.Stream.Flush(); 471return _entry.Stream.Seek(offset, origin); 477_entry.Stream.SetLength(value); 483return _entry.Stream.Read(buffer, offset, count); 489_entry.Stream.Write(buffer, offset, count); 508Contracts.AssertValue(_entry.Stream);

Microsoft.ML.Ensemble (2)

PipelineEnsemble.cs (2)

474PredictorModels[i] = new PredictorModelImpl(Host, ent.Stream); 506PredictorModels[i].Save(Host, ent.Stream);

Microsoft.ML.ResultProcessor (1)

ResultProcessor.cs (1)

475using (StreamReader sr = new StreamReader(ent.Stream))