Package io.hstream
-
Interface Summary Interface Description BatchAckResponder BatchReceiver BufferedProducer The interface for the HStream BufferedProducer.BufferedProducerBuilder A builder forBufferedProducer
s.Consumer The interface for the HStream consumer.ConsumerBuilder A builder forConsumer
s.HRecordReceiver HStreamClient A client for the HStreamDB.HStreamClientBuilder A builder forHStreamClient
s.Observer<V> An object used to receive results of aQueryer
.Producer The interface for the HStream producer, all of methods are thread-safeProducerBuilder A builder forProducer
s.Queryer Deprecated. QueryerBuilder Deprecated. RawRecordReceiver This interface can be implemented by users ofConsumer
to receive raw records.Reader Deprecated. ReaderBuilder Deprecated. Responder An object used to send acks to the HStream servers.StreamKeyReader StreamKeyReaderBuilder StreamShardReader StreamShardReaderBatchReceiver StreamShardReaderBuilder StreamShardReaderReceiver -
Class Summary Class Description BatchSetting BatchSetting.Builder Cluster Cluster.Builder Connector Connector.ConnectorBuilder ConsumerInformation ConsumerInformation.Builder CreateConnectorRequest CreateConnectorRequest.CreateConnectorRequestBuilder FlowControlSetting FlowControlSetting.Builder GetStreamResponse GetStreamResponse.Builder GetSubscriptionResponse GetSubscriptionResponse.Builder HArray A data structure like arrayHArrayBuilder A builder forHArray
s.HRecord A data structure like json object.HRecordBuilder A builder forHRecord
s.HServerException.ErrBody Query Query.Builder ReceivedHRecord An object that represents a receivedHRecord
format record.ReceivedRawRecord An object that represents a received raw record.ReceivedRecord Record Record.Builder RecordHeader RecordHeader.Builder Shard Stream Stream.Builder StreamShardOffset Subscription Subscription.Builder SubscriptionOffset SubscriptionOffset.Builder View View.Builder -
Enum Summary Enum Description CompressionType ConnectorType Query.QueryType StreamShardOffset.OffsetType StreamShardOffset.SpecialOffset Subscription.SubscriptionOffset TaskStatus UrlSchema -
Exception Summary Exception Description HServerException HStreamDBClientException Client exception definitionHStreamDBClientException.ConsumerException HStreamDBClientException.InvalidRecordException HStreamDBClientException.SubscribeException