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
↓ 25 callers
Method
expandPrimitiveArrayScenario
Expands test cases for primitive array data types. Word "primitiveArray" is replaced by each primitive array type and the scenario is expanded to for
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderSpecTest.java:236
↓ 25 callers
Method
get
(String attribute)
hazelcast/src/main/java/com/hazelcast/query/PredicateBuilder.java:41
↓ 25 callers
Method
getClientConfig
()
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/HazelcastClientProxy.java:282
↓ 25 callers
Method
getClusterName
Returns the configured cluster name. The name is sent as part of client authentication message and may be verified on the member. @return the configu
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:805
↓ 25 callers
Method
getExpiryMetadata
(Data key)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpirySystem.java:69
↓ 25 callers
Method
getField
(String fieldName)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/Schema.java:165
↓ 25 callers
Method
getFirstResourceConfig
()
hazelcast/src/test/java/com/hazelcast/jet/config/ResourceConfigTest.java:142
↓ 25 callers
Method
getForUpdate
Locks the key and then gets and returns the value to which the specified key is mapped. The lock will be released at the end of the transaction (eithe
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:99
↓ 25 callers
Method
getIndexes
Returns all the indexes known to this indexes instance.
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:444
↓ 25 callers
Method
getLastCallId
Returns the last issued call ID. <strong>ONLY FOR TESTING. Must not be used for production code.</strong>
hazelcast/src/main/java/com/hazelcast/spi/impl/sequence/CallIdSequence.java:77
↓ 25 callers
Method
getLocalPort
Gets the local port of the {@link AsyncServerSocket}. <p/> If {@link #bind(SocketAddress)} has not been called, then -1 is returned. @return the loca
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncServerSocket.java:88
↓ 25 callers
Method
getLongAttribute
(String name)
hazelcast/src/test/java/com/hazelcast/internal/jmx/ReplicatedMapMBeanTest.java:185
↓ 25 callers
Method
getMinor
()
hazelcast/src/main/java/com/hazelcast/version/Version.java:75
↓ 25 callers
Method
getName
Gets the name of this {@link NearCache} instance. @return the name of this {@link NearCache} instance
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCache.java:117
↓ 25 callers
Method
getNextSequenceToReadFrom
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/ReadResultSetImpl.java:213
↓ 25 callers
Method
getQueryCacheConfigs
Returns all {@link QueryCacheConfig} instances defined on this {@code MapConfig}. @return all {@link QueryCacheConfig} instances defined on this {@co
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:647
↓ 25 callers
Method
getReadOnlyConfig
()
hazelcast/src/test/java/com/hazelcast/config/MapConfigReadOnlyTest.java:37
↓ 25 callers
Method
getService
(TestBundleContext bundleContext)
hazelcast/src/test/java/com/hazelcast/osgi/HazelcastOSGiServiceTest.java:114
↓ 25 callers
Method
getTarget
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlOrderByTest.java:199
↓ 25 callers
Method
getTtl
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpiryMetadata.java:33
↓ 25 callers
Method
group
(PrimitivePortable.Init init)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderTestStructure.java:596
↓ 25 callers
Method
handleAsync
(BiFunction<? super V, Throwable, ? extends U> fn)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientDelegatingFuture.java:344
↓ 25 callers
Method
invalidateNearCache
(Object key)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/nearcache/NearCachedClientCacheProxy.java:704
↓ 25 callers
Method
invokeOnAllPartitions
(Object request, boolean urgent)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/InvokerWrapper.java:31
↓ 25 callers
Method
isAlive
Check if ClientConnectionManager is alive. ClientConnectionManager is not alive only when client is closing. @return true if alive, false otherwise.
hazelcast/src/main/java/com/hazelcast/client/impl/connection/ClientConnectionManager.java:40
↓ 25 callers
Method
isFsync
Returns whether disk write should be followed by an {@code fsync()} system call. @return true if fsync is be called after disk write, false otherwise
hazelcast/src/main/java/com/hazelcast/config/HotRestartConfig.java:77
↓ 25 callers
Method
isOrHasCause
Checks, if {@code t} itself or any exception in its cause chain is an instance of {@code classToFind}.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ExceptionUtil.java:199
↓ 25 callers
Method
isRepublishingEnabled
Returns {@code true} if incoming WAN events to this member should be republished (forwarded) to this WAN replication reference. The default state for
hazelcast/src/main/java/com/hazelcast/config/WanReplicationRef.java:158
↓ 25 callers
Method
isTrue
Detects whether this value represents the JSON literal <code>true</code>. @return <code>true</code> if this value represents the JSON literal <code>t
hazelcast/src/main/java/com/hazelcast/internal/json/JsonValue.java:121
↓ 25 callers
Method
isValid
@return {@code true} if supplied record store is valid to apply forced eviction, otherwise return {@code false}
hazelcast/src/main/java/com/hazelcast/map/impl/operation/ForcedEviction.java:104
↓ 25 callers
Method
isWanReplicationEnabled
Returns {@code true} if WAN replication is enabled for the cache named {@code cacheNameWithPrefix}. @param cacheNameWithPrefix the full name of the {
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:142
↓ 25 callers
Method
item
(int index)
hazelcast/src/main/java/com/hazelcast/internal/config/yaml/EmptyNodeList.java:33
↓ 25 callers
Method
itemsByTag
Accepts an argument list of alternating tags and values, interprets them as a list of tag-value pairs, and returns an {@code ItemsByTag} populated wit
hazelcast/src/main/java/com/hazelcast/jet/datamodel/ItemsByTag.java:49
↓ 25 callers
Method
iterator
Returns an iterator over the items in the inbox in the order they would be returned by the {@link #poll()} method. <p> The returned iterator doesn't s
hazelcast/src/main/java/com/hazelcast/jet/core/Inbox.java:69
↓ 25 callers
Method
kafkaMapping
(String name)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlAvroTest.java:146
↓ 25 callers
Method
load
Loads a YAML document from an {@link InputStream} and builds a {@link YamlNode} tree that is under the provided top-level {@code rootName} key. This l
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlLoader.java:50
↓ 25 callers
Method
newCompletableFuture
(long completeAfterMillis)
hazelcast/src/test/java/com/hazelcast/spi/impl/DelegatingCompletableFuture_SerializationExceptionTest.java:260
↓ 25 callers
Method
newDoubleGauge
Creates a {@link DoubleGauge} for a given metric name. @param name name of the metric @return the create DoubleGauge @throws NullPointerException if
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricsRegistry.java:108
↓ 25 callers
Method
newHazelcastClient
()
hazelcast/src/test/java/com/hazelcast/client/executor/ExecutorServiceLiteMemberTest.java:79
↓ 25 callers
Method
produce
(String topic, Object key, Object value)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:180
↓ 25 callers
Method
putAllAsync
Asynchronously copies all of the mappings from the specified map to this map. This version doesn't support batching. <pre>{@code CompletionStage<V
hazelcast/src/main/java/com/hazelcast/map/IMap.java:920
↓ 25 callers
Method
putEntry
Inserts a new entry into this indexes instance or updates an existing one. <p> Consider using {@link #putEntry(CachedQueryEntry, CachedQueryEntry, Que
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:324
↓ 25 callers
Method
range
Returns list of integers from begin (inclusive) to end (exclusive).
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:498
↓ 25 callers
Method
resolve
(ProtocolType protocolType, String identifier)
hazelcast/src/main/java/com/hazelcast/instance/EndpointQualifier.java:149
↓ 25 callers
Method
resolveMetadata
( boolean isKey, List<MappingField> resolvedFields, Map<String, String> op
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataResolver.java:54
↓ 25 callers
Method
reuseOrCreate
(RelMetadataQuery mq)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/metadata/HazelcastRelMetadataQuery.java:42
↓ 25 callers
Method
runWithNamespace
Obtains a {@link NodeEngine} reference from {@link NodeEngineThreadLocalContext} and uses it to call {@link UserCodeNamespaceService#runWithNamespace(
hazelcast/src/main/java/com/hazelcast/internal/namespace/NamespaceUtil.java:95
↓ 25 callers
Method
setBackupCount
Sets the number of synchronous backups. For example, if 1 is set as the backup count, then all entries of the map will be copied to another JVM for fa
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:320
↓ 25 callers
Method
setEnabled
@param enabled Enable or disable User Code Deployment. Default: {{@code false}} @return this for chaining
hazelcast/src/main/java/com/hazelcast/client/config/ClientUserCodeDeploymentConfig.java:65
↓ 25 callers
Method
setEnabled
Sets if Jet is enabled
hazelcast/src/main/java/com/hazelcast/jet/config/JetConfig.java:287
↓ 25 callers
Method
setInt64
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:241
↓ 25 callers
Method
setName
Sets the name of the {@link IMap} @param name the name to set for this {@link IMap}
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:210
↓ 25 callers
Method
setPortAutoIncrement
Sets if a Hazelcast member is allowed to find a free port by incrementing the port number when it encounters an occupied port. <p> If you explicitly w
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:170
↓ 25 callers
Method
setPosition
(@Nonnull String fieldName, @Nonnull FieldType fieldType)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/DefaultPortableWriter.java:390
↓ 25 callers
Method
setProperty
Sets a single property. See {@link DataConnectionConfig#setProperties(Properties)} @param key the property key @param value the property value @ret
hazelcast/src/main/java/com/hazelcast/config/DataConnectionConfig.java:170
↓ 25 callers
Method
setResponse
(byte[] value)
hazelcast/src/main/java/com/hazelcast/internal/ascii/memcache/SetCommand.java:61
↓ 25 callers
Method
size
Returns the number of elements in this {@link WriteBehindQueue}. @return the number of elements in this {@link WriteBehindQueue}.
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueue.java:85
↓ 25 callers
Method
socket
@see java.nio.channels.SocketChannel#socket() This method will be removed from the interface. Only an explicit cast to NioChannel will expose the Soc
hazelcast/src/main/java/com/hazelcast/internal/networking/Channel.java:130
↓ 25 callers
Method
sql
(Object field, Object source)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ExtractFunctionIntegrationTest.java:455
↓ 25 callers
Method
toEventData
(Object obj)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:465
↓ 25 callers
Method
toJson
Returns the raw JSON string that this object wraps. You can use it if parsing is failing for some reason (for example on some untested DB-connector ve
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/RecordPart.java:90
↓ 25 callers
Method
toMember
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/MemberInfo.java:132
↓ 25 callers
Method
unblockCommunicationBetween
(HazelcastInstance h1, HazelcastInstance h2)
hazelcast/src/test/java/com/hazelcast/test/SplitBrainTestSupport.java:391
↓ 25 callers
Method
withMetric
(String metric)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:94
↓ 24 callers
Method
addListenerConfig
Helper method to add a new ListenerConfig @param listenerConfig ListenerConfig @return configured {@link com.hazelcast.client.config.ClientConfig} fo
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:399
↓ 24 callers
Method
addSerializer
Registers the given Compact serializer. <p> For the class returned by the serializer's {@link CompactSerializer#getCompactClass()} method, Compact ser
hazelcast/src/main/java/com/hazelcast/config/CompactSerializationConfig.java:175
↓ 24 callers
Method
against
(String... allowed)
hazelcast/src/test/java/com/hazelcast/security/permission/PermissionTestSupport.java:54
↓ 24 callers
Method
applyState
@param state state to be applied to operation after execution of all step chain
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/StepAwareOperation.java:41
↓ 24 callers
Method
assertCompletions
(TestObserver observer, int completions)
hazelcast/src/test/java/com/hazelcast/jet/core/ObservableResultsTest.java:620
↓ 24 callers
Method
assertError
(TestObserver observer, String error)
hazelcast/src/test/java/com/hazelcast/jet/core/ObservableResultsTest.java:609
↓ 24 callers
Method
checkClasses
(Converter converter, Class<?>... classes)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:891
↓ 24 callers
Method
checkConverterConversions
(Converter converter, QueryDataTypeFamily... expectedSupportedConversions)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:931
↓ 24 callers
Method
checkFamily
(Converter converter, QueryDataTypeFamily expectedTypeFamily)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:898
↓ 24 callers
Method
checkId
(Converter converter, int id)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:886
↓ 24 callers
Method
checkLiteral
(String literal, String function, boolean expectedResult)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/IsTrueFalsePredicateIntegrationTest.java:208
↓ 24 callers
Method
checkPartitionArgumentIndex
(String sql, Integer expectedIndex, Object... arguments)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlClientTest.java:131
↓ 24 callers
Method
col
(String name, ColumnType type)
hazelcast/src/test/java/com/hazelcast/test/jdbc/TestDatabaseRecordProvider.java:102
↓ 24 callers
Method
consumeLong
Called when the Metric contains a {@code long} value. @param descriptor metric descriptor @param value metric value
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricConsumer.java:30
↓ 24 callers
Method
contains
(Object objectToCheck)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/OAHashSet.java:168
↓ 24 callers
Method
createEntry
(Object key)
hazelcast/src/test/java/com/hazelcast/query/impl/CachedQueryEntryTest.java:235
↓ 24 callers
Method
decode
(byte[] buffer, int position)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListCNFixedSizeCodec.java:213
↓ 24 callers
Method
decodeParamsAndAuthenticate
(HttpPostCommand cmd, int expectedParamCount)
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpCommandProcessor.java:197
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/AtomicRefSetCodec.java:99
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPSessionCloseSessionCodec.java:87
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/AtomicLongAlterCodec.java:100
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/AtomicRefGetCodec.java:85
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/FencedLockTryLockCodec.java:121
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetSubmitJobCodec.java:101
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/TransactionalMapContainsValueCodec.java:101
↓ 24 callers
Method
decodeRequest
UUID of the unreachable CP member
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCRemoveCPMemberCodec.java:76
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPGroupDestroyCPObjectCodec.java:92
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetExportSnapshotCodec.java:89
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SemaphoreChangeCodec.java:114
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SemaphoreAcquireCodec.java:124
↓ 24 callers
Method
decodeRequest
The proxy name of this data structure instance
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPGroupCreateCPGroupCodec.java:74
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SemaphoreAvailablePermitsCodec.java:86
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPSessionCreateSessionCodec.java:88
↓ 24 callers
Method
decodeRequest
New state of the cluster: 0 - ACTIVE 1 - NO_MIGRATION 2 - FROZEN 3 - PASSIVE 4 - IN_TRANSITION (not allowed)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCChangeClusterStateCodec.java:80
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetGetJobSubmissionTimeCodec.java:91
↓ 24 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetTerminateJobCodec.java:96
← previous
next →
3,501–3,600 of 147,315, ranked by callers