类 BinaryOperatorAggregate<ValueType, UpdateType>

构造函数

• new BinaryOperatorAggregate<ValueType, UpdateType>(operator, initialValueFactory?): BinaryOperatorAggregate<ValueType, UpdateType>

• 类型参数

  • ValueType
  • UpdateType = ValueType

  参数

  • operator: BinaryOperator<ValueType, UpdateType>
  • 可选 initialValueFactory: (() => ValueType)
    • • (): ValueType

      • 返回 ValueType

  返回 BinaryOperatorAggregate<ValueType, UpdateType>

可选 initialValueFactory

lc_graph_name

operator

value

checkpoint

• checkpoint(): ValueType

• 返回通道当前状态的字符串表示形式。

  返回 ValueType

  抛出

  如果通道为空（尚未更新），或者不支持检查点。

fromCheckpoint

• fromCheckpoint(checkpoint?): this

• 返回一个相同的新通道，可选择从检查点初始化。可以将其视为从检查点（通道状态的“快照”）进行的“恢复”。

  参数

  • 可选 checkpoint: ValueType

  返回 this

get

• get(): ValueType

• 返回通道的当前值。

  返回 ValueType

  抛出

  如果通道为空（尚未更新）。

isAvailable

• isAvailable(): boolean

• 如果通道可用（不为空），则返回 True，否则返回 False。子类应重写此方法以提供比调用 get() 和捕获 EmptyChannelError 更高效的实现。

  返回 boolean

update

• update(values): boolean

• 使用给定的更新序列更新通道的值。序列中更新的顺序是任意的。Pregel 在每个步骤结束时会为所有通道调用此方法。如果没有更新，则使用空序列调用。

  如果更新序列无效，则引发 InvalidUpdateError。如果通道已更新，则返回 True，否则返回 False。

  参数

  • values: UpdateType[]

  返回 boolean

  抛出

  如果更新序列无效。