Hierarchy For All Packages

Package Hierarchies:

• io.hstream,
• io.hstream.internal

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)
        • io.hstream.internal.AdminCommandRequest (implements io.hstream.internal.AdminCommandRequestOrBuilder)
        • io.hstream.internal.AdminCommandResponse (implements io.hstream.internal.AdminCommandResponseOrBuilder)
        • io.hstream.internal.AlterConnectorConfigRequest (implements io.hstream.internal.AlterConnectorConfigRequestOrBuilder)
        • io.hstream.internal.AppendRequest (implements io.hstream.internal.AppendRequestOrBuilder)
        • io.hstream.internal.AppendResponse (implements io.hstream.internal.AppendResponseOrBuilder)
        • io.hstream.internal.BatchedRecord (implements io.hstream.internal.BatchedRecordOrBuilder)
        • io.hstream.internal.BatchHStreamRecords (implements io.hstream.internal.BatchHStreamRecordsOrBuilder)
        • io.hstream.internal.CheckSubscriptionExistRequest (implements io.hstream.internal.CheckSubscriptionExistRequestOrBuilder)
        • io.hstream.internal.CheckSubscriptionExistResponse (implements io.hstream.internal.CheckSubscriptionExistResponseOrBuilder)
        • io.hstream.internal.ColumnCatalog (implements io.hstream.internal.ColumnCatalogOrBuilder)
        • io.hstream.internal.CommandConnect (implements io.hstream.internal.CommandConnectOrBuilder)
        • io.hstream.internal.CommandConnected (implements io.hstream.internal.CommandConnectedOrBuilder)
        • io.hstream.internal.CommandQuery (implements io.hstream.internal.CommandQueryOrBuilder)
        • io.hstream.internal.CommandQueryResponse (implements io.hstream.internal.CommandQueryResponseOrBuilder)
        • io.hstream.internal.CommandStreamTask (implements io.hstream.internal.CommandStreamTaskOrBuilder)
        • io.hstream.internal.CommandStreamTaskResponse (implements io.hstream.internal.CommandStreamTaskResponseOrBuilder)
        • io.hstream.internal.Connector (implements io.hstream.internal.ConnectorOrBuilder)
        • io.hstream.internal.Consumer (implements io.hstream.internal.ConsumerOrBuilder)
        • io.hstream.internal.CreateConnectorRequest (implements io.hstream.internal.CreateConnectorRequestOrBuilder)
        • io.hstream.internal.CreateQueryRequest (implements io.hstream.internal.CreateQueryRequestOrBuilder)
        • io.hstream.internal.CreateQueryWithNamespaceRequest (implements io.hstream.internal.CreateQueryWithNamespaceRequestOrBuilder)
        • io.hstream.internal.CreateShardReaderRequest (implements io.hstream.internal.CreateShardReaderRequestOrBuilder)
        • io.hstream.internal.CreateShardReaderResponse (implements io.hstream.internal.CreateShardReaderResponseOrBuilder)
        • io.hstream.internal.DeleteConnectorRequest (implements io.hstream.internal.DeleteConnectorRequestOrBuilder)
        • io.hstream.internal.DeleteQueryRequest (implements io.hstream.internal.DeleteQueryRequestOrBuilder)
        • io.hstream.internal.DeleteShardReaderRequest (implements io.hstream.internal.DeleteShardReaderRequestOrBuilder)
        • io.hstream.internal.DeleteStreamRequest (implements io.hstream.internal.DeleteStreamRequestOrBuilder)
        • io.hstream.internal.DeleteSubscriptionRequest (implements io.hstream.internal.DeleteSubscriptionRequestOrBuilder)
        • io.hstream.internal.DeleteViewRequest (implements io.hstream.internal.DeleteViewRequestOrBuilder)
        • io.hstream.internal.DescribeClusterResponse (implements io.hstream.internal.DescribeClusterResponseOrBuilder)
        • io.hstream.internal.EchoRequest (implements io.hstream.internal.EchoRequestOrBuilder)
        • io.hstream.internal.EchoResponse (implements io.hstream.internal.EchoResponseOrBuilder)
        • io.hstream.internal.ExecuteViewQueryRequest (implements io.hstream.internal.ExecuteViewQueryRequestOrBuilder)
        • io.hstream.internal.ExecuteViewQueryResponse (implements io.hstream.internal.ExecuteViewQueryResponseOrBuilder)
        • io.hstream.internal.ExecuteViewQuerySql (implements io.hstream.internal.ExecuteViewQuerySqlOrBuilder)
        • io.hstream.internal.ExecuteViewQueryWithNamespaceRequest (implements io.hstream.internal.ExecuteViewQueryWithNamespaceRequestOrBuilder)
        • io.hstream.internal.GetConnectorLogsRequest (implements io.hstream.internal.GetConnectorLogsRequestOrBuilder)
        • io.hstream.internal.GetConnectorLogsResponse (implements io.hstream.internal.GetConnectorLogsResponseOrBuilder)
        • io.hstream.internal.GetConnectorRequest (implements io.hstream.internal.GetConnectorRequestOrBuilder)
        • io.hstream.internal.GetConnectorSpecRequest (implements io.hstream.internal.GetConnectorSpecRequestOrBuilder)
        • io.hstream.internal.GetConnectorSpecResponse (implements io.hstream.internal.GetConnectorSpecResponseOrBuilder)
        • io.hstream.internal.GetQueryRequest (implements io.hstream.internal.GetQueryRequestOrBuilder)
        • io.hstream.internal.GetSchemaRequest (implements io.hstream.internal.GetSchemaRequestOrBuilder)
        • io.hstream.internal.GetStatsRequest (implements io.hstream.internal.GetStatsRequestOrBuilder)
        • io.hstream.internal.GetStatsResponse (implements io.hstream.internal.GetStatsResponseOrBuilder)
        • io.hstream.internal.GetStreamRequest (implements io.hstream.internal.GetStreamRequestOrBuilder)
        • io.hstream.internal.GetStreamResponse (implements io.hstream.internal.GetStreamResponseOrBuilder)
        • io.hstream.internal.GetSubscriptionRequest (implements io.hstream.internal.GetSubscriptionRequestOrBuilder)
        • io.hstream.internal.GetSubscriptionResponse (implements io.hstream.internal.GetSubscriptionResponseOrBuilder)
        • io.hstream.internal.GetTailRecordIdRequest (implements io.hstream.internal.GetTailRecordIdRequestOrBuilder)
        • io.hstream.internal.GetTailRecordIdResponse (implements io.hstream.internal.GetTailRecordIdResponseOrBuilder)
        • io.hstream.internal.GetViewRequest (implements io.hstream.internal.GetViewRequestOrBuilder)
        • io.hstream.internal.HStreamRecord (implements io.hstream.internal.HStreamRecordOrBuilder)
        • io.hstream.internal.HStreamRecordHeader (implements io.hstream.internal.HStreamRecordHeaderOrBuilder)
        • io.hstream.internal.HStreamVersion (implements io.hstream.internal.HStreamVersionOrBuilder)
        • io.hstream.internal.ListConnectorsRequest (implements io.hstream.internal.ListConnectorsRequestOrBuilder)
        • io.hstream.internal.ListConnectorsResponse (implements io.hstream.internal.ListConnectorsResponseOrBuilder)
        • io.hstream.internal.ListConsumersRequest (implements io.hstream.internal.ListConsumersRequestOrBuilder)
        • io.hstream.internal.ListConsumersResponse (implements io.hstream.internal.ListConsumersResponseOrBuilder)
        • io.hstream.internal.ListQueriesRequest (implements io.hstream.internal.ListQueriesRequestOrBuilder)
        • io.hstream.internal.ListQueriesResponse (implements io.hstream.internal.ListQueriesResponseOrBuilder)
        • io.hstream.internal.ListShardReadersRequest (implements io.hstream.internal.ListShardReadersRequestOrBuilder)
        • io.hstream.internal.ListShardReadersResponse (implements io.hstream.internal.ListShardReadersResponseOrBuilder)
        • io.hstream.internal.ListShardsRequest (implements io.hstream.internal.ListShardsRequestOrBuilder)
        • io.hstream.internal.ListShardsResponse (implements io.hstream.internal.ListShardsResponseOrBuilder)
        • io.hstream.internal.ListStreamsRequest (implements io.hstream.internal.ListStreamsRequestOrBuilder)
        • io.hstream.internal.ListStreamsResponse (implements io.hstream.internal.ListStreamsResponseOrBuilder)
        • io.hstream.internal.ListStreamsWithPrefixRequest (implements io.hstream.internal.ListStreamsWithPrefixRequestOrBuilder)
        • io.hstream.internal.ListSubscriptionsRequest (implements io.hstream.internal.ListSubscriptionsRequestOrBuilder)
        • io.hstream.internal.ListSubscriptionsResponse (implements io.hstream.internal.ListSubscriptionsResponseOrBuilder)
        • io.hstream.internal.ListSubscriptionsWithPrefixRequest (implements io.hstream.internal.ListSubscriptionsWithPrefixRequestOrBuilder)
        • io.hstream.internal.ListViewsRequest (implements io.hstream.internal.ListViewsRequestOrBuilder)
        • io.hstream.internal.ListViewsResponse (implements io.hstream.internal.ListViewsResponseOrBuilder)
        • io.hstream.internal.LookupKeyRequest (implements io.hstream.internal.LookupKeyRequestOrBuilder)
        • io.hstream.internal.LookupResourceRequest (implements io.hstream.internal.LookupResourceRequestOrBuilder)
        • io.hstream.internal.LookupShardReaderRequest (implements io.hstream.internal.LookupShardReaderRequestOrBuilder)
        • io.hstream.internal.LookupShardReaderResponse (implements io.hstream.internal.LookupShardReaderResponseOrBuilder)
        • io.hstream.internal.LookupShardRequest (implements io.hstream.internal.LookupShardRequestOrBuilder)
        • io.hstream.internal.LookupShardResponse (implements io.hstream.internal.LookupShardResponseOrBuilder)
        • io.hstream.internal.LookupSubscriptionRequest (implements io.hstream.internal.LookupSubscriptionRequestOrBuilder)
        • io.hstream.internal.LookupSubscriptionResponse (implements io.hstream.internal.LookupSubscriptionResponseOrBuilder)
        • io.hstream.internal.ParseSqlRequest (implements io.hstream.internal.ParseSqlRequestOrBuilder)
        • io.hstream.internal.ParseSqlResponse (implements io.hstream.internal.ParseSqlResponseOrBuilder)
        • io.hstream.internal.PauseConnectorRequest (implements io.hstream.internal.PauseConnectorRequestOrBuilder)
        • io.hstream.internal.PauseQueryRequest (implements io.hstream.internal.PauseQueryRequestOrBuilder)
        • io.hstream.internal.PerStreamTimeSeriesStatsAllRequest (implements io.hstream.internal.PerStreamTimeSeriesStatsAllRequestOrBuilder)
        • io.hstream.internal.PerStreamTimeSeriesStatsAllResponse (implements io.hstream.internal.PerStreamTimeSeriesStatsAllResponseOrBuilder)
        • io.hstream.internal.PerStreamTimeSeriesStatsRequest (implements io.hstream.internal.PerStreamTimeSeriesStatsRequestOrBuilder)
        • io.hstream.internal.PerStreamTimeSeriesStatsResponse (implements io.hstream.internal.PerStreamTimeSeriesStatsResponseOrBuilder)
        • io.hstream.internal.Query (implements io.hstream.internal.QueryOrBuilder)
        • io.hstream.internal.ReadShardRequest (implements io.hstream.internal.ReadShardRequestOrBuilder)
        • io.hstream.internal.ReadShardResponse (implements io.hstream.internal.ReadShardResponseOrBuilder)
        • io.hstream.internal.ReadShardStreamRequest (implements io.hstream.internal.ReadShardStreamRequestOrBuilder)
        • io.hstream.internal.ReadShardStreamResponse (implements io.hstream.internal.ReadShardStreamResponseOrBuilder)
        • io.hstream.internal.ReadSingleShardStreamRequest (implements io.hstream.internal.ReadSingleShardStreamRequestOrBuilder)
        • io.hstream.internal.ReadSingleShardStreamResponse (implements io.hstream.internal.ReadSingleShardStreamResponseOrBuilder)
        • io.hstream.internal.ReadStreamByKeyRequest (implements io.hstream.internal.ReadStreamByKeyRequestOrBuilder)
        • io.hstream.internal.ReadStreamByKeyResponse (implements io.hstream.internal.ReadStreamByKeyResponseOrBuilder)
        • io.hstream.internal.ReadStreamRequest (implements io.hstream.internal.ReadStreamRequestOrBuilder)
        • io.hstream.internal.ReadStreamResponse (implements io.hstream.internal.ReadStreamResponseOrBuilder)
        • io.hstream.internal.ReceivedRecord (implements io.hstream.internal.ReceivedRecordOrBuilder)
        • io.hstream.internal.RecordId (implements io.hstream.internal.RecordIdOrBuilder)
        • io.hstream.internal.ResumeConnectorRequest (implements io.hstream.internal.ResumeConnectorRequestOrBuilder)
        • io.hstream.internal.ResumeQueryRequest (implements io.hstream.internal.ResumeQueryRequestOrBuilder)
        • io.hstream.internal.Schema (implements io.hstream.internal.SchemaOrBuilder)
        • io.hstream.internal.ServerNode (implements io.hstream.internal.ServerNodeOrBuilder)
        • io.hstream.internal.ServerNodeStatus (implements io.hstream.internal.ServerNodeStatusOrBuilder)
        • io.hstream.internal.Shard (implements io.hstream.internal.ShardOrBuilder)
        • io.hstream.internal.ShardOffset (implements io.hstream.internal.ShardOffsetOrBuilder)
        • io.hstream.internal.StatError (implements io.hstream.internal.StatErrorOrBuilder)
        • io.hstream.internal.StatsDoubleVals (implements io.hstream.internal.StatsDoubleValsOrBuilder)
        • io.hstream.internal.StatsIntervalVals (implements io.hstream.internal.StatsIntervalValsOrBuilder)
        • io.hstream.internal.StatType (implements io.hstream.internal.StatTypeOrBuilder)
        • io.hstream.internal.StatValue (implements io.hstream.internal.StatValueOrBuilder)
        • io.hstream.internal.Stream (implements io.hstream.internal.StreamOrBuilder)
        • io.hstream.internal.StreamingFetchRequest (implements io.hstream.internal.StreamingFetchRequestOrBuilder)
        • io.hstream.internal.StreamingFetchResponse (implements io.hstream.internal.StreamingFetchResponseOrBuilder)
        • io.hstream.internal.StreamOffset (implements io.hstream.internal.StreamOffsetOrBuilder)
        • io.hstream.internal.Subscription (implements io.hstream.internal.SubscriptionOrBuilder)
        • io.hstream.internal.SubscriptionOffset (implements io.hstream.internal.SubscriptionOffsetOrBuilder)
        • io.hstream.internal.TerminateQueryRequest (implements io.hstream.internal.TerminateQueryRequestOrBuilder)
        • io.hstream.internal.TimestampOffset (implements io.hstream.internal.TimestampOffsetOrBuilder)
        • io.hstream.internal.TrimShardRequest (implements io.hstream.internal.TrimShardRequestOrBuilder)
        • io.hstream.internal.TrimShardsRequest (implements io.hstream.internal.TrimShardsRequestOrBuilder)
        • io.hstream.internal.TrimShardsResponse (implements io.hstream.internal.TrimShardsResponseOrBuilder)
        • io.hstream.internal.TrimStreamRequest (implements io.hstream.internal.TrimStreamRequestOrBuilder)
        • io.hstream.internal.UnregisterSchemaRequest (implements io.hstream.internal.UnregisterSchemaRequestOrBuilder)
        • io.hstream.internal.View (implements io.hstream.internal.ViewOrBuilder)
  • 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<BuilderT>
        • io.hstream.internal.AdminCommandRequest.Builder (implements io.hstream.internal.AdminCommandRequestOrBuilder)
        • io.hstream.internal.AdminCommandResponse.Builder (implements io.hstream.internal.AdminCommandResponseOrBuilder)
        • io.hstream.internal.AlterConnectorConfigRequest.Builder (implements io.hstream.internal.AlterConnectorConfigRequestOrBuilder)
        • io.hstream.internal.AppendRequest.Builder (implements io.hstream.internal.AppendRequestOrBuilder)
        • io.hstream.internal.AppendResponse.Builder (implements io.hstream.internal.AppendResponseOrBuilder)
        • io.hstream.internal.BatchedRecord.Builder (implements io.hstream.internal.BatchedRecordOrBuilder)
        • io.hstream.internal.BatchHStreamRecords.Builder (implements io.hstream.internal.BatchHStreamRecordsOrBuilder)
        • io.hstream.internal.CheckSubscriptionExistRequest.Builder (implements io.hstream.internal.CheckSubscriptionExistRequestOrBuilder)
        • io.hstream.internal.CheckSubscriptionExistResponse.Builder (implements io.hstream.internal.CheckSubscriptionExistResponseOrBuilder)
        • io.hstream.internal.ColumnCatalog.Builder (implements io.hstream.internal.ColumnCatalogOrBuilder)
        • io.hstream.internal.CommandConnect.Builder (implements io.hstream.internal.CommandConnectOrBuilder)
        • io.hstream.internal.CommandConnected.Builder (implements io.hstream.internal.CommandConnectedOrBuilder)
        • io.hstream.internal.CommandQuery.Builder (implements io.hstream.internal.CommandQueryOrBuilder)
        • io.hstream.internal.CommandQueryResponse.Builder (implements io.hstream.internal.CommandQueryResponseOrBuilder)
        • io.hstream.internal.CommandStreamTask.Builder (implements io.hstream.internal.CommandStreamTaskOrBuilder)
        • io.hstream.internal.CommandStreamTaskResponse.Builder (implements io.hstream.internal.CommandStreamTaskResponseOrBuilder)
        • io.hstream.internal.Connector.Builder (implements io.hstream.internal.ConnectorOrBuilder)
        • io.hstream.internal.Consumer.Builder (implements io.hstream.internal.ConsumerOrBuilder)
        • io.hstream.internal.CreateConnectorRequest.Builder (implements io.hstream.internal.CreateConnectorRequestOrBuilder)
        • io.hstream.internal.CreateQueryRequest.Builder (implements io.hstream.internal.CreateQueryRequestOrBuilder)
        • io.hstream.internal.CreateQueryWithNamespaceRequest.Builder (implements io.hstream.internal.CreateQueryWithNamespaceRequestOrBuilder)
        • io.hstream.internal.CreateShardReaderRequest.Builder (implements io.hstream.internal.CreateShardReaderRequestOrBuilder)
        • io.hstream.internal.CreateShardReaderResponse.Builder (implements io.hstream.internal.CreateShardReaderResponseOrBuilder)
        • io.hstream.internal.DeleteConnectorRequest.Builder (implements io.hstream.internal.DeleteConnectorRequestOrBuilder)
        • io.hstream.internal.DeleteQueryRequest.Builder (implements io.hstream.internal.DeleteQueryRequestOrBuilder)
        • io.hstream.internal.DeleteShardReaderRequest.Builder (implements io.hstream.internal.DeleteShardReaderRequestOrBuilder)
        • io.hstream.internal.DeleteStreamRequest.Builder (implements io.hstream.internal.DeleteStreamRequestOrBuilder)
        • io.hstream.internal.DeleteSubscriptionRequest.Builder (implements io.hstream.internal.DeleteSubscriptionRequestOrBuilder)
        • io.hstream.internal.DeleteViewRequest.Builder (implements io.hstream.internal.DeleteViewRequestOrBuilder)
        • io.hstream.internal.DescribeClusterResponse.Builder (implements io.hstream.internal.DescribeClusterResponseOrBuilder)
        • io.hstream.internal.EchoRequest.Builder (implements io.hstream.internal.EchoRequestOrBuilder)
        • io.hstream.internal.EchoResponse.Builder (implements io.hstream.internal.EchoResponseOrBuilder)
        • io.hstream.internal.ExecuteViewQueryRequest.Builder (implements io.hstream.internal.ExecuteViewQueryRequestOrBuilder)
        • io.hstream.internal.ExecuteViewQueryResponse.Builder (implements io.hstream.internal.ExecuteViewQueryResponseOrBuilder)
        • io.hstream.internal.ExecuteViewQuerySql.Builder (implements io.hstream.internal.ExecuteViewQuerySqlOrBuilder)
        • io.hstream.internal.ExecuteViewQueryWithNamespaceRequest.Builder (implements io.hstream.internal.ExecuteViewQueryWithNamespaceRequestOrBuilder)
        • io.hstream.internal.GetConnectorLogsRequest.Builder (implements io.hstream.internal.GetConnectorLogsRequestOrBuilder)
        • io.hstream.internal.GetConnectorLogsResponse.Builder (implements io.hstream.internal.GetConnectorLogsResponseOrBuilder)
        • io.hstream.internal.GetConnectorRequest.Builder (implements io.hstream.internal.GetConnectorRequestOrBuilder)
        • io.hstream.internal.GetConnectorSpecRequest.Builder (implements io.hstream.internal.GetConnectorSpecRequestOrBuilder)
        • io.hstream.internal.GetConnectorSpecResponse.Builder (implements io.hstream.internal.GetConnectorSpecResponseOrBuilder)
        • io.hstream.internal.GetQueryRequest.Builder (implements io.hstream.internal.GetQueryRequestOrBuilder)
        • io.hstream.internal.GetSchemaRequest.Builder (implements io.hstream.internal.GetSchemaRequestOrBuilder)
        • io.hstream.internal.GetStatsRequest.Builder (implements io.hstream.internal.GetStatsRequestOrBuilder)
        • io.hstream.internal.GetStatsResponse.Builder (implements io.hstream.internal.GetStatsResponseOrBuilder)
        • io.hstream.internal.GetStreamRequest.Builder (implements io.hstream.internal.GetStreamRequestOrBuilder)
        • io.hstream.internal.GetStreamResponse.Builder (implements io.hstream.internal.GetStreamResponseOrBuilder)
        • io.hstream.internal.GetSubscriptionRequest.Builder (implements io.hstream.internal.GetSubscriptionRequestOrBuilder)
        • io.hstream.internal.GetSubscriptionResponse.Builder (implements io.hstream.internal.GetSubscriptionResponseOrBuilder)
        • io.hstream.internal.GetTailRecordIdRequest.Builder (implements io.hstream.internal.GetTailRecordIdRequestOrBuilder)
        • io.hstream.internal.GetTailRecordIdResponse.Builder (implements io.hstream.internal.GetTailRecordIdResponseOrBuilder)
        • io.hstream.internal.GetViewRequest.Builder (implements io.hstream.internal.GetViewRequestOrBuilder)
        • io.hstream.internal.HStreamRecord.Builder (implements io.hstream.internal.HStreamRecordOrBuilder)
        • io.hstream.internal.HStreamRecordHeader.Builder (implements io.hstream.internal.HStreamRecordHeaderOrBuilder)
        • io.hstream.internal.HStreamVersion.Builder (implements io.hstream.internal.HStreamVersionOrBuilder)
        • io.hstream.internal.ListConnectorsRequest.Builder (implements io.hstream.internal.ListConnectorsRequestOrBuilder)
        • io.hstream.internal.ListConnectorsResponse.Builder (implements io.hstream.internal.ListConnectorsResponseOrBuilder)
        • io.hstream.internal.ListConsumersRequest.Builder (implements io.hstream.internal.ListConsumersRequestOrBuilder)
        • io.hstream.internal.ListConsumersResponse.Builder (implements io.hstream.internal.ListConsumersResponseOrBuilder)
        • io.hstream.internal.ListQueriesRequest.Builder (implements io.hstream.internal.ListQueriesRequestOrBuilder)
        • io.hstream.internal.ListQueriesResponse.Builder (implements io.hstream.internal.ListQueriesResponseOrBuilder)
        • io.hstream.internal.ListShardReadersRequest.Builder (implements io.hstream.internal.ListShardReadersRequestOrBuilder)
        • io.hstream.internal.ListShardReadersResponse.Builder (implements io.hstream.internal.ListShardReadersResponseOrBuilder)
        • io.hstream.internal.ListShardsRequest.Builder (implements io.hstream.internal.ListShardsRequestOrBuilder)
        • io.hstream.internal.ListShardsResponse.Builder (implements io.hstream.internal.ListShardsResponseOrBuilder)
        • io.hstream.internal.ListStreamsRequest.Builder (implements io.hstream.internal.ListStreamsRequestOrBuilder)
        • io.hstream.internal.ListStreamsResponse.Builder (implements io.hstream.internal.ListStreamsResponseOrBuilder)
        • io.hstream.internal.ListStreamsWithPrefixRequest.Builder (implements io.hstream.internal.ListStreamsWithPrefixRequestOrBuilder)
        • io.hstream.internal.ListSubscriptionsRequest.Builder (implements io.hstream.internal.ListSubscriptionsRequestOrBuilder)
        • io.hstream.internal.ListSubscriptionsResponse.Builder (implements io.hstream.internal.ListSubscriptionsResponseOrBuilder)
        • io.hstream.internal.ListSubscriptionsWithPrefixRequest.Builder (implements io.hstream.internal.ListSubscriptionsWithPrefixRequestOrBuilder)
        • io.hstream.internal.ListViewsRequest.Builder (implements io.hstream.internal.ListViewsRequestOrBuilder)
        • io.hstream.internal.ListViewsResponse.Builder (implements io.hstream.internal.ListViewsResponseOrBuilder)
        • io.hstream.internal.LookupKeyRequest.Builder (implements io.hstream.internal.LookupKeyRequestOrBuilder)
        • io.hstream.internal.LookupResourceRequest.Builder (implements io.hstream.internal.LookupResourceRequestOrBuilder)
        • io.hstream.internal.LookupShardReaderRequest.Builder (implements io.hstream.internal.LookupShardReaderRequestOrBuilder)
        • io.hstream.internal.LookupShardReaderResponse.Builder (implements io.hstream.internal.LookupShardReaderResponseOrBuilder)
        • io.hstream.internal.LookupShardRequest.Builder (implements io.hstream.internal.LookupShardRequestOrBuilder)
        • io.hstream.internal.LookupShardResponse.Builder (implements io.hstream.internal.LookupShardResponseOrBuilder)
        • io.hstream.internal.LookupSubscriptionRequest.Builder (implements io.hstream.internal.LookupSubscriptionRequestOrBuilder)
        • io.hstream.internal.LookupSubscriptionResponse.Builder (implements io.hstream.internal.LookupSubscriptionResponseOrBuilder)
        • io.hstream.internal.ParseSqlRequest.Builder (implements io.hstream.internal.ParseSqlRequestOrBuilder)
        • io.hstream.internal.ParseSqlResponse.Builder (implements io.hstream.internal.ParseSqlResponseOrBuilder)
        • io.hstream.internal.PauseConnectorRequest.Builder (implements io.hstream.internal.PauseConnectorRequestOrBuilder)
        • io.hstream.internal.PauseQueryRequest.Builder (implements io.hstream.internal.PauseQueryRequestOrBuilder)
        • io.hstream.internal.PerStreamTimeSeriesStatsAllRequest.Builder (implements io.hstream.internal.PerStreamTimeSeriesStatsAllRequestOrBuilder)
        • io.hstream.internal.PerStreamTimeSeriesStatsAllResponse.Builder (implements io.hstream.internal.PerStreamTimeSeriesStatsAllResponseOrBuilder)
        • io.hstream.internal.PerStreamTimeSeriesStatsRequest.Builder (implements io.hstream.internal.PerStreamTimeSeriesStatsRequestOrBuilder)
        • io.hstream.internal.PerStreamTimeSeriesStatsResponse.Builder (implements io.hstream.internal.PerStreamTimeSeriesStatsResponseOrBuilder)
        • io.hstream.internal.Query.Builder (implements io.hstream.internal.QueryOrBuilder)
        • io.hstream.internal.ReadShardRequest.Builder (implements io.hstream.internal.ReadShardRequestOrBuilder)
        • io.hstream.internal.ReadShardResponse.Builder (implements io.hstream.internal.ReadShardResponseOrBuilder)
        • io.hstream.internal.ReadShardStreamRequest.Builder (implements io.hstream.internal.ReadShardStreamRequestOrBuilder)
        • io.hstream.internal.ReadShardStreamResponse.Builder (implements io.hstream.internal.ReadShardStreamResponseOrBuilder)
        • io.hstream.internal.ReadSingleShardStreamRequest.Builder (implements io.hstream.internal.ReadSingleShardStreamRequestOrBuilder)
        • io.hstream.internal.ReadSingleShardStreamResponse.Builder (implements io.hstream.internal.ReadSingleShardStreamResponseOrBuilder)
        • io.hstream.internal.ReadStreamByKeyRequest.Builder (implements io.hstream.internal.ReadStreamByKeyRequestOrBuilder)
        • io.hstream.internal.ReadStreamByKeyResponse.Builder (implements io.hstream.internal.ReadStreamByKeyResponseOrBuilder)
        • io.hstream.internal.ReadStreamRequest.Builder (implements io.hstream.internal.ReadStreamRequestOrBuilder)
        • io.hstream.internal.ReadStreamResponse.Builder (implements io.hstream.internal.ReadStreamResponseOrBuilder)
        • io.hstream.internal.ReceivedRecord.Builder (implements io.hstream.internal.ReceivedRecordOrBuilder)
        • io.hstream.internal.RecordId.Builder (implements io.hstream.internal.RecordIdOrBuilder)
        • io.hstream.internal.ResumeConnectorRequest.Builder (implements io.hstream.internal.ResumeConnectorRequestOrBuilder)
        • io.hstream.internal.ResumeQueryRequest.Builder (implements io.hstream.internal.ResumeQueryRequestOrBuilder)
        • io.hstream.internal.Schema.Builder (implements io.hstream.internal.SchemaOrBuilder)
        • io.hstream.internal.ServerNode.Builder (implements io.hstream.internal.ServerNodeOrBuilder)
        • io.hstream.internal.ServerNodeStatus.Builder (implements io.hstream.internal.ServerNodeStatusOrBuilder)
        • io.hstream.internal.Shard.Builder (implements io.hstream.internal.ShardOrBuilder)
        • io.hstream.internal.ShardOffset.Builder (implements io.hstream.internal.ShardOffsetOrBuilder)
        • io.hstream.internal.StatError.Builder (implements io.hstream.internal.StatErrorOrBuilder)
        • io.hstream.internal.StatsDoubleVals.Builder (implements io.hstream.internal.StatsDoubleValsOrBuilder)
        • io.hstream.internal.StatsIntervalVals.Builder (implements io.hstream.internal.StatsIntervalValsOrBuilder)
        • io.hstream.internal.StatType.Builder (implements io.hstream.internal.StatTypeOrBuilder)
        • io.hstream.internal.StatValue.Builder (implements io.hstream.internal.StatValueOrBuilder)
        • io.hstream.internal.Stream.Builder (implements io.hstream.internal.StreamOrBuilder)
        • io.hstream.internal.StreamingFetchRequest.Builder (implements io.hstream.internal.StreamingFetchRequestOrBuilder)
        • io.hstream.internal.StreamingFetchResponse.Builder (implements io.hstream.internal.StreamingFetchResponseOrBuilder)
        • io.hstream.internal.StreamOffset.Builder (implements io.hstream.internal.StreamOffsetOrBuilder)
        • io.hstream.internal.Subscription.Builder (implements io.hstream.internal.SubscriptionOrBuilder)
        • io.hstream.internal.SubscriptionOffset.Builder (implements io.hstream.internal.SubscriptionOffsetOrBuilder)
        • io.hstream.internal.TerminateQueryRequest.Builder (implements io.hstream.internal.TerminateQueryRequestOrBuilder)
        • io.hstream.internal.TimestampOffset.Builder (implements io.hstream.internal.TimestampOffsetOrBuilder)
        • io.hstream.internal.TrimShardRequest.Builder (implements io.hstream.internal.TrimShardRequestOrBuilder)
        • io.hstream.internal.TrimShardsRequest.Builder (implements io.hstream.internal.TrimShardsRequestOrBuilder)
        • io.hstream.internal.TrimShardsResponse.Builder (implements io.hstream.internal.TrimShardsResponseOrBuilder)
        • io.hstream.internal.TrimStreamRequest.Builder (implements io.hstream.internal.TrimStreamRequestOrBuilder)
        • io.hstream.internal.UnregisterSchemaRequest.Builder (implements io.hstream.internal.UnregisterSchemaRequestOrBuilder)
        • io.hstream.internal.View.Builder (implements io.hstream.internal.ViewOrBuilder)
  • io.grpc.stub.AbstractStub<S>
    • io.grpc.stub.AbstractAsyncStub<S>
      • io.hstream.internal.HStreamApiGrpc.HStreamApiStub
    • io.grpc.stub.AbstractBlockingStub<S>
      • io.hstream.internal.HStreamApiGrpc.HStreamApiBlockingStub
    • io.grpc.stub.AbstractFutureStub<S>
      • io.hstream.internal.HStreamApiGrpc.HStreamApiFutureStub
  • 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.internal.HStreamApiGrpc
  • io.hstream.internal.HStreamApiGrpc.HStreamApiImplBase (implements io.grpc.BindableService, io.hstream.internal.HStreamApiGrpc.AsyncService)
  • io.hstream.internal.HStreamProto
  • 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
  • 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
• io.hstream.BatchAckResponder
• io.hstream.BatchReceiver
• io.hstream.BufferedProducerBuilder
• io.hstream.ConsumerBuilder
• io.hstream.HRecordReceiver
• io.hstream.internal.HStreamApiGrpc.AsyncService
• io.hstream.HStreamClientBuilder
• com.google.protobuf.MessageLiteOrBuilder
  • com.google.protobuf.MessageOrBuilder
    • io.hstream.internal.AdminCommandRequestOrBuilder
    • io.hstream.internal.AdminCommandResponseOrBuilder
    • io.hstream.internal.AlterConnectorConfigRequestOrBuilder
    • io.hstream.internal.AppendRequestOrBuilder
    • io.hstream.internal.AppendResponseOrBuilder
    • io.hstream.internal.BatchedRecordOrBuilder
    • io.hstream.internal.BatchHStreamRecordsOrBuilder
    • io.hstream.internal.CheckSubscriptionExistRequestOrBuilder
    • io.hstream.internal.CheckSubscriptionExistResponseOrBuilder
    • io.hstream.internal.ColumnCatalogOrBuilder
    • io.hstream.internal.CommandConnectedOrBuilder
    • io.hstream.internal.CommandConnectOrBuilder
    • io.hstream.internal.CommandQueryOrBuilder
    • io.hstream.internal.CommandQueryResponseOrBuilder
    • io.hstream.internal.CommandStreamTaskOrBuilder
    • io.hstream.internal.CommandStreamTaskResponseOrBuilder
    • io.hstream.internal.ConnectorOrBuilder
    • io.hstream.internal.ConsumerOrBuilder
    • io.hstream.internal.CreateConnectorRequestOrBuilder
    • io.hstream.internal.CreateQueryRequestOrBuilder
    • io.hstream.internal.CreateQueryWithNamespaceRequestOrBuilder
    • io.hstream.internal.CreateShardReaderRequestOrBuilder
    • io.hstream.internal.CreateShardReaderResponseOrBuilder
    • io.hstream.internal.DeleteConnectorRequestOrBuilder
    • io.hstream.internal.DeleteQueryRequestOrBuilder
    • io.hstream.internal.DeleteShardReaderRequestOrBuilder
    • io.hstream.internal.DeleteStreamRequestOrBuilder
    • io.hstream.internal.DeleteSubscriptionRequestOrBuilder
    • io.hstream.internal.DeleteViewRequestOrBuilder
    • io.hstream.internal.DescribeClusterResponseOrBuilder
    • io.hstream.internal.EchoRequestOrBuilder
    • io.hstream.internal.EchoResponseOrBuilder
    • io.hstream.internal.ExecuteViewQueryRequestOrBuilder
    • io.hstream.internal.ExecuteViewQueryResponseOrBuilder
    • io.hstream.internal.ExecuteViewQuerySqlOrBuilder
    • io.hstream.internal.ExecuteViewQueryWithNamespaceRequestOrBuilder
    • io.hstream.internal.GetConnectorLogsRequestOrBuilder
    • io.hstream.internal.GetConnectorLogsResponseOrBuilder
    • io.hstream.internal.GetConnectorRequestOrBuilder
    • io.hstream.internal.GetConnectorSpecRequestOrBuilder
    • io.hstream.internal.GetConnectorSpecResponseOrBuilder
    • io.hstream.internal.GetQueryRequestOrBuilder
    • io.hstream.internal.GetSchemaRequestOrBuilder
    • io.hstream.internal.GetStatsRequestOrBuilder
    • io.hstream.internal.GetStatsResponseOrBuilder
    • io.hstream.internal.GetStreamRequestOrBuilder
    • io.hstream.internal.GetStreamResponseOrBuilder
    • io.hstream.internal.GetSubscriptionRequestOrBuilder
    • io.hstream.internal.GetSubscriptionResponseOrBuilder
    • io.hstream.internal.GetTailRecordIdRequestOrBuilder
    • io.hstream.internal.GetTailRecordIdResponseOrBuilder
    • io.hstream.internal.GetViewRequestOrBuilder
    • io.hstream.internal.HStreamRecordHeaderOrBuilder
    • io.hstream.internal.HStreamRecordOrBuilder
    • io.hstream.internal.HStreamVersionOrBuilder
    • io.hstream.internal.ListConnectorsRequestOrBuilder
    • io.hstream.internal.ListConnectorsResponseOrBuilder
    • io.hstream.internal.ListConsumersRequestOrBuilder
    • io.hstream.internal.ListConsumersResponseOrBuilder
    • io.hstream.internal.ListQueriesRequestOrBuilder
    • io.hstream.internal.ListQueriesResponseOrBuilder
    • io.hstream.internal.ListShardReadersRequestOrBuilder
    • io.hstream.internal.ListShardReadersResponseOrBuilder
    • io.hstream.internal.ListShardsRequestOrBuilder
    • io.hstream.internal.ListShardsResponseOrBuilder
    • io.hstream.internal.ListStreamsRequestOrBuilder
    • io.hstream.internal.ListStreamsResponseOrBuilder
    • io.hstream.internal.ListStreamsWithPrefixRequestOrBuilder
    • io.hstream.internal.ListSubscriptionsRequestOrBuilder
    • io.hstream.internal.ListSubscriptionsResponseOrBuilder
    • io.hstream.internal.ListSubscriptionsWithPrefixRequestOrBuilder
    • io.hstream.internal.ListViewsRequestOrBuilder
    • io.hstream.internal.ListViewsResponseOrBuilder
    • io.hstream.internal.LookupKeyRequestOrBuilder
    • io.hstream.internal.LookupResourceRequestOrBuilder
    • io.hstream.internal.LookupShardReaderRequestOrBuilder
    • io.hstream.internal.LookupShardReaderResponseOrBuilder
    • io.hstream.internal.LookupShardRequestOrBuilder
    • io.hstream.internal.LookupShardResponseOrBuilder
    • io.hstream.internal.LookupSubscriptionRequestOrBuilder
    • io.hstream.internal.LookupSubscriptionResponseOrBuilder
    • io.hstream.internal.ParseSqlRequestOrBuilder
    • io.hstream.internal.ParseSqlResponseOrBuilder
    • io.hstream.internal.PauseConnectorRequestOrBuilder
    • io.hstream.internal.PauseQueryRequestOrBuilder
    • io.hstream.internal.PerStreamTimeSeriesStatsAllRequestOrBuilder
    • io.hstream.internal.PerStreamTimeSeriesStatsAllResponseOrBuilder
    • io.hstream.internal.PerStreamTimeSeriesStatsRequestOrBuilder
    • io.hstream.internal.PerStreamTimeSeriesStatsResponseOrBuilder
    • io.hstream.internal.QueryOrBuilder
    • io.hstream.internal.ReadShardRequestOrBuilder
    • io.hstream.internal.ReadShardResponseOrBuilder
    • io.hstream.internal.ReadShardStreamRequestOrBuilder
    • io.hstream.internal.ReadShardStreamResponseOrBuilder
    • io.hstream.internal.ReadSingleShardStreamRequestOrBuilder
    • io.hstream.internal.ReadSingleShardStreamResponseOrBuilder
    • io.hstream.internal.ReadStreamByKeyRequestOrBuilder
    • io.hstream.internal.ReadStreamByKeyResponseOrBuilder
    • io.hstream.internal.ReadStreamRequestOrBuilder
    • io.hstream.internal.ReadStreamResponseOrBuilder
    • io.hstream.internal.ReceivedRecordOrBuilder
    • io.hstream.internal.RecordIdOrBuilder
    • io.hstream.internal.ResumeConnectorRequestOrBuilder
    • io.hstream.internal.ResumeQueryRequestOrBuilder
    • io.hstream.internal.SchemaOrBuilder
    • io.hstream.internal.ServerNodeOrBuilder
    • io.hstream.internal.ServerNodeStatusOrBuilder
    • io.hstream.internal.ShardOffsetOrBuilder
    • io.hstream.internal.ShardOrBuilder
    • io.hstream.internal.StatErrorOrBuilder
    • io.hstream.internal.StatsDoubleValsOrBuilder
    • io.hstream.internal.StatsIntervalValsOrBuilder
    • io.hstream.internal.StatTypeOrBuilder
    • io.hstream.internal.StatValueOrBuilder
    • io.hstream.internal.StreamingFetchRequestOrBuilder
    • io.hstream.internal.StreamingFetchResponseOrBuilder
    • io.hstream.internal.StreamOffsetOrBuilder
    • io.hstream.internal.StreamOrBuilder
    • io.hstream.internal.SubscriptionOffsetOrBuilder
    • io.hstream.internal.SubscriptionOrBuilder
    • io.hstream.internal.TerminateQueryRequestOrBuilder
    • io.hstream.internal.TimestampOffsetOrBuilder
    • io.hstream.internal.TrimShardRequestOrBuilder
    • io.hstream.internal.TrimShardsRequestOrBuilder
    • io.hstream.internal.TrimShardsResponseOrBuilder
    • io.hstream.internal.TrimStreamRequestOrBuilder
    • io.hstream.internal.UnregisterSchemaRequestOrBuilder
    • io.hstream.internal.ViewOrBuilder
• 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.internal.CompressionType (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.internal.ConnectorStats (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.ConnectorType
    • io.hstream.internal.ErrorCode (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.internal.HStreamRecordHeader.Flag (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.internal.NodeState (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.internal.ParseSqlResponse.SqlCase (implements com.google.protobuf.Internal.EnumLite)
    • io.hstream.Query.QueryType
    • io.hstream.internal.QueryStats (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.internal.QueryType (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.internal.ResourceType (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.internal.ShardOffset.OffsetCase (implements com.google.protobuf.Internal.EnumLite)
    • io.hstream.internal.SpecialOffset (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.internal.StatType.StatCase (implements com.google.protobuf.Internal.EnumLite)
    • io.hstream.internal.StreamOffset.OffsetCase (implements com.google.protobuf.Internal.EnumLite)
    • io.hstream.StreamShardOffset.OffsetType
    • io.hstream.StreamShardOffset.SpecialOffset
    • io.hstream.internal.StreamStats (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.Subscription.SubscriptionOffset
    • io.hstream.internal.SubscriptionStats (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.TaskStatus
    • io.hstream.internal.TaskStatusPB (implements com.google.protobuf.ProtocolMessageEnum)
    • io.hstream.UrlSchema
    • io.hstream.internal.ViewStats (implements com.google.protobuf.ProtocolMessageEnum)