Package com.alibaba.graphscope.loader.impl

Class FileLoader

java.lang.Object

com.alibaba.graphscope.loader.impl.FileLoader

All Implemented Interfaces:

LoaderBase

public class FileLoader
extends Object
implements LoaderBase

Load from a file on system.

Nested Class Summary

Nested classes/interfaces inherited from interface com.alibaba.graphscope.loader.LoaderBase

LoaderBase.TYPE

Constructor Summary

Constructors

Constructor	Description
FileLoader(int id, URLClassLoader classLoader)

Method Summary

Modifier and Type	Method	Description
int	concurrency()
static FileLoader	create(URLClassLoader cl)
void	init(int workerId, int workerNum, int threadNum, FFIByteVecVector vidBuffers, FFIByteVecVector vertexDataBuffers, FFIByteVecVector edgeSrcIdBuffers, FFIByteVecVector edgeDstIdBuffers, FFIByteVecVector edgeDataBuffers, FFIIntVecVector vidOffsets, FFIIntVecVector vertexDataOffsets, FFIIntVecVector edgeSrcIdOffsets, FFIIntVecVector edgeDstIdOffsets, FFIIntVecVector edgeDataOffsets)
void	loadEdges(String inputPath, String eformatClass)
LoaderBase.TYPE	loaderType()
int	loadVerticesAndEdges(String inputPath, String vformatClass)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FileLoader

public FileLoader(int id,
                  URLClassLoader classLoader)

Method Detail

create

public static FileLoader create(URLClassLoader cl)

init

public void init(int workerId,
                 int workerNum,
                 int threadNum,
                 FFIByteVecVector vidBuffers,
                 FFIByteVecVector vertexDataBuffers,
                 FFIByteVecVector edgeSrcIdBuffers,
                 FFIByteVecVector edgeDstIdBuffers,
                 FFIByteVecVector edgeDataBuffers,
                 FFIIntVecVector vidOffsets,
                 FFIIntVecVector vertexDataOffsets,
                 FFIIntVecVector edgeSrcIdOffsets,
                 FFIIntVecVector edgeDstIdOffsets,
                 FFIIntVecVector edgeDataOffsets)

loadVerticesAndEdges

public int loadVerticesAndEdges(String inputPath,
                                String vformatClass)
                         throws ExecutionException,
                                InterruptedException,
                                ClassNotFoundException

Parameters:

inputPath -

Returns:

Return an integer contains type params info.

Throws:

ExecutionException

InterruptedException

ClassNotFoundException

loadEdges

public void loadEdges(String inputPath,
                      String eformatClass)
               throws ExecutionException,
                      InterruptedException,
                      ClassNotFoundException

Throws:

ExecutionException

InterruptedException

ClassNotFoundException

loaderType

public LoaderBase.TYPE loaderType()

Specified by:

loaderType in interface LoaderBase

concurrency

public int concurrency()

Specified by:

concurrency in interface LoaderBase

toString

public String toString()

Overrides:

toString in class Object