Path	Lines of Code
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcScheduler.java	195
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/ipc/PhoenixRpcSchedulerFactory.java	50
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/ipc/RpcUtil.java	9
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/ipc/controller/InterRegionServerMetadataRpcControllerFactory.java	30
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/ipc/controller/ServerRpcControllerFactory.java	9
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/DataTableLocalIndexRegionScanner.java	96
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/IndexHalfStoreFileReader.java	106
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/IndexHalfStoreFileReaderGenerator.java	263
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/IndexKeyValueSkipListSet.java	20
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/KeyValueSkipListSet.java	115
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/LocalIndexSplitter.java	4
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/LocalIndexStoreFileScanner.java	210
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/ScannerContextUtil.java	29
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/BinaryCompatibleBaseDecoder.java	67
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/IndexedHLogReader.java	4
phoenix-core-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/IndexedWALEditCodec.java	189
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/AddColumnMutator.java	338
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/BaseMetaDataEndpointObserver.java	74
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/BaseRegionScanner.java	35
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/BaseScannerRegionObserver.java	410
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/CDCGlobalIndexRegionScanner.java	206
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/ChildLinkMetaDataEndpoint.java	77
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/ColumnMutator.java	32
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/CompactionScanner.java	2154
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/DelegateRegionCoprocessorEnvironment.java	89
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/DelegateRegionObserver.java	251
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/DelegateRegionScanner.java	84
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/DropColumnMutator.java	246
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/GlobalIndexRegionScanner.java	1243
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/GroupByCache.java	11
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/GroupedAggregateRegionObserver.java	816
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/HashJoinRegionScanner.java	360
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/IndexRebuildRegionScanner.java	382
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/IndexRepairRegionScanner.java	447
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/IndexToolVerificationResult.java	516
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/IndexerRegionScanner.java	407
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointImpl.java	4310
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/MetaDataEndpointObserver.java	41
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/MetaDataRegionObserver.java	573
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/OmidGCProcessor.java	28
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/OmidTransactionalProcessor.java	29
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/PagingRegionScanner.java	235
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/PhoenixAccessController.java	602
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/PhoenixCoprocessor.java	8
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/PhoenixMasterObserver.java	237
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/PhoenixMetaDataCoprocessorHost.java	215
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/PhoenixRegionServerEndpoint.java	102
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/PhoenixTTLRegionObserver.java	260
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/ReplicationSinkEndpoint.java	4
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/ScanRegionObserver.java	124
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/SequenceRegionObserver.java	333
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/ServerCachingEndpointImpl.java	86
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/SuffixFilter.java	35
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/SystemCatalogRegionObserver.java	25
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/TTLRegionScanner.java	237
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/TaskMetaDataEndpoint.java	87
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/TaskRegionObserver.java	228
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/TephraTransactionalProcessor.java	11
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/UncoveredGlobalIndexRegionScanner.java	191
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/UncoveredIndexRegionScanner.java	398
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/UncoveredLocalIndexRegionScanner.java	109
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionObserver.java	891
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/UngroupedAggregateRegionScanner.java	695
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/VerifyLastDDLTimestamp.java	27
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/tasks/BaseTask.java	14
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/tasks/CdcStreamPartitionMetadataTask.java	121
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/tasks/DropChildViewsTask.java	78
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/tasks/IndexRebuildTask.java	146
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/tasks/TransformMonitorTask.java	144
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/CapturingAbortable.java	32
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/IndexRegionObserver.java	1681
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/IndexRegionSplitPolicy.java	48
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/Indexer.java	542
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/LockManager.java	136
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/balancer/IndexLoadBalancer.java	4
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/builder/BaseIndexBuilder.java	95
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/builder/IndexBuildManager.java	137
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/builder/IndexBuilder.java	35
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/covered/CoveredColumns.java	23
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/covered/LocalTableState.java	142
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/covered/NonTxIndexBuilder.java	113
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/covered/data/CachedLocalTable.java	143
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/covered/data/IndexMemStore.java	145
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/parallel/ThreadPoolManager.java	80
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/wal/IndexedKeyValue.java	116
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/wal/KeyValueCodec.java	52
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/AbstractParallelWriterIndexCommitter.java	153
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/DelegateIndexFailurePolicy.java	33
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/IndexCommitter.java	12
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/IndexFailurePolicy.java	12
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriter.java	143
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/IndexWriterUtils.java	80
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/KillServerOnFailurePolicy.java	37
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/LazyParallelWriterIndexCommitter.java	9
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/LeaveIndexActiveFailurePolicy.java	26
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/ParallelWriterIndexCommitter.java	28
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/RecoveryIndexWriter.java	97
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/TrackingParallelWriterIndexCommitter.java	213
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/recovery/PerRegionIndexWriteCache.java	25
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/write/recovery/StoreFailuresInCachePolicy.java	46
phoenix-core-server/src/main/java/org/apache/phoenix/index/GlobalIndexChecker.java	488
phoenix-core-server/src/main/java/org/apache/phoenix/index/PhoenixIndexBuilder.java	236
phoenix-core-server/src/main/java/org/apache/phoenix/index/PhoenixIndexFailurePolicy.java	306
phoenix-core-server/src/main/java/org/apache/phoenix/index/PhoenixIndexMetaDataBuilder.java	78
phoenix-core-server/src/main/java/org/apache/phoenix/index/PhoenixTransactionalIndexer.java	180
phoenix-core-server/src/main/java/org/apache/phoenix/iterate/MapReduceParallelScanGrouper.java	98
phoenix-core-server/src/main/java/org/apache/phoenix/iterate/NonAggregateRegionScannerFactory.java	589
phoenix-core-server/src/main/java/org/apache/phoenix/iterate/RegionScannerFactory.java	362
phoenix-core-server/src/main/java/org/apache/phoenix/iterate/RegionScannerResultIterator.java	73
phoenix-core-server/src/main/java/org/apache/phoenix/iterate/SnapshotScanner.java	199
phoenix-core-server/src/main/java/org/apache/phoenix/iterate/TableSnapshotResultIterator.java	172
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/AbstractBulkLoadTool.java	368
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/CsvBulkImportUtil.java	49
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/CsvBulkLoadTool.java	86
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/CsvToKeyValueMapper.java	61
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/FormatToBytesWritableMapper.java	299
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/FormatToKeyValueReducer.java	150
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/ImportPreUpsertKeyValueProcessor.java	6
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/JsonBulkLoadTool.java	24
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/JsonToKeyValueMapper.java	38
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/MultiHfileOutputFormat.java	494
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/OrphanViewTool.java	764
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputFormat.java	209
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixInputSplit.java	103
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixJobCounters.java	6
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixMultiViewInputFormat.java	80
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixMultiViewInputSplit.java	45
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixMultiViewReader.java	54
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixOutputCommitter.java	24
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixOutputFormat.java	38
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordReader.java	154
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWritable.java	138
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixRecordWriter.java	73
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixServerBuildIndexInputFormat.java	174
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixTTLDeleteJobMapper.java	197
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixTTLTool.java	262
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/PhoenixTextInputFormat.java	63
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/RegexBulkLoadTool.java	43
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/RegexToKeyValueMapper.java	83
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/bulkload/TableRowkeyPair.java	88
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/bulkload/TargetTableRef.java	34
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/bulkload/TargetTableRefFunctions.java	68
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/DirectHTableWriter.java	84
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/IndexScrutinyMapper.java	453
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/IndexScrutinyMapperForTest.java	23
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/IndexScrutinyTableOutput.java	268
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/IndexScrutinyTool.java	434
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/IndexTool.java	1028
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/IndexToolUtil.java	36
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/IndexUpgradeTool.java	806
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/IndexVerificationOutputRepository.java	337
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/IndexVerificationOutputRow.java	187
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/IndexVerificationResultRepository.java	347
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexDBWritable.java	59
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportDirectMapper.java	162
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexImportDirectReducer.java	184
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexPartialBuildMapper.java	150
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixIndexToolJobCounters.java	28
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixScrutinyJobCounters.java	9
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixServerBuildIndexDBWritable.java	29
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/PhoenixServerBuildIndexMapper.java	44
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/SourceTargetColumnNames.java	118
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/automation/PhoenixAsyncIndex.java	45
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/automation/PhoenixMRJobCallable.java	44
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/automation/PhoenixMRJobSubmitter.java	268
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/index/automation/YarnApplication.java	145
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/transform/PhoenixTransformReducer.java	44
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/transform/PhoenixTransformRepairMapper.java	159
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/transform/PhoenixTransformWithViewsInputFormat.java	103
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/transform/TransformTool.java	851
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/ColumnInfoToStringEncoderDecoder.java	33
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/DefaultMultiViewJobStatusTracker.java	29
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/DefaultMultiViewSplitStrategy.java	37
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/DefaultPhoenixMultiViewListProvider.java	152
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/IndexColumnNames.java	171
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/MultiViewJobStatusTracker.java	6
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/MultiViewSplitStrategy.java	7
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixConfigurationUtil.java	676
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixMapReduceUtil.java	124
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixMultiInputUtil.java	79
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/PhoenixMultiViewListProvider.java	6
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/ViewInfoTracker.java	74
phoenix-core-server/src/main/java/org/apache/phoenix/mapreduce/util/ViewInfoWritable.java	28
phoenix-core-server/src/main/java/org/apache/phoenix/replication/SystemCatalogWALEntryFilter.java	59
phoenix-core-server/src/main/java/org/apache/phoenix/schema/MetaDataSplitPolicy.java	31
phoenix-core-server/src/main/java/org/apache/phoenix/schema/SplitOnLeadingVarCharColumnsPolicy.java	22
phoenix-core-server/src/main/java/org/apache/phoenix/schema/SystemFunctionSplitPolicy.java	7
phoenix-core-server/src/main/java/org/apache/phoenix/schema/SystemStatsSplitPolicy.java	7
phoenix-core-server/src/main/java/org/apache/phoenix/schema/SystemTaskSplitPolicy.java	4
phoenix-core-server/src/main/java/org/apache/phoenix/schema/stats/DefaultStatisticsCollector.java	300
phoenix-core-server/src/main/java/org/apache/phoenix/schema/stats/NoOpStatisticsCollector.java	44
phoenix-core-server/src/main/java/org/apache/phoenix/schema/stats/StatisticsCollector.java	23
phoenix-core-server/src/main/java/org/apache/phoenix/schema/stats/StatisticsCollectorFactory.java	40
phoenix-core-server/src/main/java/org/apache/phoenix/schema/stats/StatisticsScanner.java	155
phoenix-core-server/src/main/java/org/apache/phoenix/schema/stats/StatisticsWriter.java	225
phoenix-core-server/src/main/java/org/apache/phoenix/schema/stats/UpdateStatisticsTool.java	249
phoenix-core-server/src/main/java/org/apache/phoenix/schema/task/ServerTask.java	77
phoenix-core-server/src/main/java/org/apache/phoenix/schema/transform/Transform.java	393
phoenix-core-server/src/main/java/org/apache/phoenix/util/MergeViewIndexIdSequencesTool.java	76
phoenix-core-server/src/main/java/org/apache/phoenix/util/PhoenixMRJobUtil.java	172
phoenix-core-server/src/main/java/org/apache/phoenix/util/RepairUtil.java	22
phoenix-core-server/src/main/java/org/apache/phoenix/util/ServerIndexUtil.java	75
phoenix-core-server/src/main/java/org/apache/phoenix/util/ServerUtil.java	225
phoenix-core-server/src/main/java/org/apache/phoenix/util/ServerViewUtil.java	97
phoenix-core-server/src/main/java/org/apache/phoenix/util/ZKBasedMasterElectionUtil.java	42