From 55482ca65ce80cdca698edb2100944bb9f333d3e Mon Sep 17 00:00:00 2001 From: David Kyle Date: Fri, 3 Feb 2017 16:07:46 +0000 Subject: [PATCH] Fix check style error after upgrade Original commit: elastic/x-pack-elasticsearch@db802d18379dd140bbcf12cf3ffc234e5ea16e24 --- .../elasticsearch/xpack/ml/action/CloseJobAction.java | 2 +- .../elasticsearch/xpack/ml/action/DeleteJobAction.java | 2 +- .../elasticsearch/xpack/ml/action/FlushJobAction.java | 2 +- .../xpack/ml/action/InternalOpenJobAction.java | 2 +- .../elasticsearch/xpack/ml/action/OpenJobAction.java | 2 +- .../xpack/ml/action/StartDatafeedAction.java | 2 +- .../xpack/ml/action/StopDatafeedAction.java | 2 +- .../xpack/ml/action/UpdateJobStateAction.java | 2 +- .../xpack/ml/datafeed/ProblemTracker.java | 2 +- .../aggregation/AggregationDataExtractor.java | 2 +- .../aggregation/AggregationDataExtractorContext.java | 2 +- .../aggregation/AggregationToJsonProcessor.java | 2 +- .../ml/datafeed/extractor/scroll/ExtractedField.java | 4 ++-- .../ml/datafeed/extractor/scroll/ExtractedFields.java | 2 +- .../datafeed/extractor/scroll/ScrollDataExtractor.java | 2 +- .../extractor/scroll/ScrollDataExtractorContext.java | 2 +- .../extractor/scroll/SearchHitToJsonProcessor.java | 2 +- .../ml/job/persistence/BatchedBucketsIterator.java | 2 +- .../ml/job/persistence/BatchedInfluencersIterator.java | 2 +- .../ml/job/persistence/BatchedRecordsIterator.java | 2 +- .../autodetect/writer/CsvDataToProcessWriter.java | 2 +- .../autodetect/writer/JsonDataToProcessWriter.java | 2 +- .../process/normalizer/AbstractLeafNormalizable.java | 2 +- .../normalizer/BucketInfluencerNormalizable.java | 2 +- .../job/process/normalizer/InfluencerNormalizable.java | 2 +- .../ml/job/process/normalizer/RecordNormalizable.java | 2 +- .../ml/job/results/PerPartitionMaxProbabilities.java | 2 +- .../elasticsearch/xpack/ml/utils/NamedPipeHelper.java | 4 ++-- .../xpack/persistent/PersistentActionCoordinator.java | 10 +++++----- .../aggregation/AggregationDataExtractorTests.java | 2 +- .../extractor/scroll/ScrollDataExtractorTests.java | 2 +- .../xpack/ml/integration/DatafeedJobIT.java | 2 +- .../job/persistence/BatchedDocumentsIteratorTests.java | 2 +- .../xpack/ml/job/process/DummyDataCountsReporter.java | 2 +- .../persistent/PersistentActionCoordinatorTests.java | 4 ++-- .../xpack/persistent/TestPersistentActionPlugin.java | 4 ++-- 36 files changed, 44 insertions(+), 44 deletions(-) diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/CloseJobAction.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/CloseJobAction.java index bd13a3cecb0..4908808c876 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/CloseJobAction.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/CloseJobAction.java @@ -125,7 +125,7 @@ public class CloseJobAction extends Action { - public RequestBuilder(ElasticsearchClient client, CloseJobAction action) { + RequestBuilder(ElasticsearchClient client, CloseJobAction action) { super(client, action, new Request()); } } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/DeleteJobAction.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/DeleteJobAction.java index fed7a027ad5..1e6e747ae38 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/DeleteJobAction.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/DeleteJobAction.java @@ -114,7 +114,7 @@ public class DeleteJobAction extends Action { - public RequestBuilder(ElasticsearchClient client, DeleteJobAction action) { + RequestBuilder(ElasticsearchClient client, DeleteJobAction action) { super(client, action, new Request()); } } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/FlushJobAction.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/FlushJobAction.java index 5d4109477fb..8c72eb10a18 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/FlushJobAction.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/FlushJobAction.java @@ -187,7 +187,7 @@ public class FlushJobAction extends Action { - public RequestBuilder(ElasticsearchClient client, FlushJobAction action) { + RequestBuilder(ElasticsearchClient client, FlushJobAction action) { super(client, action, new Request()); } } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/InternalOpenJobAction.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/InternalOpenJobAction.java index 7976e536675..74825f2bdae 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/InternalOpenJobAction.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/InternalOpenJobAction.java @@ -62,7 +62,7 @@ public class InternalOpenJobAction extends Action { - public RequestBuilder(ElasticsearchClient client, InternalOpenJobAction action) { + RequestBuilder(ElasticsearchClient client, InternalOpenJobAction action) { super(client, action, new Request()); } } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/OpenJobAction.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/OpenJobAction.java index d256fa97998..feb297930f5 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/OpenJobAction.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/OpenJobAction.java @@ -136,7 +136,7 @@ public class OpenJobAction extends Action { - public RequestBuilder(ElasticsearchClient client, OpenJobAction action) { + RequestBuilder(ElasticsearchClient client, OpenJobAction action) { super(client, action, new Request()); } } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/StartDatafeedAction.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/StartDatafeedAction.java index 87861c060a7..15bb7d9d30a 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/StartDatafeedAction.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/StartDatafeedAction.java @@ -189,7 +189,7 @@ public class StartDatafeedAction static class RequestBuilder extends ActionRequestBuilder { - public RequestBuilder(ElasticsearchClient client, StartDatafeedAction action) { + RequestBuilder(ElasticsearchClient client, StartDatafeedAction action) { super(client, action, new Request()); } } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/StopDatafeedAction.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/StopDatafeedAction.java index fa692308953..edd773badda 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/StopDatafeedAction.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/StopDatafeedAction.java @@ -111,7 +111,7 @@ public class StopDatafeedAction static class RequestBuilder extends ActionRequestBuilder { - public RequestBuilder(ElasticsearchClient client, StopDatafeedAction action) { + RequestBuilder(ElasticsearchClient client, StopDatafeedAction action) { super(client, action, new Request()); } } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/UpdateJobStateAction.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/UpdateJobStateAction.java index 7220f0a0b62..96da125f42b 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/UpdateJobStateAction.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/UpdateJobStateAction.java @@ -132,7 +132,7 @@ public class UpdateJobStateAction static class RequestBuilder extends MasterNodeOperationRequestBuilder { - public RequestBuilder(ElasticsearchClient client, UpdateJobStateAction action) { + RequestBuilder(ElasticsearchClient client, UpdateJobStateAction action) { super(client, action, new Request()); } } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/ProblemTracker.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/ProblemTracker.java index 178cbae1fc3..a2072d3f15f 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/ProblemTracker.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/ProblemTracker.java @@ -35,7 +35,7 @@ class ProblemTracker { private volatile int emptyDataCount; - public ProblemTracker(Supplier auditor) { + ProblemTracker(Supplier auditor) { this.auditor = Objects.requireNonNull(auditor); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractor.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractor.java index 78e4cafb6fb..0dd0a28ea23 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractor.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractor.java @@ -38,7 +38,7 @@ class AggregationDataExtractor implements DataExtractor { private boolean hasNext; private boolean isCancelled; - public AggregationDataExtractor(Client client, AggregationDataExtractorContext dataExtractorContext) { + AggregationDataExtractor(Client client, AggregationDataExtractorContext dataExtractorContext) { this.client = Objects.requireNonNull(client); this.context = Objects.requireNonNull(dataExtractorContext); this.hasNext = true; diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractorContext.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractorContext.java index 4a814b6c2e0..860ce25b690 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractorContext.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractorContext.java @@ -22,7 +22,7 @@ class AggregationDataExtractorContext { final long start; final long end; - public AggregationDataExtractorContext(String jobId, String timeField, List indexes, List types, QueryBuilder query, + AggregationDataExtractorContext(String jobId, String timeField, List indexes, List types, QueryBuilder query, AggregatorFactories.Builder aggs, long start, long end) { this.jobId = Objects.requireNonNull(jobId); this.timeField = Objects.requireNonNull(timeField); diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationToJsonProcessor.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationToJsonProcessor.java index ecf6e29a453..03bc67e0496 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationToJsonProcessor.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationToJsonProcessor.java @@ -30,7 +30,7 @@ class AggregationToJsonProcessor implements Releasable { private final XContentBuilder jsonBuilder; private final Map keyValuePairs; - public AggregationToJsonProcessor(OutputStream outputStream) throws IOException { + AggregationToJsonProcessor(OutputStream outputStream) throws IOException { jsonBuilder = new XContentBuilder(JsonXContent.jsonXContent, outputStream); keyValuePairs = new LinkedHashMap<>(); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ExtractedField.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ExtractedField.java index 50a1394141a..c994c8152b1 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ExtractedField.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ExtractedField.java @@ -50,7 +50,7 @@ abstract class ExtractedField { private static class FromFields extends ExtractedField { - public FromFields(String name, ExtractionMethod extractionMethod) { + FromFields(String name, ExtractionMethod extractionMethod) { super(name, extractionMethod); } @@ -69,7 +69,7 @@ abstract class ExtractedField { private String[] namePath; - public FromSource(String name, ExtractionMethod extractionMethod) { + FromSource(String name, ExtractionMethod extractionMethod) { super(name, extractionMethod); namePath = name.split("\\."); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ExtractedFields.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ExtractedFields.java index abded996211..719870d0dd6 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ExtractedFields.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ExtractedFields.java @@ -22,7 +22,7 @@ class ExtractedFields { private final ExtractedField timeField; private final List allFields; - public ExtractedFields(ExtractedField timeField, List allFields) { + ExtractedFields(ExtractedField timeField, List allFields) { if (!allFields.contains(timeField)) { throw new IllegalArgumentException("timeField should also be contained in allFields"); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractor.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractor.java index fbecf555662..d8c7f16d6a7 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractor.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractor.java @@ -47,7 +47,7 @@ class ScrollDataExtractor implements DataExtractor { private boolean hasNext; private Long timestampOnCancel; - public ScrollDataExtractor(Client client, ScrollDataExtractorContext dataExtractorContext) { + ScrollDataExtractor(Client client, ScrollDataExtractorContext dataExtractorContext) { this.client = Objects.requireNonNull(client); this.context = Objects.requireNonNull(dataExtractorContext); this.hasNext = true; diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractorContext.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractorContext.java index 6acde5e821a..80fe0922c8c 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractorContext.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractorContext.java @@ -23,7 +23,7 @@ class ScrollDataExtractorContext { final long start; final long end; - public ScrollDataExtractorContext(String jobId, ExtractedFields extractedFields, List indexes, List types, + ScrollDataExtractorContext(String jobId, ExtractedFields extractedFields, List indexes, List types, QueryBuilder query, List scriptFields, int scrollSize, long start, long end) { this.jobId = Objects.requireNonNull(jobId); diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/SearchHitToJsonProcessor.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/SearchHitToJsonProcessor.java index da2d4f61dc2..193d92a13dc 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/SearchHitToJsonProcessor.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/SearchHitToJsonProcessor.java @@ -19,7 +19,7 @@ class SearchHitToJsonProcessor implements Releasable { private final ExtractedFields fields; private final XContentBuilder jsonBuilder; - public SearchHitToJsonProcessor(ExtractedFields fields, OutputStream outputStream) throws IOException { + SearchHitToJsonProcessor(ExtractedFields fields, OutputStream outputStream) throws IOException { this.fields = Objects.requireNonNull(fields); this.jsonBuilder = new XContentBuilder(JsonXContent.jsonXContent, outputStream); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedBucketsIterator.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedBucketsIterator.java index dad65d80ba9..c05056e8220 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedBucketsIterator.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedBucketsIterator.java @@ -18,7 +18,7 @@ import java.io.IOException; class BatchedBucketsIterator extends BatchedResultsIterator { - public BatchedBucketsIterator(Client client, String jobId) { + BatchedBucketsIterator(Client client, String jobId) { super(client, jobId, Bucket.RESULT_TYPE_VALUE); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedInfluencersIterator.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedInfluencersIterator.java index 6efa361da5d..2d908786cff 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedInfluencersIterator.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedInfluencersIterator.java @@ -17,7 +17,7 @@ import org.elasticsearch.xpack.ml.job.results.Influencer; import java.io.IOException; class BatchedInfluencersIterator extends BatchedResultsIterator { - public BatchedInfluencersIterator(Client client, String jobId) { + BatchedInfluencersIterator(Client client, String jobId) { super(client, jobId, Influencer.RESULT_TYPE_VALUE); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedRecordsIterator.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedRecordsIterator.java index 11fe417b169..71d65802787 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedRecordsIterator.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedRecordsIterator.java @@ -18,7 +18,7 @@ import java.io.IOException; class BatchedRecordsIterator extends BatchedResultsIterator { - public BatchedRecordsIterator(Client client, String jobId) { + BatchedRecordsIterator(Client client, String jobId) { super(client, jobId, AnomalyRecord.RESULT_TYPE_VALUE); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/writer/CsvDataToProcessWriter.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/writer/CsvDataToProcessWriter.java index 4a8d5e910af..13957d70d5b 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/writer/CsvDataToProcessWriter.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/writer/CsvDataToProcessWriter.java @@ -52,7 +52,7 @@ class CsvDataToProcessWriter extends AbstractDataToProcessWriter { */ private static final int MAX_LINES_PER_RECORD = 10000; - public CsvDataToProcessWriter(boolean includeControlField, AutodetectProcess autodetectProcess, + CsvDataToProcessWriter(boolean includeControlField, AutodetectProcess autodetectProcess, DataDescription dataDescription, AnalysisConfig analysisConfig, DataCountsReporter dataCountsReporter) { super(includeControlField, autodetectProcess, dataDescription, analysisConfig, dataCountsReporter, LOGGER); diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/writer/JsonDataToProcessWriter.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/writer/JsonDataToProcessWriter.java index f7fdbd78182..351accad434 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/writer/JsonDataToProcessWriter.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/writer/JsonDataToProcessWriter.java @@ -33,7 +33,7 @@ class JsonDataToProcessWriter extends AbstractDataToProcessWriter { private static final Logger LOGGER = Loggers.getLogger(JsonDataToProcessWriter.class); - public JsonDataToProcessWriter(boolean includeControlField, AutodetectProcess autodetectProcess, DataDescription dataDescription, + JsonDataToProcessWriter(boolean includeControlField, AutodetectProcess autodetectProcess, DataDescription dataDescription, AnalysisConfig analysisConfig, DataCountsReporter dataCountsReporter) { super(includeControlField, autodetectProcess, dataDescription, analysisConfig, dataCountsReporter, LOGGER); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/AbstractLeafNormalizable.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/AbstractLeafNormalizable.java index 4bb3e5f6748..17e6e965bdd 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/AbstractLeafNormalizable.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/AbstractLeafNormalizable.java @@ -10,7 +10,7 @@ import java.util.List; abstract class AbstractLeafNormalizable extends Normalizable { - public AbstractLeafNormalizable(String indexName) { + AbstractLeafNormalizable(String indexName) { super(indexName); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/BucketInfluencerNormalizable.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/BucketInfluencerNormalizable.java index 00412a46944..af570970095 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/BucketInfluencerNormalizable.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/BucketInfluencerNormalizable.java @@ -15,7 +15,7 @@ import java.util.Objects; class BucketInfluencerNormalizable extends AbstractLeafNormalizable { private final BucketInfluencer bucketInfluencer; - public BucketInfluencerNormalizable(BucketInfluencer influencer, String indexName) { + BucketInfluencerNormalizable(BucketInfluencer influencer, String indexName) { super(indexName); bucketInfluencer = Objects.requireNonNull(influencer); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/InfluencerNormalizable.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/InfluencerNormalizable.java index c7aa5e051bd..d54666d686a 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/InfluencerNormalizable.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/InfluencerNormalizable.java @@ -14,7 +14,7 @@ import java.util.Objects; class InfluencerNormalizable extends AbstractLeafNormalizable { private final Influencer influencer; - public InfluencerNormalizable(Influencer influencer, String indexName) { + InfluencerNormalizable(Influencer influencer, String indexName) { super(indexName); this.influencer = Objects.requireNonNull(influencer); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/RecordNormalizable.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/RecordNormalizable.java index 3980f37d6aa..eedf640d954 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/RecordNormalizable.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/RecordNormalizable.java @@ -15,7 +15,7 @@ import java.util.Objects; class RecordNormalizable extends AbstractLeafNormalizable { private final AnomalyRecord record; - public RecordNormalizable(AnomalyRecord record, String indexName) { + RecordNormalizable(AnomalyRecord record, String indexName) { super(indexName); this.record = Objects.requireNonNull(record); } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/results/PerPartitionMaxProbabilities.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/results/PerPartitionMaxProbabilities.java index bcdb0d285fb..3937ee6abeb 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/results/PerPartitionMaxProbabilities.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/results/PerPartitionMaxProbabilities.java @@ -132,7 +132,7 @@ public class PerPartitionMaxProbabilities extends ToXContentToBytes implements W private final class DoubleMaxBox { private double value = 0.0; - public DoubleMaxBox() { + DoubleMaxBox() { } public void accept(double d) { diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/utils/NamedPipeHelper.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/utils/NamedPipeHelper.java index ccce5fed877..d41a6e1c917 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/utils/NamedPipeHelper.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/ml/utils/NamedPipeHelper.java @@ -278,7 +278,7 @@ public class NamedPipeHelper { private final Path file; - public PrivilegedInputPipeOpener(Path file) { + PrivilegedInputPipeOpener(Path file) { this.file = file; } @@ -300,7 +300,7 @@ public class NamedPipeHelper { private final Path file; - public PrivilegedOutputPipeOpener(Path file) { + PrivilegedOutputPipeOpener(Path file) { this.file = file; } diff --git a/elasticsearch/src/main/java/org/elasticsearch/xpack/persistent/PersistentActionCoordinator.java b/elasticsearch/src/main/java/org/elasticsearch/xpack/persistent/PersistentActionCoordinator.java index 61ada404271..f30f2a2d663 100644 --- a/elasticsearch/src/main/java/org/elasticsearch/xpack/persistent/PersistentActionCoordinator.java +++ b/elasticsearch/src/main/java/org/elasticsearch/xpack/persistent/PersistentActionCoordinator.java @@ -193,7 +193,7 @@ public class PersistentActionCoordinator extends AbstractComponent implements Cl private class PersistentTaskListener implements ActionListener { private final RunningPersistentTask task; - public PersistentTaskListener(final RunningPersistentTask task) { + PersistentTaskListener(final RunningPersistentTask task) { this.task = task; } @@ -221,7 +221,7 @@ public class PersistentActionCoordinator extends AbstractComponent implements Cl private class PublishedResponseListener implements ActionListener { private final RunningPersistentTask task; - public PublishedResponseListener(final RunningPersistentTask task) { + PublishedResponseListener(final RunningPersistentTask task) { this.task = task; } @@ -256,7 +256,7 @@ public class PersistentActionCoordinator extends AbstractComponent implements Cl private final long id; private final long allocationId; - public PersistentTaskId(long id, long allocationId) { + PersistentTaskId(long id, long allocationId) { this.id = id; this.allocationId = allocationId; } @@ -284,11 +284,11 @@ public class PersistentActionCoordinator extends AbstractComponent implements Cl @Nullable private Exception failure; - public RunningPersistentTask(PersistentTask task, long id) { + RunningPersistentTask(PersistentTask task, long id) { this(task, id, State.STARTED); } - public RunningPersistentTask(PersistentTask task, long id, State state) { + RunningPersistentTask(PersistentTask task, long id, State state) { this.task = task; this.id = id; this.state = new AtomicReference<>(state); diff --git a/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractorTests.java b/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractorTests.java index 74669781b1b..64054b2c291 100644 --- a/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractorTests.java +++ b/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractorTests.java @@ -57,7 +57,7 @@ public class AggregationDataExtractorTests extends ESTestCase { private SearchResponse nextResponse; - public TestDataExtractor(long start, long end) { + TestDataExtractor(long start, long end) { super(client, createContext(start, end)); } diff --git a/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractorTests.java b/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractorTests.java index 4aae114f04d..05eaf26066e 100644 --- a/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractorTests.java +++ b/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractorTests.java @@ -59,7 +59,7 @@ public class ScrollDataExtractorTests extends ESTestCase { private SearchResponse nextResponse; - public TestDataExtractor(long start, long end) { + TestDataExtractor(long start, long end) { super(client, createContext(start, end)); } diff --git a/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/integration/DatafeedJobIT.java b/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/integration/DatafeedJobIT.java index 51824ecf06b..e873a142425 100644 --- a/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/integration/DatafeedJobIT.java +++ b/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/integration/DatafeedJobIT.java @@ -266,7 +266,7 @@ public class DatafeedJobIT extends ESRestTestCase { private boolean shouldSucceedInput; private boolean shouldSucceedProcessing; - public LookbackOnlyTestHelper(String jobId, String dataIndex) { + LookbackOnlyTestHelper(String jobId, String dataIndex) { this.jobId = jobId; this.dataIndex = dataIndex; this.shouldSucceedInput = true; diff --git a/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/job/persistence/BatchedDocumentsIteratorTests.java b/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/job/persistence/BatchedDocumentsIteratorTests.java index 7fcc08ff99c..98ad716743b 100644 --- a/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/job/persistence/BatchedDocumentsIteratorTests.java +++ b/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/job/persistence/BatchedDocumentsIteratorTests.java @@ -188,7 +188,7 @@ public class BatchedDocumentsIteratorTests extends ESTestCase { } private static class TestIterator extends BatchedDocumentsIterator { - public TestIterator(Client client, String jobId) { + TestIterator(Client client, String jobId) { super(client, jobId); } diff --git a/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/job/process/DummyDataCountsReporter.java b/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/job/process/DummyDataCountsReporter.java index 9be269f9c3d..28d91a30289 100644 --- a/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/job/process/DummyDataCountsReporter.java +++ b/elasticsearch/src/test/java/org/elasticsearch/xpack/ml/job/process/DummyDataCountsReporter.java @@ -19,7 +19,7 @@ class DummyDataCountsReporter extends DataCountsReporter { int logStatusCallCount = 0; - public DummyDataCountsReporter() { + DummyDataCountsReporter() { super(mock(ThreadPool.class), Settings.EMPTY, "DummyJobId", new DataCounts("DummyJobId"), mock(JobDataCountsPersister.class)); } diff --git a/elasticsearch/src/test/java/org/elasticsearch/xpack/persistent/PersistentActionCoordinatorTests.java b/elasticsearch/src/test/java/org/elasticsearch/xpack/persistent/PersistentActionCoordinatorTests.java index 772bcabfb4d..54073b200c9 100644 --- a/elasticsearch/src/test/java/org/elasticsearch/xpack/persistent/PersistentActionCoordinatorTests.java +++ b/elasticsearch/src/test/java/org/elasticsearch/xpack/persistent/PersistentActionCoordinatorTests.java @@ -328,7 +328,7 @@ public class PersistentActionCoordinatorTests extends ESTestCase { private final PersistentActionRegistry.PersistentActionHolder holder; private final ActionListener listener; - public Execution(PersistentActionRequest request, PersistentTask task, PersistentActionRegistry.PersistentActionHolder holder, + Execution(PersistentActionRequest request, PersistentTask task, PersistentActionRegistry.PersistentActionHolder holder, ActionListener listener) { this.request = request; this.task = task; @@ -340,7 +340,7 @@ public class PersistentActionCoordinatorTests extends ESTestCase { private class MockExecutor extends PersistentActionExecutor { private List executions = new ArrayList<>(); - public MockExecutor() { + MockExecutor() { super(null); } diff --git a/elasticsearch/src/test/java/org/elasticsearch/xpack/persistent/TestPersistentActionPlugin.java b/elasticsearch/src/test/java/org/elasticsearch/xpack/persistent/TestPersistentActionPlugin.java index fdba169079a..fdd5eac704c 100644 --- a/elasticsearch/src/test/java/org/elasticsearch/xpack/persistent/TestPersistentActionPlugin.java +++ b/elasticsearch/src/test/java/org/elasticsearch/xpack/persistent/TestPersistentActionPlugin.java @@ -422,11 +422,11 @@ public class TestPersistentActionPlugin extends Plugin implements ActionPlugin { static class TestTaskResponse implements Writeable { - public TestTaskResponse() { + TestTaskResponse() { } - public TestTaskResponse(StreamInput in) throws IOException { + TestTaskResponse(StreamInput in) throws IOException { in.readBoolean(); }