Commit 0ea7210
authored
* [Refactor] StreamIO from common to core.common namespace in core lib (#8157)
* [Refactor] StreamIO from common to core.common in core lib
This PR is a mechanical refactor of all Stream classes in
o.o.common.io.stream to o.o.core.common.io.stream namespace.
In addition to the namespace refactor several loose end classes in
o.o.common.io.stream of the :server module are refactored to
o.o.core.common.io.stream of the :libs:opensearch-core library. These
classes include the following:
* ByteBufferStreamInpu
* BytesStreamInput
* DataOutputStreamOutput
* FilterStreamInput
* NamedWriteableAwareStreamInput
* OutputStreamStreamOutput
* VersionedNamedWriteable
Companion tests are also refactored from the server test folder to the
corresponding core test folder.
Signed-off-by: Nicholas Walter Knize <nknize@apache.org>
* update changelog
Signed-off-by: Nicholas Walter Knize <nknize@apache.org>
---------
Signed-off-by: Nicholas Walter Knize <nknize@apache.org>
1 parent ac52550 commit 0ea7210
2,895 files changed
Lines changed: 5868 additions & 5744 deletions
File tree
- benchmarks/src/main/java/org/opensearch/benchmark/search/aggregations
- bucket/terms
- client
- client-benchmark-noop-api-plugin/src/main/java/org/opensearch/plugin/noop/action
- bulk
- search
- rest-high-level/src
- main/java/org/opensearch/client
- cluster
- core
- indices
- slm
- tasks
- test/java/org/opensearch/client
- core
- tasks
- documentation
- indices
- tasks
- distribution/tools
- keystore-cli/src
- main/java/org/opensearch/common/settings
- test/java/org/opensearch
- bootstrap
- common/settings
- upgrade-cli/src/main/java/org/opensearch/upgrade
- libs
- core/src
- main/java/org/opensearch
- common
- io
- xcontent
- core
- action
- support
- common
- bytes
- compress
- io/stream
- settings
- text
- util
- index
- shard
- snapshots
- rest
- xcontent
- test/java/org/opensearch/core
- action/support
- common/io
- stream
- util
- ssl-config/src/test/java/org/opensearch/common/ssl
- x-content/src/test/java/org/opensearch/common/xcontent
- modules
- aggs-matrix-stats/src/main/java/org/opensearch/search/aggregations
- matrix/stats
- support
- analysis-common/src
- main/java/org/opensearch/analysis/common
- test/java/org/opensearch/analysis/common
- geo/src
- internalClusterTest/java/org/opensearch/geo/search/aggregations/metrics
- main/java/org/opensearch/geo/search/aggregations
- bucket
- composite
- geogrid
- metrics
- test/java/org/opensearch/geo/search/aggregations/bucket
- composite
- ingest-common/src
- internalClusterTest/java/org/opensearch/ingest/common
- main/java/org/opensearch/ingest/common
- test/java/org/opensearch/ingest/common
- ingest-geoip/src/internalClusterTest/java/org/opensearch/ingest/geoip
- lang-expression/src/internalClusterTest/java/org/opensearch/script/expression
- lang-mustache/src
- internalClusterTest/java/org/opensearch/script/mustache
- main/java/org/opensearch/script/mustache
- test/java/org/opensearch/script/mustache
- lang-painless/src
- main/java/org/opensearch/painless
- action
- test/java/org/opensearch/painless
- action
- mapper-extras/src
- main/java/org/opensearch/index/query
- test/java/org/opensearch/index/mapper
- parent-join/src
- internalClusterTest/java/org/opensearch/join/query
- main/java/org/opensearch/join
- aggregations
- query
- test/java/org/opensearch/join
- aggregations
- mapper
- percolator/src
- internalClusterTest/java/org/opensearch/percolator
- main/java/org/opensearch/percolator
- test/java/org/opensearch/percolator
- rank-eval/src
- main/java/org/opensearch/index/rankeval
- test/java/org/opensearch/index/rankeval
- reindex/src
- internalClusterTest/java/org/opensearch/client/documentation
- main/java/org/opensearch/index/reindex
- remote
- test/java/org/opensearch/index/reindex
- remote
- repository-url/src
- test/java/org/opensearch/repositories/url
- yamlRestTest/java/org/opensearch/repositories/url
- search-pipeline-common/src
- internalClusterTest/java/org/opensearch/search/pipeline/common
- main/java/org/opensearch/search/pipeline/common
- test/java/org/opensearch/search/pipeline/common
- systemd/src/main/java/org/opensearch/systemd
- transport-netty4/src
- javaRestTest/java/org/opensearch/rest
- main/java/org/opensearch
- http/netty4
- transport
- netty4
- test/java/org/opensearch
- http/netty4
- transport/netty4
- plugins
- analysis-icu/src
- main/java/org/opensearch
- index/mapper
- plugin/analysis/icu
- test/java/org/opensearch/index/analysis
- analysis-kuromoji/src/test/java/org/opensearch/index/analysis
- analysis-phonetic/src/test/java/org/opensearch/index/analysis
- analysis-smartcn/src/test/java/org/opensearch/index/analysis
- analysis-stempel/src/test/java/org/opensearch/index/analysis
- analysis-ukrainian/src/test/java/org/opensearch/index/analysis
- discovery-ec2
- qa/amazon-ec2/src/yamlRestTest/java/org/opensearch/discovery/ec2
- src
- main/java/org/opensearch/discovery/ec2
- test/java/org/opensearch/discovery/ec2
- discovery-gce/qa/gce/src/yamlRestTest/java/org/opensearch/cloud/gce
- examples
- custom-settings/src/main/java/org/opensearch/example/customsettings
- custom-significance-heuristic/src
- main/java/org/opensearch/example/customsigheuristic
- test/java/org/opensearch/example/customsigheuristic
- custom-suggester/src/main/java/org/opensearch/example/customsuggester
- rescore/src
- main/java/org/opensearch/example/rescore
- test/java/org/opensearch/example/rescore
- mapper-size/src/internalClusterTest/java/org/opensearch/index/mapper/size
- repository-azure/src
- internalClusterTest/java/org/opensearch/repositories/azure
- main/java/org/opensearch/repositories/azure
- test/java/org/opensearch/repositories/azure
- repository-gcs/src
- internalClusterTest/java/org/opensearch/repositories/gcs
- main/java/org/opensearch/repositories/gcs
- test/java/org/opensearch/repositories/gcs
- repository-hdfs/src/test/java/org/opensearch/repositories/hdfs
- repository-s3/src
- internalClusterTest/java/org/opensearch/repositories/s3
- main/java/org/opensearch/repositories/s3
- test/java/org/opensearch/repositories/s3
- transport-nio/src
- main/java/org/opensearch
- http/nio
- transport/nio
- test/java/org/opensearch
- http/nio
- transport/nio
- qa
- full-cluster-restart/src/test/java/org/opensearch/upgrades
- logging-config/src/test/java/org/opensearch/common/logging
- mixed-cluster/src/test/java/org/opensearch/backwards
- multi-cluster-search/src/test/java/org/opensearch/search
- rolling-upgrade/src/test/java/org/opensearch/upgrades
- smoke-test-http/src/test/java/org/opensearch/http
- server/src
- internalClusterTest/java/org/opensearch
- action
- admin
- cluster
- allocation
- node/tasks
- snapshots
- indices
- alias
- create
- datastream
- forcemerge
- mapping/put
- shards
- bulk
- ingest
- search
- support
- replication
- cluster
- allocation
- coordination
- metadata
- routing
- common/settings
- explain
- gateway
- get
- index
- engine
- seqno
- shard
- store
- indices
- memory/breaker
- recovery
- replication
- state
- stats
- store
- template
- ingest
- mget
- recovery
- remotestore
- repositories/fs
- routing
- script
- search
- aggregations
- bucket
- metrics
- pipeline
- backpressure
- basic
- fetch
- subphase
- highlight
- fields
- functionscore
- geo
- preference
- query
- scroll
- simple
- sort
- suggest
- snapshots
- update
- validate
- versioning
- main/java/org
- apache/lucene/queries
- opensearch
- action
- admin
- cluster
- allocation
- configuration
- decommission/awareness
- delete
- get
- put
- health
- node
- hotthreads
- info
- liveness
- reload
- stats
- tasks
- cancel
- get
- list
- usage
- remotestore
- restore
- stats
- remote
- repositories
- cleanup
- delete
- get
- put
- verify
- reroute
- settings
- shards
- routing/weighted
- delete
- get
- put
- snapshots
- clone
- create
- delete
- get
- restore
- status
- state
- stats
- storedscripts
- tasks
- indices
- alias
- get
- analyze
- cache/clear
- close
- create
- dangling
- delete
- find
- import_index
- list
- datastream
- delete
- exists/indices
- flush
- forcemerge
- get
- mapping
- get
- put
- open
- readonly
- recovery
- refresh
- replication
- resolve
- rollover
- segments
- settings
- get
- put
- shards
- shrink
- stats
- template
- delete
- get
- post
- put
- upgrade
- get
- post
- validate/query
- bulk
- delete
- explain
- fieldcaps
- get
- index
- ingest
- main
- resync
- search
- support
- broadcast
- node
- clustermanager
- info
- master
- info
- nodes
- replication
- single
- instance
- shard
- tasks
- termvectors
- update
- bootstrap
- client
- node
- support
- transport
- cli
- cluster
- ack
- action
- index
- shard
- awarenesshealth
- block
- coordination
- decommission
- health
- metadata
- node
- routing
- allocation
- command
- decider
- service
- common
- blobstore
- breaker
- bytes
- compress
- document
- geo
- builders
- io
- stream
- joda
- logging
- lucene
- index
- search/function
- metrics
- network
- rounding
- settings
- transport
- unit
- util
- concurrent
- xcontent
- discovery
- env
- extensions
- action
- rest
- settings
- gateway
- http
- index
- analysis
- cache
- bitset
- query
- request
- engine
- fielddata
- plain
- fieldvisitor
- flush
- get
- mapper
- merge
- query
- functionscore
- recovery
- refresh
- reindex
- remote
- search
- stats
- seqno
- shard
- snapshots
- blobstore
- stats
- store
- remote/filecache
- termvectors
- translog
- listener
- transfer
- warmer
- indices
- breaker
- cluster
- fielddata/cache
- recovery
- replication
- checkpoint
- common
- store
- ingest
- monitor
- fs
- jvm
- os
- process
- node
- persistent
- plugins
- repositories
- blobstore
- rest
- action
- admin
- cluster
- dangling
- indices
- cat
- document
- ingest
- search
- script
- search
- aggregations
- bucket
- adjacency
- composite
- filter
- global
- histogram
- missing
- nested
- range
- sampler
- terms
- heuristic
- metrics
- pipeline
- support
- backpressure
- stats
- trackers
- builder
- collapse
- dfs
- fetch
- subphase
- highlight
- internal
- lookup
- pipeline
- profile
- aggregation
- query
- query
- rescore
- searchafter
- slice
- sort
- suggest
- completion
- phrase
- term
- snapshots
- tasks
- threadpool
- transport
- test/java/org/opensearch
- action
- admin
- cluster
- allocation
- configuration
- decommission/awareness
- health
- node
- info
- stats
- tasks
- remotestore
- restore
- stats
- repositories/put
- reroute
- settings
- shards
- routing/weighted/put
- snapshots
- create
- get
- restore
- status
- state
- stats
- storedscripts
- indices
- alias
- get
- analyze
- cache/clear
- close
- create
- datastream
- flush
- forcemerge
- get
- mapping
- get
- put
- open
- refresh
- resolve
- rollover
- settings
- get
- put
- shards
- shrink
- stats
- template
- delete
- get
- post
- put
- validate/query
- bulk
- delete
- explain
- fieldcaps
- get
- index
- ingest
- main
- resync
- search
- support
- broadcast/node
- clustermanager
- nodes
- replication
- single/instance
- termvectors
- update
- client/node
- cluster
- action
- index
- shard
- awarenesshealth
- block
- coordination
- health
- metadata
- node
- routing
- allocation
- decider
- serialization
- service
- structure
- common
- bytes
- compress
- geo
- builders
- io
- stream
- lucene
- index
- uid
- network
- settings
- transport
- unit
- util
- xcontent
- builder
- cbor
- support
- filtering
- discovery
- env
- extensions
- action
- rest
- settings
- gateway
- http
- index
- analysis
- cache/bitset
- engine
- fielddata
- fieldstats
- get
- mapper
- query
- functionscore
- plugin
- refresh
- reindex
- remote
- replication
- search
- geo
- nested
- seqno
- shard
- snapshots/blobstore
- store
- remote
- filecache
- metadata
- suggest/stats
- translog
- listener
- transfer
- indices
- cluster
- recovery
- replication
- checkpoint
- common
- settings
- store
- ingest
- monitor/os
- nodesinfo
- node
- persistent
- plugins
- recovery
- repositories
- blobstore
- fs
- rest
- action
- admin
- cluster
- indices
- cat
- document
- script
- search
- aggregations
- bucket
- histogram
- range
- terms
- metrics
- weighted_avg
- pipeline
- support
- backpressure
- stats
- builder
- collapse
- fetch/subphase
- highlight
- internal
- pipeline
- pit
- profile
- aggregation
- query
- query
- rescore
- scroll
- searchafter
- slice
- sort
- plugin
- suggest
- completion
- phrase
- snapshots
- mockstore
- tasks
- threadpool
- transport
- test
- external-modules/delayed-aggs/src/main/java/org/opensearch/search/aggregations
- fixtures
- azure-fixture/src/main/java/fixture/azure
- gcs-fixture/src/main/java/fixture/gcs
- s3-fixture/src/main/java/fixture/s3
- framework/src
- main/java/org/opensearch
- action/support/replication
- cluster
- coordination
- routing
- common
- bytes
- settings
- util
- index
- engine
- mapper
- replication
- shard
- indices/recovery
- node
- repositories/blobstore
- search
- aggregations
- composite
- snapshots
- test
- client
- engine
- gateway
- hamcrest
- rest
- yaml
- restspec
- section
- store
- transport
- transport
- nio
- test/java/org/opensearch
- test
- disruption
- hamcrest
- rest/yaml
- restspec
- section
- test
- transport/nio
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
18 | 18 | | |
19 | 19 | | |
20 | 20 | | |
| 21 | + | |
21 | 22 | | |
22 | 23 | | |
23 | 24 | | |
| |||
Lines changed: 3 additions & 3 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
42 | 42 | | |
43 | 43 | | |
44 | 44 | | |
45 | | - | |
| 45 | + | |
46 | 46 | | |
47 | 47 | | |
48 | | - | |
49 | | - | |
| 48 | + | |
| 49 | + | |
50 | 50 | | |
51 | 51 | | |
52 | 52 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
34 | 34 | | |
35 | 35 | | |
36 | 36 | | |
37 | | - | |
| 37 | + | |
38 | 38 | | |
39 | 39 | | |
40 | 40 | | |
| |||
Lines changed: 2 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
41 | 41 | | |
42 | 42 | | |
43 | 43 | | |
44 | | - | |
| 44 | + | |
45 | 45 | | |
46 | 46 | | |
47 | 47 | | |
| |||
56 | 56 | | |
57 | 57 | | |
58 | 58 | | |
59 | | - | |
| 59 | + | |
60 | 60 | | |
61 | 61 | | |
62 | 62 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
41 | 41 | | |
42 | 42 | | |
43 | 43 | | |
44 | | - | |
| 44 | + | |
45 | 45 | | |
46 | 46 | | |
47 | 47 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
39 | 39 | | |
40 | 40 | | |
41 | 41 | | |
42 | | - | |
| 42 | + | |
43 | 43 | | |
44 | 44 | | |
45 | 45 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
47 | 47 | | |
48 | 48 | | |
49 | 49 | | |
50 | | - | |
| 50 | + | |
51 | 51 | | |
52 | 52 | | |
53 | 53 | | |
| |||
Lines changed: 2 additions & 2 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
39 | 39 | | |
40 | 40 | | |
41 | 41 | | |
42 | | - | |
| 42 | + | |
43 | 43 | | |
44 | 44 | | |
45 | 45 | | |
| |||
48 | 48 | | |
49 | 49 | | |
50 | 50 | | |
51 | | - | |
| 51 | + | |
52 | 52 | | |
53 | 53 | | |
54 | 54 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
88 | 88 | | |
89 | 89 | | |
90 | 90 | | |
91 | | - | |
| 91 | + | |
92 | 92 | | |
93 | 93 | | |
94 | 94 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
73 | 73 | | |
74 | 74 | | |
75 | 75 | | |
76 | | - | |
| 76 | + | |
77 | 77 | | |
78 | 78 | | |
79 | 79 | | |
| |||
0 commit comments