org.locationtech.geowave.test.services.grpc

Class GeoWaveGrpcTestClient

java.lang.Object

org.locationtech.geowave.test.services.grpc.GeoWaveGrpcTestClient

public class GeoWaveGrpcTestClient
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
AnalyticMapreduceGrpc.AnalyticMapreduceBlockingStub	analyticMapreduceBlockingStub
AnalyticSparkGrpc.AnalyticSparkBlockingStub	analyticSparkBlockingStub
io.grpc.ManagedChannel	channel
CliGeoserverGrpc.CliGeoserverBlockingStub	cliGeoserverBlockingStub
CoreCliGrpc.CoreCliBlockingStub	coreCliBlockingStub
CoreIngestGrpc.CoreIngestBlockingStub	coreIngestBlockingStub
CoreMapreduceGrpc.CoreMapreduceBlockingStub	coreMapreduceBlockingStub
CoreStoreGrpc.CoreStoreBlockingStub	coreStoreBlockingStub
int	numFeaturesProcessed
VectorGrpc.VectorStub	vectorAsyncStub
VectorGrpc.VectorBlockingStub	vectorBlockingStub

Constructor Summary

Constructors

Constructor and Description
GeoWaveGrpcTestClient(io.grpc.netty.NettyChannelBuilder channelBuilder)
GeoWaveGrpcTestClient(String host, int port)

Method Summary

Modifier and Type	Method and Description
boolean	ClearCommand()
String	ConfigGeoServerCommand()
boolean	configHDFSCommand()
ArrayList<FeatureProtos>	cqlQuery()
boolean	dbScanCommand()
boolean	DescribeAdapterCommand()
String	GeoServerAddCoverageCommand()
String	GeoServerAddCoverageStoreCommand()
String	GeoServerAddDatastoreCommand()
String	GeoServerAddFeatureProtosLayerCommand()
String	GeoServerAddLayerCommand()
String	GeoServerAddStyleCommand()
String	GeoServerAddWorkspaceCommand()
String	GeoServerGetCoverageCommand()
String	GeoServerGetCoverageStoreCommand()
String	GeoServerGetDatastoreCommand()
String	GeoServerGetFeatureProtosLayerCommand()
List<String>	GeoServerGetStoreAdapterCommand()
String	GeoServerGetStyleCommand()
String	GeoServerListCoveragesCommand()
String	GeoServerListCoverageStoresCommand()
String	GeoServerListDatastoresCommand()
String	GeoServerListFeatureProtosLayersCommand()
String	GeoServerListStylesCommand()
List<String>	GeoServerListWorkspacesCommand()
String	GeoServerRemoveCoverageCommand()
String	GeoServerRemoveCoverageStoreCommand()
String	GeoServerRemoveDatastoreCommand()
String	GeoServerRemoveFeatureProtosLayerCommand()
String	GeoServerRemoveStyleCommand()
String	GeoServerRemoveWorkspaceCommand()
String	GeoServerSetLayerStyleCommand()
boolean	KafkaToGeoWaveCommand()
boolean	kdeCommand()
boolean	KmeansSparkCommand()
String	ListAdapterCommand()
Map<String,String>	listCommand()
String	ListIndexCommand()
String	ListIndexPluginsCommand()
String	ListIngestPluginsCommand()
String	ListStatsCommand()
String	ListStorePluginsCommand()
boolean	LocalToGeoWaveCommand()
boolean	LocalToHdfsCommand()
boolean	LocalToKafkaCommand()
boolean	LocalToMapReduceToGeoWaveCommand()
boolean	MapReduceToGeoWaveCommand()
boolean	nearestNeighborCommand()
boolean	RecalculateStatsCommand()
boolean	RemoveAdapterCommand()
String	RemoveIndexCommand()
boolean	RemoveStatCommand()
String	RemoveStoreCommand()
void	setCommand(String key, String val)
void	shutdown()
boolean	SparkSqlCommand()
boolean	SparkToGeoWaveCommand()
boolean	SpatialJoinCommand()
ArrayList<FeatureProtos>	spatialQuery()
ArrayList<FeatureProtos>	spatialTemporalQuery()
void	vectorIngest(int minLat, int maxLat, int minLon, int maxLon, int latStepDegs, int lonStepDegs)
ArrayList<FeatureProtos>	vectorQuery()
boolean	VersionCommand()

Methods inherited from class java.lang.Object

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

Field Detail

channel

public final io.grpc.ManagedChannel channel

vectorBlockingStub

public final VectorGrpc.VectorBlockingStub vectorBlockingStub

vectorAsyncStub

public final VectorGrpc.VectorStub vectorAsyncStub

coreCliBlockingStub

public final CoreCliGrpc.CoreCliBlockingStub coreCliBlockingStub

coreMapreduceBlockingStub

public final CoreMapreduceGrpc.CoreMapreduceBlockingStub coreMapreduceBlockingStub

analyticMapreduceBlockingStub

public final AnalyticMapreduceGrpc.AnalyticMapreduceBlockingStub analyticMapreduceBlockingStub

analyticSparkBlockingStub

public final AnalyticSparkGrpc.AnalyticSparkBlockingStub analyticSparkBlockingStub

coreStoreBlockingStub

public final CoreStoreGrpc.CoreStoreBlockingStub coreStoreBlockingStub

coreIngestBlockingStub

public final CoreIngestGrpc.CoreIngestBlockingStub coreIngestBlockingStub

cliGeoserverBlockingStub

public final CliGeoserverGrpc.CliGeoserverBlockingStub cliGeoserverBlockingStub

numFeaturesProcessed

public int numFeaturesProcessed

Constructor Detail

GeoWaveGrpcTestClient

public GeoWaveGrpcTestClient(String host,
                             int port)

GeoWaveGrpcTestClient

public GeoWaveGrpcTestClient(io.grpc.netty.NettyChannelBuilder channelBuilder)

Method Detail

shutdown

public void shutdown()
              throws InterruptedException

Throws:

InterruptedException

setCommand

public void setCommand(String key,
                       String val)

listCommand

public Map<String,String> listCommand()

vectorIngest

public void vectorIngest(int minLat,
                         int maxLat,
                         int minLon,
                         int maxLon,
                         int latStepDegs,
                         int lonStepDegs)
                  throws InterruptedException,
                         UnsupportedEncodingException,
                         ParseException

Throws:

InterruptedException

UnsupportedEncodingException

ParseException

vectorQuery

public ArrayList<FeatureProtos> vectorQuery()
                                     throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

cqlQuery

public ArrayList<FeatureProtos> cqlQuery()
                                  throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

spatialQuery

public ArrayList<FeatureProtos> spatialQuery()
                                      throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

spatialTemporalQuery

public ArrayList<FeatureProtos> spatialTemporalQuery()
                                              throws ParseException

Throws:

ParseException

configHDFSCommand

public boolean configHDFSCommand()

dbScanCommand

public boolean dbScanCommand()

nearestNeighborCommand

public boolean nearestNeighborCommand()

kdeCommand

public boolean kdeCommand()

RecalculateStatsCommand

public boolean RecalculateStatsCommand()

RemoveIndexCommand

public String RemoveIndexCommand()

VersionCommand

public boolean VersionCommand()

ListIndexCommand

public String ListIndexCommand()

ListStatsCommand

public String ListStatsCommand()

ClearCommand

public boolean ClearCommand()

ListAdapterCommand

public String ListAdapterCommand()

DescribeAdapterCommand

public boolean DescribeAdapterCommand()

RemoveStoreCommand

public String RemoveStoreCommand()

RemoveAdapterCommand

public boolean RemoveAdapterCommand()

RemoveStatCommand

public boolean RemoveStatCommand()

GeoServerAddLayerCommand

public String GeoServerAddLayerCommand()

GeoServerGetDatastoreCommand

public String GeoServerGetDatastoreCommand()

GeoServerGetFeatureProtosLayerCommand

public String GeoServerGetFeatureProtosLayerCommand()

GeoServerListCoverageStoresCommand

public String GeoServerListCoverageStoresCommand()

GeoServerGetStoreAdapterCommand

public List<String> GeoServerGetStoreAdapterCommand()

GeoServerGetCoverageCommand

public String GeoServerGetCoverageCommand()

GeoServerRemoveFeatureProtosLayerCommand

public String GeoServerRemoveFeatureProtosLayerCommand()

GeoServerAddCoverageCommand

public String GeoServerAddCoverageCommand()

GeoServerRemoveWorkspaceCommand

public String GeoServerRemoveWorkspaceCommand()

GeoServerListWorkspacesCommand

public List<String> GeoServerListWorkspacesCommand()

GeoServerGetCoverageStoreCommand

public String GeoServerGetCoverageStoreCommand()

ConfigGeoServerCommand

public String ConfigGeoServerCommand()

GeoServerListCoveragesCommand

public String GeoServerListCoveragesCommand()

GeoServerListStylesCommand

public String GeoServerListStylesCommand()

GeoServerAddCoverageStoreCommand

public String GeoServerAddCoverageStoreCommand()

GeoServerAddFeatureProtosLayerCommand

public String GeoServerAddFeatureProtosLayerCommand()

GeoServerAddDatastoreCommand

public String GeoServerAddDatastoreCommand()

GeoServerListDatastoresCommand

public String GeoServerListDatastoresCommand()

GeoServerSetLayerStyleCommand

public String GeoServerSetLayerStyleCommand()

GeoServerRemoveCoverageStoreCommand

public String GeoServerRemoveCoverageStoreCommand()

GeoServerRemoveDatastoreCommand

public String GeoServerRemoveDatastoreCommand()

GeoServerAddStyleCommand

public String GeoServerAddStyleCommand()

GeoServerAddWorkspaceCommand

public String GeoServerAddWorkspaceCommand()

GeoServerGetStyleCommand

public String GeoServerGetStyleCommand()

GeoServerRemoveStyleCommand

public String GeoServerRemoveStyleCommand()

GeoServerRemoveCoverageCommand

public String GeoServerRemoveCoverageCommand()

GeoServerListFeatureProtosLayersCommand

public String GeoServerListFeatureProtosLayersCommand()

LocalToHdfsCommand

public boolean LocalToHdfsCommand()

LocalToGeoWaveCommand

public boolean LocalToGeoWaveCommand()

MapReduceToGeoWaveCommand

public boolean MapReduceToGeoWaveCommand()

SparkToGeoWaveCommand

public boolean SparkToGeoWaveCommand()

LocalToMapReduceToGeoWaveCommand

public boolean LocalToMapReduceToGeoWaveCommand()

KafkaToGeoWaveCommand

public boolean KafkaToGeoWaveCommand()

ListIngestPluginsCommand

public String ListIngestPluginsCommand()

ListIndexPluginsCommand

public String ListIndexPluginsCommand()

ListStorePluginsCommand

public String ListStorePluginsCommand()

LocalToKafkaCommand

public boolean LocalToKafkaCommand()

KmeansSparkCommand

public boolean KmeansSparkCommand()

SparkSqlCommand

public boolean SparkSqlCommand()

SpatialJoinCommand

public boolean SpatialJoinCommand()