trait VowpalWabbitSyncSchedule extends Serializable

Defines when VW needs to synchronize across partitions.

Linear Supertypes
Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. VowpalWabbitSyncSchedule
  2. Serializable
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def shouldTriggerAllReduce(row: Row): Boolean

    Implementations must guarantee to trigger the same number of times across all partitions.

    Implementations must guarantee to trigger the same number of times across all partitions.

    row

    passed in to enable content passed schedules (e.g. temporal)

    returns

    True if this partition needs to synchronize, false otherwise.