MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 2 callersMethodfindPropertyAccessor
( @Nonnull Class<?> clazz, @Nonnull String propertyName, @Nonnull String..
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ReflectionUtils.java:228
↓ 2 callersMethodfindPrunedAndNonPrunedInstance
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/SqlPrunedMemberLeftTest.java:140
↓ 2 callersMethodfindQueryCacheConfigFromMapConfig
(MapConfig mapConfig, String cacheName)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/NodeQueryCacheConfigurator.java:84
↓ 2 callersMethodfindQueueConfig
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 callersMethodfindResource
(String name)
hazelcast/src/test/java/com/hazelcast/internal/util/ServiceLoaderTest.java:684
↓ 2 callersMethodfindResource
(String name)
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/JetClassLoader.java:73
↓ 2 callersMethodfindResource
(String name)
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/MapResourceClassLoader.java:208
↓ 2 callersMethodfindResources
(String name)
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/JetClassLoader.java:86
↓ 2 callersMethodfindRootCause
(Throwable t)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlErrorAbstractTest.java:213
↓ 2 callersMethodfindThreadCount
(int configuredThreadCount)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:340
↓ 2 callersMethodfindValue
(int key, SimpleEntry<Integer, Integer>[] values)
hazelcast/src/test/java/com/hazelcast/client/replicatedmap/ClientReplicatedMapTest.java:1035
↓ 2 callersMethodfindYearOwnedBy
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/map/MapIndexLifecycleTest.java:370
↓ 2 callersMethodfingerprint64
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 callersMethodfinishFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperationImpl.java:106
↓ 2 callersMethodfinishIndexMarking
(Queue<InternalIndex> notIndexedPartitions)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MergeOperation.java:187
↓ 2 callersMethodfireConnectionEvent
(TcpClientConnection connection, boolean isAdded)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:740
↓ 2 callersMethodfireConnectionRemovedEvent
(final Connection connection, final Address endPoint)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnectionManagerBase.java:243
↓ 2 callersMethodfixDependencies
(ChannelHandler addedHandler)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioInboundPipeline.java:239
↓ 2 callersMethodflatMapFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/FlatMapTransform.java:50
↓ 2 callersMethodflatMapUsingServiceAsyncBatchedP
( @Nonnull ServiceFactory<C, S> serviceFactory, int maxConcurrentOps, int
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/ProcessorTransform.java:153
↓ 2 callersMethodflatMapUsingServiceAsyncP
( @Nonnull ServiceFactory<C, S> serviceFactory, int maxConcurrentOps, bool
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/ProcessorTransform.java:139
↓ 2 callersMethodflatten
(final Class<?> clazz, final Collection<Class<?>> result)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/ProbeUtils.java:28
↓ 2 callersMethodflipState
(ClusterState state)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/AdvancedClusterStateTest.java:703
↓ 2 callersMethodflush
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncSocket.java:280
↓ 2 callersMethodflush
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataOutputStream.java:286
↓ 2 callersMethodflush
()
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/IMapOutputStream.java:85
↓ 2 callersMethodflush
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 callersMethodflushBuffer
(boolean isLastPart)
extensions/s3/src/main/java/com/hazelcast/jet/s3/S3Sinks.java:225
↓ 2 callersMethodflushBuffers
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/SlidingWindowP.java:475
↓ 2 callersMethodflushInternal
(List<DelayedEntry> delayedEntries)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/DefaultWriteBehindProcessor.java:276
↓ 2 callersMethodflushPartition
(int partitionId)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/AsyncSnapshotWriterImpl.java:221
↓ 2 callersMethodfootprint
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 callersMethodforAllReplicationContainers
(BiConsumer<WanPublisher, Object> publisherContainerConsumer)
hazelcast/src/main/java/com/hazelcast/wan/impl/WanEventContainerReplicationOperation.java:88
↓ 2 callersMethodforEachMatchingService
@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 callersMethodforceCreateBackupLogs
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionImpl.java:386
↓ 2 callersMethodforceEvictAndRun0
(MapOperation mapOperation, double evictionPercentage, Runnable runnable)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/SingleRecordStoreForcedEviction.java:45
↓ 2 callersMethodforceEvictAndRun0
(MapOperation mapOperation, double evictionPercentage, Runnable runnable)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MultipleRecordStoreForcedEviction.java:50
↓ 2 callersMethodforceEvictByPercentage
(RecordStore recordStore, double evictionPercentage)
hazelcast/src/main/java/com/hazelcast/map/impl/eviction/Evictor.java:39
↓ 2 callersMethodforceLocalMemberToBeSafe
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 callersMethodforget
(Xid xid)
hazelcast/src/main/java/com/hazelcast/transaction/impl/xa/XAResourceImpl.java:213
↓ 2 callersMethodformatClassAndValue
(Object value, String valueString)
hazelcast/src/main/java/com/hazelcast/jet/core/test/JetAssert.java:98
↓ 2 callersMethodformatDuration
@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 callersMethodformatEntry
(int s)
hazelcast/src/test/java/com/hazelcast/jet/core/PeekingWrapperTest.java:357
↓ 2 callersMethodformatJobs
(boolean isLightJob)
hazelcast/src/main/java/com/hazelcast/jet/impl/operation/GetJobIdsOperation.java:192
↓ 2 callersMethodframeAsBytes
(ClientMessage.Frame frame, boolean isLastFrame)
hazelcast/src/test/java/com/hazelcast/client/impl/clientside/ClientTestUtil.java:69
↓ 2 callersMethodfree
(long address)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:78
↓ 2 callersMethodfree0
(long address, long size)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/HeapMemoryManager.java:146
↓ 2 callersMethodfreePhysicalMemory
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 callersMethodfrom
(Map<String, String> options)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/kafka/PropertiesResolver.java:108
↓ 2 callersMethodfrom
(QueryDataType targetType, int index, SqlParserPos parserPosition)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/param/AbstractParameterConverter.java:101
↓ 2 callersMethodfrom
(@Nonnull JsonObject statefulSet)
hazelcast/src/main/java/com/hazelcast/kubernetes/RuntimeContext.java:157
↓ 2 callersMethodfromClass
(@Nonnull Class<?>... classes)
hazelcast/src/main/java/com/hazelcast/jet/config/ResourceConfig.java:92
↓ 2 callersMethodfromColumns
(List<SqlColumnType> columnTypes, List<List<?>> columns, boolean last)
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlPage.java:57
↓ 2 callersMethodfromEvent
(Event event)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/MCEventDTO.java:38
↓ 2 callersMethodfromId
(int id)
hazelcast/src/main/java/com/hazelcast/config/BitmapIndexOptions.java:111
↓ 2 callersMethodfromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalWanPublisherStatsImpl.java:146
↓ 2 callersMethodfromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/TimedMemberState.java:185
↓ 2 callersMethodfromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/WanConsumerConfigDTO.java:56
↓ 2 callersMethodfromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/WanReplicationConfigDTO.java:65
↓ 2 callersMethodfromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/DiscoveryStrategyConfigDTO.java:58
↓ 2 callersMethodfromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/AliasedDiscoveryConfigDTO.java:63
↓ 2 callersMethodfromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/DiscoveryConfigDTO.java:57
↓ 2 callersMethodfromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/WanSyncConfigDTO.java:48
↓ 2 callersMethodfromJson
(JsonObject json)
hazelcast/src/main/java/com/hazelcast/internal/management/dto/SlowOperationDTO.java:70
↓ 2 callersMethodfunction
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/AbstractGauge.java:118
↓ 2 callersMethodgenerateErrorMessage
(String codecName, String cause)
hazelcast/src/test/java/com/hazelcast/client/protocol/CodecHashTest.java:85
↓ 2 callersMethodgenerateInterceptorId
(String mapName, MapInterceptor interceptor)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContextInterceptorSupport.java:90
↓ 2 callersMethodgenerateMapEvents
(IMap<String, Person> map, AllListener listener)
hazelcast/src/test/java/com/hazelcast/map/MapListenerTest.java:87
↓ 2 callersMethodgenerateProxyForInterface
Generates a JDK dynamic proxy implementing the expected interfaces.
hazelcast/src/test/java/com/hazelcast/test/starter/HazelcastProxyFactory.java:227
↓ 2 callersMethodgenerateRandomIntegerList
(int count)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapAbstractTest.java:120
↓ 2 callersMethodgenerateReliableTopicNameForPartition
(HazelcastInstance instance, int partitionId)
hazelcast/src/test/java/com/hazelcast/topic/impl/reliable/SubscriptionMigrationTest.java:131
↓ 2 callersMethodget
(Metric metric)
hazelcast-sql/src/test/java/com/hazelcast/internal/util/phonehome/SqlPhoneHomeTest.java:52
↓ 2 callersMethodget
(@Nonnull List<Address> addresses)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/map/SpecificPartitionsImapReaderPms.java:106
↓ 2 callersMethodget
(Class<T> clazz)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardQueue.java:58
↓ 2 callersMethodget
(@Nonnull Address address, int streamId)
hazelcast/src/test/java/com/hazelcast/test/mocknetwork/MockServer.java:104
↓ 2 callersMethodget
(int id)
hazelcast/src/test/java/com/hazelcast/internal/partition/service/TestMigrationAwareService.java:103
↓ 2 callersMethodget
(String name, int id)
hazelcast/src/test/java/com/hazelcast/internal/partition/service/fragment/TestFragmentedMigrationAwareService.java:157
↓ 2 callersMethodget
(@Nonnull Address address, int streamId)
hazelcast/src/test/java/com/hazelcast/internal/server/FirewallingServer.java:280
↓ 2 callersMethodget
()
hazelcast/src/main/java/com/hazelcast/function/SupplierEx.java:43
↓ 2 callersMethodget
()
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/impl/DistributedObjectFuture.java:45
↓ 2 callersMethodget
@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 callersMethodget
()
hazelcast/src/main/java/com/hazelcast/internal/longregister/LongRegister.java:26
↓ 2 callersMethodget
(K key)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/ReadOptimizedLruCache.java:76
↓ 2 callersMethodget
(long sequence)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/DefaultCyclicBuffer.java:87
↓ 2 callersMethodget
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 callersMethodget
(int index)
hazelcast/src/main/java/com/hazelcast/json/internal/JsonPattern.java:68
↓ 2 callersMethodget
(String v)
hazelcast/src/main/java/com/hazelcast/config/LoginModuleConfig.java:66
↓ 2 callersMethodget
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMultiMap.java:47
↓ 2 callersMethodget0
(long timeout, TimeUnit unit)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientScheduledFutureProxy.java:195
↓ 2 callersMethodget0
()
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledFutureProxy.java:139
↓ 2 callersMethodgetAccumulatorInfoOrNull
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 callersMethodgetAccumulatorOrNull
Returns {@code Accumulator} of a partition. @see Accumulator
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/utils/QueryCacheUtil.java:73
↓ 2 callersMethodgetActions
()
hazelcast/src/test/java/com/hazelcast/security/permission/AbstractMapPermissionTest.java:27
↓ 2 callersMethodgetActions
()
hazelcast/src/test/java/com/hazelcast/security/permission/MapPermissionTest.java:32
↓ 2 callersMethodgetActiveClientsInCluster
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 callersMethodgetActiveConnections
()
hazelcast/src/main/java/com/hazelcast/client/impl/connection/tcp/TcpClientConnectionManager.java:694
↓ 2 callersMethodgetActiveMigration
(int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:78
↓ 2 callersMethodgetActiveMigrations
()
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionRuntimeState.java:144
↓ 2 callersMethodgetActiveMigrations
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:80
↓ 2 callersMethodgetActiveRegistrations
(final UUID uuid)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/listener/ClientListenerServiceImpl.java:320
← previousnext →17,901–18,000 of 147,315, ranked by callers