反馈

streaming_estimator 模块

  • 参考

由支持流式处理的转换器支持的输入的预处理类。

类

NimbusMLStreamingEstimator

基于 NimbusML 的估算器的估计器类。
StreamingEstimatorBase

可遵循流式处理范例的所有估算器的基类

所有子类都需要替代：

  1. 一个 fit() 方法，它可以接受和理解 AzureML Dataflow 对象。
  2. 一个 transform() 方法，它读入 pandas.DataFrame 对象，并生成经过转换的 pandas.DataFrame 对象

基础框架应该根据内存压力的具体情况来处理 StreamingInputType 的批处理转换。