PartitionConsolidator

class PartitionConsolidator.PartitionConsolidator(backoffTiming='[I@5cd1a068', concurrency=1, concurrentTimeout=100.0, handlingStrategy='advanced', inputCol=None, outputCol=None)[source]

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

Parameters:
  • backoffTiming (object) – times to use in backoffs (default: [I@5cd1a068)
  • concurrency (int) – max number of concurrent calls (default: 1)
  • concurrentTimeout (double) – max number seconds to wait on futures if concurrency >= 1 (default: 100.0)
  • handlingStrategy (str) – Which strategy to use when handling requests (default: advanced)
  • inputCol (str) – The name of the input column
  • outputCol (str) – The name of the output column
getBackoffTiming()[source]
Returns:times to use in backoffs (default: [I@5cd1a068)
Return type:object
getConcurrency()[source]
Returns:max number of concurrent calls (default: 1)
Return type:int
getConcurrentTimeout()[source]
Returns:max number seconds to wait on futures if concurrency >= 1 (default: 100.0)
Return type:double
getHandlingStrategy()[source]
Returns:Which strategy to use when handling requests (default: advanced)
Return type:str
getInputCol()[source]
Returns:The name of the input column
Return type:str
static getJavaPackage()[source]

Returns package name String.

getOutputCol()[source]
Returns:The name of the output column
Return type:str
classmethod read()[source]

Returns an MLReader instance for this class.

setBackoffTiming(value)[source]
Parameters:backoffTiming (object) – times to use in backoffs (default: [I@5cd1a068)
setConcurrency(value)[source]
Parameters:concurrency (int) – max number of concurrent calls (default: 1)
setConcurrentTimeout(value)[source]
Parameters:concurrentTimeout (double) – max number seconds to wait on futures if concurrency >= 1 (default: 100.0)
setHandlingStrategy(value)[source]
Parameters:handlingStrategy (str) – Which strategy to use when handling requests (default: advanced)
setInputCol(value)[source]
Parameters:inputCol (str) – The name of the input column
setOutputCol(value)[source]
Parameters:outputCol (str) – The name of the output column
setParams(backoffTiming='[I@5cd1a068', concurrency=1, concurrentTimeout=100.0, handlingStrategy='advanced', inputCol=None, outputCol=None)[source]

Set the (keyword only) parameters

Parameters:
  • backoffTiming (object) – times to use in backoffs (default: [I@5cd1a068)
  • concurrency (int) – max number of concurrent calls (default: 1)
  • concurrentTimeout (double) – max number seconds to wait on futures if concurrency >= 1 (default: 100.0)
  • handlingStrategy (str) – Which strategy to use when handling requests (default: advanced)
  • inputCol (str) – The name of the input column
  • outputCol (str) – The name of the output column