Modifier and Type | Method and Description |
---|---|
static Build |
Build.readBuild(StreamInput in) |
static Version |
Version.readVersion(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ActionRequest.readFrom(StreamInput in) |
void |
ActionResponse.readFrom(StreamInput in) |
static OriginalIndices |
OriginalIndices.readOptionalOriginalIndices(StreamInput in) |
static OriginalIndices |
OriginalIndices.readOriginalIndices(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static ClusterIndexHealth |
ClusterIndexHealth.readClusterIndexHealth(StreamInput in) |
void |
ClusterHealthRequest.readFrom(StreamInput in) |
void |
ClusterHealthResponse.readFrom(StreamInput in) |
void |
ClusterIndexHealth.readFrom(StreamInput in) |
void |
ClusterShardHealth.readFrom(StreamInput in) |
static ClusterHealthResponse |
ClusterHealthResponse.readResponseFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
NodeHotThreads.readFrom(StreamInput in) |
void |
NodesHotThreadsResponse.readFrom(StreamInput in) |
void |
NodesHotThreadsRequest.readFrom(StreamInput in) |
static NodeHotThreads |
NodeHotThreads.readNodeHotThreads(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
NodeInfo.readFrom(StreamInput in) |
void |
PluginsInfo.readFrom(StreamInput in) |
void |
NodesInfoRequest.readFrom(StreamInput in) |
void |
NodesInfoResponse.readFrom(StreamInput in) |
void |
PluginInfo.readFrom(StreamInput in) |
static NodeInfo |
NodeInfo.readNodeInfo(StreamInput in) |
static PluginInfo |
PluginInfo.readPluginInfo(StreamInput in) |
static PluginsInfo |
PluginsInfo.readPluginsInfo(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
NodesRestartResponse.readFrom(StreamInput in) |
void |
TransportNodesRestartAction.NodeRestartRequest.readFrom(StreamInput in) |
void |
NodesRestartRequest.readFrom(StreamInput in) |
static NodesRestartResponse.NodeRestartResponse |
NodesRestartResponse.NodeRestartResponse.readNodeRestartResponse(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
NodesShutdownResponse.readFrom(StreamInput in) |
void |
NodesShutdownRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
NodesStatsResponse.readFrom(StreamInput in) |
void |
NodeStats.readFrom(StreamInput in) |
void |
NodesStatsRequest.readFrom(StreamInput in) |
static NodeStats |
NodeStats.readNodeStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DeleteRepositoryRequest.readFrom(StreamInput in) |
void |
DeleteRepositoryResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetRepositoriesRequest.readFrom(StreamInput in) |
void |
GetRepositoriesResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PutRepositoryResponse.readFrom(StreamInput in) |
void |
PutRepositoryRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
VerifyRepositoryRequest.readFrom(StreamInput in) |
void |
VerifyRepositoryResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterRerouteRequest.readFrom(StreamInput in) |
void |
ClusterRerouteResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterUpdateSettingsResponse.readFrom(StreamInput in) |
void |
ClusterUpdateSettingsRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterSearchShardsGroup.readFrom(StreamInput in) |
void |
ClusterSearchShardsResponse.readFrom(StreamInput in) |
void |
ClusterSearchShardsRequest.readFrom(StreamInput in) |
static ClusterSearchShardsGroup |
ClusterSearchShardsGroup.readSearchShardsGroupResponse(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CreateSnapshotResponse.readFrom(StreamInput in) |
void |
CreateSnapshotRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DeleteSnapshotRequest.readFrom(StreamInput in) |
void |
DeleteSnapshotResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetSnapshotsResponse.readFrom(StreamInput in) |
void |
GetSnapshotsRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
RestoreSnapshotRequest.readFrom(StreamInput in) |
void |
RestoreSnapshotResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SnapshotIndexShardStatus.readFrom(StreamInput in) |
void |
SnapshotStatus.readFrom(StreamInput in) |
void |
TransportNodesSnapshotsStatus.NodesSnapshotStatus.readFrom(StreamInput in) |
void |
TransportNodesSnapshotsStatus.NodeSnapshotStatus.readFrom(StreamInput in) |
void |
SnapshotStats.readFrom(StreamInput in) |
void |
SnapshotsStatusRequest.readFrom(StreamInput in) |
void |
SnapshotsStatusResponse.readFrom(StreamInput in) |
static SnapshotIndexShardStatus |
SnapshotIndexShardStatus.readShardSnapshotStatus(StreamInput in) |
static SnapshotStats |
SnapshotStats.readSnapshotStats(StreamInput in) |
static SnapshotStatus |
SnapshotStatus.readSnapshotStatus(StreamInput in)
Reads snapshot status from stream input
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterStateRequest.readFrom(StreamInput in) |
void |
ClusterStateResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static ClusterStatsNodes.Counts |
ClusterStatsNodes.Counts.readCounts(StreamInput in) |
void |
ClusterStatsResponse.readFrom(StreamInput in) |
void |
ClusterStatsNodeResponse.readFrom(StreamInput in) |
void |
ClusterStatsNodes.readFrom(StreamInput in) |
void |
ClusterStatsNodes.Counts.readFrom(StreamInput in) |
void |
ClusterStatsNodes.OsStats.readFrom(StreamInput in) |
void |
ClusterStatsNodes.ProcessStats.readFrom(StreamInput in) |
void |
ClusterStatsNodes.JvmStats.readFrom(StreamInput in) |
void |
ClusterStatsNodes.JvmVersion.readFrom(StreamInput in) |
void |
ClusterStatsIndices.readFrom(StreamInput in) |
void |
ClusterStatsIndices.ShardStats.readFrom(StreamInput in) |
void |
ClusterStatsRequest.readFrom(StreamInput in) |
static ClusterStatsIndices |
ClusterStatsIndices.readIndicesStats(StreamInput in) |
static ClusterStatsNodes.JvmStats |
ClusterStatsNodes.JvmStats.readJvmStats(StreamInput in) |
static ClusterStatsNodes.JvmVersion |
ClusterStatsNodes.JvmVersion.readJvmVersion(StreamInput in) |
static ClusterStatsNodeResponse |
ClusterStatsNodeResponse.readNodeResponse(StreamInput in) |
static ClusterStatsNodes |
ClusterStatsNodes.readNodeStats(StreamInput in) |
static ClusterStatsNodes.OsStats |
ClusterStatsNodes.OsStats.readOsStats(StreamInput in) |
static ClusterStatsIndices.ShardStats |
ClusterStatsIndices.ShardStats.readShardStats(StreamInput in) |
static ClusterStatsNodes.ProcessStats |
ClusterStatsNodes.ProcessStats.readStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PendingClusterTasksRequest.readFrom(StreamInput in) |
void |
PendingClusterTasksResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static Alias |
Alias.read(StreamInput in)
Allows to read an alias from the provided input stream
|
void |
IndicesAliasesRequest.readFrom(StreamInput in) |
IndicesAliasesRequest.AliasActions |
IndicesAliasesRequest.AliasActions.readFrom(StreamInput in) |
void |
Alias.readFrom(StreamInput in) |
void |
IndicesAliasesResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
AliasesExistResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetAliasesRequest.readFrom(StreamInput in) |
void |
GetAliasesResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static AnalyzeResponse.AnalyzeToken |
AnalyzeResponse.AnalyzeToken.readAnalyzeToken(StreamInput in) |
void |
AnalyzeResponse.readFrom(StreamInput in) |
void |
AnalyzeResponse.AnalyzeToken.readFrom(StreamInput in) |
void |
AnalyzeRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ClearIndicesCacheResponse.readFrom(StreamInput in) |
void |
ClearIndicesCacheRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CloseIndexRequest.readFrom(StreamInput in) |
void |
CloseIndexResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CreateIndexRequest.readFrom(StreamInput in) |
void |
CreateIndexResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DeleteIndexRequest.readFrom(StreamInput in) |
void |
DeleteIndexResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
IndicesExistsRequest.readFrom(StreamInput in) |
void |
IndicesExistsResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TypesExistsRequest.readFrom(StreamInput in) |
void |
TypesExistsResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
FlushResponse.readFrom(StreamInput in) |
void |
FlushRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetIndexResponse.readFrom(StreamInput in) |
void |
GetIndexRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DeleteMappingResponse.readFrom(StreamInput in) |
void |
DeleteMappingRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetFieldMappingsRequest.readFrom(StreamInput in) |
void |
GetMappingsResponse.readFrom(StreamInput in) |
void |
GetFieldMappingsResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PutMappingRequest.readFrom(StreamInput in) |
void |
PutMappingResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
OpenIndexResponse.readFrom(StreamInput in) |
void |
OpenIndexRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
OptimizeRequest.readFrom(StreamInput in) |
void |
OptimizeResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ShardRecoveryResponse.readFrom(StreamInput in) |
void |
RecoveryRequest.readFrom(StreamInput in) |
void |
RecoveryResponse.readFrom(StreamInput in) |
static ShardRecoveryResponse |
ShardRecoveryResponse.readShardRecoveryResponse(StreamInput in)
Builds a new ShardRecoveryResponse from the give input stream.
|
Modifier and Type | Method and Description |
---|---|
void |
RefreshRequest.readFrom(StreamInput in) |
void |
RefreshResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
IndicesSegmentResponse.readFrom(StreamInput in) |
void |
ShardSegments.readFrom(StreamInput in) |
static ShardSegments |
ShardSegments.readShardSegments(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetSettingsResponse.readFrom(StreamInput in) |
void |
GetSettingsRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
UpdateSettingsRequest.readFrom(StreamInput in) |
void |
UpdateSettingsResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static CommonStats |
CommonStats.readCommonStats(StreamInput in) |
static CommonStatsFlags |
CommonStatsFlags.readCommonStatsFlags(StreamInput in) |
void |
CommonStats.readFrom(StreamInput in) |
void |
IndexShardStats.readFrom(StreamInput in) |
void |
ShardStats.readFrom(StreamInput in) |
void |
CommonStatsFlags.readFrom(StreamInput in) |
void |
IndicesStatsRequest.readFrom(StreamInput in) |
void |
IndicesStatsResponse.readFrom(StreamInput in) |
static IndexShardStats |
IndexShardStats.readIndexShardStats(StreamInput in) |
static ShardStats |
ShardStats.readShardStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
IndicesStatusRequest.readFrom(StreamInput in)
Deprecated.
|
void |
IndicesStatusResponse.readFrom(StreamInput in)
Deprecated.
|
void |
ShardStatus.readFrom(StreamInput in)
Deprecated.
|
static ShardStatus |
ShardStatus.readIndexShardStatus(StreamInput in)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
DeleteIndexTemplateRequest.readFrom(StreamInput in) |
void |
DeleteIndexTemplateResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetIndexTemplatesResponse.readFrom(StreamInput in) |
void |
GetIndexTemplatesRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PutIndexTemplateRequest.readFrom(StreamInput in) |
void |
PutIndexTemplateResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ValidateQueryResponse.readFrom(StreamInput in) |
void |
ValidateQueryRequest.readFrom(StreamInput in) |
void |
QueryExplanation.readFrom(StreamInput in) |
static QueryExplanation |
QueryExplanation.readQueryExplanation(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DeleteWarmerRequest.readFrom(StreamInput in) |
void |
DeleteWarmerResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetWarmersResponse.readFrom(StreamInput in) |
void |
GetWarmersRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PutWarmerRequest.readFrom(StreamInput in) |
void |
PutWarmerResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static BulkItemResponse |
BulkItemResponse.readBulkItem(StreamInput in) |
static BulkItemRequest |
BulkItemRequest.readBulkItem(StreamInput in) |
void |
BulkItemResponse.readFrom(StreamInput in) |
void |
BulkRequest.readFrom(StreamInput in) |
void |
BulkShardResponse.readFrom(StreamInput in) |
void |
BulkItemRequest.readFrom(StreamInput in) |
void |
BulkShardRequest.readFrom(StreamInput in) |
void |
BulkResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CountRequest.readFrom(StreamInput in) |
void |
CountResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
IndexDeleteResponse.readFrom(StreamInput in) |
void |
DeleteResponse.readFrom(StreamInput in) |
void |
DeleteRequest.readFrom(StreamInput in) |
void |
ShardDeleteRequest.readFrom(StreamInput in) |
void |
ShardDeleteResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DeleteByQueryRequest.readFrom(StreamInput in) |
void |
ShardDeleteByQueryResponse.readFrom(StreamInput in) |
void |
IndexDeleteByQueryResponse.readFrom(StreamInput in) |
void |
DeleteByQueryResponse.readFrom(StreamInput in) |
void |
ShardDeleteByQueryRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ExistsRequest.readFrom(StreamInput in) |
void |
ExistsResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ExplainRequest.readFrom(StreamInput in) |
void |
ExplainResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static MultiGetResponse.Failure |
MultiGetResponse.Failure.readFailure(StreamInput in) |
void |
MultiGetRequest.readFrom(StreamInput in) |
void |
MultiGetRequest.Item.readFrom(StreamInput in) |
void |
MultiGetItemResponse.readFrom(StreamInput in) |
void |
GetResponse.readFrom(StreamInput in) |
void |
GetRequest.readFrom(StreamInput in) |
void |
MultiGetShardResponse.readFrom(StreamInput in) |
void |
MultiGetResponse.readFrom(StreamInput in) |
void |
MultiGetResponse.Failure.readFrom(StreamInput in) |
void |
MultiGetShardRequest.readFrom(StreamInput in) |
static GetResponse |
GetResponse.readGetResponse(StreamInput in) |
static MultiGetRequest.Item |
MultiGetRequest.Item.readItem(StreamInput in) |
static MultiGetItemResponse |
MultiGetItemResponse.readItemResponse(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
IndexResponse.readFrom(StreamInput in) |
void |
IndexRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DeleteIndexedScriptResponse.readFrom(StreamInput in) |
void |
DeleteIndexedScriptRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetIndexedScriptRequest.readFrom(StreamInput in) |
void |
GetIndexedScriptResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PutIndexedScriptRequest.readFrom(StreamInput in) |
void |
PutIndexedScriptResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MoreLikeThisRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PercolateShardResponse.readFrom(StreamInput in) |
void |
PercolateShardRequest.readFrom(StreamInput in) |
void |
PercolateResponse.readFrom(StreamInput in) |
void |
PercolateResponse.Match.readFrom(StreamInput in) |
void |
MultiPercolateResponse.readFrom(StreamInput in) |
void |
MultiPercolateResponse.Item.readFrom(StreamInput in) |
void |
PercolateRequest.readFrom(StreamInput in) |
void |
MultiPercolateRequest.readFrom(StreamInput in) |
void |
TransportShardMultiPercolateAction.Request.readFrom(StreamInput in) |
void |
TransportShardMultiPercolateAction.Response.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ClearScrollRequest.readFrom(StreamInput in) |
void |
MultiSearchResponse.readFrom(StreamInput in) |
void |
MultiSearchResponse.Item.readFrom(StreamInput in) |
void |
SearchRequest.readFrom(StreamInput in) |
void |
MultiSearchRequest.readFrom(StreamInput in) |
void |
ShardSearchFailure.readFrom(StreamInput in) |
void |
ClearScrollResponse.readFrom(StreamInput in) |
void |
SearchResponse.readFrom(StreamInput in) |
void |
SearchScrollRequest.readFrom(StreamInput in) |
static MultiSearchResponse.Item |
MultiSearchResponse.Item.readItem(StreamInput in) |
static SearchResponse |
SearchResponse.readSearchResponse(StreamInput in) |
static ShardSearchFailure |
ShardSearchFailure.readShardSearchFailure(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SuggestRequest.readFrom(StreamInput in) |
void |
SuggestResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultShardOperationFailedException.readFrom(StreamInput in) |
static IndicesOptions |
IndicesOptions.readIndicesOptions(StreamInput in) |
static DefaultShardOperationFailedException |
DefaultShardOperationFailedException.readShardOperationFailed(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
BroadcastShardOperationResponse.readFrom(StreamInput in) |
void |
BroadcastOperationRequest.readFrom(StreamInput in) |
void |
BroadcastOperationResponse.readFrom(StreamInput in) |
void |
BroadcastShardOperationRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
AcknowledgedResponse.readAcknowledged(StreamInput in)
Reads the timeout value
|
void |
MasterNodeOperationRequest.readFrom(StreamInput in) |
protected void |
MasterNodeReadOperationRequest.readLocal(StreamInput in)
Reads the local flag
|
protected void |
MasterNodeReadOperationRequest.readLocal(StreamInput in,
Version minVersion)
Reads the local flag if on or after the specified min version or if the version is
null . |
protected void |
AcknowledgedRequest.readTimeout(StreamInput in)
Reads the timeout value
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterInfoRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
NodeOperationResponse.readFrom(StreamInput in) |
void |
NodesOperationResponse.readFrom(StreamInput in) |
void |
NodesOperationRequest.readFrom(StreamInput in) |
void |
NodeOperationRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
IndicesReplicationOperationRequest.readFrom(StreamInput in) |
void |
TransportShardReplicationOperationAction.ReplicaOperationRequest.readFrom(StreamInput in) |
void |
IndexReplicationOperationRequest.readFrom(StreamInput in) |
void |
ShardReplicationOperationRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TransportSingleCustomOperationAction.ShardSingleOperationRequest.readFrom(StreamInput in) |
void |
SingleCustomOperationRequest.readFrom(StreamInput in) |
protected void |
SingleCustomOperationRequest.readIndex(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InstanceShardOperationRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SingleShardOperationRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static MultiTermVectorsResponse.Failure |
MultiTermVectorsResponse.Failure.readFailure(StreamInput in) |
void |
MultiTermVectorsShardResponse.readFrom(StreamInput in) |
void |
MultiTermVectorsResponse.readFrom(StreamInput in) |
void |
MultiTermVectorsResponse.Failure.readFrom(StreamInput in) |
void |
TermVectorRequest.readFrom(StreamInput in) |
void |
MultiTermVectorsShardRequest.readFrom(StreamInput in) |
void |
TermVectorResponse.readFrom(StreamInput in) |
void |
MultiTermVectorsRequest.readFrom(StreamInput in) |
void |
MultiTermVectorsItemResponse.readFrom(StreamInput in) |
static MultiTermVectorsItemResponse |
MultiTermVectorsItemResponse.readItemResponse(StreamInput in) |
static TermVectorRequest |
TermVectorRequest.readTermVectorRequest(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
UpdateRequest.readFrom(StreamInput in) |
void |
UpdateResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static ClusterName |
ClusterName.readClusterName(StreamInput in) |
T |
ClusterState.Custom.Factory.readFrom(StreamInput in) |
void |
ClusterName.readFrom(StreamInput in) |
static ClusterState |
ClusterState.Builder.readFrom(StreamInput in,
DiscoveryNode localNode,
ClusterName defaultClusterName) |
Modifier and Type | Method and Description |
---|---|
void |
MappingUpdatedAction.MappingUpdatedResponse.readFrom(StreamInput in) |
void |
MappingUpdatedAction.MappingUpdatedRequest.readFrom(StreamInput in) |
void |
NodeMappingRefreshAction.NodeMappingRefreshRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static ClusterBlock |
ClusterBlock.readClusterBlock(StreamInput in) |
static ClusterBlocks |
ClusterBlocks.Builder.readClusterBlocks(StreamInput in) |
void |
ClusterBlock.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static AliasAction |
AliasAction.readAliasAction(StreamInput in) |
void |
SnapshotMetaData.ShardSnapshotStatus.readFrom(StreamInput in) |
SnapshotMetaData |
SnapshotMetaData.Factory.readFrom(StreamInput in) |
void |
RestoreMetaData.ShardRestoreStatus.readFrom(StreamInput in)
Reads restore status from stream input
|
RestoreMetaData |
RestoreMetaData.Factory.readFrom(StreamInput in) |
static MappingMetaData |
MappingMetaData.readFrom(StreamInput in) |
void |
SnapshotId.readFrom(StreamInput in) |
static AliasMetaData |
AliasMetaData.Builder.readFrom(StreamInput in) |
static RepositoryMetaData |
RepositoryMetaData.readFrom(StreamInput in)
Reads repository metadata from stream input
|
T |
IndexMetaData.Custom.Factory.readFrom(StreamInput in) |
static IndexMetaData |
IndexMetaData.Builder.readFrom(StreamInput in) |
static IndexTemplateMetaData |
IndexTemplateMetaData.Builder.readFrom(StreamInput in) |
RepositoriesMetaData |
RepositoriesMetaData.Factory.readFrom(StreamInput in) |
void |
AliasAction.readFrom(StreamInput in) |
abstract T |
MetaData.Custom.Factory.readFrom(StreamInput in) |
static MetaData |
MetaData.Builder.readFrom(StreamInput in) |
static RestoreMetaData.ShardRestoreStatus |
RestoreMetaData.ShardRestoreStatus.readShardRestoreStatus(StreamInput in)
Reads restore status from stream input
|
static SnapshotMetaData.ShardSnapshotStatus |
SnapshotMetaData.ShardSnapshotStatus.readShardSnapshotStatus(StreamInput in) |
static SnapshotId |
SnapshotId.readSnapshotId(StreamInput in)
Reads snapshot id from stream input
|
Modifier and Type | Method and Description |
---|---|
void |
DiscoveryNode.readFrom(StreamInput in) |
static DiscoveryNodes |
DiscoveryNodes.Builder.readFrom(StreamInput in,
DiscoveryNode localNode) |
static DiscoveryNode |
DiscoveryNode.readNode(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static IndexShardRoutingTable |
IndexShardRoutingTable.Builder.readFrom(StreamInput in) |
void |
RoutingTableValidation.readFrom(StreamInput in) |
void |
RestoreSource.readFrom(StreamInput in) |
static IndexRoutingTable |
IndexRoutingTable.Builder.readFrom(StreamInput in)
Reads an
IndexRoutingTable from an StreamInput |
void |
ImmutableShardRouting.readFrom(StreamInput in) |
static RoutingTable |
RoutingTable.Builder.readFrom(StreamInput in) |
void |
ImmutableShardRouting.readFrom(StreamInput in,
String index,
int shardId) |
void |
ShardRouting.readFromThin(StreamInput in) |
void |
ImmutableShardRouting.readFromThin(StreamInput in) |
static IndexShardRoutingTable |
IndexShardRoutingTable.Builder.readFromThin(StreamInput in,
String index) |
static RestoreSource |
RestoreSource.readOptionalRestoreSource(StreamInput in) |
static RestoreSource |
RestoreSource.readRestoreSource(StreamInput in) |
static ImmutableShardRouting |
ImmutableShardRouting.readShardRoutingEntry(StreamInput in) |
static ImmutableShardRouting |
ImmutableShardRouting.readShardRoutingEntry(StreamInput in,
String index,
int shardId) |
Modifier and Type | Method and Description |
---|---|
static AllocationExplanation |
AllocationExplanation.readAllocationExplanation(StreamInput in)
Read an
AllocationExplanation from an StreamInput |
void |
AllocationExplanation.readFrom(StreamInput in) |
static RoutingExplanations |
RoutingExplanations.readFrom(StreamInput in)
Read in a RoutingExplanations object
|
static RerouteExplanation |
RerouteExplanation.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
AllocateAllocationCommand |
AllocateAllocationCommand.Factory.readFrom(StreamInput in) |
CancelAllocationCommand |
CancelAllocationCommand.Factory.readFrom(StreamInput in) |
static AllocationCommands |
AllocationCommands.readFrom(StreamInput in)
Reads a
AllocationCommands from a StreamInput |
MoveAllocationCommand |
MoveAllocationCommand.Factory.readFrom(StreamInput in) |
T |
AllocationCommand.Factory.readFrom(StreamInput in)
|
Modifier and Type | Method and Description |
---|---|
static Decision |
Decision.readFrom(StreamInput in) |
static Decision.Type |
Decision.Type.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PendingClusterTask.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static Priority |
Priority.readFrom(StreamInput input) |
Modifier and Type | Method and Description |
---|---|
static CircuitBreaker.Name |
CircuitBreaker.Name.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
StreamInput |
PagedBytesReference.streamInput() |
StreamInput |
HashedBytesArray.streamInput() |
StreamInput |
ChannelBufferBytesReference.streamInput() |
StreamInput |
BytesReference.streamInput()
A stream input of the bytes.
|
StreamInput |
BytesArray.streamInput() |
Modifier and Type | Class and Description |
---|---|
class |
CompressedStreamInput<T extends CompressorContext> |
Modifier and Type | Method and Description |
---|---|
StreamInput |
CompressedStreamInput.setVersion(Version version) |
Modifier and Type | Method and Description |
---|---|
static CompressedString |
CompressedString.readCompressedString(StreamInput in) |
void |
CompressedString.readFrom(StreamInput in) |
protected abstract void |
CompressedStreamInput.readHeader(StreamInput in) |
CompressedStreamInput |
Compressor.streamInput(StreamInput in) |
protected abstract int |
CompressedStreamInput.uncompress(StreamInput in,
byte[] out)
Uncompress the data into the out array, returning the size uncompressed
|
Constructor and Description |
---|
CompressedStreamInput(StreamInput in,
T context) |
Modifier and Type | Class and Description |
---|---|
class |
LZFCompressedStreamInput |
Modifier and Type | Method and Description |
---|---|
void |
LZFCompressedStreamInput.readHeader(StreamInput in) |
CompressedStreamInput |
LZFCompressor.streamInput(StreamInput in) |
int |
LZFCompressedStreamInput.uncompress(StreamInput in,
byte[] out) |
Constructor and Description |
---|
LZFCompressedStreamInput(StreamInput in,
com.ning.compress.lzf.ChunkDecoder decoder) |
Modifier and Type | Class and Description |
---|---|
class |
AdapterStreamInput |
class |
ByteBufferStreamInput |
class |
BytesStreamInput |
class |
HandlesStreamInput |
class |
InputStreamStreamInput |
Modifier and Type | Field and Description |
---|---|
protected StreamInput |
AdapterStreamInput.in |
Modifier and Type | Method and Description |
---|---|
static StreamInput |
CachedStreamInput.compressed(Compressor compressor,
StreamInput in) |
StreamInput |
StreamInput.setVersion(Version version) |
StreamInput |
AdapterStreamInput.setVersion(Version version) |
Modifier and Type | Method and Description |
---|---|
static HandlesStreamInput |
CachedStreamInput.cachedHandles(StreamInput in) |
static HandlesStreamInput |
CachedStreamInput.cachedHandlesCompressed(Compressor compressor,
StreamInput in) |
static StreamInput |
CachedStreamInput.compressed(Compressor compressor,
StreamInput in) |
void |
Streamable.readFrom(StreamInput in) |
void |
HandlesStreamInput.reset(StreamInput in) |
void |
AdapterStreamInput.reset(StreamInput in) |
Constructor and Description |
---|
AdapterStreamInput(StreamInput in) |
HandlesStreamInput(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static org.apache.lucene.search.Explanation |
Lucene.readExplanation(StreamInput in) |
static org.apache.lucene.search.FieldDoc |
Lucene.readFieldDoc(StreamInput in) |
static org.apache.lucene.search.ScoreDoc |
Lucene.readScoreDoc(StreamInput in) |
static org.apache.lucene.search.SortField.Type |
Lucene.readSortType(StreamInput in) |
static org.apache.lucene.search.TopDocs |
Lucene.readTopDocs(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static long |
Versions.readVersion(StreamInput in) |
static long |
Versions.readVersionWithVLongForBW(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static Rounding |
Rounding.Streams.read(StreamInput in) |
void |
Rounding.Interval.readFrom(StreamInput in) |
void |
Rounding.FactorRounding.readFrom(StreamInput in) |
void |
Rounding.PrePostRounding.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static Settings |
ImmutableSettings.readSettingsFromStream(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static TransportAddress |
TransportAddressSerializers.addressFromStream(StreamInput input) |
static BoundTransportAddress |
BoundTransportAddress.readBoundTransportAddress(StreamInput in) |
void |
DummyTransportAddress.readFrom(StreamInput in) |
void |
BoundTransportAddress.readFrom(StreamInput in) |
void |
InetSocketTransportAddress.readFrom(StreamInput in) |
void |
LocalTransportAddress.readFrom(StreamInput in) |
static InetSocketTransportAddress |
InetSocketTransportAddress.readInetSocketTransportAddress(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static ByteSizeValue |
ByteSizeValue.readBytesSizeValue(StreamInput in) |
static DistanceUnit |
DistanceUnit.readDistanceUnit(StreamInput in)
Read a
DistanceUnit from a StreamInput |
void |
SizeValue.readFrom(StreamInput in) |
void |
TimeValue.readFrom(StreamInput in)
serialization converts TimeValue internally to NANOSECONDS
|
void |
Percent.readFrom(StreamInput in) |
void |
ByteSizeValue.readFrom(StreamInput in) |
static SizeValue |
SizeValue.readSizeValue(StreamInput in) |
static TimeValue |
TimeValue.readTimeValue(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static BloomFilter |
BloomFilter.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
NodesFaultDetection.PingRequest.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
ZenPing.PingResponse.readFrom(StreamInput in) |
static ZenPing.PingResponse |
ZenPing.PingResponse.readPingResponse(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TransportNodesListGatewayMetaState.NodesLocalGatewayMetaState.readFrom(StreamInput in) |
void |
TransportNodesListGatewayMetaState.NodeLocalGatewayMetaState.readFrom(StreamInput in) |
void |
LocalAllocateDangledIndices.AllocateDangledResponse.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TransportNodesListGatewayStartedShards.NodesLocalGatewayStartedShards.readFrom(StreamInput in) |
void |
TransportNodesListGatewayStartedShards.NodeLocalGatewayStartedShards.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
HttpStats.readFrom(StreamInput in) |
void |
HttpInfo.readFrom(StreamInput in) |
static HttpInfo |
HttpInfo.readHttpInfo(StreamInput in) |
static HttpStats |
HttpStats.readHttpStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
Index.readFrom(StreamInput in) |
static Index |
Index.readIndexName(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static FilterCacheStats |
FilterCacheStats.readFilterCacheStats(StreamInput in) |
void |
FilterCacheStats.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
IdCacheStats.readFrom(StreamInput in)
Deprecated.
|
static IdCacheStats |
IdCacheStats.readIdCacheStats(StreamInput in)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
QueryCacheStats.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SegmentsStats.readFrom(StreamInput in) |
void |
Segment.readFrom(StreamInput in) |
static Segment |
Segment.readSegment(StreamInput in) |
static SegmentsStats |
SegmentsStats.readSegmentsStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static FieldDataStats |
FieldDataStats.readFieldDataStats(StreamInput in) |
void |
FieldDataStats.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static FlushStats |
FlushStats.readFlushStats(StreamInput in) |
void |
FlushStats.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
GetStats.readFrom(StreamInput in) |
void |
GetResult.readFrom(StreamInput in) |
void |
GetField.readFrom(StreamInput in) |
static GetField |
GetField.readGetField(StreamInput in) |
static GetResult |
GetResult.readGetResult(StreamInput in) |
static GetStats |
GetStats.readGetStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
IndexingStats.readFrom(StreamInput in) |
void |
IndexingStats.Stats.readFrom(StreamInput in) |
static IndexingStats |
IndexingStats.readIndexingStats(StreamInput in) |
static IndexingStats.Stats |
IndexingStats.Stats.readStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
MergeStats.readFrom(StreamInput in) |
static MergeStats |
MergeStats.readMergeStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PercolateStats.readFrom(StreamInput in) |
static PercolateStats |
PercolateStats.readPercolateStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
RecoveryStats.readFrom(StreamInput in) |
static RecoveryStats |
RecoveryStats.readRecoveryStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
RefreshStats.readFrom(StreamInput in) |
static RefreshStats |
RefreshStats.readRefreshStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SearchStats.readFrom(StreamInput in) |
void |
SearchStats.Stats.readFrom(StreamInput in) |
static SearchStats |
SearchStats.readSearchStats(StreamInput in) |
static SearchStats.Stats |
SearchStats.Stats.readStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static DocsStats |
DocsStats.readDocStats(StreamInput in) |
void |
DocsStats.readFrom(StreamInput in) |
void |
ShardId.readFrom(StreamInput in) |
static ShardId |
ShardId.readShardId(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static Store.MetadataSnapshot |
Store.MetadataSnapshot.read(StreamInput in) |
void |
StoreStats.readFrom(StreamInput in) |
void |
Store.MetadataSnapshot.readFrom(StreamInput in) |
void |
StoreFileMetaData.readFrom(StreamInput in) |
static StoreFileMetaData |
StoreFileMetaData.readStoreFileMetaData(StreamInput in) |
static StoreStats |
StoreStats.readStoreStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SuggestStats.readFrom(StreamInput in) |
static SuggestStats |
SuggestStats.readSuggestStats(StreamInput in) |
Modifier and Type | Class and Description |
---|---|
class |
BufferedChecksumStreamInput
Similar to Lucene's BufferedChecksumIndexInput, however this wraps a
StreamInput so anything read will update the checksum |
Modifier and Type | Method and Description |
---|---|
StreamInput |
TranslogStream.openInput(File translogFile)
Seek past the header, if any header is present
|
StreamInput |
LegacyTranslogStream.openInput(File translogFile) |
StreamInput |
ChecksummedTranslogStream.openInput(File translogFile) |
Modifier and Type | Method and Description |
---|---|
Translog.Operation |
TranslogStream.read(StreamInput in)
Read the next translog operation from the input stream
|
Translog.Operation |
LegacyTranslogStream.read(StreamInput in) |
Translog.Operation |
ChecksummedTranslogStream.read(StreamInput inStream) |
void |
TranslogStats.readFrom(StreamInput in) |
void |
Translog.Create.readFrom(StreamInput in) |
void |
Translog.Index.readFrom(StreamInput in) |
void |
Translog.Delete.readFrom(StreamInput in) |
void |
Translog.DeleteByQuery.readFrom(StreamInput in) |
static Translog.Operation |
TranslogStreams.readTranslogOperation(StreamInput in)
Read the next
Translog.Operation from the stream using the
latest translog version |
Constructor and Description |
---|
BufferedChecksumStreamInput(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
WarmerStats.readFrom(StreamInput in) |
static WarmerStats |
WarmerStats.readWarmerStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
NodeIndicesStats.readFrom(StreamInput in) |
static NodeIndicesStats |
NodeIndicesStats.readIndicesStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
CircuitBreakerStats.readFrom(StreamInput in) |
void |
AllCircuitBreakerStats.readFrom(StreamInput in) |
static AllCircuitBreakerStats |
AllCircuitBreakerStats.readOptionalAllCircuitBreakerStats(StreamInput in) |
static CircuitBreakerStats |
CircuitBreakerStats.readOptionalCircuitBreakerStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static RecoveryState.File |
RecoveryState.File.readFile(StreamInput in) |
void |
RecoveryFileChunkRequest.readFrom(StreamInput in) |
void |
StartRecoveryRequest.readFrom(StreamInput in) |
void |
RecoveryState.readFrom(StreamInput in) |
void |
RecoveryState.Timer.readFrom(StreamInput in) |
void |
RecoveryState.Start.readFrom(StreamInput in) |
void |
RecoveryState.Translog.readFrom(StreamInput in) |
void |
RecoveryState.File.readFrom(StreamInput in) |
void |
RecoveryState.Index.readFrom(StreamInput in) |
static RecoveryState |
RecoveryState.readRecoveryState(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TransportNodesListShardStoreMetaData.StoreFilesMetaData.readFrom(StreamInput in) |
void |
TransportNodesListShardStoreMetaData.NodesStoreFilesMetaData.readFrom(StreamInput in) |
void |
TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData.readFrom(StreamInput in) |
static TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData |
TransportNodesListShardStoreMetaData.NodeStoreFilesMetaData.readListShardStoreNodeOperationResponse(StreamInput in) |
static TransportNodesListShardStoreMetaData.StoreFilesMetaData |
TransportNodesListShardStoreMetaData.StoreFilesMetaData.readStoreFilesMetaData(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
FsStats.readFrom(StreamInput in) |
void |
FsStats.Info.readFrom(StreamInput in) |
static FsStats |
FsStats.readFsStats(StreamInput in) |
static FsStats.Info |
FsStats.Info.readInfoFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
JvmStats.readFrom(StreamInput in) |
void |
JvmStats.GarbageCollectors.readFrom(StreamInput in) |
void |
JvmStats.GarbageCollector.readFrom(StreamInput in) |
void |
JvmStats.GarbageCollector.LastGc.readFrom(StreamInput in) |
void |
JvmStats.Threads.readFrom(StreamInput in) |
void |
JvmStats.MemoryPool.readFrom(StreamInput in) |
void |
JvmStats.Mem.readFrom(StreamInput in) |
void |
JvmStats.BufferPool.readFrom(StreamInput in) |
void |
JvmInfo.readFrom(StreamInput in) |
void |
JvmInfo.Mem.readFrom(StreamInput in) |
static JvmStats.GarbageCollector |
JvmStats.GarbageCollector.readGarbageCollector(StreamInput in) |
static JvmStats.GarbageCollectors |
JvmStats.GarbageCollectors.readGarbageCollectors(StreamInput in) |
static JvmInfo |
JvmInfo.readJvmInfo(StreamInput in) |
static JvmStats |
JvmStats.readJvmStats(StreamInput in) |
static JvmStats.GarbageCollector.LastGc |
JvmStats.GarbageCollector.LastGc.readLastGc(StreamInput in) |
static JvmStats.Mem |
JvmStats.Mem.readMem(StreamInput in) |
static JvmInfo.Mem |
JvmInfo.Mem.readMem(StreamInput in) |
static JvmStats.MemoryPool |
JvmStats.MemoryPool.readMemoryPool(StreamInput in) |
static JvmStats.Threads |
JvmStats.Threads.readThreads(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
NetworkStats.readFrom(StreamInput in) |
void |
NetworkStats.Tcp.readFrom(StreamInput in) |
void |
NetworkInfo.readFrom(StreamInput in) |
void |
NetworkInfo.Interface.readFrom(StreamInput in) |
static NetworkInfo |
NetworkInfo.readNetworkInfo(StreamInput in) |
static NetworkInfo.Interface |
NetworkInfo.Interface.readNetworkInterface(StreamInput in) |
static NetworkStats |
NetworkStats.readNetworkStats(StreamInput in) |
static NetworkStats.Tcp |
NetworkStats.Tcp.readNetworkTcp(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static OsStats.Cpu |
OsStats.Cpu.readCpu(StreamInput in) |
static OsInfo.Cpu |
OsInfo.Cpu.readCpu(StreamInput in) |
void |
OsStats.readFrom(StreamInput in) |
void |
OsStats.Swap.readFrom(StreamInput in) |
void |
OsStats.Mem.readFrom(StreamInput in) |
void |
OsStats.Cpu.readFrom(StreamInput in) |
void |
OsInfo.readFrom(StreamInput in) |
void |
OsInfo.Swap.readFrom(StreamInput in) |
void |
OsInfo.Mem.readFrom(StreamInput in) |
void |
OsInfo.Cpu.readFrom(StreamInput in) |
static OsStats.Mem |
OsStats.Mem.readMem(StreamInput in) |
static OsInfo.Mem |
OsInfo.Mem.readMem(StreamInput in) |
static OsInfo |
OsInfo.readOsInfo(StreamInput in) |
static OsStats |
OsStats.readOsStats(StreamInput in) |
static OsStats.Swap |
OsStats.Swap.readSwap(StreamInput in) |
static OsInfo.Swap |
OsInfo.Swap.readSwap(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static ProcessStats.Cpu |
ProcessStats.Cpu.readCpu(StreamInput in) |
void |
ProcessStats.readFrom(StreamInput in) |
void |
ProcessStats.Mem.readFrom(StreamInput in) |
void |
ProcessStats.Cpu.readFrom(StreamInput in) |
void |
ProcessInfo.readFrom(StreamInput in) |
static ProcessStats.Mem |
ProcessStats.Mem.readMem(StreamInput in) |
static ProcessInfo |
ProcessInfo.readProcessInfo(StreamInput in) |
static ProcessStats |
ProcessStats.readProcessStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
VerificationFailure.readFrom(StreamInput in) |
static VerificationFailure |
VerificationFailure.readNode(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static RestStatus |
RestStatus.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static RiverClusterState |
RiverClusterState.Builder.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
RiverRouting.readFrom(StreamInput in) |
static RiversRouting |
RiversRouting.Builder.readFrom(StreamInput in) |
static RiverRouting |
RiverRouting.readRiverRouting(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static ScriptService.ScriptType |
ScriptService.ScriptType.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SearchShardTarget.readFrom(StreamInput in) |
void |
Scroll.readFrom(StreamInput in) |
static Scroll |
Scroll.readScroll(StreamInput in) |
static SearchShardTarget |
SearchShardTarget.readSearchShardTarget(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static InternalAggregations |
InternalAggregations.readAggregations(StreamInput in) |
void |
InternalAggregations.readFrom(StreamInput in) |
static InternalAggregations |
InternalAggregations.readOptionalAggregations(StreamInput in) |
InternalAggregation |
AggregationStreams.Stream.readResult(StreamInput in) |
protected static int |
InternalAggregation.readSize(StreamInput in)
Read a size under the assumption that a value of 0 means unlimited.
|
Modifier and Type | Method and Description |
---|---|
void |
InternalSingleBucketAggregation.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalFilters.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalGeoHashGrid.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalDateHistogram.readFrom(StreamInput in) |
void |
InternalHistogram.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalRange.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SignificantLongTerms.readFrom(StreamInput in) |
void |
UnmappedSignificantTerms.readFrom(StreamInput in) |
void |
SignificantStringTerms.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static SignificanceHeuristic |
SignificanceHeuristicStreams.read(StreamInput in) |
static SignificanceHeuristic |
PercentageScore.readFrom(StreamInput in) |
static SignificanceHeuristic |
JLHScore.readFrom(StreamInput in) |
SignificanceHeuristic |
SignificanceHeuristicStreams.Stream.readResult(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
LongTerms.readFrom(StreamInput in) |
void |
UnmappedTerms.readFrom(StreamInput in) |
void |
StringTerms.readFrom(StreamInput in) |
void |
DoubleTerms.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalAvg.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalCardinality.readFrom(StreamInput in) |
static HyperLogLogPlusPlus |
HyperLogLogPlusPlus.readFrom(StreamInput in,
BigArrays bigArrays) |
Modifier and Type | Method and Description |
---|---|
void |
InternalGeoBounds.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalMax.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalMin.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static TDigestState |
TDigestState.read(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalScriptedMetric.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalStats.readFrom(StreamInput in) |
void |
InternalStats.readOtherStatsFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalExtendedStats.readOtherStatsFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalSum.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalTopHits.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalValueCount.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static ValueFormatter |
ValueFormatterStreams.read(StreamInput in) |
void |
ValueFormatter.Raw.readFrom(StreamInput in) |
void |
ValueFormatter.DateTime.readFrom(StreamInput in) |
void |
ValueFormatter.Number.Pattern.readFrom(StreamInput in) |
void |
ValueFormatter.IPv4Formatter.readFrom(StreamInput in) |
void |
ValueFormatter.GeoHash.readFrom(StreamInput in) |
static ValueFormatter |
ValueFormatterStreams.readOptional(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static AggregatedDfs |
AggregatedDfs.readAggregatedDfs(StreamInput in) |
static DfsSearchResult |
DfsSearchResult.readDfsSearchResult(StreamInput in) |
static com.carrotsearch.hppc.ObjectObjectOpenHashMap<String,org.apache.lucene.search.CollectionStatistics> |
DfsSearchResult.readFieldStats(StreamInput in) |
static com.carrotsearch.hppc.ObjectObjectOpenHashMap<String,org.apache.lucene.search.CollectionStatistics> |
DfsSearchResult.readFieldStats(StreamInput in,
com.carrotsearch.hppc.ObjectObjectOpenHashMap<String,org.apache.lucene.search.CollectionStatistics> fieldStatistics) |
void |
AggregatedDfs.readFrom(StreamInput in) |
void |
DfsSearchResult.readFrom(StreamInput in) |
static org.apache.lucene.search.TermStatistics[] |
DfsSearchResult.readTermStats(StreamInput in,
org.apache.lucene.index.Term[] terms) |
Modifier and Type | Method and Description |
---|---|
Facet |
InternalFacet.Stream.readFacet(StreamInput in) |
static InternalFacets |
InternalFacets.readFacets(StreamInput in) |
void |
InternalFacet.readFrom(StreamInput in) |
void |
InternalFacets.readFrom(StreamInput in) |
static InternalFacets |
InternalFacets.readOptionalFacets(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalCountDateHistogramFacet.readFrom(StreamInput in) |
void |
InternalFullDateHistogramFacet.readFrom(StreamInput in) |
static InternalCountDateHistogramFacet |
InternalCountDateHistogramFacet.readHistogramFacet(StreamInput in) |
static InternalFullDateHistogramFacet |
InternalFullDateHistogramFacet.readHistogramFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static FilterFacet |
InternalFilterFacet.readFilterFacet(StreamInput in) |
void |
InternalFilterFacet.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalGeoDistanceFacet.readFrom(StreamInput in) |
static InternalGeoDistanceFacet |
InternalGeoDistanceFacet.readGeoDistanceFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalCountHistogramFacet.readFrom(StreamInput in) |
void |
InternalFullHistogramFacet.readFrom(StreamInput in) |
static InternalCountHistogramFacet |
InternalCountHistogramFacet.readHistogramFacet(StreamInput in) |
static InternalFullHistogramFacet |
InternalFullHistogramFacet.readHistogramFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalQueryFacet.readFrom(StreamInput in) |
static QueryFacet |
InternalQueryFacet.readQueryFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalRangeFacet.readFrom(StreamInput in) |
static InternalRangeFacet |
InternalRangeFacet.readRangeFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalStatisticalFacet.readFrom(StreamInput in) |
static StatisticalFacet |
InternalStatisticalFacet.readStatisticalFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalDoubleTermsFacet.readFrom(StreamInput in) |
static InternalDoubleTermsFacet |
InternalDoubleTermsFacet.readTermsFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalLongTermsFacet.readFrom(StreamInput in) |
static InternalLongTermsFacet |
InternalLongTermsFacet.readTermsFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalStringTermsFacet.readFrom(StreamInput in) |
static InternalStringTermsFacet |
InternalStringTermsFacet.readTermsFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalTermsStatsDoubleFacet.readFrom(StreamInput in) |
static InternalTermsStatsDoubleFacet |
InternalTermsStatsDoubleFacet.readTermsStatsFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalTermsStatsLongFacet.readFrom(StreamInput in) |
static InternalTermsStatsLongFacet |
InternalTermsStatsLongFacet.readTermsStatsFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
InternalTermsStatsStringFacet.readFrom(StreamInput in) |
static InternalTermsStatsStringFacet |
InternalTermsStatsStringFacet.readTermsStatsFacet(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static FetchSearchResult |
FetchSearchResult.readFetchSearchResult(StreamInput in) |
void |
ScrollQueryFetchSearchResult.readFrom(StreamInput in) |
void |
FetchSearchResult.readFrom(StreamInput in) |
void |
QueryFetchSearchResult.readFrom(StreamInput in) |
void |
ShardFetchSearchRequest.readFrom(StreamInput in) |
void |
ShardFetchRequest.readFrom(StreamInput in) |
static QueryFetchSearchResult |
QueryFetchSearchResult.readQueryFetchSearchResult(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static FetchSourceContext |
FetchSourceContext.optionalReadFromStream(StreamInput in) |
void |
FetchSourceContext.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
HighlightField.readFrom(StreamInput in) |
static HighlightField |
HighlightField.readHighlightField(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
ShardSearchLocalRequest.innerReadFrom(StreamInput in) |
void |
InternalSearchHits.readFrom(StreamInput in) |
void |
InternalSearchResponse.readFrom(StreamInput in) |
void |
InternalSearchHit.readFrom(StreamInput in) |
void |
InternalSearchHit.InternalNestedIdentity.readFrom(StreamInput in) |
void |
InternalScrollSearchRequest.readFrom(StreamInput in) |
void |
InternalSearchHitField.readFrom(StreamInput in) |
void |
ShardSearchTransportRequest.readFrom(StreamInput in) |
void |
InternalSearchHits.readFrom(StreamInput in,
InternalSearchHits.StreamContext context) |
void |
InternalSearchHit.readFrom(StreamInput in,
InternalSearchHits.StreamContext context) |
static InternalSearchResponse |
InternalSearchResponse.readInternalSearchResponse(StreamInput in) |
static InternalSearchHit |
InternalSearchHit.readSearchHit(StreamInput in,
InternalSearchHits.StreamContext context) |
static InternalSearchHitField |
InternalSearchHitField.readSearchHitField(StreamInput in) |
static InternalSearchHits |
InternalSearchHits.readSearchHits(StreamInput in) |
static InternalSearchHits |
InternalSearchHits.readSearchHits(StreamInput in,
InternalSearchHits.StreamContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ScrollQuerySearchResult.readFrom(StreamInput in) |
void |
QuerySearchRequest.readFrom(StreamInput in) |
void |
QuerySearchResult.readFrom(StreamInput in) |
void |
QuerySearchResult.readFromWithId(long id,
StreamInput in) |
static QuerySearchResult |
QuerySearchResult.readQuerySearchResult(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
Suggest.Suggestion.innerReadFrom(StreamInput in) |
void |
Suggest.readFrom(StreamInput in) |
void |
Suggest.Suggestion.readFrom(StreamInput in) |
void |
Suggest.Suggestion.Entry.readFrom(StreamInput in) |
void |
Suggest.Suggestion.Entry.Option.readFrom(StreamInput in) |
static Suggest |
Suggest.readSuggest(XContentBuilderString name,
StreamInput in) |
Modifier and Type | Method and Description |
---|---|
static CompletionStats |
CompletionStats.readCompletionStats(StreamInput in) |
void |
CompletionSuggestion.Entry.Option.readFrom(StreamInput in) |
void |
CompletionStats.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
PhraseSuggestion.Entry.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
TermSuggestion.innerReadFrom(StreamInput in) |
void |
TermSuggestion.Entry.Option.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
IndexWarmersMetaData |
IndexWarmersMetaData.Factory.readFrom(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
SnapshotShardFailure.readFrom(StreamInput in) |
void |
SnapshotInfo.readFrom(StreamInput in) |
void |
RestoreInfo.readFrom(StreamInput in) |
static RestoreInfo |
RestoreInfo.readOptionalRestoreInfo(StreamInput in)
Reads optional restore info from
StreamInput |
static SnapshotInfo |
SnapshotInfo.readOptionalSnapshotInfo(StreamInput in)
Reads optional snapshot information from stream input
|
static RestoreInfo |
RestoreInfo.readRestoreInfo(StreamInput in)
Reads restore info from
StreamInput |
static SnapshotInfo |
SnapshotInfo.readSnapshotInfo(StreamInput in)
Reads snapshot information from stream input
|
static SnapshotShardFailure |
SnapshotShardFailure.readSnapshotShardFailure(StreamInput in)
Reads shard failure information from stream input
|
Modifier and Type | Method and Description |
---|---|
void |
ThreadPoolStats.readFrom(StreamInput in) |
void |
ThreadPoolStats.Stats.readFrom(StreamInput in) |
void |
ThreadPoolInfo.readFrom(StreamInput in) |
void |
ThreadPool.Info.readFrom(StreamInput in) |
static ThreadPoolInfo |
ThreadPoolInfo.readThreadPoolInfo(StreamInput in) |
static ThreadPoolStats |
ThreadPoolStats.readThreadPoolStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
void |
TransportStats.readFrom(StreamInput in) |
void |
TransportInfo.readFrom(StreamInput in) |
void |
TransportMessage.readFrom(StreamInput in) |
void |
BytesTransportRequest.readFrom(StreamInput in) |
static TransportInfo |
TransportInfo.readTransportInfo(StreamInput in) |
static TransportStats |
TransportStats.readTransportStats(StreamInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
LocalTransport.handleResponse(StreamInput buffer,
LocalTransport sourceTransport,
TransportResponseHandler handler) |
Modifier and Type | Class and Description |
---|---|
class |
ChannelBufferStreamInput
A Netty
ChannelBuffer based StreamInput . |
Modifier and Type | Method and Description |
---|---|
static StreamInput |
ChannelBufferStreamInputFactory.create(org.jboss.netty.buffer.ChannelBuffer buffer) |
static StreamInput |
ChannelBufferStreamInputFactory.create(org.jboss.netty.buffer.ChannelBuffer buffer,
int size) |
Modifier and Type | Method and Description |
---|---|
protected String |
MessageChannelHandler.handleRequest(org.jboss.netty.channel.Channel channel,
StreamInput buffer,
long requestId,
Version version) |
protected void |
MessageChannelHandler.handleResponse(org.jboss.netty.channel.Channel channel,
StreamInput buffer,
TransportResponseHandler handler) |
Copyright © 2009–2015. All rights reserved.