-
Notifications
You must be signed in to change notification settings - Fork 455
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[tools] Allow reading all the shards in the directory in read_data_files #3857
Conversation
if err != nil { | ||
log.Fatalf("unable to open reader: %v", err) | ||
} | ||
for _, shard := range shards { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM just one comment re: default value.
optShard = getopt.Uint32Long("shard", 's', 0, "Shard [expected format uint32]") | ||
optPathPrefix = getopt.StringLong("path-prefix", 'p', "", "Path prefix [e.g. /var/lib/m3db]") | ||
optNamespace = getopt.StringLong("namespace", 'n', "default", "Namespace [e.g. metrics]") | ||
optShard = getopt.IntLong("shard", 's', 0, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think this should default to allShards
and not 0 now?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
* master: Remove unused message-read-error metric (#3869) Add p75/p25 as aggregation options (#3867) [aggregator] track dirty values to consume instead of scanning all within buffer past (#3847) [rules] Correctly match rollup tags for excludeBy operations (#3865) [dbnode] Create empty warm index fileset (#3859) [aggregator] Allow wait during tick to be interrupted on close (#3861) [aggregator] Add support for default configuration (#3856) [dbnode] Add WriteAttempt integration test index helper method (#3860) [tools] Allow reading all the shards in the directory in read_data_files (#3857) [tests] Add test for in-process aggregator writes [tools] Add annotation_checker tool (#3854) [tests] Convert docker-integration-tests/simple/test.sh to in-process test (#3850) [documentation] Update rollup rules documentation to provide an example of aggregating gauges (#3852)
What this PR does / why we need it:
Add option to
read_data_files
for reading all the shards in the directory.Special notes for your reviewer:
Does this PR introduce a user-facing and/or backwards incompatible change?:
Does this PR require updating code package or user-facing documentation?: