Class

org.opencypher.spark.api.io.csv.hdfs

HdfsCsvGraphDataSource

Related Doc: package hdfs

Permalink

case class HdfsCsvGraphDataSource(hadoopConfig: Configuration, rootPath: String)(implicit session: CAPSSession) extends CAPSPropertyGraphDataSource with Product with Serializable

Data source for loading graphs from HDFS.

hadoopConfig

Hadoop configuration

rootPath

root path containing one ore more graphs

Linear Supertypes
Serializable, Serializable, Product, Equals, CAPSPropertyGraphDataSource, PropertyGraphDataSource, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. HdfsCsvGraphDataSource
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. CAPSPropertyGraphDataSource
  7. PropertyGraphDataSource
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new HdfsCsvGraphDataSource(hadoopConfig: Configuration, rootPath: String)(implicit session: CAPSSession)

    Permalink

    hadoopConfig

    Hadoop configuration

    rootPath

    root path containing one ore more graphs

Value Members

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

    Permalink
    Definition Classes
    AnyRef → Any

  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any

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

    Permalink
    Definition Classes
    AnyRef → Any

  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any

  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  6. def delete(name: GraphName): Unit

    Permalink
    Definition Classes
    HdfsCsvGraphDataSource → PropertyGraphDataSource

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

    Permalink
    Definition Classes
    AnyRef

  8. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

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

    Permalink
    Definition Classes
    AnyRef → Any

  10. def graph(name: GraphName): PropertyGraph

    Permalink
    Definition Classes
    HdfsCsvGraphDataSource → PropertyGraphDataSource

  11. def graphNames: Set[GraphName]

    Permalink
    Definition Classes
    HdfsCsvGraphDataSource → PropertyGraphDataSource

  12. val hadoopConfig: Configuration

    Permalink

    Hadoop configuration

  13. def hasGraph(name: GraphName): Boolean

    Permalink
    Definition Classes
    HdfsCsvGraphDataSource → PropertyGraphDataSource

  14. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any

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

    Permalink
    Definition Classes
    AnyRef

  16. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef

  17. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef

  18. val rootPath: String

    Permalink

    root path containing one ore more graphs

  19. def schema(name: GraphName): Option[Schema]

    Permalink
    Definition Classes
    HdfsCsvGraphDataSource → PropertyGraphDataSource

  20. implicit val session: CAPSSession

    Permalink

  21. def store(name: GraphName, graph: PropertyGraph): Unit

    Permalink
    Definition Classes
    HdfsCsvGraphDataSource → PropertyGraphDataSource

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

    Permalink
    Definition Classes
    AnyRef

  23. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

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

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from CAPSPropertyGraphDataSource

Inherited from PropertyGraphDataSource

Inherited from AnyRef

Inherited from Any

Ungrouped