eu.slipo.athenarc.triplegeo.partitioning

Interface Partitioner

All Known Implementing Classes:

CsvPartitioner, ShpPartitioner

public interface Partitioner

Partitioning Interface for TripleGeo used in splitting input files into several equi-sized pieces for applying concurrent transformation to RDF.

Version:

2.0

Author:

Kostas Patroumpas

Method Summary

Modifier and Type	Method and Description
java.lang.String[]	split(java.lang.String filePath, java.lang.String tmpDir, int numParts) Splits an input .CSV file into a specified number of partitions.
java.lang.String[]	split(java.lang.String filePath, java.lang.String tmpDir, int numParts, java.lang.String encoding) Splits an input shapefile into a specified number of partitions.

Method Detail

split

java.lang.String[] split(java.lang.String filePath,
                         java.lang.String tmpDir,
                         int numParts)
                  throws java.io.IOException

Splits an input .CSV file into a specified number of partitions.

Parameters:

filePath - Path to the input .CSV file

tmpDir - Folder to hold the output partitions (i.e., files with the same extension)

numParts - Number of partitions to be created

Returns:

Array holding the absolute path to each of the resulting partitions

Throws:

java.io.IOException

split

java.lang.String[] split(java.lang.String filePath,
                         java.lang.String tmpDir,
                         int numParts,
                         java.lang.String encoding)
                  throws java.io.IOException

Splits an input shapefile into a specified number of partitions.

Parameters:

filePath - Path to the input shapefile

tmpDir - Folder to hold the output partitions (i.e., files with the same extension)

numParts - Number of partitions to be created

Returns:

Array holding the absolute path to each of the resulting partitions

Throws:

java.io.IOException