以调试形式，深入理解凤凰全局索引

PhoenixConnection connection = (PhoenixConnection)DriverManager.getConnection(                  "jdbc:phoenix:local:2181",                  "test",                  "test");
PhoenixStatement statement = (PhoenixStatement)connection.createStatement();String sql = "select /*+ INDEX(test idx_test_email) */ * from test where email='test@test.com'";PhoenixResultSet explainRes = (PhoenixResultSet)statement.executeQuery("explain "+sql);while (explainRes.next()){    logger.info("explain: {}",explainRes.getString(1));}
PhoenixResultSet resultSet = (PhoenixResultSet)statement.executeQuery(sql);while (resultSet.next()){    logger.info("id: {},name: {},email: {}",            resultSet.getString("id"),            resultSet.getString("name"),            resultSet.getString("email"));}explainRes.close();resultSet.close();statement.close();connection.close();} catch (SQLException e) {e.printStackTrace();}

CLIENT 1-CHUNK PARALLEL 1-WAY ROUND ROBIN FULL SCAN OVER TEST    SKIP-SCAN-JOIN TABLE 0        CLIENT 1-CHUNK PARALLEL 1-WAY ROUND ROBIN RANGE SCAN OVER IDX_TEST_EMAIL ['test@test.com']            SERVER FILTER BY FIRST KEY ONLY    DYNAMIC SERVER FILTER BY "TEST.ID" IN ($2.$4)

plan = {ScanPlan@3907}  splits = null scans = null allowPageFilter = true isSerial = false isDataToScanWithinThreshold = false serialRowsEstimate = null serialBytesEstimate = null serialEstimateInfoTs = null tableRef = {TableRef@3910}  tableRefs = {SingletonImmutableSet@3911}  size = 1 context = {StatementContext@3912}   resolver = {FromCompiler$ProjectedTableColumnResolver@3920}   binds = {BindManager@3921}   scan = {Scan@3922} "{"loadColumnFamiliesOnDemand":true,"filter":"EMAIL = 'test@test.com'","startRow":"","stopRow":"","batch":-1,"cacheBlocks":true,"totalColumns":1,"maxResultSize":-1,"families":{"0":["ALL"]},"caching":2147483647,"maxVersions":1,"timeRange":[0,9223372036854775807]}"  expressions = {ExpressionManager@3923}   aggregates = {AggregationManager@3924}   dateFormat = "yyyy-MM-dd HH:mm:ss.SSS"  dateFormatter = {FastDateFormat@3926} "FastDateFormat[yyyy-MM-dd HH:mm:ss.SSS]"  timeFormat = "yyyy-MM-dd HH:mm:ss.SSS"  timeFormatter = {FastDateFormat@3926} "FastDateFormat[yyyy-MM-dd HH:mm:ss.SSS]"  timestampFormat = "yyyy-MM-dd HH:mm:ss.SSS"  timestampFormatter = {FastDateFormat@3926} "FastDateFormat[yyyy-MM-dd HH:mm:ss.SSS]"  dateFormatTimeZone = {ZoneInfo@3927} "sun.util.calendar.ZoneInfo[id="GMT",offset=0,dstSavings=0,useDaylight=false,transitions=0,lastRule=null]"  numberFormat = "#,##0.###"  tempPtr = {ImmutableBytesWritable@3929} ""  statement = {PhoenixStatement@3903}   dataColumns = {LinkedHashMap@3930}  size = 0  currentTime = -1  scanRanges = {ScanRanges@3931} "ScanRanges[[]]"  sequences = {SequenceManager@3932}   currentTable = {TableRef@3910}   whereConditionColumns = {ArrayList@3933}  size = 1  subqueryResults = {HashMap@3934}  size = 0  readMetricsQueue = {ReadMetricQueue@3935}   overAllQueryMetrics = {OverAllQueryMetrics@3936}   queryLogger = null  isClientSideUpsertSelect = false statement = {PhoenixStatement$ExecutableSelectStatement@3904} "SELECT /*+ INDEX(TEST IDX_TEST_EMAIL) */  *  FROM TEST  WHERE EMAIL = 'test@test.com'" projection = {RowProjector@3913} "[ID,NAME,EMAIL]" paramMetaData = {PhoenixParameterMetaData@3914}  limit = null offset = null orderBy = {OrderByCompiler$OrderBy@3915}  groupBy = {GroupByCompiler$GroupBy$1@3916}  parallelIteratorFactory = {ParallelIteratorFactory$1@3917}  dynamicFilter = null dataPlan = null estimatedRows = null estimatedSize = null estimateInfoTimestamp = null getEstimatesCalled = false

plan = connection.getQueryServices().getOptimizer().optimize(PhoenixStatement.this, plan);

plan = {HashJoinPlan@3967}  statement = {SelectStatement@3970} "SELECT /*+ NO_INDEX */ TEST.* FROM TEST  Semi JOIN (SELECT /*+ INDEX(TEST IDX_TEST_EMAIL) */ 1 $3,":ID" $4 FROM "IDX_TEST_EMAIL"  WHERE "0:EMAIL" = 'test@test.com') ON ("ID" = $2.$4)" joinInfo = {HashJoinInfo@3971}  subPlans = {HashJoinPlan$HashSubPlan[1]@3972}   0 = {HashJoinPlan$HashSubPlan@3978}    index = 0   plan = {TupleProjectionPlan@3979}     tupleProjector = {TupleProjector@3984} "TUPLE-PROJECTOR {[1, "ID"] ==> [INTEGER, VARCHAR]}"    postFilter = null    delegate = {ScanPlan@3985}      splits = null     scans = null     allowPageFilter = true     isSerial = false     isDataToScanWithinThreshold = false     serialRowsEstimate = null     serialBytesEstimate = null     serialEstimateInfoTs = null     tableRef = {TableRef@3987}      tableRefs = {SingletonImmutableSet@3988}  size = 1     context = {StatementContext@3989}      statement = {SelectStatement@3990} "SELECT /*+ INDEX(TEST IDX_TEST_EMAIL) */ 1 $3,":ID" $4 FROM "IDX_TEST_EMAIL"  WHERE "0:EMAIL" = 'test@test.com'"     projection = {RowProjector@3991} "[1,"ID"]"     paramMetaData = {PhoenixParameterMetaData@3992}      limit = null     offset = null     orderBy = {OrderByCompiler$OrderBy@3993}      groupBy = {GroupByCompiler$GroupBy$1@3994}      parallelIteratorFactory = {ParallelIteratorFactory$1@3995}      dynamicFilter = null     dataPlan = null     estimatedRows = null     estimatedSize = null     estimateInfoTimestamp = null     getEstimatesCalled = false   hashExpressions = null   singleValueOnly = false   keyRangeLhsExpression = {RowKeyColumnExpression@3980} ""TEST.ID""   keyRangeRhsExpression = {ProjectedColumnExpression@3981} "$2.$4" recompileWhereClause = false tableRefs = {HashSet@3974}  size = 2 maxServerCacheTimeToLive = 30000 serverCacheLimit = 104857600 dependencies = {HashMap@3975}  size = 0 hashClient = null firstJobEndTime = null keyRangeExpressions = null estimatedRows = null estimatedBytes = null estimateInfoTs = null getEstimatesCalled = false delegate = {ScanPlan@3976}

/** *  * Interface for an executable query plan * *  * @since 0.1 */public interface QueryPlan extends StatementPlan ;/** * Get a result iterator to iterate over the results * @return result iterator for iterating over the results * @throws SQLException */public ResultIterator iterator() throws SQLException;/** *  * @return whether underlying {@link ResultScanner} can be picked up in a round-robin  * fashion. Generally, selecting scanners in such a fashion is possible if rows don't * have to be returned back in a certain order. * @throws SQLException  */public boolean useRoundRobinIterator() throws SQLException;

public ResultIterator iterator(ParallelScanGrouper scanGrouper, Scan scan) throws SQLException

iterator = {RoundRobinResultIterator@4319}  threshold = 2147483646 numScannersCacheExhausted = 0 resultIterators = {ParallelIterators@4325} "ResultIterators [name=PARALLEL,id=8f373aba-e360-94d0-ae67-3774e06c338e,scans=[[{"loadColumnFamiliesOnDemand":true,"startRow":"1","stopRow":"1\\x00","batch":-1,"cacheBlocks":true,"totalColumns":3,"maxResultSize":-1,"families":{"0":["\\x00\\x00\\x00\\x00","\\x80\\x0B","\\x80\\x0C"]},"caching":2147483647,"maxVersions":1,"timeRange":[0,9223372036854775807]}]]]"  iteratorFactory = {ParallelIteratorFactory$1@4328}   initFirstScanOnly = false  scans = {ArrayList@4329}  size = 1  splits = {SingletonImmutableList@4330}  size = 1  physicalTableName = {byte[4]@4331}   plan = {ScanPlan@3968}   scanId = "8f373aba-e360-94d0-ae67-3774e06c338e"  mutationState = {MutationState@4333}   scanGrouper = {DefaultParallelScanGrouper@3967}   allFutures = {ArrayList@4334}  size = 0  estimatedRows = {Long@4335} 1  estimatedSize = {Long@4336} 206  estimateInfoTimestamp = {Long@4337} 0  hasGuidePosts = false  scan = {Scan@4249} "{"loadColumnFamiliesOnDemand":true,"startRow":"1","stopRow":"1\\x00","batch":-1,"cacheBlocks":true,"totalColumns":3,"maxResultSize":-1,"families":{"0":["\\x00\\x00\\x00\\x00","\\x80\\x0B","\\x80\\x0C"]},"caching":2147483647,"maxVersions":1,"timeRange":[0,9223372036854775807]}"  useStatsForParallelization = true  caches = {HashMap@3974}  size = 0  dataPlan = null  context = {StatementContext@4269}   tableRef = {TableRef@4338}   groupBy = {GroupByCompiler$GroupBy$1@4339}   orderBy = {OrderByCompiler$OrderBy@4340}   hint = {HintNode@4341} "/*+ NO_INDEX */ "  limit = null  offset = null openIterators = {ArrayList@4326}  size = 0 index = 0 closed = false plan = {ScanPlan@3968}  numParallelFetches = 0

plan = connection.getQueryServices().getOptimizer().optimize(PhoenixStatement.this, plan);