Package io.hstream
-
Interface Summary Interface Description BatchAckResponder BatchReceiver BufferedProducer The interface for the HStream BufferedProducer.BufferedProducerBuilder A builder forBufferedProducers.Consumer The interface for the HStream consumer.ConsumerBuilder A builder forConsumers.HRecordReceiver HStreamClient A client for the HStreamDB.HStreamClientBuilder A builder forHStreamClients.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 forProducers.Queryer Deprecated. QueryerBuilder Deprecated. RawRecordReceiver This interface can be implemented by users ofConsumerto 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 forHArrays.HRecord A data structure like json object.HRecordBuilder A builder forHRecords.HServerException.ErrBody Query Query.Builder ReceivedHRecord An object that represents a receivedHRecordformat 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