honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix check style error after upgrade 

Original commit: elastic/x-pack-elasticsearch@db802d1837
This commit is contained in:
David Kyle 2017-02-03 16:07:46 +00:00
parent 1b65366478
commit 55482ca65c
36 changed files with 44 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/CloseJobAction.java
View File

@ -125,7 +125,7 @@ public class CloseJobAction extends Action<CloseJobAction.Request, CloseJobActio
static class RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder> {
public RequestBuilder(ElasticsearchClient client, CloseJobAction action) {
RequestBuilder(ElasticsearchClient client, CloseJobAction action) {
super(client, action, new Request());
}
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/DeleteJobAction.java
View File

@ -114,7 +114,7 @@ public class DeleteJobAction extends Action<DeleteJobAction.Request, DeleteJobAc
static class RequestBuilder extends MasterNodeOperationRequestBuilder<Request, Response, RequestBuilder> {
public RequestBuilder(ElasticsearchClient client, DeleteJobAction action) {
RequestBuilder(ElasticsearchClient client, DeleteJobAction action) {
super(client, action, new Request());
}
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/FlushJobAction.java
View File

@ -187,7 +187,7 @@ public class FlushJobAction extends Action<FlushJobAction.Request, FlushJobActio
static class RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder> {
public RequestBuilder(ElasticsearchClient client, FlushJobAction action) {
RequestBuilder(ElasticsearchClient client, FlushJobAction action) {
super(client, action, new Request());
}
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/InternalOpenJobAction.java
View File

@ -62,7 +62,7 @@ public class InternalOpenJobAction extends Action<InternalOpenJobAction.Request,
static class RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder> {
public RequestBuilder(ElasticsearchClient client, InternalOpenJobAction action) {
RequestBuilder(ElasticsearchClient client, InternalOpenJobAction action) {
super(client, action, new Request());
}
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/OpenJobAction.java
View File

@ -136,7 +136,7 @@ public class OpenJobAction extends Action<OpenJobAction.Request, OpenJobAction.R
static class RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder> {
public RequestBuilder(ElasticsearchClient client, OpenJobAction action) {
RequestBuilder(ElasticsearchClient client, OpenJobAction action) {
super(client, action, new Request());
}
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/StartDatafeedAction.java
View File

@ -189,7 +189,7 @@ public class StartDatafeedAction
static class RequestBuilder extends ActionRequestBuilder<Request, PersistentActionResponse, RequestBuilder> {
public RequestBuilder(ElasticsearchClient client, StartDatafeedAction action) {
RequestBuilder(ElasticsearchClient client, StartDatafeedAction action) {
super(client, action, new Request());
}
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/StopDatafeedAction.java
View File

@ -111,7 +111,7 @@ public class StopDatafeedAction
static class RequestBuilder extends ActionRequestBuilder<Request, RemovePersistentTaskAction.Response, RequestBuilder> {
public RequestBuilder(ElasticsearchClient client, StopDatafeedAction action) {
RequestBuilder(ElasticsearchClient client, StopDatafeedAction action) {
super(client, action, new Request());
}
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/action/UpdateJobStateAction.java
View File

@ -132,7 +132,7 @@ public class UpdateJobStateAction
static class RequestBuilder extends MasterNodeOperationRequestBuilder<Request, Response, RequestBuilder> {
public RequestBuilder(ElasticsearchClient client, UpdateJobStateAction action) {
RequestBuilder(ElasticsearchClient client, UpdateJobStateAction action) {
super(client, action, new Request());
}
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/ProblemTracker.java
View File

@ -35,7 +35,7 @@ class ProblemTracker {
private volatile int emptyDataCount;
public ProblemTracker(Supplier<Auditor> auditor) {
ProblemTracker(Supplier<Auditor> auditor) {
this.auditor = Objects.requireNonNull(auditor);
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractor.java
View File

@ -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;

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractorContext.java
View File

@ -22,7 +22,7 @@ class AggregationDataExtractorContext {
final long start;
final long end;
public AggregationDataExtractorContext(String jobId, String timeField, List<String> indexes, List<String> types, QueryBuilder query,
AggregationDataExtractorContext(String jobId, String timeField, List<String> indexes, List<String> types, QueryBuilder query,
AggregatorFactories.Builder aggs, long start, long end) {
this.jobId = Objects.requireNonNull(jobId);
this.timeField = Objects.requireNonNull(timeField);

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationToJsonProcessor.java
View File

@ -30,7 +30,7 @@ class AggregationToJsonProcessor implements Releasable {
private final XContentBuilder jsonBuilder;
private final Map<String, Object> keyValuePairs;
public AggregationToJsonProcessor(OutputStream outputStream) throws IOException {
AggregationToJsonProcessor(OutputStream outputStream) throws IOException {
jsonBuilder = new XContentBuilder(JsonXContent.jsonXContent, outputStream);
keyValuePairs = new LinkedHashMap<>();
}

4
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ExtractedField.java
View File

@ -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("\\.");
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ExtractedFields.java
View File

@ -22,7 +22,7 @@ class ExtractedFields {
private final ExtractedField timeField;
private final List<ExtractedField> allFields;
public ExtractedFields(ExtractedField timeField, List<ExtractedField> allFields) {
ExtractedFields(ExtractedField timeField, List<ExtractedField> allFields) {
if (!allFields.contains(timeField)) {
throw new IllegalArgumentException("timeField should also be contained in allFields");
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractor.java
View File

@ -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;

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractorContext.java
View File

@ -23,7 +23,7 @@ class ScrollDataExtractorContext {
final long start;
final long end;
public ScrollDataExtractorContext(String jobId, ExtractedFields extractedFields, List<String> indexes, List<String> types,
ScrollDataExtractorContext(String jobId, ExtractedFields extractedFields, List<String> indexes, List<String> types,
QueryBuilder query, List<SearchSourceBuilder.ScriptField> scriptFields, int scrollSize,
long start, long end) {
this.jobId = Objects.requireNonNull(jobId);

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/SearchHitToJsonProcessor.java
View File

@ -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);
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedBucketsIterator.java
View File

@ -18,7 +18,7 @@ import java.io.IOException;
class BatchedBucketsIterator extends BatchedResultsIterator<Bucket> {
public BatchedBucketsIterator(Client client, String jobId) {
BatchedBucketsIterator(Client client, String jobId) {
super(client, jobId, Bucket.RESULT_TYPE_VALUE);
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedInfluencersIterator.java
View File

@ -17,7 +17,7 @@ import org.elasticsearch.xpack.ml.job.results.Influencer;
import java.io.IOException;
class BatchedInfluencersIterator extends BatchedResultsIterator<Influencer> {
public BatchedInfluencersIterator(Client client, String jobId) {
BatchedInfluencersIterator(Client client, String jobId) {
super(client, jobId, Influencer.RESULT_TYPE_VALUE);
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/persistence/BatchedRecordsIterator.java
View File

@ -18,7 +18,7 @@ import java.io.IOException;
class BatchedRecordsIterator extends BatchedResultsIterator<AnomalyRecord> {
public BatchedRecordsIterator(Client client, String jobId) {
BatchedRecordsIterator(Client client, String jobId) {
super(client, jobId, AnomalyRecord.RESULT_TYPE_VALUE);
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/writer/CsvDataToProcessWriter.java
View File

@ -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);

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/autodetect/writer/JsonDataToProcessWriter.java
View File

@ -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);
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/AbstractLeafNormalizable.java
View File

@ -10,7 +10,7 @@ import java.util.List;
abstract class AbstractLeafNormalizable extends Normalizable {
public AbstractLeafNormalizable(String indexName) {
AbstractLeafNormalizable(String indexName) {
super(indexName);
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/BucketInfluencerNormalizable.java
View File

@ -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);
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/InfluencerNormalizable.java
View File

@ -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);
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/process/normalizer/RecordNormalizable.java
View File

@ -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);
}

2
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/job/results/PerPartitionMaxProbabilities.java
View File

@ -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) {

4
elasticsearch/src/main/java/org/elasticsearch/xpack/ml/utils/NamedPipeHelper.java
View File

@ -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;
}

10
elasticsearch/src/main/java/org/elasticsearch/xpack/persistent/PersistentActionCoordinator.java
View File

@ -193,7 +193,7 @@ public class PersistentActionCoordinator extends AbstractComponent implements Cl
private class PersistentTaskListener implements ActionListener<Empty> {
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<CompletionPersistentTaskAction.Response> {
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);

2
elasticsearch/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/aggregation/AggregationDataExtractorTests.java
View File

@ -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));
}

2
elasticsearch/src/test/java/org/elasticsearch/xpack/ml/datafeed/extractor/scroll/ScrollDataExtractorTests.java
View File

@ -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));
}

2
elasticsearch/src/test/java/org/elasticsearch/xpack/ml/integration/DatafeedJobIT.java
View File

@ -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;

2
elasticsearch/src/test/java/org/elasticsearch/xpack/ml/job/persistence/BatchedDocumentsIteratorTests.java
View File

@ -188,7 +188,7 @@ public class BatchedDocumentsIteratorTests extends ESTestCase {
}
private static class TestIterator extends BatchedDocumentsIterator<String> {
public TestIterator(Client client, String jobId) {
TestIterator(Client client, String jobId) {
super(client, jobId);
}

2
elasticsearch/src/test/java/org/elasticsearch/xpack/ml/job/process/DummyDataCountsReporter.java
View File

@ -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));
}

4
elasticsearch/src/test/java/org/elasticsearch/xpack/persistent/PersistentActionCoordinatorTests.java
View File

@ -328,7 +328,7 @@ public class PersistentActionCoordinatorTests extends ESTestCase {
private final PersistentActionRegistry.PersistentActionHolder<?> holder;
private final ActionListener<Empty> listener;
public Execution(PersistentActionRequest request, PersistentTask task, PersistentActionRegistry.PersistentActionHolder<?> holder,
Execution(PersistentActionRequest request, PersistentTask task, PersistentActionRegistry.PersistentActionHolder<?> holder,
ActionListener<Empty> listener) {
this.request = request;
this.task = task;
@ -340,7 +340,7 @@ public class PersistentActionCoordinatorTests extends ESTestCase {
private class MockExecutor extends PersistentActionExecutor {
private List<Execution> executions = new ArrayList<>();
public MockExecutor() {
MockExecutor() {
super(null);
}

4
elasticsearch/src/test/java/org/elasticsearch/xpack/persistent/TestPersistentActionPlugin.java
View File

@ -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();
}