Skip to content

Commit 8baa32e

Browse files
tglmantglman
committed
refactor: moved execution stream implementations to specific package
1 parent d35a634 commit 8baa32e

File tree

211 files changed

+218
-215
lines changed

Some content is hidden

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

211 files changed

+218
-215
lines changed

‎core/src/main/java/com/orientechnologies/orient/core/db/ODatabaseDocumentInternal.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@
3939
import com.orientechnologies.orient.core.serialization.serializer.record.ORecordSerializer;
4040
import com.orientechnologies.orient.core.sql.executor.OInternalExecutionPlan;
4141
import com.orientechnologies.orient.core.sql.executor.OResultSet;
42-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
42+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
4343
import com.orientechnologies.orient.core.storage.OPhysicalPosition;
4444
import com.orientechnologies.orient.core.storage.ORawBuffer;
4545
import com.orientechnologies.orient.core.storage.OStorage;

‎core/src/main/java/com/orientechnologies/orient/core/index/OIndexManagerRemote.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -31,8 +31,8 @@
3131
import com.orientechnologies.orient.core.id.ORID;
3232
import com.orientechnologies.orient.core.id.ORecordId;
3333
import com.orientechnologies.orient.core.metadata.OMetadata;
34-
import com.orientechnologies.orient.core.metadata.OSessionMetadata;
3534
import com.orientechnologies.orient.core.metadata.OMetadataInternal;
35+
import com.orientechnologies.orient.core.metadata.OSessionMetadata;
3636
import com.orientechnologies.orient.core.record.ORecord;
3737
import com.orientechnologies.orient.core.record.ORecordInternal;
3838
import com.orientechnologies.orient.core.record.impl.ODocument;

‎core/src/main/java/com/orientechnologies/orient/core/index/OIndexManagerShared.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -36,8 +36,8 @@
3636
import com.orientechnologies.orient.core.id.ORID;
3737
import com.orientechnologies.orient.core.id.ORecordId;
3838
import com.orientechnologies.orient.core.metadata.OMetadata;
39-
import com.orientechnologies.orient.core.metadata.OSessionMetadata;
4039
import com.orientechnologies.orient.core.metadata.OMetadataInternal;
40+
import com.orientechnologies.orient.core.metadata.OSessionMetadata;
4141
import com.orientechnologies.orient.core.metadata.schema.OClass;
4242
import com.orientechnologies.orient.core.metadata.schema.OClassImpl;
4343
import com.orientechnologies.orient.core.metadata.schema.OSchemaShared;

‎core/src/main/java/com/orientechnologies/orient/core/metadata/sequence/OSessionSequenceLibrary.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,8 @@
3333
* @since 3/2/2015
3434
*/
3535
public class OSessionSequenceLibrary extends OSequenceLibraryAbstract {
36-
private static final OLogger logger = OLogManager.instance().logger(OSessionSequenceLibrary.class);
36+
private static final OLogger logger =
37+
OLogManager.instance().logger(OSessionSequenceLibrary.class);
3738
private static final int replicationProtocolVersion =
3839
OGlobalConfiguration.DISTRIBUTED_REPLICATION_PROTOCOL_VERSION.getValue();
3940

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/AbstractExecutionStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
5-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
5+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
66
import java.util.Optional;
77

88
/** @author Luigi Dell'Aquila (l.dellaquila-(at)-orientdb.com) */

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/AbstractTraverseStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
55
import com.orientechnologies.orient.core.id.ORID;
6-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
6+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
77
import com.orientechnologies.orient.core.sql.parser.OInteger;
88
import com.orientechnologies.orient.core.sql.parser.OTraverseProjectionItem;
99
import com.orientechnologies.orient.core.sql.parser.OWhereClause;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/AbstractUnrollStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
55
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
6-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
6+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
77
import java.util.Collection;
88

99
/**

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/AccumulatingTimeoutStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
5-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
5+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
66
import com.orientechnologies.orient.core.sql.parser.OTimeout;
77

88
/** Created by luigidellaquila on 08/08/16. */

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/AggregateProjectionCalculationStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
55
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
6-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
6+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
77
import com.orientechnologies.orient.core.sql.parser.OExpression;
88
import com.orientechnologies.orient.core.sql.parser.OGroupBy;
99
import com.orientechnologies.orient.core.sql.parser.OProjection;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/BatchStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
55
import com.orientechnologies.orient.core.db.ODatabaseSession;
6-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
6+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
77
import com.orientechnologies.orient.core.sql.parser.OBatch;
88

99
/** Created by luigidellaquila on 14/02/17. */

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/BreadthFirstTraverseStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import com.orientechnologies.orient.core.command.OCommandContext;
44
import com.orientechnologies.orient.core.db.record.OIdentifiable;
55
import com.orientechnologies.orient.core.id.ORID;
6-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
6+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
77
import com.orientechnologies.orient.core.sql.parser.OInteger;
88
import com.orientechnologies.orient.core.sql.parser.OTraverseProjectionItem;
99
import com.orientechnologies.orient.core.sql.parser.OWhereClause;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CartesianProductStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
5-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
5+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
66
import java.util.ArrayList;
77
import java.util.List;
88
import java.util.stream.Stream;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CastToEdgeStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import com.orientechnologies.orient.core.command.OCommandContext;
55
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
66
import com.orientechnologies.orient.core.record.OEdge;
7-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
7+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
88

99
/** Created by luigidellaquila on 20/02/17. */
1010
public class CastToEdgeStep extends AbstractExecutionStep {

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CastToVertexStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import com.orientechnologies.orient.core.command.OCommandContext;
55
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
66
import com.orientechnologies.orient.core.record.OVertex;
7-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
7+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
88

99
/** Created by luigidellaquila on 20/02/17. */
1010
public class CastToVertexStep extends AbstractExecutionStep {

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CheckClassTypeStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
77
import com.orientechnologies.orient.core.metadata.schema.OClass;
88
import com.orientechnologies.orient.core.metadata.schema.OSchema;
9-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
9+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1010

1111
/**
1212
* This step is used just as a gate check for classes (eg. for CREATE VERTEX to make sure that the

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CheckClusterTypeStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import com.orientechnologies.orient.core.db.ODatabaseDocumentInternal;
66
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
77
import com.orientechnologies.orient.core.metadata.schema.OClass;
8-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
8+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
99
import com.orientechnologies.orient.core.sql.parser.OCluster;
1010

1111
/**

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CheckRecordTypeStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
66
import com.orientechnologies.orient.core.metadata.schema.OClass;
77
import com.orientechnologies.orient.core.record.OElement;
8-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
8+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
99
import java.util.Optional;
1010

1111
/**

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CheckSafeDeleteStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
import com.orientechnologies.orient.core.record.ORecord;
99
import com.orientechnologies.orient.core.record.impl.ODocument;
1010
import com.orientechnologies.orient.core.record.impl.ODocumentInternal;
11-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
11+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1212

1313
/**
1414
* Checks if a record can be safely deleted (throws OCommandExecutionException in case). A record

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/ConvertToResultInternalStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import com.orientechnologies.orient.core.command.OCommandContext;
55
import com.orientechnologies.orient.core.record.ORecord;
66
import com.orientechnologies.orient.core.record.impl.ODocument;
7-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
7+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
88

99
/**
1010
* takes a result set made of OUpdatableRecord instances and transforms it in another result set

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/ConvertToUpdatableResultStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import com.orientechnologies.orient.core.id.ORID;
66
import com.orientechnologies.orient.core.record.ORecord;
77
import com.orientechnologies.orient.core.record.impl.ODocument;
8-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
8+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
99

1010
/**
1111
* takes a normal result set and transforms it in another result set made of OUpdatableRecord

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CopyDocumentStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import com.orientechnologies.orient.core.record.impl.OBlob;
77
import com.orientechnologies.orient.core.record.impl.ODocument;
88
import com.orientechnologies.orient.core.record.impl.ORecordBytes;
9-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
9+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1010

1111
/**
1212
* Reads an upstream result set and returns a new result set that contains copies of the original

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CopyRecordContentBeforeUpdateStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
import com.orientechnologies.orient.core.record.ORecord;
88
import com.orientechnologies.orient.core.record.impl.ODocument;
99
import com.orientechnologies.orient.core.record.impl.ODocumentInternal;
10-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
10+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1111

1212
/**
1313
* Reads an upstream result set and returns a new result set that contains copies of the original

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CountFromClassStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
77
import com.orientechnologies.orient.core.metadata.schema.OClass;
88
import com.orientechnologies.orient.core.metadata.schema.OImmutableSchema;
9-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
9+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1010
import com.orientechnologies.orient.core.sql.parser.OIdentifier;
1111

1212
/**

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CountFromIndexStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import com.orientechnologies.orient.core.command.OCommandContext;
66
import com.orientechnologies.orient.core.db.ODatabaseDocumentInternal;
77
import com.orientechnologies.orient.core.index.OIndexInternal;
8-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
8+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
99
import com.orientechnologies.orient.core.sql.parser.OIndexIdentifier;
1010
import java.util.Collections;
1111

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CountFromIndexWithKeyStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import com.orientechnologies.orient.core.db.ODatabaseDocumentInternal;
77
import com.orientechnologies.orient.core.index.OIndex;
88
import com.orientechnologies.orient.core.index.OIndexInternal;
9-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
9+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1010
import com.orientechnologies.orient.core.sql.parser.OExpression;
1111
import com.orientechnologies.orient.core.sql.parser.OIndexIdentifier;
1212
import java.util.Collections;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CountStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
5-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
5+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
66

77
/**
88
* Counts the records from the previous steps. Returns a record with a single property, called

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CreateEdgesStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010
import com.orientechnologies.orient.core.record.OEdge;
1111
import com.orientechnologies.orient.core.record.OElement;
1212
import com.orientechnologies.orient.core.record.OVertex;
13-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
13+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1414
import com.orientechnologies.orient.core.sql.parser.OBatch;
1515
import com.orientechnologies.orient.core.sql.parser.OIdentifier;
1616
import java.util.ArrayList;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/CreateRecordStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
55
import com.orientechnologies.orient.core.record.impl.ODocument;
6-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
6+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
77
import java.util.Optional;
88

99
/** @author Luigi Dell'Aquila (l.dellaquila-(at)-orientdb.com) */

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/DeleteFromIndexStep.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,8 @@
88
import com.orientechnologies.orient.core.index.OIndex;
99
import com.orientechnologies.orient.core.index.OIndexDefinition;
1010
import com.orientechnologies.orient.core.index.OIndexInternal;
11-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
12-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStreamProducer;
11+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
12+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStreamProducer;
1313
import com.orientechnologies.orient.core.sql.parser.OAndBlock;
1414
import com.orientechnologies.orient.core.sql.parser.OBetweenCondition;
1515
import com.orientechnologies.orient.core.sql.parser.OBinaryCompareOperator;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/DeleteStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
55
import com.orientechnologies.orient.core.id.ORID;
6-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
6+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
77
import java.util.Optional;
88

99
/**

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/DepthFirstTraverseStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import com.orientechnologies.orient.core.db.record.OIdentifiable;
55
import com.orientechnologies.orient.core.db.record.ridbag.ORidBag;
66
import com.orientechnologies.orient.core.id.ORID;
7-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
7+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
88
import com.orientechnologies.orient.core.sql.parser.OInteger;
99
import com.orientechnologies.orient.core.sql.parser.OTraverseProjectionItem;
1010
import com.orientechnologies.orient.core.sql.parser.OWhereClause;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/DistinctExecutionStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import com.orientechnologies.orient.core.db.ODatabaseSession;
77
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
88
import com.orientechnologies.orient.core.id.ORID;
9-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
9+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1010
import java.util.HashSet;
1111
import java.util.Set;
1212

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/DistributedExecutionStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
55
import com.orientechnologies.orient.core.db.ODatabaseDocumentInternal;
6-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
6+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
77

88
/** Created by luigidellaquila on 08/05/17. */
99
public class DistributedExecutionStep extends AbstractExecutionStep {

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/EmptyDataGeneratorStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
5-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
5+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
66

77
/** Created by luigidellaquila on 08/07/16. */
88
public class EmptyDataGeneratorStep extends AbstractExecutionStep {

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/EmptyStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import com.orientechnologies.common.concur.OTimeoutException;
44
import com.orientechnologies.orient.core.command.OCommandContext;
5-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
5+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
66

77
/** Created by luigidellaquila on 08/07/16. */
88
public class EmptyStep extends AbstractExecutionStep {

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/ExpandStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import com.orientechnologies.orient.core.db.record.OIdentifiable;
66
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
77
import com.orientechnologies.orient.core.record.ORecord;
8-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
8+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
99
import java.util.Iterator;
1010

1111
/**

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/FetchEdgesFromToVerticesStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
import com.orientechnologies.orient.core.record.ODirection;
99
import com.orientechnologies.orient.core.record.OEdge;
1010
import com.orientechnologies.orient.core.record.OElement;
11-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
11+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1212
import com.orientechnologies.orient.core.sql.parser.OIdentifier;
1313
import java.util.Collections;
1414
import java.util.HashSet;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/FetchEdgesToVerticesStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
import com.orientechnologies.orient.core.record.ODirection;
88
import com.orientechnologies.orient.core.record.OEdge;
99
import com.orientechnologies.orient.core.record.OElement;
10-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
10+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1111
import com.orientechnologies.orient.core.sql.parser.OIdentifier;
1212
import java.util.Collections;
1313
import java.util.Iterator;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/FetchFromClassExecutionStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66
import com.orientechnologies.orient.core.db.ODatabaseDocumentInternal;
77
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
88
import com.orientechnologies.orient.core.metadata.schema.OClass;
9-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
9+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1010
import java.util.ArrayList;
1111
import java.util.Arrays;
1212
import java.util.List;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/FetchFromClusterExecutionStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
99
import com.orientechnologies.orient.core.id.ORID;
1010
import com.orientechnologies.orient.core.iterator.ORecordIteratorCluster;
11-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
11+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
1212
import com.orientechnologies.orient.core.sql.parser.OBinaryCompareOperator;
1313
import com.orientechnologies.orient.core.sql.parser.OBinaryCondition;
1414
import com.orientechnologies.orient.core.sql.parser.OBooleanExpression;

‎core/src/main/java/com/orientechnologies/orient/core/sql/executor/FetchFromClustersExecutionStep.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
import com.orientechnologies.common.exception.OException;
55
import com.orientechnologies.orient.core.command.OCommandContext;
66
import com.orientechnologies.orient.core.exception.OCommandExecutionException;
7-
import com.orientechnologies.orient.core.sql.executor.resultset.OExecutionStream;
7+
import com.orientechnologies.orient.core.sql.executor.stream.OExecutionStream;
88
import java.util.ArrayList;
99
import java.util.Arrays;
1010
import java.util.List;

0 commit comments

Comments
 (0)