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
↓ 9 callers
Method
decrement
Decrements capacity count for a transaction. @param txnId id of transaction
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/TxnReservedCapacityCounter.java:70
↓ 9 callers
Method
defaultObjectType
Returns default value for the Object Type mapping property, so if user won't provide any type, this will be assumed. @since 5.3
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/SqlConnector.java:241
↓ 9 callers
Method
delete
(Data dataKey)
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapContainer.java:110
↓ 9 callers
Method
deregisterAllLocalListeners
Deregisters all local listeners belonging to the given service and topic. @param serviceName service name @param topic topic name
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/EventService.java:180
↓ 9 callers
Method
deregisterDynamicMetricsProvider
Deregisters the given dynamic metrics provider. The metrics collection cycles after this call will not call the given metrics provider until it is reg
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricsRegistry.java:175
↓ 9 callers
Method
describeNetworkInterfaces
()
hazelcast/src/test/java/com/hazelcast/aws/AwsEc2ApiTest.java:209
↓ 9 callers
Method
discoverNodes
Returns a discovered and filtered, if a {@link NodeFilter} is setup, set of discovered nodes to connect to. @return a set of discovered and filtered
hazelcast/src/main/java/com/hazelcast/spi/discovery/integration/DiscoveryService.java:64
↓ 9 callers
Method
disposeDeferredBlocks
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:117
↓ 9 callers
Method
doCall
(String methodName, boolean isCooperative, Runnable r)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:1004
↓ 9 callers
Method
doubleAvg
@param <I> type of the input object. @return an aggregator that calculates the average of the input values. Does NOT accept null input values. Accepts
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:173
↓ 9 callers
Method
doubleSum
@param <I> type of the input object. @return an aggregator that calculates the sum of the input values. Does NOT accept null input values. Accepts onl
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:628
↓ 9 callers
Method
empty
()
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:562
↓ 9 callers
Method
encodeRequest
(java.lang.String name, java.util.Collection<com.hazelcast.replicatedmap.impl.record.ReplicatedMapEntryViewHol
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapPutAllWithMetadataCodec.java:82
↓ 9 callers
Method
encodeRequest
(java.lang.String name, @Nullable com.hazelcast.client.impl.protocol.codec.holder.WanConsumerConfigHolder cons
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddWanReplicationConfigCodec.java:82
↓ 9 callers
Method
encodeRequest
(java.lang.String name, java.util.Collection<com.hazelcast.map.impl.SimpleEntryView<com.hazelcast.internal.ser
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapPutAllWithMetadataCodec.java:77
↓ 9 callers
Method
encodeRequest
(java.lang.String name, @Nullable java.util.UUID cursorId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapEndEntryViewIterationCodec.java:74
↓ 9 callers
Method
encodeRequest
(java.util.UUID uuid, byte[] token)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientTpcAuthenticationCodec.java:73
↓ 9 callers
Method
encodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddUserCodeNamespaceConfigCodec.java:95
↓ 9 callers
Method
encodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddWanReplicationConfigCodec.java:110
↓ 9 callers
Method
encodeResponse
(java.util.UUID cursorId, java.util.Collection<com.hazelcast.replicatedmap.impl.record.ReplicatedMapEntryViewH
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapFetchEntryViewsCodec.java:138
↓ 9 callers
Method
encodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapPutAllWithMetadataCodec.java:101
↓ 9 callers
Method
encodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapEndEntryViewIterationCodec.java:96
↓ 9 callers
Method
encodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientTpcAuthenticationCodec.java:95
↓ 9 callers
Method
ensureNoSplitBrain
(SplitBrainProtectionOn requiredSplitBrainProtectionPermissionType)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/ReplicatedMapProxy.java:511
↓ 9 callers
Method
ensureNoSplitBrain
Ensures that the split brain protection with the given name is present. Throws a SplitBrainProtectionException if split brain protection not present.
hazelcast/src/main/java/com/hazelcast/splitbrainprotection/SplitBrainProtectionService.java:55
↓ 9 callers
Method
entry
(Data data)
hazelcast/src/test/java/com/hazelcast/query/impl/DuplicateDetectingMultiResultTest.java:129
↓ 9 callers
Method
equals
(Object o)
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/MongoSinkTest.java:288
↓ 9 callers
Method
equals
(Object o)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/SnapshotBarrier.java:48
↓ 9 callers
Method
eventloopThread
Returns the {@link Thread} that runs the eventloop. The eventloop thread is created when the Reactor is created. <p/> This method is thread-safe. @re
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Reactor.java:187
↓ 9 callers
Method
eventsWithKey
(String key)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SessionWindowPTest.java:233
↓ 9 callers
Method
executeAndJoin
(List<MockTasklet> tasklets)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/TaskletExecutionServiceTest.java:386
↓ 9 callers
Method
executeOnPartitions
Executes for each of the partitions, a task created by the taskFactory. For more info see the {@link com.hazelcast.spi.impl.operationexecutor.Operati
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationService.java:118
↓ 9 callers
Method
expectCardinalityEstimatorException
(ThrowingCallable toRun)
hazelcast/src/test/java/com/hazelcast/internal/config/MergePolicyValidatorCacheIntegrationTest.java:142
↓ 9 callers
Method
expectDuplicateElementError
(String elName, ThrowingCallable toRun)
hazelcast/src/test/java/com/hazelcast/config/XmlSchemaValidationTest.java:152
↓ 9 callers
Method
expectedInvalidMergePolicyException
(ThrowingCallable toRun)
hazelcast/src/test/java/com/hazelcast/internal/config/MergePolicyValidatorCacheIntegrationTest.java:149
↓ 9 callers
Method
extendedRow
Creates a copy of this row with the number of fields increased by {@code extendBy}. The added fields will contain {@code null}s. If {@code extendBy ==
hazelcast/src/main/java/com/hazelcast/sql/impl/row/JetSqlRow.java:106
↓ 9 callers
Method
extractMillis
(Object value)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/WindowUtils.java:157
↓ 9 callers
Method
fileMapping
(String name, File file)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/file/SqlAvroTest.java:64
↓ 9 callers
Method
filesBuilder
Returns a builder object that offers a step-by-step fluent API to build a custom source to read files for the Pipeline API. The source reads lines fro
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:1206
↓ 9 callers
Method
filter
(long input)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/jet/Calculator.java:23
↓ 9 callers
Method
findDurableExecutorConfig
Finds existing Durable Executor config. @param name name of the config @return Durable Executor config or {@code null} when requested Durable Executo
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:198
↓ 9 callers
Method
findPropertyField
Return a {@link Field} object for the given {@code fieldName}. The field must be public and non-static. @param clazz The containing class @param
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ReflectionUtils.java:260
↓ 9 callers
Method
finishSnapshotRestore
Called after a job was restarted from a snapshot and the processor has consumed all the snapshot data in {@link #restoreFromSnapshot}. <p> If this met
hazelcast/src/main/java/com/hazelcast/jet/core/Processor.java:528
↓ 9 callers
Method
fireEntryListenerEvent
(Data key, Data oldValue, Data value, String name, Address caller)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/ReplicatedMapEventPublishingService.java:200
↓ 9 callers
Method
firstArrangement
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:244
↓ 9 callers
Method
flushAndResetMap
()
hazelcast/src/main/java/com/hazelcast/jet/impl/util/AsyncSnapshotWriter.java:28
↓ 9 callers
Method
formatJobDuration
Formats a duration given im milliseconds to the form of: <ul> <li>{@code HH:MM:SS.sss}, if <24 hours <li>{@code Nd HH:MM:SS.sss} otherwise </u
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:709
↓ 9 callers
Method
frame
(long ts, long value)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SlidingWindowP_stage1Test.java:191
↓ 9 callers
Method
from
(boolean ignoreNulls, boolean distinct)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/CountSqlAggregations.java:30
↓ 9 callers
Method
get
Returns the value for the given key. If this {@code HazelcastProperties} object is initialized with a "compromised" {@link Properties} object (ie one
hazelcast/src/main/java/com/hazelcast/spi/properties/HazelcastProperties.java:106
↓ 9 callers
Method
get
Returns the current thread's {@link Random}. @return the current thread's {@link Random}.
hazelcast/src/main/java/com/hazelcast/internal/util/ThreadLocalRandomProvider.java:38
↓ 9 callers
Method
get2
Returns the second value.
hazelcast/src/main/java/com/hazelcast/jet/accumulator/LongLongAccumulator.java:60
↓ 9 callers
Method
getAddressHolder
(String address)
hazelcast/src/main/java/com/hazelcast/internal/util/AddressUtil.java:116
↓ 9 callers
Method
getAddresses
Returns the list of candidate addresses that client will use to establish initial connection @return list of addresses
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:261
↓ 9 callers
Method
getAdvancedNetworkConfigWithSocketOption
(String socketOption, int value)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:5779
↓ 9 callers
Method
getAdvancedNetworkConfigWithSocketOption
(String socketOption, int value)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:5394
↓ 9 callers
Method
getAllEvents
Reads from the event journal a set of events. @param adapter the adapter for a specific data structure @param predicate the predicate which the
hazelcast/src/test/java/com/hazelcast/journal/AbstractEventJournalBasicTest.java:710
↓ 9 callers
Method
getAllRecordStores
()
hazelcast/src/main/java/com/hazelcast/map/impl/PartitionContainer.java:31
↓ 9 callers
Method
getAndPutAsync
Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed. <p> In case a previous
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:366
↓ 9 callers
Method
getAndRemove
Atomically removes the entry for a key only if it is currently mapped to some value. <p> This is equivalent to: <pre><code> if (cache.containsKey(key)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheRecordStore.java:158
↓ 9 callers
Method
getAndReplace
Atomically replaces the assigned value of the given key by the specified value using a custom {@link javax.cache.expiry.ExpiryPolicy} and returns the
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:894
↓ 9 callers
Method
getAndSet
Sets the current value of the counter and returns the old value. @param newValue the new value. @return the old value of the counter.
hazelcast/src/main/java/com/hazelcast/internal/util/counters/Counter.java:48
↓ 9 callers
Method
getArray
Returns a field in a Json object as an array. Throws IllegalArgumentException if the field value is null. @param object the Json Object @param field
hazelcast/src/main/java/com/hazelcast/internal/util/JsonUtil.java:228
↓ 9 callers
Method
getAttribute
@return the attribute on which this range predicate acts.
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangePredicate.java:29
↓ 9 callers
Method
getBitsNodeId
@see #setBitsNodeId(int)
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:257
↓ 9 callers
Method
getBitsSequence
@see #setBitsSequence(int)
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:235
↓ 9 callers
Method
getById
Returns the OverflowPolicy for the given ID. @return the OverflowPolicy found or null if not found
hazelcast/src/main/java/com/hazelcast/ringbuffer/OverflowPolicy.java:83
↓ 9 callers
Method
getCache
(String name, MergePolicyConfig mergePolicyConfig)
hazelcast/src/test/java/com/hazelcast/internal/config/MergePolicyValidatorCachingProviderIntegrationTest.java:67
↓ 9 callers
Method
getCacheConfig
(String cacheNameWithPrefix)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:473
↓ 9 callers
Method
getCapacity
Returns the capacity of this device. @return device capacity.
hazelcast/src/main/java/com/hazelcast/config/LocalDeviceConfig.java:129
↓ 9 callers
Method
getCapacityPolicy
@return the policy of the capacity setting
hazelcast/src/main/java/com/hazelcast/config/ScheduledExecutorConfig.java:214
↓ 9 callers
Method
getClassCacheMode
Return the current ClassCacheMode @return current ProviderMode
hazelcast/src/main/java/com/hazelcast/config/UserCodeDeploymentConfig.java:250
↓ 9 callers
Method
getClassDefinitionList
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientUserCodeDeploymentService.java:158
↓ 9 callers
Method
getClassFilterConfig
()
hazelcast/src/main/java/com/hazelcast/config/UserCodeNamespacesConfig.java:89
↓ 9 callers
Method
getClassId
Returns the class ID. @return class ID
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinition.java:103
↓ 9 callers
Method
getClassName
@return class name of proxy factory
hazelcast/src/main/java/com/hazelcast/client/config/ProxyFactoryConfig.java:60
↓ 9 callers
Method
getClassName
Returns the name of the class of the EventListener. If no class is specified, null is returned. @return the class name of the EventListener @see #set
hazelcast/src/main/java/com/hazelcast/config/ListenerConfig.java:81
↓ 9 callers
Method
getClientIcmpPingConfig
ICMP ping is used to detect if machine that a remote hazelcast member runs on alive or not @return current configuration for client icmp ping, return
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:523
↓ 9 callers
Method
getClientPolicyConfig
()
hazelcast/src/main/java/com/hazelcast/config/SecurityConfig.java:98
↓ 9 callers
Method
getCollection
()
hazelcast/src/main/java/com/hazelcast/spi/impl/SerializableList.java:42
↓ 9 callers
Method
getConfig
()
hazelcast/src/test/java/com/hazelcast/collection/impl/queue/QueueStoreTest.java:672
↓ 9 callers
Method
getConfig
(String mapName, long maxWbqCapacity)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TransactionsWithWriteBehind_whenNoCoalescingQueueIsFullTest.java:254
↓ 9 callers
Method
getConfigurationUrl
Returns the {@link URL} to the declarative configuration, which has been parsed to create this {@link Config} instance. @return the configuration URL
hazelcast/src/main/java/com/hazelcast/config/Config.java:2860
↓ 9 callers
Method
getCreationTime
Returns the creation time of the merge data. @return the creation time of the merge data
hazelcast/src/main/java/com/hazelcast/spi/merge/MergingCreationTime.java:31
↓ 9 callers
Method
getCreationTime
()
hazelcast/src/main/java/com/hazelcast/map/impl/record/Record.java:95
↓ 9 callers
Method
getDataConnectionName
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcTable.java:91
↓ 9 callers
Method
getDataValue
Gets cache entry value as {@link Data}. @return value as {@link Data}.
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventData.java:66
↓ 9 callers
Method
getDefaultEdgeConfig
Returns the default DAG edge configuration.
hazelcast/src/main/java/com/hazelcast/jet/config/JetConfig.java:338
↓ 9 callers
Method
getDeserializedValue
Returns the merging value in deserialized form. @implNote This method invokes deserialization of the value when called - <b>be careful not to use it
hazelcast/src/main/java/com/hazelcast/spi/merge/MergingValue.java:58
↓ 9 callers
Method
getDictionaryId
Returns the dictionary id for the given word. If the word is not yet stored in the dictionary, the word gets stored and a newly assigned id is returne
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsDictionary.java:47
↓ 9 callers
Method
getDirtyEntryCount
Returns the number of entries that the member owns and are dirty (updated but not persisted yet). dirty entry count is meaningful when there is a pers
hazelcast/src/main/java/com/hazelcast/map/LocalMapStats.java:137
↓ 9 callers
Method
getDiscoveryServiceProvider
()
hazelcast/src/main/java/com/hazelcast/config/DiscoveryConfig.java:71
↓ 9 callers
Method
getDurability
Gets the durability of the executor @return the durability of the executor
hazelcast/src/main/java/com/hazelcast/config/DurableExecutorConfig.java:144
↓ 9 callers
Method
getEffectiveMemberList
<p> Gets the collection of members, or an empty list if the client changed the cluster and the new member list is not received yet. </p> <p> When {@li
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientClusterService.java:68
↓ 9 callers
Method
getEmptyQueueTtl
@return the TTL (time to live) for destroying the Queue (in seconds). <br> Once items have been removed and the Queue has been empty for a giv
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:110
↓ 9 callers
Method
getEventQueue
()
hazelcast/src/test/java/com/hazelcast/wan/impl/WanDummyPublisher.java:70
↓ 9 callers
Method
getEvictionConfigHolder
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/holder/CacheConfigHolder.java:143
↓ 9 callers
Method
getEvictionPolicy
Gets the eviction policy. @return the eviction policy
hazelcast/src/main/java/com/hazelcast/internal/eviction/EvictionConfiguration.java:39
↓ 9 callers
Method
getFactoryId
Returns the factory ID. @return factory ID
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinition.java:96
↓ 9 callers
Method
getFileFromResources
(String resourceFileName)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:652
← previous
next →
7,101–7,200 of 147,315, ranked by callers