MCPcopy Create free account

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

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

↓ 1,337 callersMethodget
sync version of Get, please refer to the async version {@link #asyncGet(byte[], byte[], int)}
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:882
↓ 937 callersMethodsize
src/utils/blob.h:113
↓ 716 callersMethodend
src/shell/argh.h:130
↓ 657 callersMethodfind
src/utils/string_view.cpp:93
↓ 433 callersMethodset
sync version of Set, please refer to the async version {@link #asyncSet(byte[], byte[], byte[], int, int)} and {@link #asyncSet(byte[], byte[], byte[]
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:1054
↓ 377 callersMethoddata
src/utils/blob.h:110
↓ 309 callersMethodsize
return total data size in the block
src/replica/log_block.h:84
↓ 294 callersFunctionenum_to_string
TODO(wutao): rename to negotiation_status_to_string
src/runtime/security/negotiation_utils.h:26
↓ 293 callersFunctionto_string
src/meta/meta_backup_service.h:111
↓ 285 callersMethodadd
(Future<Result> task)
java-client/src/main/java/org/apache/pegasus/client/FutureGroup.java:33
↓ 272 callersMethodsize
src/shell/argh.h:131
↓ 269 callersFunctionenqueue
src/runtime/task/async_calls.h:83
↓ 267 callersMethodbegin
begin() and end() for using range-for over positional args.
src/shell/argh.h:129
↓ 253 callersMethodlength
src/utils/blob.h:112
↓ 252 callersMethodString
String returns the name of the Codec implementation.
go-client/rpc/codec.go:31
↓ 246 callersMethodempty
src/meta/meta_data.cpp:309
↓ 220 callersMethodstore
src/replica/replication_app_base.cpp:132
↓ 200 callersMethodinit_app_counter
init app counter create counters for some specific service_app, so different service_app can create counter with the same name.
src/perf_counter/perf_counter_wrapper.h:80
↓ 194 callersMethodget_app_id
src/common/gpid.h:57
↓ 182 callersMethodsize
src/replica/duplication/mutation_batch.h:73
↓ 179 callersMethodemplace
src/utils/strings.cpp:174
↓ 171 callersMethodload
arguments: k1=v1;k2=v2;k3=v3; ... e.g., port = %port% timeout = %timeout% arguments: port=23466;timeout=1000 or arguments: ports=23466,timout=1000
src/utils/configuration.cpp:66
↓ 168 callersMethodget
Get value. @param tableName TableHandler name @param hashKey used to decide which partition to get this k-v, if null or length == 0, means no has
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:127
↓ 149 callersMethodget_partition_index
src/common/gpid.h:59
↓ 146 callersMethodclear
src/meta/meta_data.cpp:272
↓ 145 callersMethodstr
Get the string value.
src/shell/argh.h:80
↓ 143 callersMethodlength
src/replica/log_file_stream.h:163
↓ 141 callersMethodisCheckValueReturned
()
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:597
↓ 140 callersMethodempty
src/replica/log_file_stream.h:164
↓ 140 callersMethodto_string
src/meta/duplication/duplication_info.cpp:180
↓ 140 callersMethodwait
src/utils/metrics.cpp:596
↓ 139 callersMethodisCheckValueExist
()
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:605
↓ 137 callersFunctionc_escape_string
src/base/pegasus_utils.h:90
↓ 135 callersMethodto_string
src/utils/gpid.cpp:39
↓ 133 callersMethodappend_data
src/utils/output_utils.h:118
↓ 130 callersMethoderror
src/runtime/task/task.h:230
↓ 129 callersMethoderase
src/zookeeper/distributed_lock_service_zookeeper.cpp:88
↓ 128 callersMethoddel
sync version of Del, please refer to the async version {@link #asyncDel(byte[], byte[], int)}
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:1156
↓ 127 callersMethodadd_column
src/utils/output_utils.cpp:72
↓ 124 callersMethodclear
()
java-client/src/main/java/org/apache/pegasus/base/blob.java:117
↓ 124 callersMethodempty
src/server/pegasus_write_service.h:96
↓ 124 callersMethodsubstr
string_view::substr() Returns a "substring" of the `string_view` (at offset `pos` and length `n`) as another string_view. This function throws `std::
src/utils/string_view.h:336
↓ 123 callersMethodclose
Close the client. The client can not be used again after closed.
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:40
↓ 122 callersMethodname
()
java-client/src/main/java/org/apache/pegasus/security/AuthProtocol.java:25
↓ 114 callersMethodadd_row_name_and_data
src/utils/output_utils.h:126
↓ 114 callersMethodgetCheckValue
()
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:613
↓ 111 callersFunctiondsn_now_ms
src/runtime/api_layer1.h:268
↓ 111 callersMethodis_ok
src/utils/errors.h:92
↓ 110 callersMethodincrement
src/utils/metrics.h:820
↓ 107 callersFunctionunmarshall
src/runtime/rpc/serialization.h:69
↓ 105 callersMethodnext
Get the next item. @return item like {@literal <<hashKey, sortKey>, value>}; null returned if scan completed. @throws PException
java-client/src/main/java/org/apache/pegasus/client/PegasusScannerInterface.java:36
↓ 105 callersFunctionpath_combine
src/utils/filesystem.cpp:609
↓ 103 callersMethoddel
Delete value. @param tableName TableHandler name @param hashKey used to decide which partition to put this k-v, if null or length == 0, means no
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:432
↓ 100 callersFunctioncfg
extern*/
src/utils/fail_point.cpp:84
↓ 100 callersFunctionremove_path
src/utils/filesystem.cpp:352
↓ 98 callersFunctiondsn_now_ns
src/utils/clock.cpp:22
↓ 97 callersMethodwait_outstanding_tasks
src/runtime/task/task_tracker.cpp:70
↓ 96 callersMethodback
string_view::back() Returns the last element of a `string_view`.
src/utils/string_view.h:276
↓ 95 callersMethodmulti_get
src/client_lib/pegasus_client_impl.cpp:305
↓ 94 callersMethodis_invalid
src/aio/aio_provider.h:46
↓ 93 callersMethodmultiGet
Get multiple values under the same hash key. @param tableName table name @param hashKey used to decide which partition to put this k-v, should not be
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:190
↓ 93 callersMethodthread_hash
src/common/gpid.h:75
↓ 93 callersMethodtoString
()
java-client/src/main/java/org/apache/pegasus/security/Credential.java:43
↓ 92 callersMethodend
string_view::end() Returns an iterator pointing just beyond the last character at the end of the `string_view`. This iterator acts as a placeholder;
src/utils/string_view.h:204
↓ 90 callersMethodload
src/replica/replication_app_base.cpp:118
↓ 88 callersMethoddelete
(currentAction *Action)
admin-cli/executor/toolkits/nodesmigrator/action.go:65
↓ 85 callersFunctionfile_exists
src/utils/filesystem.cpp:238
↓ 81 callersMethodcheck_and_mutate
src/server/pegasus_write_service.cpp:242
↓ 80 callersMethodfail
src/replica/storage/simple_kv/test/case.cpp:1090
↓ 79 callersMethodappend
src/replica/mutation_log.cpp:65
↓ 79 callersMethodlast_committed_decree
src/replica/replica.h:237
↓ 78 callersMethodcheckAndMutate
Atomically check and mutate by key. If the check condition is satisfied, then apply to mutate. @param tableName the table name. @param hashKey the ha
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:611
↓ 77 callersMethodcheck_and_set
src/server/pegasus_write_service.cpp:222
↓ 76 callersFunctionbuf2int32
src/utils/string_conv.h:107
↓ 76 callersMethodclear
src/replica/mutation.cpp:446
↓ 74 callersMethodGetErr
()
go-client/session/meta_call.go:34
↓ 74 callersMethodassign
src/utils/blob.h:85
↓ 74 callersMethodrelease_ref
src/utils/autoref_ptr.h:70
↓ 73 callersMethodget_value
src/perf_counter/perf_counter_atomic.h:180
↓ 73 callersMethodisMutateSucceed
()
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:686
↓ 72 callersMethodcheckAndSet
Atomically check and set value by key. If the check condition is satisfied, then apply to set value. @param tableName the table name. @param hashKey
java-client/src/main/java/org/apache/pegasus/client/PegasusClientInterface.java:587
↓ 72 callersMethodisSetSucceed
()
java-client/src/main/java/org/apache/pegasus/client/PegasusTableInterface.java:589
↓ 72 callersMethodresize
src/utils/blob.h:180
↓ 70 callersFunctiondecode
src/http/uri_decoder.cpp:56
↓ 70 callersMethodget_error_string
src/geo/lib/geo_client.h:370
↓ 69 callersFunctiondirectory_exists
src/utils/filesystem.cpp:221
↓ 69 callersMethodrbegin
string_view::rbegin() Returns a reverse iterator pointing to the last character at the end of the `string_view`, or `rend()` if the `string_view` is
src/utils/string_view.h:223
↓ 69 callersMethodsize
src/utils/absl/utility/utility.h:76
↓ 69 callersMethodto_string
src/replica/replication_app_base.cpp:182
↓ 68 callersMethodError
()
go-client/pegasus/error.go:87
↓ 67 callersFunctionget_normalized_path
TODO(yingchun): remove the return value because it's always 0.
src/utils/filesystem.cpp:98
↓ 66 callersMethodadd_ref
src/utils/autoref_ptr.h:58
↓ 66 callersMethodgetTableName
()
java-client/src/main/java/org/apache/pegasus/rpc/Table.java:48
↓ 66 callersMethodwait
src/meta/test/meta_service_test_app.h:67
↓ 65 callersMethodfront
src/meta/meta_data.cpp:287
↓ 65 callersFunctionsplit_args
src/utils/strings.cpp:293
↓ 64 callersMethodempty
string_view::empty() Checks if the `string_view` is empty (refers to no characters).
src/utils/string_view.h:260
↓ 63 callersMethodString
()
go-client/session/session.go:57
↓ 63 callersFunctionpegasus_generate_key
src/base/pegasus_key_schema.h:41
↓ 63 callersMethodput_back
TODO(wutao): call it add_advice()
src/utils/join_point.h:71
next →1–100 of 8,667, ranked by callers