oracle.pg.common

Class OracleDataLoaderConfigBase

java.lang.Object

oracle.pg.common.OracleFileSplitterConfig

oracle.pg.common.OracleDataLoaderConfigBase

Direct Known Subclasses:

OracleDataLoaderConfig

public class OracleDataLoaderConfigBase
extends OracleFileSplitterConfig

This class specifies the configuration settings used for Parallel data loading tasks including degree of parallelism, ID offsets, partitions, among others.

Constructor Summary

Constructors

Constructor and Description
OracleDataLoaderConfigBase()

Method Summary

Modifier and Type	Method and Description
int	getBatchSize() Get the batch size of Oracle update in batching mode for JDBC-based loading.
long	getBatchSizeToDebug() The batch size to use when reporting the loading progress
static OracleDataLoaderConfigBase	getInstance(long lVertexSrcOffsetlines, long lEdgeSrcOffsetlines, long lVertexSrcMaxlines, long lEdgeSrcMaxlines, long lVertexIDOffset, long lEdgeIDOffset, int iDop, int iPartitions, int iOffset, int batchSize, DataLoaderListener dll) Creates a new OracleDataLoader config object .
boolean	isSkipGhostVerticesOn() Specifies if edges with ghost vertices (vertices not defined in the graph) should not be loaded
void	setBatchSize(int batchSize) Set the batch size used in the data loader
void	setSkipGhostVertices(boolean skip) Specifies if edges with ghost vertices (vertices not defined in the graph) should not be loaded

Methods inherited from class oracle.pg.common.OracleFileSplitterConfig

getDataLoaderListener, getDOP, getEdgeIDOffset, getEdgeSrcMaxlines, getEdgeSrcOffsetlines, getInstance, getInstance, getPartitionsOffset, getTotalPartitions, getVertexIDOffset, getVertexSrcMaxlines, getVertexSrcOffsetlines, setBatchSizeToDebug, setDataLoaderListener, setDOP, setEdgeIDOffset, setEdgeSrcMaxlines, setEdgeSrcOffsetlines, setPartitionsOffset, setTotalPartitions, setVertexIDOffset, setVertexSrcMaxlines, setVertexSrcOffsetlines

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OracleDataLoaderConfigBase

public OracleDataLoaderConfigBase()

Method Detail

getBatchSize

public int getBatchSize()

Get the batch size of Oracle update in batching mode for JDBC-based loading. Default value is 1000.

Returns:

the batch size of Oracle update in batching mode for JDBC-based loading.

getBatchSizeToDebug

public long getBatchSizeToDebug()

Description copied from class: OracleFileSplitterConfig

The batch size to use when reporting the loading progress

Overrides:

getBatchSizeToDebug in class OracleFileSplitterConfig

getInstance

public static OracleDataLoaderConfigBase getInstance(long lVertexSrcOffsetlines,
                                                     long lEdgeSrcOffsetlines,
                                                     long lVertexSrcMaxlines,
                                                     long lEdgeSrcMaxlines,
                                                     long lVertexIDOffset,
                                                     long lEdgeIDOffset,
                                                     int iDop,
                                                     int iPartitions,
                                                     int iOffset,
                                                     int batchSize,
                                                     DataLoaderListener dll)

Creates a new OracleDataLoader config object .

Parameters:

lVertexSrcOffsetlines - the line offset of vertices. Loading vertices after the offset. Default is 0.

lEdgeSrcOffsetlines - the line offset of edges. Loading edges after the offset. Default is 0.

lVertexSrcMaxlines - the max lines of vertices to be loaded. Default is -1 (i.e., load all vertices)

lEdgeSrcMaxlines - the max lines of edges to be loaded. Default is -1 (i.e., load all edges)

lVertexIDOffset - the offset of vertex ID. That is, the vertex ID would be vertexID+lVertexIDOffset. Default is 0

lEdgeIDOffset - the offset of edge ID. That is, the edge ID would be edgeID+lEdgeIDOffset. Default is 0

iDop - degree of parallelism. It has to be a positive integer.

iPartitions - number of partitions (i.e., data loading clients)

iOffset - offset of partitions. It is from 0 to iPartitions-1

dll - a DataLoaderListener object.

isSkipGhostVerticesOn

public boolean isSkipGhostVerticesOn()

Specifies if edges with ghost vertices (vertices not defined in the graph) should not be loaded

Returns:

if true then edges with ghost vertices (vertices that do not already exist in the graph) will be skipped.

setBatchSize

public void setBatchSize(int batchSize)

Set the batch size used in the data loader

Parameters:

batchSize - the batch size of Oracle update in batching mode for JDBC-based loading. Default value is 1000.

setSkipGhostVertices

public void setSkipGhostVertices(boolean skip)

Specifies if edges with ghost vertices (vertices not defined in the graph) should not be loaded

Parameters:

skip - if true then edges with ghost vertices (vertices that do not already exist in the graph) will be skipped.