MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 3 callersMethoddelete
Removes {@code key} if present. @param key non-null key of the key-value entry to remove @throws NullPointerException when {@code key} is null
hazelcast/src/main/java/com/hazelcast/cp/CPMap.java:82
↓ 3 callersMethoddeleteCacheEntry
(Data key)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1069
↓ 3 callersMethoddeleteCacheStat
(String cacheNameWithPrefix)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:435
↓ 3 callersMethoddeletesMongo_using
(String expr)
extensions/mongodb/src/test/java/com/hazelcast/jet/sql/impl/connector/mongodb/MongoBatchSqlConnectorDeleteIT.java:161
↓ 3 callersMethoddemotion_shouldFail_whenClusterState_NotAllowMigration
(ClusterState state)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/DemoteDataMemberTest.java:282
↓ 3 callersMethoddereferenceValue
(Object value)
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrentReferenceHashMap.java:460
↓ 3 callersMethodderegisterHandler
(String dataStructureName)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/RepairingTask.java:209
↓ 3 callersMethodderiveType
(SqlValidator validator)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastJsonType.java:79
↓ 3 callersMethoddescendingKeys
Returns a List of keys in descending value order. @return the list of keys
hazelcast/src/main/java/com/hazelcast/internal/util/ItemCounter.java:63
↓ 3 callersMethoddescribeThread
(Thread thread)
hazelcast/src/test/java/classloading/ThreadLocalLeakTestUtils.java:240
↓ 3 callersMethoddeserialize
(DatumReader<T> datumReader, byte[] data)
extensions/avro/src/main/java/com/hazelcast/jet/avro/impl/AvroSerializerHooks.java:71
↓ 3 callersMethoddeserialize
(byte[] array)
hazelcast/src/test/java/com/hazelcast/test/TestJavaSerializationUtils.java:36
↓ 3 callersMethoddeserializeEntriesInto
(ObjectDataInput in, int size, Collection<?> collection)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/defaultserializers/AbstractCollectionStreamSerializer.java:47
↓ 3 callersMethoddestroy
()
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapContainer.java:187
↓ 3 callersMethoddestroy
()
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainer.java:178
↓ 3 callersMethoddestroyContainer
(int partitionId, ObjectNamespace namespace)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferService.java:150
↓ 3 callersMethoddestroyFn
Sets the function that Jet will call when it is done cleaning up after an execution. It gives you the opportunity to release any resources that your c
hazelcast/src/main/java/com/hazelcast/jet/pipeline/SourceBuilder.java:363
↓ 3 callersMethoddestroyLocally
Destroys this client proxy instance locally without issuing distributed object destroy request to the cluster as the {@link #destroy} method does. <p>
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientProxy.java:121
↓ 3 callersMethoddestroyMap
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContext.java:150
↓ 3 callersMethoddestroyStorageAfterClear
Calls also {@link #clearStorage()} to release allocated HD memory of key+value pairs because only releases internal resources of backing data structur
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:1715
↓ 3 callersMethoddestroyStorageImmediate
(boolean isDuringShutdown, boolean internal, @Nullable Queue<Disposabl
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:1680
↓ 3 callersMethoddeterminedLocalParallelism
(int determinedLocalParallelism)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/AbstractTransform.java:92
↓ 3 callersMethoddisable
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryStoreBackupTest.java:158
↓ 3 callersMethoddisableBackupsFrom
Installs a packet filter to all instances. The filter will drop {@link PartitionReplicaSyncRequestOffloadable} operation on all members, and will drop
hazelcast/src/test/java/com/hazelcast/jet/core/IndeterminateSnapshotTest.java:668
↓ 3 callersMethoddisallowRetryOnRandom
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientInvocation.java:149
↓ 3 callersMethoddiscoveryStrategyConfigXmlGenerator
(ConfigXmlGenerator.XmlGenerator gen, DiscoveryConfig c)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigXmlGenerator.java:852
↓ 3 callersMethoddispatchPartitionScanQueryOnOwnerMemberOnPartitionThread
( Query query, PartitionIdSet partitionIds)
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryEngineImpl.java:327
↓ 3 callersMethoddispose
(Queue<Disposable> queue)
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/HazelcastClientInstanceImpl.java:857
↓ 3 callersMethoddispose
()
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2LongMap.java:48
↓ 3 callersMethoddisposeData
(Data data)
hazelcast/src/main/java/com/hazelcast/internal/serialization/InternalSerializationService.java:102
↓ 3 callersMethoddisposePartition
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapReplicationOperation.java:101
↓ 3 callersMethoddoAndDrain
(BooleanSupplier action)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/InsertWatermarksPTest.java:299
↓ 3 callersMethoddoCacheEntryViewTest
(CacheEntryViews.CacheEntryViewType cacheEntryViewType)
hazelcast/src/test/java/com/hazelcast/cache/CacheEntryViewsTest.java:53
↓ 3 callersMethoddoEviction
Does eviction as specified configuration {@link com.hazelcast.config.EvictionConfig} in {@link com.hazelcast.config.NearCacheConfig}. @param withoutM
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCacheRecordStore.java:115
↓ 3 callersMethoddoExecute
(boolean onKey, boolean onMember, String[] args)
hazelcast/src/main/java/com/hazelcast/client/console/ClientConsoleApp.java:1297
↓ 3 callersMethoddoExecute
(boolean onKey, boolean onMember, String[] args)
hazelcast/src/main/java/com/hazelcast/console/ConsoleApp.java:1255
↓ 3 callersMethoddoInvoke
(boolean isAsync)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/Invocation.java:567
↓ 3 callersMethoddoInvokeJoinJob
()
hazelcast/src/main/java/com/hazelcast/jet/impl/AbstractJobProxy.java:471
↓ 3 callersMethoddoPostEvictionOperations
Does post eviction operations like sending events @param dataValue record to process
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:457
↓ 3 callersMethoddoRelease
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TransactionPoolSnapshotUtility.java:276
↓ 3 callersMethoddoRemoteRegistrationSync
(ClientListenerRegistration registration, ClientConnection connection,
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/listener/ClientListenerServiceImpl.java:139
↓ 3 callersMethoddoSendResponse
(Object value)
hazelcast/src/main/java/com/hazelcast/jet/impl/operation/AsyncOperation.java:98
↓ 3 callersMethoddoTestForOwnedEntryCount
(boolean useBackups, boolean triggerMigration)
hazelcast/src/test/java/com/hazelcast/cache/stats/CacheStatsTest.java:573
↓ 3 callersMethoddo_test_putGetChar
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:297
↓ 3 callersMethoddo_test_putGetDouble
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:573
↓ 3 callersMethoddo_test_putGetFloat
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:462
↓ 3 callersMethoddo_test_putGetInt
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:407
↓ 3 callersMethoddo_test_putGetLong
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:518
↓ 3 callersMethoddo_test_putGetShort
(boolean aligned)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/BaseMemoryAccessorTest.java:353
↓ 3 callersMethoddockerEnabled
()
hazelcast/src/test/java/com/hazelcast/test/DockerTestUtil.java:25
↓ 3 callersMethoddrainFrom
Drains as many items from the src as fit into this CircularQueue. @param src the queue to drain. @return the number of items drained.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/util/CircularQueue.java:117
↓ 3 callersMethoddrainFromBackup
(Set<Long> itemIdSet)
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueContainer.java:655
↓ 3 callersMethoddrainTo
Drains at most {@code limit} available items into the provided {@link Collection}. <p> <i>Implementation note:</i> this method is expected to take adv
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/Pipe.java:79
↓ 3 callersMethoddrainTo
Removes all elements from this queue and adds them to the given collection. @param collection all elements to be added to this collection. @return nu
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueue.java:70
↓ 3 callersMethoddrainerArrived
Called by the drainer thread to signal that it has started draining the queue.
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/ConcurrentConveyor.java:323
↓ 3 callersMethoddrainerFailed
Called by the drainer thread to signal that it has failed and will drain no more items from the queue. @param t the drainer's failure
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/ConcurrentConveyor.java:334
↓ 3 callersMethoddummyTaskConfig
()
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/impl/TaskRunnerTest.java:93
↓ 3 callersMethoddurableExec
(int index, SplitBrainProtectionOn splitBrainProtectionOn)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/AbstractSplitBrainProtectionTest.java:312
↓ 3 callersMethoddynamicMapConfig
()
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/ConfigSearchTest.java:122
↓ 3 callersMethodedgeBetween
(String sourceName, String destName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/index/SqlIndexSortTest.java:112
↓ 3 callersMethodeditPermissionsRecursively
Edits the permissions on all the files in the {@code basePath} and its subdirectories. It calls {@link #editPermissions} with every file. @param base
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:685
↓ 3 callersMethodelastic
Creates a source which queries local instance of Elasticsearch for all documents <p> Useful for quick prototyping. See other methods {@link #elastic(S
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/ElasticSources.java:55
↓ 3 callersMethodelasticSource
(SupplierEx<RestClientBuilder> clientFn)
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/AuthElasticSourcesTest.java:104
↓ 3 callersMethodempty
Returns an empty {@link JobMetrics} object.
hazelcast/src/main/java/com/hazelcast/jet/core/metrics/JobMetrics.java:69
↓ 3 callersMethodemptyNodeList
Returns the singleton instance of this class @return an empty {@link NodeList} @see #INSTANCE
hazelcast/src/main/java/com/hazelcast/internal/config/yaml/EmptyNodeList.java:49
↓ 3 callersMethodenableChunkedStreaming
()
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:646
↓ 3 callersMethodenableSnapshotting
(TestProcessorContext testProcessorContext)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/impl/ReadKafkaConnectPTest.java:259
↓ 3 callersMethodenableStatisticManagementOnNodes
Enables/disables statistics or management support of cache on the all servers in the cluster. @param client the client instance which will send th
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheHelper.java:121
↓ 3 callersMethodenabled
()
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlStoreConfigBuilder.java:28
↓ 3 callersMethodenabled
Checks if this ConcurrencyDetection is enabled. <p> This is useful if you want to fall back to legacy mode. @return true if enabled, false otherwise.
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrencyDetection.java:62
↓ 3 callersMethodencode
(ClientMessage clientMessage, com.hazelcast.config.DataPersistenceConfig dataPersistenceConfig)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/DataPersistenceConfigCodec.java:44
↓ 3 callersMethodencode
(ClientMessage clientMessage, com.hazelcast.client.impl.protocol.codec.holder.PagingPredicateHolder pagingPred
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/PagingPredicateHolderCodec.java:45
↓ 3 callersMethodencode
(ClientMessage clientMessage, javax.transaction.xa.Xid xid)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/XidCodec.java:43
↓ 3 callersMethodencode
(ClientMessage clientMessage, com.hazelcast.vector.impl.DataVectorDocument vectorDocument)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/VectorDocumentCodec.java:41
↓ 3 callersMethodencode
(ClientMessage clientMessage, com.hazelcast.client.impl.protocol.task.dynamicconfig.EvictionConfigHolder evict
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/custom/EvictionConfigHolderCodec.java:43
↓ 3 callersMethodencode
(List<ErrorHolder> errorHolders)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ErrorsCodec.java:40
↓ 3 callersMethodencode
(ClientMessage clientMessage, Collection<Integer> collection)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListIntegerCodec.java:35
↓ 3 callersMethodencodeFloat
(byte[] buffer, int pos, float value)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/FixedSizeTypesCodec.java:151
↓ 3 callersMethodencodeHeader
(ClientMessage.Frame frame, byte type, int size)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListCNFixedSizeCodec.java:110
↓ 3 callersMethodencodeUnauthenticated
(byte status, boolean failoverSupported)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AuthenticationBaseMessageTask.java:199
↓ 3 callersMethodendAndPrepare
Prepares for a commit. To achieve correctness, the transaction must be able to eventually commit after this call, writes must be durably stored in the
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:304
↓ 3 callersMethodendSection
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/DiagnosticsLogWriterImpl.java:141
↓ 3 callersMethodendpointConfigFromProperties
(HazelcastProperties properties)
hazelcast/src/main/java/com/hazelcast/instance/impl/DefaultAddressPicker.java:163
↓ 3 callersMethodensureCapacity
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/SelectorOptimizer.java:196
↓ 3 callersMethodensureCapacity
(int tagPtr)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:307
↓ 3 callersMethodensureOpenIfAvailable
(ICacheInternal<K, V> cache)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:217
↓ 3 callersMethodensureServerSocketEndpointConfig
(EndpointConfig endpointConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/MemberDomConfigProcessor.java:1173
↓ 3 callersMethodensureTransactions
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TransactionPoolSnapshotUtility.java:259
↓ 3 callersMethodentry
(K key, V value)
hazelcast/src/test/java/com/hazelcast/internal/config/override/EnvVariablesClientConfigParserTest.java:64
↓ 3 callersMethodentry
(K key, V value)
hazelcast/src/test/java/com/hazelcast/internal/config/override/EnvVariablesMemberConfigParserTest.java:76
↓ 3 callersMethodentry
(K key, V value)
hazelcast/src/test/java/com/hazelcast/internal/config/override/SystemPropertiesMemberConfigParserTest.java:64
↓ 3 callersMethodentryEvicted
Invoked upon eviction of an entry. @param event the event invoked when an entry is evicted
hazelcast/src/main/java/com/hazelcast/map/listener/EntryEvictedListener.java:39
↓ 3 callersMethodentryListenerConfigXmlGenerator
(ConfigXmlGenerator.XmlGenerator gen, MapConfig m)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigXmlGenerator.java:688
↓ 3 callersMethodentryUpdated
Invoked upon update of an entry. @param event the event invoked when an entry is updated
hazelcast/src/main/java/com/hazelcast/map/listener/EntryUpdatedListener.java:38
↓ 3 callersMethodequal
(long key1a, long key2a, long key1b, long key2b)
hazelcast/src/main/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArrayBase.java:413
↓ 3 callersMethodequals
(Object o)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/string/LikeFunction.java:156
↓ 3 callersMethodequals
(Object o)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcTableField.java:43
↓ 3 callersMethodequals
(Object o)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/WriteMongoP.java:409
↓ 3 callersMethodequals
(Object obj)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/HashRange.java:114
↓ 3 callersMethodequals
(Object o)
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/impl/WriteKafkaP.java:441
← previousnext →13,901–14,000 of 147,315, ranked by callers