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
↓ 24 callers
Method
getActiveMemberNetworkConfig
(Config config)
hazelcast/src/main/java/com/hazelcast/config/ConfigAccessor.java:41
↓ 24 callers
Method
getAge
()
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/utils/Employee.java:70
↓ 24 callers
Method
getBindAddress
Returns a server socket listener address. The returned address for different {@link EndpointQualifier}s may be the same or different, depending on the
hazelcast/src/main/java/com/hazelcast/instance/AddressPicker.java:45
↓ 24 callers
Method
getBrokerConnectionString
()
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:146
↓ 24 callers
Method
getClasses
Returns unmodifiable set of class names.
hazelcast/src/main/java/com/hazelcast/config/ClassFilter.java:74
↓ 24 callers
Method
getComparatorClassName
Gets the class name of the configured {@link EvictionPolicyComparator} implementation. @return class name of the configured {@link EvictionPolicyComp
hazelcast/src/main/java/com/hazelcast/internal/eviction/EvictionConfiguration.java:46
↓ 24 callers
Method
getConfig
Returns a config for the given name, creating one if necessary and adding it to the collection of known configurations. <p> The configuration is found
hazelcast/src/main/java/com/hazelcast/internal/config/ConfigUtils.java:94
↓ 24 callers
Method
getDestName
Returns the name of the destination vertex.
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:217
↓ 24 callers
Method
getDirectory
Returns the directory of this {@link PersistentMemoryDirectoryConfig}. @return the directory
hazelcast/src/main/java/com/hazelcast/config/PersistentMemoryDirectoryConfig.java:78
↓ 24 callers
Method
getEventType
Return the event type @return event type
hazelcast/src/main/java/com/hazelcast/cache/impl/event/ICacheEvent.java:40
↓ 24 callers
Method
getHazelcastClientInstanceImpl
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/client/impl/clientside/ClientTestUtil.java:47
↓ 24 callers
Method
getItemId
()
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueItem.java:75
↓ 24 callers
Method
getJobExecutionService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JetServiceBackend.java:368
↓ 24 callers
Method
getLeft
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/RecurrentStructuresNestedFieldsTest.java:399
↓ 24 callers
Method
getLocalMapStatsImpl
(String name)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:110
↓ 24 callers
Method
getMajor
()
hazelcast/src/main/java/com/hazelcast/version/Version.java:71
↓ 24 callers
Method
getMemberAddressProviderConfig
(Config cfg)
hazelcast/src/test/java/com/hazelcast/config/ConfigXmlGeneratorTest.java:185
↓ 24 callers
Method
getMultiMapStats
()
hazelcast/src/test/java/com/hazelcast/multimap/LocalMultiMapStatsTest.java:68
↓ 24 callers
Method
getName
Returns the name of this data connection as specified in the {@link DataConnectionConfig} or the {@code CREATE DATA CONNECTION} command. @return the
hazelcast/src/main/java/com/hazelcast/dataconnection/DataConnection.java:92
↓ 24 callers
Method
getNewValue
Returns the event new value
hazelcast/src/test/java/com/hazelcast/journal/EventJournalEventAdapter.java:38
↓ 24 callers
Method
getOffset
@return the offset to read the primitive field from. If field is not primitive returns -1
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/FieldDescriptor.java:71
↓ 24 callers
Method
getOwnedEntryCount
@return number of Near Cache entries owned by this member
hazelcast/src/main/java/com/hazelcast/nearcache/NearCacheStats.java:36
↓ 24 callers
Method
getPartition
(int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/InternalPartitionService.java:48
↓ 24 callers
Method
getPreloaderConfig
Returns the {@link NearCachePreloaderConfig} of this Near Cache. @return the {@link NearCachePreloaderConfig} of this Near Cache
hazelcast/src/main/java/com/hazelcast/config/NearCacheConfig.java:374
↓ 24 callers
Method
getRemoveOperationCount
Returns the number of Remove operations @return number of remove operations
hazelcast/src/main/java/com/hazelcast/map/LocalMapStats.java:165
↓ 24 callers
Method
getReplicatedRecordStore
(String name, boolean create, Object key)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/ReplicatedMapService.java:241
↓ 24 callers
Method
getSalt
Returns the salt. @return the salt
hazelcast/src/main/java/com/hazelcast/config/AbstractSymmetricEncryptionConfig.java:83
↓ 24 callers
Method
getSplitBrainMergePolicyProvider
Returns the {@link SplitBrainMergePolicyProvider} for this instance. @return the {@link SplitBrainMergePolicyProvider} @since 3.10
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:307
↓ 24 callers
Method
getSplitBrainProtectionConfig
Returns the {@link SplitBrainProtectionConfig} for the given name, creating one if necessary and adding it to the collection of known configurations.
hazelcast/src/main/java/com/hazelcast/config/Config.java:2358
↓ 24 callers
Method
getSplitBrainProtectionName
Returns the split brain protection name for operations of the data structure. @return the split brain protection name
hazelcast/src/main/java/com/hazelcast/config/SplitBrainPolicyAwareConfig.java:33
↓ 24 callers
Method
getSubscriberContext
Returns {@link SubscriberContext} for this context. @return {@link SubscriberContext} for this context. @see SubscriberContext
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/QueryCacheContext.java:53
↓ 24 callers
Method
getTo
@return the upper/right bound of this range predicate or {@code null} if the predicate range is right-unbounded.
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangePredicate.java:49
↓ 24 callers
Method
getValueClass
()
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:1118
↓ 24 callers
Method
getVersion
()
hazelcast/src/main/java/com/hazelcast/map/impl/record/Record.java:49
↓ 24 callers
Method
getWatermarkedFieldsKey
(RelNode node)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/WatermarkKeysAssigner.java:88
↓ 24 callers
Method
index
Returns the index of the processor that will handle this transaction ID. Used when restoring transaction IDs to determine which processor owns which t
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:352
↓ 24 callers
Method
isSerializeKeys
Checks if the Near Cache key is stored in serialized format or by-reference. @return {@code true} if the key is stored in serialized format, {@code f
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCache.java:183
↓ 24 callers
Method
isUsePublicIp
Checks whether the public or private IP should be used to connect to Hazelcast members. @return {@code true} for public IP, {@code false} for private
hazelcast/src/main/java/com/hazelcast/config/AliasedDiscoveryConfig.java:137
↓ 24 callers
Method
jobContext
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:268
↓ 24 callers
Method
limb
(String name, List<String> tattoos, Finger... fingers)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/extractor/ComplexTestDataStructure.java:161
↓ 24 callers
Method
loadClass
(String name)
hazelcast/src/test/java/com/hazelcast/osgi/TestBundle.java:85
↓ 24 callers
Method
mapResultsToSortedList
(IMap<?, ?> map)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/AbstractCdcIntegrationTest.java:64
↓ 24 callers
Method
naturalOrder
{@code Serializable} variant of {@link Comparator#naturalOrder() java.util.Comparator#naturalOrder()}. @param <T> the {@link Comparable} type of elem
hazelcast/src/main/java/com/hazelcast/function/ComparatorEx.java:65
↓ 24 callers
Method
newNearCacheConfig
()
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/NearCacheTestSupport.java:190
↓ 24 callers
Method
offer
(String queueName, Object value)
hazelcast/src/main/java/com/hazelcast/internal/ascii/TextCommandService.java:29
↓ 24 callers
Method
onEvent
Handle event. @param event type of event.
hazelcast/src/main/java/com/hazelcast/map/impl/ListenerAdapter.java:36
↓ 24 callers
Method
partition
Return the slice of the hash range for partition {@code index} out of {@code count} partitions.
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/HashRange.java:77
↓ 24 callers
Method
populateMap
(Map<Integer, Integer> map, int mapSize)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/NearCacheTestSupport.java:235
↓ 24 callers
Method
populateNearCache
(Map<Integer, ?> map, int mapSize)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/NearCacheTestSupport.java:241
↓ 24 callers
Method
predicate
(String indexName, CompositeValue value, String... components)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/CompositeEqualPredicateTest.java:143
↓ 24 callers
Method
publishLong
Publish the given metric with a long value.
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricsPublisher.java:27
↓ 24 callers
Method
putCheckCommute
(Object value, String operand1, String operand2, Boolean expectedResult, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/AndOrPredicateIntegrationTest.java:242
↓ 24 callers
Method
readCharArray
@return the char array read @throws IOException if it reaches end of file before finish reading
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:62
↓ 24 callers
Method
readInt32
Reads a 32-bit two's complement signed integer. <p> This method can also read a nullable int32, as long as it is not {@code null}. If a {@code null} v
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:138
↓ 24 callers
Method
readLong
(byte[] buffer, int pos, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:179
↓ 24 callers
Method
register
(TextCommandConstants.TextCommandType type, TextCommandProcessor processor)
hazelcast/src/main/java/com/hazelcast/internal/ascii/TextCommandServiceImpl.java:148
↓ 24 callers
Method
removeMessageListener
Stops receiving messages for the given message listener. <p> If the given listener already removed, this method does nothing. @param registrationId I
hazelcast/src/main/java/com/hazelcast/topic/ITopic.java:100
↓ 24 callers
Method
results
(Object... args)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ExtractFunctionIntegrationTest.java:487
↓ 24 callers
Method
setBaseDir
Sets the base directory where the Python files reside. When you set this, also set the name of the {@link #setHandlerModule handler module} to identif
extensions/python/src/main/java/com/hazelcast/jet/python/PythonServiceConfig.java:182
↓ 24 callers
Method
setCacheLoaderFactory
Set the {@link javax.cache.integration.CacheLoader} factory. @param factory the {@link javax.cache.integration.CacheLoader} {@link javax.cache.config
hazelcast/src/main/java/com/hazelcast/config/CacheConfiguration.java:81
↓ 24 callers
Method
setClassCacheMode
Configure caching of classes loaded from remote members. <p> Default: {@link ClassCacheMode#ETERNAL} @return this instance of UserCodeDeploymentConfi
hazelcast/src/main/java/com/hazelcast/config/UserCodeDeploymentConfig.java:240
↓ 24 callers
Method
setDataAdapter
(DataStructureAdapter<K, V> dataAdapter)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestContextBuilder.java:78
↓ 24 callers
Method
setDataInstance
(HazelcastInstance dataInstance)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestContextBuilder.java:68
↓ 24 callers
Method
setDefaultsDisabled
Sets whether the default serialization filters are disabled. @param defaultsDisabled {@code true} to disable defaults, {@code false} otherwise @retur
hazelcast/src/main/java/com/hazelcast/config/JavaSerializationFilterConfig.java:116
↓ 24 callers
Method
setHandlerModule
Sets the name of the Python module that has the function that transforms Jet pipeline data.
extensions/python/src/main/java/com/hazelcast/jet/python/PythonServiceConfig.java:255
↓ 24 callers
Method
setTypes
Sets the expected type of keys and values for a {@link javax.cache.Cache} configured with this {@link javax.cache.configuration.Configuration}. Settin
hazelcast/src/main/java/com/hazelcast/config/CacheConfiguration.java:53
↓ 24 callers
Method
string
(Object value)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/misc/CastFunctionIntegrationTest.java:1227
↓ 24 callers
Method
timeInMsOrOneIfResultIsZero
Convert time to milliseconds based on the given time unit. If conversion result is 0 and {@code time} was > 0, then 1 is returned. @param time
hazelcast/src/main/java/com/hazelcast/internal/util/TimeUtil.java:70
↓ 24 callers
Method
uncheckCall
(@Nonnull Callable<T> callable)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:165
↓ 24 callers
Method
valueOf
(boolean isMadeProgress, boolean isDone)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ProgressState.java:41
↓ 24 callers
Method
with
(Config memberConfig)
hazelcast/src/test/java/com/hazelcast/test/bounce/BounceMemberRule.java:297
↓ 24 callers
Method
writeStringArray
@param values String array to be written @throws IOException in case of any exceptional case
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataOutput.java:102
↓ 23 callers
Method
add
(final Integer value)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/IntHashSet.java:61
↓ 23 callers
Method
addMultiMapConfig
Adds the multimap configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtaine
hazelcast/src/main/java/com/hazelcast/config/Config.java:1333
↓ 23 callers
Method
assertListContent
(List<Object> list)
hazelcast/src/test/java/com/hazelcast/collection/impl/list/ListSplitBrainTest.java:268
↓ 23 callers
Method
assertMapEventually
Execute a query and assert that it eventually returns the expected entries. @param mapName The IMap name @param sql The query @param expected E
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:141
↓ 23 callers
Method
assertNoOptimization
(Predicate original)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/EvaluateVisitorTest.java:197
↓ 23 callers
Method
assertNotContains
(String expected)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/AbstractDiagnosticsPluginTest.java:56
↓ 23 callers
Method
assertQueueContent
(Queue<Object> queue)
hazelcast/src/test/java/com/hazelcast/collection/impl/queue/QueueSplitBrainTest.java:299
↓ 23 callers
Method
assertRingbufferContent
(Ringbuffer<Object> ringbuffer, int expectedSize)
hazelcast/src/test/java/com/hazelcast/ringbuffer/RingbufferSplitBrainTest.java:331
↓ 23 callers
Method
assertSetContent
(Set<Object> set)
hazelcast/src/test/java/com/hazelcast/collection/impl/set/SetSplitBrainTest.java:267
↓ 23 callers
Method
assertSummedMetricValue
(String metricName, long expectedValue)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetricsChecker.java:62
↓ 23 callers
Method
assertThrowsNPE
(ConsumerEx<HazelcastInstance> method)
hazelcast/src/test/java/com/hazelcast/instance/AbstractHazelcastInstanceNullTest.java:59
↓ 23 callers
Method
bitWidthOf
@return the bit width required to represent the given value.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastIntegerType.java:187
↓ 23 callers
Method
call
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/operations/ReadManyOperation.java:64
↓ 23 callers
Method
checkConverterSelf
(Converter converter)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:1103
↓ 23 callers
Method
clientFn
Set the client supplier function <p> The connector uses the returned instance to access Elasticsearch. Also see {@link ElasticClients} for convenience
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/ElasticSinkBuilder.java:99
↓ 23 callers
Method
constant
Creates an {@code IntervalFunction} which returns a fixed interval in milliseconds.
hazelcast/src/main/java/com/hazelcast/jet/retry/IntervalFunction.java:38
↓ 23 callers
Method
container
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/Contexts.java:417
↓ 23 callers
Method
defaultDatabase
()
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/AbstractMongoTest.java:133
↓ 23 callers
Method
equals
(Object o)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/schema/model/Person.java:41
↓ 23 callers
Method
equals
(Object o)
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/InputRef.java:64
↓ 23 callers
Method
expectInvalid
()
hazelcast/src/test/java/com/hazelcast/config/InvalidConfigurationTest.java:332
↓ 23 callers
Method
forceNext
Generates the next unique call ID. This never blocks and it should be used only for urgent operation or when retrying. @return the generated call ID
hazelcast/src/main/java/com/hazelcast/spi/impl/sequence/CallIdSequence.java:69
↓ 23 callers
Method
get
(IMap map, Object key)
hazelcast/src/test/java/com/hazelcast/map/InterceptorTest.java:80
↓ 23 callers
Method
get
(@Nonnull String fieldName, @Nonnull FieldKind primitiveFieldKind, @Nonnull FieldKind nu
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/DeserializedGenericRecord.java:567
↓ 23 callers
Method
get
(long key)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2LongMap.java:24
↓ 23 callers
Method
getBoolean
Returns the configured boolean value of a {@link HazelcastProperty}. @param property the {@link HazelcastProperty} to get the value from @return the
hazelcast/src/main/java/com/hazelcast/spi/properties/HazelcastProperties.java:186
↓ 23 callers
Method
getByteOrder
@return ByteOrder BIG_ENDIAN or LITTLE_ENDIAN
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:143
↓ 23 callers
Method
getCatalogReader
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/logical/UpdateLogicalRel.java:86
← previous
next →
3,801–3,900 of 147,315, ranked by callers