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
↓ 2 callers
Method
containsAll
(Collection<?> c)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberSelectingCollection.java:125
↓ 2 callers
Method
containsAnyOf
(Exception e, List<String> nonRetryableKeywords)
hazelcast/src/main/java/com/hazelcast/spi/utils/RetryUtils.java:79
↓ 2 callers
Method
containsCycles
Check if the given type contains cycles.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/QueryUtils.java:169
↓ 2 callers
Method
containsEdge
(V v1, V v2)
hazelcast/src/main/java/com/hazelcast/internal/util/graph/Graph.java:71
↓ 2 callers
Method
containsEntry
(boolean binary, Data key, Data value)
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapContainer.java:136
↓ 2 callers
Method
containsInternal
(Collection<Data> dataList)
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueProxySupport.java:142
↓ 2 callers
Method
containsKey
Long primitive specialised containsKey. @param key the key to check. @return true if the map contains key as a key, false otherwise.
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2LongHashMap.java:201
↓ 2 callers
Method
containsPartition
(Integer partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateGeneratorImpl.java:464
↓ 2 callers
Method
containsPartition
(Integer partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateGeneratorImpl.java:623
↓ 2 callers
Method
containsValue
(Object value)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:55
↓ 2 callers
Method
containsVertex
(Vertex vertex)
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:350
↓ 2 callers
Method
containsVertexName
(Vertex vertex)
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:354
↓ 2 callers
Method
convert
(Object value)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/type/converter/ToConverter.java:35
↓ 2 callers
Method
convert
Converts a {@link TableField} to {@link RelDataType}.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:334
↓ 2 callers
Method
convertAndApplyForSingleAttributeValue
(Object attributeValue)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/AbstractPredicate.java:87
↓ 2 callers
Method
convertCollation
(List<RelFieldCollation> colls)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/FieldCollation.java:55
↓ 2 callers
Method
convertEntryToRow
(QueryableEntry entry)
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryResult.java:301
↓ 2 callers
Method
convertFromBson
Converts from MongoDB-read value. <p> In other words, converts for SELECT statements.
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/ConversionsFromBson.java:57
↓ 2 callers
Method
convertFromCompositeFilter
( List<IndexComponentCandidate> candidates, QueryDataType converterType, P
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexComponentFilterResolver.java:167
↓ 2 callers
Method
convertLiteral
Converts the given REX literal to runtime {@link ConstantExpression constant expression}. @param literal the literal to convert. @return the resultin
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/visitor/RexToExpression.java:134
↓ 2 callers
Method
convertMemberListToMemberUuidList
(Collection<Member> members)
hazelcast/src/main/java/com/hazelcast/internal/util/ParallelOperationInvoker.java:131
↓ 2 callers
Method
convertNullAs
(org.apache.calcite.util.Sarg<?> sarg)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/visitor/RexToExpression.java:543
↓ 2 callers
Method
convertOperands
(Object[] operands)
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/RexToMongo.java:119
↓ 2 callers
Method
convertRow
(Row row)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlJsonTestSupport.java:118
↓ 2 callers
Method
convertSargValue
(Comparable<CI> value, SqlTypeName typeName)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/visitor/RexToExpression.java:547
↓ 2 callers
Method
convertToData
Convert the supplied argument into serialized format. @throws HazelcastSerializationException when serialization fails.
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:587
↓ 2 callers
Method
convertToData
(Iterable<K> keys)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:685
↓ 2 callers
Method
convertToErrorHolder
(Throwable t)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientExceptionFactory.java:441
↓ 2 callers
Method
convertToInputStream
(DataInput in, int offset)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:184
↓ 2 callers
Method
convertToJobStream
(@Nullable M member, GetJobIdsResult result)
hazelcast/src/main/java/com/hazelcast/jet/impl/AbstractJetInstance.java:278
↓ 2 callers
Method
convertToObjectKeys
Deserialises all of the items in the provided collection if they are not deserialised already. @param keys the items to be deserialised @return the l
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/AbstractMapDataStore.java:113
↓ 2 callers
Method
convertToRingbufferFormat
Converts the {@code item} into the ringbuffer {@link InMemoryFormat} or keeps it unchanged if the supplied argument is already in the ringbuffer forma
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:576
↓ 2 callers
Method
convertToSelf
(Converter converter, Object val)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:1225
↓ 2 callers
Method
convertToTimestampIfNeeded
Convert the given temporal type to timestamp.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/misc/HazelcastArithmeticOperatorUtils.java:131
↓ 2 callers
Method
convertWindowBound
(long boundary, QueryDataType descriptorType)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/WindowUtils.java:119
↓ 2 callers
Method
converters
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/IndexScanSelectQueryBuilder.java:124
↓ 2 callers
Method
converters
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/SelectQueryBuilder.java:89
↓ 2 callers
Method
conveyorSum
(ToIntFunction<QueuedPipe<Object>> toIntF)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ConcurrentInboundEdgeStream.java:125
↓ 2 callers
Method
cooperativeTimeout
If {@code timeout > 0}, the test will fail if any call to processing method in a cooperative processor exceeds this timeout. Has no effect for non-coo
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:528
↓ 2 callers
Method
coordinationExecutor
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JobCoordinationService.java:1502
↓ 2 callers
Method
copy
( RelTraitSet traitSet, RexNode conditionExpr, RelNode left, R
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/StreamToStreamJoinPhysicalRel.java:105
↓ 2 callers
Method
copy
(int from, int to, int length)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/SessionWindowP.java:419
↓ 2 callers
Method
copyEntries
(Set<Entry<K, V>> source, Set<Entry<K, V>> destination)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/AggregatingMap.java:130
↓ 2 callers
Method
copyFromByteArray
Copies bytes from a Java byte array into this accessor's address space. @param source the source byte array @param offset index of the first byte to
hazelcast/src/main/java/com/hazelcast/internal/memory/MemoryAccessor.java:180
↓ 2 callers
Method
copyInputStream
(InputStream configStream, int readLimit)
hazelcast/src/main/java/com/hazelcast/config/ConfigStream.java:69
↓ 2 callers
Method
copyIntoTakeStack
(Node putStackHead)
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/MPSCQueue.java:258
↓ 2 callers
Method
copyMemory
(long srcAddress, long destAddress, long lengthBytes)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/StandardMemoryAccessor.java:123
↓ 2 callers
Method
copyOldValueToHeapWhenNeeded
(Object oldValue)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/EntryOperation.java:393
↓ 2 callers
Method
copyTo
Copies the payload contained in the Data to the destination buffer. <p> The dest byte-buffer needs to be large enough to contain the payload. Otherwis
hazelcast/src/main/java/com/hazelcast/internal/serialization/Data.java:65
↓ 2 callers
Method
copyToByteArray
Copies bytes from this accessor's address space to a Java byte array. @param srcAddress address of the first byte to copy @param destination the dest
hazelcast/src/main/java/com/hazelcast/internal/memory/MemoryAccessor.java:190
↓ 2 callers
Method
copyWithoutHeader
(Data src, byte[] dst, int dstOffset)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/AsyncSnapshotWriterImpl.java:207
↓ 2 callers
Method
countActiveJobs
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/SqlJobManagementTest.java:519
↓ 2 callers
Method
countConnectorCount
(String connectorName, HazelcastInstance[] instances)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/JetPhoneHomeTestUtil.java:75
↓ 2 callers
Method
create
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:977
↓ 2 callers
Method
create
( SqlService sqlService, String connectorType, String tableName,
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/test/TestAbstractSqlConnector.java:72
↓ 2 callers
Method
create
(Expression<?> time, ExtractField extractField)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/datetime/ExtractFunction.java:44
↓ 2 callers
Method
create
(Expression<?> original, Expression<?> from, Expression<?> to)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/string/ReplaceFunction.java:33
↓ 2 callers
Method
create
(Expression<?> operand)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/NotPredicate.java:39
↓ 2 callers
Method
create
(Expression<?>... operands)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/OrPredicate.java:39
↓ 2 callers
Method
create
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/record/AllTypesRecord.java:96
↓ 2 callers
Method
create
Factory method that creates a {@link RingbufferStoreWrapper}. It attempts to create the ring buffer store from several sources : <ul> <li>checks if th
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferStoreWrapper.java:83
↓ 2 callers
Method
create
()
hazelcast/src/main/java/com/hazelcast/console/ConsoleApp.java:1527
↓ 2 callers
Method
create
(Iterator<Map.Entry<K, ReplicatedRecord<K, V>>> iterator)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/LazySet.java:123
↓ 2 callers
Method
create
Creates an IdentifiedDataSerializable instance using given type ID @param typeId IdentifiedDataSerializable type ID @return IdentifiedDataSerializabl
hazelcast/src/main/java/com/hazelcast/nio/serialization/DataSerializableFactory.java:33
↓ 2 callers
Method
create
(String attribute, Comparable c)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/SqlPredicate.java:65
↓ 2 callers
Method
create
Returns a {@link ProcessorMetaSupplier} that behaves as specified by the provided file source builder. @param configuration the configuration object
hazelcast/src/main/java/com/hazelcast/jet/pipeline/file/impl/FileSourceFactory.java:38
↓ 2 callers
Method
create0
(SqlTypeName typeName, boolean nullable, int bitWidth)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastIntegerType.java:162
↓ 2 callers
Method
createAccumulator
@param info info which will be used by an {@link Accumulator}. @return an instance of {@link Accumulator}.
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/AccumulatorFactory.java:31
↓ 2 callers
Method
createAddress
(String hostname, int defaultPort)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/discovery/HazelcastCloudDiscovery.java:163
↓ 2 callers
Method
createAddress
(KubernetesClient.EndpointAddress address, ToIntFunction<KubernetesClient.EndpointAddress> portRes
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesApiEndpointResolver.java:105
↓ 2 callers
Method
createAddress
(AddressDefinition addressDef, int port)
hazelcast/src/main/java/com/hazelcast/instance/impl/DefaultAddressPicker.java:174
↓ 2 callers
Method
createAddressPicker
(Node node)
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeContext.java:36
↓ 2 callers
Method
createAllFieldsDTO
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:151
↓ 2 callers
Method
createAndFillEntries
()
hazelcast/src/test/java/com/hazelcast/cache/CachePutAllTest.java:100
↓ 2 callers
Method
createAndInitReplacer
(String password, Properties properties)
hazelcast/src/test/java/com/hazelcast/config/replacer/EncryptionReplacerTest.java:170
↓ 2 callers
Method
createAndInitializeEntryLoader
(int entryCount)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryLoaderInitializationTest.java:147
↓ 2 callers
Method
createAndInitializeEntryLoaderWithExpiry
(int entryCount)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryLoaderInitializationTest.java:130
↓ 2 callers
Method
createArrayOfFixedSizeFieldsDTO
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:210
↓ 2 callers
Method
createAvroPayload
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/file/FileUtil.java:193
↓ 2 callers
Method
createAwsEc2Api
(String tagKey, String tagValue)
hazelcast/src/test/java/com/hazelcast/aws/AwsEc2ApiTest.java:81
↓ 2 callers
Method
createAzureConfig
()
hazelcast/src/main/java/com/hazelcast/azure/AzureDiscoveryStrategy.java:89
↓ 2 callers
Method
createBasicConfig
()
hazelcast/src/test/java/com/hazelcast/cache/CacheCreationTest.java:250
↓ 2 callers
Method
createCPSubsystem
Creates the relevant {@link CPSubsystem}.
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:421
↓ 2 callers
Method
createCacheConcurrently
(CountDownLatch latch, CacheManager cacheManager, AtomicIntege
hazelcast/src/test/java/com/hazelcast/cache/CacheBasicAbstractTest.java:1050
↓ 2 callers
Method
createCacheConfig
()
hazelcast/src/test/java/com/hazelcast/cache/CacheDestroyTest.java:89
↓ 2 callers
Method
createCacheConfig
(InMemoryFormat inMemoryFormat)
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/ClientCacheNearCacheSerializationCountTest.java:242
↓ 2 callers
Method
createCacheConfig
(InMemoryFormat inMemoryFormat)
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/invalidation/ClientCacheInvalidationMemberAddRemoveTest.java:258
↓ 2 callers
Method
createCacheConfig
(InMemoryFormat inMemoryFormat)
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/invalidation/ClientCacheInvalidationMetadataDistortionTest.java:157
↓ 2 callers
Method
createCacheConfig
(String cacheName, C configuration)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:388
↓ 2 callers
Method
createCacheConfig
Creates a new cache configuration on Hazelcast members. @param client the client instance which will send the operation to server @param newC
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheHelper.java:91
↓ 2 callers
Method
createCacheCreatedEvent
(Data dataKey, Data dataValue, long expirationTime
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventContextUtil.java:70
↓ 2 callers
Method
createCacheEventData
(String name, int cacheEventType, Data dataKey, Data
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:84
↓ 2 callers
Method
createCacheExpiredEvent
(Data dataKey, Data dataValue, long expirationTime
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventContextUtil.java:62
↓ 2 callers
Method
createCacheInternal
(String cacheName, C configuration)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:105
↓ 2 callers
Method
createCachePartitionLostListenerConfiguredXml
(String cacheName, String listenerName)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:1817
↓ 2 callers
Method
createCachePartitionLostListenerConfiguredYaml
(String cacheName, String listenerName)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:1882
↓ 2 callers
Method
createCacheProxy
(CacheConfig<K, V> cacheConfig)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:421
↓ 2 callers
Method
createCacheStatIfAbsent
(String cacheNameWithPrefix)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:91
↓ 2 callers
Method
createCachingProvider
(HazelcastInstance server)
hazelcast/src/test/java/com/hazelcast/cache/CachePartitionIteratorMigrationTest.java:62
↓ 2 callers
Method
createCall
(SqlLiteral functionQualifier, SqlParserPos pos, SqlNode... operands)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/misc/HazelcastCaseOperator.java:211
← previous
next →
17,101–17,200 of 147,315, ranked by callers