Skip to content

Commit 0a2f6d7

Browse files
acarbonettoacarbonetto
committed
Fix core refactor: StreamIO from common to core.common (#296)
* Fix core refactor: StreamIO from common to core.common Signed-off-by: acarbonetto <andrewc@bitquilltech.com> * Fix core refactor: StreamIO from common to core.common Signed-off-by: acarbonetto <andrewc@bitquilltech.com> --------- Signed-off-by: acarbonetto <andrewc@bitquilltech.com>
1 parent e186cf7 commit 0a2f6d7

70 files changed

Lines changed: 97 additions & 105 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎datasources/src/main/java/org/opensearch/sql/datasources/exceptions/ErrorMessage.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
import com.google.gson.GsonBuilder;
1111
import com.google.gson.JsonObject;
1212
import lombok.Getter;
13-
import org.opensearch.rest.RestStatus;
13+
import org.opensearch.core.rest.RestStatus;
1414

1515
/**
1616
* Error Message.

‎datasources/src/main/java/org/opensearch/sql/datasources/model/transport/CreateDataSourceActionRequest.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import lombok.Getter;
1515
import org.opensearch.action.ActionRequest;
1616
import org.opensearch.action.ActionRequestValidationException;
17-
import org.opensearch.common.io.stream.StreamInput;
17+
import org.opensearch.core.common.io.stream.StreamInput;
1818
import org.opensearch.sql.datasource.model.DataSourceMetadata;
1919

2020
public class CreateDataSourceActionRequest

‎datasources/src/main/java/org/opensearch/sql/datasources/model/transport/CreateDataSourceActionResponse.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,8 @@
1111
import lombok.Getter;
1212
import lombok.RequiredArgsConstructor;
1313
import org.opensearch.action.ActionResponse;
14-
import org.opensearch.common.io.stream.StreamInput;
15-
import org.opensearch.common.io.stream.StreamOutput;
14+
import org.opensearch.core.common.io.stream.StreamInput;
15+
import org.opensearch.core.common.io.stream.StreamOutput;
1616

1717
@RequiredArgsConstructor
1818
public class CreateDataSourceActionResponse

‎datasources/src/main/java/org/opensearch/sql/datasources/model/transport/DeleteDataSourceActionRequest.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import org.apache.commons.lang3.StringUtils;
1515
import org.opensearch.action.ActionRequest;
1616
import org.opensearch.action.ActionRequestValidationException;
17-
import org.opensearch.common.io.stream.StreamInput;
17+
import org.opensearch.core.common.io.stream.StreamInput;
1818

1919
public class DeleteDataSourceActionRequest extends ActionRequest {
2020

‎datasources/src/main/java/org/opensearch/sql/datasources/model/transport/DeleteDataSourceActionResponse.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,8 @@
1111
import lombok.Getter;
1212
import lombok.RequiredArgsConstructor;
1313
import org.opensearch.action.ActionResponse;
14-
import org.opensearch.common.io.stream.StreamInput;
15-
import org.opensearch.common.io.stream.StreamOutput;
14+
import org.opensearch.core.common.io.stream.StreamInput;
15+
import org.opensearch.core.common.io.stream.StreamOutput;
1616

1717
@RequiredArgsConstructor
1818
public class DeleteDataSourceActionResponse extends ActionResponse {

‎datasources/src/main/java/org/opensearch/sql/datasources/model/transport/GetDataSourceActionRequest.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import lombok.NoArgsConstructor;
1515
import org.opensearch.action.ActionRequest;
1616
import org.opensearch.action.ActionRequestValidationException;
17-
import org.opensearch.common.io.stream.StreamInput;
17+
import org.opensearch.core.common.io.stream.StreamInput;
1818

1919
@NoArgsConstructor
2020
public class GetDataSourceActionRequest extends ActionRequest {

‎datasources/src/main/java/org/opensearch/sql/datasources/model/transport/GetDataSourceActionResponse.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,8 @@
1111
import lombok.Getter;
1212
import lombok.RequiredArgsConstructor;
1313
import org.opensearch.action.ActionResponse;
14-
import org.opensearch.common.io.stream.StreamInput;
15-
import org.opensearch.common.io.stream.StreamOutput;
14+
import org.opensearch.core.common.io.stream.StreamInput;
15+
import org.opensearch.core.common.io.stream.StreamOutput;
1616

1717
@RequiredArgsConstructor
1818
public class GetDataSourceActionResponse extends ActionResponse {

‎datasources/src/main/java/org/opensearch/sql/datasources/model/transport/UpdateDataSourceActionRequest.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@
1414
import lombok.Getter;
1515
import org.opensearch.action.ActionRequest;
1616
import org.opensearch.action.ActionRequestValidationException;
17-
import org.opensearch.common.io.stream.StreamInput;
17+
import org.opensearch.core.common.io.stream.StreamInput;
1818
import org.opensearch.sql.datasource.model.DataSourceMetadata;
1919

2020
public class UpdateDataSourceActionRequest

‎datasources/src/main/java/org/opensearch/sql/datasources/model/transport/UpdateDataSourceActionResponse.java‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,8 @@
1111
import lombok.Getter;
1212
import lombok.RequiredArgsConstructor;
1313
import org.opensearch.action.ActionResponse;
14-
import org.opensearch.common.io.stream.StreamInput;
15-
import org.opensearch.common.io.stream.StreamOutput;
14+
import org.opensearch.core.common.io.stream.StreamInput;
15+
import org.opensearch.core.common.io.stream.StreamOutput;
1616

1717
@RequiredArgsConstructor
1818
public class UpdateDataSourceActionResponse

‎datasources/src/main/java/org/opensearch/sql/datasources/rest/RestDataSourceQueryAction.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,13 +7,13 @@
77

88
package org.opensearch.sql.datasources.rest;
99

10+
import static org.opensearch.core.rest.RestStatus.BAD_REQUEST;
11+
import static org.opensearch.core.rest.RestStatus.NOT_FOUND;
12+
import static org.opensearch.core.rest.RestStatus.SERVICE_UNAVAILABLE;
1013
import static org.opensearch.rest.RestRequest.Method.DELETE;
1114
import static org.opensearch.rest.RestRequest.Method.GET;
1215
import static org.opensearch.rest.RestRequest.Method.POST;
1316
import static org.opensearch.rest.RestRequest.Method.PUT;
14-
import static org.opensearch.rest.RestStatus.BAD_REQUEST;
15-
import static org.opensearch.rest.RestStatus.NOT_FOUND;
16-
import static org.opensearch.rest.RestStatus.SERVICE_UNAVAILABLE;
1717

1818
import com.google.common.collect.ImmutableList;
1919
import java.io.IOException;
@@ -24,11 +24,11 @@
2424
import org.opensearch.OpenSearchException;
2525
import org.opensearch.action.ActionListener;
2626
import org.opensearch.client.node.NodeClient;
27+
import org.opensearch.core.rest.RestStatus;
2728
import org.opensearch.rest.BaseRestHandler;
2829
import org.opensearch.rest.BytesRestResponse;
2930
import org.opensearch.rest.RestChannel;
3031
import org.opensearch.rest.RestRequest;
31-
import org.opensearch.rest.RestStatus;
3232
import org.opensearch.sql.datasource.model.DataSourceMetadata;
3333
import org.opensearch.sql.datasources.exceptions.DataSourceNotFoundException;
3434
import org.opensearch.sql.datasources.exceptions.ErrorMessage;

0 commit comments

Comments
 (0)