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
↓ 5 callers
Method
readLong
See the general contract of the {@code readLong} method of {@code DataInput}. <p> Bytes for this operation are read from the contained input stream.
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataInput.java:323
↓ 5 callers
Method
readMapStringKey
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:287
↓ 5 callers
Method
readNullableField
(@Nonnull String fieldName, FieldType fieldType, Reader<ObjectDataInput, T> reader)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableInternalGenericRecord.java:214
↓ 5 callers
Method
readNullableField
(@Nonnull String fieldName, FieldType fieldType, Reader<ObjectDataInput, T
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/DefaultPortableReader.java:142
↓ 5 callers
Method
readObjectArrayField
(@Nonnull String fieldName, FieldType fieldType, IntFunction<T[]> constructor,
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableInternalGenericRecord.java:416
↓ 5 callers
Method
readObjectArrayField
(@Nonnull String fieldName, FieldType fieldType, IntFunction<T[]> constructor,
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/DefaultPortableReader.java:394
↓ 5 callers
Method
readObjectFromArrayField
(@Nonnull String fieldName, FieldType fieldType, Reader<ObjectDataI
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableInternalGenericRecord.java:862
↓ 5 callers
Method
readOnly
()
hazelcast/src/main/java/com/hazelcast/internal/config/DataConnectionConfigReadOnly.java:35
↓ 5 callers
Method
readRecord
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/map/impl/record/Records.java:47
↓ 5 callers
Method
readResource
(String name)
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/ChildFirstClassLoaderTest.java:250
↓ 5 callers
Method
readResult
(Future<T> future)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/KinesisUtil.java:32
↓ 5 callers
Method
readStaticField
Reads a value of a static field. In case of any exceptions it returns null.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ReflectionUtils.java:139
↓ 5 callers
Method
reconnectIfNecessary
@return true if there is a connection to Mongo after exiting this method
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/MongoConnection.java:80
↓ 5 callers
Method
recordIterator
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:87
↓ 5 callers
Method
recreate
Recreates this query cache. Recreation steps are: <ul> <li> Reset local subscribers' state, clear all cached entries </li> <li> Recreate/reset publis
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/InternalQueryCache.java:104
↓ 5 callers
Method
refreshIndex
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/BaseElasticTest.java:225
↓ 5 callers
Method
regexContains
(String str, String regex)
hazelcast/src/test/java/com/hazelcast/jet/core/DotTest.java:161
↓ 5 callers
Method
register
(String name, int defaultPoolSize, int defaultQueueCapacity, ExecutorType type)
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/impl/ExecutionServiceImpl.java:161
↓ 5 callers
Method
registerCacheEntryListener
Registers the provided listener configuration. @param cacheEntryListenerConfiguration The cache configuration to be used for registering the entry li
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheInternal.java:49
↓ 5 callers
Method
registerInvocation
(ClientInvocation clientInvocation, ClientConnection connection)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientInvocationServiceImpl.java:301
↓ 5 callers
Method
registerPublisher
Register a custom {@link MetricsPublisher} implementation with a register function that takes {@link NodeEngine} as input letting the caller to option
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsService.java:121
↓ 5 callers
Method
registerStaticProbeWithUnit
(S source, MetricDescriptor descriptor, String name, ProbeLevel level,
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsRegistryImpl.java:223
↓ 5 callers
Method
rejectExecution
(String executorName)
hazelcast/src/main/java/com/hazelcast/map/impl/ExecutorStats.java:60
↓ 5 callers
Method
release
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Promise.java:153
↓ 5 callers
Method
remoteCacheJournal
Returns a source that will stream the {@link EventJournalCacheEvent} events of the Hazelcast {@code ICache} with the specified name from a remote clus
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:1052
↓ 5 callers
Method
removeAll
Removes keys from map store. It also handles {@link Data} to object conversions of keys. @param keys to be removed
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:81
↓ 5 callers
Method
removeCacheEntryListenerConfiguration
Remove a configuration for a {@link javax.cache.event.CacheEntryListener}. @param cacheEntryListenerConfiguration the {@link javax.cache.configuratio
hazelcast/src/main/java/com/hazelcast/config/CacheConfiguration.java:72
↓ 5 callers
Method
removeFirstOccurrence
Removes the first occurrence of the specified element in this queue when searching it by starting from the head of this queue. @param e element to be
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueue.java:62
↓ 5 callers
Method
removeIf
(Predicate<? super E> filter)
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryResultCollection.java:86
↓ 5 callers
Method
removeInternal
(Object key)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientMapProxy.java:297
↓ 5 callers
Method
removeInternal
(Object key)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:693
↓ 5 callers
Method
removeKey
Overloaded version of {@link Map#remove(Object)} that takes a primitive long key. Due to type erasure have to rename the method @param key for indexi
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Object2LongHashMap.java:329
↓ 5 callers
Method
removeListener
Removes listener from this event service. @param mapName underlying IMap name of query-cache @param cacheId ID of the query cache @param listen
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/QueryCacheEventService.java:98
↓ 5 callers
Method
removeLogListener
(@Nonnull LogListener logListener)
hazelcast/src/main/java/com/hazelcast/logging/LoggingService.java:26
↓ 5 callers
Method
removeModifierSuffix
Remove modifier suffix from given fullName.
hazelcast/src/main/java/com/hazelcast/query/impl/getters/SuffixModifierUtils.java:41
↓ 5 callers
Method
removeThreadLocalTestMethodName
()
hazelcast/src/test/java/com/hazelcast/test/TestLoggingUtils.java:52
↓ 5 callers
Method
replace
(K key, V newValue)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:68
↓ 5 callers
Method
replaceInternal
(Object key, Data expect, Data update)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:594
↓ 5 callers
Method
replaceVariables
Replaces variables in the given {@link Node} with the provided {@link ConfigReplacer}. @param node The node in which the variables to be replaced
hazelcast/src/main/java/com/hazelcast/internal/config/DomVariableReplacer.java:41
↓ 5 callers
Method
replicas
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionImpl.java:210
↓ 5 callers
Method
reportEvent
Called to report the observation of an event with the given timestamp. The next call to {@link #getCurrentWatermark()} should reflect this. @param ti
hazelcast/src/main/java/com/hazelcast/jet/core/WatermarkPolicy.java:50
↓ 5 callers
Method
requiresJob
(RelNode rel)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:403
↓ 5 callers
Method
reset
Resets the record store to it's initial state. <p> Used in replication operations. @see #putOrUpdateReplicatedRecord
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:656
↓ 5 callers
Method
resolveAndValidateFields
( boolean isKey, List<MappingField> userFields, Map<String, String> option
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataResolver.java:47
↓ 5 callers
Method
resolveForConverter
(Converter converter)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:426
↓ 5 callers
Method
resolveNodes
()
hazelcast/src/main/java/com/hazelcast/kubernetes/DnsEndpointResolver.java:65
↓ 5 callers
Method
resourceTypes
Returns the list of possible values for {@link DataConnectionResource#type()}, that will be returned when {@link #listResources()} is called. Returned
hazelcast/src/main/java/com/hazelcast/dataconnection/DataConnection.java:116
↓ 5 callers
Method
rethrow
(Throwable t)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/TpcTestSupport.java:213
↓ 5 callers
Method
rethrowIfError
(final Throwable t)
hazelcast/src/main/java/com/hazelcast/internal/util/ExceptionUtil.java:158
↓ 5 callers
Method
routingPolicy
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/EdgeDef.java:74
↓ 5 callers
Method
rowCount
()
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/WriteJdbcPTest.java:392
↓ 5 callers
Method
run
()
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/BackpressureRegulatorTest.java:264
↓ 5 callers
Method
run
(List<Operation> operationList)
hazelcast/src/main/java/com/hazelcast/collection/impl/CollectionTxnUtil.java:63
↓ 5 callers
Method
run
Runs the {@link Operation} on the calling thread. @param op the {@link Operation} to run. @throws java.lang.NullPointerException if op is null. @thro
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/OperationExecutor.java:150
↓ 5 callers
Method
runTest
(TestMode testMode)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:667
↓ 5 callers
Method
runWithOwnClassLoader
Runs the passed {@link Runnable} within the {@link ClassLoader} context of the passed {@link Object}'s own {@link ClassLoader} as defined by {@code Ob
hazelcast/src/main/java/com/hazelcast/internal/namespace/NamespaceUtil.java:196
↓ 5 callers
Method
sampleObject
(T obj, byte[] serializedObject)
hazelcast/src/test/java/com/hazelcast/test/compatibility/SamplingSerializationService.java:265
↓ 5 callers
Method
scheduleOnKeyOwnerAtFixedRate
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period on the partiti
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:270
↓ 5 callers
Method
scheduleOnMemberAtFixedRate
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period at the given {
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:204
↓ 5 callers
Method
scheduleOnMembersAtFixedRate
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period on all {@link
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:422
↓ 5 callers
Method
scheduleWithRepetition
Executes a task periodically with the supplied {@code delaySeconds}. @param task task to execute. @param delaySeconds the time between subseq
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/QueryCacheScheduler.java:50
↓ 5 callers
Method
sendInvalidationEvent
(String cacheNameWithPrefix, Data key, UUID sourceUuid)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:135
↓ 5 callers
Method
sendMemberListToOthers
Invoked on the master to send the member list (see {@link MembersUpdateOp}) to non-master nodes.
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:257
↓ 5 callers
Method
sendRequestForPreparation
(Schema schema)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/schema/SchemaReplicator.java:337
↓ 5 callers
Method
serialize
(Serializable entry)
hazelcast/src/test/java/com/hazelcast/test/TestJavaSerializationUtils.java:43
↓ 5 callers
Method
serializeAliasedDiscoveryConfig
Serializes the provided aliased discovery config and adds the serialized contents under the tag in the JSON object if the config is not {@code null}.
hazelcast/src/main/java/com/hazelcast/internal/management/dto/WanBatchPublisherConfigDTO.java:217
↓ 5 callers
Method
setArrayOfNullableBoolean
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:898
↓ 5 callers
Method
setArrayOfNullableFloat32
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:1028
↓ 5 callers
Method
setArrayOfNullableFloat64
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:1054
↓ 5 callers
Method
setArrayOfNullableInt64
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:1002
↓ 5 callers
Method
setArrayOfNullableInt8
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:924
↓ 5 callers
Method
setAsyncBackupCount
Sets the number of asynchronous backups. 0 means no backups. @param asyncBackupCount the number of asynchronous synchronous backups to set @return th
hazelcast/src/main/java/com/hazelcast/config/RingbufferConfig.java:223
↓ 5 callers
Method
setAttribute
(TransformerFactory transformerFactory, String attributeName)
hazelcast/src/main/java/com/hazelcast/internal/util/XmlUtil.java:197
↓ 5 callers
Method
setAutoCommit
(boolean autoCommit)
hazelcast/src/main/java/com/hazelcast/dataconnection/impl/ConnectionDelegate.java:71
↓ 5 callers
Method
setAutoRemoveStaleData
Sets whether automatic removal of stale Persistence restart data is enabled. <p> When a member terminates or crashes when cluster state is {@link com.
hazelcast/src/main/java/com/hazelcast/config/PersistenceConfig.java:244
↓ 5 callers
Method
setBackupCount
(int backupCount)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:492
↓ 5 callers
Method
setBackupCount
Sets the number of synchronous backups for this queue. @param backupCount the number of synchronous backups to set @return the current QueueConfig @t
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:178
↓ 5 callers
Method
setBackupEntryCount
(long backupEntryCount)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalMapStatsImpl.java:224
↓ 5 callers
Method
setBatchSize
(int batchSize)
hazelcast/src/main/java/com/hazelcast/internal/config/QueryCacheConfigReadOnly.java:69
↓ 5 callers
Method
setByteOrder
Note that configuring use native byte order as enabled will override the byte order set by this method. @param byteOrder that serialization will use
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:443
↓ 5 callers
Method
setCPMapLimit
Sets the limit of permitted {@link com.hazelcast.cp.CPMap} instances. <p> This is a soft limit and is used exclusively by Hazelcast Management Center.
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:849
↓ 5 callers
Method
setCRDTReplicationConfig
Sets the replication configuration for {@link com.hazelcast.internal.crdt.CRDT} implementations. @param crdtReplicationConfig the replication configu
hazelcast/src/main/java/com/hazelcast/config/Config.java:2774
↓ 5 callers
Method
setCacheEntryListeners
Sets a list of {@link CacheSimpleEntryListenerConfig} for this {@link com.hazelcast.cache.ICache}. @param cacheEntryListeners list of {@link CacheSim
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:471
↓ 5 callers
Method
setCallerProvenance
(CallerProvenance callerProvenance)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:215
↓ 5 callers
Method
setChar
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:166
↓ 5 callers
Method
setCheckIfLoaded
(boolean checkIfLoaded)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:191
↓ 5 callers
Method
setClusterDataRecoveryPolicy
Sets the policy to be used when the cluster is started @param clusterDataRecoveryPolicy the policy to be used when the cluster is started @return Pe
hazelcast/src/main/java/com/hazelcast/config/PersistenceConfig.java:117
↓ 5 callers
Method
setConfigurationFile
Sets the {@link File} from which this configuration has been retrieved and created. <p> Is set by the {@link XmlConfigBuilder}, when the XML configura
hazelcast/src/main/java/com/hazelcast/config/Config.java:2899
↓ 5 callers
Method
setConnection
(Operation op, ServerConnection connection)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationAccessor.java:37
↓ 5 callers
Method
setCooperative
(boolean cooperative)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TransformP.java:59
↓ 5 callers
Method
setCurrentMapName
(String currentMapName)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/MockSnapshotContext.java:45
↓ 5 callers
Method
setDataNewValue
(Data dataNewValue)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/DefaultQueryCacheEventData.java:139
↓ 5 callers
Method
setDeny
Configures if this permission config is for a grant ({@code false}, default) permission or deny ({@code true}) @param deny value to set @return this i
hazelcast/src/main/java/com/hazelcast/config/PermissionConfig.java:339
↓ 5 callers
Method
setDeviceName
Sets the device name for this disk tier. @param deviceName device name. @return this DiskTierConfig
hazelcast/src/main/java/com/hazelcast/config/DiskTierConfig.java:86
↓ 5 callers
Method
setEnableCompression
(boolean enableCompression)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:59
↓ 5 callers
Method
setEnableSharedObject
(boolean enableSharedObject)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:61
↓ 5 callers
Method
setEnabled
Enables or disables the TPC-aware mode. <p> When enabled, the configuration option set by the {@link ClusterRoutingConfig#setRoutingMode(RoutingMode)}
hazelcast/src/main/java/com/hazelcast/client/config/ClientTpcConfig.java:73
↓ 5 callers
Method
setEntryListenerConfigs
(List<EntryListenerConfig> listenerConfigs)
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:546
↓ 5 callers
Method
setEntryOperator
(EntryOperator operator)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:379
↓ 5 callers
Method
setEpochStart
Sets the offset of timestamp component in milliseconds. By default, it's {@value DEFAULT_EPOCH_START}, that is the beginning of 2018. You can adjust t
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:197
← previous
next →
11,101–11,200 of 147,315, ranked by callers