MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 22 callersMethodcheckFailure_2
(Object operand1, Object operand2, int expectedErrorCode, String expectedErrorMessage, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/RoundFunctionIntegrationTest.java:343
↓ 22 callersMethodcheckFailure_2
(Object operand1, Object operand2, int expectedErrorCode, String expectedErrorMessage, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/TruncateFunctionIntegrationTest.java:334
↓ 22 callersMethodcollection
()
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/AbstractMongoTest.java:129
↓ 22 callersMethodcomparing
{@code Serializable} variant of {@link Comparator#comparing(Function, Comparator) java.util.Comparator#comparing(Function, Comparator)}. @param <T> t
hazelcast/src/main/java/com/hazelcast/function/ComparatorEx.java:132
↓ 22 callersMethodconfigGenerator
( T subConfig, boolean configIsXml, int indent, String subConf
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigGeneratorUtil.java:300
↓ 22 callersMethodcontainsKey
(K key)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:90
↓ 22 callersMethodcreateEntryListener
(final boolean isLocal)
hazelcast/src/test/java/com/hazelcast/map/ListenerTest.java:687
↓ 22 callersMethodcreateHazelcastInstance
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/BaseElasticTest.java:129
↓ 22 callersMethodcreateUpdateCountResult
(long updateCount)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/UpdateSqlResultImpl.java:37
↓ 22 callersMethoddataException
(String message, Throwable cause)
hazelcast/src/main/java/com/hazelcast/sql/impl/QueryException.java:101
↓ 22 callersMethoddecodeResponse
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlExecuteCodec.java:218
↓ 22 callersMethoddeleteAsync
Asynchronously removes the given key, returning an {@link CompletionStage} on which the caller can register further computation stages to be invoked u
hazelcast/src/main/java/com/hazelcast/map/IMap.java:1201
↓ 22 callersMethodentryKey
Returns a function that extracts the key of a {@link Entry}. @param <K> type of entry's key
hazelcast/src/main/java/com/hazelcast/function/Functions.java:47
↓ 22 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/internal/util/BiTuple.java:50
↓ 22 callersMethoderror
(String s)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/ValidatorResource.java:28
↓ 22 callersMethodextract
Extracts a value from the given target object. <p> The method does not return any value since the extracted value may be collected by the ValueCollect
hazelcast/src/main/java/com/hazelcast/query/extractor/ValueExtractor.java:122
↓ 22 callersMethodforDates
(@Nonnull String format)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/datetime/Formatter.java:244
↓ 22 callersMethodfrom
(Member member)
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionReplica.java:124
↓ 22 callersMethodgenerateRandomKeys
(HazelcastInstance instance, int partitionCount)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapAbstractTest.java:129
↓ 22 callersMethodgetActiveConnections
()
hazelcast/src/main/java/com/hazelcast/client/impl/connection/ClientConnectionManager.java:65
↓ 22 callersMethodgetAllHazelcastClients
Gets an immutable collection of all client HazelcastInstances created in this JVM. <p> In managed environments such as Java EE or OSGi Hazelcast can b
hazelcast/src/main/java/com/hazelcast/client/HazelcastClient.java:307
↓ 22 callersMethodgetAverageHitLatency
Returns the average hit latency (in nanoseconds) for the index.
hazelcast/src/main/java/com/hazelcast/query/LocalIndexStats.java:51
↓ 22 callersMethodgetCacheConfigs
()
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:85
↓ 22 callersMethodgetCachingProvider
()
hazelcast/src/test/java/com/hazelcast/cache/CacheTestSupport.java:121
↓ 22 callersMethodgetChannel
()
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioPipeline.java:94
↓ 22 callersMethodgetClient
(TestHazelcastFactory testHazelcastFactory, NearCacheConfig nearCacheConfig)
hazelcast/src/test/java/com/hazelcast/client/map/impl/nearcache/ClientMapNearCacheTest.java:1213
↓ 22 callersMethodgetClusterState
Returns the state of the cluster. <p> If cluster state change is in process, {@link ClusterState#IN_TRANSITION} will be returned. <p> This is a local
hazelcast/src/main/java/com/hazelcast/cluster/Cluster.java:152
↓ 22 callersMethodgetContext
Returns an existing or newly created context for given query path. If maximum cache size is reached, then some entries are evicted. The newly created
hazelcast/src/main/java/com/hazelcast/query/impl/getters/JsonGetterContextCache.java:39
↓ 22 callersMethodgetDestination
Returns the new owner of the migrating partition replica. @return the new owner of the migrating partition replica
hazelcast/src/main/java/com/hazelcast/partition/ReplicaMigrationEvent.java:50
↓ 22 callersMethodgetDiskTierConfig
Returns the disk tier config of this tiered-store configuration. @return {@code TSDiskTierConfig} of this tiered-store configuration.
hazelcast/src/main/java/com/hazelcast/config/TieredStoreConfig.java:98
↓ 22 callersMethodgetEndpoint
Gets the endpoint for a given connection. @param connection the connection to the endpoint. @return the found endpoint or null of no endpoint was fou
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEndpointManager.java:46
↓ 22 callersMethodgetExtractorClassName
Gets the full class name of the extractor in a String format, e.g. {@code com.example.car.SpeedExtractor}. @return the full class name of the extract
hazelcast/src/main/java/com/hazelcast/config/AttributeConfig.java:124
↓ 22 callersMethodgetFileName
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:246
↓ 22 callersMethodgetIdString
Returns the string representation of this job's ID.
hazelcast/src/main/java/com/hazelcast/jet/Job.java:61
↓ 22 callersMethodgetJoiner
()
hazelcast/src/main/java/com/hazelcast/instance/impl/Node.java:955
↓ 22 callersMethodgetKey
Returns the key for the event entry. @return the entry key
hazelcast/src/main/java/com/hazelcast/map/EventJournalMapEvent.java:33
↓ 22 callersMethodgetMapConfigs
Returns all registered map configurations. @return registered map configurations
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:269
↓ 22 callersMethodgetMapDataStore
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:460
↓ 22 callersMethodgetMember
(Address address)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberMap.java:167
↓ 22 callersMethodgetMemberListJoinVersion
Returns the member list join version of the local member instance. <p> The join algorithm assigns different member list join versions to each member i
hazelcast/src/main/java/com/hazelcast/internal/cluster/ClusterService.java:207
↓ 22 callersMethodgetNameWithPrefix
Gets the full name of the {@link com.hazelcast.cache.ICache}, including the manager scope prefix. @return the full name of the {@link com.hazelcast.c
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:293
↓ 22 callersMethodgetNextSequenceToReadFrom
Returns the sequence of the item following the last read item. This sequence can then be used to read items following the ones returned by this result
hazelcast/src/main/java/com/hazelcast/ringbuffer/ReadResultSet.java:106
↓ 22 callersMethodgetOperator
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlOption.java:69
↓ 22 callersMethodgetOwnerUuid
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/Transaction.java:46
↓ 22 callersMethodgetPartitionId
Returns the partition ID for a {@link Data} key. @param key the {@link Data} key @return the partition ID @throws NullPointerException if key is {@co
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:99
↓ 22 callersMethodgetPartitionStateManager
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:1310
↓ 22 callersMethodgetPermission
Creates a permission @param name the permission name @param serviceName the service name @param actions the actions @return the created Pe
hazelcast/src/main/java/com/hazelcast/security/permission/ActionConstants.java:147
↓ 22 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/AndPredicate.java:207
↓ 22 callersMethodgetRight
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/RecurrentStructuresNestedFieldsTest.java:407
↓ 22 callersMethodgetTotalSetLatency
Returns the total latency of set operations. To get the average latency, divide by the number of sets @return the total latency of set operations
hazelcast/src/main/java/com/hazelcast/map/LocalMapStats.java:193
↓ 22 callersMethodgetTtlMillis
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecord.java:73
↓ 22 callersMethodgetVertex
Returns the vertex with the given name, or {@code null} if there is no vertex with that name.
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:293
↓ 22 callersMethodinNextMilli
(Runnable r)
hazelcast/src/test/java/com/hazelcast/internal/management/MCEventStoreTest.java:77
↓ 22 callersMethodincrementPutLatencyNanos
(long latencyNanos)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalMapStatsImpl.java:514
↓ 22 callersMethodisCooperative
Returns a boolean flag whether this expression is allowed to be evaluated in cooperative processor. <p> Expressions returning false directly (i.e. not
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/Expression.java:86
↓ 22 callersMethodisFromInclusive
@return {@code true} if the predicate range is left-closed, {@code false} otherwise. <p> Can't be {@code true} if the predicate range is left-unbounde
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangePredicate.java:43
↓ 22 callersMethodisInfoEnabled
Checks if the {@link Level#INFO} level is enabled. @return true if enabled, false otherwise
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/logging/TpcLogger.java:112
↓ 22 callersMethodisNullOrEmpty
(int pos)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableInternalGenericRecord.java:257
↓ 22 callersMethodisPresent
@since 5.6
hazelcast/src/main/java/com/hazelcast/vector/Hint.java:40
↓ 22 callersMethodisShutdown
()
hazelcast/src/test/java/com/hazelcast/jet/core/TestUtil.java:128
↓ 22 callersMethodisToInclusive
@return {@code true} if the predicate range is right-closed, {@code false} otherwise. <p> Can't be {@code true} if the predicate range is right-unboun
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangePredicate.java:57
↓ 22 callersMethodisUnbounded
(RelNode rel)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:265
↓ 22 callersMethodisUnknown
@return {@code true} if this version is equal to {@link Version#UNKNOWN}
hazelcast/src/main/java/com/hazelcast/version/Version.java:250
↓ 22 callersMethoditems
(@Nonnull SupplierEx<T>... items)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/CdcSinksTest.java:328
↓ 22 callersMethodmap
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/multimap/MultiMapSplitBrainProtectionReadTest.java:179
↓ 22 callersMethodmap
Returns a sink that puts {@code Map.Entry}s it receives into a Hazelcast {@code IMap} with the specified name. <p> This sink provides the exactly-once
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sinks.java:136
↓ 22 callersMethodnewInvalidationOnChangeEnabledNearCacheConfig
(String name)
hazelcast/src/test/java/com/hazelcast/client/map/impl/nearcache/ClientMapNearCacheTest.java:1197
↓ 22 callersMethodoverflowError
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/PlusOperatorIntegrationTest.java:610
↓ 22 callersMethodpickAddress
Picks both server socket listener address and public address. @throws Exception if failure happened while picking an address.
hazelcast/src/main/java/com/hazelcast/instance/AddressPicker.java:35
↓ 22 callersMethodpopulateNearCache
(NearCacheTestContext<Integer, String, ?, ?> context)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheBasicTest.java:1701
↓ 22 callersMethodpopulateSet
(OAHashSet<Integer> set, int elementCount)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/OAHashSetTest.java:690
↓ 22 callersMethodput
Associates the specified value with the specified key in this cache, returning an existing value if one existed. <p> If the cache previously contained
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheRecordStore.java:92
↓ 22 callersMethodputExternally
(K key, V value, long expirationTime)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/TestEntryStore.java:123
↓ 22 callersMethodputToBatchSrcMap
(Collection<Integer> data)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineTestSupport.java:126
↓ 22 callersMethodreadIncompatibleField
(@Nonnull String fieldName, FieldType fieldType, Reader<String, T> rea
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/MorphingPortableReader.java:357
↓ 22 callersMethodreadInt
(byte[] buffer, int pos, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:143
↓ 22 callersMethodremoteMap
Returns a source that fetches entries from the Hazelcast {@code IMap} with the specified name in a remote cluster identified by the supplied {@code Cl
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:559
↓ 22 callersMethodremove
Removes the existing entry mapping in this index. @param value the value to remove the mapping from. @param entry the entry to remo
hazelcast/src/main/java/com/hazelcast/query/impl/IndexStore.java:106
↓ 22 callersMethodsetClassLoader
Sets the class-loader to be used during de-serialization and as context class-loader of Hazelcast internal threads. <p> If not set (or set to {@code n
hazelcast/src/main/java/com/hazelcast/config/Config.java:537
↓ 22 callersMethodsetEnabled
(boolean enabled)
hazelcast/src/main/java/com/hazelcast/internal/config/MapStoreConfigReadOnly.java:53
↓ 22 callersMethodsetGenericRecord
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:529
↓ 22 callersMethodsetReconnectMode
How a client reconnect to cluster after a disconnect can be configured. This parameter is used by default strategy and custom implementations may igno
hazelcast/src/main/java/com/hazelcast/client/config/ClientConnectionStrategyConfig.java:98
↓ 22 callersMethodsinkToBag
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineTestSupport.java:157
↓ 22 callersMethodstartNodes
(final Config config, int count)
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionCorrectnessTestSupport.java:96
↓ 22 callersMethodstreaming
()
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:507
↓ 22 callersMethodsubmitToAllMembers
Submits task to all cluster members and returns a map of Member-Future pairs representing pending completion of the task on each member. @param task
hazelcast/src/main/java/com/hazelcast/core/IExecutorService.java:167
↓ 22 callersMethodsumHash
Sums the hash of the left and the right children <p> May be used only when calculating a non-leaf node's hash code from its children's hashes. @param
hazelcast/src/main/java/com/hazelcast/wan/impl/merkletree/MerkleTreeUtil.java:162
↓ 22 callersMethodtoLocalDateTime
(long timestamp)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:380
↓ 22 callersMethodtoNearCacheKey
(Object key)
hazelcast/src/main/java/com/hazelcast/client/map/impl/nearcache/NearCachedClientMapProxy.java:625
↓ 22 callersMethodtoNearCacheKeyWithStrategy
(Object key)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/NearCachedMapProxyImpl.java:631
↓ 22 callersMethodtraverseStream
Returns a traverser over the given stream. It will traverse it through its spliterator, which it obtains immediately. When it exhausts the stream, it
hazelcast/src/main/java/com/hazelcast/jet/Traversers.java:133
↓ 22 callersMethoduncheckRun
(@Nonnull RunnableEx r)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:173
↓ 22 callersMethodvalidateOpWithoutDeduct
( AggregateOperation1<? super T, A, ? extends R> op, Function<? super A, ? extends X>
hazelcast/src/test/java/com/hazelcast/jet/aggregate/AggregateOperationsTest.java:754
↓ 22 callersMethodvalueCount
Returns the number of values that match the given key in the multimap. <p> <b>Warning:</b> This method uses {@code hashCode} and {@code equals} of the
hazelcast/src/main/java/com/hazelcast/multimap/MultiMap.java:300
↓ 22 callersMethodwriteVariableSizeField
(@Nonnull String fieldName, @Nonnull FieldKind fieldKind, @Nulla
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/DefaultCompactWriter.java:241
↓ 21 callersMethodadaptSupplier
(ProcessorMetaSupplier processorMetaSupplier)
hazelcast/src/test/java/com/hazelcast/jet/TestContextSupport.java:53
↓ 21 callersMethodadd
(E element)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/OAHashSet.java:124
↓ 21 callersMethodadd
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/internal/util/collection/LongHashSet.java:71
↓ 21 callersMethodadd
Registers the given aggregate operation with the tag corresponding to an input to the co-aggregating operation being built. If you are preparing an op
hazelcast/src/main/java/com/hazelcast/jet/aggregate/CoAggregateOperationBuilder.java:69
↓ 21 callersMethodaddClass
@param className name of the class that will be sent to cluster @return this for chaining
hazelcast/src/main/java/com/hazelcast/client/config/ClientUserCodeDeploymentConfig.java:115
← previousnext →4,001–4,100 of 147,315, ranked by callers