MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

⨍ Functions 147,315◇ Types & classes 15,944
↓ 3 callersMethodid
Returns the identifier of this resource. For example, for a {@code CLASS} type resource it can be the fully-qualified name of the class. @return the i
hazelcast/src/main/java/com/hazelcast/internal/namespace/ResourceDefinition.java:29
↓ 3 callersMethodidleTime
(EvictableEntryView entryView)
hazelcast/src/test/java/com/hazelcast/internal/eviction/impl/comparator/LRUEvictionPolicyComparatorTest.java:66
↓ 3 callersMethodimportDocuments
Imports external YAML documents into the provided main YAML document. <p> Since the YAML configuration uses mappings, in order to keep the configurati
hazelcast/src/main/java/com/hazelcast/config/AbstractYamlConfigBuilder.java:89
↓ 3 callersMethodincAccepted
Increases the number of accepted sockets by 1.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncServerSocketMetrics.java:45
↓ 3 callersMethodincBytesRead
Increases the bytes read. @param delta the amount to increase.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncSocketMetrics.java:54
↓ 3 callersMethodincBytesWritten
Increases the bytes written. @param delta the amount to increase.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncSocketMetrics.java:72
↓ 3 callersMethodincReadEvents
Increases the number of read events by 1.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncSocketMetrics.java:106
↓ 3 callersMethodincWriteEvents
Increases the number of write events by 1.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncSocketMetrics.java:89
↓ 3 callersMethodincreaseEntryCount
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheContext.java:37
↓ 3 callersMethodincrementActiveTxnIndex
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TransactionPoolSnapshotUtility.java:269
↓ 3 callersMethodincrementHeapCost
(long heapCost)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:532
↓ 3 callersMethodincrementOwnedEntryCount
()
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/NearCacheStatsImpl.java:133
↓ 3 callersMethodincrementPublishedEventCount
(long latency)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalWanPublisherStatsImpl.java:133
↓ 3 callersMethodincrementQueryResultSizeExceededCount
()
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalMapStatsImpl.java:562
↓ 3 callersMethodincrementRemovesNanos
(long latencyNanos)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalReplicatedMapStatsImpl.java:282
↓ 3 callersMethodindexForDefaultType
(final int typeId)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:160
↓ 3 callersMethodindexOf
(Object o)
extensions/avro/src/main/java/com/hazelcast/jet/avro/impl/AvroSerializerHooks.java:300
↓ 3 callersMethodinit
(ProcessingGuarantee guarantee)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SlidingWindowP_failoverTest.java:53
↓ 3 callersMethodinit
(ProcessingGuarantee guarantee)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SessionWindowP_failoverTest.java:52
↓ 3 callersMethodinit
Initializes record store.
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheRecordStore.java:353
↓ 3 callersMethodinit
(byte[] data, int offset)
hazelcast/src/main/java/com/hazelcast/internal/nio/BufferObjectDataInput.java:75
↓ 3 callersMethodinitClockOffsetTest
Sets up the test to use Hazelcast classes off a separate classloader so that the clock offset can be set to any arbitrary value. This is necessary for
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/impl/AbstractSplitBrainProtectionFunctionTest.java:139
↓ 3 callersMethodinitFails
()
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/TaskletExecutionServiceTest.java:461
↓ 3 callersMethodinitHazelcastInstances
()
hazelcast/src/test/java/com/hazelcast/instance/impl/AbstractOutOfMemoryHandlerTest.java:60
↓ 3 callersMethodinitInstanceAndMapContainer
(String name)
hazelcast/src/test/java/com/hazelcast/wan/impl/WanReplicationConfigurationTest.java:135
↓ 3 callersMethodinitMultiTypeObject
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/json/JsonValueFunctionIntegrationTest.java:280
↓ 3 callersMethodinitOrGetListOf
(List<T> list)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/AndPredicate.java:114
↓ 3 callersMethodinitSelectionKey
()
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioPipeline.java:134
↓ 3 callersMethodinitShardedIndex
Creates an index with given name with 3 shards
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/BaseElasticTest.java:134
↓ 3 callersMethodinitializeDistributedObject
(String serviceName, String objectId, UUID source)
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/ProxyService.java:36
↓ 3 callersMethodinitializeLogging
()
hazelcast/src/test/java/com/hazelcast/test/TestLoggingUtils.java:37
↓ 3 callersMethodinitializeProcessor
( String destinationName, boolean isQueue, FunctionEx<Message, String> pro
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/StreamJmsPTest.java:171
↓ 3 callersMethodinjectDependencies
(Object obj)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventListenerAdaptor.java:134
↓ 3 callersMethodinnerHashJoin
( @Nonnull BatchStage<T1_IN> stage1, @Nonnull JoinClause<K, ? super T, ? super T1_IN,
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:257
↓ 3 callersMethodinsert
(long key, long value)
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapTest.java:153
↓ 3 callersMethodinsertAndAssertRecords
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlAvroSchemaEvolutionTest.java:253
↓ 3 callersMethodinsertInitialRecordAndAlterSchema
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlAvroSchemaEvolutionTest.java:235
↓ 3 callersMethodinstancesResponseForNetworkInterfaces
Response recorded from the real Cloud Compute API call.
hazelcast/src/test/java/com/hazelcast/azure/AzureComputeApiTest.java:146
↓ 3 callersMethodinstancesResponseForPublicIPAddresses
()
hazelcast/src/test/java/com/hazelcast/azure/AzureComputeApiTest.java:325
↓ 3 callersMethodintAtAddress
(long address)
hazelcast/src/main/java/com/hazelcast/internal/util/sort/IntMemArrayQuickSorter.java:67
↓ 3 callersMethodintAtIndex
(long index)
hazelcast/src/main/java/com/hazelcast/internal/util/sort/IntMemArrayQuickSorter.java:63
↓ 3 callersMethodinteger
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/util/ThreadAffinity.java:251
↓ 3 callersMethodintegerSequenceSource
(boolean addFaultTolerance)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/SourceBuilderTest.java:507
↓ 3 callersMethodinterceptAfterRemove
Intercept the remove operation after the value is removed. <p> This method can modify the input {@Code value}, so use with caution. @param intercepto
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContextInterceptorSupport.java:88
↓ 3 callersMethodinterceptRemove
Intercepts the remove operation before removing the data. <p> Returns the object to be returned as the result of the remove operation. Throwing an exc
hazelcast/src/main/java/com/hazelcast/map/MapInterceptor.java:141
↓ 3 callersMethodinternalBuffer
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCompressor.java:462
↓ 3 callersMethodinternalSetUp
(int partitionCount, int clusterSize, int limit, int preCheckTrigger)
hazelcast/src/test/java/com/hazelcast/map/MapUnboundedReturnValuesTestSupport.java:135
↓ 3 callersMethodinternalSetUpClient
(int partitionCount, int clusterSize, int limit, int preCheckTrigger)
hazelcast/src/test/java/com/hazelcast/client/map/ClientMapUnboundReturnValuesTestSupport.java:116
↓ 3 callersMethodinterruptThreads
(Thread[] threads)
hazelcast/src/test/java/com/hazelcast/collection/impl/txnqueue/TransactionQueueTest.java:437
↓ 3 callersMethodintersects
Returns whether the intersection of this set with given argument is not empty. @return {@code true} when the intersection of {@code this} and {@code
hazelcast/src/main/java/com/hazelcast/internal/util/collection/PartitionIdSet.java:207
↓ 3 callersMethodinvalidEvictionConfig
(boolean isNearCache, boolean isIMap)
hazelcast-spring/src/test/java/com/hazelcast/spring/config/ConfigFactoryTest.java:144
↓ 3 callersMethodinvocationToString
()
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:113
↓ 3 callersMethodinvoke
()
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/InvocationFuture_CancelTest.java:90
↓ 3 callersMethodinvoke
(K key, EntryProcessor<K, V, T> entryProcessor, Object... arguments)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxy.java:234
↓ 3 callersMethodinvoke
(NodeEngine nodeEngine, TransactionLogRecord transactionLogRecord, Operation op)
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionLog.java:128
↓ 3 callersMethodinvokeAsync
(HazelcastInstance instance, boolean throwsException)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/CompletableFutureTestUtil.java:52
↓ 3 callersMethodinvokeBackupExpiryOperation
(Collection<ExpiredKey> expiredKeys, int backupReplicaCount, int p
hazelcast/src/main/java/com/hazelcast/internal/eviction/ToBackupSender.java:89
↓ 3 callersMethodinvokeClusterOp
(Operation op, Address target)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:907
↓ 3 callersMethodinvokeFetchMembersViewOp
(Address target, UUID targetUuid)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:1038
↓ 3 callersMethodinvokeOnAllMembers
(Registration reg, Supplier<Operation> operationSupplier)
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/impl/EventServiceImpl.java:355
↓ 3 callersMethodinvokeOnConnection
For testing only.
hazelcast/src/main/java/com/hazelcast/sql/impl/client/SqlClientService.java:418
↓ 3 callersMethodinvokeOnMaster
Invokes an {@link Operation} on the {@code master} member of the cluster, on behalf of the service defined by the provided {@code serviceName}. <p><b
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationService.java:242
↓ 3 callersMethodinvokeOnSelection
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientInvocation.java:173
↓ 3 callersMethodinvokeOnStableClusterParallelExcludeLocal
( NodeEngine nodeEngine, Supplier<Operation> operationSupplier, int maxRet
hazelcast/src/main/java/com/hazelcast/internal/util/InvocationUtil.java:140
↓ 3 callersMethodinvokeRequestNoRetryOnRandom
(UUID uuid, ClientMessage request)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetClientInstanceImpl.java:336
↓ 3 callersMethodinvokeRequestOnAnyMemberAndDecodeResponse
(ClientMessage request, Function<ClientMessage, Ob
hazelcast/src/main/java/com/hazelcast/jet/impl/JetClientInstanceImpl.java:330
↓ 3 callersMethodinvokeSync
(HazelcastInstance instance, boolean throwsException)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/CompletableFutureTestUtil.java:43
↓ 3 callersMethodisAbsentInPartitionTable
(Member member)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateManager.java:98
↓ 3 callersMethodisAcceptedSuffixConfigured
Checks if the suffix of the passed {@code configFile} is in the accepted suffixes list passed in {@code acceptedSuffixes}. @param configFile Th
hazelcast/src/main/java/com/hazelcast/internal/config/DeclarativeConfigUtil.java:142
↓ 3 callersMethodisAfterLostEvents
Returns {@code true} if lost events were detected before this event in the journal. @return {@code true} if earlier events were lost, {@code false} ot
hazelcast/src/main/java/com/hazelcast/map/EventJournalMapEvent.java:69
↓ 3 callersMethodisAligned
(long address)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/HsaHeapMemoryManager.java:73
↓ 3 callersMethodisAlive
()
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnection.java:188
↓ 3 callersMethodisAlive
Returns true if the tracked member is considered as alive/available. @param timestamp timestamp in milliseconds @return true if the member is alive
hazelcast/src/main/java/com/hazelcast/internal/cluster/fd/FailureDetector.java:36
↓ 3 callersMethodisAnalyzed
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/SqlPlanImpl.java:1225
↓ 3 callersMethodisAuthenticationConfigured
()
hazelcast/src/main/java/com/hazelcast/config/security/RealmConfig.java:168
↓ 3 callersMethodisAutoDisposable
(Object command)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorServiceProxy.java:540
↓ 3 callersMethodisAutoStepDownWhenLeader
Returns whether this CP member is configured to automatically step down from leadership in non-metadata CP groups. <p>If {@code true}, whenever this
hazelcast/src/main/java/com/hazelcast/cp/CPMember.java:85
↓ 3 callersMethodisBackup
(RecordStore recordStore)
hazelcast/src/main/java/com/hazelcast/map/impl/eviction/EvictorImpl.java:138
↓ 3 callersMethodisBinaryFormat
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferStoreWrapper.java:220
↓ 3 callersMethodisBindToSingleConnection
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientInvocation.java:381
↓ 3 callersMethodisBounded
(RelNode rel)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:261
↓ 3 callersMethodisCheckIfLoaded
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:250
↓ 3 callersMethodisChunkedMigrationEnabled
()
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/PartitionReplicaSyncRequest.java:290
↓ 3 callersMethodisClassAvailable
(String className)
hazelcast/src/main/java/com/hazelcast/cache/impl/JCacheDetector.java:102
↓ 3 callersMethodisClientAllowed
(Client client)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEngineImpl.java:462
↓ 3 callersMethodisClosed
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/ConvenientSourceP.java:60
↓ 3 callersMethodisClosed
()
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/IMapOutputStream.java:56
↓ 3 callersMethodisClusterInSafeState
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:743
↓ 3 callersMethodisCompatible
(ExpiryPolicyFactoryConfig c1, ExpiryPolicyFactoryConfig c2)
hazelcast/src/test/java/com/hazelcast/config/ConfigCompatibilityChecker.java:968
↓ 3 callersMethodisCompatible
(WanReplicationRef c1, WanReplicationRef c2)
hazelcast/src/test/java/com/hazelcast/config/ConfigCompatibilityChecker.java:1054
↓ 3 callersMethodisConnected
Returns if this member is connected to the Wan publisher @return if this member is connected to the Wan publisher
hazelcast/src/main/java/com/hazelcast/internal/monitor/LocalWanPublisherStats.java:40
↓ 3 callersMethodisConsoleEnabled
()
hazelcast/src/main/java/com/hazelcast/internal/management/TimedMemberState.java:129
↓ 3 callersMethodisContainsSerializedDataInRequest
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientMessage.java:333
↓ 3 callersMethodisCoreService
()
hazelcast/src/main/java/com/hazelcast/spi/impl/servicemanager/ServiceInfo.java:46
↓ 3 callersMethodisCountAsAccess
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:254
↓ 3 callersMethodisDescending
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/IndexScanMapPhysicalRel.java:112
↓ 3 callersMethodisDialectSupported
(SqlDialect dialect)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/SupportedDatabases.java:77
↓ 3 callersMethodisDisablePerEntryInvalidationEvents
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/holder/CacheConfigHolder.java:215
↓ 3 callersMethodisDone
(IterationPointer[] partitionPointers)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/ReadMapOrCacheP.java:249
↓ 3 callersMethodisDrainerGone
@return whether the drainer thread has left
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/ConcurrentConveyor.java:354
← previousnext →14,901–15,000 of 147,315, ranked by callers