Package org.apache.sedona.viz.core

Class VisualizationPartitioner

java.lang.Object

org.apache.spark.Partitioner

org.apache.sedona.viz.core.VisualizationPartitioner

All Implemented Interfaces:

Serializable, scala.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	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	Description
VisualizationPartitioner(int resolutionX, int resolutionY, int partitionX, int partitionY)	Instantiates a new visualization partitioner.

Method Summary

Modifier and Type	Method	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