repo.or.cz
/
hbase.git
/
tree
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
log
|
graphiclog1
|
graphiclog2
|
commit
|
commitdiff
|
tree
|
refs
|
edit
|
fork
history
|
HEAD
|
snapshot (
tar.gz
zip
)
HBASE-26765 Minor refactor of async scanning code (#4121)
[hbase.git]
/
hbase-client
/
src
/
main
/
java
/
org
/
apache
/
hadoop
/
hbase
/
client
/
tree
622acb41953d6f2750f8bab16b281fb4680cad75
drwxr-xr-x
..
-rw-r--r--
1769
AbstractClientScanner.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1212
AbstractResponse.java
blob
|
blame
|
history
|
raw
-rw-r--r--
12624
AbstractRpcBasedConnectionRegistry.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2885
Action.java
blob
|
blame
|
history
|
raw
-rw-r--r--
117491
Admin.java
blob
|
blame
|
history
|
raw
-rw-r--r--
34162
AdminOverAsyncAdmin.java
blob
|
blame
|
history
|
raw
-rw-r--r--
5304
AdvancedScanResultConsumer.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3164
AllowPartialScanResultCache.java
blob
|
blame
|
history
|
raw
-rw-r--r--
7202
Append.java
blob
|
blame
|
history
|
raw
-rw-r--r--
74739
AsyncAdmin.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3878
AsyncAdminBuilder.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2607
AsyncAdminBuilderBase.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2689
AsyncAdminRequestRetryingCaller.java
blob
|
blame
|
history
|
raw
-rw-r--r--
22334
AsyncBatchRpcRetryingCaller.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3410
AsyncBufferedMutator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4219
AsyncBufferedMutatorBuilder.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3682
AsyncBufferedMutatorBuilderImpl.java
blob
|
blame
|
history
|
raw
-rw-r--r--
5636
AsyncBufferedMutatorImpl.java
blob
|
blame
|
history
|
raw
-rw-r--r--
8577
AsyncClientScanner.java
blob
|
blame
|
history
|
raw
-rw-r--r--
10287
AsyncConnection.java
blob
|
blame
|
history
|
raw
-rw-r--r--
10516
AsyncConnectionConfiguration.java
blob
|
blame
|
history
|
raw
-rw-r--r--
16603
AsyncConnectionImpl.java
blob
|
blame
|
history
|
raw
-rw-r--r--
30779
AsyncHBaseAdmin.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3046
AsyncMasterRequestRpcRetryingCaller.java
blob
|
blame
|
history
|
raw
-rw-r--r--
5544
AsyncMetaRegionLocator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
28183
AsyncNonMetaRegionLocator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
11218
AsyncRegionLocator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
5990
AsyncRegionLocatorHelper.java
blob
|
blame
|
history
|
raw
-rw-r--r--
8779
AsyncRpcRetryingCaller.java
blob
|
blame
|
history
|
raw
-rw-r--r--
18353
AsyncRpcRetryingCallerFactory.java
blob
|
blame
|
history
|
raw
-rw-r--r--
24486
AsyncScanSingleRegionRpcRetryingCaller.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2828
AsyncServerRequestRpcRetryingCaller.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4287
AsyncSingleRequestRpcRetryingCaller.java
blob
|
blame
|
history
|
raw
-rw-r--r--
29202
AsyncTable.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4926
AsyncTableBuilder.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3764
AsyncTableBuilderBase.java
blob
|
blame
|
history
|
raw
-rw-r--r--
9596
AsyncTableImpl.java
blob
|
blame
|
history
|
raw
-rw-r--r--
5955
AsyncTableRegionLocator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2804
AsyncTableRegionLocatorImpl.java
blob
|
blame
|
history
|
raw
-rw-r--r--
5203
AsyncTableResultScanner.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1584
Attributes.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3725
BalanceRequest.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4170
BalanceResponse.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4728
BalancerDecision.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3547
BalancerRejection.java
blob
|
blame
|
history
|
raw
-rw-r--r--
6348
BatchScanResultCache.java
blob
|
blame
|
history
|
raw
-rw-r--r--
8457
BufferedMutator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
6486
BufferedMutatorOverAsyncBufferedMutator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
7380
BufferedMutatorParams.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1783
CatalogReplicaLoadBalanceSelector.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1973
CatalogReplicaLoadBalanceSelectorFactory.java
blob
|
blame
|
history
|
raw
-rw-r--r--
12391
CatalogReplicaLoadBalanceSimpleSelector.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2207
CatalogReplicaMode.java
blob
|
blame
|
history
|
raw
-rw-r--r--
9248
CheckAndMutate.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1514
CheckAndMutateResult.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2002
ClientCoprocessorRpcController.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3288
ClientIdGenerator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3214
ClientUtil.java
blob
|
blame
|
history
|
raw
-rw-r--r--
9405
ClusterStatusListener.java
blob
|
blame
|
history
|
raw
-rw-r--r--
8305
ColumnFamilyDescriptor.java
blob
|
blame
|
history
|
raw
-rw-r--r--
51918
ColumnFamilyDescriptorBuilder.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1173
CompactType.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1047
CompactionState.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4580
CompleteScanResultCache.java
blob
|
blame
|
history
|
raw
-rw-r--r--
10537
Connection.java
blob
|
blame
|
history
|
raw
-rw-r--r--
8672
ConnectionConfiguration.java
blob
|
blame
|
history
|
raw
-rw-r--r--
12228
ConnectionFactory.java
blob
|
blame
|
history
|
raw
-rw-r--r--
8255
ConnectionOverAsyncConnection.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2157
ConnectionRegistry.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1650
ConnectionRegistryFactory.java
blob
|
blame
|
history
|
raw
-rw-r--r--
24858
ConnectionUtils.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1892
Consistency.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2462
CoprocessorBlockingRpcCallback.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1754
CoprocessorDescriptor.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3516
CoprocessorDescriptorBuilder.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1244
Cursor.java
blob
|
blame
|
history
|
raw
-rw-r--r--
11589
Delete.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1476
DoNotRetryRegionException.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2116
Durability.java
blob
|
blame
|
history
|
raw
-rw-r--r--
15618
Get.java
blob
|
blame
|
history
|
raw
-rw-r--r--
9722
HBaseHbck.java
blob
|
blame
|
history
|
raw
-rw-r--r--
6470
Hbck.java
blob
|
blame
|
history
|
raw
-rw-r--r--
14282
ImmutableScan.java
blob
|
blame
|
history
|
raw
-rw-r--r--
10132
Increment.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1795
IsolationLevel.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1394
LogEntry.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4021
LogQueryFilter.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3661
MasterCoprocessorRpcChannelImpl.java
blob
|
blame
|
history
|
raw
-rw-r--r--
6245
MasterRegistry.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1020
MasterSwitchType.java
blob
|
blame
|
history
|
raw
-rw-r--r--
20372
MetricsConnection.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1269
MobCompactPartitionPolicy.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3609
MultiResponse.java
blob
|
blame
|
history
|
raw
-rw-r--r--
11012
MutableRegionInfo.java
blob
|
blame
|
history
|
raw
-rw-r--r--
32392
Mutation.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1343
NoServerForRegionException.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1469
NonceGenerator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3392
NormalizeTableFilterParams.java
blob
|
blame
|
history
|
raw
-rw-r--r--
9719
OnlineLogRecord.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3984
Operation.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4275
OperationWithAttributes.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1594
PackagePrivateFieldAccessor.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1992
PerClientRandomNonceGenerator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
8721
Put.java
blob
|
blame
|
history
|
raw
-rw-r--r--
9178
Query.java
blob
|
blame
|
history
|
raw
-rw-r--r--
188163
RawAsyncHBaseAdmin.java
blob
|
blame
|
history
|
raw
-rw-r--r--
36686
RawAsyncTableImpl.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4995
RegionCoprocessorRpcChannelImpl.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3680
RegionCoprocessorServiceExec.java
blob
|
blame
|
history
|
raw
-rw-r--r--
29136
RegionInfo.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4017
RegionInfoBuilder.java
blob
|
blame
|
history
|
raw
-rw-r--r--
5397
RegionInfoDisplay.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1514
RegionLoadStats.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1303
RegionLocateType.java
blob
|
blame
|
history
|
raw
-rw-r--r--
6854
RegionLocator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2193
RegionLocatorOverAsyncTableRegionLocator.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1318
RegionOfflineException.java
blob
|
blame
|
history
|
raw
-rw-r--r--
6674
RegionReplicaUtil.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3693
RegionServerCoprocessorRpcChannelImpl.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4635
RegionStatesCount.java
blob
|
blame
|
history
|
raw
-rw-r--r--
6118
RegistryEndpointsRefresher.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3924
RequestController.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1780
RequestControllerFactory.java
blob
|
blame
|
history
|
raw
-rw-r--r--
34271
Result.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4003
ResultScanner.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1686
ResultStatsUtil.java
blob
|
blame
|
history
|
raw
-rw-r--r--
4444
RetriesExhaustedException.java
blob
|
blame
|
history
|
raw
-rw-r--r--
6113
RetriesExhaustedWithDetailsException.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1188
Row.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1307
RowAccess.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3921
RowMutations.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1259
RowTooBigException.java
blob
|
blame
|
history
|
raw
-rw-r--r--
5551
RpcConnectionRegistry.java
blob
|
blame
|
history
|
raw
-rw-r--r--
34500
Scan.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2121
ScanResultCache.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1526
ScanResultConsumer.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1857
ScanResultConsumerBase.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2034
ServerStatisticTracker.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1194
ServerType.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2066
ServiceCaller.java
blob
|
blame
|
history
|
raw
-rw-r--r--
20097
SimpleRequestController.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1692
SingleResponse.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2393
SlowLogParams.java
blob
|
blame
|
history
|
raw
-rw-r--r--
5328
SnapshotDescription.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1032
SnapshotType.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1216
StatisticTrackable.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3274
SyncCoprocessorRpcChannel.java
blob
|
blame
|
history
|
raw
-rw-r--r--
34276
Table.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2142
TableBuilder.java
blob
|
blame
|
history
|
raw
-rw-r--r--
2264
TableBuilderBase.java
blob
|
blame
|
history
|
raw
-rw-r--r--
11134
TableDescriptor.java
blob
|
blame
|
history
|
raw
-rw-r--r--
58346
TableDescriptorBuilder.java
blob
|
blame
|
history
|
raw
-rw-r--r--
3485
TableDescriptorUtils.java
blob
|
blame
|
history
|
raw
-rw-r--r--
19727
TableOverAsyncTable.java
blob
|
blame
|
history
|
raw
-rw-r--r--
6445
TableState.java
blob
|
blame
|
history
|
raw
-rw-r--r--
1177
WrongRowIOException.java
blob
|
blame
|
history
|
raw
-rw-r--r--
9436
ZKConnectionRegistry.java
blob
|
blame
|
history
|
raw
drwxr-xr-x
-
backoff
tree
|
history
drwxr-xr-x
-
coprocessor
tree
|
history
drwxr-xr-x
-
metrics
tree
|
history
-rw-r--r--
10436
package-info.java
blob
|
blame
|
history
|
raw
drwxr-xr-x
-
replication
tree
|
history
drwxr-xr-x
-
security
tree
|
history
drwxr-xr-x
-
trace
tree
|
history