Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/hazelcast/hazelcast
/ functions
Functions
147,315 in github.com/hazelcast/hazelcast
⨍
Functions
147,315
◇
Types & classes
15,944
↓ 26 callers
Method
getPublicType
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataTypeFamily.java:157
↓ 26 callers
Method
getRandomInstance
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/integration/CompactFormatSplitBrainTest.java:174
↓ 26 callers
Method
getSetOperationCount
Returns the number of set operations @return number of set operations
hazelcast/src/main/java/com/hazelcast/map/LocalMapStats.java:151
↓ 26 callers
Method
getThisAddress
@return the address of this member that listens for CLIENT protocol connections. When advanced network config is in use, it will be different from the
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEngine.java:81
↓ 26 callers
Method
getThisAddress
()
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:59
↓ 26 callers
Method
getThreadId
Get the thread ID. @return the thread ID
hazelcast/src/main/java/com/hazelcast/internal/util/ThreadUtil.java:38
↓ 26 callers
Method
getTimeoutMillis
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/Transaction.java:38
↓ 26 callers
Method
getTotalInsertLatency
Returns the total latency (in nanoseconds) of insert operations performed on the index. <p> To compute the average latency divide the returned value b
hazelcast/src/main/java/com/hazelcast/query/LocalIndexStats.java:75
↓ 26 callers
Method
getTxnId
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/Transaction.java:34
↓ 26 callers
Method
getWanContext
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:89
↓ 26 callers
Method
hashCode
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:375
↓ 26 callers
Method
isCompatible
Checks if two {@link Config} instances are compatible. <p> This mostly means that the config values will have the same impact on the behaviour of the
hazelcast/src/test/java/com/hazelcast/config/ConfigCompatibilityChecker.java:80
↓ 26 callers
Method
iterator
@return an iterator that iterates over all the indexes of bits set in this sparse bit set.
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseBitSet.java:163
↓ 26 callers
Method
jobStatus
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:169
↓ 26 callers
Method
list
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/list/ListSplitBrainProtectionReadTest.java:184
↓ 26 callers
Method
load
(K key)
hazelcast/src/test/java/com/hazelcast/journal/EventJournalDataStructureAdapter.java:37
↓ 26 callers
Method
nested
(GroupObject object)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/reader/CompactValueReaderTestStructure.java:550
↓ 26 callers
Method
nested
(GroupPortable portable)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderTestStructure.java:616
↓ 26 callers
Method
onFirstNull
Returns a traverser that will emit the same items as this traverser and additionally run the supplied action the first time this traverser returns {@c
hazelcast/src/main/java/com/hazelcast/jet/Traverser.java:227
↓ 26 callers
Method
orElseThrow
(Function<K, Throwable> keyNotFoundException)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/DefaultedMap.java:98
↓ 26 callers
Method
partitionPredicate
Creates a new partition predicate that restricts the execution of the target predicate to a single partition. @param partitionKey the partition key @
hazelcast/src/main/java/com/hazelcast/query/Predicates.java:579
↓ 26 callers
Method
permissions
@return the list of permissions required to run this function @implNote If used, permissions should be hardcoded based on function arguments/context.
hazelcast/src/main/java/com/hazelcast/security/impl/function/SecuredFunction.java:42
↓ 26 callers
Method
putBiValue
(Object field1, Object field2, ExpressionType<?> type1, ExpressionType<?> type2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/misc/CaseOperatorIntegrationTest.java:411
↓ 26 callers
Method
readCount
Returns the number of items that have been read before filtering. <p> If no filter is set, then the {@code readCount} will be equal to {@link #size}.
hazelcast/src/main/java/com/hazelcast/ringbuffer/ReadResultSet.java:55
↓ 26 callers
Method
registerClassDefinition
(ClassDefinition cd)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableContext.java:43
↓ 26 callers
Method
remove
Removes the given key value pair from the multimap. <p> <b>Warning:</b> This method uses {@code hashCode} and {@code equals} of the binary form of the
hazelcast/src/main/java/com/hazelcast/multimap/MultiMap.java:149
↓ 26 callers
Method
rethrow
(Throwable cause, ClientConnection connection)
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlClientService.java:491
↓ 26 callers
Method
setOperationResponseHandler
Sets the {@link OperationResponseHandler}. Value is allowed to be null. @param responseHandler the {@link OperationResponseHandler} to set. @return t
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operation.java:476
↓ 26 callers
Method
setShared
{@code true} if an instance of the data connection will be reused. {@code false} when on each usage the data connection instance should be created @p
hazelcast/src/main/java/com/hazelcast/config/DataConnectionConfig.java:127
↓ 26 callers
Method
setThreadId
(long threadId)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperation.java:401
↓ 26 callers
Method
timeToString
Returns a String representation of the time. <p> This method is not particularly efficient since it generates a ton of litter. @param timeMillis time
hazelcast/src/main/java/com/hazelcast/internal/util/StringUtil.java:153
↓ 26 callers
Method
totalParallelism
Returns the total number of {@code Processor}s that will be created across the cluster. This number remains stable for entire job execution. It is equ
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorMetaSupplier.java:853
↓ 26 callers
Method
trim
(String value)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/TrimSimpleFunctionIntegrationTest.java:113
↓ 26 callers
Method
validateConfiguredTypes
Validates that the configured key matches the provided key. @param cacheConfig Cache configuration. @param key the key to be validated with i
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxyUtil.java:164
↓ 26 callers
Method
writeInt32
Writes a 32-bit two's complement signed integer. @param fieldName name of the field. @param value to be written.
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactWriter.java:67
↓ 25 callers
Method
addTimestamps
Adds a timestamp to each item in the stream using the supplied function and specifies the allowed amount of disorder between them. As the stream moves
hazelcast/src/main/java/com/hazelcast/jet/pipeline/GeneralStage.java:1219
↓ 25 callers
Method
allToOne
Activates a special-cased {@link RoutingPolicy#PARTITIONED PARTITIONED} routing policy where all items will be routed to the same partition ID, determ
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:353
↓ 25 callers
Method
apply
Determines whether the minimum cluster size property is satisfied based on the current list of members in the cluster. Lite members are excluded and o
hazelcast/src/main/java/com/hazelcast/splitbrainprotection/SplitBrainProtectionFunction.java:51
↓ 25 callers
Method
assertAnyOrder
Asserts that the previous stage emitted the expected items in any order, but nothing else. If the assertion fails, the job will fail with an {@link As
hazelcast/src/main/java/com/hazelcast/jet/pipeline/test/Assertions.java:107
↓ 25 callers
Method
assertBackupSizeEventually
(final int expectedSize, final BackupAccessor<K, V> accessor)
hazelcast/src/test/java/com/hazelcast/test/backup/TestBackupUtils.java:119
↓ 25 callers
Method
assertEqualsEventually
(List<T> actual, T... expected)
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:294
↓ 25 callers
Method
assertOutput
(int output)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/impl/sink/SlowRecoveryDegraderTest.java:133
↓ 25 callers
Method
assertSizeAndDataEventually
()
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionCorrectnessTestSupport.java:211
↓ 25 callers
Method
attributeMap
Returns an attributeMap of this connection. @return the attribute map.
hazelcast/src/main/java/com/hazelcast/internal/nio/Connection.java:50
↓ 25 callers
Method
checkFalse
Tests whether the supplied expression is {@code false}. @param expression the expression tested to see if it is {@code false}. @param errorMessage
hazelcast/src/main/java/com/hazelcast/internal/util/Preconditions.java:322
↓ 25 callers
Method
checkPermission
checks security permissions
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/ExpressionEvalContext.java:128
↓ 25 callers
Method
checkRowValue
(SqlColumnType expectedType, Object expectedValue, SqlRow row, String columnName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlBasicTest.java:300
↓ 25 callers
Method
comparableMax
@param <I> type of the input object. @param <R> type of the return object (subtype of Comparable) @return an aggregator that calculates the max of the
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:385
↓ 25 callers
Method
comparableMin
@param <I> type of the input object. @param <R> type of the return object (subtype of Comparable) @return an aggregator that calculates the min of the
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:541
↓ 25 callers
Method
completeExceptionally
Completes this Promise with the provided exceptional value. @param value the exceptional value. @throws NullPointerException if value is <code>null<
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Promise.java:84
↓ 25 callers
Method
convertNanosToMillis
Convert nanoseconds to milliseconds If conversion result is 0 and {@code nanos} was > 0, then 1 is returned. @param nanos The number of nanosecond
hazelcast/src/main/java/com/hazelcast/internal/util/TimeUtil.java:47
↓ 25 callers
Method
coordinationService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:300
↓ 25 callers
Method
create
(String className)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionValue.java:73
↓ 25 callers
Method
create
( @Nullable Comparable<?> from, boolean fromInclusive, @Nullable Comparabl
hazelcast/src/main/java/com/hazelcast/internal/iteration/IndexIterationPointer.java:122
↓ 25 callers
Method
createMapStore
()
extensions/mapstore/src/test/java/com/hazelcast/mapstore/GenericMapStoreBasicIT.java:503
↓ 25 callers
Method
createMergingEntry
(SerializationService serializationService, En
hazelcast/src/main/java/com/hazelcast/spi/impl/merge/MergingValueFactory.java:95
↓ 25 callers
Method
createStream
(int shardCount)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisTestHelper.java:113
↓ 25 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator, Function<C
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListCodec.java:61
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CacheManagementConfigCodec.java:101
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ListSetCodec.java:93
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CacheRemoveEntryListenerCodec.java:88
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CachePutCodec.java:114
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CacheAddNearCacheInvalidationListenerCodec.java:97
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapFetchWithQueryCodec.java:106
↓ 25 callers
Method
decodeRequest
Name of the MultiMap
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MultiMapValuesCodec.java:75
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ScheduledExecutorGetDelayFromMemberCodec.java:93
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ListCompareAndRemoveAllCodec.java:87
↓ 25 callers
Method
decodeRequest
Name of the List
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ListIsEmptyCodec.java:75
↓ 25 callers
Method
decodeRequest
The name of CardinalityEstimator
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CardinalityEstimatorEstimateCodec.java:76
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ExecutorServiceCancelOnMemberCodec.java:95
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/QueueRemoveListenerCodec.java:88
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapTryPutCodec.java:109
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapKeySetWithPagingPredicateCodec.java:89
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SetRemoveCodec.java:89
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/TransactionalMultiMapPutCodec.java:107
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddCacheConfigCodec.java:283
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/TransactionalQueuePeekCodec.java:100
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ListAddCodec.java:90
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ScheduledExecutorSubmitToPartitionCodec.java:126
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddListConfigCodec.java:150
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapReplaceIfSameCodec.java:106
↓ 25 callers
Method
decodeRequest
Name of the Set
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SetClearCodec.java:74
↓ 25 callers
Method
decodeRequest
Name of the executor.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DurableExecutorShutdownCodec.java:75
↓ 25 callers
Method
decodeRequest
Name of List
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ListSizeCodec.java:76
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ListCompareAndRetainAllCodec.java:88
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CacheEntryProcessorCodec.java:108
↓ 25 callers
Method
decodeRequest
Name of the Ringbuffer
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/RingbufferHeadSequenceCodec.java:77
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MultiMapValueCountCodec.java:94
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapAddPartitionLostListenerCodec.java:98
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/PNCounterGetCodec.java:101
↓ 25 callers
Method
decodeRequest
Name of the Queue
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/QueueSizeCodec.java:76
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapExecuteOnKeyCodec.java:100
↓ 25 callers
Method
decodeRequest
name of map
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapIsEmptyCodec.java:75
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapExecuteWithPredicateCodec.java:93
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/QueueAddListenerCodec.java:100
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ScheduledExecutorGetStatsFromMemberCodec.java:97
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapAddInterceptorCodec.java:87
↓ 25 callers
Method
decodeRequest
Name of the Queue
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/QueueDrainToCodec.java:78
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapRemoveAllCodec.java:86
↓ 25 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetGetJobIdsCodec.java:95
← previous
next →
2,201–2,300 of 147,315, ranked by callers