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
↓ 2 callers
Method
findPropertyAccessor
( @Nonnull Class<?> clazz, @Nonnull String propertyName, @Nonnull String..
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ReflectionUtils.java:228
↓ 2 callers
Method
findPrunedAndNonPrunedInstance
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/SqlPrunedMemberLeftTest.java:140
↓ 2 callers
Method
findQueryCacheConfigFromMapConfig
(MapConfig mapConfig, String cacheName)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/NodeQueryCacheConfigurator.java:84
↓ 2 callers
Method
findQueueConfig
Returns a read-only {@link IQueue} configuration for the given name. <p> The name is matched by pattern to the configuration and by stripping the part
hazelcast/src/main/java/com/hazelcast/config/Config.java:984
↓ 2 callers
Method
findResource
(String name)
hazelcast/src/test/java/com/hazelcast/internal/util/ServiceLoaderTest.java:684
↓ 2 callers
Method
findResource
(String name)
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/JetClassLoader.java:73
↓ 2 callers
Method
findResource
(String name)
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/MapResourceClassLoader.java:208
↓ 2 callers
Method
findResources
(String name)
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/JetClassLoader.java:86
↓ 2 callers
Method
findRootCause
(Throwable t)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlErrorAbstractTest.java:213
↓ 2 callers
Method
findThreadCount
(int configuredThreadCount)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:340
↓ 2 callers
Method
findValue
(int key, SimpleEntry<Integer, Integer>[] values)
hazelcast/src/test/java/com/hazelcast/client/replicatedmap/ClientReplicatedMapTest.java:1035
↓ 2 callers
Method
findYearOwnedBy
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/map/MapIndexLifecycleTest.java:370
↓ 2 callers
Method
fingerprint64
Calculates the fingerprint of the schema from its type name and fields.
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/RabinFingerprint.java:48
↓ 2 callers
Method
finishFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperationImpl.java:106
↓ 2 callers
Method
finishIndexMarking
(Queue<InternalIndex> notIndexedPartitions)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MergeOperation.java:187
↓ 2 callers
Method
fireConnectionEvent
(TcpClientConnection connection, boolean isAdded)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:740
↓ 2 callers
Method
fireConnectionRemovedEvent
(final Connection connection, final Address endPoint)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnectionManagerBase.java:243
↓ 2 callers
Method
fixDependencies
(ChannelHandler addedHandler)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioInboundPipeline.java:239
↓ 2 callers
Method
flatMapFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/FlatMapTransform.java:50
↓ 2 callers
Method
flatMapUsingServiceAsyncBatchedP
( @Nonnull ServiceFactory<C, S> serviceFactory, int maxConcurrentOps, int
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/ProcessorTransform.java:153
↓ 2 callers
Method
flatMapUsingServiceAsyncP
( @Nonnull ServiceFactory<C, S> serviceFactory, int maxConcurrentOps, bool
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/ProcessorTransform.java:139
↓ 2 callers
Method
flatten
(final Class<?> clazz, final Collection<Class<?>> result)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/ProbeUtils.java:28
↓ 2 callers
Method
flipState
(ClusterState state)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/AdvancedClusterStateTest.java:703
↓ 2 callers
Method
flush
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncSocket.java:280
↓ 2 callers
Method
flush
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataOutputStream.java:286
↓ 2 callers
Method
flush
()
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/IMapOutputStream.java:85
↓ 2 callers
Method
flush
Flushes the supplied key to the map-store. @param key key to be flushed @param value value to be flushed @param backup <code>true</code> calling
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:141
↓ 2 callers
Method
flushBuffer
(boolean isLastPart)
extensions/s3/src/main/java/com/hazelcast/jet/s3/S3Sinks.java:225
↓ 2 callers
Method
flushBuffers
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/SlidingWindowP.java:475
↓ 2 callers
Method
flushInternal
(List<DelayedEntry> delayedEntries)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/DefaultWriteBehindProcessor.java:276
↓ 2 callers
Method
flushPartition
(int partitionId)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/AsyncSnapshotWriterImpl.java:221
↓ 2 callers
Method
footprint
Returns the current memory consumption (in bytes) @return the current memory consumption
hazelcast/src/main/java/com/hazelcast/internal/util/collection/OAHashSet.java:321
↓ 2 callers
Method
forAllReplicationContainers
(BiConsumer<WanPublisher, Object> publisherContainerConsumer)
hazelcast/src/main/java/com/hazelcast/wan/impl/WanEventContainerReplicationOperation.java:88
↓ 2 callers
Method
forEachMatchingService
@param serviceClass the class/interface the service should implement. @param consumer to consume {@link ServiceInfo}
hazelcast/src/main/java/com/hazelcast/spi/impl/servicemanager/ServiceManager.java:66
↓ 2 callers
Method
forceCreateBackupLogs
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionImpl.java:386
↓ 2 callers
Method
forceEvictAndRun0
(MapOperation mapOperation, double evictionPercentage, Runnable runnable)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/SingleRecordStoreForcedEviction.java:45
↓ 2 callers
Method
forceEvictAndRun0
(MapOperation mapOperation, double evictionPercentage, Runnable runnable)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MultipleRecordStoreForcedEviction.java:50
↓ 2 callers
Method
forceEvictByPercentage
(RecordStore recordStore, double evictionPercentage)
hazelcast/src/main/java/com/hazelcast/map/impl/eviction/Evictor.java:39
↓ 2 callers
Method
forceLocalMemberToBeSafe
Force the local member to be safe by checking and syncing partitions owned by the local member with at least one of the backups. @param timeout the t
hazelcast/src/main/java/com/hazelcast/partition/PartitionService.java:156
↓ 2 callers
Method
forget
(Xid xid)
hazelcast/src/main/java/com/hazelcast/transaction/impl/xa/XAResourceImpl.java:213
↓ 2 callers
Method
formatClassAndValue
(Object value, String valueString)
hazelcast/src/main/java/com/hazelcast/jet/core/test/JetAssert.java:98
↓ 2 callers
Method
formatDuration
@see <a href="https://github.com/hazelcast/hazelcast/pull/25028#discussion_r1266692838">Discussion</a>
hazelcast/src/test/java/com/hazelcast/partition/PartitionMigrationListenerTest.java:452
↓ 2 callers
Method
formatEntry
(int s)
hazelcast/src/test/java/com/hazelcast/jet/core/PeekingWrapperTest.java:357
↓ 2 callers
Method
formatJobs
(boolean isLightJob)
hazelcast/src/main/java/com/hazelcast/jet/impl/operation/GetJobIdsOperation.java:192
↓ 2 callers
Method
frameAsBytes
(ClientMessage.Frame frame, boolean isLastFrame)
hazelcast/src/test/java/com/hazelcast/client/impl/clientside/ClientTestUtil.java:69
↓ 2 callers
Method
free
(long address)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:78
↓ 2 callers
Method
free0
(long address, long size)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/HeapMemoryManager.java:146
↓ 2 callers
Method
freePhysicalMemory
Returns the amount of physical memory that is available on the system in bytes or -1 if not available. @return free physical memory in bytes or -1 if
hazelcast/src/main/java/com/hazelcast/internal/memory/MemoryStatsSupport.java:50
↓ 2 callers
Method
from
(Map<String, String> options)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/kafka/PropertiesResolver.java:108
↓ 2 callers
Method
from
(QueryDataType targetType, int index, SqlParserPos parserPosition)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/param/AbstractParameterConverter.java:101
↓ 2 callers
Method
from
(@Nonnull JsonObject statefulSet)
hazelcast/src/main/java/com/hazelcast/kubernetes/RuntimeContext.java:157
↓ 2 callers
Method
fromClass
(@Nonnull Class<?>... classes)
hazelcast/src/main/java/com/hazelcast/jet/config/ResourceConfig.java:92
↓ 2 callers
Method
fromColumns
(List<SqlColumnType> columnTypes, List<List<?>> columns, boolean last)
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlPage.java:57
↓ 2 callers
Method
fromEvent
(Event event)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/MCEventDTO.java:38
↓ 2 callers
Method
fromId
(int id)
hazelcast/src/main/java/com/hazelcast/config/BitmapIndexOptions.java:111
↓ 2 callers
Method
fromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalWanPublisherStatsImpl.java:146
↓ 2 callers
Method
fromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/TimedMemberState.java:185
↓ 2 callers
Method
fromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/WanConsumerConfigDTO.java:56
↓ 2 callers
Method
fromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/WanReplicationConfigDTO.java:65
↓ 2 callers
Method
fromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/DiscoveryStrategyConfigDTO.java:58
↓ 2 callers
Method
fromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/AliasedDiscoveryConfigDTO.java:63
↓ 2 callers
Method
fromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/DiscoveryConfigDTO.java:57
↓ 2 callers
Method
fromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/WanSyncConfigDTO.java:48
↓ 2 callers
Method
fromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/SlowOperationDTO.java:70
↓ 2 callers
Method
function
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/AbstractGauge.java:118
↓ 2 callers
Method
generateErrorMessage
(String codecName, String cause)
hazelcast/src/test/java/com/hazelcast/client/protocol/CodecHashTest.java:85
↓ 2 callers
Method
generateInterceptorId
(String mapName, MapInterceptor interceptor)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContextInterceptorSupport.java:90
↓ 2 callers
Method
generateMapEvents
(IMap<String, Person> map, AllListener listener)
hazelcast/src/test/java/com/hazelcast/map/MapListenerTest.java:87
↓ 2 callers
Method
generateProxyForInterface
Generates a JDK dynamic proxy implementing the expected interfaces.
hazelcast/src/test/java/com/hazelcast/test/starter/HazelcastProxyFactory.java:227
↓ 2 callers
Method
generateRandomIntegerList
(int count)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapAbstractTest.java:120
↓ 2 callers
Method
generateReliableTopicNameForPartition
(HazelcastInstance instance, int partitionId)
hazelcast/src/test/java/com/hazelcast/topic/impl/reliable/SubscriptionMigrationTest.java:131
↓ 2 callers
Method
get
(Metric metric)
hazelcast-sql/src/test/java/com/hazelcast/internal/util/phonehome/SqlPhoneHomeTest.java:52
↓ 2 callers
Method
get
(@Nonnull List<Address> addresses)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/map/SpecificPartitionsImapReaderPms.java:106
↓ 2 callers
Method
get
(Class<T> clazz)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardQueue.java:58
↓ 2 callers
Method
get
(@Nonnull Address address, int streamId)
hazelcast/src/test/java/com/hazelcast/test/mocknetwork/MockServer.java:104
↓ 2 callers
Method
get
(int id)
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestMigrationAwareService.java:103
↓ 2 callers
Method
get
(String name, int id)
hazelcast/src/test/java/com/hazelcast/internal/partition/service/fragment/TestFragmentedMigrationAwareService.java:157
↓ 2 callers
Method
get
(@Nonnull Address address, int streamId)
hazelcast/src/test/java/com/hazelcast/internal/server/FirewallingServer.java:280
↓ 2 callers
Method
get
()
hazelcast/src/main/java/com/hazelcast/function/SupplierEx.java:43
↓ 2 callers
Method
get
()
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/impl/DistributedObjectFuture.java:45
↓ 2 callers
Method
get
@param source the source object. @return the current value of the source object. @throws Exception if something fails while getting the value.
hazelcast/src/main/java/com/hazelcast/internal/metrics/DoubleProbeFunction.java:33
↓ 2 callers
Method
get
()
hazelcast/src/main/java/com/hazelcast/internal/longregister/LongRegister.java:26
↓ 2 callers
Method
get
(K key)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/ReadOptimizedLruCache.java:76
↓ 2 callers
Method
get
(long sequence)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/DefaultCyclicBuffer.java:87
↓ 2 callers
Method
get
Gets record from {@link RecordStore}. Loads missing keys from map store. @param dataKey key. @param backup {@code true} if a backup partition, other
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:168
↓ 2 callers
Method
get
(int index)
hazelcast/src/main/java/com/hazelcast/json/internal/JsonPattern.java:68
↓ 2 callers
Method
get
(String v)
hazelcast/src/main/java/com/hazelcast/config/LoginModuleConfig.java:66
↓ 2 callers
Method
get
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMultiMap.java:47
↓ 2 callers
Method
get0
(long timeout, TimeUnit unit)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientScheduledFutureProxy.java:195
↓ 2 callers
Method
get0
()
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledFutureProxy.java:139
↓ 2 callers
Method
getAccumulatorInfoOrNull
Returns {@link AccumulatorInfo} for cache of ma{@code IMap}p. @param mapName map name. @param cacheId cache name. @return {@link AccumulatorInfo} for
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/AccumulatorInfoSupplier.java:34
↓ 2 callers
Method
getAccumulatorOrNull
Returns {@code Accumulator} of a partition. @see Accumulator
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/utils/QueryCacheUtil.java:73
↓ 2 callers
Method
getActions
()
hazelcast/src/test/java/com/hazelcast/security/permission/AbstractMapPermissionTest.java:27
↓ 2 callers
Method
getActions
()
hazelcast/src/test/java/com/hazelcast/security/permission/MapPermissionTest.java:32
↓ 2 callers
Method
getActiveClientsInCluster
Returns the map of the active clients connected to the cluster. Mapping is from the client type to client count.
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEngine.java:108
↓ 2 callers
Method
getActiveConnections
()
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:694
↓ 2 callers
Method
getActiveMigration
(int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:78
↓ 2 callers
Method
getActiveMigrations
()
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionRuntimeState.java:144
↓ 2 callers
Method
getActiveMigrations
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:80
↓ 2 callers
Method
getActiveRegistrations
(final UUID uuid)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/listener/ClientListenerServiceImpl.java:320
← previous
next →
17,901–18,000 of 147,315, ranked by callers