Class Hierarchy
- java.lang.Object
- com.google.protobuf.AbstractMessageLite<MessageType,BuilderType> (implements com.google.protobuf.MessageLite)
- com.google.protobuf.AbstractMessage (implements com.google.protobuf.Message)
- com.google.protobuf.GeneratedMessageV3 (implements java.io.Serializable)
- com.google.protobuf.AbstractMessageLite.Builder<MessageType,BuilderType> (implements com.google.protobuf.MessageLite.Builder)
- com.google.protobuf.AbstractMessage.Builder<BuilderType> (implements com.google.protobuf.Message.Builder)
- com.google.protobuf.GeneratedMessageV3.Builder<BuilderType>
- org.apache.flink.streaming.api.operators.AbstractStreamOperator<OUT> (implements java.io.Serializable, org.apache.flink.streaming.api.operators.SetupableStreamOperator<OUT>, org.apache.flink.streaming.api.operators.StreamOperator<OUT>)
- org.apache.flink.statefun.flink.core.feedback.FeedbackSinkOperator<V> (implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
- org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperator<T> (implements org.apache.flink.statefun.flink.core.feedback.FeedbackConsumer<T>, org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
- org.apache.flink.statefun.flink.core.functions.FunctionGroupOperator (implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
- org.apache.flink.statefun.flink.state.processor.operator.FunctionsStateBootstrapOperator (implements org.apache.flink.streaming.api.operators.BoundedOneInput, org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
- org.apache.flink.statefun.flink.core.translation.IngressRouterOperator<T> (implements org.apache.flink.streaming.api.operators.OneInputStreamOperator<IN,OUT>)
- org.apache.flink.statefun.sdk.Address
- org.apache.flink.statefun.examples.ridesharing.simulator.controllers.ApiController
- org.apache.flink.statefun.sdk.state.ApiExtension
- org.apache.flink.statefun.sdk.AsyncOperationResult<M,T>
- org.apache.flink.statefun.flink.core.protorouter.AutoRoutableProtobufRouter (implements org.apache.flink.statefun.sdk.io.Router<InT>)
- org.apache.flink.statefun.sdk.kinesis.auth.AwsCredentials
- org.apache.flink.statefun.sdk.kinesis.auth.AwsRegion
- org.hamcrest.BaseMatcher<T> (implements org.hamcrest.Matcher<T>)
- org.hamcrest.TypeSafeMatcher<T>
- org.apache.flink.statefun.flink.state.processor.union.BootstrapDataset<T>
- org.apache.flink.statefun.flink.state.processor.union.BootstrapDatasetUnion
- org.apache.flink.statefun.flink.core.backpressure.BoundedExponentialBackoff
- org.apache.flink.statefun.flink.core.state.BoundState
- org.apache.flink.statefun.flink.core.state.BoundState.Builder
- org.apache.flink.runtime.entrypoint.ClusterEntrypoint (implements org.apache.flink.util.AutoCloseableAsync, org.apache.flink.runtime.rpc.FatalErrorHandler)
- org.apache.flink.runtime.entrypoint.JobClusterEntrypoint
- org.apache.flink.statefun.examples.ridesharing.simulator.simulation.messaging.Communication (implements org.apache.flink.statefun.examples.ridesharing.simulator.simulation.DriverMessaging, org.apache.flink.statefun.examples.ridesharing.simulator.simulation.PassengerMessaging)
- org.apache.flink.statefun.sdk.kafka.Constants
- org.apache.flink.statefun.flink.core.spi.Constants
- org.apache.flink.statefun.flink.harness.io.ConsumingEgressSpec<T> (implements org.apache.flink.statefun.sdk.io.EgressSpec<T>, java.io.Serializable)
- org.apache.flink.statefun.examples.ridesharing.simulator.simulation.Driver (implements org.apache.flink.statefun.examples.ridesharing.simulator.simulation.engine.Simulatee)
- org.apache.flink.statefun.examples.async.service.DummyTaskQueryService (implements org.apache.flink.statefun.examples.async.service.TaskQueryService)
- org.apache.flink.statefun.flink.core.types.DynamicallyRegisteredTypes
- org.apache.flink.statefun.sdk.io.EgressIdentifier<T> (implements java.io.Serializable)
- org.apache.flink.statefun.sdk.kinesis.egress.EgressRecord
- org.apache.flink.statefun.sdk.kinesis.egress.EgressRecord.Builder
- org.apache.flink.statefun.sdk.EgressType
- org.apache.flink.statefun.e2e.exactlyonce.generated.ExactlyOnceVerification
- org.apache.flink.statefun.e2e.exactlyonce.ExactlyOnceVerificationModule (implements org.apache.flink.statefun.sdk.spi.StatefulFunctionModule)
- org.apache.flink.statefun.sdk.state.Expiration
- org.junit.rules.ExternalResource (implements org.junit.rules.TestRule)
- org.apache.flink.statefun.flink.core.feedback.FeedbackChannel<T> (implements java.io.Closeable)
- org.apache.flink.statefun.flink.core.feedback.FeedbackChannelBroker
- org.apache.flink.statefun.flink.core.feedback.FeedbackKey<V> (implements java.io.Serializable)
- org.apache.flink.statefun.flink.core.feedback.FeedbackUnionOperatorFactory<E> (implements org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<IN,OUT>, org.apache.flink.streaming.api.operators.YieldingOperatorFactory<OUT>)
- org.apache.flink.statefun.flink.core.metrics.FlinkMetricsFactory (implements org.apache.flink.statefun.flink.core.metrics.MetricsFactory)
- org.apache.flink.statefun.flink.core.state.FlinkState (implements org.apache.flink.statefun.flink.core.state.State)
- org.apache.flink.statefun.flink.core.translation.FlinkUniverse
- org.apache.flink.statefun.examples.ridesharing.FnGeoCell (implements org.apache.flink.statefun.sdk.StatefulFunction)
- org.apache.flink.statefun.flink.core.functions.FunctionGroupDispatchFactory (implements org.apache.flink.streaming.api.operators.OneInputStreamOperatorFactory<IN,OUT>, org.apache.flink.streaming.api.operators.YieldingOperatorFactory<OUT>)
- org.apache.flink.statefun.examples.ridesharing.FunctionProvider (implements org.apache.flink.statefun.sdk.StatefulFunctionProvider)
- org.apache.flink.statefun.testutils.function.FunctionTestHarness
- org.apache.flink.statefun.sdk.FunctionType
- org.apache.flink.statefun.flink.io.kafka.GenericKafkaEgressSerializer (implements org.apache.flink.statefun.sdk.kafka.KafkaEgressSerializer<OutT>)
- org.apache.flink.statefun.flink.io.kinesis.polyglot.GenericKinesisEgressSerializer (implements org.apache.flink.statefun.sdk.kinesis.egress.KinesisEgressSerializer<T>)
- org.apache.flink.statefun.flink.io.kinesis.polyglot.GenericKinesisSinkProvider (implements org.apache.flink.statefun.flink.io.spi.SinkProvider)
- org.apache.flink.statefun.examples.greeter.generated.Greeter
- org.apache.flink.statefun.examples.greeter.GreetingModule (implements org.apache.flink.statefun.sdk.spi.StatefulFunctionModule)
- org.apache.flink.statefun.flink.state.processor.example.GreetStatefulFunctionBootstrapExample
- org.apache.flink.statefun.flink.state.processor.example.GreetStatefulFunctionBootstrapExample.GreetingsStateBootstrapDataRouter (implements org.apache.flink.statefun.sdk.io.Router<InT>)
- org.apache.flink.statefun.flink.state.processor.example.GreetStatefulFunctionBootstrapExample.GreetingsStateBootstrapFunction (implements org.apache.flink.statefun.flink.state.processor.StateBootstrapFunction)
- org.apache.flink.statefun.flink.core.grpcfn.GrpcFunction (implements org.apache.flink.statefun.sdk.StatefulFunction)
- org.apache.flink.statefun.flink.core.grpcfn.GrpcFunctionProvider (implements org.apache.flink.statefun.sdk.StatefulFunctionProvider)
- org.apache.flink.statefun.flink.core.grpcfn.GrpcFunctionSpec (implements org.apache.flink.statefun.flink.core.jsonmodule.FunctionSpec)
- org.apache.flink.statefun.flink.harness.Harness
- org.apache.flink.statefun.flink.harness.io.HarnessConstants
- org.apache.flink.statefun.flink.harness.io.HarnessIoModule (implements org.apache.flink.statefun.flink.io.spi.FlinkIoModule)
- it.unimi.dsi.fastutil.HashCommon
- org.apache.flink.statefun.flink.core.polyglot.generated.HttpFunction
- org.apache.flink.statefun.flink.core.httpfn.HttpFunctionProvider (implements org.apache.flink.statefun.sdk.StatefulFunctionProvider)
- org.apache.flink.statefun.flink.core.httpfn.HttpFunctionSpec (implements org.apache.flink.statefun.flink.core.jsonmodule.FunctionSpec)
- org.apache.flink.statefun.flink.core.httpfn.HttpFunctionSpec.Builder
- org.apache.flink.statefun.examples.ridesharing.InboundDriverRouter (implements org.apache.flink.statefun.sdk.io.Router<InT>)
- org.apache.flink.statefun.examples.ridesharing.InboundPassengerRouter (implements org.apache.flink.statefun.sdk.io.Router<InT>)
- org.apache.flink.statefun.sdk.io.IngressIdentifier<T> (implements java.io.Serializable)
- org.apache.flink.statefun.sdk.kinesis.ingress.IngressRecord
- org.apache.flink.statefun.sdk.kinesis.ingress.IngressRecord.Builder
- org.apache.flink.statefun.sdk.IngressType
- org.apache.flink.statefun.flink.io.spi.JsonEgressSpec<T> (implements org.apache.flink.statefun.sdk.io.EgressSpec<T>)
- org.apache.flink.statefun.flink.io.spi.JsonIngressSpec<T> (implements org.apache.flink.statefun.sdk.io.IngressSpec<T>)
- org.apache.flink.statefun.flink.core.jsonmodule.JsonServiceLoader
- org.apache.flink.statefun.examples.ridesharing.simulator.configurations.KafkaConsumerConfig
- org.apache.flink.statefun.examples.ridesharing.simulator.services.KafkaConsumerService
- org.apache.flink.statefun.examples.ridesharing.simulator.services.KafkaDriverPublisher (implements java.util.function.Consumer<T>)
- org.apache.flink.statefun.flink.io.generated.KafkaEgress
- org.apache.flink.statefun.sdk.kafka.KafkaEgressBuilder<OutT>
- org.apache.flink.statefun.sdk.kafka.KafkaEgressSpec<OutT> (implements org.apache.flink.statefun.sdk.io.EgressSpec<T>)
- org.apache.flink.statefun.flink.io.kafka.KafkaEgressTypes
- org.apache.flink.statefun.flink.io.kafka.KafkaFlinkIoModule (implements org.apache.flink.statefun.flink.io.spi.FlinkIoModule)
- org.apache.flink.statefun.sdk.kafka.KafkaIngressBuilder<T>
- org.apache.flink.statefun.sdk.kafka.KafkaIngressBuilderApiExtension
- org.apache.flink.statefun.sdk.kafka.KafkaIngressSpec<T> (implements org.apache.flink.statefun.sdk.io.IngressSpec<T>)
- org.apache.flink.statefun.sdk.kafka.KafkaIngressStartupPosition
- org.apache.flink.statefun.e2e.common.kafka.KafkaIOVerifier<PK,PV,CK,CV>
- org.apache.flink.statefun.examples.ridesharing.simulator.services.KafkaPassengerPublisher (implements java.util.function.Consumer<T>)
- org.apache.flink.statefun.examples.ridesharing.simulator.configurations.KafkaProducerConfig
- org.apache.flink.statefun.e2e.common.kafka.KafkaProtobufSerializer<T> (implements org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serializer<T>)
- org.apache.flink.statefun.flink.io.kafka.KafkaSinkProvider (implements org.apache.flink.statefun.flink.io.spi.SinkProvider)
- org.apache.flink.statefun.flink.io.kafka.KafkaSourceProvider (implements org.apache.flink.statefun.flink.io.spi.SourceProvider)
- org.apache.flink.statefun.sdk.kafka.KafkaTopicPartition
- org.apache.flink.statefun.flink.core.common.KeyBy
- org.apache.flink.statefun.flink.core.logger.KeyGroupStreamFactory<T> (implements java.util.function.Supplier<T>)
- org.apache.flink.statefun.flink.io.generated.KinesisEgress
- org.apache.flink.statefun.sdk.kinesis.egress.KinesisEgressBuilder<T>
- org.apache.flink.statefun.sdk.kinesis.egress.KinesisEgressSpec<T> (implements org.apache.flink.statefun.sdk.io.EgressSpec<T>)
- org.apache.flink.statefun.flink.io.kinesis.KinesisFlinkIOModule (implements org.apache.flink.statefun.flink.io.spi.FlinkIoModule)
- org.apache.flink.statefun.sdk.kinesis.ingress.KinesisIngressBuilder<T>
- org.apache.flink.statefun.sdk.kinesis.ingress.KinesisIngressBuilderApiExtension
- org.apache.flink.statefun.sdk.kinesis.ingress.KinesisIngressSpec<T> (implements org.apache.flink.statefun.sdk.io.IngressSpec<T>)
- org.apache.flink.statefun.sdk.kinesis.ingress.KinesisIngressStartupPosition
- org.apache.flink.statefun.sdk.kinesis.KinesisIOTypes
- org.apache.flink.statefun.flink.io.kinesis.KinesisSinkProvider (implements org.apache.flink.statefun.flink.io.spi.SinkProvider)
- org.apache.flink.statefun.flink.io.kinesis.KinesisSourceProvider (implements org.apache.flink.statefun.flink.io.spi.SourceProvider)
- org.apache.flink.statefun.flink.core.di.Lazy<T>
- org.apache.flink.statefun.examples.ridesharing.simulator.simulation.engine.LifecycleMessages
- org.apache.flink.statefun.flink.core.feedback.LockFreeBatchFeedbackQueue<ElementT>
- org.apache.flink.statefun.flink.core.queue.Locks
- org.apache.flink.statefun.flink.core.logger.Loggers
- org.apache.flink.statefun.flink.core.common.MailboxExecutorFacade (implements java.util.concurrent.Executor)
- org.apache.flink.statefun.examples.ridesharing.simulator.Main
- org.apache.flink.statefun.flink.core.common.Maps
- org.apache.flink.statefun.sdk.match.MatchBinder
- org.apache.flink.statefun.testutils.matchers.MatchersByAddress
- org.apache.flink.statefun.flink.core.message.MessageFactory
- org.apache.flink.statefun.flink.core.message.MessageKeySelector (implements org.apache.flink.api.java.functions.KeySelector<IN,KEY>)
- org.apache.flink.statefun.flink.core.message.MessagePayloadSerializerKryo (implements org.apache.flink.statefun.flink.core.message.MessagePayloadSerializer)
- org.apache.flink.statefun.flink.core.message.MessagePayloadSerializerMultiLanguage (implements org.apache.flink.statefun.flink.core.message.MessagePayloadSerializer)
- org.apache.flink.statefun.flink.core.message.MessagePayloadSerializerPb (implements org.apache.flink.statefun.flink.core.message.MessagePayloadSerializer)
- org.apache.flink.statefun.flink.core.message.MessagePayloadSerializerRaw (implements org.apache.flink.statefun.flink.core.message.MessagePayloadSerializer)
- org.apache.flink.statefun.flink.core.message.MessageTypeSerializer.Snapshot (implements org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>)
- org.apache.flink.statefun.examples.ridesharing.Module (implements org.apache.flink.statefun.sdk.spi.StatefulFunctionModule)
- org.apache.flink.statefun.examples.async.Module (implements org.apache.flink.statefun.sdk.spi.StatefulFunctionModule)
- org.apache.flink.statefun.flink.core.spi.Modules
- org.apache.flink.statefun.flink.core.spi.ModuleSpecs (implements java.lang.Iterable<T>, java.io.Serializable)
- org.apache.flink.statefun.flink.core.spi.ModuleSpecs.ModuleSpec (implements java.io.Serializable)
- org.apache.flink.statefun.flink.core.queue.MpscQueue<T>
- org.apache.flink.statefun.examples.harness.MyModule (implements org.apache.flink.statefun.sdk.spi.StatefulFunctionModule)
- org.apache.flink.statefun.flink.common.json.NamespaceNamePair
- org.apache.flink.statefun.flink.core.di.ObjectContainer
- it.unimi.dsi.fastutil.objects.ObjectOpenHashMap<K,V>
- org.apache.flink.statefun.examples.ridesharing.simulator.simulation.Passenger (implements org.apache.flink.statefun.examples.ridesharing.simulator.simulation.engine.Simulatee)
- org.apache.flink.statefun.sdk.state.PersistedAppendingBuffer<E>
- org.apache.flink.statefun.sdk.state.PersistedTable<K,V>
- org.apache.flink.statefun.sdk.state.PersistedValue<T>
- org.apache.flink.statefun.flink.io.kinesis.PolyglotKinesisIOTypes
- org.apache.flink.statefun.flink.core.common.PolyglotUtil
- org.apache.flink.statefun.flink.common.protobuf.ProtobufDescriptorMap
- org.apache.flink.statefun.flink.io.kafka.ProtobufKafkaIngressTypes
- org.apache.flink.statefun.examples.shoppingcart.generated.ProtobufMessages
- org.apache.flink.statefun.flink.common.protopath.ProtobufPath
- org.apache.flink.statefun.flink.common.protobuf.ProtobufReflectionUtil
- org.apache.flink.statefun.flink.core.protorouter.ProtobufRouter (implements org.apache.flink.statefun.sdk.io.Router<InT>)
- org.apache.flink.statefun.flink.common.protobuf.ProtobufSerializer<M>
- org.apache.flink.statefun.flink.common.protobuf.ProtobufTypeSerializerSnapshot<M> (implements org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<T>)
- org.apache.flink.statefun.flink.io.common.ReflectionUtil
- org.apache.flink.statefun.e2e.remote.generated.RemoteModuleVerification
- org.apache.flink.statefun.flink.core.reqreply.RequestReplyFunction (implements org.apache.flink.statefun.sdk.StatefulFunction)
- org.apache.flink.statefun.flink.common.ResourceLocator
- org.apache.flink.statefun.examples.ridesharing.generated.Ridesharing
- org.apache.flink.statefun.flink.io.generated.Routable
- org.apache.flink.statefun.flink.io.kafka.RoutableProtobufKafkaIngressDeserializer (implements org.apache.flink.statefun.sdk.kafka.KafkaIngressDeserializer<T>)
- org.apache.flink.statefun.flink.io.kinesis.polyglot.RoutableProtobufKinesisIngressDeserializer (implements org.apache.flink.statefun.sdk.kinesis.ingress.KinesisIngressDeserializer<T>)
- org.apache.flink.statefun.flink.io.kinesis.polyglot.RoutableProtobufKinesisSourceProvider (implements org.apache.flink.statefun.flink.io.spi.SourceProvider)
- org.apache.flink.statefun.e2e.sanity.SanityVerificationModule (implements org.apache.flink.statefun.sdk.spi.StatefulFunctionModule)
- org.apache.flink.statefun.examples.ridesharing.simulator.simulation.engine.Scheduler
- org.apache.flink.statefun.flink.common.json.Selectors
- org.apache.flink.statefun.flink.common.generated.Serializer
- org.apache.flink.statefun.flink.common.SetContextClassLoader (implements java.io.Closeable)
- org.apache.flink.statefun.examples.shoppingcart.ShoppingCartModule (implements org.apache.flink.statefun.sdk.spi.StatefulFunctionModule)
- org.apache.flink.statefun.flink.core.pool.SimplePool<ElementT>
- org.apache.flink.statefun.examples.ridesharing.simulator.simulation.Simulation
- org.apache.flink.statefun.examples.ridesharing.simulator.model.SimulationStartedEvent
- org.apache.flink.statefun.flink.core.cache.SingleThreadedLruCache<K,V>
- org.apache.flink.statefun.flink.io.datastream.SinkFunctionSpec<T> (implements org.apache.flink.statefun.sdk.io.EgressSpec<T>, java.io.Serializable)
- org.apache.flink.statefun.flink.io.datastream.SourceFunctionSpec<T> (implements org.apache.flink.statefun.sdk.io.IngressSpec<T>, java.io.Serializable)
- org.apache.flink.statefun.flink.io.datastream.SourceSinkModule (implements org.apache.flink.statefun.flink.io.spi.FlinkIoModule)
- org.apache.flink.statefun.flink.core.state.StateBinder
- org.apache.flink.statefun.flink.state.processor.operator.StateBootstrapFunctionRegistry (implements java.io.Serializable)
- org.apache.flink.statefun.testutils.matchers.StatefulFunctionMatchers
- org.apache.flink.statefun.flink.core.generated.StatefulFunctions
- org.apache.flink.statefun.e2e.common.StatefulFunctionsAppContainers.Builder
- org.apache.flink.statefun.flink.launcher.StatefulFunctionsClusterConfigurationParserFactory (implements org.apache.flink.runtime.entrypoint.parser.ParserResultFactory<T>)
- org.apache.flink.statefun.flink.core.StatefulFunctionsConfig (implements java.io.Serializable)
- org.apache.flink.statefun.flink.core.StatefulFunctionsConfigValidator
- org.apache.flink.statefun.flink.core.StatefulFunctionsJob
- org.apache.flink.statefun.flink.core.StatefulFunctionsJobConstants
- org.apache.flink.statefun.flink.state.processor.StatefulFunctionsSavepointCreator
- org.apache.flink.statefun.flink.core.StatefulFunctionsUniverse (implements org.apache.flink.statefun.flink.io.spi.FlinkIoModule.Binder, org.apache.flink.statefun.sdk.spi.StatefulFunctionModule.Binder)
- org.apache.flink.statefun.flink.core.StatefulFunctionsUniverses
- org.apache.flink.statefun.sdk.match.StatefulMatchFunction (implements org.apache.flink.statefun.sdk.StatefulFunction)
- org.apache.flink.statefun.flink.core.httpfn.StateSpec
- org.apache.flink.statefun.flink.core.types.StaticallyRegisteredTypes
- org.apache.flink.statefun.flink.core.feedback.SubtaskFeedbackKey<V> (implements java.io.Serializable)
- org.apache.flink.statefun.flink.harness.io.SupplyingIngressSpec<T> (implements org.apache.flink.statefun.sdk.io.IngressSpec<T>, java.io.Serializable)
- org.apache.flink.statefun.flink.state.processor.union.TaggedBootstrapData
- org.apache.flink.statefun.examples.async.events.TaskCompletionEvent
- org.apache.flink.statefun.examples.async.events.TaskStartedEvent
- org.apache.flink.statefun.examples.async.service.TaskStatus
- org.apache.flink.statefun.flink.common.protobuf.generated.TestProtos
- org.apache.flink.statefun.flink.core.protorouter.generated.TestProtos
- org.apache.flink.statefun.flink.core.backpressure.ThresholdBackPressureValve (implements org.apache.flink.statefun.flink.core.backpressure.BackPressureValve)
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- java.lang.RuntimeException
- org.apache.flink.api.common.typeinfo.TypeInformation<T> (implements java.io.Serializable)
- org.apache.flink.api.common.typeutils.TypeSerializer<T> (implements java.io.Serializable)
- org.apache.flink.statefun.flink.core.logger.UnboundedFeedbackLogger<T> (implements org.apache.flink.statefun.flink.core.logger.FeedbackLogger<T>)
- org.apache.flink.statefun.flink.core.logger.UnboundedFeedbackLoggerFactory<T>
- org.apache.flink.statefun.e2e.sanity.generated.VerificationMessages
- org.apache.flink.statefun.examples.ridesharing.simulator.configurations.WebSocketConfig (implements org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer)
- org.apache.flink.statefun.examples.ridesharing.simulator.model.WebsocketDriverEvent
- org.apache.flink.statefun.examples.ridesharing.simulator.model.WebsocketDriverEvent.Builder
- org.apache.flink.statefun.examples.ridesharing.simulator.model.WebsocketDriverEvent.RideInformation
- org.apache.flink.statefun.examples.ridesharing.simulator.model.WebsocketPassengerEvent
- org.apache.flink.statefun.examples.ridesharing.simulator.model.WebsocketPassengerEvent.Builder
Interface Hierarchy
Annotation Type Hierarchy
- org.apache.flink.statefun.sdk.annotations.ForRuntime (implements java.lang.annotation.Annotation)
- org.apache.flink.statefun.sdk.annotations.Persisted (implements java.lang.annotation.Annotation)
- org.apache.flink.statefun.flink.core.di.Inject (implements java.lang.annotation.Annotation)
- org.apache.flink.statefun.flink.core.di.Label (implements java.lang.annotation.Annotation)
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.