Class/Object

org.opencypher.spark.impl.io.hdfs

CsvGraphLoader

Related Docs: object CsvGraphLoader | package hdfs

Permalink

class CsvGraphLoader extends AnyRef

Loads a graph stored in indexed CSV format from HDFS or the local file system The CSV files must be stored following this schema: # Nodes

all files describing nodes are stored in a subfolder called "nodes"
create one file for each possible label combination that exists in the data, i.e. there must not be overlapping entities in different files (e.g. all nodes with labels :Person:Employee in a single file and all nodes that have label :Person exclusively in another file)
for every node csv file create a schema file called FILE_NAME.csv.SCHEMA
for information about the structure of the node schema file see CsvNodeSchema # Relationships
all files describing relationships are stored in a subfolder called "relationships"
create one csv file per relationship type
for every relationship csv file create a schema file called FILE_NAME.csv.SCHEMA
for information about the structure of the relationship schema file see CsvRelSchema

Linear Supertypes

AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

CsvGraphLoader
AnyRef
Any

Hide All
Show All

Visibility

Public
All

Instance Constructors

new CsvGraphLoader(fileHandler: CsvFileHandler)(implicit capsSession: CAPSSession)

fileHandler
CsvGraphLoaderFileHandler file handler for hdfs or local file system
capsSession
CAPS Session

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def load: PropertyGraph
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped