MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 4 callersMethodcheckUrgentInvocation_withNoData
(ClientConnection connection)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/ClientInvocationServiceImplTest.java:242
↓ 4 callersMethodclassKeyName
Returns the key name in the form {@code class.<id>}
hazelcast/src/main/java/com/hazelcast/jet/impl/JobRepository.java:727
↓ 4 callersMethodclassSchema
()
extensions/avro/src/test/java/com/hazelcast/jet/avro/model/User.java:38
↓ 4 callersMethodclear
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpirySystem.java:99
↓ 4 callersMethodclearBit
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 callersMethodclearCachingProviderRegistry
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 callersMethodclearLockStore
(int partitionId, ObjectNamespace namespace)
hazelcast/src/main/java/com/hazelcast/internal/locksupport/LockSupportService.java:33
↓ 4 callersMethodclearNearCache
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 callersMethodclearParameters
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 callersMethodclearProcessorClassLoaders
Clears processor classloaders from the current thread
hazelcast/src/main/java/com/hazelcast/jet/impl/JobClassLoaderService.java:202
↓ 4 callersMethodclientAttributes
()
hazelcast/src/main/java/com/hazelcast/client/impl/statistics/ClientStatistics.java:45
↓ 4 callersMethodclientConfig
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/ReadMapOrCacheP_ConsistencyTest.java:258
↓ 4 callersMethodcloneConfig
(Object thisConfigObject, ClassLoader classloader)
hazelcast/src/test/java/com/hazelcast/test/starter/constructor/AbstractConfigConstructor.java:49
↓ 4 callersMethodcloneRemoving
(List<Member> members, int removeCount)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationManagerTest.java:198
↓ 4 callersMethodclose
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/join/FullScanResultSetIterator.java:104
↓ 4 callersMethodclose
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/join/JoinPredicateScanResultSetIterator.java:106
↓ 4 callersMethodcloseBlocks
()
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:353
↓ 4 callersMethodcloseCurrentFile
()
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/StreamFilesP.java:340
↓ 4 callersMethodcollect
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/MaxSqlAggregation.java:72
↓ 4 callersMethodcollect
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/MinSqlAggregation.java:72
↓ 4 callersMethodcollect
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 callersMethodcollection
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 callersMethodcolumns
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlCreateType.java:158
↓ 4 callersMethodcombine
Merge another aggregation into this aggregation.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/SqlAggregation.java:34
↓ 4 callersMethodcombineP
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 callersMethodcompare
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 callersMethodcompareAndSetSequence
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 callersMethodcompareTo
(XPortable o)
hazelcast/src/test/java/com/hazelcast/query/impl/extractor/specification/PortableDataStructure.java:345
↓ 4 callersMethodcomplete
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 callersMethodcomplexKeyTable
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/logical/LogicalUpdateTest.java:298
↓ 4 callersMethodcomponents
(String... names)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/CompositeIndexVisitorTest.java:85
↓ 4 callersMethodcompose
{@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 callersMethodcompress
(byte[] input)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:405
↓ 4 callersMethodcondition
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 callersMethodconfigureBatching
(Config config, int batchSize, int period)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/MapNearCacheInvalidationTest.java:241
↓ 4 callersMethodconnectionAdded
(C connection)
hazelcast/src/main/java/com/hazelcast/internal/nio/ConnectionListener.java:24
↓ 4 callersMethodconnectionClosedException
()
hazelcast/src/test/java/com/hazelcast/client/protocol/ClientMessageProtectionTest.java:221
↓ 4 callersMethodconnectionRemoved
(C connection)
hazelcast/src/main/java/com/hazelcast/internal/nio/ConnectionListener.java:26
↓ 4 callersMethodconstructAttributeBasedKey
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 callersMethodconstructMappingOptions
(String keyFormat, String valueFormat)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaSqlTestSupport.java:163
↓ 4 callersMethodcontains
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 callersMethodcontainsKey
(K key)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:114
↓ 4 callersMethodcontainsKey
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 callersMethodcontainsPagingPredicate
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 callersMethodcontext
(HazelcastSchema schema, QueryDataType... parameterTypes)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/OptimizerTestSupport.java:132
↓ 4 callersMethodconvert
(YamlNode yamlNode)
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlToJsonConverter.java:32
↓ 4 callersMethodconvert
(Comparable value, boolean convertNull)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangeVisitor.java:366
↓ 4 callersMethodcopy
(Operation op)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/OperationSerializationTest.java:218
↓ 4 callersMethodcopy
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:116
↓ 4 callersMethodcopyFile
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 callersMethodcopyMetadataFrom
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 callersMethodcopyState
()
extensions/kafka-connect/src/main/java/com/hazelcast/jet/kafka/connect/impl/TaskRunner.java:153
↓ 4 callersMethodcopyStream
(InputStream in, OutputStream out)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/IOUtil.java:96
↓ 4 callersMethodcopyWithInitializedDefaultMaxSizeForOnHeapMaps
(NearCacheConfig nearCacheConfig)
hazelcast/src/main/java/com/hazelcast/config/NearCacheConfigAccessor.java:31
↓ 4 callersMethodcount
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/ExecutionPlanBuilder.java:314
↓ 4 callersMethodcountDownCompletionLatch
(int id)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheSyncListenerCompleter.java:24
↓ 4 callersMethodcreate
(Expression<?>[] operands)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/CaseExpression.java:70
↓ 4 callersMethodcreate
(Expression<?>... operands)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/AndPredicate.java:39
↓ 4 callersMethodcreate
(int... partitions)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/PartitionIdSetTest.java:310
↓ 4 callersMethodcreate
(int keyCount)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/OrderedProcessingMergingStagesTest.java:322
↓ 4 callersMethodcreate
(int typeId)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ArrayDataSerializableFactory.java:42
↓ 4 callersMethodcreate
Factory method. @param queueCount number of queues
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/WatermarkCoalescer.java:100
↓ 4 callersMethodcreate
(String xmlString)
hazelcast/src/main/java/com/hazelcast/aws/XmlNode.java:44
↓ 4 callersMethodcreateAndFillEntries
()
hazelcast/src/test/java/com/hazelcast/cache/CacheClearTest.java:92
↓ 4 callersMethodcreateAvroFile
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 callersMethodcreateAvroFile
()
extensions/hadoop/src/test/java/com/hazelcast/jet/hadoop/file/AvroFileFormatTest.java:102
↓ 4 callersMethodcreateBackoffIdleStrategy
Creates a new BackoffIdleStrategy.
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/BackoffIdleStrategy.java:99
↓ 4 callersMethodcreateCacheConfig
()
hazelcast/src/test/java/com/hazelcast/cache/CacheClearTest.java:80
↓ 4 callersMethodcreateCacheConfig
()
hazelcast/src/test/java/com/hazelcast/cache/CacheReadWriteThroughTest.java:112
↓ 4 callersMethodcreateCacheFromNewClient
(String cacheName)
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/invalidation/ClientCacheReconciliationTest.java:191
↓ 4 callersMethodcreateCacheRecordStore
(HazelcastInstance instance, String cacheName, int part
hazelcast/src/test/java/com/hazelcast/cache/recordstore/CacheRecordStoreTestSupport.java:81
↓ 4 callersMethodcreateCapacity
(Node node)
hazelcast/src/main/java/com/hazelcast/internal/config/AbstractDomConfigProcessor.java:427
↓ 4 callersMethodcreateClientAndGetMap
()
hazelcast/src/test/java/com/hazelcast/client/map/impl/query/PortableGenericRecordQueryTest.java:127
↓ 4 callersMethodcreateClock
()
hazelcast/src/main/java/com/hazelcast/internal/util/Clock.java:58
↓ 4 callersMethodcreateConfig
()
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/ClientNearCacheTestSupport.java:56
↓ 4 callersMethodcreateConfig
()
hazelcast/src/test/java/com/hazelcast/internal/ascii/RestLogLevelTest.java:59
↓ 4 callersMethodcreateConfig
(MapStoreConfig.InitialLoadMode loadMode, EntryLoader entryLoader)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/EntryLoaderInitializationTest.java:121
↓ 4 callersMethodcreateConveyorArray
(int count, int queueCount, int queueSize)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/ExecutionPlan.java:731
↓ 4 callersMethodcreateDag
( PhysicalRel physicalRel, QueryParameterMetadata parameterMetadata, Set<P
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/CalciteSqlOptimizerImpl.java:889
↓ 4 callersMethodcreateDb
(String database)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/AbstractMySqlCdcIntegrationTest.java:59
↓ 4 callersMethodcreateDeleteOperation
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 callersMethodcreateDescriptor
(String name)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsRegistryImpl.java:286
↓ 4 callersMethodcreateDirectory
(String dirName)
hazelcast/src/test/java/com/hazelcast/nio/IOUtilTest.java:885
↓ 4 callersMethodcreateDiscoveryStrategyConfigs
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 callersMethodcreateEnabled
(long durationMs)
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrencyDetection.java:66
↓ 4 callersMethodcreateEntry
(int i)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/StreamKafkaPTest.java:953
↓ 4 callersMethodcreateExecutor
(String name, int poolSize, int queueCapacity, ExecutorType
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/impl/ExecutionServiceImpl.java:196
↓ 4 callersMethodcreateFakeResource
(String resourceUrl)
hazelcast/src/test/java/com/hazelcast/config/UserCodeNamespaceConfigTest.java:177
↓ 4 callersMethodcreateFieldProbe
(Field field, Probe probe, SourceMetadata sourceMetadata)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/FieldProbe.java:72
↓ 4 callersMethodcreateForDecode
(Frame startFrame)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientMessage.java:164
↓ 4 callersMethodcreateFromData
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 callersMethodcreateFunction
(String original, String from, String to)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/ReplaceFunctionIntegrationTest.java:149
↓ 4 callersMethodcreateGetOperation
(String name, Data dataKey)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperationProvider.java:89
↓ 4 callersMethodcreateHealthMonitor
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 callersMethodcreateImap
()
hazelcast/src/test/java/com/hazelcast/jet/SimpleTestInClusterSupportTest.java:128
↓ 4 callersMethodcreateInnerPortableClassDefinition
(int portableVersion)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/PortableClassVersionTest.java:229
↓ 4 callersMethodcreateInt2ObjectHashMap
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 callersMethodcreateItemIdArray
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 callersMethodcreateKafkaCluster
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaSqlTestSupport.java:65
↓ 4 callersMethodcreateLinkedHashSet
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
← previousnext →11,701–11,800 of 147,315, ranked by callers