org.locationtech.geowave.service.grpc.protobuf

Class CoreIngestGrpc.CoreIngestFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<CoreIngestGrpc.CoreIngestFutureStub>

org.locationtech.geowave.service.grpc.protobuf.CoreIngestGrpc.CoreIngestFutureStub

Enclosing class:

CoreIngestGrpc

public static final class CoreIngestGrpc.CoreIngestFutureStub
extends io.grpc.stub.AbstractFutureStub<CoreIngestGrpc.CoreIngestFutureStub>

Nested Class Summary

Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method and Description
com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos>	addTypeCommand(AddTypeCommandParametersProtos request)
protected CoreIngestGrpc.CoreIngestFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos>	kafkaToGeoWaveCommand(KafkaToGeoWaveCommandParametersProtos request)
com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.StringResponseProtos>	listIngestPluginsCommand(ListIngestPluginsCommandParametersProtos request)
com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos>	localToGeoWaveCommand(LocalToGeoWaveCommandParametersProtos request)
com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos>	localToHdfsCommand(LocalToHdfsCommandParametersProtos request)
com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos>	localToKafkaCommand(LocalToKafkaCommandParametersProtos request)
com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos>	localToMapReduceToGeoWaveCommand(LocalToMapReduceToGeoWaveCommandParametersProtos request)
com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos>	mapReduceToGeoWaveCommand(MapReduceToGeoWaveCommandParametersProtos request)
com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos>	sparkToGeoWaveCommand(SparkToGeoWaveCommandParametersProtos request)

Methods inherited from class io.grpc.stub.AbstractFutureStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOption, withWaitForReady

Methods inherited from class java.lang.Object

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

Method Detail

build

protected CoreIngestGrpc.CoreIngestFutureStub build(io.grpc.Channel channel,
                                                    io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<CoreIngestGrpc.CoreIngestFutureStub>

sparkToGeoWaveCommand

public com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos> sparkToGeoWaveCommand(SparkToGeoWaveCommandParametersProtos request)

localToGeoWaveCommand

public com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos> localToGeoWaveCommand(LocalToGeoWaveCommandParametersProtos request)

mapReduceToGeoWaveCommand

public com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos> mapReduceToGeoWaveCommand(MapReduceToGeoWaveCommandParametersProtos request)

localToKafkaCommand

public com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos> localToKafkaCommand(LocalToKafkaCommandParametersProtos request)

listIngestPluginsCommand

public com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.StringResponseProtos> listIngestPluginsCommand(ListIngestPluginsCommandParametersProtos request)

localToMapReduceToGeoWaveCommand

public com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos> localToMapReduceToGeoWaveCommand(LocalToMapReduceToGeoWaveCommandParametersProtos request)

localToHdfsCommand

public com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos> localToHdfsCommand(LocalToHdfsCommandParametersProtos request)

kafkaToGeoWaveCommand

public com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos> kafkaToGeoWaveCommand(KafkaToGeoWaveCommandParametersProtos request)

addTypeCommand

public com.google.common.util.concurrent.ListenableFuture<GeoWaveReturnTypesProtos.VoidResponseProtos> addTypeCommand(AddTypeCommandParametersProtos request)