MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 20 callersMethodgetMaxIdle
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpiryMetadata.java:53
↓ 20 callersMethodgetMaxSetLatency
Returns the maximum latency of set operations. @return the maximum latency of set operations
hazelcast/src/main/java/com/hazelcast/map/LocalMapStats.java:221
↓ 20 callersMethodgetMemberAddress
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembersViewResponse.java:46
↓ 20 callersMethodgetMerkleTreeConfig
Gets the {@code MerkleTreeConfig} for this {@code MapConfig} @return merkle tree config
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:749
↓ 20 callersMethodgetMultiMap
()
hazelcast/src/main/java/com/hazelcast/console/ConsoleApp.java:121
↓ 20 callersMethodgetNamespacesConfig
@return the namespaces configuration object @since 5.4.0
hazelcast/src/main/java/com/hazelcast/config/Config.java:3298
↓ 20 callersMethodgetObjectFields
@return read-only list of fields
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:162
↓ 20 callersMethodgetPartitionId
Returns partition ID which this sequence belongs to. @return partition ID which this sequence belongs to.
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/sequence/Sequenced.java:36
↓ 20 callersMethodgetPartitioningAttributeConfigs
Get Partition Attribute configs used for creation of {@link com.hazelcast.partition.strategy.AttributePartitioningStrategy} @return list of partition
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:831
↓ 20 callersMethodgetPredicates
Visitable predicates are treated as effectively immutable, therefore callers should not make any changes to the returned array.
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/OrPredicate.java:182
↓ 20 callersMethodgetReplicaManager
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:1320
↓ 20 callersMethodgetReplicatedMap
()
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapStatsTest.java:53
↓ 20 callersMethodgetResourceConfigs
Returns all the registered resource configurations.
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1117
↓ 20 callersMethodgetRingbufferConfig
Returns the RingbufferConfig for the given name, creating one if necessary and adding it to the collection of known configurations. <p> The configurat
hazelcast/src/main/java/com/hazelcast/config/Config.java:1523
↓ 20 callersMethodgetSize
Returns the size which is used by the {@link MaxSizePolicy}. <p> The interpretation of the value depends on the configured {@link MaxSizePolicy}. @re
hazelcast/src/main/java/com/hazelcast/config/EvictionConfig.java:102
↓ 20 callersMethodgetTables
@return Collection of tables to be registered.
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/TableResolver.java:49
↓ 20 callersMethodgetVariableSize
(FieldDescriptor fieldDescriptor, Reader<T> reader)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/CompactInternalGenericRecord.java:344
↓ 20 callersMethodgetVersion
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:83
↓ 20 callersMethodinvokeOnPartition
(String serviceName, Operation op, int partitionId)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationServiceImpl.java:341
↓ 20 callersMethodinvokeOnStableClusterSerial
Invoke operation on all cluster members. <p> The invocation is serial: It iterates over all members starting from the oldest member to the youngest o
hazelcast/src/main/java/com/hazelcast/internal/util/InvocationUtil.java:77
↓ 20 callersMethodisDescending
()
hazelcast/src/main/java/com/hazelcast/internal/iteration/IndexIterationPointer.java:170
↓ 20 callersMethodisEnabled
Returns if this configuration is enabled @return {@code true} if this configuration is enabled, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/MapStoreConfig.java:193
↓ 20 callersMethodisIndexed
()
hazelcast/src/test/java/com/hazelcast/map/LocalIndexStatsTest.java:725
↓ 20 callersMethodisMigrationAllowed
Returns {@code true}, if migrations and replications are allowed in this state. @return {@code true} if migrations and replications are allowed in thi
hazelcast/src/main/java/com/hazelcast/cluster/ClusterState.java:196
↓ 20 callersMethodisNullEmptyTarget
()
hazelcast/src/main/java/com/hazelcast/query/impl/getters/MultiResult.java:122
↓ 20 callersMethodisRunning
Checks whether the instance is running. @return {@code true}, if instance is active and running, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/core/LifecycleService.java:33
↓ 20 callersMethodisShared
{@code true} if an instance of the data connection will be reused. {@code false} when on each usage the data connection instance should be created. Th
hazelcast/src/main/java/com/hazelcast/config/DataConnectionConfig.java:116
↓ 20 callersMethodjoinMapEntries
A shorthand factory for the common case of hash-joining with a stream of map entries. The right key extractor is {@code Map.Entry::getKey} and the rig
hazelcast/src/main/java/com/hazelcast/jet/pipeline/JoinClause.java:108
↓ 20 callersMethodkeyFn
Returns the function that extracts the key from stream items. The purpose of the key varies with the operation you apply.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/GeneralStageWithKey.java:61
↓ 20 callersMethodlistIterator
()
hazelcast/src/main/java/com/hazelcast/collection/impl/list/ListProxyImpl.java:129
↓ 20 callersMethodmemberOfLargerSameVersionGroup
Finds a larger same-version group of data members from a collection of members and, if {@code localMember} is from that group, return that. Otherwise,
hazelcast/src/main/java/com/hazelcast/sql/impl/CoreQueryUtils.java:78
↓ 20 callersMethodnewBuilder
@param ss the serializationService @param indexCopyBehavior the indexCopyBehavior @return new builder instance which will be used to cr
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:156
↓ 20 callersMethodnewSourceStage
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/WindowGroupAggregateTest.java:135
↓ 20 callersMethodnewTransactionContext
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/map/TransactionalMapSplitBrainProtectionWriteTest.java:266
↓ 20 callersMethodobject
(String... namesAndValues)
hazelcast/src/test/java/com/hazelcast/internal/json/JsonObject_Test.java:1020
↓ 20 callersMethodof
(X element1, Y element2)
hazelcast/src/main/java/com/hazelcast/internal/util/BiTuple.java:38
↓ 20 callersMethodonStart
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/MetricsPlugin.java:64
↓ 20 callersMethodoutboundPipeline
Returns the {@link OutboundPipeline} that belongs to this Channel. <p> This method is thread-safe, but most methods on the {@link OutboundPipeline} ar
hazelcast/src/main/java/com/hazelcast/internal/networking/Channel.java:118
↓ 20 callersMethodproduceSync
(String topic, Object key, Object value)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:185
↓ 20 callersMethodput
Transactional implementation of {@link IMap#put(Object, Object)}. <p> The object to be put will be accessible only in the current transaction context
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:127
↓ 20 callersMethodputClassLoader
(String methodName)
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/JetClassLoaderTest.java:346
↓ 20 callersMethodputToMap
(Map<String, Integer> dest, Collection<Integer> data)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineTestSupport.java:134
↓ 20 callersMethodrandomKey
()
hazelcast/src/test/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArray16byteKeyImplTest.java:398
↓ 20 callersMethodrandomKey
()
hazelcast/src/test/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArray12byteKeyImplTest.java:368
↓ 20 callersMethodrandomKey
()
hazelcast/src/test/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArray16byteKeyNoValueTest.java:337
↓ 20 callersMethodreadBooleanArray
@return the boolean array read @throws IOException if it reaches end of file before finish reading
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:55
↓ 20 callersMethodregister
(String serviceName, ClientProxyFactory factory)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ProxyManager.java:204
↓ 20 callersMethodremove
(Object queryCacheKey)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/QueryCacheRecordStore.java:49
↓ 20 callersMethodrunnable
()
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/scheduledexecutor/ScheduledExecutorSplitBrainProtectionWriteTest.java:254
↓ 20 callersMethodserialize
(String str)
hazelcast/src/test/java/com/hazelcast/jet/impl/util/AsyncSnapshotWriterImplTest.java:307
↓ 20 callersMethodservice
(ServicePort... ports)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesFakeUtils.java:487
↓ 20 callersMethodset
Sets or replaces a value at the given index to the new given value. @param index the index to set value at. @param value the value to set. @return a
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseIntArray.java:224
↓ 20 callersMethodsetCooperativeThreadCount
Sets the number of threads each cluster member will use to execute Jet jobs. This refers only to threads executing <em>cooperative</em> processors; ea
hazelcast/src/main/java/com/hazelcast/jet/config/JetConfig.java:86
↓ 20 callersMethodsetKey
(Data key, Object metadataKey)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/JsonMetadataStore.java:40
↓ 20 callersMethodsetLevel
Sets the level of this logger to the given level. @param level the level to set, can be {@code null} if the underlying logging framework
hazelcast/src/main/java/com/hazelcast/logging/impl/InternalLogger.java:34
↓ 20 callersMethodsetPacketType
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/PacketTest.java:59
↓ 20 callersMethodsetType
(QueryDataType type)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/MappingField.java:85
↓ 20 callersMethodsingleton
Creates a singleton {@code MemberMap} including only specified member. @param member sole member in map @return singleton {@code MemberMap}
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberMap.java:73
↓ 20 callersMethodstart
Starts the Server, initializes its endpoints, starts threads, etc. After start, Endpoints becomes fully operational. <p> If it is already started, the
hazelcast/src/main/java/com/hazelcast/internal/server/Server.java:116
↓ 20 callersMethodstreamingDag
()
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:123
↓ 20 callersMethodstrip
A {@code null}-safe version of {@link String#strip()}
hazelcast/src/main/java/com/hazelcast/internal/util/StringUtil.java:249
↓ 20 callersMethodtest
Evaluates this predicate with the given arguments. @param t the first argument @param u the second argument @param v the third argument @return {@cod
hazelcast/src/main/java/com/hazelcast/jet/function/TriPredicate.java:53
↓ 20 callersMethodtestVerbosity
(String... args)
hazelcast/src/test/java/com/hazelcast/client/console/HazelcastCommandLineTest.java:818
↓ 20 callersMethodthenAccept
(Consumer<? super V> action)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientDelegatingFuture.java:178
↓ 20 callersMethodthenApplyAsync
(Function<? super V, ? extends U> fn)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientDelegatingFuture.java:168
↓ 20 callersMethodtoLocalDate
(DateString string)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/visitor/RexToExpression.java:665
↓ 20 callersMethodtoString
()
hazelcast/src/main/java/com/hazelcast/config/RestApiConfig.java:139
↓ 20 callersMethodvalueMiddle
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionType.java:38
↓ 20 callersMethodvalues
Returns the collection of values in the multimap. <p> <b>Warning:</b> The collection is <b>NOT</b> backed by the map, so changes to the map are <b>NOT
hazelcast/src/main/java/com/hazelcast/multimap/MultiMap.java:223
↓ 20 callersMethodwhenEntryIsRemoved_thenNearCacheShouldBeInvalidated
With the {@link NearCacheTestContext#dataAdapter} we have to set {@link NearCacheConfig#setInvalidateOnChange(boolean)}. With the {@link NearCacheTest
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheBasicTest.java:1241
↓ 20 callersMethodwithPartitionCount
(int partitionCount)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:94
↓ 20 callersMethodwrapObjectWithMap
(String key, Object value)
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigYamlGenerator.java:1962
↓ 19 callersMethodacquire
Acquires a permit if one is available, and returns immediately, reducing the number of available permits by one. <p> If no permit is available, then t
hazelcast/src/main/java/com/hazelcast/cp/ISemaphore.java:164
↓ 19 callersMethodadd
(TransactionLogRecord transactionLogRecord)
hazelcast/src/main/java/com/hazelcast/transaction/impl/Transaction.java:40
↓ 19 callersMethodaddClass
Adds the given classes and recursively all their nested (inner & anonymous) classes to the Jet job's classpath. They will be accessible to all the cod
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:312
↓ 19 callersMethodasXmlString
Converts {@link ClientConfig} to xml representation using {@link ClientConfigXmlGenerator}.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ImdgUtil.java:81
↓ 19 callersMethodassertAssignment
( int[] partitionCounts, int processorIdx, int totalParallelism, Tuple2<Integer, Integ
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaPartitionAssignmentTest.java:108
↓ 19 callersMethodassertContains
(String string, String sequence)
hazelcast-build-utils/src/test/java/com/hazelcast/buildutils/PackageDefinitionTest.java:130
↓ 19 callersMethodassertOptimization
(Predicate original, Predicate expected)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/EvaluateVisitorTest.java:202
↓ 19 callersMethodattemptFailed
()
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/RetryTracker.java:35
↓ 19 callersMethodbuildVectorCollectionConfig
( String collectionName, String indexName, int indexDim, Metri
hazelcast/src/test/java/com/hazelcast/config/vector/VectorTestHelper.java:22
↓ 19 callersMethodcheckCollectionImmutable
(Collection<T> c)
hazelcast/src/test/java/com/hazelcast/map/BasicMapTest.java:752
↓ 19 callersMethodcheckLiteral
( SqlLiteral literal, Object expectedValue, Object expectedStringValue,
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/LiteralTypeResolutionTest.java:102
↓ 19 callersMethodcheckParameter
(Object parameterValue, Object expectedValue)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/AbsFunctionIntegrationTest.java:171
↓ 19 callersMethodclassNameOrImplClass
(String className, Object impl)
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfigXmlGenerator.java:650
↓ 19 callersMethodclear
Clears out all entries from this index.
hazelcast/src/main/java/com/hazelcast/query/impl/Index.java:282
↓ 19 callersMethodcolumn
(String name, SqlColumnType type, boolean nullable)
hazelcast-sql/src/test/java/com/hazelcast/sql/SqlMetadataTest.java:143
↓ 19 callersMethodcount
()
hazelcast/src/main/java/com/hazelcast/internal/util/LatencyDistribution.java:121
↓ 19 callersMethodcreateCache
()
hazelcast/src/test/java/com/hazelcast/internal/eviction/CacheExpirationBouncingMemberTest.java:109
↓ 19 callersMethodcreateCollection
Picks right collection type, like {@link java.util.Set} or {@link java.util.List} depending on the {@link MultiMapConfig#getValueCollectionType()} and
hazelcast/src/main/java/com/hazelcast/multimap/impl/ValueCollectionFactory.java:46
↓ 19 callersMethodcreateTestDatabaseProvider
()
hazelcast/src/test/java/com/hazelcast/test/jdbc/OracleDatabaseProviderFactory.java:28
↓ 19 callersMethodcreateTopic
(AtomicInteger count, Collection<String> receivedValues)
hazelcast/src/test/java/com/hazelcast/client/topic/ClientTopicTest.java:199
↓ 19 callersMethoddecodeRequest
The id assigned during the listener registration.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientRemoveMigrationListenerCodec.java:76
↓ 19 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlFetchCodec.java:86
↓ 19 callersMethoddecodeRequest
If set to true, the server adds the listener only to itself, otherwise the listener is added for all members in the cluster.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientAddMigrationListenerCodec.java:91
↓ 19 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlExecuteCodec.java:138
↓ 19 callersMethoddecodeResponse
true if the listener existed and was removed, false otherwise.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientRemoveMigrationListenerCodec.java:95
↓ 19 callersMethoddecodeResponse
The listener registration id.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientAddMigrationListenerCodec.java:110
↓ 19 callersMethoddeserializeEntries
(ObjectDataInput in, int size, MapType result)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/defaultserializers/AbstractMapStreamSerializer.java:37
↓ 19 callersMethoddestroyCache
(String cacheName)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractHazelcastCacheManager.java:263
← previousnext →4,301–4,400 of 147,315, ranked by callers