Skip to content

Commit

Permalink
Code style fixes.
Browse files Browse the repository at this point in the history
Signed-off-by: Yury-Fridlyand <[email protected]>
  • Loading branch information
Yury-Fridlyand committed May 29, 2023
1 parent 07debe3 commit 96cf27b
Show file tree
Hide file tree
Showing 5 changed files with 7 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,9 @@
*/
public class CloseCursor extends UnresolvedPlan {

/** An instance of {@link Cursor} */
/**
* An instance of {@link FetchCursor}.
*/
private UnresolvedPlan cursor;

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@ public class CommandPlan extends AbstractPlan {

protected final ResponseListener<ExecutionEngine.QueryResponse> listener;

/** Constructor. */
public CommandPlan(QueryId queryId, UnresolvedPlan plan, QueryService queryService,
ResponseListener<ExecutionEngine.QueryResponse> listener) {
super(queryId);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,8 @@
import org.opensearch.sql.ast.statement.Explain;
import org.opensearch.sql.ast.statement.Query;
import org.opensearch.sql.ast.statement.Statement;
import org.opensearch.sql.ast.tree.FetchCursor;
import org.opensearch.sql.ast.tree.CloseCursor;
import org.opensearch.sql.ast.tree.FetchCursor;
import org.opensearch.sql.ast.tree.UnresolvedPlan;
import org.opensearch.sql.common.response.ResponseListener;
import org.opensearch.sql.exception.UnsupportedCursorRequestException;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,6 @@
import java.util.Map;
import java.util.Set;
import java.util.stream.Stream;

import org.apache.commons.lang3.tuple.Pair;
import org.junit.jupiter.api.DisplayNameGeneration;
import org.junit.jupiter.api.DisplayNameGenerator;
Expand Down Expand Up @@ -144,7 +143,7 @@ public static Stream<Arguments> getPhysicalPlanForTest() {

@ParameterizedTest(name = "{1}")
@MethodSource("getPhysicalPlanForTest")
public void PhysicalPlanVisitor_should_return_null(PhysicalPlan plan, String name) {
public void test_PhysicalPlanVisitor_should_return_null(PhysicalPlan plan, String name) {
assertNull(plan.accept(new PhysicalPlanNodeVisitor<Integer, Object>() {
}, null));
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ public class CommandResponseFormatterTest {
public void produces_always_same_output_for_any_query_response() {
var formatter = new CommandResponseFormatter();
assertEquals(formatter.format(mock(QueryResult.class)),
formatter.format(mock(QueryResult.class)));
formatter.format(mock(QueryResult.class)));

QueryResult response = new QueryResult(
new ExecutionEngine.Schema(ImmutableList.of(
Expand Down

0 comments on commit 96cf27b

Please sign in to comment.