This is an automated email from the ASF dual-hosted git repository. gvvinblade pushed a commit to branch ignite-12248 in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/ignite-12248 by this push: new fbca075 fix imports checkstyle fbca075 is described below commit fbca07567983665fc62d2555d0b1a750d6cc2beb Author: Igor Seliverstov <gvvinbl...@gmail.com> AuthorDate: Tue Jul 14 18:36:59 2020 +0300 fix imports checkstyle --- .../processors/query/calcite/CalciteQueryProcessor.java | 1 + .../processors/query/calcite/exec/ArrayRowHandler.java | 1 + .../query/calcite/exec/ClosableIteratorsHolder.java | 1 + .../processors/query/calcite/exec/ExchangeService.java | 1 + .../processors/query/calcite/exec/ExchangeServiceImpl.java | 3 ++- .../processors/query/calcite/exec/ExecutionContext.java | 1 + .../processors/query/calcite/exec/ExecutionService.java | 1 + .../processors/query/calcite/exec/ExecutionServiceImpl.java | 3 ++- .../internal/processors/query/calcite/exec/IndexScan.java | 1 + .../processors/query/calcite/exec/LogicalRelImplementor.java | 1 + .../processors/query/calcite/exec/MailboxRegistry.java | 1 + .../processors/query/calcite/exec/MailboxRegistryImpl.java | 1 + .../processors/query/calcite/exec/QueryTaskExecutor.java | 1 + .../processors/query/calcite/exec/QueryTaskExecutorImpl.java | 1 + .../internal/processors/query/calcite/exec/RowHandler.java | 1 + .../internal/processors/query/calcite/exec/TableScan.java | 1 + .../processors/query/calcite/exec/exp/ExpressionFactory.java | 3 ++- .../query/calcite/exec/exp/ExpressionFactoryImpl.java | 7 ++++--- .../processors/query/calcite/exec/exp/agg/Accumulator.java | 1 + .../processors/query/calcite/exec/exp/agg/Accumulators.java | 1 + .../query/calcite/exec/exp/agg/AccumulatorsFactory.java | 11 ++++++----- .../processors/query/calcite/exec/rel/AbstractJoinNode.java | 1 + .../processors/query/calcite/exec/rel/AbstractNode.java | 1 + .../processors/query/calcite/exec/rel/AggregateNode.java | 1 + .../processors/query/calcite/exec/rel/AntiJoinNode.java | 1 + .../processors/query/calcite/exec/rel/FilterNode.java | 1 + .../processors/query/calcite/exec/rel/FullOuterJoinNode.java | 1 + .../internal/processors/query/calcite/exec/rel/Inbox.java | 1 + .../processors/query/calcite/exec/rel/InnerJoinNode.java | 1 + .../processors/query/calcite/exec/rel/LeftJoinNode.java | 1 + .../processors/query/calcite/exec/rel/ModifyNode.java | 2 ++ .../internal/processors/query/calcite/exec/rel/Node.java | 1 + .../internal/processors/query/calcite/exec/rel/Outbox.java | 1 + .../processors/query/calcite/exec/rel/ProjectNode.java | 1 + .../processors/query/calcite/exec/rel/RightJoinNode.java | 1 + .../internal/processors/query/calcite/exec/rel/RootNode.java | 1 + .../internal/processors/query/calcite/exec/rel/ScanNode.java | 1 + .../processors/query/calcite/exec/rel/SemiJoinNode.java | 1 + .../internal/processors/query/calcite/exec/rel/SortNode.java | 1 + .../processors/query/calcite/externalize/RelJson.java | 11 ++++++----- .../processors/query/calcite/externalize/RelJsonReader.java | 7 ++++--- .../processors/query/calcite/externalize/RelJsonWriter.java | 7 ++++--- .../query/calcite/message/CalciteMessageFactory.java | 1 + .../query/calcite/message/ExecutionContextAware.java | 1 + .../processors/query/calcite/message/GenericRowMessage.java | 1 + .../processors/query/calcite/message/InboxCancelMessage.java | 1 + .../processors/query/calcite/message/MessageService.java | 1 + .../processors/query/calcite/message/MessageServiceImpl.java | 1 + .../processors/query/calcite/message/MessageType.java | 1 + .../query/calcite/message/QueryBatchAcknowledgeMessage.java | 1 + .../processors/query/calcite/message/QueryBatchMessage.java | 1 + .../processors/query/calcite/message/QueryCancelRequest.java | 1 + .../processors/query/calcite/message/QueryStartRequest.java | 1 + .../processors/query/calcite/message/QueryStartResponse.java | 1 + .../processors/query/calcite/metadata/MappingService.java | 1 + .../processors/query/calcite/metadata/MappingServiceImpl.java | 1 + .../processors/query/calcite/metadata/NodesMapping.java | 1 + .../processors/query/calcite/metadata/PartitionService.java | 1 + .../query/calcite/metadata/PartitionServiceImpl.java | 1 + .../query/calcite/prepare/AbstractMultiStepPlan.java | 1 + .../query/calcite/prepare/CalciteQueryFieldMetadata.java | 1 + .../internal/processors/query/calcite/prepare/Cloner.java | 3 ++- .../processors/query/calcite/prepare/ExplainPlan.java | 1 + .../internal/processors/query/calcite/prepare/Fragment.java | 3 ++- .../processors/query/calcite/prepare/FragmentDescription.java | 1 + .../processors/query/calcite/prepare/FragmentSplitter.java | 3 ++- .../processors/query/calcite/prepare/IgnitePlanner.java | 3 ++- .../processors/query/calcite/prepare/IgniteSqlValidator.java | 1 + .../processors/query/calcite/prepare/MultiStepDmlPlan.java | 3 ++- .../processors/query/calcite/prepare/MultiStepPlan.java | 1 + .../processors/query/calcite/prepare/MultiStepQueryPlan.java | 3 ++- .../processors/query/calcite/prepare/PlanningContext.java | 1 + .../processors/query/calcite/prepare/QueryPlanCache.java | 1 + .../processors/query/calcite/prepare/QueryPlanCacheImpl.java | 1 + .../internal/processors/query/calcite/prepare/Splitter.java | 3 ++- .../processors/query/calcite/prepare/ValidationResult.java | 1 + .../processors/query/calcite/rel/IgniteAggregate.java | 1 + .../internal/processors/query/calcite/rel/IgniteExchange.java | 3 ++- .../internal/processors/query/calcite/rel/IgniteFilter.java | 3 ++- .../internal/processors/query/calcite/rel/IgniteJoin.java | 5 +++-- .../processors/query/calcite/rel/IgniteMapAggregate.java | 1 + .../internal/processors/query/calcite/rel/IgniteProject.java | 3 ++- .../internal/processors/query/calcite/rel/IgniteReceiver.java | 1 + .../processors/query/calcite/rel/IgniteReduceAggregate.java | 3 ++- .../internal/processors/query/calcite/rel/IgniteRel.java | 1 + .../internal/processors/query/calcite/rel/IgniteSender.java | 1 + .../internal/processors/query/calcite/rel/IgniteSort.java | 3 ++- .../processors/query/calcite/rel/IgniteTableModify.java | 1 + .../processors/query/calcite/rel/IgniteTableScan.java | 3 ++- .../processors/query/calcite/rel/IgniteTrimExchange.java | 3 ++- .../internal/processors/query/calcite/rel/IgniteUnionAll.java | 1 + .../internal/processors/query/calcite/rel/IgniteValues.java | 3 ++- .../processors/query/calcite/rule/RegisterIndexRule.java | 1 + .../processors/query/calcite/rule/UnionConverterRule.java | 3 ++- .../query/calcite/rule/logical/LogicalOrToUnionRule.java | 3 ++- .../internal/processors/query/calcite/schema/IgniteIndex.java | 1 + .../processors/query/calcite/schema/IgniteSchema.java | 1 + .../internal/processors/query/calcite/schema/IgniteTable.java | 1 + .../processors/query/calcite/schema/IgniteTableImpl.java | 3 ++- .../processors/query/calcite/schema/SchemaHolderImpl.java | 1 + .../processors/query/calcite/schema/TableDescriptor.java | 1 + .../processors/query/calcite/schema/TableDescriptorImpl.java | 1 + .../processors/query/calcite/trait/DistributionFunction.java | 1 + .../processors/query/calcite/trait/DistributionTrait.java | 3 ++- .../processors/query/calcite/trait/IgniteDistributions.java | 1 + .../internal/processors/query/calcite/trait/TraitUtils.java | 3 ++- .../processors/query/calcite/type/IgniteTypeFactory.java | 1 + .../processors/query/calcite/type/IgniteTypeSystem.java | 1 + .../internal/processors/query/calcite/util/Commons.java | 1 + .../query/calcite/util/ConvertingClosableIterator.java | 1 + .../internal/processors/query/calcite/util/IgniteMethod.java | 1 + .../processors/query/calcite/util/ListFieldsQueryCursor.java | 1 + .../calcite/CalciteBasicSecondaryIndexIntegrationTest.java | 1 + .../processors/query/calcite/CalciteQueryProcessorTest.java | 3 ++- .../ignite/internal/processors/query/calcite/PlannerTest.java | 1 + .../internal/processors/query/calcite/QueryChecker.java | 1 + .../query/calcite/exec/ClosableIteratorsHolderTest.java | 1 + .../query/calcite/exec/rel/AbstractExecutionTest.java | 3 ++- .../query/calcite/exec/rel/ContinuousExecutionTest.java | 3 ++- .../processors/query/calcite/exec/rel/ExecutionTest.java | 3 ++- .../internal/processors/query/calcite/jdbc/JdbcQueryTest.java | 1 + .../org/apache/ignite/testsuites/IgniteCalciteTestSuite.java | 2 +- 122 files changed, 171 insertions(+), 49 deletions(-) diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessor.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessor.java index 3e83316..5ec299e 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessor.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessor.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite; import java.util.List; + import org.apache.calcite.config.Lex; import org.apache.calcite.plan.Contexts; import org.apache.calcite.plan.RelOptCostImpl; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ArrayRowHandler.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ArrayRowHandler.java index 4e98585..1f53ad2 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ArrayRowHandler.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ArrayRowHandler.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec; import java.lang.reflect.Type; + import org.apache.ignite.internal.util.typedef.F; /** diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ClosableIteratorsHolder.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ClosableIteratorsHolder.java index d3910c9..063abb5 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ClosableIteratorsHolder.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ClosableIteratorsHolder.java @@ -24,6 +24,7 @@ import java.util.Iterator; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.function.Consumer; + import org.apache.ignite.IgniteLogger; import org.apache.ignite.internal.processors.query.calcite.util.Commons; import org.apache.ignite.internal.util.typedef.internal.U; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeService.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeService.java index 0ae9360..731023b 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeService.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeService.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec; import java.util.List; import java.util.UUID; + import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.processors.query.calcite.util.Service; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeServiceImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeServiceImpl.java index 961a974..4ab6cb6 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeServiceImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExchangeServiceImpl.java @@ -17,10 +17,11 @@ package org.apache.ignite.internal.processors.query.calcite.exec; -import com.google.common.collect.ImmutableMap; import java.util.List; import java.util.Objects; import java.util.UUID; + +import com.google.common.collect.ImmutableMap; import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.GridKernalContext; import org.apache.ignite.internal.processors.query.calcite.CalciteQueryProcessor; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionContext.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionContext.java index 8ef75a3..70d52b0 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionContext.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionContext.java @@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec; import java.util.List; import java.util.Map; import java.util.UUID; + import org.apache.calcite.DataContext; import org.apache.calcite.linq4j.QueryProvider; import org.apache.calcite.schema.SchemaPlus; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionService.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionService.java index 59ba0a8..64e2f71 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionService.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionService.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec; import java.util.List; import java.util.UUID; + import org.apache.ignite.cache.query.FieldsQueryCursor; import org.apache.ignite.internal.processors.query.QueryContext; import org.apache.ignite.internal.processors.query.calcite.util.Service; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java index 7d81530..4826dbe 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/ExecutionServiceImpl.java @@ -17,7 +17,6 @@ package org.apache.ignite.internal.processors.query.calcite.exec; -import com.google.common.collect.ImmutableList; import java.util.ArrayList; import java.util.Collection; import java.util.HashSet; @@ -29,6 +28,8 @@ import java.util.Set; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; import java.util.function.Predicate; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.ConventionTraitDef; import org.apache.calcite.plan.RelOptUtil; import org.apache.calcite.plan.RelTraitDef; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/IndexScan.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/IndexScan.java index cc5b1ff..a6d720f 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/IndexScan.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/IndexScan.java @@ -22,6 +22,7 @@ import java.util.Iterator; import java.util.List; import java.util.NoSuchElementException; import java.util.function.Predicate; + import org.apache.calcite.rel.type.RelDataType; import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.IgniteException; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/LogicalRelImplementor.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/LogicalRelImplementor.java index cea789b..bb4297a 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/LogicalRelImplementor.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/LogicalRelImplementor.java @@ -22,6 +22,7 @@ import java.util.function.Function; import java.util.function.Predicate; import java.util.function.Supplier; import java.util.function.ToIntFunction; + import org.apache.calcite.rel.RelCollation; import org.apache.calcite.rel.RelDistribution; import org.apache.calcite.rel.RelNode; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistry.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistry.java index e4ced07..d49009d 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistry.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistry.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec; import java.util.Collection; import java.util.UUID; + import org.apache.ignite.internal.processors.query.calcite.exec.rel.Inbox; import org.apache.ignite.internal.processors.query.calcite.exec.rel.Outbox; import org.apache.ignite.internal.processors.query.calcite.util.Service; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistryImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistryImpl.java index 8924913..77e1101 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistryImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/MailboxRegistryImpl.java @@ -22,6 +22,7 @@ import java.util.Map; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; import java.util.stream.Collectors; + import org.apache.ignite.internal.GridKernalContext; import org.apache.ignite.internal.processors.query.calcite.exec.rel.Inbox; import org.apache.ignite.internal.processors.query.calcite.exec.rel.Outbox; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutor.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutor.java index 6891cde..4d7861c 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutor.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutor.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec; import java.util.UUID; + import org.apache.ignite.internal.processors.query.calcite.util.Service; /** diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutorImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutorImpl.java index e53e0e5..ff8263d 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutorImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/QueryTaskExecutorImpl.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec; import java.util.Objects; import java.util.UUID; + import org.apache.ignite.failure.FailureContext; import org.apache.ignite.failure.FailureType; import org.apache.ignite.internal.GridKernalContext; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RowHandler.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RowHandler.java index 2edf0fc0..f6e4e9b 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RowHandler.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/RowHandler.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec; import java.lang.reflect.Type; import java.util.List; + import org.apache.calcite.plan.RelOptUtil; import org.apache.calcite.rel.type.RelDataType; import org.apache.ignite.internal.processors.query.calcite.type.IgniteTypeFactory; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/TableScan.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/TableScan.java index 6305f06..090abc7 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/TableScan.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/TableScan.java @@ -23,6 +23,7 @@ import java.util.Iterator; import java.util.List; import java.util.NoSuchElementException; import java.util.Queue; + import org.apache.calcite.rel.type.RelDataType; import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.cluster.ClusterTopologyCheckedException; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactory.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactory.java index 88b1679..69ee0a2 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactory.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactory.java @@ -17,12 +17,13 @@ package org.apache.ignite.internal.processors.query.calcite.exec.exp; -import com.google.common.collect.ImmutableList; import java.util.Comparator; import java.util.List; import java.util.function.Function; import java.util.function.Predicate; import java.util.function.Supplier; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.rel.RelCollation; import org.apache.calcite.rel.core.AggregateCall; import org.apache.calcite.rel.type.RelDataType; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactoryImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactoryImpl.java index 0202949a..34b5284 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactoryImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/ExpressionFactoryImpl.java @@ -17,9 +17,6 @@ package org.apache.ignite.internal.processors.query.calcite.exec.exp; -import com.google.common.collect.ImmutableList; -import com.google.common.collect.Ordering; -import com.google.common.primitives.Primitives; import java.lang.reflect.Modifier; import java.lang.reflect.Type; import java.util.ArrayList; @@ -30,6 +27,10 @@ import java.util.function.Function; import java.util.function.Predicate; import java.util.function.Supplier; import java.util.stream.Collectors; + +import com.google.common.collect.ImmutableList; +import com.google.common.collect.Ordering; +import com.google.common.primitives.Primitives; import org.apache.calcite.adapter.enumerable.EnumUtils; import org.apache.calcite.adapter.enumerable.RexToLixTranslator; import org.apache.calcite.linq4j.tree.BlockBuilder; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulator.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulator.java index 6ccd661..a4fff5f 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulator.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulator.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.exp.agg; import java.io.Serializable; import java.util.List; + import org.apache.calcite.rel.type.RelDataType; import org.apache.ignite.internal.processors.query.calcite.type.IgniteTypeFactory; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulators.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulators.java index 1e80ab2..b3bfc3c 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulators.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/Accumulators.java @@ -21,6 +21,7 @@ import java.math.BigDecimal; import java.math.MathContext; import java.util.List; import java.util.function.Supplier; + import org.apache.calcite.rel.core.AggregateCall; import org.apache.calcite.rel.type.RelDataType; import org.apache.ignite.internal.processors.query.calcite.type.IgniteTypeFactory; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AccumulatorsFactory.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AccumulatorsFactory.java index 0a71c07..521be1a 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AccumulatorsFactory.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/exp/agg/AccumulatorsFactory.java @@ -17,16 +17,17 @@ package org.apache.ignite.internal.processors.query.calcite.exec.exp.agg; -import com.google.common.cache.CacheBuilder; -import com.google.common.cache.CacheLoader; -import com.google.common.cache.LoadingCache; -import com.google.common.collect.ImmutableList; -import com.google.common.primitives.Primitives; import java.lang.reflect.Modifier; import java.util.List; import java.util.concurrent.ExecutionException; import java.util.function.Function; import java.util.function.Supplier; + +import com.google.common.cache.CacheBuilder; +import com.google.common.cache.CacheLoader; +import com.google.common.cache.LoadingCache; +import com.google.common.collect.ImmutableList; +import com.google.common.primitives.Primitives; import org.apache.calcite.DataContext; import org.apache.calcite.adapter.enumerable.JavaRowFormat; import org.apache.calcite.adapter.enumerable.PhysTypeImpl; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractJoinNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractJoinNode.java index b198e2f..5332485 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractJoinNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractJoinNode.java @@ -22,6 +22,7 @@ import java.util.ArrayList; import java.util.Deque; import java.util.List; import java.util.function.Predicate; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.processors.query.calcite.exec.RowHandler; import org.apache.ignite.internal.util.typedef.F; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractNode.java index 2a3dff6..67a2718 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractNode.java @@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.Collection; import java.util.Comparator; import java.util.List; + import org.apache.ignite.IgniteSystemProperties; import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.util.typedef.F; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AggregateNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AggregateNode.java index d79467b..347f533 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AggregateNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AggregateNode.java @@ -25,6 +25,7 @@ import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.function.Supplier; + import org.apache.calcite.util.ImmutableBitSet; import org.apache.ignite.IgniteException; import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AntiJoinNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AntiJoinNode.java index 7044d24..17f4e97 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AntiJoinNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AntiJoinNode.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.function.Predicate; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; /** */ diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/FilterNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/FilterNode.java index 93b21b2..e7202fd 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/FilterNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/FilterNode.java @@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.ArrayDeque; import java.util.Deque; import java.util.function.Predicate; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.util.typedef.F; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/FullOuterJoinNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/FullOuterJoinNode.java index 7d1b0a3..2e999d3 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/FullOuterJoinNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/FullOuterJoinNode.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.BitSet; import java.util.function.Predicate; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.processors.query.calcite.exec.RowHandler; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Inbox.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Inbox.java index 03f9452..ce82e36 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Inbox.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Inbox.java @@ -26,6 +26,7 @@ import java.util.List; import java.util.Map; import java.util.PriorityQueue; import java.util.UUID; + import org.apache.calcite.util.Pair; import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.processors.query.calcite.exec.ExchangeService; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/InnerJoinNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/InnerJoinNode.java index 97af8b9..13623c2 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/InnerJoinNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/InnerJoinNode.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.function.Predicate; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; /** */ diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/LeftJoinNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/LeftJoinNode.java index 3bd265f..e249a42 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/LeftJoinNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/LeftJoinNode.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.function.Predicate; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.processors.query.calcite.exec.RowHandler; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ModifyNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ModifyNode.java index b67184e..d291413 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ModifyNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ModifyNode.java @@ -20,10 +20,12 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.ArrayList; import java.util.List; import java.util.Map; + import javax.cache.processor.EntryProcessor; import javax.cache.processor.EntryProcessorException; import javax.cache.processor.EntryProcessorResult; import javax.cache.processor.MutableEntry; + import org.apache.calcite.rel.core.TableModify; import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.processors.cache.GridCacheContext; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Node.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Node.java index b3b72d8..33f14ba 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Node.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Node.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.List; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; /** diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Outbox.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Outbox.java index 4f41791..b81223f 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Outbox.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/Outbox.java @@ -25,6 +25,7 @@ import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; + import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.processors.query.calcite.exec.ExchangeService; import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ProjectNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ProjectNode.java index f09dd98..0c2c2ab 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ProjectNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ProjectNode.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.function.Function; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.util.typedef.F; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RightJoinNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RightJoinNode.java index 693e68a..8b175f7 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RightJoinNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RightJoinNode.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.BitSet; import java.util.function.Predicate; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.processors.query.calcite.exec.RowHandler; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RootNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RootNode.java index 369b2f0..ca4c370 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RootNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/RootNode.java @@ -25,6 +25,7 @@ import java.util.UUID; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.ReentrantLock; import java.util.function.Consumer; + import org.apache.ignite.IgniteInterruptedException; import org.apache.ignite.internal.processors.cache.query.IgniteQueryErrorCode; import org.apache.ignite.internal.processors.query.IgniteSQLException; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ScanNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ScanNode.java index dfebd059..72df1e4 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ScanNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ScanNode.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.Iterator; import java.util.List; + import org.apache.ignite.internal.IgniteInterruptedCheckedException; import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.processors.query.calcite.util.Commons; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SemiJoinNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SemiJoinNode.java index 058a31a..38f65f5 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SemiJoinNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SemiJoinNode.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.function.Predicate; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; /** */ diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortNode.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortNode.java index 4a21c59..79943b3 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortNode.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/SortNode.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; import java.util.Comparator; import java.util.PriorityQueue; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.util.typedef.F; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJson.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJson.java index ebba71d..278268c 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJson.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJson.java @@ -16,11 +16,6 @@ */ package org.apache.ignite.internal.processors.query.calcite.externalize; -import com.google.common.cache.CacheBuilder; -import com.google.common.cache.CacheLoader; -import com.google.common.cache.LoadingCache; -import com.google.common.collect.ImmutableList; -import com.google.common.collect.ImmutableMap; import java.lang.reflect.Constructor; import java.lang.reflect.Modifier; import java.math.BigDecimal; @@ -32,6 +27,12 @@ import java.util.Map; import java.util.Set; import java.util.function.Function; import java.util.stream.Collectors; + +import com.google.common.cache.CacheBuilder; +import com.google.common.cache.CacheLoader; +import com.google.common.cache.LoadingCache; +import com.google.common.collect.ImmutableList; +import com.google.common.collect.ImmutableMap; import org.apache.calcite.avatica.AvaticaUtils; import org.apache.calcite.avatica.util.TimeUnit; import org.apache.calcite.avatica.util.TimeUnitRange; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJsonReader.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJsonReader.java index 275dddc..3f8798c 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJsonReader.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJsonReader.java @@ -16,9 +16,6 @@ */ package org.apache.ignite.internal.processors.query.calcite.externalize; -import com.fasterxml.jackson.core.type.TypeReference; -import com.fasterxml.jackson.databind.ObjectMapper; -import com.google.common.collect.ImmutableList; import java.io.IOException; import java.util.AbstractList; import java.util.ArrayList; @@ -27,6 +24,10 @@ import java.util.List; import java.util.Locale; import java.util.Map; import java.util.function.Function; + +import com.fasterxml.jackson.core.type.TypeReference; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptSchema; import org.apache.calcite.plan.RelOptTable; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJsonWriter.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJsonWriter.java index 7f448df..3bafa24 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJsonWriter.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/externalize/RelJsonWriter.java @@ -16,15 +16,16 @@ */ package org.apache.ignite.internal.processors.query.calcite.externalize; -import com.fasterxml.jackson.core.util.DefaultPrettyPrinter; -import com.fasterxml.jackson.databind.ObjectMapper; -import com.fasterxml.jackson.databind.ObjectWriter; import java.io.IOException; import java.io.StringWriter; import java.util.ArrayList; import java.util.IdentityHashMap; import java.util.List; import java.util.Map; + +import com.fasterxml.jackson.core.util.DefaultPrettyPrinter; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.ObjectWriter; import org.apache.calcite.rel.RelNode; import org.apache.calcite.rel.RelWriter; import org.apache.calcite.rex.RexNode; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteMessageFactory.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteMessageFactory.java index 126515f..61b77f3 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteMessageFactory.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/CalciteMessageFactory.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.message; import java.util.function.Supplier; + import org.apache.ignite.plugin.extensions.communication.IgniteMessageFactory; import org.apache.ignite.plugin.extensions.communication.Message; import org.apache.ignite.plugin.extensions.communication.MessageFactoryProvider; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/ExecutionContextAware.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/ExecutionContextAware.java index 779dc91..dc3f6ad 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/ExecutionContextAware.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/ExecutionContextAware.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.message; import java.util.UUID; + import org.apache.ignite.internal.managers.communication.GridIoPolicy; /** diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/GenericRowMessage.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/GenericRowMessage.java index d9e7590..ae71e6e 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/GenericRowMessage.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/GenericRowMessage.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.message; import java.nio.ByteBuffer; + import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.GridDirectTransient; import org.apache.ignite.marshaller.Marshaller; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/InboxCancelMessage.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/InboxCancelMessage.java index 9368052..933d656 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/InboxCancelMessage.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/InboxCancelMessage.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.message; import java.nio.ByteBuffer; import java.util.UUID; + import org.apache.ignite.plugin.extensions.communication.MessageReader; import org.apache.ignite.plugin.extensions.communication.MessageWriter; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageService.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageService.java index 3293365..3444347 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageService.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageService.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.message; import java.util.UUID; + import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.processors.query.calcite.util.Service; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java index 3a2f175..e8c3caa 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageServiceImpl.java @@ -21,6 +21,7 @@ import java.util.EnumMap; import java.util.Objects; import java.util.UUID; import java.util.concurrent.ThreadLocalRandom; + import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.failure.FailureContext; import org.apache.ignite.failure.FailureType; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageType.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageType.java index 9bd47c9..9c1446c 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageType.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MessageType.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.message; import java.util.function.Supplier; + import org.apache.ignite.internal.processors.query.calcite.metadata.NodesMapping; import org.apache.ignite.internal.processors.query.calcite.prepare.FragmentDescription; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchAcknowledgeMessage.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchAcknowledgeMessage.java index 7258272..07bfa7f 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchAcknowledgeMessage.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchAcknowledgeMessage.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.message; import java.nio.ByteBuffer; import java.util.UUID; + import org.apache.ignite.plugin.extensions.communication.MessageReader; import org.apache.ignite.plugin.extensions.communication.MessageWriter; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchMessage.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchMessage.java index 66e0265..627c6d6 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchMessage.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryBatchMessage.java @@ -21,6 +21,7 @@ import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.List; import java.util.UUID; + import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.GridDirectCollection; import org.apache.ignite.internal.GridDirectTransient; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryCancelRequest.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryCancelRequest.java index fe0e2ac..0a3766e 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryCancelRequest.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryCancelRequest.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.message; import java.nio.ByteBuffer; import java.util.UUID; + import org.apache.ignite.plugin.extensions.communication.MessageReader; import org.apache.ignite.plugin.extensions.communication.MessageWriter; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartRequest.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartRequest.java index c8946e5..2d3c6b2 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartRequest.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartRequest.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.message; import java.nio.ByteBuffer; import java.util.UUID; + import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.GridDirectTransient; import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartResponse.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartResponse.java index 05140b5..3118b43 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartResponse.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryStartResponse.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.message; import java.nio.ByteBuffer; import java.util.UUID; + import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.internal.GridDirectTransient; import org.apache.ignite.marshaller.Marshaller; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingService.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingService.java index ba44d60..421be15 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingService.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingService.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.metadata; import java.util.function.Predicate; + import org.apache.ignite.cluster.ClusterNode; import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion; import org.apache.ignite.internal.processors.query.calcite.util.Service; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingServiceImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingServiceImpl.java index 25c38dd..1d719b6 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingServiceImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/MappingServiceImpl.java @@ -22,6 +22,7 @@ import java.util.Collections; import java.util.List; import java.util.function.Predicate; import java.util.stream.Collectors; + import org.apache.ignite.IgniteSystemProperties; import org.apache.ignite.cluster.ClusterNode; import org.apache.ignite.internal.GridKernalContext; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/NodesMapping.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/NodesMapping.java index b47f724..2020dbc 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/NodesMapping.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/NodesMapping.java @@ -23,6 +23,7 @@ import java.util.HashSet; import java.util.List; import java.util.Objects; import java.util.UUID; + import org.apache.ignite.configuration.CacheConfiguration; import org.apache.ignite.internal.GridDirectCollection; import org.apache.ignite.internal.GridDirectTransient; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/PartitionService.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/PartitionService.java index 54638d1..7716103 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/PartitionService.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/PartitionService.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.metadata; import java.util.function.ToIntFunction; + import org.apache.ignite.internal.processors.query.calcite.util.Service; /** diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/PartitionServiceImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/PartitionServiceImpl.java index ed85c4e..7c7e3c4 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/PartitionServiceImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/metadata/PartitionServiceImpl.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.metadata; import java.util.function.ToIntFunction; + import org.apache.ignite.cache.affinity.AffinityFunction; import org.apache.ignite.internal.GridKernalContext; import org.apache.ignite.internal.processors.cache.GridCacheSharedContext; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/AbstractMultiStepPlan.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/AbstractMultiStepPlan.java index cc1e6e8..47aa7c8 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/AbstractMultiStepPlan.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/AbstractMultiStepPlan.java @@ -21,6 +21,7 @@ import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; + import org.apache.calcite.rel.metadata.RelMetadataQuery; import org.apache.ignite.internal.processors.query.GridQueryFieldMetadata; import org.apache.ignite.internal.processors.query.IgniteSQLException; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/CalciteQueryFieldMetadata.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/CalciteQueryFieldMetadata.java index 4708878..4113a1e 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/CalciteQueryFieldMetadata.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/CalciteQueryFieldMetadata.java @@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; import java.io.IOException; import java.io.ObjectInput; import java.io.ObjectOutput; + import org.apache.ignite.internal.processors.query.GridQueryFieldMetadata; /** diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Cloner.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Cloner.java index 901e2d7..28ce580 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Cloner.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Cloner.java @@ -17,9 +17,10 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; -import com.google.common.collect.ImmutableList; import java.util.ArrayList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.rel.RelNode; import org.apache.ignite.internal.processors.query.calcite.rel.IgniteAggregate; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ExplainPlan.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ExplainPlan.java index a521797..6d0e3cb 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ExplainPlan.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ExplainPlan.java @@ -17,6 +17,7 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; import java.util.List; + import org.apache.ignite.internal.processors.query.GridQueryFieldMetadata; import org.jetbrains.annotations.Nullable; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Fragment.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Fragment.java index afb4c39..4ce3320 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Fragment.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Fragment.java @@ -17,10 +17,11 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; -import com.google.common.collect.ImmutableList; import java.util.Collections; import java.util.List; import java.util.concurrent.atomic.AtomicLong; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.rel.RelDistribution; import org.apache.calcite.rel.metadata.RelMetadataQuery; import org.apache.ignite.internal.processors.query.calcite.metadata.IgniteMdNodesMapping; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentDescription.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentDescription.java index ae9c92e..1b836eb 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentDescription.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentDescription.java @@ -22,6 +22,7 @@ import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.UUID; + import org.apache.ignite.internal.GridDirectMap; import org.apache.ignite.internal.GridDirectTransient; import org.apache.ignite.internal.processors.query.calcite.message.MarshalableMessage; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentSplitter.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentSplitter.java index e8a853c..9c73207 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentSplitter.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/FragmentSplitter.java @@ -17,11 +17,12 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; -import com.google.common.collect.ImmutableList; import java.util.ArrayList; import java.util.Deque; import java.util.LinkedList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelTraitSet; import org.apache.calcite.rel.RelNode; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgnitePlanner.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgnitePlanner.java index 174aa06..9b96e43 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgnitePlanner.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgnitePlanner.java @@ -17,9 +17,10 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; -import com.google.common.collect.ImmutableList; import java.io.Reader; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.Context; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptCost; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgniteSqlValidator.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgniteSqlValidator.java index eafa777..d34a74a 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgniteSqlValidator.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/IgniteSqlValidator.java @@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; import java.util.List; import java.util.Map; import java.util.Set; + import org.apache.calcite.plan.RelOptTable; import org.apache.calcite.prepare.CalciteCatalogReader; import org.apache.calcite.prepare.Prepare; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepDmlPlan.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepDmlPlan.java index 131dff8..75cf46a 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepDmlPlan.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepDmlPlan.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; -import com.google.common.collect.ImmutableList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.ignite.internal.processors.query.GridQueryFieldMetadata; /** diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepPlan.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepPlan.java index 1d09db0..d0ac8fb 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepPlan.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepPlan.java @@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; import java.util.List; import java.util.Map; import java.util.UUID; + import org.apache.ignite.internal.processors.query.GridQueryFieldMetadata; import org.apache.ignite.internal.processors.query.calcite.metadata.MappingService; import org.apache.ignite.internal.processors.query.calcite.metadata.NodesMapping; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepQueryPlan.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepQueryPlan.java index 05bdb6d..7b64c9b 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepQueryPlan.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/MultiStepQueryPlan.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; -import com.google.common.collect.ImmutableList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.ignite.internal.processors.query.GridQueryFieldMetadata; /** diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/PlanningContext.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/PlanningContext.java index a7c88fd..7ddbd3d 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/PlanningContext.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/PlanningContext.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; import java.util.Properties; import java.util.UUID; + import org.apache.calcite.config.CalciteConnectionConfig; import org.apache.calcite.config.CalciteConnectionConfigImpl; import org.apache.calcite.config.CalciteConnectionProperty; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCache.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCache.java index fe5f628..732830f 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCache.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCache.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; import java.util.List; + import org.apache.ignite.internal.processors.query.calcite.util.Service; /** diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCacheImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCacheImpl.java index b5d13d2..e73955f 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCacheImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/QueryPlanCacheImpl.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; import java.util.List; import java.util.Map; + import org.apache.ignite.internal.GridKernalContext; import org.apache.ignite.internal.processors.cache.GridCacheContextInfo; import org.apache.ignite.internal.processors.query.GridIndex; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Splitter.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Splitter.java index 2038692..5a5dee0 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Splitter.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/Splitter.java @@ -17,11 +17,12 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; -import com.google.common.collect.ImmutableList; import java.util.ArrayList; import java.util.Deque; import java.util.LinkedList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.ignite.internal.processors.query.calcite.rel.IgniteAggregate; import org.apache.ignite.internal.processors.query.calcite.rel.IgniteExchange; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ValidationResult.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ValidationResult.java index a0b25c0..69fbb9e 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ValidationResult.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/prepare/ValidationResult.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.prepare; import java.util.List; + import org.apache.calcite.rel.type.RelDataType; import org.apache.calcite.sql.SqlNode; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteAggregate.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteAggregate.java index 619a0fb..00424d4 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteAggregate.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteAggregate.java @@ -23,6 +23,7 @@ import java.util.HashSet; import java.util.List; import java.util.Set; import java.util.stream.Collectors; + import org.apache.calcite.linq4j.Ord; import org.apache.calcite.plan.DeriveMode; import org.apache.calcite.plan.RelOptCluster; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteExchange.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteExchange.java index 23f41d6..8e26076 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteExchange.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteExchange.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.processors.query.calcite.rel; -import com.google.common.collect.ImmutableList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptCost; import org.apache.calcite.plan.RelOptPlanner; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteFilter.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteFilter.java index 3b4ea74..2915029 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteFilter.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteFilter.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.processors.query.calcite.rel; -import com.google.common.collect.ImmutableList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelTraitSet; import org.apache.calcite.rel.RelInput; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteJoin.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteJoin.java index 0b757cf..880b8d4 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteJoin.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteJoin.java @@ -17,14 +17,15 @@ package org.apache.ignite.internal.processors.query.calcite.rel; -import com.google.common.collect.ImmutableList; -import com.google.common.collect.ImmutableSet; import java.util.ArrayList; import java.util.Collection; import java.util.HashSet; import java.util.List; import java.util.Objects; import java.util.Set; + +import com.google.common.collect.ImmutableList; +import com.google.common.collect.ImmutableSet; import org.apache.calcite.plan.DeriveMode; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptPlanner; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteMapAggregate.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteMapAggregate.java index ede743c..cde5549 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteMapAggregate.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteMapAggregate.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.rel; import java.util.List; + import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelTraitSet; import org.apache.calcite.rel.RelInput; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteProject.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteProject.java index a153baf..eb6ba7e 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteProject.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteProject.java @@ -17,11 +17,12 @@ package org.apache.ignite.internal.processors.query.calcite.rel; -import com.google.common.collect.ImmutableList; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.linq4j.Ord; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelTraitSet; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteReceiver.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteReceiver.java index c7aad56..7f5b089 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteReceiver.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteReceiver.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.rel; import java.util.List; + import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelTraitSet; import org.apache.calcite.rel.AbstractRelNode; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteReduceAggregate.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteReduceAggregate.java index c572291..023ea24 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteReduceAggregate.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteReduceAggregate.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.processors.query.calcite.rel; -import com.google.common.collect.ImmutableList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.linq4j.Ord; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptUtil; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteRel.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteRel.java index 5d0a0f9..8e73318 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteRel.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteRel.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.rel; import java.util.List; + import org.apache.calcite.plan.RelTraitSet; import org.apache.calcite.rel.PhysicalNode; import org.apache.calcite.rel.RelCollation; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSender.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSender.java index 0dad7b1..385b659 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSender.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSender.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.rel; import java.util.List; + import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelTraitSet; import org.apache.calcite.rel.RelDistributions; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSort.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSort.java index 2b751fa..fa941ad 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSort.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteSort.java @@ -16,8 +16,9 @@ */ package org.apache.ignite.internal.processors.query.calcite.rel; -import com.google.common.collect.ImmutableList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelTraitSet; import org.apache.calcite.rel.RelCollation; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableModify.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableModify.java index 2242164..c2c2157 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableModify.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableModify.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.rel; import java.util.List; + import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptTable; import org.apache.calcite.plan.RelTraitSet; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableScan.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableScan.java index 81b7643..39c11f4 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableScan.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTableScan.java @@ -17,13 +17,14 @@ package org.apache.ignite.internal.processors.query.calcite.rel; -import com.google.common.collect.ImmutableList; import java.util.ArrayList; import java.util.EnumSet; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Set; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptCost; import org.apache.calcite.plan.RelOptPlanner; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTrimExchange.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTrimExchange.java index ddec7c0..d8816a9 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTrimExchange.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteTrimExchange.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.processors.query.calcite.rel; -import com.google.common.collect.ImmutableList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelTraitSet; import org.apache.calcite.rel.RelDistribution; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteUnionAll.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteUnionAll.java index ecfb14f..f9fcd04 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteUnionAll.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteUnionAll.java @@ -21,6 +21,7 @@ import java.util.ArrayList; import java.util.List; import java.util.Set; import java.util.stream.Collectors; + import org.apache.calcite.plan.DeriveMode; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptRule; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteValues.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteValues.java index bda7276..42a3c63 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteValues.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rel/IgniteValues.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.processors.query.calcite.rel; -import com.google.common.collect.ImmutableList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelTraitSet; import org.apache.calcite.rel.RelInput; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/RegisterIndexRule.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/RegisterIndexRule.java index 5bc6038..afecdf9 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/RegisterIndexRule.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/RegisterIndexRule.java @@ -21,6 +21,7 @@ import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; + import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptRule; import org.apache.calcite.plan.RelOptRuleCall; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/UnionConverterRule.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/UnionConverterRule.java index 9556814..7735dfb 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/UnionConverterRule.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/UnionConverterRule.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.processors.query.calcite.rule; -import com.google.common.collect.ImmutableList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptPlanner; import org.apache.calcite.plan.RelOptRule; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/logical/LogicalOrToUnionRule.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/logical/LogicalOrToUnionRule.java index 920319e..2dd202d 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/logical/LogicalOrToUnionRule.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/rule/logical/LogicalOrToUnionRule.java @@ -17,9 +17,10 @@ package org.apache.ignite.internal.processors.query.calcite.rule.logical; +import java.util.List; + import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableMap; -import java.util.List; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptRule; import org.apache.calcite.plan.RelOptRuleCall; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteIndex.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteIndex.java index 3e931d9..d746ec5 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteIndex.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteIndex.java @@ -17,6 +17,7 @@ package org.apache.ignite.internal.processors.query.calcite.schema; import java.util.function.Predicate; + import org.apache.calcite.rel.RelCollation; import org.apache.ignite.internal.processors.query.GridIndex; import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteSchema.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteSchema.java index 3dcf4a0..ee2422f 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteSchema.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteSchema.java @@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.query.calcite.schema; import java.util.Collections; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; + import org.apache.calcite.schema.Table; import org.apache.calcite.schema.impl.AbstractSchema; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTable.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTable.java index adc01f9..00a9e74 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTable.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTable.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.schema; import java.util.List; import java.util.Map; + import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptTable; import org.apache.calcite.rel.RelCollation; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTableImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTableImpl.java index e415267..1b83abf 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTableImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/IgniteTableImpl.java @@ -17,12 +17,13 @@ package org.apache.ignite.internal.processors.query.calcite.schema; -import com.google.common.collect.ImmutableList; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.DataContext; import org.apache.calcite.linq4j.Enumerable; import org.apache.calcite.plan.RelOptCluster; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/SchemaHolderImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/SchemaHolderImpl.java index ff544f4..daef6b7 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/SchemaHolderImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/SchemaHolderImpl.java @@ -21,6 +21,7 @@ import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; + import org.apache.calcite.rel.RelCollation; import org.apache.calcite.rel.RelCollations; import org.apache.calcite.rel.RelFieldCollation; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptor.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptor.java index 2ce85f1..eef32fc 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptor.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptor.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.schema; import java.util.Map; + import org.apache.calcite.plan.RelOptTable; import org.apache.calcite.rel.core.TableModify; import org.apache.calcite.rel.type.RelDataType; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptorImpl.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptorImpl.java index 76dca91..1f9eeea 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptorImpl.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/schema/TableDescriptorImpl.java @@ -25,6 +25,7 @@ import java.util.List; import java.util.Map; import java.util.Objects; import java.util.Set; + import org.apache.calcite.plan.RelOptTable; import org.apache.calcite.rel.core.TableModify; import org.apache.calcite.rel.type.RelDataType; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionFunction.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionFunction.java index dfa5f32..8db896d 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionFunction.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionFunction.java @@ -24,6 +24,7 @@ import java.util.List; import java.util.Objects; import java.util.UUID; import java.util.function.ToIntFunction; + import org.apache.calcite.rel.RelDistribution; import org.apache.calcite.rel.RelNode; import org.apache.calcite.util.ImmutableIntList; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionTrait.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionTrait.java index 27dcbdf..2d3cc49 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionTrait.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/DistributionTrait.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.processors.query.calcite.trait; -import com.google.common.collect.Ordering; import java.util.Objects; + +import com.google.common.collect.Ordering; import org.apache.calcite.plan.RelMultipleTrait; import org.apache.calcite.plan.RelOptPlanner; import org.apache.calcite.plan.RelTrait; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/IgniteDistributions.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/IgniteDistributions.java index ad6e926..0a4fa77 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/IgniteDistributions.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/IgniteDistributions.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.trait; import java.util.List; + import org.apache.calcite.plan.RelTraitDef; import org.apache.calcite.util.ImmutableIntList; import org.apache.ignite.internal.processors.query.calcite.trait.DistributionFunction.AffinityDistribution; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/TraitUtils.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/TraitUtils.java index 6ca3ad1..e9ad7af 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/TraitUtils.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/trait/TraitUtils.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.processors.query.calcite.trait; -import com.google.common.collect.ImmutableList; import java.util.List; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.plan.RelOptCluster; import org.apache.calcite.plan.RelOptPlanner; import org.apache.calcite.plan.RelOptRule; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeFactory.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeFactory.java index 5aabe79..8d39f69 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeFactory.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeFactory.java @@ -19,6 +19,7 @@ package org.apache.ignite.internal.processors.query.calcite.type; import java.util.List; import java.util.Objects; + import org.apache.calcite.jdbc.JavaTypeFactoryImpl; import org.apache.calcite.rel.type.RelDataType; import org.apache.calcite.rel.type.RelDataTypeSystem; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeSystem.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeSystem.java index 9323e12..d4785f6 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeSystem.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/type/IgniteTypeSystem.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.type; import java.io.Serializable; + import org.apache.calcite.rel.type.RelDataTypeSystem; import org.apache.calcite.rel.type.RelDataTypeSystemImpl; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/Commons.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/Commons.java index b22ca25..a53b357 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/Commons.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/Commons.java @@ -28,6 +28,7 @@ import java.util.Objects; import java.util.Set; import java.util.function.Function; import java.util.stream.Collectors; + import org.apache.calcite.config.CalciteSystemProperty; import org.apache.calcite.plan.Context; import org.apache.calcite.plan.Contexts; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/ConvertingClosableIterator.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/ConvertingClosableIterator.java index ba75e6c..44e07bb 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/ConvertingClosableIterator.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/ConvertingClosableIterator.java @@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.query.calcite.util; import java.util.ArrayList; import java.util.Iterator; import java.util.List; + import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.processors.query.calcite.exec.RowHandler; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/IgniteMethod.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/IgniteMethod.java index c486f57..dca2c4f 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/IgniteMethod.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/IgniteMethod.java @@ -18,6 +18,7 @@ package org.apache.ignite.internal.processors.query.calcite.util; import java.lang.reflect.Method; + import org.apache.calcite.linq4j.tree.Types; import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.processors.query.calcite.exec.RowHandler; diff --git a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/ListFieldsQueryCursor.java b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/ListFieldsQueryCursor.java index ec491dc..c1bc194 100644 --- a/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/ListFieldsQueryCursor.java +++ b/modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/util/ListFieldsQueryCursor.java @@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.query.calcite.util; import java.util.ArrayList; import java.util.Iterator; import java.util.List; + import org.apache.ignite.IgniteCheckedException; import org.apache.ignite.cache.query.FieldsQueryCursor; import org.apache.ignite.internal.processors.cache.query.QueryCursorEx; diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/CalciteBasicSecondaryIndexIntegrationTest.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/CalciteBasicSecondaryIndexIntegrationTest.java index 051f4ca..8e18e4b 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/CalciteBasicSecondaryIndexIntegrationTest.java +++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/CalciteBasicSecondaryIndexIntegrationTest.java @@ -17,6 +17,7 @@ package org.apache.ignite.internal.processors.query.calcite; import java.util.LinkedHashMap; + import org.apache.ignite.Ignite; import org.apache.ignite.IgniteCache; import org.apache.ignite.cache.CacheMode; diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessorTest.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessorTest.java index b49bd47..985e75f 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessorTest.java +++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/CalciteQueryProcessorTest.java @@ -17,9 +17,10 @@ package org.apache.ignite.internal.processors.query.calcite; -import com.google.common.collect.ImmutableMap; import java.util.Arrays; import java.util.List; + +import com.google.common.collect.ImmutableMap; import org.apache.ignite.IgniteCache; import org.apache.ignite.cache.CacheMode; import org.apache.ignite.cache.QueryEntity; diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/PlannerTest.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/PlannerTest.java index 89a8f9b..7968f0a 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/PlannerTest.java +++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/PlannerTest.java @@ -27,6 +27,7 @@ import java.util.Map; import java.util.UUID; import java.util.concurrent.atomic.AtomicInteger; import java.util.function.Predicate; + import org.apache.calcite.DataContext; import org.apache.calcite.config.CalciteConnectionConfig; import org.apache.calcite.linq4j.Enumerable; diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/QueryChecker.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/QueryChecker.java index 836204f..b79db57 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/QueryChecker.java +++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/QueryChecker.java @@ -24,6 +24,7 @@ import java.util.Comparator; import java.util.Iterator; import java.util.List; import java.util.stream.Collectors; + import org.apache.ignite.cache.query.FieldsQueryCursor; import org.apache.ignite.internal.processors.query.QueryEngine; import org.apache.ignite.internal.util.typedef.F; diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/ClosableIteratorsHolderTest.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/ClosableIteratorsHolderTest.java index d1587d0..85c468b 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/ClosableIteratorsHolderTest.java +++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/ClosableIteratorsHolderTest.java @@ -23,6 +23,7 @@ import java.util.NoSuchElementException; import java.util.Optional; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; + import org.apache.ignite.testframework.GridTestUtils; import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; import org.junit.After; diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractExecutionTest.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractExecutionTest.java index 34f7c24..c3c7f9a 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractExecutionTest.java +++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/AbstractExecutionTest.java @@ -17,13 +17,14 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; -import com.google.common.collect.ImmutableMap; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; import java.util.stream.Collectors; import java.util.stream.IntStream; + +import com.google.common.collect.ImmutableMap; import org.apache.ignite.internal.GridKernalContext; import org.apache.ignite.internal.processors.query.calcite.exec.ArrayRowHandler; import org.apache.ignite.internal.processors.query.calcite.exec.ExchangeService; diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ContinuousExecutionTest.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ContinuousExecutionTest.java index 0a0c4d1..cf4f8c5 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ContinuousExecutionTest.java +++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ContinuousExecutionTest.java @@ -17,12 +17,13 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; -import com.google.common.collect.ImmutableList; import java.util.Iterator; import java.util.List; import java.util.NoSuchElementException; import java.util.Random; import java.util.UUID; + +import com.google.common.collect.ImmutableList; import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext; import org.apache.ignite.internal.processors.query.calcite.exec.MailboxRegistry; import org.apache.ignite.internal.processors.query.calcite.trait.AllNodes; diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ExecutionTest.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ExecutionTest.java index e8688f2..21bd420 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ExecutionTest.java +++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/exec/rel/ExecutionTest.java @@ -17,12 +17,13 @@ package org.apache.ignite.internal.processors.query.calcite.exec.rel; -import com.google.common.collect.ImmutableList; import java.util.ArrayList; import java.util.Arrays; import java.util.List; import java.util.UUID; import java.util.function.Supplier; + +import com.google.common.collect.ImmutableList; import org.apache.calcite.rel.RelCollations; import org.apache.calcite.rel.core.AggregateCall; import org.apache.calcite.rel.type.RelDataType; diff --git a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/jdbc/JdbcQueryTest.java b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/jdbc/JdbcQueryTest.java index 848e275..c755974 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/jdbc/JdbcQueryTest.java +++ b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/jdbc/JdbcQueryTest.java @@ -23,6 +23,7 @@ import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import java.util.concurrent.TimeUnit; + import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion; import org.apache.ignite.testframework.junits.WithSystemProperty; import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; diff --git a/modules/calcite/src/test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite.java b/modules/calcite/src/test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite.java index b823ddd..26b66c9 100644 --- a/modules/calcite/src/test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite.java +++ b/modules/calcite/src/test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite.java @@ -19,12 +19,12 @@ package org.apache.ignite.testsuites; import org.apache.ignite.internal.processors.query.calcite.CalciteBasicSecondaryIndexIntegrationTest; import org.apache.ignite.internal.processors.query.calcite.CalciteQueryProcessorTest; -import org.apache.ignite.internal.processors.query.calcite.rules.OrToUnionRuleTest; import org.apache.ignite.internal.processors.query.calcite.PlannerTest; import org.apache.ignite.internal.processors.query.calcite.exec.ClosableIteratorsHolderTest; import org.apache.ignite.internal.processors.query.calcite.exec.rel.ContinuousExecutionTest; import org.apache.ignite.internal.processors.query.calcite.exec.rel.ExecutionTest; import org.apache.ignite.internal.processors.query.calcite.jdbc.JdbcQueryTest; +import org.apache.ignite.internal.processors.query.calcite.rules.OrToUnionRuleTest; import org.junit.runner.RunWith; import org.junit.runners.Suite;