Hierarchy For Package com.here.platform.data.client.service.stream

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • scala.runtime.AbstractFunction3<T1,T2,T3,R> (implements scala.Function3<T1,T2,T3,R>)
    • com.here.platform.data.client.service.stream.endpoints.Consume$ (implements java.io.Serializable)
    • com.here.platform.data.client.service.stream.endpoints.Unsubscribe$ (implements java.io.Serializable)
  • scala.runtime.AbstractFunction4<T1,T2,T3,T4,R> (implements scala.Function4<T1,T2,T3,T4,R>)
    • com.here.platform.data.client.service.stream.endpoints.Commit$ (implements java.io.Serializable)
    • com.here.platform.data.client.service.stream.endpoints.Subscribe$ (implements java.io.Serializable)
  • com.here.platform.data.client.service.stream.CheckpointMark (implements scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.CommitOffsets (implements scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.DefaultStreamConfigProvider (implements com.here.platform.data.client.service.stream.StreamConfigProvider)
  • com.here.platform.data.client.service.stream.DefaultStreamService (implements com.here.platform.data.client.service.stream.StreamService)
  • com.here.platform.data.client.service.stream.EmbeddedStreamConfigProvider (implements com.here.platform.data.client.service.stream.StreamConfigProvider)
  • com.here.platform.data.client.service.stream.endpoints
  • com.here.platform.data.client.service.stream.endpoints.Commit (implements com.here.platform.data.client.service.stream.endpoints.StreamEndpoint, scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.endpoints.Consume (implements com.here.platform.data.client.service.stream.endpoints.StreamEndpoint, scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.endpoints.Subscribe (implements scala.Product, com.here.platform.data.client.http.RestEndpoint, java.io.Serializable, com.here.platform.data.client.service.stream.StreamApi)
  • com.here.platform.data.client.service.stream.endpoints.Unsubscribe (implements com.here.platform.data.client.service.stream.endpoints.StreamEndpoint, scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.GetKafkaSettings (implements scala.Product, com.here.platform.data.client.http.RestEndpoint, java.io.Serializable, com.here.platform.data.client.service.stream.StreamApi)
  • org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,M> (implements org.apache.pekko.stream.Graph<S,M>)
    • com.here.platform.data.client.service.stream.StreamSourceStage
  • com.here.platform.data.client.service.stream.KafkaEndpoint (implements scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.KafkaEndpoints (implements scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.KafkaStreamSettings (implements scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.NotificationParser
  • com.here.platform.data.client.service.stream.StreamMessage (implements scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.StreamMessageMetadata (implements scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.StreamMessageOffset (implements scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.StreamOutput (implements scala.Product, java.io.Serializable)
  • com.here.platform.data.client.service.stream.StreamPartitionMessage (implements com.here.platform.data.client.service.stream.HasCheckpointing, com.here.platform.data.client.scaladsl.Partition)
    • com.here.platform.data.client.service.stream.StreamEmbeddedPartitionMessage (implements com.here.platform.data.client.scaladsl.EmbeddedData, scala.Product, java.io.Serializable)
    • com.here.platform.data.client.service.stream.StreamReferencedPartitionMessage (implements scala.Product, com.here.platform.data.client.scaladsl.ReferenceData, java.io.Serializable)
  • com.here.platform.data.client.service.stream.StreamSubscription (implements scala.Product, java.io.Serializable)

Interface Hierarchy

• com.here.platform.data.client.http.Api
  • com.here.platform.data.client.http.Endpoint
    • com.here.platform.data.client.http.HyperMediaEndpoint
      • com.here.platform.data.client.service.stream.endpoints.StreamEndpoint (also extends com.here.platform.data.client.service.stream.StreamApi)
  • com.here.platform.data.client.service.stream.StreamApi
    • com.here.platform.data.client.service.stream.endpoints.StreamEndpoint (also extends com.here.platform.data.client.http.HyperMediaEndpoint)
• com.here.platform.data.client.service.stream.DirectKafka
• com.here.platform.data.client.service.stream.HasCheckpointing
• com.here.platform.data.client.service.stream.StreamConfigProvider
• com.here.platform.data.client.service.stream.StreamService