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
↓ 21 callers
Method
addMigrationListener
Adds a MigrationListener. <p> The addMigrationListener returns a register ID. This ID is needed to remove the MigrationListener using the {@link #remo
hazelcast/src/main/java/com/hazelcast/partition/PartitionService.java:68
↓ 21 callers
Method
addVectorIndexConfig
Adds a vector index configuration to this vector collection configuration. @param vectorIndexConfig the vector index configuration to add @return thi
hazelcast/src/main/java/com/hazelcast/config/vector/VectorCollectionConfig.java:135
↓ 21 callers
Method
alwaysFalse
Creates an <b>always false</b> predicate that will filter out all items. @param <K> the type of keys the predicate operates on. @param <V> the type of
hazelcast/src/main/java/com/hazelcast/query/Predicates.java:211
↓ 21 callers
Method
assertQueryPlan
(String query)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/SqlEndToEndTestSupport.java:113
↓ 21 callers
Method
assertTipOfStream
Execute the given `sql` and assert that the first rows it returns are those in `expectedRows`. Ignores the rest of rows. <p> This is useful for assert
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:288
↓ 21 callers
Method
awaitTermination
(long timeout, @Nonnull TimeUnit unit)
hazelcast/src/test/java/com/hazelcast/jet/core/TestUtil.java:138
↓ 21 callers
Method
bit
(int bit, long value)
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapTest.java:201
↓ 21 callers
Method
broadcastConfig
Registers a dynamic configurations to all cluster members. @param config configuration to register
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:65
↓ 21 callers
Method
check
(String sql, Integer expectedResult, Object... parameters)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/PositionFunctionIntegrationTest.java:154
↓ 21 callers
Method
checkLiteral
(Object literal, SqlColumnType expectedType, Object expectedValue)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/AbsFunctionIntegrationTest.java:218
↓ 21 callers
Method
clear
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:109
↓ 21 callers
Method
converter
(TypeConverter... converters)
hazelcast/src/test/java/com/hazelcast/query/impl/CompositeConverterTest.java:93
↓ 21 callers
Method
createConcurrentHashMap
Utility method that creates an {@link java.util.LinkedHashMap} with its initialCapacity calculated to minimize rehash operations
hazelcast/src/main/java/com/hazelcast/internal/util/MapUtil.java:62
↓ 21 callers
Method
createCursor
Creates a new cursor from given attribute path.
hazelcast/src/main/java/com/hazelcast/query/impl/getters/JsonPathCursor.java:59
↓ 21 callers
Method
createEntry
(String key, String value)
hazelcast/src/test/java/com/hazelcast/query/impl/QueryEntryTest.java:242
↓ 21 callers
Method
createManagedMap
(String configName)
hazelcast-spring/src/main/java/com/hazelcast/spring/HazelcastConfigBeanDefinitionParser.java:307
↓ 21 callers
Method
createMapping
(String name, boolean simple)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlPrimitiveTest.java:61
↓ 21 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/TopicPublishAllCodec.java:86
↓ 21 callers
Method
decodeRequest
Query ID.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlCloseCodec.java:74
↓ 21 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MultiMapPutAllCodec.java:89
↓ 21 callers
Method
deregister
()
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:363
↓ 21 callers
Method
deregisterListener
(@Nonnull UUID registrationId)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientListenerService.java:36
↓ 21 callers
Method
divisionByZeroError
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/DivideOperatorIntegrationTest.java:417
↓ 21 callers
Method
doGet
(String url)
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:479
↓ 21 callers
Method
enableGroups
Enables provided REST endpoint groups. It doesn't replace already enabled groups.
hazelcast/src/main/java/com/hazelcast/config/RestApiConfig.java:66
↓ 21 callers
Method
encodeRequest
(java.lang.String name, java.util.Collection<com.hazelcast.internal.serialization.Data> messages)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/TopicPublishAllCodec.java:72
↓ 21 callers
Method
encodeRequest
(java.lang.String sql, java.util.Collection<com.hazelcast.internal.serialization.Data> parameters, long timeou
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlExecuteCodec.java:118
↓ 21 callers
Method
encodeRequest
(java.lang.String sql, java.util.Collection<com.hazelcast.internal.serialization.Data> parameters, long timeou
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlExecute_reservedCodec.java:87
↓ 21 callers
Method
encodeRequest
(java.lang.String name, java.util.Collection<java.util.Map.Entry<com.hazelcast.internal.serialization.Data, ja
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MultiMapPutAllCodec.java:75
↓ 21 callers
Method
encodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/TopicPublishAllCodec.java:96
↓ 21 callers
Method
encodeResponse
(@Nullable java.util.List<com.hazelcast.sql.SqlColumnMetadata> rowMetadata, @Nullable com.hazelcast.sql.impl.c
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlExecuteCodec.java:203
↓ 21 callers
Method
encodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlCloseCodec.java:81
↓ 21 callers
Method
encodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MultiMapPutAllCodec.java:99
↓ 21 callers
Method
equals
(Object o)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetEvent.java:72
↓ 21 callers
Method
field
(String name, QueryDataType type)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataAvroResolverTest.java:220
↓ 21 callers
Method
flatMap
(@Nonnull FunctionEx<? super T, ? extends Traverser<R>> flatMapFn)
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:122
↓ 21 callers
Method
from
Returns an edge with the given source vertex and no destination vertex. The ordinal of the edge is 0. Typically followed by one of the {@code to()} me
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:144
↓ 21 callers
Method
fromString
(String value)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/SelectorMode.java:43
↓ 21 callers
Method
getBean
(String name)
hazelcast-spring/src/main/java/com/hazelcast/spring/jet/JetSpringServiceFactories.java:116
↓ 21 callers
Method
getCPSubsystemConfig
Get current configuration for the CP subsystem @return CP subsystem configuration @since 3.12
hazelcast/src/main/java/com/hazelcast/config/Config.java:2991
↓ 21 callers
Method
getCacheLoaderFactory
Gets the factory for the {@link javax.cache.integration.CacheLoader}. @return the factory for the {@link javax.cache.integration.CacheLoader}
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:321
↓ 21 callers
Method
getCacheWriterFactory
Gets the factory for the {@link javax.cache.integration.CacheWriter}. @return the factory for the {@link javax.cache.integration.CacheWriter}
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:369
↓ 21 callers
Method
getComponentType
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastDynamicTableFunction.java:286
↓ 21 callers
Method
getConfig
Gets the configuration of the cache that this store belongs to. @return {@link CacheConfig}
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheRecordStore.java:393
↓ 21 callers
Method
getDataKey
Gets cache entry key as {@link Data}. @return key as {@link Data}.
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventData.java:60
↓ 21 callers
Method
getDataNewValue
()
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/QueryCacheEventData.java:37
↓ 21 callers
Method
getDirectoryConfigs
Returns the persistent memory directory configurations to be used to store memory structures allocated by native memory manager. <p> By default, there
hazelcast/src/main/java/com/hazelcast/config/PersistentMemoryConfig.java:92
↓ 21 callers
Method
getExpiryPolicyFactoryConfig
Gets the factory configuration for the {@link javax.cache.expiry.ExpiryPolicy}. @return the factory configuration for the {@link javax.cache.expiry.E
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:417
↓ 21 callers
Method
getFactoryImplementation
()
hazelcast/src/test/java/com/hazelcast/config/MapStoreConfigTest.java:156
↓ 21 callers
Method
getHazelcastInstance
Gets the underlying {@link HazelcastInstance} implementation. @return the underlying {@link HazelcastInstance} implementation
hazelcast/src/main/java/com/hazelcast/cache/HazelcastCacheManager.java:50
↓ 21 callers
Method
getInstanceName
()
hazelcast/src/main/java/com/hazelcast/internal/ascii/TextCommandService.java:100
↓ 21 callers
Method
getJobCoordinationService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JetServiceBackend.java:360
↓ 21 callers
Method
getMap
()
hazelcast/src/test/java/com/hazelcast/map/impl/tx/LocalTxnMapStatsTest.java:70
↓ 21 callers
Method
getMemoryTierConfig
Returns memory tier configuration for this index. @return memory tier configuration for this index.
hazelcast/src/main/java/com/hazelcast/config/BTreeIndexConfig.java:78
↓ 21 callers
Method
getMergePolicy
(String dataStructureName)
hazelcast/src/main/java/com/hazelcast/map/impl/MapMergeRunnable.java:78
↓ 21 callers
Method
getMultiMap
()
hazelcast/src/test/java/com/hazelcast/multimap/LocalMultiMapStatsTest.java:76
↓ 21 callers
Method
getObjectName
Gets the object name within the service. @return the object name within the service
hazelcast/src/main/java/com/hazelcast/internal/services/ObjectNamespace.java:29
↓ 21 callers
Method
getOption
Gets an option value. @param option the option @param <T> the type of the value @return null if value is null. @throws com.hazelcast.core.HazelcastEx
hazelcast/src/main/java/com/hazelcast/internal/networking/ChannelOptions.java:48
↓ 21 callers
Method
getPartitionOwner
Gets the owner of the partition if it's set. <p> If the owner of the partition is not set yet, it will trigger partition assignment. @param partition
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:53
↓ 21 callers
Method
getProtocolType
()
hazelcast/src/main/java/com/hazelcast/config/EndpointConfig.java:116
↓ 21 callers
Method
getSchemaId
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/Schema.java:173
↓ 21 callers
Method
getSsl
Gets the SSL configuration. @return the SSL configuration.
hazelcast/src/main/java/com/hazelcast/config/rest/RestConfig.java:664
↓ 21 callers
Method
getStats
Gathers statistics of related {@link WanPublisher} instance. This method will always return the same instance. NOTE: used only in Hazelcast Enterprise
hazelcast/src/main/java/com/hazelcast/wan/impl/InternalWanPublisher.java:126
↓ 21 callers
Method
getSteadyMember
@return cluster member that stays up for the duration of the test
hazelcast/src/test/java/com/hazelcast/test/bounce/BounceMemberRule.java:168
↓ 21 callers
Method
getString
Returns the configured value of a {@link HazelcastProperty} as String. @param property the {@link HazelcastProperty} to get the value from @return th
hazelcast/src/main/java/com/hazelcast/spi/properties/HazelcastProperties.java:116
↓ 21 callers
Method
getTarget
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastTable.java:148
↓ 21 callers
Method
getThisUuid
Returns UUID of the local member. @return member UUID
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:66
↓ 21 callers
Method
getTpcSocketConfig
Gets the TpcSocketConfig. @return the TpcSocketConfig @see TpcConfig @since 5.3
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:427
↓ 21 callers
Method
getType
Returns serialization type of binary form. It's defined by {@link Serializer#getTypeId()} @return serializer type ID
hazelcast/src/main/java/com/hazelcast/internal/serialization/Data.java:41
↓ 21 callers
Method
getYamlRoot
()
hazelcast/src/test/java/com/hazelcast/internal/yaml/YamlTest.java:448
↓ 21 callers
Method
init
Initializes this processor with the outbox that the <em>processing methods</em> must use to deposit their output items. This method will be called exa
hazelcast/src/main/java/com/hazelcast/jet/core/Processor.java:161
↓ 21 callers
Method
isDone
()
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:518
↓ 21 callers
Method
isNumaNodeSet
Returns if the NUMA node for the given persistent memory directory is set. @return {@code true} if the NUMA node is set, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/PersistentMemoryDirectoryConfig.java:123
↓ 21 callers
Method
isPersistWanReplicatedData
()
hazelcast/src/main/java/com/hazelcast/map/impl/wan/MapWanContext.java:154
↓ 21 callers
Method
isSerializeKeys
Checks if the Near Cache key is stored in serialized format or by-reference. <p> <b>NOTE:</b> When the in-memory-format is {@code NATIVE}, this method
hazelcast/src/main/java/com/hazelcast/config/NearCacheConfig.java:197
↓ 21 callers
Method
isUrgent
Checks if this OutboundFrame is urgent. <p> Frames that are urgent, have priority above regular frames. This is useful to implement system operations
hazelcast/src/main/java/com/hazelcast/internal/networking/OutboundFrame.java:54
↓ 21 callers
Method
mapName
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlOrderByTest.java:1181
↓ 21 callers
Method
mapUsingServiceAsync
( @Nonnull ServiceFactory<?, S> serviceFactory, @Nonnull BiFunctionEx<? super S, ? sup
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:152
↓ 21 callers
Method
message
@param message event message. May be {@code null} @return this instance
hazelcast/src/main/java/com/hazelcast/auditlog/EventBuilder.java:38
↓ 21 callers
Method
newDescriptor
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/jmx/JmxPublisherTest.java:310
↓ 21 callers
Method
newId
Generates and returns a cluster-wide unique ID. <p> Operation on a member is always local, if the member has valid node ID, otherwise it's remote. On
hazelcast/src/main/java/com/hazelcast/flakeidgen/FlakeIdGenerator.java:106
↓ 21 callers
Method
newIdBaseLocal
(int batchSize)
hazelcast/src/main/java/com/hazelcast/flakeidgen/impl/FlakeIdGeneratorProxy.java:148
↓ 21 callers
Method
newMapConfig
(String mapName)
hazelcast/src/test/java/com/hazelcast/map/EvictionTest.java:1307
↓ 21 callers
Method
of
Returns an instance of {@link Capacity}. @param value value of the capacity @param unit unit of the capacity @return a {@link Capacity} instance
hazelcast/src/main/java/com/hazelcast/memory/Capacity.java:108
↓ 21 callers
Method
preferLocalParallelismOne
Wraps the provided {@code ProcessorSupplier} into a meta-supplier that will always return it. The {@link #preferredLocalParallelism()} of the meta-sup
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorMetaSupplier.java:410
↓ 21 callers
Method
prefix
Returns the prefix of the metric denoted by this instance. @return the prefix
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:43
↓ 21 callers
Method
publishEvent
Publish an event to the event subsystem. Note: Exceptions during publications are caught and logged. @param caller the address of the caller that
hazelcast/src/main/java/com/hazelcast/map/impl/event/MapEventPublisher.java:70
↓ 21 callers
Method
putBiValue
(Object field1, Object field2, ExpressionType<?> type1, ExpressionType<?> type2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/ComparisonPredicateIntegrationTest.java:509
↓ 21 callers
Method
putIfAbsent
Associates {@code key} with {@code value} only if {@code key} is not present. @param key non-null key of the entry @param value non-null value of the
hazelcast/src/main/java/com/hazelcast/cp/CPMap.java:54
↓ 21 callers
Method
readDoubleArray
@return double array read @throws IOException if it reaches end of file before finish reading
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:83
↓ 21 callers
Method
readShortArray
@return short array read @throws IOException if it reaches end of file before finish reading
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:97
↓ 21 callers
Method
readUnsignedByte
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:100
↓ 21 callers
Method
reset
Resets the counter that prevents adding more than {@code batchSize} items until this method is called again. Note that the counter may jump to the "fu
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/OutboxInternal.java:28
↓ 21 callers
Method
setConsumerThread
Sets the consumer thread. <p> The consumer thread is needed for blocking, so that an offering known which thread to wakeup. There can only be a single
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/MPSCQueue.java:88
↓ 21 callers
Method
setCreationTime
(long creationTime)
hazelcast/src/main/java/com/hazelcast/map/impl/record/Record.java:99
↓ 21 callers
Method
setMembers
Sets the well known members. <p> If members are empty, calling this method will have the same effect as calling {@link #clear()}. <p> A member can be
hazelcast/src/main/java/com/hazelcast/config/TcpIpConfig.java:121
↓ 21 callers
Method
setStoreMetricsAfterJobCompletion
Sets whether metrics should be stored in the cluster after the job completes. If enabled, metrics can be retrieved for the configured job after it has
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1376
↓ 21 callers
Method
sinkList
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineTestSupport.java:144
↓ 21 callers
Method
startNewSnapshotPhase1
This method is called when the member received {@link SnapshotPhase1Operation}.
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/SnapshotContext.java:212
↓ 21 callers
Method
storage
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/AbstractSchemaStorage.java:46
← previous
next →
4,101–4,200 of 147,315, ranked by callers