IChannelProvider

Data\IHostEnvironment.cs (1)

59public interface IHostEnvironment : IChannelProvider, IProgressChannelProvider

Environment\HostEnvironmentBase.cs (1)

96internal abstract class HostEnvironmentBase<TEnv> : ChannelProviderBase, IHostEnvironmentInternal, IChannelProvider, ICancelable

API\ExperimentBase.cs (1)

42_logger = ((IChannelProvider)context).Start("AutoML");

AutoMLExperiment\AutoMLExperiment.cs (1)

70_serviceCollection.TryAddSingleton(((IChannelProvider)_context).Start(nameof(AutoMLExperiment)));

AutoMLExperiment\IMLContextManager.cs (1)

31_channel = ((IChannelProvider)mainContext).Start(channelName);

Utils\Logger.cs (1)

17_channel = ((IChannelProvider)context).Start(ChannelName);

GetNextPipelineTests.cs (2)

32TaskKind.BinaryClassification, ((IChannelProvider)context).Start("AutoMLTest")); 62var pipeline = PipelineSuggester.GetNextPipeline(context, history, columns, task, ((IChannelProvider)context).Start("AutoMLTest"));

MLContextManagerTests.cs (1)

50var channel = ((IChannelProvider)childContext).Start("childContext");

Data\IProgressChannel.cs (1)

15/// REVIEW: make <see cref="IChannelProvider"/> implement this, instead of the environment?

Data\LinkedRootCursorBase.cs (1)

30protected LinkedRootCursorBase(IChannelProvider provider, DataViewRowCursor input)

Data\LinkedRowFilterCursorBase.cs (1)

17protected LinkedRowFilterCursorBase(IChannelProvider provider, DataViewRowCursor input, DataViewSchema schema, bool[] active)

Data\LinkedRowRootCursorBase.cs (1)

23protected LinkedRowRootCursorBase(IChannelProvider provider, DataViewRowCursor input, DataViewSchema schema, bool[] active)

Data\RootCursorBase.cs (1)

38protected RootCursorBase(IChannelProvider provider)

Data\ServerChannel.cs (5)

24private readonly IChannelProvider _chp; 42private ServerChannel(IChannelProvider provider, string idenfier) 59public static ServerChannel Start(IChannelProvider provider, string identifier) 257/// channel creation methods on <see cref="IChannelProvider"/>. 264public static ServerChannel StartServerChannel(this IChannelProvider provider, string identifier)

Data\SynchronizedCursorBase.cs (1)

42protected SynchronizedCursorBase(IChannelProvider provider, DataViewRowCursor input)

Commands\DataCommand.cs (2)

109protected virtual void SendTelemetry(IChannelProvider prov) 139protected void SendTelemetryMetricCore(IChannelProvider prov, Dictionary<string, double> averageMetric)

Data\DataViewUtils.cs (8)

149public static DataViewRowCursor[] CreateSplitCursors(IChannelProvider provider, DataViewRowCursor input, int num) 256public static DataViewRowCursor ConsolidateGeneric(IChannelProvider provider, DataViewRowCursor[] inputs, int batchSize) 321public static DataViewRowCursor Consolidate(IChannelProvider provider, DataViewRowCursor[] inputs, int batchSize, ref object[] ourPools) 330private static DataViewRowCursor ConsolidateCore(IChannelProvider provider, DataViewRowCursor[] inputs, ref object[] ourPools, IChannel ch) 496public static DataViewRowCursor[] Split(IChannelProvider provider, DataViewSchema schema, DataViewRowCursor input, int cthd) 508private DataViewRowCursor[] SplitCore(IChannelProvider ch, DataViewRowCursor input, int cthd) 1027public Cursor(IChannelProvider provider, DataViewSchema schema, int[] activeToCol, int[] colToActive, 1182public SynchronousConsolidatingCursor(IChannelProvider provider, DataViewRowCursor[] cursors)

Data\SlotCursor.cs (3)

30private protected SlotCursor(IChannelProvider provider) 86public SynchronizedSlotCursor(IChannelProvider provider, SlotCursor cursor) 110public RootSlotCursor(IChannelProvider provider)

DataLoadSave\Binary\BinarySaver.cs (1)

397DataViewSchema sourceSchema, int rowsPerBlock, IChannelProvider cp, ExceptionMarshaller exMarshaller)

DataLoadSave\Text\TextLoaderParser.cs (1)

152public ParseStats(IChannelProvider provider, int cref, long maxShow = MaxShow)

DataView\ArrayDataViewBuilder.cs (1)

265public Cursor(IChannelProvider provider, DataView view, Func<int, bool> predicate, Random rand)

DataView\EmptyDataView.cs (1)

52public Cursor(IChannelProvider provider, DataViewSchema schema, IEnumerable<DataViewSchema.Column> columnsNeeded)

DataView\RowToRowMapperTransform.cs (1)

368public Cursor(IChannelProvider provider, DataViewRowCursor input, RowToRowMapperTransform parent, bool[] active)

DataView\Transposer.cs (6)

1269public Cursor(IChannelProvider provider, DataViewSlicer slicer, DataViewRowCursor input, Func<int, bool> pred, bool[] activeSplitters) 1330private static readonly FuncStaticMethodInfo1<IChannelProvider, SlotCursor, DataViewRowCursor> _getRowCursorShimCoreMethodInfo 1331= new FuncStaticMethodInfo1<IChannelProvider, SlotCursor, DataViewRowCursor>(GetRowCursorShimCore<int>); 1394public static DataViewRowCursor GetRowCursorShim(IChannelProvider provider, SlotCursor cursor) 1402private static DataViewRowCursor GetRowCursorShimCore<T>(IChannelProvider provider, SlotCursor cursor) 1534public SlotRowCursorShim(IChannelProvider provider, SlotCursor cursor)

Dirty\ChooseColumnsByIndexTransform.cs (1)

283public Cursor(IChannelProvider provider, Bindings bindings, DataViewRowCursor input, bool[] active)

Dirty\ModelParametersBase.cs (1)

78private protected static bool WarnOnOldNormalizer(ModelLoadContext ctx, Type typePredictor, IChannelProvider provider)

MLContext.cs (2)

175IChannel IChannelProvider.Start(string name) => _env.Start(name); 176IPipe<TMessage> IChannelProvider.StartPipe<TMessage>(string name) => _env.StartPipe<TMessage>(name);

Scorers\RowToRowScorerBase.cs (1)

238public Cursor(IChannelProvider provider, RowToRowScorerBase parent, DataViewRowCursor input, bool[] active, IEnumerable<DataViewSchema.Column> activeMapperColumns)

Transforms\BindingsWrappedRowCursor.cs (1)

28public BindingsWrappedRowCursor(IChannelProvider provider, DataViewRowCursor input, ColumnBindingsBase bindings)

Transforms\ColumnSelecting.cs (1)

759public Cursor(IChannelProvider provider, Mapper mapper, DataViewRowCursor input, bool[] active)

Transforms\GenerateNumberTransform.cs (1)

390public Cursor(IChannelProvider provider, Bindings bindings, DataViewRowCursor input, bool[] active)

Transforms\LabelConvertTransform.cs (1)

210public SlotCursorImpl(IChannelProvider provider, SlotCursor cursor, VectorDataViewType typeDst)

Transforms\RowShufflingTransformer.cs (2)

225public static DataViewRowCursor GetShuffledCursor(IChannelProvider provider, int poolRows, DataViewRowCursor cursor, Random rand) 502public Cursor(IChannelProvider provider, int poolRows, DataViewRowCursor input, Random rand)

Transforms\SkipTakeFilter.cs (1)

238public Cursor(IChannelProvider provider, DataViewRowCursor input, DataViewSchema schema, bool[] active, long skip, long take)

Transforms\TransformBase.cs (1)

853public Cursor(IChannelProvider provider, OneToOneTransformBase parent, DataViewRowCursor input, bool[] active)

PartitionedFileLoader.cs (1)

388public Cursor(IChannelProvider provider, PartitionedFileLoader parent, IMultiStreamSource files, IEnumerable<DataViewSchema.Column> columnsNeeded, Random rand)

OnnxConversionTest.cs (1)

804using (var conversionChannel = (mlContext as IChannelProvider).Start("ONNX conversion"))

TrainerEstimators\TreeEstimators.cs (1)

521using (var ch = (mlContext as IChannelProvider).Start("Training LightGBM..."))

SequentialTransformerBase.cs (1)

1027public Cursor(IChannelProvider provider, DataViewRowCursor input, TimeSeriesRowToRowMapperTransform parent, bool[] active)

OptionalColumnTransform.cs (1)

440public Cursor(IChannelProvider provider, Bindings bindings, DataViewRowCursor input, bool[] active)

ProduceIdTransform.cs (1)

180public Cursor(IChannelProvider provider, Bindings bindings, DataViewRowCursor input, bool active)

UngroupTransform.cs (1)

479public Cursor(IChannelProvider provider, DataViewRowCursor input, UngroupBinding schema, Func<int, bool> predicate)