MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 2 callersMethodcontainsAll
(Collection<?> c)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberSelectingCollection.java:125
↓ 2 callersMethodcontainsAnyOf
(Exception e, List<String> nonRetryableKeywords)
hazelcast/src/main/java/com/hazelcast/spi/utils/RetryUtils.java:79
↓ 2 callersMethodcontainsCycles
Check if the given type contains cycles.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/QueryUtils.java:169
↓ 2 callersMethodcontainsEdge
(V v1, V v2)
hazelcast/src/main/java/com/hazelcast/internal/util/graph/Graph.java:71
↓ 2 callersMethodcontainsEntry
(boolean binary, Data key, Data value)
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapContainer.java:136
↓ 2 callersMethodcontainsInternal
(Collection<Data> dataList)
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueProxySupport.java:142
↓ 2 callersMethodcontainsKey
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 callersMethodcontainsPartition
(Integer partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateGeneratorImpl.java:464
↓ 2 callersMethodcontainsPartition
(Integer partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateGeneratorImpl.java:623
↓ 2 callersMethodcontainsValue
(Object value)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:55
↓ 2 callersMethodcontainsVertex
(Vertex vertex)
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:350
↓ 2 callersMethodcontainsVertexName
(Vertex vertex)
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:354
↓ 2 callersMethodconvert
(Object value)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/type/converter/ToConverter.java:35
↓ 2 callersMethodconvert
Converts a {@link TableField} to {@link RelDataType}.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:334
↓ 2 callersMethodconvertAndApplyForSingleAttributeValue
(Object attributeValue)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/AbstractPredicate.java:87
↓ 2 callersMethodconvertCollation
(List<RelFieldCollation> colls)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/FieldCollation.java:55
↓ 2 callersMethodconvertEntryToRow
(QueryableEntry entry)
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryResult.java:301
↓ 2 callersMethodconvertFromBson
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 callersMethodconvertFromCompositeFilter
( List<IndexComponentCandidate> candidates, QueryDataType converterType, P
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexComponentFilterResolver.java:167
↓ 2 callersMethodconvertLiteral
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 callersMethodconvertMemberListToMemberUuidList
(Collection<Member> members)
hazelcast/src/main/java/com/hazelcast/internal/util/ParallelOperationInvoker.java:131
↓ 2 callersMethodconvertNullAs
(org.apache.calcite.util.Sarg<?> sarg)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/visitor/RexToExpression.java:543
↓ 2 callersMethodconvertOperands
(Object[] operands)
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/RexToMongo.java:119
↓ 2 callersMethodconvertRow
(Row row)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlJsonTestSupport.java:118
↓ 2 callersMethodconvertSargValue
(Comparable<CI> value, SqlTypeName typeName)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/visitor/RexToExpression.java:547
↓ 2 callersMethodconvertToData
Convert the supplied argument into serialized format. @throws HazelcastSerializationException when serialization fails.
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:587
↓ 2 callersMethodconvertToData
(Iterable<K> keys)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:685
↓ 2 callersMethodconvertToErrorHolder
(Throwable t)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientExceptionFactory.java:441
↓ 2 callersMethodconvertToInputStream
(DataInput in, int offset)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:184
↓ 2 callersMethodconvertToJobStream
(@Nullable M member, GetJobIdsResult result)
hazelcast/src/main/java/com/hazelcast/jet/impl/AbstractJetInstance.java:278
↓ 2 callersMethodconvertToObjectKeys
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 callersMethodconvertToRingbufferFormat
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 callersMethodconvertToSelf
(Converter converter, Object val)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:1225
↓ 2 callersMethodconvertToTimestampIfNeeded
Convert the given temporal type to timestamp.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/misc/HazelcastArithmeticOperatorUtils.java:131
↓ 2 callersMethodconvertWindowBound
(long boundary, QueryDataType descriptorType)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/WindowUtils.java:119
↓ 2 callersMethodconverters
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/IndexScanSelectQueryBuilder.java:124
↓ 2 callersMethodconverters
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/SelectQueryBuilder.java:89
↓ 2 callersMethodconveyorSum
(ToIntFunction<QueuedPipe<Object>> toIntF)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ConcurrentInboundEdgeStream.java:125
↓ 2 callersMethodcooperativeTimeout
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 callersMethodcoordinationExecutor
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JobCoordinationService.java:1502
↓ 2 callersMethodcopy
( RelTraitSet traitSet, RexNode conditionExpr, RelNode left, R
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/StreamToStreamJoinPhysicalRel.java:105
↓ 2 callersMethodcopy
(int from, int to, int length)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/SessionWindowP.java:419
↓ 2 callersMethodcopyEntries
(Set<Entry<K, V>> source, Set<Entry<K, V>> destination)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/AggregatingMap.java:130
↓ 2 callersMethodcopyFromByteArray
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 callersMethodcopyInputStream
(InputStream configStream, int readLimit)
hazelcast/src/main/java/com/hazelcast/config/ConfigStream.java:69
↓ 2 callersMethodcopyIntoTakeStack
(Node putStackHead)
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/MPSCQueue.java:258
↓ 2 callersMethodcopyMemory
(long srcAddress, long destAddress, long lengthBytes)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/StandardMemoryAccessor.java:123
↓ 2 callersMethodcopyOldValueToHeapWhenNeeded
(Object oldValue)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/EntryOperation.java:393
↓ 2 callersMethodcopyTo
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 callersMethodcopyToByteArray
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 callersMethodcopyWithoutHeader
(Data src, byte[] dst, int dstOffset)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/AsyncSnapshotWriterImpl.java:207
↓ 2 callersMethodcountActiveJobs
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/SqlJobManagementTest.java:519
↓ 2 callersMethodcountConnectorCount
(String connectorName, HazelcastInstance[] instances)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/JetPhoneHomeTestUtil.java:75
↓ 2 callersMethodcreate
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:977
↓ 2 callersMethodcreate
( SqlService sqlService, String connectorType, String tableName,
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/test/TestAbstractSqlConnector.java:72
↓ 2 callersMethodcreate
(Expression<?> time, ExtractField extractField)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/datetime/ExtractFunction.java:44
↓ 2 callersMethodcreate
(Expression<?> original, Expression<?> from, Expression<?> to)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/string/ReplaceFunction.java:33
↓ 2 callersMethodcreate
(Expression<?> operand)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/NotPredicate.java:39
↓ 2 callersMethodcreate
(Expression<?>... operands)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/OrPredicate.java:39
↓ 2 callersMethodcreate
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/record/AllTypesRecord.java:96
↓ 2 callersMethodcreate
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 callersMethodcreate
()
hazelcast/src/main/java/com/hazelcast/console/ConsoleApp.java:1527
↓ 2 callersMethodcreate
(Iterator<Map.Entry<K, ReplicatedRecord<K, V>>> iterator)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/LazySet.java:123
↓ 2 callersMethodcreate
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 callersMethodcreate
(String attribute, Comparable c)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/SqlPredicate.java:65
↓ 2 callersMethodcreate
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 callersMethodcreate0
(SqlTypeName typeName, boolean nullable, int bitWidth)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastIntegerType.java:162
↓ 2 callersMethodcreateAccumulator
@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 callersMethodcreateAddress
(String hostname, int defaultPort)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/discovery/HazelcastCloudDiscovery.java:163
↓ 2 callersMethodcreateAddress
(KubernetesClient.EndpointAddress address, ToIntFunction<KubernetesClient.EndpointAddress> portRes
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesApiEndpointResolver.java:105
↓ 2 callersMethodcreateAddress
(AddressDefinition addressDef, int port)
hazelcast/src/main/java/com/hazelcast/instance/impl/DefaultAddressPicker.java:174
↓ 2 callersMethodcreateAddressPicker
(Node node)
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeContext.java:36
↓ 2 callersMethodcreateAllFieldsDTO
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:151
↓ 2 callersMethodcreateAndFillEntries
()
hazelcast/src/test/java/com/hazelcast/cache/CachePutAllTest.java:100
↓ 2 callersMethodcreateAndInitReplacer
(String password, Properties properties)
hazelcast/src/test/java/com/hazelcast/config/replacer/EncryptionReplacerTest.java:170
↓ 2 callersMethodcreateAndInitializeEntryLoader
(int entryCount)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryLoaderInitializationTest.java:147
↓ 2 callersMethodcreateAndInitializeEntryLoaderWithExpiry
(int entryCount)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryLoaderInitializationTest.java:130
↓ 2 callersMethodcreateArrayOfFixedSizeFieldsDTO
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:210
↓ 2 callersMethodcreateAvroPayload
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/file/FileUtil.java:193
↓ 2 callersMethodcreateAwsEc2Api
(String tagKey, String tagValue)
hazelcast/src/test/java/com/hazelcast/aws/AwsEc2ApiTest.java:81
↓ 2 callersMethodcreateAzureConfig
()
hazelcast/src/main/java/com/hazelcast/azure/AzureDiscoveryStrategy.java:89
↓ 2 callersMethodcreateBasicConfig
()
hazelcast/src/test/java/com/hazelcast/cache/CacheCreationTest.java:250
↓ 2 callersMethodcreateCPSubsystem
Creates the relevant {@link CPSubsystem}.
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeExtension.java:421
↓ 2 callersMethodcreateCacheConcurrently
(CountDownLatch latch, CacheManager cacheManager, AtomicIntege
hazelcast/src/test/java/com/hazelcast/cache/CacheBasicAbstractTest.java:1050
↓ 2 callersMethodcreateCacheConfig
()
hazelcast/src/test/java/com/hazelcast/cache/CacheDestroyTest.java:89
↓ 2 callersMethodcreateCacheConfig
(InMemoryFormat inMemoryFormat)
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/ClientCacheNearCacheSerializationCountTest.java:242
↓ 2 callersMethodcreateCacheConfig
(InMemoryFormat inMemoryFormat)
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/invalidation/ClientCacheInvalidationMemberAddRemoveTest.java:258
↓ 2 callersMethodcreateCacheConfig
(InMemoryFormat inMemoryFormat)
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/invalidation/ClientCacheInvalidationMetadataDistortionTest.java:157
↓ 2 callersMethodcreateCacheConfig
(String cacheName, C configuration)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:388
↓ 2 callersMethodcreateCacheConfig
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 callersMethodcreateCacheCreatedEvent
(Data dataKey, Data dataValue, long expirationTime
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventContextUtil.java:70
↓ 2 callersMethodcreateCacheEventData
(String name, int cacheEventType, Data dataKey, Data
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/CustomTypeFactory.java:84
↓ 2 callersMethodcreateCacheExpiredEvent
(Data dataKey, Data dataValue, long expirationTime
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventContextUtil.java:62
↓ 2 callersMethodcreateCacheInternal
(String cacheName, C configuration)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:105
↓ 2 callersMethodcreateCachePartitionLostListenerConfiguredXml
(String cacheName, String listenerName)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:1817
↓ 2 callersMethodcreateCachePartitionLostListenerConfiguredYaml
(String cacheName, String listenerName)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:1882
↓ 2 callersMethodcreateCacheProxy
(CacheConfig<K, V> cacheConfig)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:421
↓ 2 callersMethodcreateCacheStatIfAbsent
(String cacheNameWithPrefix)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:91
↓ 2 callersMethodcreateCachingProvider
(HazelcastInstance server)
hazelcast/src/test/java/com/hazelcast/cache/CachePartitionIteratorMigrationTest.java:62
↓ 2 callersMethodcreateCall
(SqlLiteral functionQualifier, SqlParserPos pos, SqlNode... operands)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/misc/HazelcastCaseOperator.java:211
← previousnext →17,101–17,200 of 147,315, ranked by callers