MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 2 callersMethoddoPrepublicationChecks
Performs pre-publication checks (e.g. enforcing invariants). Invoked before {@link #publishReplicationEvent(WanEvent)} and {@link #publishReplicationE
hazelcast/src/main/java/com/hazelcast/wan/WanPublisher.java:60
↓ 2 callersMethoddoPutIfAbsentOnServer
(Data keyData, Data valueData, Data expir
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:713
↓ 2 callersMethoddoPutRecord
(Data key, R record, UUID source, boolean updateJournal)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1161
↓ 2 callersMethoddoRead
(ObjectDataInput in, DataSerializable instance)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/VersionedDataSerializableSerializer.java:225
↓ 2 callersMethoddoRemoveOnServer
(Data keyData, Data oldValueData, boolean withCompletionEvent)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:426
↓ 2 callersMethoddoReplaceOnServer
(Data keyData, Data newValueData, Data oldValueData,
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:502
↓ 2 callersMethoddoRun
(Random random)
hazelcast/src/test/java/com/hazelcast/cache/CacheBasicAbstractTest.java:367
↓ 2 callersMethoddoRun
()
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/impl/operations/AbstractRegistrationOperation.java:81
↓ 2 callersMethoddoSchedule
(ScheduledTaskDescriptor descriptor)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainer.java:473
↓ 2 callersMethoddoSetClusterState
(ClusterState newState, boolean isTransient)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterStateManager.java:169
↓ 2 callersMethoddoSetClusterVersion
(Version newVersion)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterStateManager.java:176
↓ 2 callersMethoddoShutdown
()
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/LifecycleServiceImpl.java:161
↓ 2 callersMethoddoSomethingTxnal
()
hazelcast/src/test/java/com/hazelcast/map/impl/tx/MapTransactionStressTest.java:310
↓ 2 callersMethoddoTestAddEqualEntryConcurrently
(boolean coalesced)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/StoreWorkerConcurrentUpdateTest.java:59
↓ 2 callersMethoddoTestCacheGetCallable
(final Object returnValue)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/cache/HazelcastCacheTest.java:82
↓ 2 callersMethoddoTestCacheGetCallableNotInvokedWithHit
(Object initialValue)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/cache/HazelcastCacheTest.java:102
↓ 2 callersMethoddo_putAsAdd_writeThrough
(boolean acceptAll)
hazelcast/src/test/java/com/hazelcast/cache/CacheReadWriteThroughTest.java:228
↓ 2 callersMethoddo_putAsUpdate_writeThrough
(boolean acceptAll)
hazelcast/src/test/java/com/hazelcast/cache/CacheReadWriteThroughTest.java:275
↓ 2 callersMethoddo_test_compareAndSwapInt
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:673
↓ 2 callersMethoddo_test_compareAndSwapLong
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:706
↓ 2 callersMethoddo_test_compareAndSwapObject
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:733
↓ 2 callersMethoddo_test_copyMemory
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:181
↓ 2 callersMethoddo_test_putOrderedInt
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:761
↓ 2 callersMethoddo_test_putOrderedLong
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:784
↓ 2 callersMethoddo_test_putOrderedObject
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:801
↓ 2 callersMethoddo_test_setMemory
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:217
↓ 2 callersMethoddoit
(Object response)
hazelcast/src/test/java/com/hazelcast/executor/CompletableFutureTest.java:332
↓ 2 callersMethoddone
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/map/MapIndexScanP.java:406
↓ 2 callersMethoddrainAllReplicaSyncPermits
(InternalPartitionServiceImpl partitionService)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/PartitionReplicaStateCheckerTest.java:245
↓ 2 callersMethoddrainInternal
(Queue<? extends T> q, Collection<? super T> target, boolean logItems, S
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestOutbox.java:192
↓ 2 callersMethoddrainPutStack
()
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/MPSCQueue.java:244
↓ 2 callersMethoddriverFactory
(DriverFactory driverFactory)
hazelcast/src/test/java/com/hazelcast/test/bounce/BounceMemberRule.java:553
↓ 2 callersMethoddropMapping
(String mappingName)
extensions/mapstore/src/main/java/com/hazelcast/mapstore/MappingHelper.java:132
↓ 2 callersMethoddropMapping
(String mappingName)
extensions/mapstore/src/main/java/com/hazelcast/mapstore/GenericMapLoader.java:304
↓ 2 callersMethoddump
(ThreadInfo[] infos, StringBuilder s)
hazelcast/src/main/java/com/hazelcast/internal/management/ThreadDumpGenerator.java:50
↓ 2 callersMethoddumpNotExpiredRecordsToString
(HazelcastInstance node, String mapName)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindEntryStoreQueueReplicationTest.java:98
↓ 2 callersMethodduplicateColumn
(String columnName)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/ParserResource.java:49
↓ 2 callersMethoddynamicStream_mergesDuringData
(int shards, int merges)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisIntegrationTest.java:281
↓ 2 callersMethoddynamicStream_splitsDuringData
(int shards, int splits)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisIntegrationTest.java:335
↓ 2 callersMethodedgeIterator
Returns an iterator over the DAG's edges in unspecified order. @since 5.4
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:324
↓ 2 callersMethodeditPermissions
Edits the permissions on the file denoted by {@code path} by calling {@code editFn} with the set of that file's current permissions. {@code editFn} sh
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:666
↓ 2 callersMethodemitMCConfigUpdatedEvent
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:852
↓ 2 callersMethodempty
()
hazelcast/src/main/java/com/hazelcast/jet/impl/metrics/RawJobMetrics.java:40
↓ 2 callersMethodemptyNamedNodeMap
Returns the singleton instance of this class @return an empty {@link NamedNodeMap} @see #INSTANCE
hazelcast/src/main/java/com/hazelcast/internal/config/yaml/EmptyNamedNodeMap.java:81
↓ 2 callersMethodemptyPartitionArray
(int partitionCount)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/PartitionStateGeneratorTest.java:261
↓ 2 callersMethodenableDiagnostics
(int duration)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsPhoneHomeTest.java:68
↓ 2 callersMethodenableFailingPhase2
()
hazelcast/src/test/java/com/hazelcast/jet/job/AbstractJobInitialSnapshotTest.java:168
↓ 2 callersMethodenableStatisticManagementOnNodes
(String cacheName, boolean statOrMan, boolean enabled)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/HazelcastClientCacheManager.java:85
↓ 2 callersMethodenableStatisticManagementOnOtherNodes
(String cacheName, boolean statOrMan, boolean enabled)
hazelcast/src/main/java/com/hazelcast/cache/impl/HazelcastServerCacheManager.java:104
↓ 2 callersMethodenableTcp
(Config config)
hazelcast/src/test/java/com/hazelcast/cluster/ClusterJoinConfigCheckTest.java:90
↓ 2 callersMethodencode
(ClientMessage clientMessage, com.hazelcast.config.MemoryTierConfig memoryTierConfig)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/MemoryTierConfigCodec.java:41
↓ 2 callersMethodencode
(ClientMessage clientMessage, com.hazelcast.cp.CPMember cPMember)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/CPMemberCodec.java:44
↓ 2 callersMethodencode
(ClientMessage clientMessage, com.hazelcast.internal.serialization.impl.compact.Schema schema)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/SchemaCodec.java:41
↓ 2 callersMethodencode
(ClientMessage clientMessage, com.hazelcast.cluster.Address address)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/AddressCodec.java:43
↓ 2 callersMethodencode
(ClientMessage clientMessage, com.hazelcast.memory.Capacity capacity)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/CapacityCodec.java:44
↓ 2 callersMethodencode
(ClientMessage clientMessage, com.hazelcast.partition.MigrationState migrationState)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/MigrationStateCodec.java:46
↓ 2 callersMethodencode
(ClientMessage clientMessage, Collection<Map.Entry<UUID, List<Integer>>> collection)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListUUIDListIntegerCodec.java:36
↓ 2 callersMethodencode
(ClientMessage clientMessage, Collection<Map.Entry<Integer, UUID>> collection)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListIntegerUUIDCodec.java:43
↓ 2 callersMethodencode
(ClientMessage clientMessage, Collection<Map.Entry<UUID, UUID>> collection)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListUUIDUUIDCodec.java:40
↓ 2 callersMethodencodeAuthenticationResponse
(byte status, Address thisAddress, UUID uuid, byte se
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AuthenticationBaseMessageTask.java:271
↓ 2 callersMethodencodeEvent
(Data key, Data newValue, Data oldValue, Data mergingValue, i
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/replicatedmap/AbstractReplicatedMapAddEntryListenerMessageTask.java:140
↓ 2 callersMethodencodeEvent
(Data keyData, Data newValueData, Data oldValueData, Data mer
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/map/AbstractMapAddEntryListenerMessageTask.java:128
↓ 2 callersMethodencodeEvent
(Data key, Data value, Data oldValue, int type, UUID uuid, in
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/multimap/AbstractMultiMapAddEntryListenerMessageTask.java:126
↓ 2 callersMethodencodeException
(Throwable throwable)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AbstractMessageTask.java:336
↓ 2 callersMethodencodeMigrationEvent
(MigrationState migrationState, MigrationProcessState processState)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AddMigrationListenerMessageTask.java:107
↓ 2 callersMethodencodeReplicaMigrationEvent
(ReplicaMigrationEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AddMigrationListenerMessageTask.java:90
↓ 2 callersMethodencrypt
Encrypts given string with key generated from {@link #getPassword()} with given iteration count and return the masked value (to be used as the variabl
hazelcast/src/main/java/com/hazelcast/config/replacer/AbstractPbeReplacer.java:125
↓ 2 callersMethodend
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/DefaultPortableWriter.java:425
↓ 2 callersMethodendArray
Indicates the end of an array in the JSON input. This method will be called after reading the closing square bracket character (<code>']'</code>). @p
hazelcast/src/main/java/com/hazelcast/internal/json/JsonHandler.java:156
↓ 2 callersMethodendBoolean
Indicates the end of a boolean literal (<code>true</code> or <code>false</code>) in the JSON input. This method will be called after reading the last
hazelcast/src/main/java/com/hazelcast/internal/json/JsonHandler.java:95
↓ 2 callersMethodendCapture
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonParser.java:461
↓ 2 callersMethodendCapture
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonReducedValueParser.java:311
↓ 2 callersMethodendObject
Indicates the end of an object in the JSON input. This method will be called after reading the closing curly bracket character (<code>'}'</code>). @p
hazelcast/src/main/java/com/hazelcast/internal/json/JsonHandler.java:209
↓ 2 callersMethodengineActive
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/Invocation.java:522
↓ 2 callersMethodenhanceDescriptor
(MetricDescriptor descriptor, long timestamp)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEndpointImpl.java:354
↓ 2 callersMethodenqueue
(TextCommand response)
hazelcast/src/main/java/com/hazelcast/internal/nio/ascii/TextEncoder.java:50
↓ 2 callersMethodenqueueSnapshot
(String snapshotName, boolean isTerminal, CompletableFuture<Void> future)
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterSnapshotContext.java:150
↓ 2 callersMethodensureAndGetSingleEventPack
()
hazelcast/src/test/java/com/hazelcast/partition/PartitionMigrationListenerTest.java:593
↓ 2 callersMethodensureBufHasRoom
(FileOutputStream fos, int expectedSize)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/preloader/NearCachePreloader.java:271
↓ 2 callersMethodensureCapacity
(int minCapacity)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/AsyncSnapshotWriterImpl.java:487
↓ 2 callersMethodensureDataInBuffer
()
hazelcast/src/main/java/com/hazelcast/internal/util/BufferingInputStream.java:70
↓ 2 callersMethodensureExecutionRecord
(long jobId, JobExecutionRecord record)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobCoordinationService.java:1478
↓ 2 callersMethodensureHasPath
(@Nonnull URL url)
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1080
↓ 2 callersMethodensureMember
Makes sure that a list of counters is created for a member. <p> This method exists to ensure that an operation-heartbeat is always sent, even if there
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/CallsPerMember.java:85
↓ 2 callersMethodensureMemberExist
(Member member)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberMap.java:285
↓ 2 callersMethodensureNoPartitionProblems
(Operation op)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationRunnerImpl.java:398
↓ 2 callersMethodensureNoSplitBrain
Ensures that there is no split brain if the split brain protection is configured and the operation service is split brain protection aware. @param op
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationRunnerImpl.java:367
↓ 2 callersMethodensureNotCallingFromPartitionOperationThread
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/AbstractInvokeOnPartitions.java:77
↓ 2 callersMethodensureOpen
()
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheIterator.java:201
↓ 2 callersMethodensurePartitionsInitialized
(HazelcastInstance... instances)
hazelcast/src/test/java/com/hazelcast/internal/partition/MigrationInvocationsSafetyTest.java:452
↓ 2 callersMethodensureResultSet
(long timeout, TimeUnit unit)
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/impl/BasicCompletableFuture.java:64
↓ 2 callersMethodensureSignProvision
Ensure matching bracket. Add anchored minus if there is no negative sign provision.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/datetime/Formatter.java:659
↓ 2 callersMethodensureSqlType
(RelDataType type, RexNode node)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/HazelcastSqlToRelConverter.java:663
↓ 2 callersMethodensureTypeIsAllowed
(@Nonnull Class<?> type)
hazelcast/src/main/java/com/hazelcast/jet/json/impl/JsonUtilImpl.java:81
↓ 2 callersMethodensureValidConfiguration
(JoinMessage joinMessage)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:218
↓ 2 callersMethodenterpriseOnly
(String wanReplicationName, String wanPublisherId,
hazelcast/src/main/java/com/hazelcast/internal/management/events/WanSyncIgnoredEvent.java:39
↓ 2 callersMethodentry
Returns a {@code Map.Entry} with the given key and value.
hazelcast/src/main/java/com/hazelcast/internal/util/MapUtil.java:101
↓ 2 callersMethodentryListenerConfigWithClassName
()
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/DynamicConfigTest.java:963
↓ 2 callersMethodentryListenerConfigWithImplementation
()
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/DynamicConfigTest.java:959
↓ 2 callersMethodentryProjector
Returns a supplier of processors that convert a row represented as {@link JetSqlRow} to an entry represented as {@code Entry<Object, Object>}.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvProcessors.java:48
← previousnext →17,601–17,700 of 147,315, ranked by callers