MCPcopy Create free account

hub / github.com/apache/incubator-pegasus / functions

Functions8,667 in github.com/apache/incubator-pegasus

⨍ Functions 8,667◇ Types & classes 2,204
↓ 1 callersMethodasyncOperate
(client_operator op, ClientOPCallback callback, int timeoutMs)
java-client/src/main/java/org/apache/pegasus/rpc/async/TableHandler.java:501
↓ 1 callersMethodasyncSortKeyCount
(byte[] hashKey, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:110
↓ 1 callersMethodasyncStartScan
()
java-client/src/main/java/org/apache/pegasus/client/PegasusScanner.java:190
↓ 1 callersMethodasyncTTL
get TTL value for a specific (hashKey, sortKey) pair, async version @param hashKey used to decide which partition the key may exist if null or empty,
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:863
↓ 1 callersMethodasync_check_and_set
src/client_lib/pegasus_client_impl.cpp:879
↓ 1 callersMethodasync_checkpoint
src/replica/storage/simple_kv/simple_kv.server.impl.cpp:254
↓ 1 callersMethodasync_distance
src/geo/lib/geo_client.cpp:976
↓ 1 callersMethodasync_duplicate
src/client_lib/pegasus_client_impl.cpp:1283
↓ 1 callersMethodasync_get_scanner
src/client_lib/pegasus_client_impl.cpp:1134
↓ 1 callersFunctionasync_nfs_copy
src/nfs/nfs_client_impl.h:82
↓ 1 callersFunctionasync_nfs_get_file_size
src/nfs/nfs_client_impl.h:68
↓ 1 callersMethodauthenticate
start the authentiate process
java-client/src/main/java/org/apache/pegasus/security/AuthProtocol.java:27
↓ 1 callersMethodbackground_clear_backup_checkpoint
src/replica/backup/replica_backup_manager.cpp:168
↓ 1 callersMethodbackground_sync_checkpoint
run in init thread
src/replica/replica_chkpt.cpp:337
↓ 1 callersMethodbackupCall
(ClientRequestRound clientRequestRound, TableHandler tableHandler)
java-client/src/main/java/org/apache/pegasus/rpc/interceptor/BackupRequestInterceptor.java:55
↓ 1 callersMethodbackup_app
src/client/replication_ddl_client.cpp:1058
↓ 1 callersFunctionbackup_get_tmp_dir_name
backup/backup_tmp.<policy_name>.<backup_id>.<timestamp>
src/replica/replica_backup.cpp:283
↓ 1 callersFunctionbackup_parse_dir_name
src/replica/replica_backup.cpp:404
↓ 1 callersFunctionbackup_start_time
[0 ~ 60)
src/meta/meta_backup_service.h:109
↓ 1 callersMethodbalance
src/meta/greedy_load_balancer.cpp:200
↓ 1 callersMethodbalance
src/meta/app_balance_policy.cpp:79
↓ 1 callersMethodbalance
(ctx context.Context, req *admin.ConfigurationBalancerRequest)
go-client/session/admin_rpc_types.go:355
↓ 1 callersMethodbalance_config_file
src/meta/test/balancer_validator.cpp:226
↓ 1 callersMethodbalancer_validator
src/meta/test/balancer_validator.cpp:116
↓ 1 callersMethodbatchClear
()
go-client/pegasus/scanner.go:190
↓ 1 callersMethodbatchDel
Batch delete values of different keys. Will terminate immediately if any error occurs. @deprecated Retained only for backward compatibility, will be
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:445
↓ 1 callersMethodbatchDel
(List<Pair<byte[], byte[]>> keys, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1684
↓ 1 callersMethodbatchDel2
Batch delete values of different keys. Will wait for all requests done even if some error occurs. @deprecated Retained only for backward compatibilit
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:466
↓ 1 callersMethodbatchDel2
(List<Pair<byte[], byte[]>> keys, List<PException> results, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1703
↓ 1 callersMethodbatchGet
Batch get values of different keys. Will terminate immediately if any error occurs. @deprecated Retained only for backward compatibility, will be rem
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:900
↓ 1 callersMethodbatchGet
(List<Pair<byte[], byte[]>> keys, List<byte[]> values, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1147
↓ 1 callersMethodbatchGet2
Batch get values of different keys. Will wait for all requests done even if some error occurs. @deprecated Retained only for backward compatibility,
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:164
↓ 1 callersMethodbatchGet2
( List<Pair<byte[], byte[]>> keys, List<Pair<PException, byte[]>> results, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1264
↓ 1 callersMethodbatchGetByPartitions
( List<Pair<byte[], byte[]>> keys, List<Pair<PException, byte[]>> results, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1174
↓ 1 callersMethodbatchMultiDel
Batch delete specified sort keys under the same hash key. Will terminate immediately if any error occurs. @deprecated Retained only for backward comp
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:511
↓ 1 callersMethodbatchMultiDel
(List<Pair<byte[], List<byte[]>>> keys, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1851
↓ 1 callersMethodbatchMultiDel2
Batch delete specified sort keys under the same hash key. Will wait for all requests done even if some error occurs. @deprecated Retained only for ba
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:532
↓ 1 callersMethodbatchMultiDel2
( List<Pair<byte[], List<byte[]>>> keys, List<PException> results, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1871
↓ 1 callersMethodbatchMultiGet
( List<Pair<byte[], List<byte[]>>> keys, List<HashKeyData> values, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1391
↓ 1 callersMethodbatchMultiGet2
Batch get multiple values under the same hash key. Will wait for all requests done even if some error occurs. @deprecated Retained only for backward
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:278
↓ 1 callersMethodbatchMultiGet2
( List<Pair<byte[], List<byte[]>>> keys, List<Pair<PException, HashKeyData>> results, int ti
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1423
↓ 1 callersMethodbatchMultiSet
Batch set multiple value under the same hash key. Will terminate immediately if any error occurs. @deprecated Retained only for backward compatibilit
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:388
↓ 1 callersMethodbatchMultiSet
(List<HashKeyData> items, int ttlSeconds, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1610
↓ 1 callersMethodbatchMultiSet2
Batch set multiple value under the same hash key. Will wait for all requests done even if some error occurs. @deprecated Retained only for backward c
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:413
↓ 1 callersMethodbatchMultiSet2
( List<HashKeyData> items, int ttlSeconds, List<PException> results, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1634
↓ 1 callersMethodbatchSet
Batch set lots of values. Will terminate immediately if any error occurs. @deprecated Retained only for backward compatibility, will be removed later
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:336
↓ 1 callersMethodbatchSet
(List<SetItem> items, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1523
↓ 1 callersMethodbatchSet2
Batch set lots of values. Will wait for all requests done even if some error occurs. @deprecated Retained only for backward compatibility, will be re
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:355
↓ 1 callersMethodbatchSet2
(List<SetItem> items, List<PException> results, int timeout)
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1536
↓ 1 callersMethodbatch_get_sync
---------- call RPC_RRDB_RRDB_BATCH_GET ------------ - synchronous
src/include/rrdb/rrdb.client.h:308
↓ 1 callersMethodbegin_remote_copy
src/nfs/nfs_client_impl.cpp:129
↓ 1 callersMethodblock
src/meta/test/meta_service_test_app.h:72
↓ 1 callersFunctionbold
(s)
scripts/run-clang-format.py:233
↓ 1 callersFunctionbold_red
(s)
scripts/run-clang-format.py:228
↓ 1 callersFunctionbuild_client_network_confs
src/runtime/global_config.cpp:52
↓ 1 callersFunctionbuild_server_network_confs
src/runtime/global_config.cpp:122
↓ 1 callersMethodbytes
src/replica/duplication/mutation_batch.h:75
↓ 1 callersMethodbytesToHex
(byte[] bytes)
java-client/src/test/java/org/apache/pegasus/client/TestBasic.java:43
↓ 1 callersFunctionbytes_cmp
(left, right)
python-client/pypegasus/utils/tools.py:108
↓ 1 callersFunctionc_unescape_sequences
return < 0 means failed
src/base/pegasus_utils.cpp:129
↓ 1 callersFunctionc_unescape_string
src/base/pegasus_utils.cpp:186
↓ 1 callersFunctioncacheline_aligned_alloc
extern */
src/utils/alloc.cpp:31
↓ 1 callersMethodcalc
src/perf_counter/perf_counter_atomic.h:392
↓ 1 callersMethodcall_task
src/client/partition_resolver.cpp:57
↓ 1 callersMethodcall_update_configuration
src/meta/test/update_configuration_test.cpp:164
↓ 1 callersMethodcall_update_configuration
src/meta/test/meta_partition_guardian_test.cpp:125
↓ 1 callersFunctioncan_gc_replica_slog
src/replica/mutation_log.cpp:1430
↓ 1 callersMethodcan_run_balancer
src/meta/server_state.cpp:2426
↓ 1 callersMethodcancel
src/utils/defer.h:53
↓ 1 callersMethodcannot_run_balancer_test
src/meta/test/update_configuration_test.cpp:465
↓ 1 callersMethodcapacity
src/replica/mutation_cache.h:59
↓ 1 callersFunctioncas_check_type_to_string
src/base/idl_utils.h:29
↓ 1 callersMethodchange_dup_status
src/client/replication_ddl_client.cpp:1388
↓ 1 callersMethodcheckAndMutate
( byte[] hashKey, byte[] checkSortKey, CheckType checkType, byte[] checkOperand,
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1968
↓ 1 callersMethodcheckAndSet
( byte[] hashKey, byte[] checkSortKey, CheckType checkType, byte[] checkOperand,
java-client/src/main/java/org/apache/pegasus/client/PegasusTable.java:1935
↓ 1 callersMethodcheckArguments
(byte[] hashKey, List<Pair<byte[], byte[]>> values)
java-client/src/main/java/org/apache/pegasus/client/request/MultiSet.java:57
↓ 1 callersMethodcheckArguments
(byte[] hashKey, List<byte[]> sortKeys)
java-client/src/main/java/org/apache/pegasus/client/request/MultiDelete.java:47
↓ 1 callersMethodcheckArguments
(byte[] hashKey, List<byte[]> sortKeys)
java-client/src/main/java/org/apache/pegasus/client/request/MultiGet.java:47
↓ 1 callersFunctioncheckDuplicationCompleted
(perfSessions map[string]*aggregate.PerfSession, tableID int32)
admin-cli/executor/toolkits/tablemigrator/migrator.go:126
↓ 1 callersFunctioncheckPendingMutationCount
(perfSessions map[string]*aggregate.PerfSession)
admin-cli/executor/toolkits/tablemigrator/migrator.go:100
↓ 1 callersMethodcheckTGTAndRelogin
()
java-client/src/main/java/org/apache/pegasus/security/KerberosProtocol.java:106
↓ 1 callersMethodcheck_and_mutate
src/client_lib/pegasus_client_impl.cpp:967
↓ 1 callersMethodcheck_and_set
src/client_lib/pegasus_client_impl.cpp:846
↓ 1 callersMethodcheck_app_bulk_load_states
ThreadPool: THREAD_POOL_META_SERVER
src/meta/meta_bulk_load_service.cpp:2076
↓ 1 callersMethodcheck_backup_on_remote_test
src/replica/test/cold_backup_context_test.cpp:57
↓ 1 callersMethodcheck_bulk_load_request_params
ThreadPool: THREAD_POOL_META_SERVER
src/meta/meta_bulk_load_service.cpp:163
↓ 1 callersMethodcheck_client_read
src/replica/storage/simple_kv/test/case.cpp:1197
↓ 1 callersMethodcheck_client_write
src/replica/storage/simple_kv/test/case.cpp:1175
↓ 1 callersMethodcheck_config
src/replica/storage/simple_kv/test/case.cpp:306
↓ 1 callersFunctioncheck_configuration
Attention: we can't do these check work by `DSN_DEFINE_validator`, because somebody may don't want to use security, so these configuration may not set
src/runtime/security/kinit_context.cpp:68
↓ 1 callersFunctioncheck_cure
src/meta/test/balancer_validator.cpp:56
↓ 1 callersFunctioncheck_dangling_lock
src/runtime/zlocks.cpp:64
↓ 1 callersFunctioncheck_diff
Check if .licenserc.yaml is consistent with all real files of the project.
scripts/check_license.py:167
↓ 1 callersFunctioncheck_empty
src/utils/test/utils.cpp:99
↓ 1 callersFunctioncheck_entities_from_json_string
src/utils/test/metrics_test.cpp:2383
↓ 1 callersFunctioncheck_entity_from_json_string
src/utils/test/metrics_test.cpp:1446
↓ 1 callersFunctioncheck_entity_ids_from_json_string
src/utils/test/metrics_test.cpp:2250
↓ 1 callersMethodcheck_ever_ingestion_succeed
ThreadPool: THREAD_POOL_META_STATE
src/meta/meta_bulk_load_service.cpp:1179
↓ 1 callersMethodcheck_if_add
src/meta/meta_bulk_load_ingestion_context.cpp:87
↓ 1 callersFunctioncheck_nodes_loads
src/meta/test/meta_partition_guardian_test.cpp:756
← previousnext →2,201–2,300 of 8,667, ranked by callers