Serialized Form (client 0.17.1-SNAPSHOT API)

Package io.hstream
- Class io.hstream.HServerException extends RuntimeException implements Serializable
  - Serialized Fields
    - errBody
      
      HServerException.ErrBody errBody
- Class io.hstream.HStreamDBClientException extends RuntimeException implements Serializable
- Class io.hstream.HStreamDBClientException.ConsumerException extends HStreamDBClientException implements Serializable
- Class io.hstream.HStreamDBClientException.InvalidRecordException extends HStreamDBClientException implements Serializable
- Class io.hstream.HStreamDBClientException.SubscribeException extends HStreamDBClientException implements Serializable
Package io.hstream.internal
- Class io.hstream.internal.AdminCommandRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - command_
      
      Object command_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.AdminCommandResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - result_
      
      Object result_
- Class io.hstream.internal.AlterConnectorConfigRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - config_
      
      Object config_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
- Class io.hstream.internal.AppendRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - records_
      
      BatchedRecord records_
    - shardId_
      
      long shardId_
    - streamName_
      
      Object streamName_
- Class io.hstream.internal.AppendResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - recordIds_
      
      List<RecordId> recordIds_
    - shardId_
      
      long shardId_
    - streamName_
      
      Object streamName_
- Class io.hstream.internal.BatchedRecord extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - batchSize_
      
      int batchSize_
    - compressionType_
      
      int compressionType_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - payload_
      
      com.google.protobuf.ByteString payload_
    - publishTime_
      
      com.google.protobuf.Timestamp publishTime_
- Class io.hstream.internal.BatchHStreamRecords extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - records_
      
      List<HStreamRecord> records_
- Class io.hstream.internal.CheckSubscriptionExistRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - subscriptionId_
      
      Object subscriptionId_
- Class io.hstream.internal.CheckSubscriptionExistResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - exists_
      
      boolean exists_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.ColumnCatalog extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - index_
      
      int index_
    - isHidden_
      
      boolean isHidden_
    - isNullable_
      
      boolean isNullable_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
    - type_
      
      Object type_
- Class io.hstream.internal.CommandConnect extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - clientVersion_
      
      Object clientVersion_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - protocolVersion_
      
      int protocolVersion_
- Class io.hstream.internal.CommandConnected extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - protocolVersion_
      
      int protocolVersion_
    - serverVersion_
      
      Object serverVersion_
- Class io.hstream.internal.CommandQuery extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - stmtText_
      
      Object stmtText_
- Class io.hstream.internal.CommandQueryResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - resultSet_
      
      List<com.google.protobuf.Struct> resultSet_
- Class io.hstream.internal.CommandStreamTask extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - commandSql_
      
      Object commandSql_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.CommandStreamTaskResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - commandResp_
      
      Object commandResp_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.Connector extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - config_
      
      Object config_
    - creationTime_
      
      com.google.protobuf.Timestamp creationTime_
    - dockerStatus_
      
      Object dockerStatus_
    - image_
      
      Object image_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
    - node_
      
      Object node_
    - offsets_
      
      List<com.google.protobuf.Struct> offsets_
    - status_
      
      Object status_
    - target_
      
      Object target_
    - taskId_
      
      Object taskId_
    - type_
      
      Object type_
- Class io.hstream.internal.Consumer extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
    - uri_
      
      Object uri_
    - userAgent_
      
      Object userAgent_
- Class io.hstream.internal.CreateConnectorRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - config_
      
      Object config_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
    - target_
      
      Object target_
    - type_
      
      Object type_
- Class io.hstream.internal.CreateQueryRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - queryName_
      
      Object queryName_
    - sql_
      
      Object sql_
- Class io.hstream.internal.CreateQueryWithNamespaceRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - namespace_
      
      Object namespace_
    - queryName_
      
      Object queryName_
    - sql_
      
      Object sql_
- Class io.hstream.internal.CreateShardReaderRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      Object readerId_
    - shardId_
      
      long shardId_
    - shardOffset_
      
      ShardOffset shardOffset_
    - streamName_
      
      Object streamName_
    - timeout_
      
      int timeout_
- Class io.hstream.internal.CreateShardReaderResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      Object readerId_
    - shardId_
      
      long shardId_
    - shardOffset_
      
      ShardOffset shardOffset_
    - streamName_
      
      Object streamName_
    - timeout_
      
      int timeout_
- Class io.hstream.internal.DeleteConnectorRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
- Class io.hstream.internal.DeleteQueryRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - id_
      
      Object id_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.DeleteShardReaderRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      Object readerId_
- Class io.hstream.internal.DeleteStreamRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - force_
      
      boolean force_
    - ignoreNonExist_
      
      boolean ignoreNonExist_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - streamName_
      
      Object streamName_
- Class io.hstream.internal.DeleteSubscriptionRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - force_
      
      boolean force_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - subscriptionId_
      
      Object subscriptionId_
- Class io.hstream.internal.DeleteViewRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - ignoreNonExist_
      
      boolean ignoreNonExist_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - viewId_
      
      Object viewId_
- Class io.hstream.internal.DescribeClusterResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - clusterUpTime_
      
      long clusterUpTime_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - protocolVersion_
      
      Object protocolVersion_
    - serverNodes_
      
      List<ServerNode> serverNodes_
    - serverNodesStatus_
      
      List<ServerNodeStatus> serverNodesStatus_
- Class io.hstream.internal.EchoRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - msg_
      
      Object msg_
- Class io.hstream.internal.EchoResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - msg_
      
      Object msg_
- Class io.hstream.internal.ExecuteViewQueryRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - sql_
      
      Object sql_
- Class io.hstream.internal.ExecuteViewQueryResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - results_
      
      List<com.google.protobuf.Struct> results_
- Class io.hstream.internal.ExecuteViewQuerySql extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - view_
      
      Object view_
- Class io.hstream.internal.ExecuteViewQueryWithNamespaceRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - namespace_
      
      Object namespace_
    - sql_
      
      Object sql_
- Class io.hstream.internal.GetConnectorLogsRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - begin_
      
      int begin_
    - count_
      
      int count_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
- Class io.hstream.internal.GetConnectorLogsResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - logs_
      
      Object logs_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.GetConnectorRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
- Class io.hstream.internal.GetConnectorSpecRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - target_
      
      Object target_
    - type_
      
      Object type_
- Class io.hstream.internal.GetConnectorSpecResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - spec_
      
      Object spec_
- Class io.hstream.internal.GetQueryRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - id_
      
      Object id_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.GetSchemaRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - owner_
      
      Object owner_
- Class io.hstream.internal.GetStatsRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - stats_
      
      List<StatType> stats_
- Class io.hstream.internal.GetStatsResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - errors_
      
      List<StatError> errors_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - statsValues_
      
      List<StatValue> statsValues_
- Class io.hstream.internal.GetStreamRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
- Class io.hstream.internal.GetStreamResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - stream_
      
      Stream stream_
- Class io.hstream.internal.GetSubscriptionRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - id_
      
      Object id_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.GetSubscriptionResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - offsets_
      
      List<SubscriptionOffset> offsets_
    - subscription_
      
      Subscription subscription_
- Class io.hstream.internal.GetTailRecordIdRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - shardId_
      
      long shardId_
    - streamName_
      
      Object streamName_
- Class io.hstream.internal.GetTailRecordIdResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - tailRecordId_
      
      RecordId tailRecordId_
- Class io.hstream.internal.GetViewRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - viewId_
      
      Object viewId_
- Class io.hstream.internal.HStreamRecord extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - header_
      
      HStreamRecordHeader header_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - payload_
      
      com.google.protobuf.ByteString payload_
- Class io.hstream.internal.HStreamRecordHeader extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - attributes_
      
      com.google.protobuf.MapField<String,String> attributes_
    - flag_
      
      int flag_
    - key_
      
      Object key_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.HStreamVersion extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - commit_
      
      Object commit_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - version_
      
      Object version_
- Class io.hstream.internal.ListConnectorsRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.ListConnectorsResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - connectors_
      
      List<Connector> connectors_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.ListConsumersRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - subscriptionId_
      
      Object subscriptionId_
- Class io.hstream.internal.ListConsumersResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - consumers_
      
      List<Consumer> consumers_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.ListQueriesRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.ListQueriesResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - queries_
      
      List<Query> queries_
- Class io.hstream.internal.ListShardReadersRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.ListShardReadersResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      com.google.protobuf.LazyStringArrayList readerId_
- Class io.hstream.internal.ListShardsRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - streamName_
      
      Object streamName_
- Class io.hstream.internal.ListShardsResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - shards_
      
      List<Shard> shards_
- Class io.hstream.internal.ListStreamsRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.ListStreamsResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - streams_
      
      List<Stream> streams_
- Class io.hstream.internal.ListStreamsWithPrefixRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - prefix_
      
      Object prefix_
- Class io.hstream.internal.ListSubscriptionsRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.ListSubscriptionsResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - subscription_
      
      List<Subscription> subscription_
- Class io.hstream.internal.ListSubscriptionsWithPrefixRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - prefix_
      
      Object prefix_
- Class io.hstream.internal.ListViewsRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.ListViewsResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - views_
      
      List<View> views_
- Class io.hstream.internal.LookupKeyRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - partitionKey_
      
      Object partitionKey_
- Class io.hstream.internal.LookupResourceRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - resId_
      
      Object resId_
    - resType_
      
      int resType_
- Class io.hstream.internal.LookupShardReaderRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      Object readerId_
- Class io.hstream.internal.LookupShardReaderResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      Object readerId_
    - serverNode_
      
      ServerNode serverNode_
- Class io.hstream.internal.LookupShardRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - shardId_
      
      long shardId_
- Class io.hstream.internal.LookupShardResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - serverNode_
      
      ServerNode serverNode_
    - shardId_
      
      long shardId_
- Class io.hstream.internal.LookupSubscriptionRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - subscriptionId_
      
      Object subscriptionId_
- Class io.hstream.internal.LookupSubscriptionResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - serverNode_
      
      ServerNode serverNode_
    - subscriptionId_
      
      Object subscriptionId_
- Class io.hstream.internal.ParseSqlRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - sql_
      
      Object sql_
- Class io.hstream.internal.ParseSqlResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - sql_
      
      Object sql_
    - sqlCase_
      
      int sqlCase_
- Class io.hstream.internal.PauseConnectorRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
- Class io.hstream.internal.PauseQueryRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - id_
      
      Object id_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.PerStreamTimeSeriesStatsAllRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - intervals_
      
      StatsIntervalVals intervals_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - method_
      
      Object method_
- Class io.hstream.internal.PerStreamTimeSeriesStatsAllResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - stats_
      
      com.google.protobuf.MapField<String,StatsDoubleVals> stats_
- Class io.hstream.internal.PerStreamTimeSeriesStatsRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - intervals_
      
      StatsIntervalVals intervals_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - method_
      
      Object method_
    - streamName_
      
      Object streamName_
- Class io.hstream.internal.PerStreamTimeSeriesStatsResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - stats_
      
      StatsDoubleVals stats_
- Class io.hstream.internal.Query extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - createdTime_
      
      long createdTime_
    - id_
      
      Object id_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - nodeId_
      
      int nodeId_
    - queryText_
      
      Object queryText_
    - resultName_
      
      Object resultName_
    - sources_
      
      com.google.protobuf.LazyStringArrayList sources_
    - status_
      
      int status_
    - type_
      
      int type_
- Class io.hstream.internal.ReadShardRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - maxRecords_
      
      int maxRecords_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      Object readerId_
- Class io.hstream.internal.ReadShardResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - receivedRecords_
      
      List<ReceivedRecord> receivedRecords_
- Class io.hstream.internal.ReadShardStreamRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - from_
      
      ShardOffset from_
    - maxReadBatches_
      
      long maxReadBatches_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      Object readerId_
    - shardId_
      
      long shardId_
    - streamName_
      
      Object streamName_
    - until_
      
      ShardOffset until_
- Class io.hstream.internal.ReadShardStreamResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - receivedRecords_
      
      List<ReceivedRecord> receivedRecords_
- Class io.hstream.internal.ReadSingleShardStreamRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - from_
      
      ShardOffset from_
    - maxReadBatches_
      
      long maxReadBatches_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      Object readerId_
    - streamName_
      
      Object streamName_
    - until_
      
      ShardOffset until_
- Class io.hstream.internal.ReadSingleShardStreamResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - receivedRecords_
      
      List<ReceivedRecord> receivedRecords_
- Class io.hstream.internal.ReadStreamByKeyRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - from_
      
      ShardOffset from_
    - key_
      
      Object key_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      Object readerId_
    - readRecordCount_
      
      long readRecordCount_
    - streamName_
      
      Object streamName_
    - until_
      
      ShardOffset until_
- Class io.hstream.internal.ReadStreamByKeyResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - receivedRecords_
      
      List<HStreamRecord> receivedRecords_
    - recordIds_
      
      List<RecordId> recordIds_
- Class io.hstream.internal.ReadStreamRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - from_
      
      StreamOffset from_
    - maxReadBatches_
      
      long maxReadBatches_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - readerId_
      
      Object readerId_
    - streamName_
      
      Object streamName_
    - until_
      
      StreamOffset until_
- Class io.hstream.internal.ReadStreamResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - receivedRecords_
      
      List<ReceivedRecord> receivedRecords_
- Class io.hstream.internal.ReceivedRecord extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - record_
      
      BatchedRecord record_
    - recordIds_
      
      List<RecordId> recordIds_
- Class io.hstream.internal.RecordId extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - batchId_
      
      long batchId_
    - batchIndex_
      
      int batchIndex_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - shardId_
      
      long shardId_
- Class io.hstream.internal.ResumeConnectorRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - name_
      
      Object name_
- Class io.hstream.internal.ResumeQueryRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - id_
      
      Object id_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.Schema extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - columns_
      
      List<ColumnCatalog> columns_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - owner_
      
      Object owner_
- Class io.hstream.internal.ServerNode extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - host_
      
      Object host_
    - id_
      
      int id_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - port_
      
      int port_
    - version_
      
      HStreamVersion version_
- Class io.hstream.internal.ServerNodeStatus extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - node_
      
      ServerNode node_
    - state_
      
      int state_
- Class io.hstream.internal.Shard extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - endHashRangeKey_
      
      Object endHashRangeKey_
    - epoch_
      
      long epoch_
    - isActive_
      
      boolean isActive_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - shardId_
      
      long shardId_
    - startHashRangeKey_
      
      Object startHashRangeKey_
    - streamName_
      
      Object streamName_
- Class io.hstream.internal.ShardOffset extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - offset_
      
      Object offset_
    - offsetCase_
      
      int offsetCase_
- Class io.hstream.internal.StatError extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - message_
      
      Object message_
    - statType_
      
      StatType statType_
- Class io.hstream.internal.StatsDoubleVals extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - vals_
      
      com.google.protobuf.Internal.DoubleList vals_
    - valsMemoizedSerializedSize
      
      int valsMemoizedSerializedSize
- Class io.hstream.internal.StatsIntervalVals extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - intervals_
      
      com.google.protobuf.Internal.IntList intervals_
    - intervalsMemoizedSerializedSize
      
      int intervalsMemoizedSerializedSize
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
- Class io.hstream.internal.StatType extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - stat_
      
      Object stat_
    - statCase_
      
      int statCase_
- Class io.hstream.internal.StatValue extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - statType_
      
      StatType statType_
    - statValues_
      
      com.google.protobuf.MapField<String,Long> statValues_
- Class io.hstream.internal.Stream extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - backlogDuration_
      
      int backlogDuration_
    - creationTime_
      
      com.google.protobuf.Timestamp creationTime_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - replicationFactor_
      
      int replicationFactor_
    - shardCount_
      
      int shardCount_
    - streamName_
      
      Object streamName_
- Class io.hstream.internal.StreamingFetchRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - ackIds_
      
      List<RecordId> ackIds_
    - consumerName_
      
      Object consumerName_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - subscriptionId_
      
      Object subscriptionId_
- Class io.hstream.internal.StreamingFetchResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - receivedRecords_
      
      ReceivedRecord receivedRecords_
- Class io.hstream.internal.StreamOffset extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - offset_
      
      Object offset_
    - offsetCase_
      
      int offsetCase_
- Class io.hstream.internal.Subscription extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - ackTimeoutSeconds_
      
      int ackTimeoutSeconds_
    - creationTime_
      
      com.google.protobuf.Timestamp creationTime_
    - maxUnackedRecords_
      
      int maxUnackedRecords_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - offset_
      
      int offset_
    - streamName_
      
      Object streamName_
    - subscriptionId_
      
      Object subscriptionId_
- Class io.hstream.internal.SubscriptionOffset extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - batchId_
      
      long batchId_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - shardId_
      
      long shardId_
- Class io.hstream.internal.TerminateQueryRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - queryId_
      
      Object queryId_
- Class io.hstream.internal.TimestampOffset extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - strictAccuracy_
      
      boolean strictAccuracy_
    - timestampInMs_
      
      long timestampInMs_
- Class io.hstream.internal.TrimShardRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - shardId_
      
      long shardId_
    - streamName_
      
      Object streamName_
    - trimPoint_
      
      ShardOffset trimPoint_
- Class io.hstream.internal.TrimShardsRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - recordIds_
      
      com.google.protobuf.LazyStringArrayList recordIds_
    - streamName_
      
      Object streamName_
- Class io.hstream.internal.TrimShardsResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - trimPoints_
      
      com.google.protobuf.MapField<Long,String> trimPoints_
- Class io.hstream.internal.TrimStreamRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - streamName_
      
      Object streamName_
    - trimPoint_
      
      StreamOffset trimPoint_
- Class io.hstream.internal.UnregisterSchemaRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - owner_
      
      Object owner_
- Class io.hstream.internal.View extends com.google.protobuf.GeneratedMessageV3 implements Serializable
  
  serialVersionUID:
  
  0L
  - Serialized Fields
    - createdTime_
      
      long createdTime_
    - memoizedIsInitialized
      
      byte memoizedIsInitialized
    - queryName_
      
      Object queryName_
    - schema_
      
      com.google.protobuf.LazyStringArrayList schema_
    - sql_
      
      Object sql_
    - status_
      
      int status_
    - viewId_
      
      Object viewId_

Serialized Form

Package io.hstream

Class io.hstream.HServerException extends RuntimeException implements Serializable

Serialized Fields

errBody

Class io.hstream.HStreamDBClientException extends RuntimeException implements Serializable

Class io.hstream.HStreamDBClientException.ConsumerException extends HStreamDBClientException implements Serializable

Class io.hstream.HStreamDBClientException.InvalidRecordException extends HStreamDBClientException implements Serializable

Class io.hstream.HStreamDBClientException.SubscribeException extends HStreamDBClientException implements Serializable

Package io.hstream.internal

Class io.hstream.internal.AdminCommandRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

command_

memoizedIsInitialized

Class io.hstream.internal.AdminCommandResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

memoizedIsInitialized

result_

Class io.hstream.internal.AlterConnectorConfigRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

config_

memoizedIsInitialized

name_

Class io.hstream.internal.AppendRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

memoizedIsInitialized

records_

shardId_

streamName_

Class io.hstream.internal.AppendResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

memoizedIsInitialized

recordIds_

shardId_

streamName_

Class io.hstream.internal.BatchedRecord extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

batchSize_

compressionType_

memoizedIsInitialized

payload_

publishTime_

Class io.hstream.internal.BatchHStreamRecords extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

memoizedIsInitialized

records_

Class io.hstream.internal.CheckSubscriptionExistRequest extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

memoizedIsInitialized

subscriptionId_

Class io.hstream.internal.CheckSubscriptionExistResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

exists_

memoizedIsInitialized

Class io.hstream.internal.ColumnCatalog extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

index_

isHidden_

isNullable_

memoizedIsInitialized

name_

type_

Class io.hstream.internal.CommandConnect extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

clientVersion_

memoizedIsInitialized

protocolVersion_

Class io.hstream.internal.CommandConnected extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

memoizedIsInitialized

protocolVersion_

serverVersion_

Class io.hstream.internal.CommandQuery extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

memoizedIsInitialized

stmtText_

Class io.hstream.internal.CommandQueryResponse extends com.google.protobuf.GeneratedMessageV3 implements Serializable

Serialized Fields

memoizedIsInitialized

resultSet_