Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Index your code
hub
/
github.com/hazelcast/hazelcast
/ functions
Functions
147,315 in github.com/hazelcast/hazelcast
⨍
Functions
147,315
◇
Types & classes
15,944
↓ 225 callers
Method
valueFrom
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionType.java:37
↓ 223 callers
Method
readInt
(int position)
hazelcast/src/main/java/com/hazelcast/internal/nio/BufferObjectDataInput.java:31
↓ 222 callers
Method
cancel
Makes a request to cancel this job and returns. The job will complete after its execution has stopped on all the nodes, which can happen some time aft
hazelcast/src/main/java/com/hazelcast/jet/Job.java:128
↓ 222 callers
Method
waitAllForSafeState
(Collection<HazelcastInstance> instances)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:765
↓ 220 callers
Method
invokeOnPartition
Invokes an {@link Operation} on the specified {@code partitionId}, on behalf of the service defined by the provided {@code serviceName}, expecting a r
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationService.java:134
↓ 219 callers
Method
toData
Serializes an object to a {@link Data}. <p> This method can safely be called with a {@link Data} instance. In that case, that instance is returned. <p
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationService.java:39
↓ 218 callers
Method
getList
@since Jet 3.0 @deprecated Use {@link HazelcastInstance#getList(String)} instead.
hazelcast/src/main/java/com/hazelcast/jet/JetInstance.java:110
↓ 218 callers
Method
submit
Submits a task to a randomly selected member and returns a Future representing that task. @param task task submitted to a randomly selected
hazelcast/src/main/java/com/hazelcast/core/IExecutorService.java:108
↓ 216 callers
Method
hz
()
hazelcast/src/test/java/com/hazelcast/jet/TestInClusterSupport.java:126
↓ 215 callers
Method
create
Create the target that will be used for extraction. @param serializationService Serialization service. @param extractors Extractors associated with t
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/extract/QueryTargetDescriptor.java:40
↓ 215 callers
Method
identity
{@code Serializable} variant of {@link Function#identity() java.util.function.Function#identity()}. @param <T> the type of the input and output object
hazelcast/src/main/java/com/hazelcast/function/FunctionEx.java:58
↓ 214 callers
Method
putIfAbsent
{@inheritDoc} <p> <b>Note:</b> <p> This method uses {@code hashCode} and {@code equals} of the binary form of the {@code key}, not the actual implemen
hazelcast/src/main/java/com/hazelcast/map/IMap.java:1515
↓ 212 callers
Method
checkFields
(Object field1, Object field2, SqlColumnType expectedType, Object expectedResult)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/ArithmeticOperatorIntegrationTest.java:164
↓ 211 callers
Method
writeData
(ObjectDataOutput out, Data data)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:261
↓ 210 callers
Method
assertContains
alternative implementation of {@link org.assertj.core.api.AbstractIterableAssert#contains(Object...)} that does not rely on an implementation of {@lin
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:852
↓ 210 callers
Method
between
(Comparable from, Comparable to)
hazelcast/src/main/java/com/hazelcast/query/PredicateBuilder.java:65
↓ 210 callers
Method
compareAndSet
Atomically sets {@code key} to {@code newValue} if the current value for {@code key} is equal-to {@code expectedValue}. @param key non-null key of the
hazelcast/src/main/java/com/hazelcast/cp/CPMap.java:92
↓ 210 callers
Method
hash
(Object value, int mask)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Hashing.java:42
↓ 207 callers
Method
isFineEnabled
Checks if the {@link Level#FINE} level is enabled. @return true if enabled, false otherwise
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/logging/TpcLogger.java:82
↓ 207 callers
Method
readData
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:266
↓ 207 callers
Method
sequence
(Map<String, ?> debeziumOffset)
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/impl/SequenceExtractor.java:41
↓ 207 callers
Method
verify
(Set<Map.Entry<Long, Person>> actual)
hazelcast/src/test/java/com/hazelcast/client/map/impl/query/ClientBitmapIndexTest.java:344
↓ 206 callers
Method
getTextContent
(Node node)
hazelcast-spring/src/main/java/com/hazelcast/spring/AbstractHazelcastBeanDefinitionParser.java:123
↓ 204 callers
Method
decode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/DataCodec.java:65
↓ 204 callers
Method
encode
(ClientMessage clientMessage, Data data)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/DataCodec.java:46
↓ 201 callers
Method
checkEquals
(Object first, Object second, boolean expected)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:463
↓ 201 callers
Method
severe
Logs a message at {@link Level#SEVERE}. @param message the message to log.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/logging/TpcLogger.java:149
↓ 200 callers
Method
getName
This method may return null depending on the client version and the client type Java client provides client name starting with 3.12 @return the name
hazelcast/src/main/java/com/hazelcast/client/Client.java:65
↓ 199 callers
Method
setInMemoryFormat
()
hazelcast/src/test/java/com/hazelcast/config/RingbufferConfigTest.java:204
↓ 198 callers
Method
equal
Creates an <b>equal</b> predicate that will pass items if the given {@code value} and the value stored under the given item {@code attribute} are equa
hazelcast/src/main/java/com/hazelcast/query/Predicates.java:302
↓ 198 callers
Method
jetRow
(Object... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:783
↓ 197 callers
Method
accept
(T t)
hazelcast/src/test/java/com/hazelcast/cluster/AbstractClusterNullTest.java:66
↓ 197 callers
Method
and
{@code Serializable} variant of {@link Predicate#and(Predicate) java.util.function.Predicate#and(Predicate)}.
hazelcast/src/main/java/com/hazelcast/function/PredicateEx.java:86
↓ 197 callers
Method
intValue
(Integer value)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/index/IndexFilterTestSupport.java:45
↓ 196 callers
Method
getMapConfig
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:104
↓ 194 callers
Method
apply
Transforms {@code this} stage using the provided {@code transformFn} and returns the transformed stage. It allows you to extract common pipeline trans
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:620
↓ 194 callers
Method
setContainsSerializedDataInRequest
(boolean containsSerializedDataInRequest)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientMessage.java:337
↓ 194 callers
Method
withExpectedDynamicParameterFailureRegex
This test case is expected to fail if the source is a dynamic parameter (the {@link #test_insertDynamicParameters()} method).
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/validate/RowAssignmentTypeCoercionTest.java:1206
↓ 193 callers
Method
terminate
Terminate HazelcastInstance ungracefully. Does not wait for partition operations, forces immediate shutdown. Use {@link #shutdown()} for graceful shut
hazelcast/src/main/java/com/hazelcast/core/LifecycleService.java:45
↓ 192 callers
Method
getAttribute
Returns the value of the specified key for this member or null if value is undefined. @param key The key to lookup. @return The value for this member
hazelcast/src/main/java/com/hazelcast/cluster/Member.java:104
↓ 192 callers
Method
size
Returns the current number of endpoints. @return the current number of endpoints.
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEndpointManager.java:61
↓ 192 callers
Method
size
Returns the number of objects in the inbox.
hazelcast/src/main/java/com/hazelcast/jet/core/Inbox.java:144
↓ 192 callers
Method
spawn
Note: the {@code cancel()} method on the returned Future has no effect.
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:347
↓ 191 callers
Method
assertInstanceOf
(Class<E> expected, Object actual)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:921
↓ 191 callers
Method
sleepSeconds
(int seconds)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:412
↓ 190 callers
Method
getLocalMapStats
Returns LocalMapStats for this map. <p> LocalMapStats are the statistics for the local portion of this distributed map and contains information such a
hazelcast/src/main/java/com/hazelcast/map/IMap.java:2741
↓ 190 callers
Method
newTransactionContext
Creates a new TransactionContext associated with the current thread using default options. @return new TransactionContext associated with the current
hazelcast/src/main/java/com/hazelcast/core/HazelcastInstance.java:255
↓ 189 callers
Method
buildConfig
(String yaml)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:2029
↓ 188 callers
Method
setPartitionId
@param partitionId the partition ID of this record
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCacheRecord.java:102
↓ 185 callers
Method
assertClusterSize
(int expectedSize, HazelcastInstance... instances)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1036
↓ 183 callers
Method
getObject
Gets the value of the column by index. <p> The class of the returned value depends on the SQL type of the column. No implicit conversions are performe
hazelcast/src/main/java/com/hazelcast/sql/SqlRow.java:39
↓ 182 callers
Method
invoke
(NodeEngine nodeEngine)
hazelcast/src/test/java/com/hazelcast/instance/impl/NodeStateTest.java:198
↓ 182 callers
Method
type
@return the type of the resource.
hazelcast/src/main/java/com/hazelcast/internal/namespace/ResourceDefinition.java:34
↓ 181 callers
Method
getSerializationService
()
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:80
↓ 178 callers
Method
add
Adds an item to the buffer. <p> Since this class isn't thread-safe, you can call this method only on the thread on which you received its instance fro
hazelcast/src/main/java/com/hazelcast/jet/pipeline/SourceBuilder.java:94
↓ 178 callers
Method
buildConfig
(String xml)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:1827
↓ 178 callers
Method
createCache
()
hazelcast/src/test/java/com/hazelcast/cache/CacheTestSupport.java:81
↓ 178 callers
Method
decodeUUID
(byte[] buffer, int pos)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/FixedSizeTypesCodec.java:195
↓ 178 callers
Method
encodeUUID
(byte[] buffer, int pos, UUID value)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/FixedSizeTypesCodec.java:183
↓ 177 callers
Method
newHazelcastClient
(ClientConfig config, AddressProvider addressProvider)
hazelcast/src/test/java/com/hazelcast/client/HazelcastClientUtil.java:27
↓ 176 callers
Method
convert
Compares a {@link java.lang.Comparable}-typed value to another. Since TypeConverters are not statically typed themselves, the developer needs to take
hazelcast/src/main/java/com/hazelcast/core/TypeConverter.java:39
↓ 176 callers
Method
getAddress
()
hazelcast/src/main/java/com/hazelcast/internal/monitor/MemberState.java:31
↓ 176 callers
Method
getMembers
Set of the current members in the cluster. The returned set is an immutable set; it can't be modified. <p> The returned set is backed by an ordered se
hazelcast/src/main/java/com/hazelcast/cluster/Cluster.java:83
↓ 176 callers
Method
items
Returns a batch source which iterates through the supplied iterable and then terminates. The source is non-distributed. @since Jet 3.2
hazelcast/src/main/java/com/hazelcast/jet/pipeline/test/TestSources.java:54
↓ 175 callers
Method
castError
(SqlColumnType type1, SqlColumnType type2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/misc/CastFunctionIntegrationTest.java:1223
↓ 175 callers
Method
close
Close is equivalent to below operations in the given order: <ul> <li>close resources.</li> <li>unregister all listeners.</li> </ul> @param onShutdown
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheRecordStore.java:367
↓ 175 callers
Method
get
(K key)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:63
↓ 175 callers
Method
getValue
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/exec/scan/KeyValueIterator.java:43
↓ 174 callers
Method
getBooleanValue
(final String value)
hazelcast/src/main/java/com/hazelcast/internal/config/DomConfigHelper.java:146
↓ 174 callers
Method
given
()
hazelcast/src/test/java/com/hazelcast/spi/impl/executionservice/impl/BasicCompletableFutureTest.java:56
↓ 173 callers
Method
getProperty
Returns the value for a named property. If it has not been previously set, it will try to get the value from the system properties. @param name prope
hazelcast/src/main/java/com/hazelcast/config/Config.java:580
↓ 173 callers
Method
sleepMillis
(int millis)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:404
↓ 172 callers
Method
apply
(T input)
hazelcast/src/main/java/com/hazelcast/core/IFunction.java:41
↓ 172 callers
Method
failingCase
(int testId, QueryDataTypeFamily srcType, QueryDataTypeFamily targetType,
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/validate/RowAssignmentTypeCoercionTest.java:1179
↓ 172 callers
Method
getAttributes
Returns configured attributes for this member.<br> <b>This method might not be available on all native clients.</b> @return configured attributes for
hazelcast/src/main/java/com/hazelcast/cluster/Member.java:95
↓ 172 callers
Method
getValue
()
hazelcast/src/main/java/com/hazelcast/map/impl/record/Record.java:38
↓ 171 callers
Method
accept
(T t, U u)
hazelcast/src/main/java/com/hazelcast/function/BiConsumerEx.java:44
↓ 171 callers
Method
builder
@return builder of {@link SearchOptions}
hazelcast/src/main/java/com/hazelcast/vector/SearchOptions.java:63
↓ 171 callers
Method
longValue
(String name, long value)
hazelcast/src/test/java/com/hazelcast/internal/metrics/jmx/JmxPublisherTest.java:319
↓ 170 callers
Method
getKey
()
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/entry/DelayedEntry.java:36
↓ 170 callers
Method
getMessage
()
hazelcast/src/test/java/com/hazelcast/internal/util/executor/LoggingScheduledExecutorTest.java:256
↓ 170 callers
Method
withExpectedColumnFailureRegex
This test case is expected to fail if the source is a column (the {@link #test_insertSelect()} method).
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/validate/RowAssignmentTypeCoercionTest.java:1197
↓ 169 callers
Method
assertRowsEventuallyInAnyOrder
(String sql, Collection<Row> expectedRows)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:166
↓ 169 callers
Method
checkFieldsCommute
(Object field1, Object field2, SqlColumnType expectedType, Object expectedResult)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/ArithmeticOperatorIntegrationTest.java:170
↓ 169 callers
Method
getTcpIpConfig
@return the tcpIpConfig
hazelcast/src/main/java/com/hazelcast/config/JoinConfig.java:68
↓ 169 callers
Method
max
(Comparable<?> left, boolean leftInclusive, Comparable<?
hazelcast/src/main/java/com/hazelcast/internal/iteration/IndexIterationPointer.java:317
↓ 169 callers
Method
toObject
Deserializes an object. <p> This method can safely be called on an object that is already deserialized. In that case, that instance is returned. <p> I
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationService.java:92
↓ 168 callers
Method
computeIfAbsent
{@inheritDoc} <p> </p> <p> If the supplied {@code mappingFunction} is a lambda, anonymous class or an inner class, it would be executed local
hazelcast/src/main/java/com/hazelcast/map/IMap.java:3264
↓ 168 callers
Method
log
Logs a LogEvent. @param logEvent the logEvent to log @deprecated the method is unused
hazelcast/src/main/java/com/hazelcast/logging/ILogger.java:34
↓ 168 callers
Method
of
(Predicate predicate, Multivalue mv)
hazelcast/src/test/java/com/hazelcast/query/impl/extractor/AbstractExtractionSpecification.java:77
↓ 168 callers
Method
withExpectedLiteralFailureRegex
This test case is expected to fail if the source is a literal (the {@link #test_insertValues()} method).
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/validate/RowAssignmentTypeCoercionTest.java:1188
↓ 167 callers
Method
object
Creates a new empty JsonObject. This is equivalent to creating a new JsonObject using the constructor. @return a new empty JSON object
hazelcast/src/main/java/com/hazelcast/internal/json/Json.java:275
↓ 165 callers
Method
destroy
Closes the cache. Clears the internal content and releases any resource. @see javax.cache.CacheManager#destroyCache(String)
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:909
↓ 165 callers
Method
getSerializationService
()
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheRecordStore.java:563
↓ 165 callers
Method
register
Registers the SocketChannel and returns the created Channel. <p> The Channel is not yet started so that modifications can be made to the channel e.g.
hazelcast/src/main/java/com/hazelcast/internal/networking/Networking.java:55
↓ 164 callers
Method
generateKeyOwnedBy
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:573
↓ 164 callers
Method
getValue
Gets the value of this {@link Evictable}. @return the value of this {@link Evictable}
hazelcast/src/main/java/com/hazelcast/internal/eviction/Evictable.java:29
↓ 163 callers
Method
array
Creates a new empty JsonArray. This is equivalent to creating a new JsonArray using the constructor. @return a new empty JSON array
hazelcast/src/main/java/com/hazelcast/internal/json/Json.java:152
↓ 163 callers
Method
assertThrows
(Class<? extends Exception> expectedExceptionClass, ConsumerEx<HazelcastInstance
hazelcast/src/test/java/com/hazelcast/instance/AbstractHazelcastInstanceNullTest.java:63
↓ 163 callers
Method
getReplicatedMap
Creates or returns the replicated map instance with the specified name. @param name name of the distributed map @param <K> the type of keys maintaine
hazelcast/src/main/java/com/hazelcast/core/HazelcastInstance.java:142
← previous
next →
301–400 of 147,315, ranked by callers