eu.slipo.athenarc.triplegeo.partitioning

Class SparkPartitioner

java.lang.Object

eu.slipo.athenarc.triplegeo.partitioning.SparkPartitioner

public class SparkPartitioner
extends java.lang.Object

Performs a transformation task using Spark, under the given configuration settings

Version:

2.0

Author:

Georgios Mandilaras

Field Summary

Fields

Modifier and Type	Field and Description
private static Classification	classification
private static Configuration	currentConfig

Constructor Summary

Constructors

Constructor and Description
SparkPartitioner(Configuration config, Classification classific, java.lang.String inFile, java.lang.String outFile, int sourceSRID, int targetSRID)

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

currentConfig

private static Configuration currentConfig

classification

private static Classification classification

Constructor Detail

SparkPartitioner

public SparkPartitioner(Configuration config,
                        Classification classific,
                        java.lang.String inFile,
                        java.lang.String outFile,
                        int sourceSRID,
                        int targetSRID)