c

org.graphframes.lib

三角形计数

TriangleCount 继承自 Arguments 并实现 SerializableWithIntermediateStorageLevel

计算通过每个顶点的三角形数量。

该算法忽略边的方向;即所有边都被视为无向边。在多图中,重复的边将仅被计数一次。

**警告** 此实现基于邻接集合的交集运算,需要为每条边同时收集源节点和目标节点的邻接关系!当图中包含极高度数节点(幂律网络)时,这将导致内存爆炸!针对这种情况请考虑采用采样策略!

返回的DataFrame包含所有原始顶点信息和一个额外的列:

  • count (LongType): the count of triangles
Linear Supertypes
带中间存储级别, 日志记录, 可序列化, 参数, 任意引用, 任意类型
Ordering
  1. 按字母顺序
  2. 按继承关系
Inherited
  1. TriangleCount
  2. WithIntermediateStorageLevel
  3. 日志记录
  4. 可序列化
  5. 参数
  6. AnyRef
  7. 任意
Implicitly
  1. 由 any2stringadd
  2. 由 StringFormat 提供
  3. 通过确保
  4. 由 ArrowAssoc 提供
  1. 隐藏全部
  2. 显示全部
Visibility
  1. 公开
  2. 受保护

值成员

  1. final def !=(arg0: 任意): 布尔值
    定义类
    AnyRef → Any
  2. final def ##: 整数
    定义类
    AnyRef → Any
  3. def +(other: String): String
    隐式
    该成员通过从 TriangleCountany2stringadd[TriangleCount] 的隐式转换添加,该转换由 scala.Predef 中的 any2stringadd 方法执行。
    定义类
    任意转字符串加法
  4. def ->[B](y: B): (TriangleCount, B)
    隐式
    该成员通过从 TriangleCountArrowAssoc[TriangleCount] 的隐式转换添加,该转换由 scala.Predef 中的 ArrowAssoc 方法执行。
    定义类
    ArrowAssoc
    注解
    @inline()
  5. final def ==(arg0: 任意): 布尔值
    定义类
    AnyRef → Any
  6. final def asInstanceOf[T0]: T0
    定义类
    任意
  7. def clone(): AnyRef
    属性
    protected[lang]
    定义类
    AnyRef
    注解
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  8. def ensuring(cond: (TriangleCount) => 布尔值, msg: => 任意): TriangleCount
    隐式
    该成员通过从 TriangleCountEnsuring[TriangleCount] 的隐式转换添加,该转换由 scala.Predef 中的 Ensuring 方法执行。
    定义类
    确保
  9. def ensuring(cond: (TriangleCount) => 布尔值): TriangleCount
    隐式
    该成员通过从 TriangleCountEnsuring[TriangleCount] 的隐式转换添加,该转换由 scala.Predef 中的 Ensuring 方法执行。
    定义类
    确保
  10. def ensuring(cond: 布尔值, msg: => 任意): TriangleCount
    隐式
    该成员通过从 TriangleCountEnsuring[TriangleCount] 的隐式转换添加,该转换由 scala.Predef 中的 Ensuring 方法执行。
    定义类
    确保
  11. def ensuring(cond: 布尔值): TriangleCount
    隐式
    该成员通过从 TriangleCountEnsuring[TriangleCount] 的隐式转换添加,该转换由 scala.Predef 中的 Ensuring 方法执行。
    定义类
    确保
  12. final def eq(arg0: AnyRef): 布尔值
    定义类
    AnyRef
  13. def equals(arg0: AnyRef): 布尔值
    定义类
    AnyRef → Any
  14. final def getClass(): [_ <: AnyRef]
    定义类
    AnyRef → Any
    注解
    @IntrinsicCandidate() @native()
  15. def getIntermediateStorageLevel: StorageLevel

    获取需要多次传递的中间数据集的存储级别。

    获取需要多次传递的中间数据集的存储级别。

    定义类
    WithIntermediateStorageLevel
  16. def hashCode(): 整数
    定义类
    AnyRef → Any
    注解
    @IntrinsicCandidate() @native()
  17. val intermediateStorageLevel: StorageLevel
    属性
    受保护的
    定义类
    WithIntermediateStorageLevel
  18. final def isInstanceOf[T0]: 布尔值
    定义类
    任意
  19. def logDebug(s: => String): 单元
    属性
    受保护的
    定义类
    日志记录
  20. def logInfo(s: => String): 单元
    属性
    受保护的
    定义类
    日志记录
  21. def logTrace(s: => String): 单元
    属性
    受保护的
    定义类
    日志记录
  22. def logWarn(s: => String): 单元
    属性
    受保护的
    定义类
    日志记录
  23. final def ne(arg0: AnyRef): 布尔值
    定义类
    AnyRef
  24. final def notify(): 单元
    定义类
    AnyRef
    注解
    @IntrinsicCandidate() @native()
  25. final def notifyAll(): 单元
    定义类
    AnyRef
    注解
    @IntrinsicCandidate() @native()
  26. def resultIsPersistent(): 单元
    属性
    受保护的
    定义类
    日志记录
  27. def run(): DataFrame
  28. def setIntermediateStorageLevel(value: StorageLevel): TriangleCount.this.type

    Sets storage level for intermediate datasets that require multiple passes (default: MEMORY_AND_DISK).

    Sets storage level for intermediate datasets that require multiple passes (default: MEMORY_AND_DISK).

    定义类
    WithIntermediateStorageLevel
  29. final def synchronized[T0](arg0: => T0): T0
    定义类
    AnyRef
  30. def toString(): 字符串
    定义类
    AnyRef → Any
  31. final def wait(arg0: 长整型, arg1: 整数): 单元
    定义类
    AnyRef
    注解
    @throws(classOf[java.lang.InterruptedException])
  32. final def wait(arg0: 长整型): 单元
    定义类
    AnyRef
    注解
    @throws(classOf[java.lang.InterruptedException]) @native()
  33. final def wait(): 单元
    定义类
    AnyRef
    注解
    @throws(classOf[java.lang.InterruptedException])

已弃用的值成员

  1. def finalize(): 单元
    属性
    protected[lang]
    定义类
    AnyRef
    注解
    @throws(classOf[java.lang.Throwable]) @Deprecated
    已弃用

    (自版本 9 起)

  2. def formatted(fmtstr: String): String
    隐式
    该成员通过从 TriangleCountStringFormat[TriangleCount] 的隐式转换添加,该转换由 scala.Predef 中的 StringFormat 方法执行。
    定义类
    StringFormat
    注解
    @deprecated @inline()
    已弃用

    (Since version 2.12.16) Use formatString.format(value) instead of value.formatted(formatString), or use the f"" string interpolator. In Java 15 and later, formatted resolves to the new method in String which has reversed parameters.

  3. def [B](y: B): (TriangleCount, B)
    隐式
    该成员通过从 TriangleCountArrowAssoc[TriangleCount] 的隐式转换添加,该转换由 scala.Predef 中的 ArrowAssoc 方法执行。
    定义类
    ArrowAssoc
    注解
    @deprecated
    已弃用

    (Since version 2.13.0) Use -> instead. If you still wish to display it as one character, consider using a font with programming ligatures such as Fira Code.

Inherited from WithIntermediateStorageLevel

Inherited from Logging

Inherited from Serializable

Inherited from Arguments

Inherited from AnyRef

Inherited from Any

通过隐式转换 any2stringadd 从三角形计数继承至any2stringadd[三角形计数]

通过隐式转换 StringFormat 从TriangleCount 继承至 StringFormat[TriangleCount]

通过隐式转换 Ensuring 从三角形计数继承至 确保[三角形计数]

通过隐式转换 ArrowAssoc 从三角形计数继承至 ArrowAssoc[三角形计数]

未分组