public class OracleFileSplitterConfig
extends java.lang.Object
Constructor and Description |
---|
OracleFileSplitterConfig() |
Modifier and Type | Method and Description |
---|---|
long |
getBatchSizeToDebug()
The batch size to use when reporting the loading progress
|
DataLoaderListener |
getDataLoaderListener()
Returns the data loader listener associated to this configuration object
|
int |
getDOP()
Get the degree of parallelism used for data loading.
|
long |
getEdgeIDOffset()
Get the offset of the edge ID.
|
long |
getEdgeSrcMaxlines()
Get the maximum number of lines to load from the edges file.
|
long |
getEdgeSrcOffsetlines()
Get the line offset of edges.
|
static OracleFileSplitterConfig |
getInstance()
Create an OracleFileSpliterConfig with the default settings.
|
static OracleFileSplitterConfig |
getInstance(long lVertexSrcOffsetlines, long lEdgeSrcOffsetlines, long lVertexSrcMaxlines, long lEdgeSrcMaxlines, long lVertexIDOffset, long lEdgeIDOffset, int iDop, int iPartitions, int iOffset, DataLoaderListener dll)
Creates a new OracleDataLoader config object .
|
int |
getPartitionsOffset()
Get the offset of the partition (i.e.
|
int |
getTotalPartitions()
Get the total number of partitions (i.e.
|
long |
getVertexIDOffset()
Get the offset of the vertex ID.
|
long |
getVertexSrcMaxlines()
Get the maximum number of lines to load from the vertices file.
|
long |
getVertexSrcOffsetlines()
Get the line offset of vertices.
|
void |
setBatchSizeToDebug(long size)
Set the batch size to show debug information
|
void |
setDataLoaderListener(DataLoaderListener dll)
Set the data loader listener associated to this configuration object
|
void |
setDOP(int iDop)
Set the degree of parallelism used for data loading.
|
void |
setEdgeIDOffset(long lEdgeIDOffset)
Set the offset of the edge ID.
|
void |
setEdgeSrcMaxlines(long lSrcMaxlines)
Set the maximum number of lines to load from the edges file.
|
void |
setEdgeSrcOffsetlines(long lSrcOffsetlines)
Set the line offset of edges.
|
void |
setPartitionsOffset(int iOffset)
Set the offset of the partition (i.e.
|
void |
setTotalPartitions(int iPartitions)
Set the total number of partitions (i.e.
|
void |
setVertexIDOffset(long lVertexIDOffset)
Set the offset of the vertex ID.
|
void |
setVertexSrcMaxlines(long lSrcMaxlines)
Set the maximum number of lines to load from the vertices file.
|
void |
setVertexSrcOffsetlines(long lSrcOffsetlines)
Set the line offset of vertices.
|
public long getBatchSizeToDebug()
public DataLoaderListener getDataLoaderListener()
DataLoaderListener
object.public int getDOP()
public long getEdgeIDOffset()
public long getEdgeSrcMaxlines()
public long getEdgeSrcOffsetlines()
public static OracleFileSplitterConfig getInstance()
public static OracleFileSplitterConfig getInstance(long lVertexSrcOffsetlines, long lEdgeSrcOffsetlines, long lVertexSrcMaxlines, long lEdgeSrcMaxlines, long lVertexIDOffset, long lEdgeIDOffset, int iDop, int iPartitions, int iOffset, DataLoaderListener dll)
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 0lEdgeIDOffset
- the offset of edge ID. That is, the edge ID would be edgeID+lEdgeIDOffset. Default is 0iDop
- 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-1dll
- a DataLoaderListener
object.public int getPartitionsOffset()
public int getTotalPartitions()
public long getVertexIDOffset()
public long getVertexSrcMaxlines()
public long getVertexSrcOffsetlines()
public void setBatchSizeToDebug(long size)
size
- the batch size that has a default value of 10000public void setDataLoaderListener(DataLoaderListener dll)
dll
- a DataLoaderListener
object.public void setDOP(int iDop)
iDop
- the degree of parallelism for data loadingpublic void setEdgeIDOffset(long lEdgeIDOffset)
lEdgeIDOffset
- the offset for edges IDspublic void setEdgeSrcMaxlines(long lSrcMaxlines)
lSrcMaxlines
- the maximum number of lines to load from the edges filepublic void setEdgeSrcOffsetlines(long lSrcOffsetlines)
lSrcOffsetlines
- the line offset of vertices. Loading edges after the offset. Default is 0.public void setPartitionsOffset(int iOffset)
iOffset
- the offset of the partitions.public void setTotalPartitions(int iPartitions)
iPartitions
- the total number of partitionspublic void setVertexIDOffset(long lVertexIDOffset)
lVertexIDOffset
- the offset for vertices IDspublic void setVertexSrcMaxlines(long lSrcMaxlines)
lSrcMaxlines
- the maximum number of lines to load from the vertices filepublic void setVertexSrcOffsetlines(long lSrcOffsetlines)
lSrcOffsetlines
- the line offset of vertices. Loading vertices after the offset. Default is 0.Copyright © 2017, 2018 Oracle and/or its affiliates. All Rights Reserved.