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
↓ 10 callers
Method
identity
Returns a projection that does no transformation. <p> If you use the returned projection in a 3.9 cluster it may cause a serialization exception. @par
hazelcast/src/main/java/com/hazelcast/projection/Projections.java:40
↓ 10 callers
Method
ifNotExists
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlCreateJob.java:82
↓ 10 callers
Method
illegalStateException
(IOException cause)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/DefaultCompactWriter.java:164
↓ 10 callers
Method
increment
(String operation)
hazelcast/src/test/java/com/hazelcast/map/standalone/SimpleFunctionalMapTest.java:174
↓ 10 callers
Method
incrementSetLatencyNanos
(long latencyNanos)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalMapStatsImpl.java:524
↓ 10 callers
Method
infiniteValueError
(QueryDataTypeFamily target)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/Converter.java:371
↓ 10 callers
Method
init
(InitialMembershipEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/TranslateToPublicAddressProvider.java:167
↓ 10 callers
Method
init
(SerializationService ss, Object key, Object value, Extractors extractors)
hazelcast/src/main/java/com/hazelcast/query/impl/CachedQueryEntry.java:60
↓ 10 callers
Method
init
Initialize the recordStore after creation
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:522
↓ 10 callers
Method
injectDependencies
(T obj)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:297
↓ 10 callers
Method
insert
(Object key, Object value)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapStoreTest.java:1305
↓ 10 callers
Method
inspectOutOfMemoryError
(Throwable throwable)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:150
↓ 10 callers
Method
intHash
(final int value, final int mask)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Hashing.java:29
↓ 10 callers
Method
invalidateNearCache
(List<Data> keys)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperation.java:409
↓ 10 callers
Method
invoke
(CollectionOperation operation)
hazelcast/src/main/java/com/hazelcast/collection/impl/collection/AbstractCollectionProxyImpl.java:242
↓ 10 callers
Method
invokeOnTarget
(String serviceName, Operation op, Address target)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationServiceImpl.java:391
↓ 10 callers
Method
invokeWithPredicate
(ClientMessage request, Predicate predicate)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientMapProxy.java:1324
↓ 10 callers
Method
isAtLeast
Check if the current runtime version is greater than or equal to the given version. Returns false if the given version is UNKNOWN.
hazelcast/src/main/java/com/hazelcast/internal/util/JavaVersion.java:61
↓ 10 callers
Method
isAutoRemoveStaleData
Returns whether automatic removal of stale Persistence restart data is enabled. @return whether automatically removal of stale data is enabled
hazelcast/src/main/java/com/hazelcast/config/PersistenceConfig.java:227
↓ 10 callers
Method
isCatalogPersistenceEnabled
Returns {@code true} if persistence is enabled for SQL Catalog. @return {@code true} if persistence is enabled for SQL Catalog
hazelcast/src/main/java/com/hazelcast/config/SqlConfig.java:78
↓ 10 callers
Method
isCooperative
Tells whether this processor is able to participate in cooperative multithreading. If this processor declares itself cooperative, it will share a thre
hazelcast/src/main/java/com/hazelcast/jet/core/Processor.java:144
↓ 10 callers
Method
isDestroyed
Determines whether this Cache instance has been destroyed. @return <code>true</code> if this Cache instance is destroyed; <code>false</code> if it is
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:917
↓ 10 callers
Method
isDisablePerEntryInvalidationEvents
Returns invalidation events disabled status for per entry. @return {@code true} if invalidation events are disabled for per entry, {@code false} othe
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:503
↓ 10 callers
Method
isDoubleRepresentable
@return {@code true} if instances of the given class can be represented as double values without any magnitude and precision losses, {@code false} oth
hazelcast/src/main/java/com/hazelcast/query/impl/Numbers.java:262
↓ 10 callers
Method
isEnabled
Returns true if User Code Deployment is enabled @return {@code true} when User Code Deployment is enabled
hazelcast/src/main/java/com/hazelcast/config/UserCodeDeploymentConfig.java:91
↓ 10 callers
Method
isEnabled
Checks if this PartitionGroupConfig is enabled. @return {@code true} if this PartitionGroupConfig is enabled, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/PartitionGroupConfig.java:193
↓ 10 callers
Method
isEnabled
()
hazelcast/src/main/java/com/hazelcast/config/MemberAddressProviderConfig.java:47
↓ 10 callers
Method
isEnabled
Returns if the event journal is enabled. @return {@code true} if the event journal is enabled, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/EventJournalConfig.java:152
↓ 10 callers
Method
isLaterThan
(MembersView other)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembersView.java:150
↓ 10 callers
Method
isLocalMemberMaster
Returns true only if local member is the last known master by {@code InternalPartitionServiceImpl}. <p> Last known master is updated under partition s
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:1386
↓ 10 callers
Method
isLocalMemberSafe
Checks whether local member is in safe state. <p> Safe state means; all backups of partitions currently owned by local member are in sync when this me
hazelcast/src/main/java/com/hazelcast/partition/PartitionService.java:146
↓ 10 callers
Method
isLongRepresentable
@return {@code true} if instances of the given class can be represented as long values without any magnitude and precision losses, {@code false} other
hazelcast/src/main/java/com/hazelcast/query/impl/Numbers.java:271
↓ 10 callers
Method
isMadeProgress
()
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ProgressState.java:33
↓ 10 callers
Method
isManagementEnabled
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheMXBeanImpl.java:69
↓ 10 callers
Method
isPersistWanReplicatedData
@return {@code true} when persistence of replicated data into backing store is enabled, otherwise returns {@code false}. By default, this method retur
hazelcast/src/main/java/com/hazelcast/config/WanConsumerConfig.java:136
↓ 10 callers
Method
isShutdown
@return true if the client is shutdown.
hazelcast/src/main/java/com/hazelcast/client/util/ClientStateListener.java:222
↓ 10 callers
Method
isSnapshotEnabled
Returns {@code true} if key-based coalescing is configured for this WAN publisher. When enabled, only the latest {@link WanEvent} of a key is sent to
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:177
↓ 10 callers
Method
isStartCompleted
@return {@code true} if this {@code Node} has completed startup, {@code false} otherwise. @see NodeExtension#isStartCompleted()
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:263
↓ 10 callers
Method
isStatisticsEnabled
Checks if statistics are enabled for this reliable topic. @return {@code true} if enabled, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/ReliableTopicConfig.java:250
↓ 10 callers
Method
isTemporal
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataTypeFamily.java:132
↓ 10 callers
Method
isVisible
Asserts that the {@code job} is already visible by {@linkplain JetService#getJob} methods. @param client Hazelcast Instance used to query the clu
hazelcast/src/test/java/com/hazelcast/jet/core/JobAssertions.java:87
↓ 10 callers
Method
jobConfig
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:197
↓ 10 callers
Method
join
Concatenates {@code leftRow} and {@code rightRow} into one, evaluates the {@code predicate} on it, and if the predicate passed, returns the joined row
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/ExpressionUtil.java:155
↓ 10 callers
Method
jsonArrayRow
(final Object... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/json/JsonArrayFunctionIntegrationTest.java:120
↓ 10 callers
Method
keySet
Transactional implementation of {@link IMap#keySet()}. @see IMap#keySet()
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:239
↓ 10 callers
Method
liteMember
(String host)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/ClientClusterServiceBaseTest.java:418
↓ 10 callers
Method
load
Get 'load' recorded by the current pipeline. It can be used to calculate whether this pipeline should be migrated to a different {@link NioThread} @r
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/MigratablePipeline.java:55
↓ 10 callers
Method
loadClass
(Map<String, String> options, boolean isKey)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataJavaResolver.java:243
↓ 10 callers
Method
localSync
()
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/CdcSinksTest.java:314
↓ 10 callers
Method
longHash
(final long value, final int mask)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Hashing.java:33
↓ 10 callers
Method
mapToRequestFn
Set the function mapping the item from a pipeline item to an index request <p> For example, to create an IndexRequest for a versioned document: <pre>{
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/ElasticSinkBuilder.java:143
↓ 10 callers
Method
mapWithMerging
Returns a sink that uses the supplied functions to extract the key and value with which to update a Hazelcast {@code IMap}. If the map already contain
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sinks.java:395
↓ 10 callers
Method
mapping
Adapts an aggregate operation that takes items of type {@code U} to one that takes items of type {@code T}, by applying the given mapping function to
hazelcast/src/main/java/com/hazelcast/jet/aggregate/AggregateOperations.java:605
↓ 10 callers
Method
matchIndex
Matches an index for the given pattern and match hint. @param pattern the pattern to match an index for. May be either an
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:499
↓ 10 callers
Method
maxAttempts
Sets the maximum number of retry attempts.
hazelcast/src/main/java/com/hazelcast/jet/retry/RetryStrategies.java:75
↓ 10 callers
Method
member
(String host)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/TranslateToPublicAddressProviderTest.java:222
↓ 10 callers
Method
mergePolicyConfig
(String mergePolicy, int batchSize)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/dynamicconfig/AbstractUpdateConfigMessageTask.java:89
↓ 10 callers
Method
moveAttachedFilesToPipeline
(@Nonnull ServiceFactory<?, S> serviceFactory)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:464
↓ 10 callers
Method
named
Decorate any {@link Runnable} with a {@link NamedTask} to provide naming information to scheduler. @param name The name that the task will have @
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/TaskUtils.java:39
↓ 10 callers
Method
nanValueError
(QueryDataTypeFamily target)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/Converter.java:377
↓ 10 callers
Method
newDefaultCacheConfig
(String name)
hazelcast/src/test/java/com/hazelcast/config/helpers/CacheConfigHelper.java:57
↓ 10 callers
Method
newDelegatingFuture
(ClientInvocationFuture future, ClientMessageDecoder decoder)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:1208
↓ 10 callers
Method
newExpirationManager
(HazelcastInstance node)
hazelcast/src/test/java/com/hazelcast/internal/eviction/AbstractExpirationManagerTest.java:231
↓ 10 callers
Method
newExtractor
()
hazelcast/src/test/java/com/hazelcast/query/impl/QueryEntryTest.java:248
↓ 10 callers
Method
newTransactionContext
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/queue/TransactionalQueueSplitBrainProtectionWriteTest.java:176
↓ 10 callers
Method
next
()
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/RandomizedRateTracker.java:45
↓ 10 callers
Method
next
()
hazelcast/src/main/java/com/hazelcast/internal/util/iterator/RestartingMemberIterator.java:104
↓ 10 callers
Method
nextCompletionId
()
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:1158
↓ 10 callers
Method
nextPowerOfTwo
Fast method of finding the next power of 2 greater than or equal to the supplied value. <p> If the value is <= 0 then 1 will be returned. <p> This
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/util/BitUtil.java:40
↓ 10 callers
Method
nextSequence
Returns next number in sequence for the partition. @return next number in sequence.
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/sequence/PartitionSequencer.java:38
↓ 10 callers
Method
normalSize
returns the number of normal operations pending. This method is thread safe. This method returns a best effort value and should only be used for mon
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationQueue.java:69
↓ 10 callers
Method
not
@return an iterator that represents a result of negation of the given iterator over the given universe (a set of known elements).
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithms.java:51
↓ 10 callers
Method
notDone
Equivalent to {@code mergeWith(NO_PROGRESS)}, but more descriptive in certain usages.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ProgressTracker.java:71
↓ 10 callers
Method
or
@return an iterator that represents a result of union over the given iterators.
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithms.java:43
↓ 10 callers
Method
parseString
Create instance from String @param string the string value to parse @return instance of {@link CacheDeserializedValues} @throws IllegalArgumentExcept
hazelcast/src/main/java/com/hazelcast/config/CacheDeserializedValues.java:63
↓ 10 callers
Method
partitionIdSet
(PartitionIdSet partitionIdSet)
hazelcast/src/main/java/com/hazelcast/map/impl/query/Query.java:222
↓ 10 callers
Method
prepareMetricsService
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/MetricsServiceTest.java:380
↓ 10 callers
Method
printlnBold
(Object obj)
hazelcast/src/main/java/com/hazelcast/client/console/ClientConsoleApp.java:1582
↓ 10 callers
Method
properties
()
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:52
↓ 10 callers
Method
put
(final Integer key, final V value)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Int2ObjectHashMap.java:200
↓ 10 callers
Method
putCacheConfigIfAbsent
(CacheConfig config)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:79
↓ 10 callers
Method
putFloat
Writes the given float value to given address. @param address the address where the float value will be written to @param x the float value to
hazelcast/src/main/java/com/hazelcast/internal/memory/MemoryAccessor.java:128
↓ 10 callers
Method
queryIndexedDateFieldAsNullValue
(boolean ordered, Predicate<Integer, SampleTestObjects
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryNullIndexingTest.java:135
↓ 10 callers
Method
queue
Retrieves the queue backing this inbox.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ArrayDequeInbox.java:78
↓ 10 callers
Method
quoteCompoundIdentifier
Quote the given compound identifier using Calcite dialect (= Hazelcast dialect). You can use this when giving information to the user, e.g. in excepti
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/QuoteIdentifierUtil.java:65
↓ 10 callers
Method
readFloat
(int position)
hazelcast/src/main/java/com/hazelcast/internal/nio/BufferObjectDataInput.java:55
↓ 10 callers
Method
readMap
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:275
↓ 10 callers
Method
readNullableBoolean
Reads a nullable boolean. <p> This method can also read a non-nullable boolean. @param fieldName name of the field. @return the value of the field. @
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:532
↓ 10 callers
Method
readRequiredChar
(char ch)
hazelcast/src/main/java/com/hazelcast/internal/json/JsonParser.java:292
↓ 10 callers
Method
readRequiredChar
(char ch)
hazelcast/src/main/java/com/hazelcast/internal/json/JsonReducedValueParser.java:150
↓ 10 callers
Method
readResponse
(InputStream is)
hazelcast/src/test/java/com/hazelcast/client/impl/clientside/ClientTestUtil.java:84
↓ 10 callers
Method
readUnsignedShort
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:111
↓ 10 callers
Method
reduce
An alternative to {@link Stream#reduce(Object, BiFunction, BinaryOperator) Stream.reduce(identity, accumulator, combiner)}, which is not parallelizabl
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:407
↓ 10 callers
Method
registerListener
Registers a listener on all cluster nodes. @param serviceName service name @param topic topic name @param listener listener instance @return
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/EventService.java:96
↓ 10 callers
Method
registerMetric
(Metric metric, final int value)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/HealthMonitorTest.java:63
↓ 10 callers
Method
releaseAwaitingTask
()
hazelcast/src/test/java/com/hazelcast/executor/CompletableFutureTest.java:297
↓ 10 callers
Method
remoteMapBuilder
Returns a builder to build a source that fetches entries from a remote Hazelcast {@code IMap} with the specified name. It provides a fluent API to bui
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:663
↓ 10 callers
Method
remoteMapJournal
Returns a source that will stream the {@link EventJournalMapEvent} events of the Hazelcast {@code IMap} with the specified name from a remote cluster.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:716
↓ 10 callers
Method
remove
(K key, long now, UUID transactionId)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:51
↓ 10 callers
Method
removeEntry
Removes the given entry from this index. @param entry the entry to remove. @param operationSource the operation source. @throws QueryExcept
hazelcast/src/main/java/com/hazelcast/query/impl/Index.java:109
← previous
next →
6,801–6,900 of 147,315, ranked by callers