TimeIntervalMiniBatchTransformer

class TimeIntervalMiniBatchTransformer.TimeIntervalMiniBatchTransformer(maxBatchSize=2147483647, millisToWait=None)[source]

Bases: mmlspark.Utils.ComplexParamsMixin, pyspark.ml.util.JavaMLReadable, pyspark.ml.util.JavaMLWritable, pyspark.ml.wrapper.JavaTransformer

Parameters:
  • maxBatchSize (int) – The max size of the buffer (default: 2147483647)
  • millisToWait (int) – The time to wait before constructing a batch
static getJavaPackage()[source]

Returns package name String.

getMaxBatchSize()[source]
Returns:The max size of the buffer (default: 2147483647)
Return type:int
getMillisToWait()[source]
Returns:The time to wait before constructing a batch
Return type:int
classmethod read()[source]

Returns an MLReader instance for this class.

setMaxBatchSize(value)[source]
Parameters:maxBatchSize (int) – The max size of the buffer (default: 2147483647)
setMillisToWait(value)[source]
Parameters:millisToWait (int) – The time to wait before constructing a batch
setParams(maxBatchSize=2147483647, millisToWait=None)[source]

Set the (keyword only) parameters

Parameters:
  • maxBatchSize (int) – The max size of the buffer (default: 2147483647)
  • millisToWait (int) – The time to wait before constructing a batch