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
↓ 6 callers
Method
readDigit
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonParser.java:412
↓ 6 callers
Method
readDigit
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonReducedValueParser.java:268
↓ 6 callers
Method
readInt8
Reads an 8-bit two's complement signed integer. <p> This method can also read a nullable int8, as long as it is not {@code null}. If a {@code null} va
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:104
↓ 6 callers
Method
readList
(@Nonnull ObjectDataInput input)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ImdgUtil.java:195
↓ 6 callers
Method
readNullableInt16
Reads a nullable 16-bit two's complement signed integer. <p> This method can also read a non-nullable int16. @param fieldName name of the field. @ret
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:564
↓ 6 callers
Method
readShortL
(byte[] buffer, int pos)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:119
↓ 6 callers
Method
readValue
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonParser.java:159
↓ 6 callers
Method
readsFromMongo
(boolean includeIdInMapping, boolean useUnsupportedExpressionInProjection, bool
extensions/mongodb/src/test/java/com/hazelcast/jet/sql/impl/connector/mongodb/MongoSqlConnectorIT.java:77
↓ 6 callers
Method
recover
(XAResource xaResource)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientXACompatibilityTest.java:208
↓ 6 callers
Method
regex
Creates a <b>regex</b> predicate that will pass items if the given {@code pattern} matches the value stored under the given item {@code attribute}. <p
hazelcast/src/main/java/com/hazelcast/query/Predicates.java:369
↓ 6 callers
Method
register
Registers a {@link DiagnosticsPlugin}. <p> This method is thread-safe. <p> The duplicated plugins will overwrite the previous one. <p> If the {@link D
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:316
↓ 6 callers
Method
registerCompletionLatch
(int count)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheSyncListenerCompleter.java:80
↓ 6 callers
Method
registerIndex
Tracks indexes created dynamically via {@link com.hazelcast.map.IMap#addIndex}
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContext.java:301
↓ 6 callers
Method
registerListenerAsync
(String cacheNameWithPrefix, CacheEventListener listener)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:117
↓ 6 callers
Method
registerSchema
Registers the specified {@code schema} and returns its ID.
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:291
↓ 6 callers
Method
rejectOperationsFrom
(HazelcastInstance instance, int factory, List<Integer> opTypes)
hazelcast/src/test/java/com/hazelcast/test/PacketFiltersUtil.java:92
↓ 6 callers
Method
remembered
Get the remembered value. Returns {@code null} if value was never asked for
hazelcast/src/main/java/com/hazelcast/instance/impl/executejar/ResettableSingleton.java:54
↓ 6 callers
Method
remoteMapWithUpdating
Returns a sink equivalent to {@link #mapWithUpdating}, but for a map in a remote Hazelcast cluster identified by the supplied {@code ClientConfig}. <p
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sinks.java:688
↓ 6 callers
Method
remove
Transactional implementation of {@link IMap#remove(Object)}. <p> The object to be removed will be removed from only the current transaction context un
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:205
↓ 6 callers
Method
removeAsyncInternal
(K key, V oldValue, boolean hasOldValue, boolean isGe
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxySupport.java:306
↓ 6 callers
Method
removeBadSession
Remove the bad JobUploadStatus because of an exception or expiration @param sessionId specifies the key to be used
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobUploadStore.java:55
↓ 6 callers
Method
removeCastIfPossible
Removes CAST operator from the column expression when possible. <p> The following expression might be found: {@code CAST(a AS BIGINT) > ?}. This may h
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:1447
↓ 6 callers
Method
removeCharacter
Removes all occurrence of {@code charToRemove} from {@code str}. This method is more efficient than {@link String#replaceAll(String, String)} which co
hazelcast/src/main/java/com/hazelcast/internal/util/StringUtil.java:419
↓ 6 callers
Method
removeEntriesFromMap
(IMap<Integer, Employee> map, int startIndex, int endIndex)
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/AbstractQueryCacheTestSupport.java:51
↓ 6 callers
Method
removeLifecycleListener
Removes a lifecycle listener. @param registrationId the listener ID returned by {@link #addLifecycleListener(LifecycleListener)} @return true if the
hazelcast/src/main/java/com/hazelcast/core/LifecycleService.java:61
↓ 6 callers
Method
removeMigrationListener
Removes a MigrationListener. <p> If the same MigrationListener is registered multiple times, it needs to be removed multiple times. <p> This method ca
hazelcast/src/main/java/com/hazelcast/partition/PartitionService.java:84
↓ 6 callers
Method
removeStale
()
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrentReferenceHashMap.java:983
↓ 6 callers
Method
render
Renders the value from the gauge. @param stringBuilder the {@link StringBuilder} to write to.
hazelcast/src/main/java/com/hazelcast/internal/metrics/Gauge.java:36
↓ 6 callers
Method
render
(DiagnosticsLogWriter writer, LifecycleEvent event)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/SystemLogPlugin.java:218
↓ 6 callers
Method
replaceAsync
Asynchronously replaces the assigned value of the given key by the specified value. <p> If the cache is configured for <code>write-through</code> oper
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:497
↓ 6 callers
Method
replacePlaceholders
(Document doc, ExpressionEvalContext evalContext, JetSqlRow inputRow,
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/PlaceholderReplacer.java:33
↓ 6 callers
Method
replica
(String host, int port)
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionRuntimeStateTest.java:95
↓ 6 callers
Method
reset
()
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestOutbox.java:203
↓ 6 callers
Method
resetLevel
Resets the levels of all the loggers known to this logger factory back to the default preconfigured values. Basically, undoes all the changes done by
hazelcast/src/main/java/com/hazelcast/logging/impl/InternalLoggerFactory.java:42
↓ 6 callers
Method
resetRemembered
()
hazelcast/src/main/java/com/hazelcast/instance/impl/HazelcastBootstrap.java:73
↓ 6 callers
Method
resolveConsumerProperties
(Map<String, String> options, Object keySchema, Object valueSchema)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/kafka/PropertiesResolver.java:90
↓ 6 callers
Method
resolveFields
Resolves fields based on the options passed to the connector and schema provided by user (if any). @param externalName external name of the map
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/FieldResolver.java:68
↓ 6 callers
Method
resolveNodes
()
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesApiEndpointResolver.java:69
↓ 6 callers
Method
resolveProducerProperties
(Map<String, String> options, Object keySchema, Object valueSchema)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/kafka/PropertiesResolver.java:99
↓ 6 callers
Method
restoreWatermark
(Long value)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/ReadMongoP.java:381
↓ 6 callers
Method
result
Returns the aggregated result.
hazelcast/src/main/java/com/hazelcast/jet/datamodel/WindowResult.java:80
↓ 6 callers
Method
rethrowFromCollection
If there's any Throwable instance in the values, throw it.
hazelcast/src/main/java/com/hazelcast/internal/util/ExceptionUtil.java:357
↓ 6 callers
Method
retries
Number of retries the connector will do in addition to Elastic client retries <p> Elastic client tries to connect to a node only once for each request
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/ElasticSinkBuilder.java:193
↓ 6 callers
Method
ring
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/ringbuffer/RingbufferSplitBrainProtectionWriteTest.java:102
↓ 6 callers
Method
ringbufferName
(String observableName)
hazelcast/src/main/java/com/hazelcast/jet/impl/observer/ObservableImpl.java:156
↓ 6 callers
Method
rollback
Roll back the transaction. Only called for non-prepared transactions when the job execution ends. <p> Will only be called for a transaction that was {
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:327
↓ 6 callers
Method
rollbackClusterState
(UUID txnId)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterStateManager.java:303
↓ 6 callers
Method
runJob
()
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:398
↓ 6 callers
Method
sampleValues
(RandomNumberSupplier<T> randomNumberSupplier)
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:182
↓ 6 callers
Method
sanitizeValue
(Object input)
hazelcast/src/main/java/com/hazelcast/query/impl/BaseIndexStore.java:107
↓ 6 callers
Method
schedule
(Runnable command, long delay, TimeUnit unit)
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/ExecutionService.java:158
↓ 6 callers
Method
schedule
Schedules (or reschedules) the execution of given entry. Key parameter is used to check whether there is an existing scheduling for this entry, see {@
hazelcast/src/main/java/com/hazelcast/internal/util/scheduler/EntryTaskScheduler.java:37
↓ 6 callers
Method
sendJoinRequest
Send join request to {@code toAddress}. @param toAddress the currently known master address. @return {@code true} if join request was sent succ
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:455
↓ 6 callers
Method
sendMasterAnswer
Respond to a join request by sending the master address in a {@link MasterResponseOp}. This happens when current node receives a join request but is n
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:618
↓ 6 callers
Method
sendMessage
(String destinationName, boolean isQueue)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/StreamJmsPTest.java:190
↓ 6 callers
Method
sendMigrationEvent
Sends a {@link ReplicaMigrationEvent} to the registered event listeners.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionEventManager.java:68
↓ 6 callers
Method
sendToListeningEndpoints
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/AbstractListenerService.java:67
↓ 6 callers
Method
serializeAndDeserialize
(T object)
hazelcast/src/test/java/com/hazelcast/test/TestJavaSerializationUtils.java:31
↓ 6 callers
Method
serviceLbWithoutAddr
(ServicePort... port)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesFakeUtils.java:478
↓ 6 callers
Method
set
(Integer... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/IsNullPredicateIntegrationTest.java:237
↓ 6 callers
Method
setAllAsync
Asynchronously copies all of the mappings from the specified map to this map without loading non-existing elements from map store. This version doesn'
hazelcast/src/main/java/com/hazelcast/map/IMap.java:1930
↓ 6 callers
Method
setAllowUnsafe
(boolean allowUnsafe)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:63
↓ 6 callers
Method
setAmount
(int amount)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientTxnMapTest.java:143
↓ 6 callers
Method
setAndGetListenerFlags
Sets and gets flags of implemented listener interfaces of a {@link com.hazelcast.map.listener.MapListener MapListener}.
hazelcast/src/main/java/com/hazelcast/map/impl/MapListenerFlagOperator.java:38
↓ 6 callers
Method
setArrayOfFloat32
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:847
↓ 6 callers
Method
setArrayOfFloat64
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:872
↓ 6 callers
Method
setArrayOfInt32
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:797
↓ 6 callers
Method
setArrayOfInt64
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:822
↓ 6 callers
Method
setArrayOfInt8
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:719
↓ 6 callers
Method
setArrayOfNullableInt16
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:950
↓ 6 callers
Method
setArrayOfNullableInt32
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:976
↓ 6 callers
Method
setAutoStepDownWhenLeader
Enables or disables automatic leader step-down for this CP member. <p>If enabled, the member will immediately relinquish leadership whenever elected,
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:627
↓ 6 callers
Method
setBackupAckToClientEnabled
This feature reduces number of hops and increases performance for {@link RoutingMode#ALL_MEMBERS} routing clients. It is enabled by default for {@link
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:941
↓ 6 callers
Method
setBackupDir
Sets base directory for all Hot Restart stores. @param backupDir home directory @return PersistenceConfig
hazelcast/src/main/java/com/hazelcast/config/PersistenceConfig.java:156
↓ 6 callers
Method
setBackupPacketDropFilter
(HazelcastInstance instance, float blockRatio)
hazelcast/src/test/java/com/hazelcast/internal/partition/AntiEntropyCorrectnessTest.java:95
↓ 6 callers
Method
setCacheEntryEventFilterFactory
(String cacheEntryEventFilterFactory)
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleEntryListenerConfig.java:60
↓ 6 callers
Method
setCallerAddress
(Address callerAddress)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:210
↓ 6 callers
Method
setCapacity
(int capacity)
hazelcast/src/main/java/com/hazelcast/internal/config/RingbufferConfigReadOnly.java:42
↓ 6 callers
Method
setCheckClassDefErrors
When enabled, serialization system will check for class definitions error at start and throw a Serialization Exception with error definition. @param
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:407
↓ 6 callers
Method
setClassLoader
Sets the classLoader which is used by serialization and listener configuration @param classLoader the classLoader @return configured {@link com.hazel
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:679
↓ 6 callers
Method
setClassName
(@Nonnull String className)
hazelcast/src/main/java/com/hazelcast/internal/config/MapStoreConfigReadOnly.java:33
↓ 6 callers
Method
setClientXml
(String clientXml)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/MapSinkConfiguration.java:63
↓ 6 callers
Method
setClockOffset
(long offset)
hazelcast/src/test/java/com/hazelcast/internal/util/AbstractClockTest.java:86
↓ 6 callers
Method
setCluster
(String cluster)
hazelcast/src/main/java/com/hazelcast/aws/AwsConfig.java:306
↓ 6 callers
Method
setConnectionTimeout
@param connectionTimeoutInMillis Timeout value in millis for nodes to accept client connection requests. A zero value
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:218
↓ 6 callers
Method
setDataKey
(Data dataKey)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventContext.java:68
↓ 6 callers
Method
setDisablePerEntryInvalidationEvents
Sets invalidation events disabled status for per entry. @param disablePerEntryInvalidationEvents disables invalidation event sending behaviour if it
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:514
↓ 6 callers
Method
setEnabled
Set whether the ICMP failure detector should be enabled or not. When set to true, this member will use icmp ping failure detector to detect unavailabl
hazelcast/src/main/java/com/hazelcast/config/IcmpFailureDetectorConfig.java:195
↓ 6 callers
Method
setEnabled
Enables or disables native memory allocation. @return this {@link NativeMemoryConfig} instance
hazelcast/src/main/java/com/hazelcast/config/NativeMemoryConfig.java:153
↓ 6 callers
Method
setError
(Throwable t)
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/impl/DistributedObjectFuture.java:147
↓ 6 callers
Method
setExpiryPolicyFactoryConfig
Sets the factory configuration for this {@link javax.cache.expiry.ExpiryPolicy}. @param expiryPolicyFactoryConfig the factory configuration to set fo
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:427
↓ 6 callers
Method
setExternalName
(String extName)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/MappingField.java:101
↓ 6 callers
Method
setFailFastOnStartup
Sets whether the member should fail-fast on startup if ICMP is not allowed by the underlying OS. Failure is usually due to OS level restrictions. @pa
hazelcast/src/main/java/com/hazelcast/config/IcmpFailureDetectorConfig.java:140
↓ 6 callers
Method
setFailOnIndeterminateOperationState
Sets the value to determine if CP Subsystem calls will fail when result of an API call becomes indeterminate. @return this config instance
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:513
↓ 6 callers
Method
setFileName
Sets the name of the file which will contain the tracking metadata. If set to {@code null}, {@link InstanceTrackingConfig#DEFAULT_FILE} is used instea
hazelcast/src/main/java/com/hazelcast/config/InstanceTrackingConfig.java:116
↓ 6 callers
Method
setInMemoryFormat
Data type that will be used to store records in this {@link com.hazelcast.cache.ICache}. Possible values: <ul> <li>BINARY (default): keys and values w
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:436
↓ 6 callers
Method
setInitialBackoffMillis
@param initialBackoffMillis how long to wait after the first failure before retrying @return updated ConnectionRetryConfig
hazelcast/src/main/java/com/hazelcast/client/config/ConnectionRetryConfig.java:75
↓ 6 callers
Method
setItemClass
(@Nonnull Class itemClass)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/ReadMongoParams.java:162
↓ 6 callers
Method
setIterationPointers
Sets the iteration state to the state defined by the {@code pointers} if the given response contains items. @param response the iteration response @p
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheIterator.java:221
↓ 6 callers
Method
setJaasAuthenticationConfig
(JaasAuthenticationConfig authenticationConfig)
hazelcast/src/main/java/com/hazelcast/config/security/RealmConfig.java:46
← previous
next →
9,901–10,000 of 147,315, ranked by callers