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
↓ 163 callers
Method
getVersion
Returns the Hazelcast codebase version of this member; this may or may not be different from the version reported by {@link Cluster#getClusterVersion(
hazelcast/src/main/java/com/hazelcast/cluster/Member.java:115
↓ 162 callers
Method
getBeanDefinition
()
hazelcast-spring/src/main/java/com/hazelcast/spring/HazelcastConfigBeanDefinitionParser.java:313
↓ 162 callers
Method
instance
(HazelcastInstanceImpl hazelcastInstanceImpl)
hazelcast/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java:207
↓ 162 callers
Method
size
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:105
↓ 161 callers
Method
sleep
(int ms, boolean log)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapStoreDataLoadingContinuesWhenNodeJoins.java:394
↓ 160 callers
Method
collect
Return the aggregation result.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/SqlAggregation.java:39
↓ 160 callers
Method
getCache
Returns the cache instance with the specified prefixed cache name. <p> Prefixed cache name is the name with URI and classloader prefixes, if available
hazelcast/src/main/java/com/hazelcast/core/ICacheManager.java:64
↓ 160 callers
Method
getExecutorService
Creates or returns the distributed executor service for the given name. Executor service enables you to run your <code>Runnable</code>s and <code>Call
hazelcast/src/main/java/com/hazelcast/core/HazelcastInstance.java:210
↓ 160 callers
Method
rows
(final int rowLength, final Object... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:734
↓ 159 callers
Method
getTypeFamily
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:177
↓ 158 callers
Method
contains
(C value)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/AbstractSarg.java:21
↓ 158 callers
Method
equals
(Object obj)
hazelcast/src/main/java/com/hazelcast/security/permission/AllPermissions.java:49
↓ 158 callers
Method
set
(GenericRecordBuilder record, Object value)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/inject/AvroUpsertTarget.java:171
↓ 158 callers
Method
setBackupCount
()
hazelcast/src/test/java/com/hazelcast/config/RingbufferConfigTest.java:107
↓ 157 callers
Method
getMapServiceContext
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapService.java:255
↓ 157 callers
Method
getMergePolicyConfig
Gets the {@link MergePolicyConfig} for the data structure. @return the {@link MergePolicyConfig} for the data structure
hazelcast/src/main/java/com/hazelcast/config/SplitBrainPolicyAwareConfig.java:49
↓ 157 callers
Method
times
@return some {@link LocalTimes}s to be used for testing: <ol> <li>Start of day - testing for rolling into previous day if required
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/ArithmeticOperatorIntegrationTest.java:77
↓ 156 callers
Method
toArray
(ClassLoader targetClassLoader, Object arg)
hazelcast/src/test/java/com/hazelcast/test/starter/HazelcastProxyFactory.java:305
↓ 155 callers
Method
createHashMap
Utility method that creates an {@link java.util.HashMap} with its initialCapacity calculated to minimize rehash operations
hazelcast/src/main/java/com/hazelcast/internal/util/MapUtil.java:44
↓ 155 callers
Method
setValue
(V value)
hazelcast/src/main/java/com/hazelcast/map/impl/record/Record.java:40
↓ 155 callers
Method
writeInt
(int position, int v)
hazelcast/src/main/java/com/hazelcast/internal/nio/BufferObjectDataOutput.java:31
↓ 152 callers
Method
client
Returns the client or null, if a client wasn't requested.
hazelcast/src/test/java/com/hazelcast/jet/SimpleTestInClusterSupport.java:308
↓ 152 callers
Method
getBoolean
Reads the boolean value from given address. @param address the address where the boolean value will be read from @return the value that is read
hazelcast/src/main/java/com/hazelcast/internal/memory/MemoryAccessor.java:40
↓ 152 callers
Method
getCause
()
hazelcast/src/test/java/com/hazelcast/jet/impl/util/ExceptionUtilTest.java:123
↓ 152 callers
Method
getInteger
Returns the configured int value of a {@link HazelcastProperty}. @param property the {@link HazelcastProperty} to get the value from @return the valu
hazelcast/src/main/java/com/hazelcast/spi/properties/HazelcastProperties.java:197
↓ 152 callers
Method
getPartitionId
Returns the partition id this RecordStore belongs to. @return the partition id.
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:469
↓ 152 callers
Method
getString
@param fieldName the name of the field @return the value of the field @throws HazelcastSerializationException if the field name does not exist
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecord.java:256
↓ 152 callers
Method
tuple2
Returns a new 2-tuple with the supplied values.
hazelcast/src/main/java/com/hazelcast/jet/datamodel/Tuple2.java:55
↓ 152 callers
Method
valueOf
(int ordinal)
hazelcast/src/main/java/com/hazelcast/instance/ProtocolType.java:69
↓ 151 callers
Method
getContext
Returns the ServerContext.
hazelcast/src/main/java/com/hazelcast/internal/server/Server.java:39
↓ 151 callers
Method
remove
Removes the mapping for a key from this map if it is present. <p> If you don't need the previously mapped value for the removed key, prefer to use {@l
hazelcast/src/main/java/com/hazelcast/map/IMap.java:404
↓ 151 callers
Method
valueOf
(String name)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:418
↓ 150 callers
Method
iterator
Get iterator over results. Subsequent calls must return the same instance. @return Iterator.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/QueryResultProducer.java:31
↓ 150 callers
Method
operand
(int index)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/SlidingWindow.java:108
↓ 150 callers
Method
scenario
(Portable input, Object result, String path, String parent)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderSpecTest.java:892
↓ 149 callers
Method
getConnectionStrategyConfig
()
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:814
↓ 149 callers
Method
newUnsecureUUID
Static factory to retrieve a type 4 (pseudo randomly generated) UUID. <p> The {@code UUID} is generated using a cryptographically weak pseudo random n
hazelcast/src/main/java/com/hazelcast/internal/util/UuidUtil.java:70
↓ 149 callers
Method
pointer
(com.google.common.collect.Range<C> r, boolean descending)
hazelcast/src/test/java/com/hazelcast/internal/iteration/IndexIterationPointerTest.java:53
↓ 148 callers
Method
of
(Object... objects)
hazelcast/src/test/java/com/hazelcast/query/impl/extractor/AbstractExtractionSpecification.java:63
↓ 147 callers
Method
check
(String literal, String expected, String message)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/expression/datetime/FormatterTest.java:388
↓ 147 callers
Method
compare
(T o1, T o2)
hazelcast/src/main/java/com/hazelcast/function/ComparatorEx.java:50
↓ 147 callers
Method
createMapping
(String tableName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:225
↓ 147 callers
Method
decodeNullable
(ClientMessage.ForwardFrameIterator iterator, Function<ClientMessage.ForwardFrameIterator, T> decode)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CodecUtil.java:57
↓ 147 callers
Method
decodeNullable
@apiNote This method is not equivalent to {@link CodecUtil#decodeNullable(ClientMessage.ForwardFrameIterator, Function)}. With {@link Data} this metho
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/DataCodec.java:77
↓ 147 callers
Method
encodeNullable
(ClientMessage clientMessage, T value, BiConsumer<ClientMessage, T> encode)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CodecUtil.java:47
↓ 147 callers
Method
encodeNullable
@apiNote This method is not equivalent to {@link CodecUtil#encodeNullable(ClientMessage, Object, BiConsumer)}. With {@link Data} this method should be
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/DataCodec.java:57
↓ 146 callers
Method
createBeanBuilder
(Class<?> clazz)
hazelcast-spring/src/main/java/com/hazelcast/spring/AbstractHazelcastBeanDefinitionParser.java:131
↓ 146 callers
Method
isNull
()
hazelcast/src/main/java/com/hazelcast/query/PredicateBuilder.java:53
↓ 146 callers
Method
lock
Acquires the lock for the specified key. <p> If the lock is not available, then the current thread becomes disabled for thread scheduling purposes and
hazelcast/src/main/java/com/hazelcast/map/IMap.java:1964
↓ 146 callers
Method
sendResponse
(TextCommand textCommand)
hazelcast/src/main/java/com/hazelcast/internal/ascii/TextCommandService.java:37
↓ 146 callers
Method
shutdownAll
Shuts down all running {@link HazelcastOSGiInstance}s on the owner bundle.
hazelcast/src/main/java/com/hazelcast/osgi/HazelcastOSGiService.java:113
↓ 146 callers
Method
toData
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:114
↓ 144 callers
Method
assertTrueAllTheTime
(AssertTask task, long durationSeconds)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1183
↓ 144 callers
Method
getExecutionService
()
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:70
↓ 144 callers
Method
getNetworkConfig
Gets {@link com.hazelcast.client.config.ClientNetworkConfig} @return {@link com.hazelcast.client.config.ClientNetworkConfig} @see com.hazelcast.clien
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:341
↓ 144 callers
Method
getUserCodeNamespace
Retrieve the User Code Deployment Namespace to be used for {@link ClassLoader} awareness during operations related to the structure associated with th
hazelcast/src/main/java/com/hazelcast/config/UserCodeNamespaceAwareConfig.java:53
↓ 144 callers
Method
isEnabled
Returns if the CP state persistence is enabled or not.
hazelcast/src/main/java/com/hazelcast/cp/internal/persistence/CPPersistenceService.java:35
↓ 144 callers
Method
scenario
(Object input, Object result, String path, String parent)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/reader/CompactStreamSerializerValueReaderSpecTest.java:874
↓ 143 callers
Method
addMapConfig
(Config config)
hazelcast/src/test/java/com/hazelcast/map/impl/StoreLatencyPlugin_MapIntegrationTest.java:80
↓ 142 callers
Method
addMapConfig
Adds the map configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtained in
hazelcast/src/main/java/com/hazelcast/config/Config.java:813
↓ 142 callers
Method
getThisAddress
Get the address of this member. <p> The returned value will never change and will never be {@code null}. @return the address of this member
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:138
↓ 142 callers
Method
newInstances
()
hazelcast/src/test/java/com/hazelcast/test/TestHazelcastInstanceFactory.java:295
↓ 142 callers
Method
withTag
Adds the given tag to the descriptor with the given value. @param tag The tag to add @param value The value of the tag @return the descriptor insta
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:123
↓ 141 callers
Method
getIndex
@return field index
hazelcast/src/main/java/com/hazelcast/nio/serialization/FieldDefinition.java:37
↓ 140 callers
Method
eq
(Object operand)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionPredicates.java:29
↓ 140 callers
Method
groupingKey
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:64
↓ 140 callers
Method
localParallelism
Returns the number of processors that each {@code ProcessorSupplier} will be asked to create once deserialized on each member. All members have equal
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorMetaSupplier.java:861
↓ 139 callers
Method
field
(String name, QueryDataType type)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/OptimizerTestSupport.java:202
↓ 139 callers
Method
get
(int index, boolean useLazyDeserialization)
hazelcast/src/main/java/com/hazelcast/sql/impl/row/Row.java:30
↓ 139 callers
Method
map
Adds a "map using Python" pipeline stage. See {@link com.hazelcast.jet.python.PythonServiceConfig} for more details.
extensions/python/src/main/java/com/hazelcast/jet/python/PythonExtension.java:59
↓ 139 callers
Method
setMapStoreConfig
Sets the map store configuration @param mapStoreConfig the mapStoreConfig (map store configuration) to set
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:389
↓ 138 callers
Method
getConfig
Returns the configuration of this Hazelcast instance. @return configuration of this Hazelcast instance
hazelcast/src/main/java/com/hazelcast/core/HazelcastInstance.java:319
↓ 138 callers
Method
timestamp
Returns the timestamp when this progress snapshot was taken @return the timestamp of the progress snapshot
hazelcast/src/test/java/com/hazelcast/test/TaskProgress.java:48
↓ 137 callers
Method
assertEqualsEventually
(final FutureTask<E> task, final E expected)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:1021
↓ 137 callers
Method
setImplementation
()
hazelcast/src/test/java/com/hazelcast/config/MapStoreConfigTest.java:135
↓ 137 callers
Method
tailSequence
Returns the sequence of the tail. The tail is the side of the ringbuffer where the items are added to. The initial value of the tail is {@code -1}. @
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/Ringbuffer.java:51
↓ 136 callers
Method
get
(Metric metric)
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/PhoneHomeTest.java:159
↓ 136 callers
Method
whenCompleteAsync
(BiConsumer<? super V, ? super Throwable> action)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientDelegatingFuture.java:329
↓ 135 callers
Method
asObject
Returns this JSON value as {@link JsonObject}, assuming that this value represents a JSON object. If this is not the case, an exception is thrown. @r
hazelcast/src/main/java/com/hazelcast/internal/json/JsonValue.java:151
↓ 135 callers
Method
getAdvancedNetworkConfig
()
hazelcast/src/main/java/com/hazelcast/config/Config.java:2976
↓ 135 callers
Method
getKey
()
hazelcast/src/main/java/com/hazelcast/internal/locksupport/LockResource.java:28
↓ 135 callers
Method
json
Returns a file format for JSON Lines files.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/file/FileFormat.java:105
↓ 135 callers
Method
putAll
(Map<K, V> map)
hazelcast/src/test/java/com/hazelcast/journal/EventJournalDataStructureAdapter.java:35
↓ 134 callers
Method
flatMap
Returns a traverser that will apply the given mapping function to each item retrieved from this traverser and emit all the items from the resulting tr
hazelcast/src/main/java/com/hazelcast/jet/Traverser.java:102
↓ 134 callers
Method
getMulticastConfig
@return the multicastConfig join configuration
hazelcast/src/main/java/com/hazelcast/config/JoinConfig.java:52
↓ 133 callers
Method
getHost
()
hazelcast/src/main/java/com/hazelcast/cluster/Address.java:97
↓ 133 callers
Method
getSerializationConfig
Returns the serialization configuration for this hazelcast instance. The serialization configuration defines how objects are serialized and deserializ
hazelcast/src/main/java/com/hazelcast/config/Config.java:2608
↓ 133 callers
Method
has
(String taskName)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainer.java:147
↓ 133 callers
Method
min
Returns the lower of the given guarantees.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:615
↓ 133 callers
Method
vertex
Adds a vertex to this DAG. The vertex name must be unique.
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:194
↓ 132 callers
Method
checkTrue
Tests whether the supplied expression is {@code true}. @param expression the expression tested to see if it is {@code true}. @param errorMessage th
hazelcast/src/main/java/com/hazelcast/internal/util/Preconditions.java:335
↓ 132 callers
Method
getQueryCache
Returns corresponding {@code QueryCache} instance for the supplied {@code name} or null. <p> If there is a previously created {@link QueryCache} with
hazelcast/src/main/java/com/hazelcast/map/IMap.java:3126
↓ 132 callers
Method
peek
Retrieves, but does not remove, the head of this inbox, or returns {@code null} if it is empty.
hazelcast/src/main/java/com/hazelcast/jet/core/Inbox.java:44
↓ 132 callers
Method
sort
Attaches a stage that sorts the input items according to their natural order. <p> Sample usage: <pre>{@code items.sort() }</pre> <p> This operation is
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:89
↓ 132 callers
Method
stub
(String url, KubernetesResource response)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesClientTest.java:979
↓ 132 callers
Method
verifyProcessor
@param supplier a processor supplier create processor instances
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:250
↓ 132 callers
Method
wrap
Wraps given {@link Runnable} into {@link ThrowingRunnable}. @since 5.6
hazelcast/src/main/java/com/hazelcast/function/ThrowingRunnable.java:46
↓ 131 callers
Method
assertContains
(String expected)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/AbstractDiagnosticsPluginTest.java:52
↓ 131 callers
Method
assertThrowsNPE
(ConsumerEx<IMap<Object, Object>> method)
hazelcast/src/test/java/com/hazelcast/map/AbstractMapNullTest.java:232
↓ 131 callers
Method
rootCause
(Class<? extends Throwable> expectedType, String expectedMessage)
hazelcast/src/test/java/com/hazelcast/internal/util/RootCauseMatcher.java:53
← previous
next →
401–500 of 147,315, ranked by callers