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
↓ 4 callers
Method
checkUrgentInvocation_withNoData
(ClientConnection connection)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/ClientInvocationServiceImplTest.java:242
↓ 4 callers
Method
classKeyName
Returns the key name in the form {@code class.<id>}
hazelcast/src/main/java/com/hazelcast/jet/impl/JobRepository.java:727
↓ 4 callers
Method
classSchema
()
extensions/avro/src/test/java/com/hazelcast/jet/avro/model/User.java:38
↓ 4 callers
Method
clear
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpirySystem.java:99
↓ 4 callers
Method
clearBit
Clears n-th bit of the byte value @param value byte value @param bit n-th bit @return value
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:231
↓ 4 callers
Method
clearCachingProviderRegistry
Closes and removes the {@link javax.cache.spi.CachingProvider} from the static registry in {@link Caching}.
hazelcast/src/test/java/com/hazelcast/cache/jsr/JsrTestUtil.java:113
↓ 4 callers
Method
clearLockStore
(int partitionId, ObjectNamespace namespace)
hazelcast/src/main/java/com/hazelcast/internal/locksupport/LockSupportService.java:33
↓ 4 callers
Method
clearNearCache
Clears {@link NearCache} instance associated with given {@code name} but not removes it. @param name name of the {@link NearCache} to be cleared @ret
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCacheManager.java:75
↓ 4 callers
Method
clearParameters
Clears statement parameter values. @return this instance for chaining @see #setParameters(List) @see #addParameter(Object)
hazelcast/src/main/java/com/hazelcast/sql/SqlStatement.java:211
↓ 4 callers
Method
clearProcessorClassLoaders
Clears processor classloaders from the current thread
hazelcast/src/main/java/com/hazelcast/jet/impl/JobClassLoaderService.java:202
↓ 4 callers
Method
clientAttributes
()
hazelcast/src/main/java/com/hazelcast/client/impl/statistics/ClientStatistics.java:45
↓ 4 callers
Method
clientConfig
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/ReadMapOrCacheP_ConsistencyTest.java:258
↓ 4 callers
Method
cloneConfig
(Object thisConfigObject, ClassLoader classloader)
hazelcast/src/test/java/com/hazelcast/test/starter/constructor/AbstractConfigConstructor.java:49
↓ 4 callers
Method
cloneRemoving
(List<Member> members, int removeCount)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationManagerTest.java:198
↓ 4 callers
Method
close
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/join/FullScanResultSetIterator.java:104
↓ 4 callers
Method
close
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/join/JoinPredicateScanResultSetIterator.java:106
↓ 4 callers
Method
closeBlocks
()
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:353
↓ 4 callers
Method
closeCurrentFile
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/StreamFilesP.java:340
↓ 4 callers
Method
collect
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/MaxSqlAggregation.java:72
↓ 4 callers
Method
collect
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/MinSqlAggregation.java:72
↓ 4 callers
Method
collect
Extracts, tags and collects all metrics from the given source. @param descriptor The {@link MetricDescriptor} used to describe the
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricsCollectionContext.java:31
↓ 4 callers
Method
collection
Specifies from which collection connector will read documents. If not invoked, then connector will look at all collections in given database. <p> Exam
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/MongoSourceBuilder.java:361
↓ 4 callers
Method
columns
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlCreateType.java:158
↓ 4 callers
Method
combine
Merge another aggregation into this aggregation.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/SqlAggregation.java:34
↓ 4 callers
Method
combineP
Returns a supplier of processors for a vertex that performs the combining and finishing steps of the provided aggregate operation. It expects to recei
hazelcast/src/main/java/com/hazelcast/jet/core/processor/Processors.java:290
↓ 4 callers
Method
compare
Compares the given {@link CacheEntryView} instances and returns the result. The result should be one of <ul> <li>-1: first entry has higher priority
hazelcast/src/main/java/com/hazelcast/cache/CacheEvictionPolicyComparator.java:50
↓ 4 callers
Method
compareAndSetSequence
Atomically sets the value of sequence number for the partition. @param expect the expected sequence. @param update the new sequence. @return {@code t
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/sequence/PartitionSequencer.java:54
↓ 4 callers
Method
compareTo
(XPortable o)
hazelcast/src/test/java/com/hazelcast/query/impl/extractor/specification/PortableDataStructure.java:345
↓ 4 callers
Method
complete
Completes this Promise with the provided value. @param value the value @throws IllegalStateException if the Promise has already been completed.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Promise.java:112
↓ 4 callers
Method
complexKeyTable
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/logical/LogicalUpdateTest.java:298
↓ 4 callers
Method
components
(String... names)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/CompositeIndexVisitorTest.java:85
↓ 4 callers
Method
compose
{@code Serializable} variant of {@link Function#compose(Function) java.util.function.Function#compose(Function)}. @param <V> the type of input to the
hazelcast/src/main/java/com/hazelcast/function/FunctionEx.java:76
↓ 4 callers
Method
compress
(byte[] input)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:405
↓ 4 callers
Method
condition
All join filters. Column references in this condition apply to the joined row.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/JetJoinInfo.java:124
↓ 4 callers
Method
configureBatching
(Config config, int batchSize, int period)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/MapNearCacheInvalidationTest.java:241
↓ 4 callers
Method
connectionAdded
(C connection)
hazelcast/src/main/java/com/hazelcast/internal/nio/ConnectionListener.java:24
↓ 4 callers
Method
connectionClosedException
()
hazelcast/src/test/java/com/hazelcast/client/protocol/ClientMessageProtectionTest.java:221
↓ 4 callers
Method
connectionRemoved
(C connection)
hazelcast/src/main/java/com/hazelcast/internal/nio/ConnectionListener.java:26
↓ 4 callers
Method
constructAttributeBasedKey
Constructs a PartitioningKey depending on the number of attribute values - either returns a singular object or an array of attribute values. Kept in t
hazelcast/src/main/java/com/hazelcast/internal/util/PartitioningStrategyUtil.java:47
↓ 4 callers
Method
constructMappingOptions
(String keyFormat, String valueFormat)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaSqlTestSupport.java:163
↓ 4 callers
Method
contains
Determines if this store contains an entry for the specified key. <p> More formally, returns <tt>true</tt> if and only if this store contains a mappin
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheRecordStore.java:305
↓ 4 callers
Method
containsKey
(K key)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:114
↓ 4 callers
Method
containsKey
Transactional implementation of {@link IMap#containsKey(Object)}. @throws NullPointerException if the specified key is {@code null} @see IMap#contain
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:78
↓ 4 callers
Method
containsPagingPredicate
Returns true if the predicate passed is a {@link com.hazelcast.query.PagingPredicate} or is a {@link com.hazelcast.query.PartitionPredicate} that incl
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/PredicateUtils.java:100
↓ 4 callers
Method
context
(HazelcastSchema schema, QueryDataType... parameterTypes)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/OptimizerTestSupport.java:132
↓ 4 callers
Method
convert
(YamlNode yamlNode)
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlToJsonConverter.java:32
↓ 4 callers
Method
convert
(Comparable value, boolean convertNull)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangeVisitor.java:366
↓ 4 callers
Method
copy
(Operation op)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/OperationSerializationTest.java:218
↓ 4 callers
Method
copy
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:116
↓ 4 callers
Method
copyFile
Copies source file to target and creates the target if necessary. The target can be a directory or file. If the target is a file, nests the new file u
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:725
↓ 4 callers
Method
copyMetadataFrom
Except transient field {@link com.hazelcast.query.impl.Metadata}, all record-metadata is copied from one record to another.
hazelcast/src/main/java/com/hazelcast/map/impl/record/Records.java:75
↓ 4 callers
Method
copyState
()
extensions/kafka-connect/src/main/java/com/hazelcast/jet/kafka/connect/impl/TaskRunner.java:153
↓ 4 callers
Method
copyStream
(InputStream in, OutputStream out)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/IOUtil.java:96
↓ 4 callers
Method
copyWithInitializedDefaultMaxSizeForOnHeapMaps
(NearCacheConfig nearCacheConfig)
hazelcast/src/main/java/com/hazelcast/config/NearCacheConfigAccessor.java:31
↓ 4 callers
Method
count
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/ExecutionPlanBuilder.java:314
↓ 4 callers
Method
countDownCompletionLatch
(int id)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheSyncListenerCompleter.java:24
↓ 4 callers
Method
create
(Expression<?>[] operands)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/CaseExpression.java:70
↓ 4 callers
Method
create
(Expression<?>... operands)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/AndPredicate.java:39
↓ 4 callers
Method
create
(int... partitions)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/PartitionIdSetTest.java:310
↓ 4 callers
Method
create
(int keyCount)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/OrderedProcessingMergingStagesTest.java:322
↓ 4 callers
Method
create
(int typeId)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ArrayDataSerializableFactory.java:42
↓ 4 callers
Method
create
Factory method. @param queueCount number of queues
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/WatermarkCoalescer.java:100
↓ 4 callers
Method
create
(String xmlString)
hazelcast/src/main/java/com/hazelcast/aws/XmlNode.java:44
↓ 4 callers
Method
createAndFillEntries
()
hazelcast/src/test/java/com/hazelcast/cache/CacheClearTest.java:92
↓ 4 callers
Method
createAvroFile
Creates a temporary directory with prefix 'sql-avro-test', writes the specified Avro record to 'file.avro' in this directory and returns the file.
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/file/FileUtil.java:177
↓ 4 callers
Method
createAvroFile
()
extensions/hadoop/src/test/java/com/hazelcast/jet/hadoop/file/AvroFileFormatTest.java:102
↓ 4 callers
Method
createBackoffIdleStrategy
Creates a new BackoffIdleStrategy.
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/BackoffIdleStrategy.java:99
↓ 4 callers
Method
createCacheConfig
()
hazelcast/src/test/java/com/hazelcast/cache/CacheClearTest.java:80
↓ 4 callers
Method
createCacheConfig
()
hazelcast/src/test/java/com/hazelcast/cache/CacheReadWriteThroughTest.java:112
↓ 4 callers
Method
createCacheFromNewClient
(String cacheName)
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/invalidation/ClientCacheReconciliationTest.java:191
↓ 4 callers
Method
createCacheRecordStore
(HazelcastInstance instance, String cacheName, int part
hazelcast/src/test/java/com/hazelcast/cache/recordstore/CacheRecordStoreTestSupport.java:81
↓ 4 callers
Method
createCapacity
(Node node)
hazelcast/src/main/java/com/hazelcast/internal/config/AbstractDomConfigProcessor.java:427
↓ 4 callers
Method
createClientAndGetMap
()
hazelcast/src/test/java/com/hazelcast/client/map/impl/query/PortableGenericRecordQueryTest.java:127
↓ 4 callers
Method
createClock
()
hazelcast/src/main/java/com/hazelcast/internal/util/Clock.java:58
↓ 4 callers
Method
createConfig
()
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/ClientNearCacheTestSupport.java:56
↓ 4 callers
Method
createConfig
()
hazelcast/src/test/java/com/hazelcast/internal/ascii/RestLogLevelTest.java:59
↓ 4 callers
Method
createConfig
(MapStoreConfig.InitialLoadMode loadMode, EntryLoader entryLoader)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryLoaderInitializationTest.java:121
↓ 4 callers
Method
createConveyorArray
(int count, int queueCount, int queueSize)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/ExecutionPlan.java:731
↓ 4 callers
Method
createDag
( PhysicalRel physicalRel, QueryParameterMetadata parameterMetadata, Set<P
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/CalciteSqlOptimizerImpl.java:889
↓ 4 callers
Method
createDb
(String database)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/AbstractMySqlCdcIntegrationTest.java:59
↓ 4 callers
Method
createDeleteOperation
Creates a delete operation for an entry with key equal to {@code key} from the map named {@code name}. You can also specify whether this operation sho
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:75
↓ 4 callers
Method
createDescriptor
(String name)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsRegistryImpl.java:286
↓ 4 callers
Method
createDirectory
(String dirName)
hazelcast/src/test/java/com/hazelcast/nio/IOUtilTest.java:885
↓ 4 callers
Method
createDiscoveryStrategyConfigs
Extracts aliased discovery configs from {@code config} and creates a list of {@link DiscoveryStrategyConfig} out of them.
hazelcast/src/main/java/com/hazelcast/internal/config/AliasedDiscoveryConfigUtils.java:79
↓ 4 callers
Method
createEnabled
(long durationMs)
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrencyDetection.java:66
↓ 4 callers
Method
createEntry
(int i)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/StreamKafkaPTest.java:953
↓ 4 callers
Method
createExecutor
(String name, int poolSize, int queueCapacity, ExecutorType
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/impl/ExecutionServiceImpl.java:196
↓ 4 callers
Method
createFakeResource
(String resourceUrl)
hazelcast/src/test/java/com/hazelcast/config/UserCodeNamespaceConfigTest.java:177
↓ 4 callers
Method
createFieldProbe
(Field field, Probe probe, SourceMetadata sourceMetadata)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/FieldProbe.java:72
↓ 4 callers
Method
createForDecode
(Frame startFrame)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientMessage.java:164
↓ 4 callers
Method
createFromData
Returns metadata for given binary data. Implementing class decides the type of the metadata returned. @return metadata created from given binary data
hazelcast/src/main/java/com/hazelcast/map/impl/MetadataInitializer.java:36
↓ 4 callers
Method
createFunction
(String original, String from, String to)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/ReplaceFunctionIntegrationTest.java:149
↓ 4 callers
Method
createGetOperation
(String name, Data dataKey)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:89
↓ 4 callers
Method
createHealthMonitor
Creates and implementation of the {@link HealthMonitor} depending on Hazelcast edition. @return a new {@link HealthMonitor} instance for this member
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:467
↓ 4 callers
Method
createImap
()
hazelcast/src/test/java/com/hazelcast/jet/SimpleTestInClusterSupportTest.java:128
↓ 4 callers
Method
createInnerPortableClassDefinition
(int portableVersion)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/PortableClassVersionTest.java:229
↓ 4 callers
Method
createInt2ObjectHashMap
Utility method that creates an {@link Int2ObjectHashMap} with its initialCapacity calculated to minimize rehash operations
hazelcast/src/main/java/com/hazelcast/internal/util/MapUtil.java:71
↓ 4 callers
Method
createItemIdArray
Creates an array of IDs for all operations in this transaction log. The ID is negative if the operation is a remove operation. @return an array of ID
hazelcast/src/main/java/com/hazelcast/collection/impl/txncollection/CollectionTransactionLogRecord.java:110
↓ 4 callers
Method
createKafkaCluster
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaSqlTestSupport.java:65
↓ 4 callers
Method
createLinkedHashSet
Utility method that creates an {@link java.util.LinkedHashSet} with its initialCapacity calculated to minimize rehash operations
hazelcast/src/main/java/com/hazelcast/internal/util/SetUtil.java:50
← previous
next →
11,701–11,800 of 147,315, ranked by callers