Skip to content

Commit

Permalink
Add documentation and python tests
Browse files Browse the repository at this point in the history
  • Loading branch information
Kontinuation committed Nov 11, 2024
1 parent 5b2e282 commit 3d2ba62
Show file tree
Hide file tree
Showing 12 changed files with 351 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,12 @@ public static DiagonalParameter create(Map<String, String> conf) {
PointBasedParameter pointBasedParameter = PointBasedParameter.create(conf);
double percentage = Double.parseDouble(conf.getOrDefault("percentage", "0.5"));
double buffer = Double.parseDouble(conf.getOrDefault("buffer", "0.5"));
if (percentage < 0 || percentage > 1) {
throw new IllegalArgumentException("Percentage must be between 0 and 1");
}
if (buffer < 0) {
throw new IllegalArgumentException("Buffer must be a non-negative number");
}
return new DiagonalParameter(pointBasedParameter, percentage, buffer);
}
}
Expand Down
271 changes: 271 additions & 0 deletions docs/api/sql/Spider.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,271 @@
Sedona offers a spatial data generator called Spider. It is a data source that generates random spatial data based on the user-specified parameters.

## Quick Start

Once you have your [`SedonaContext` object created](../Overview#quick-start), you can create a DataFrame with the `spider` data source.

```python
df_random_points = sedona.read.format("spider").load(n=1000, distribution='uniform')
df_random_boxes = sedona.read.format("spider").load(n=1000, distribution='gaussian', geometryType='box', maxWidth=0.05, maxHeight=0.05)
df_random_polygons = sedona.read.format("spider").load(n=1000, distribution='bit', geometryType='polygon', minSegment=3, maxSegment=5, maxSize=0.1)
```

Now we have three DataFrames with random spatial data. We can show the first three rows of the `df_random_points` DataFrame to verify the data is generated correctly.

```python
df_random_points.show(3, False)
```

Output:

```
+---+---------------------------------------------+
|id |geometry |
+---+---------------------------------------------+
|1 |POINT (0.8781393502074886 0.5925787985028703)|
|2 |POINT (0.3159498147172185 0.1907316577342276)|
|3 |POINT (0.2618294441170143 0.3623164670133922)|
+---+---------------------------------------------+
only showing top 3 rows
```

The generated DataFrame has two columns: `id` and `geometry`. The `id` column is the unique identifier of each record, and the `geometry` column is the randomly generated spatial data.

We can plot all 3 DataFrames using the following code.

```python
import matplotlib.pyplot as plt
import geopandas as gpd

# Convert DataFrames to GeoDataFrames
gdf_random_points = gpd.GeoDataFrame(df_random_points.toPandas(), geometry='geometry')
gdf_random_boxes = gpd.GeoDataFrame(df_random_boxes.toPandas(), geometry='geometry')
gdf_random_polygons = gpd.GeoDataFrame(df_random_polygons.toPandas(), geometry='geometry')

# Create a figure and a set of subplots
fig, axes = plt.subplots(1, 3, figsize=(15, 5))

# Plot each GeoDataFrame on a different subplot
gdf_random_points.plot(ax=axes[0], color='blue', markersize=5)
axes[0].set_title('Random Points')

gdf_random_boxes.boundary.plot(ax=axes[1], color='red')
axes[1].set_title('Random Boxes')

gdf_random_polygons.boundary.plot(ax=axes[2], color='green')
axes[2].set_title('Random Polygons')

# Adjust the layout
plt.tight_layout()

# Show the plot
plt.show()
```

Output:

![Random Spatial Data](../../image/spider/spider-quickstart.png)

You can browse the [SpiderWeb](https://spider.cs.ucr.edu/) website to play with the parameters and see how they affect the generated data. Once you are satisfied with the parameters, you can use them in your Spider DataFrame creation code. The following sections will explain the parameters in detail.

## Common Parameters

The following parameters are common to all distributions.

| Parameter | Description | Default Value |
| --------- | ----------- | ------------- |
| n | Number of records to generate | 100 |
| distribution | Distribution type. See [Distributions](#distributions) for details. | `uniform` |
| numPartitions | Number of partitions to generate | The default parallelism of your Spark Context |
| seed | Random seed | Current timestamp in milliseconds |

!!! warning
The same `seed` parameter may produce different results with different Java versions or Sedona versions.

## Distributions

Spider supports generating random points, boxes and polygons under various distributions. You can explore the capabilities of Spider by visiting the [SpiderWeb](https://spider.cs.ucr.edu/) website. You can specify the distribution type using the `distribution` parameter. The parameters for each distribution are listed below.

### Uniform Distribution

The uniform distribution generates random geometries in the unit square `[0, 1] x [0, 1]`. This distribution can be selected by setting the `distribution` parameter to `uniform`.

| Parameter | Description | Default Value |
| --------- | ----------- | ------------- |
| geometryType | Geometry type, either `point`, `box` or `polygon` | `point` |
| maxWidth | Maximum width of the generated boxes | 0.01 |
| maxHeight | Maximum height of the generated boxes | 0.01 |
| minSegment | Minimum number of segments of the generated polygons | 3 |
| maxSegment | Maximum number of segments of the generated polygons | 3 |
| maxSize | Maximum size of the generated polygons | 0.01 |

Example:

```python
import geopandas as gpd
df = sedona.read.format("spider").load(n=300, distribution='uniform', geometryType='box', maxWidth=0.05, maxHeight=0.05)
gpd.GeoDataFrame(df.toPandas(), geometry='geometry').boundary.plot()
```

![Uniform Distribution](../../image/spider/spider-uniform.png)

### Gaussian Distribution

The Gaussian distribution generates random geometries in a Gaussian distribution with mean `[0.5, 0.5]` and standard deviation `[0.1, 0.1]`. This distribution can be selected by setting the `distribution` parameter to `gaussian`.

| Parameter | Description | Default Value |
| --------- | ----------- | ------------- |
| geometryType | Geometry type, either `point`, `box` or `polygon` | `point` |
| maxWidth | Maximum width of the generated boxes | 0.01 |
| maxHeight | Maximum height of the generated boxes | 0.01 |
| minSegment | Minimum number of segments of the generated polygons | 3 |
| maxSegment | Maximum number of segments of the generated polygons | 3 |
| maxSize | Maximum size of the generated polygons | 0.01 |

Example:

```python
import geopandas as gpd
df = sedona.read.format("spider").load(n=300, distribution='gaussian', geometryType='polygon', maxSize=0.05)
gpd.GeoDataFrame(df.toPandas(), geometry='geometry').boundary.plot()
```

![Gaussian Distribution](../../image/spider/spider-gaussian.png)

### Bit Distribution

The bit distribution generates random geometries in a bit distribution. This distribution can be selected by setting the `distribution` parameter to `bit`.

| Parameter | Description | Default Value |
| --------- | ----------- | ------------- |
| geometryType | Geometry type, either `point`, `box` or `polygon` | `point` |
| probability | Probability of setting a bit | 0.2 |
| digits | Number of digits in the generated data | 10 |
| maxWidth | Maximum width of the generated boxes | 0.01 |
| maxHeight | Maximum height of the generated boxes | 0.01 |
| minSegment | Minimum number of segments of the generated polygons | 3 |
| maxSegment | Maximum number of segments of the generated polygons | 3 |
| maxSize | Maximum size of the generated polygons | 0.01 |

Example:

```python
import geopandas as gpd
df = sedona.read.format("spider").load(n=300, distribution='bit', geometryType='point', probability=0.2, digits=10)
gpd.GeoDataFrame(df.toPandas(), geometry='geometry').plot(markersize=1)
```

![Bit Distribution](../../image/spider/spider-bit.png)

### Diagonal Distribution

The diagonal distribution generates random geometries on the diagonal line `y = x` with some dispersion for geometries that are not exactly on the diagonal. This distribution can be selected by setting the `distribution` parameter to `diagonal`.

| Parameter | Description | Default Value |
| --------- | ----------- | ------------- |
| geometryType | Geometry type, either `point`, `box` or `polygon` | `point` |
| percentage | The percentage of records that are perfectly on the diagonal | 0.5 |
| buffer | For points not exactly on the diagonal, the buffer in which they are dispersed | 0.5 |
| maxWidth | Maximum width of the generated boxes | 0.01 |
| maxHeight | Maximum height of the generated boxes | 0.01 |
| minSegment | Minimum number of segments of the generated polygons | 3 |
| maxSegment | Maximum number of segments of the generated polygons | 3 |
| maxSize | Maximum size of the generated polygons | 0.01 |

Example:

```python
import geopandas as gpd
df = sedona.read.format("spider").load(n=300, distribution='diagonal', geometryType='point', percentage=0.5, buffer=0.5)
gpd.GeoDataFrame(df.toPandas(), geometry='geometry').plot(markersize=1)
```

![Diagonal Distribution](../../image/spider/spider-diagonal.png)

### Sierpinski Distribution

The Sierpinski distribution generates random geometries distributed on a Sierpinski triangle. This distribution can be selected by setting the `distribution` parameter to `sierpinski`.

| Parameter | Description | Default Value |
| --------- | ----------- | ------------- |
| geometryType | Geometry type, either `point`, `box` or `polygon` | `point` |
| maxWidth | Maximum width of the generated boxes | 0.01 |
| maxHeight | Maximum height of the generated boxes | 0.01 |
| minSegment | Minimum number of segments of the generated polygons | 3 |
| maxSegment | Maximum number of segments of the generated polygons | 3 |
| maxSize | Maximum size of the generated polygons | 0.01 |

Example:

```python
import geopandas as gpd
df = sedona.read.format("spider").load(n=2000, distribution='sierpinski', geometryType='point')
gpd.GeoDataFrame(df.toPandas(), geometry='geometry').plot(markersize=1)
```

![Sierpinski Distribution](../../image/spider/spider-sierpinski.png)

### Parcel Distribution

This generator produces boxes that resemble parcel areas. It works by recursively splitting the input domain (unit square) along the longest dimension and then randomly dithering each generated box to add some randomness. This generator can only generate boxes. This distribution can be selected by setting the `distribution` parameter to `parcel`.

| Parameter | Description | Default Value |
| --------- | ----------- | ------------- |
| dither | The amount of dithering as a ratio of the side length. Allowed range [0, 1] | 0.5 |
| splitRange | The allowed range for splitting boxes. Allowed range [0.0, 0.5] 0.0 means all values are allowed. 0.5 means always split in half. | 0.5 |

Example:

```python
import geopandas as gpd
df = sedona.read.format("spider").load(n=300, distribution='parcel', dither=0.5, splitRange=0.5)
gpd.GeoDataFrame(df.toPandas(), geometry='geometry').boundary.plot()
```

![Parcel Distribution](../../image/spider/spider-parcel.png)

!!!note
The number of partitions generated by the `parcel` distribution is always power of 4. This is for guaranteeing the quality of the generated data. If the specified `numPartitions` is not a power of 4, it will be automatically adjusted to the nearest power of 4 smaller or equal to the specified value.

## Affine Transformation

The random spatial data generated by Spider are mostly in the unit square `[0, 1] x [0, 1]`. If you need to generate random spatial data in a different region, you can specify affine transformation parameters to scale and translate the data to the target region.

The following code demonstrates how to generate random spatial data in a different region using affine transformation.

The affine transformation parameters are:

| Parameter | Description | Default Value |
| --------- | ----------- | ------------- |
| translateX | Translate the data horizontally | 0 |
| translateY | Translate the data vertically | 0 |
| scaleX | Scale the data horizontally | 1 |
| scaleY | Scale the data vertically | 1 |
| skewX | Skew the data horizontally | 0 |
| skewY | Skew the data vertically | 0 |

The affine transformation is applied to the generated data as follows:

```
x' = translateX + scaleX * x + skewX * y
y' = translateY + skewY * x + scaleY * y
```

Example:

```python
import geopandas as gpd
df_random_points = sedona.read.format("spider").load(n=1000, distribution='uniform', translateX=0.5, translateY=0.5, scaleX=2, scaleY=2)
gpd.GeoDataFrame(df_random_points.toPandas(), geometry='geometry').plot(markersize=1)
```

The data is now in the region `[0.5, 2.5] x [0.5, 2.5]`.

![Affine Transformation](../../image/spider/spider-uniform-affine.png)

## References

- Puloma Katiyar, Tin Vu, Sara Migliorini, Alberto Belussi, Ahmed Eldawy. "SpiderWeb: A Spatial Data Generator on the Web", ACM SIGSPATIAL 2020, Seattle, WA
- Beast Spatial Data Generator: https://bitbucket.org/bdlabucr/beast/src/master/doc/spatial-data-generator.md
- SpiderWeb: A Spatial Data Generator on the Web: https://spider.cs.ucr.edu/
- SpiderWeb YouTube Video: https://www.youtube.com/watch?v=h0xCG6Swdqw
Binary file added docs/image/spider/spider-bit.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added docs/image/spider/spider-diagonal.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added docs/image/spider/spider-gaussian.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added docs/image/spider/spider-parcel.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added docs/image/spider/spider-quickstart.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added docs/image/spider/spider-sierpinski.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added docs/image/spider/spider-uniform-affine.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Binary file added docs/image/spider/spider-uniform.png
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
1 change: 1 addition & 0 deletions mkdocs.yml
Original file line number Diff line number Diff line change
Expand Up @@ -86,6 +86,7 @@ nav:
- DataFrame Style functions: api/sql/DataFrameAPI.md
- Query optimization: api/sql/Optimizer.md
- Nearest-Neighbour searching: api/sql/NearestNeighbourSearching.md
- "Spider:Spatial Data Generator": api/sql/Spider.md
- Reading Legacy Parquet Files: api/sql/Reading-legacy-parquet.md
- Visualization:
- SedonaPyDeck: api/sql/Visualization_SedonaPyDeck.md
Expand Down
73 changes: 73 additions & 0 deletions python/tests/sql/test_spider.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,73 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.

import pytest
from tests.test_base import TestBase


class TestSpider(TestBase):
def test_spider_uniform(self):
df = self.spark.read.format("spider").load(
n=1000,
distribution="uniform",
geometryType="box",
maxWidth=0.03,
maxHeight=0.02,
translateX=0.5,
translateY=0.5,
scaleX=2,
scaleY=2,
)
assert df.count() == 1000

# Convert geometries to coordinates for bound checking
bounds_df = df.selectExpr(
"ST_XMin(geometry) as min_x",
"ST_XMax(geometry) as max_x",
"ST_YMin(geometry) as min_y",
"ST_YMax(geometry) as max_y",
).collect()[0]

# Check geometry bounds (should be within [0.5, 2.5] * [0.5, 2.5] with some tolerance)
assert bounds_df.min_x >= 0.4
assert bounds_df.max_x <= 2.6
assert bounds_df.min_y >= 0.4
assert bounds_df.max_y <= 2.6

# Check box dimensions
dimensions_df = df.selectExpr(
"ST_XMax(geometry) - ST_XMin(geometry) as width",
"ST_YMax(geometry) - ST_YMin(geometry) as height",
).collect()

for row in dimensions_df:
assert row.width <= 0.06, f"Box width {row.width} exceeds maximum 0.06"
assert row.height <= 0.04, f"Box height {row.height} exceeds maximum 0.04"

# Check mean width and height
mean_width = (
df.selectExpr("AVG(ST_XMax(geometry) - ST_XMin(geometry)) as mean_width")
.collect()[0]
.mean_width
)
mean_height = (
df.selectExpr("AVG(ST_YMax(geometry) - ST_YMin(geometry)) as mean_height")
.collect()[0]
.mean_height
)
assert abs(mean_width - 0.03) < 0.005
assert abs(mean_height - 0.02) < 0.005

0 comments on commit 3d2ba62

Please sign in to comment.