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

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);