CAPSRecords

Value Members

1. final def !=(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. def addAliases(aliasToOriginal: Map[Var, Var]): CAPSRecords

   

5. def alignWith(v: Var, targetHeader: RecordHeader): CAPSRecords

   

   Align the record header to the target header and rename the stored entity to v.

   Align the record header to the target header and rename the stored entity to v.

   It is required that the CAPSRecords instance is a scan, meaning that it must contain exactly a single entity (node or relationship) and its parts (flattened). The stored entity is renamed by this function to the argument variable v.

   v

   the variable that the aligned scan should contain

   targetHeader

   the header to align with

   returns

   a new instance of CAPSRecords aligned with the argument header

6. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

7. def cache(): CAPSRecords

   

8. implicit val caps: CAPSSession

   

9. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

10. def collect: Array[CypherMap]

    

    Definition Classes

    CAPSRecords → CypherRecords

11. lazy val columnType: Map[String, CypherType]

    

    Definition Classes

    CAPSRecords → CypherTable

12. def columns: Seq[String]

    

    Definition Classes

    CAPSRecords → CypherTable

13. def compact(implicit details: RetainedDetails): CAPSRecords

    

14. val data: DataFrame

    

15. def distinct(fields: Var*): CAPSRecords

    

16. def distinct: CAPSRecords

    

17. final def eq(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

18. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

19. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

20. def foreachPartition(f: (Iterator[CypherMap]) ⇒ Unit): Unit

    

21. final def getClass(): Class[_]

    

    Definition Classes

    AnyRef → Any

22. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

23. val header: RecordHeader

    

24. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

25. def iterator: Iterator[CypherMap]

    

    Definition Classes

    CAPSRecords → CypherRecords

26. def mapDF(f: (DataFrame) ⇒ DataFrame): CAPSRecords

    

27. final def ne(arg0: AnyRef): Boolean

    

    Definition Classes

    AnyRef

28. final def notify(): Unit

    

    Definition Classes

    AnyRef

29. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

30. def persist(storageLevel: StorageLevel): CAPSRecords

    

31. def persist(): CAPSRecords

    

32. final def printTo(stream: PrintStream)(implicit options: PrintOptions): Unit

    

    Definition Classes

    CypherPrintable

33. def removeVars(vars: Set[Var]): CAPSRecords

    

34. def renameVars(aliasToOriginal: Map[Var, Var]): CAPSRecords

    

35. def retag(replacements: Map[Int, Int]): CAPSRecords

    

36. def retagVariable(v: Var, replacements: Map[Int, Int]): CAPSRecords

    

37. def rows: Iterator[(String) ⇒ CypherValue]

    

    Definition Classes

    CAPSRecords → CypherTable

38. def select(fields: Set[Var]): CAPSRecords

    

39. def show(implicit options: PrintOptions): Unit

    

    Definition Classes

    CAPSRecords → CypherPrintable

40. def size: Long

    

    Definition Classes

    CAPSRecords → CypherTable

41. def sparkColumns: IndexedSeq[String]

    

42. final def synchronized[T0](arg0: ⇒ T0): T0

    

    Definition Classes

    AnyRef

43. def toCypherMaps: Dataset[CypherMap]

    

    Converts all values stored in this table to instances of the corresponding CypherValue class.

    Converts all values stored in this table to instances of the corresponding CypherValue class. In particular, this de-flattens, or collects, flattened entities (nodes and relationships) into compact CypherNode/CypherRelationship objects.

    All values on each row are inserted into a CypherMap object mapped to the corresponding field name.

    returns

    a dataset of CypherMaps.

44. def toDF(): DataFrame

    

45. def toLocalIterator: Iterator[CypherMap]

    

46. def toString(): String

    

    Definition Classes

    CAPSRecords → AnyRef → Any

47. def unionAll(header: RecordHeader, other: CAPSRecords): CAPSRecords

    

48. def unpersist(blocking: Boolean): CAPSRecords

    

49. def unpersist(): CAPSRecords

    

50. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

51. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

52. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )