Class Hierarchy
- java.lang.Object
- io.hstream.BatchSetting
- io.hstream.BatchSetting.Builder
- io.hstream.Cluster
- io.hstream.Cluster.Builder
- io.hstream.Connector
- io.hstream.Connector.ConnectorBuilder
- io.hstream.ConsumerInformation
- io.hstream.ConsumerInformation.Builder
- io.hstream.CreateConnectorRequest
- io.hstream.CreateConnectorRequest.CreateConnectorRequestBuilder
- io.hstream.FlowControlSetting
- io.hstream.FlowControlSetting.Builder
- io.hstream.GetStreamResponse
- io.hstream.GetStreamResponse.Builder
- io.hstream.GetSubscriptionResponse
- io.hstream.GetSubscriptionResponse.Builder
- io.hstream.HArray
- io.hstream.HArrayBuilder
- io.hstream.HRecord
- io.hstream.HRecordBuilder
- io.hstream.HServerException.ErrBody
- io.hstream.Query
- io.hstream.Query.Builder
- io.hstream.ReceivedHRecord
- io.hstream.ReceivedRawRecord
- io.hstream.ReceivedRecord
- io.hstream.Record
- io.hstream.Record.Builder
- io.hstream.RecordHeader
- io.hstream.RecordHeader.Builder
- io.hstream.Shard
- io.hstream.Stream
- io.hstream.Stream.Builder
- io.hstream.StreamShardOffset
- io.hstream.Subscription
- io.hstream.Subscription.Builder
- io.hstream.SubscriptionOffset
- io.hstream.SubscriptionOffset.Builder
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- java.lang.RuntimeException
- io.hstream.HServerException
- io.hstream.HStreamDBClientException
- io.hstream.HStreamDBClientException.ConsumerException
- io.hstream.HStreamDBClientException.InvalidRecordException
- io.hstream.HStreamDBClientException.SubscribeException
- java.lang.RuntimeException
- java.lang.Exception
- io.hstream.View
- io.hstream.View.Builder
Interface Hierarchy
- java.lang.AutoCloseable
- java.io.Closeable
- io.hstream.BufferedProducer (also extends io.hstream.Producer)
- io.hstream.HStreamClient
- io.hstream.Reader
- io.hstream.StreamKeyReader
- java.io.Closeable
- io.hstream.BatchAckResponder
- io.hstream.BatchReceiver
- io.hstream.BufferedProducerBuilder
- io.hstream.ConsumerBuilder
- io.hstream.HRecordReceiver
- io.hstream.HStreamClientBuilder
- io.hstream.Observer<V>
- io.hstream.Producer
- io.hstream.BufferedProducer (also extends java.io.Closeable)
- io.hstream.ProducerBuilder
- io.hstream.QueryerBuilder
- io.hstream.RawRecordReceiver
- io.hstream.ReaderBuilder
- io.hstream.Responder
- com.google.common.util.concurrent.Service
- io.hstream.Consumer
- io.hstream.Queryer
- io.hstream.StreamShardReader
- io.hstream.StreamKeyReaderBuilder
- io.hstream.StreamShardReaderBatchReceiver
- io.hstream.StreamShardReaderBuilder
- io.hstream.StreamShardReaderReceiver
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- io.hstream.CompressionType
- io.hstream.ConnectorType
- io.hstream.Query.QueryType
- io.hstream.StreamShardOffset.OffsetType
- io.hstream.StreamShardOffset.SpecialOffset
- io.hstream.Subscription.SubscriptionOffset
- io.hstream.TaskStatus
- io.hstream.UrlSchema
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)