org.apache.sedona.viz.core

Class VisualizationPartitioner

java.lang.Object

org.apache.spark.Partitioner

org.apache.sedona.viz.core.VisualizationPartitioner

All Implemented Interfaces:

Serializable

public class VisualizationPartitioner
extends org.apache.spark.Partitioner
implements Serializable

The Class VisualizationPartitioner.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
int	partitionIntervalX The partition interval Y.
int	partitionIntervalY The partition interval Y.
int	partitionX The partition interval Y.
int	partitionY The partition interval Y.
int	resolutionX The partition interval Y.
int	resolutionY The partition interval Y.

Constructor Summary

Constructors

Constructor and Description
VisualizationPartitioner(int resolutionX, int resolutionY, int partitionX, int partitionY) Instantiates a new visualization partitioner.

Method Summary

Modifier and Type	Method and Description
scala.Tuple2<Pixel,Double>	assignPartitionID(scala.Tuple2<Pixel,Double> pixelDoubleTuple2) Assign partition ID.
List<scala.Tuple2<Pixel,Double>>	assignPartitionIDs(scala.Tuple2<Pixel,Double> pixelDoubleTuple2, int photoFilterRadius) Assign partition I ds.
static scala.Tuple2<Integer,Integer>	Calculate2DPartitionId(int resolutionX, int resolutionY, int partitionX, int partitionY, int coordinateX, int coordinateY) Calculate the 2D partition ID, in a format
static int	CalculatePartitionId(int resolutionX, int resolutionY, int partitionX, int partitionY, int coordinateX, int coordinateY) Calculate partition id.
int	getPartition(Object key)
int	numPartitions()

Methods inherited from class org.apache.spark.Partitioner

defaultPartitioner

Methods inherited from class java.lang.Object

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

Field Detail

resolutionX

public int resolutionX

The partition interval Y.

resolutionY

public int resolutionY

The partition interval Y.

partitionX

public int partitionX

The partition interval Y.

partitionY

public int partitionY

The partition interval Y.

partitionIntervalX

public int partitionIntervalX

The partition interval Y.

partitionIntervalY

public int partitionIntervalY

The partition interval Y.

Constructor Detail

VisualizationPartitioner

public VisualizationPartitioner(int resolutionX,
                                int resolutionY,
                                int partitionX,
                                int partitionY)
                         throws Exception

Instantiates a new visualization partitioner.

Parameters:

resolutionX - the resolution X

resolutionY - the resolution Y

partitionX - the partition X

partitionY - the partition Y

Throws:

Exception - the exception

Method Detail

CalculatePartitionId

public static int CalculatePartitionId(int resolutionX,
                                       int resolutionY,
                                       int partitionX,
                                       int partitionY,
                                       int coordinateX,
                                       int coordinateY)

Calculate partition id.

Parameters:

resolutionX - the resolution X

resolutionY - the resolution Y

partitionX - the partition X

partitionY - the partition Y

coordinateX - the coordinate X

coordinateY - the coordinate Y

Returns:

the int

Calculate2DPartitionId

public static scala.Tuple2<Integer,Integer> Calculate2DPartitionId(int resolutionX,
                                                                   int resolutionY,
                                                                   int partitionX,
                                                                   int partitionY,
                                                                   int coordinateX,
                                                                   int coordinateY)

Calculate the 2D partition ID, in a format

Parameters:

resolutionX -

resolutionY -

partitionX -

partitionY -

coordinateX -

coordinateY -

Returns:

getPartition

public int getPartition(Object key)

Specified by:

getPartition in class org.apache.spark.Partitioner

numPartitions

public int numPartitions()

Specified by:

numPartitions in class org.apache.spark.Partitioner

assignPartitionIDs

public List<scala.Tuple2<Pixel,Double>> assignPartitionIDs(scala.Tuple2<Pixel,Double> pixelDoubleTuple2,
                                                           int photoFilterRadius)

Assign partition I ds.

Parameters:

pixelDoubleTuple2 - the pixel double tuple 2

photoFilterRadius - the photo filter radius

Returns:

the list

assignPartitionID

public scala.Tuple2<Pixel,Double> assignPartitionID(scala.Tuple2<Pixel,Double> pixelDoubleTuple2)

Assign partition ID.

Parameters:

pixelDoubleTuple2 - the pixel double tuple 2

Returns:

the tuple 2