MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 10 callersMethodidentity
Returns a projection that does no transformation. <p> If you use the returned projection in a 3.9 cluster it may cause a serialization exception. @par
hazelcast/src/main/java/com/hazelcast/projection/Projections.java:40
↓ 10 callersMethodifNotExists
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlCreateJob.java:82
↓ 10 callersMethodillegalStateException
(IOException cause)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/DefaultCompactWriter.java:164
↓ 10 callersMethodincrement
(String operation)
hazelcast/src/test/java/com/hazelcast/map/standalone/SimpleFunctionalMapTest.java:174
↓ 10 callersMethodincrementSetLatencyNanos
(long latencyNanos)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalMapStatsImpl.java:524
↓ 10 callersMethodinfiniteValueError
(QueryDataTypeFamily target)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/Converter.java:371
↓ 10 callersMethodinit
(InitialMembershipEvent event)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/TranslateToPublicAddressProvider.java:167
↓ 10 callersMethodinit
(SerializationService ss, Object key, Object value, Extractors extractors)
hazelcast/src/main/java/com/hazelcast/query/impl/CachedQueryEntry.java:60
↓ 10 callersMethodinit
Initialize the recordStore after creation
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:522
↓ 10 callersMethodinjectDependencies
(T obj)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:297
↓ 10 callersMethodinsert
(Object key, Object value)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapStoreTest.java:1305
↓ 10 callersMethodinspectOutOfMemoryError
(Throwable throwable)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:150
↓ 10 callersMethodintHash
(final int value, final int mask)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Hashing.java:29
↓ 10 callersMethodinvalidateNearCache
(List<Data> keys)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperation.java:409
↓ 10 callersMethodinvoke
(CollectionOperation operation)
hazelcast/src/main/java/com/hazelcast/collection/impl/collection/AbstractCollectionProxyImpl.java:242
↓ 10 callersMethodinvokeOnTarget
(String serviceName, Operation op, Address target)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationServiceImpl.java:391
↓ 10 callersMethodinvokeWithPredicate
(ClientMessage request, Predicate predicate)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientMapProxy.java:1324
↓ 10 callersMethodisAtLeast
Check if the current runtime version is greater than or equal to the given version. Returns false if the given version is UNKNOWN.
hazelcast/src/main/java/com/hazelcast/internal/util/JavaVersion.java:61
↓ 10 callersMethodisAutoRemoveStaleData
Returns whether automatic removal of stale Persistence restart data is enabled. @return whether automatically removal of stale data is enabled
hazelcast/src/main/java/com/hazelcast/config/PersistenceConfig.java:227
↓ 10 callersMethodisCatalogPersistenceEnabled
Returns {@code true} if persistence is enabled for SQL Catalog. @return {@code true} if persistence is enabled for SQL Catalog
hazelcast/src/main/java/com/hazelcast/config/SqlConfig.java:78
↓ 10 callersMethodisCooperative
Tells whether this processor is able to participate in cooperative multithreading. If this processor declares itself cooperative, it will share a thre
hazelcast/src/main/java/com/hazelcast/jet/core/Processor.java:144
↓ 10 callersMethodisDestroyed
Determines whether this Cache instance has been destroyed. @return <code>true</code> if this Cache instance is destroyed; <code>false</code> if it is
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:917
↓ 10 callersMethodisDisablePerEntryInvalidationEvents
Returns invalidation events disabled status for per entry. @return {@code true} if invalidation events are disabled for per entry, {@code false} othe
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:503
↓ 10 callersMethodisDoubleRepresentable
@return {@code true} if instances of the given class can be represented as double values without any magnitude and precision losses, {@code false} oth
hazelcast/src/main/java/com/hazelcast/query/impl/Numbers.java:262
↓ 10 callersMethodisEnabled
Returns true if User Code Deployment is enabled @return {@code true} when User Code Deployment is enabled
hazelcast/src/main/java/com/hazelcast/config/UserCodeDeploymentConfig.java:91
↓ 10 callersMethodisEnabled
Checks if this PartitionGroupConfig is enabled. @return {@code true} if this PartitionGroupConfig is enabled, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/PartitionGroupConfig.java:193
↓ 10 callersMethodisEnabled
()
hazelcast/src/main/java/com/hazelcast/config/MemberAddressProviderConfig.java:47
↓ 10 callersMethodisEnabled
Returns if the event journal is enabled. @return {@code true} if the event journal is enabled, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/EventJournalConfig.java:152
↓ 10 callersMethodisLaterThan
(MembersView other)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembersView.java:150
↓ 10 callersMethodisLocalMemberMaster
Returns true only if local member is the last known master by {@code InternalPartitionServiceImpl}. <p> Last known master is updated under partition s
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:1386
↓ 10 callersMethodisLocalMemberSafe
Checks whether local member is in safe state. <p> Safe state means; all backups of partitions currently owned by local member are in sync when this me
hazelcast/src/main/java/com/hazelcast/partition/PartitionService.java:146
↓ 10 callersMethodisLongRepresentable
@return {@code true} if instances of the given class can be represented as long values without any magnitude and precision losses, {@code false} other
hazelcast/src/main/java/com/hazelcast/query/impl/Numbers.java:271
↓ 10 callersMethodisMadeProgress
()
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ProgressState.java:33
↓ 10 callersMethodisManagementEnabled
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheMXBeanImpl.java:69
↓ 10 callersMethodisPersistWanReplicatedData
@return {@code true} when persistence of replicated data into backing store is enabled, otherwise returns {@code false}. By default, this method retur
hazelcast/src/main/java/com/hazelcast/config/WanConsumerConfig.java:136
↓ 10 callersMethodisShutdown
@return true if the client is shutdown.
hazelcast/src/main/java/com/hazelcast/client/util/ClientStateListener.java:222
↓ 10 callersMethodisSnapshotEnabled
Returns {@code true} if key-based coalescing is configured for this WAN publisher. When enabled, only the latest {@link WanEvent} of a key is sent to
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:177
↓ 10 callersMethodisStartCompleted
@return {@code true} if this {@code Node} has completed startup, {@code false} otherwise. @see NodeExtension#isStartCompleted()
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:263
↓ 10 callersMethodisStatisticsEnabled
Checks if statistics are enabled for this reliable topic. @return {@code true} if enabled, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/ReliableTopicConfig.java:250
↓ 10 callersMethodisTemporal
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataTypeFamily.java:132
↓ 10 callersMethodisVisible
Asserts that the {@code job} is already visible by {@linkplain JetService#getJob} methods. @param client Hazelcast Instance used to query the clu
hazelcast/src/test/java/com/hazelcast/jet/core/JobAssertions.java:87
↓ 10 callersMethodjobConfig
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:197
↓ 10 callersMethodjoin
Concatenates {@code leftRow} and {@code rightRow} into one, evaluates the {@code predicate} on it, and if the predicate passed, returns the joined row
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/ExpressionUtil.java:155
↓ 10 callersMethodjsonArrayRow
(final Object... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/json/JsonArrayFunctionIntegrationTest.java:120
↓ 10 callersMethodkeySet
Transactional implementation of {@link IMap#keySet()}. @see IMap#keySet()
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:239
↓ 10 callersMethodliteMember
(String host)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/ClientClusterServiceBaseTest.java:418
↓ 10 callersMethodload
Get 'load' recorded by the current pipeline. It can be used to calculate whether this pipeline should be migrated to a different {@link NioThread} @r
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/MigratablePipeline.java:55
↓ 10 callersMethodloadClass
(Map<String, String> options, boolean isKey)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataJavaResolver.java:243
↓ 10 callersMethodlocalSync
()
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/CdcSinksTest.java:314
↓ 10 callersMethodlongHash
(final long value, final int mask)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Hashing.java:33
↓ 10 callersMethodmapToRequestFn
Set the function mapping the item from a pipeline item to an index request <p> For example, to create an IndexRequest for a versioned document: <pre>{
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/ElasticSinkBuilder.java:143
↓ 10 callersMethodmapWithMerging
Returns a sink that uses the supplied functions to extract the key and value with which to update a Hazelcast {@code IMap}. If the map already contain
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sinks.java:395
↓ 10 callersMethodmapping
Adapts an aggregate operation that takes items of type {@code U} to one that takes items of type {@code T}, by applying the given mapping function to
hazelcast/src/main/java/com/hazelcast/jet/aggregate/AggregateOperations.java:605
↓ 10 callersMethodmatchIndex
Matches an index for the given pattern and match hint. @param pattern the pattern to match an index for. May be either an
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:499
↓ 10 callersMethodmaxAttempts
Sets the maximum number of retry attempts.
hazelcast/src/main/java/com/hazelcast/jet/retry/RetryStrategies.java:75
↓ 10 callersMethodmember
(String host)
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/TranslateToPublicAddressProviderTest.java:222
↓ 10 callersMethodmergePolicyConfig
(String mergePolicy, int batchSize)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/dynamicconfig/AbstractUpdateConfigMessageTask.java:89
↓ 10 callersMethodmoveAttachedFilesToPipeline
(@Nonnull ServiceFactory<?, S> serviceFactory)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/ComputeStageImplBase.java:464
↓ 10 callersMethodnamed
Decorate any {@link Runnable} with a {@link NamedTask} to provide naming information to scheduler. @param name The name that the task will have @
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/TaskUtils.java:39
↓ 10 callersMethodnanValueError
(QueryDataTypeFamily target)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/Converter.java:377
↓ 10 callersMethodnewDefaultCacheConfig
(String name)
hazelcast/src/test/java/com/hazelcast/config/helpers/CacheConfigHelper.java:57
↓ 10 callersMethodnewDelegatingFuture
(ClientInvocationFuture future, ClientMessageDecoder decoder)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:1208
↓ 10 callersMethodnewExpirationManager
(HazelcastInstance node)
hazelcast/src/test/java/com/hazelcast/internal/eviction/AbstractExpirationManagerTest.java:231
↓ 10 callersMethodnewExtractor
()
hazelcast/src/test/java/com/hazelcast/query/impl/QueryEntryTest.java:248
↓ 10 callersMethodnewTransactionContext
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/queue/TransactionalQueueSplitBrainProtectionWriteTest.java:176
↓ 10 callersMethodnext
()
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/RandomizedRateTracker.java:45
↓ 10 callersMethodnext
()
hazelcast/src/main/java/com/hazelcast/internal/util/iterator/RestartingMemberIterator.java:104
↓ 10 callersMethodnextCompletionId
()
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupport.java:1158
↓ 10 callersMethodnextPowerOfTwo
Fast method of finding the next power of 2 greater than or equal to the supplied value. <p> If the value is &lt;= 0 then 1 will be returned. <p> This
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/util/BitUtil.java:40
↓ 10 callersMethodnextSequence
Returns next number in sequence for the partition. @return next number in sequence.
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/sequence/PartitionSequencer.java:38
↓ 10 callersMethodnormalSize
returns the number of normal operations pending. This method is thread safe. This method returns a best effort value and should only be used for mon
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationQueue.java:69
↓ 10 callersMethodnot
@return an iterator that represents a result of negation of the given iterator over the given universe (a set of known elements).
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithms.java:51
↓ 10 callersMethodnotDone
Equivalent to {@code mergeWith(NO_PROGRESS)}, but more descriptive in certain usages.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ProgressTracker.java:71
↓ 10 callersMethodor
@return an iterator that represents a result of union over the given iterators.
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithms.java:43
↓ 10 callersMethodparseString
Create instance from String @param string the string value to parse @return instance of {@link CacheDeserializedValues} @throws IllegalArgumentExcept
hazelcast/src/main/java/com/hazelcast/config/CacheDeserializedValues.java:63
↓ 10 callersMethodpartitionIdSet
(PartitionIdSet partitionIdSet)
hazelcast/src/main/java/com/hazelcast/map/impl/query/Query.java:222
↓ 10 callersMethodprepareMetricsService
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/MetricsServiceTest.java:380
↓ 10 callersMethodprintlnBold
(Object obj)
hazelcast/src/main/java/com/hazelcast/client/console/ClientConsoleApp.java:1582
↓ 10 callersMethodproperties
()
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:52
↓ 10 callersMethodput
(final Integer key, final V value)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Int2ObjectHashMap.java:200
↓ 10 callersMethodputCacheConfigIfAbsent
(CacheConfig config)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:79
↓ 10 callersMethodputFloat
Writes the given float value to given address. @param address the address where the float value will be written to @param x the float value to
hazelcast/src/main/java/com/hazelcast/internal/memory/MemoryAccessor.java:128
↓ 10 callersMethodqueryIndexedDateFieldAsNullValue
(boolean ordered, Predicate<Integer, SampleTestObjects
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryNullIndexingTest.java:135
↓ 10 callersMethodqueue
Retrieves the queue backing this inbox.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ArrayDequeInbox.java:78
↓ 10 callersMethodquoteCompoundIdentifier
Quote the given compound identifier using Calcite dialect (= Hazelcast dialect). You can use this when giving information to the user, e.g. in excepti
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/QuoteIdentifierUtil.java:65
↓ 10 callersMethodreadFloat
(int position)
hazelcast/src/main/java/com/hazelcast/internal/nio/BufferObjectDataInput.java:55
↓ 10 callersMethodreadMap
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:275
↓ 10 callersMethodreadNullableBoolean
Reads a nullable boolean. <p> This method can also read a non-nullable boolean. @param fieldName name of the field. @return the value of the field. @
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:532
↓ 10 callersMethodreadRequiredChar
(char ch)
hazelcast/src/main/java/com/hazelcast/internal/json/JsonParser.java:292
↓ 10 callersMethodreadRequiredChar
(char ch)
hazelcast/src/main/java/com/hazelcast/internal/json/JsonReducedValueParser.java:150
↓ 10 callersMethodreadResponse
(InputStream is)
hazelcast/src/test/java/com/hazelcast/client/impl/clientside/ClientTestUtil.java:84
↓ 10 callersMethodreadUnsignedShort
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:111
↓ 10 callersMethodreduce
An alternative to {@link Stream#reduce(Object, BiFunction, BinaryOperator) Stream.reduce(identity, accumulator, combiner)}, which is not parallelizabl
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:407
↓ 10 callersMethodregisterListener
Registers a listener on all cluster nodes. @param serviceName service name @param topic topic name @param listener listener instance @return
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/EventService.java:96
↓ 10 callersMethodregisterMetric
(Metric metric, final int value)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/HealthMonitorTest.java:63
↓ 10 callersMethodreleaseAwaitingTask
()
hazelcast/src/test/java/com/hazelcast/executor/CompletableFutureTest.java:297
↓ 10 callersMethodremoteMapBuilder
Returns a builder to build a source that fetches entries from a remote Hazelcast {@code IMap} with the specified name. It provides a fluent API to bui
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:663
↓ 10 callersMethodremoteMapJournal
Returns a source that will stream the {@link EventJournalMapEvent} events of the Hazelcast {@code IMap} with the specified name from a remote cluster.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:716
↓ 10 callersMethodremove
(K key, long now, UUID transactionId)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:51
↓ 10 callersMethodremoveEntry
Removes the given entry from this index. @param entry the entry to remove. @param operationSource the operation source. @throws QueryExcept
hazelcast/src/main/java/com/hazelcast/query/impl/Index.java:109
← previousnext →6,801–6,900 of 147,315, ranked by callers