org.locationtech.geowave.test

Class TestUtils

java.lang.Object

org.locationtech.geowave.test.TestUtils

public class TestUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestUtils.DimensionalityType
static class	TestUtils.ExpectedResults

Field Summary

Fields

Modifier and Type	Field and Description
static org.opengis.referencing.crs.CoordinateReferenceSystem	CUSTOM_CRS
static String	CUSTOM_CRSCODE
static Index	DEFAULT_SPATIAL_INDEX
static Index	DEFAULT_SPATIAL_TEMPORAL_INDEX
static Index	DEFAULT_TEMPORAL_INDEX
static double	DOUBLE_EPSILON
static String	S3_INPUT_PATH
static String	S3URL
static File	TEMP_DIR
static String	TEST_CASE_BASE
static String	TEST_FILTER_END_TIME_ATTRIBUTE_NAME
static String	TEST_FILTER_START_TIME_ATTRIBUTE_NAME
static String	TEST_NAMESPACE
static String	TEST_NAMESPACE_BAD
static String	TEST_RESOURCE_PACKAGE

Constructor Summary

Constructors

Constructor and Description
TestUtils()

Method Summary

Modifier and Type	Method and Description
static void	assert200(String msg, int responseCode) Deprecated.
static void	assert400(String msg, int responseCode) Deprecated.
static void	assert404(String msg, int responseCode) Deprecated.
static void	assertStatusCode(int expectedCode, javax.ws.rs.core.Response response) Asserts that the response has the expected Status Code.
static void	assertStatusCode(String msg, int expectedCode, javax.ws.rs.core.Response response) Asserts that the response has the expected Status Code.
static Index	createWebMercatorSpatialIndex()
static Index	createWebMercatorSpatialTemporalIndex()
static void	deleteAll(DataStorePluginOptions dataStore)
static QueryConstraints	featureToQuery(org.opengis.feature.simple.SimpleFeature savedFilter, org.apache.commons.lang3.tuple.Pair<String,String> optimalCqlQueryGeometryAndTimeField, String crsCode, boolean useDuring)
static void	fillTestRasters(WritableRaster raster1, WritableRaster raster2, int tileSize)
static TestUtils.ExpectedResults	getExpectedResults(CloseableIterator<?> results)
static TestUtils.ExpectedResults	getExpectedResults(URL[] expectedResultsResources)
static TestUtils.ExpectedResults	getExpectedResults(URL[] expectedResultsResources, org.opengis.referencing.crs.CoordinateReferenceSystem crs)
static StoreTestEnvironment	getTestEnvironment(String type)
static double	getTileValue(int x, int y, int b, int tileSize)
static double	getTileValue(int x, int y, int b, int r, int tileSize)
static long	hashCentroid(org.locationtech.jts.geom.Geometry geometry)
static boolean	isOracleJRE()
static boolean	isSet(String str)
static boolean	isYarn()
static void	printEndOfTest(org.slf4j.Logger logger, String testName, long startMillis)
static void	printStartOfTest(org.slf4j.Logger logger, String testName)
protected static void	replaceParameters(Map<String,String> values, File file)
static org.opengis.feature.simple.SimpleFeature	resourceToFeature(URL filterResource)
static QueryConstraints	resourceToQuery(URL filterResource)
static QueryConstraints	resourceToQuery(URL filterResource, org.apache.commons.lang3.tuple.Pair<String,String> optimalCqlQueryGeometryAndTimeFields, boolean useDuring)
static void	testLocalIngest(DataStorePluginOptions dataStore, TestUtils.DimensionalityType dimensionalityType, String ingestFilePath)
static void	testLocalIngest(DataStorePluginOptions dataStore, TestUtils.DimensionalityType dimensionalityType, String ingestFilePath, int nthreads)
static void	testLocalIngest(DataStorePluginOptions dataStore, TestUtils.DimensionalityType dimensionalityType, String ingestFilePath, String format, int nthreads)
static void	testLocalIngest(DataStorePluginOptions dataStore, TestUtils.DimensionalityType dimensionalityType, String crsCode, String ingestFilePath, String format, int nthreads)
static void	testLocalIngest(DataStorePluginOptions dataStore, TestUtils.DimensionalityType dimensionalityType, String crsCode, String ingestFilePath, String format, int nthreads, boolean supportTimeRange)
static void	testS3LocalIngest(DataStorePluginOptions dataStore, TestUtils.DimensionalityType dimensionalityType, String s3Url, String ingestFilePath, String format, int nthreads)
static void	testSparkIngest(DataStorePluginOptions dataStore, TestUtils.DimensionalityType dimensionalityType, String format)
static void	testSparkIngest(DataStorePluginOptions dataStore, TestUtils.DimensionalityType dimensionalityType, String s3Url, String ingestFilePath, String format)
static void	testTileAgainstReference(BufferedImage actual, BufferedImage expected, double minPctError, double maxPctError)
static org.opengis.referencing.operation.MathTransform	transformFromCrs(org.opengis.referencing.crs.CoordinateReferenceSystem crs)
static void	writeConfigToFile(File file, org.apache.hadoop.conf.Configuration config)

Methods inherited from class java.lang.Object

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

Field Detail

TEMP_DIR

public static final File TEMP_DIR

TEST_FILTER_START_TIME_ATTRIBUTE_NAME

public static final String TEST_FILTER_START_TIME_ATTRIBUTE_NAME

See Also:

Constant Field Values

TEST_FILTER_END_TIME_ATTRIBUTE_NAME

public static final String TEST_FILTER_END_TIME_ATTRIBUTE_NAME

See Also:

Constant Field Values

TEST_NAMESPACE

public static final String TEST_NAMESPACE

See Also:

Constant Field Values

TEST_NAMESPACE_BAD

public static final String TEST_NAMESPACE_BAD

See Also:

Constant Field Values

TEST_RESOURCE_PACKAGE

public static final String TEST_RESOURCE_PACKAGE

See Also:

Constant Field Values

TEST_CASE_BASE

public static final String TEST_CASE_BASE

See Also:

Constant Field Values

DEFAULT_SPATIAL_INDEX

public static final Index DEFAULT_SPATIAL_INDEX

DEFAULT_TEMPORAL_INDEX

public static final Index DEFAULT_TEMPORAL_INDEX

DEFAULT_SPATIAL_TEMPORAL_INDEX

public static final Index DEFAULT_SPATIAL_TEMPORAL_INDEX

CUSTOM_CRSCODE

public static String CUSTOM_CRSCODE

CUSTOM_CRS

public static final org.opengis.referencing.crs.CoordinateReferenceSystem CUSTOM_CRS

DOUBLE_EPSILON

public static final double DOUBLE_EPSILON

See Also:

Constant Field Values

S3_INPUT_PATH

public static final String S3_INPUT_PATH

See Also:

Constant Field Values

S3URL

public static final String S3URL

See Also:

Constant Field Values

Constructor Detail

TestUtils

public TestUtils()

Method Detail

createWebMercatorSpatialIndex

public static Index createWebMercatorSpatialIndex()

createWebMercatorSpatialTemporalIndex

public static Index createWebMercatorSpatialTemporalIndex()

isYarn

public static boolean isYarn()

isOracleJRE

public static boolean isOracleJRE()

writeConfigToFile

public static void writeConfigToFile(File file,
                                     org.apache.hadoop.conf.Configuration config)
                              throws IOException

Throws:

IOException

testLocalIngest

public static void testLocalIngest(DataStorePluginOptions dataStore,
                                   TestUtils.DimensionalityType dimensionalityType,
                                   String ingestFilePath,
                                   int nthreads)
                            throws Exception

Throws:

Exception

testLocalIngest

public static void testLocalIngest(DataStorePluginOptions dataStore,
                                   TestUtils.DimensionalityType dimensionalityType,
                                   String ingestFilePath)
                            throws Exception

Throws:

Exception

isSet

public static boolean isSet(String str)

deleteAll

public static void deleteAll(DataStorePluginOptions dataStore)

testLocalIngest

public static void testLocalIngest(DataStorePluginOptions dataStore,
                                   TestUtils.DimensionalityType dimensionalityType,
                                   String ingestFilePath,
                                   String format,
                                   int nthreads)
                            throws Exception

Throws:

Exception

testLocalIngest

public static void testLocalIngest(DataStorePluginOptions dataStore,
                                   TestUtils.DimensionalityType dimensionalityType,
                                   String crsCode,
                                   String ingestFilePath,
                                   String format,
                                   int nthreads)
                            throws Exception

Throws:

Exception

testLocalIngest

public static void testLocalIngest(DataStorePluginOptions dataStore,
                                   TestUtils.DimensionalityType dimensionalityType,
                                   String crsCode,
                                   String ingestFilePath,
                                   String format,
                                   int nthreads,
                                   boolean supportTimeRange)
                            throws Exception

Throws:

Exception

testS3LocalIngest

public static void testS3LocalIngest(DataStorePluginOptions dataStore,
                                     TestUtils.DimensionalityType dimensionalityType,
                                     String s3Url,
                                     String ingestFilePath,
                                     String format,
                                     int nthreads)
                              throws Exception

Throws:

Exception

testSparkIngest

public static void testSparkIngest(DataStorePluginOptions dataStore,
                                   TestUtils.DimensionalityType dimensionalityType,
                                   String format)
                            throws Exception

Throws:

Exception

testSparkIngest

public static void testSparkIngest(DataStorePluginOptions dataStore,
                                   TestUtils.DimensionalityType dimensionalityType,
                                   String s3Url,
                                   String ingestFilePath,
                                   String format)
                            throws Exception

Throws:

Exception

hashCentroid

public static long hashCentroid(org.locationtech.jts.geom.Geometry geometry)

getExpectedResults

public static TestUtils.ExpectedResults getExpectedResults(CloseableIterator<?> results)
                                                    throws IOException

Throws:

IOException

getExpectedResults

public static TestUtils.ExpectedResults getExpectedResults(URL[] expectedResultsResources)
                                                    throws IOException

Throws:

IOException

transformFromCrs

public static org.opengis.referencing.operation.MathTransform transformFromCrs(org.opengis.referencing.crs.CoordinateReferenceSystem crs)

getExpectedResults

public static TestUtils.ExpectedResults getExpectedResults(URL[] expectedResultsResources,
                                                           org.opengis.referencing.crs.CoordinateReferenceSystem crs)
                                                    throws IOException

Throws:

IOException

resourceToQuery

public static QueryConstraints resourceToQuery(URL filterResource)
                                        throws IOException

Throws:

IOException

resourceToQuery

public static QueryConstraints resourceToQuery(URL filterResource,
                                               org.apache.commons.lang3.tuple.Pair<String,String> optimalCqlQueryGeometryAndTimeFields,
                                               boolean useDuring)
                                        throws IOException

Throws:

IOException

resourceToFeature

public static org.opengis.feature.simple.SimpleFeature resourceToFeature(URL filterResource)
                                                                  throws IOException

Throws:

IOException

featureToQuery

public static QueryConstraints featureToQuery(org.opengis.feature.simple.SimpleFeature savedFilter,
                                              org.apache.commons.lang3.tuple.Pair<String,String> optimalCqlQueryGeometryAndTimeField,
                                              String crsCode,
                                              boolean useDuring)

replaceParameters

protected static void replaceParameters(Map<String,String> values,
                                        File file)
                                 throws IOException

Throws:

IOException

printStartOfTest

public static void printStartOfTest(org.slf4j.Logger logger,
                                    String testName)

Parameters:

testName - Name of the test that we are starting.

printEndOfTest

public static void printEndOfTest(org.slf4j.Logger logger,
                                  String testName,
                                  long startMillis)

Parameters:

testName - Name of the test that we are starting.

startMillis - The time (millis) that the test started.

testTileAgainstReference

public static void testTileAgainstReference(BufferedImage actual,
                                            BufferedImage expected,
                                            double minPctError,
                                            double maxPctError)

Parameters:

actual - sample

expected - reference

minPctError - used for testing subsampling - to ensure we are properly subsampling we want there to be some error if subsampling is aggressive (10 pixels)

maxPctError - used for testing subsampling - we want to ensure at most we are off by this percentile

getTileValue

public static double getTileValue(int x,
                                  int y,
                                  int b,
                                  int tileSize)

fillTestRasters

public static void fillTestRasters(WritableRaster raster1,
                                   WritableRaster raster2,
                                   int tileSize)

getTileValue

public static double getTileValue(int x,
                                  int y,
                                  int b,
                                  int r,
                                  int tileSize)

assert200

@Deprecated
public static void assert200(String msg,
                                         int responseCode)

Deprecated.

assert400

@Deprecated
public static void assert400(String msg,
                                         int responseCode)

Deprecated.

assert404

@Deprecated
public static void assert404(String msg,
                                         int responseCode)

Deprecated.

assertStatusCode

public static void assertStatusCode(String msg,
                                    int expectedCode,
                                    javax.ws.rs.core.Response response)

Asserts that the response has the expected Status Code. The assertion message is formatted to include the provided string.

Parameters:

msg - String message to include in the assertion message.

expectedCode - Integer HTTP Status code to expect from the response.

response - The Response object on which .getStatus() will be performed.

assertStatusCode

public static void assertStatusCode(int expectedCode,
                                    javax.ws.rs.core.Response response)

Asserts that the response has the expected Status Code. The assertion message automatically formatted.

Parameters:

expectedCode - Integer HTTP Status code to expect from the response.

response - The Response object on which .getStatus() will be performed.

getTestEnvironment

public static StoreTestEnvironment getTestEnvironment(String type)