MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 9 callersMethoddecrement
Decrements capacity count for a transaction. @param txnId id of transaction
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/TxnReservedCapacityCounter.java:70
↓ 9 callersMethoddefaultObjectType
Returns default value for the Object Type mapping property, so if user won't provide any type, this will be assumed. @since 5.3
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/SqlConnector.java:241
↓ 9 callersMethoddelete
(Data dataKey)
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapContainer.java:110
↓ 9 callersMethodderegisterAllLocalListeners
Deregisters all local listeners belonging to the given service and topic. @param serviceName service name @param topic topic name
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/EventService.java:180
↓ 9 callersMethodderegisterDynamicMetricsProvider
Deregisters the given dynamic metrics provider. The metrics collection cycles after this call will not call the given metrics provider until it is reg
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricsRegistry.java:175
↓ 9 callersMethoddescribeNetworkInterfaces
()
hazelcast/src/test/java/com/hazelcast/aws/AwsEc2ApiTest.java:209
↓ 9 callersMethoddiscoverNodes
Returns a discovered and filtered, if a {@link NodeFilter} is setup, set of discovered nodes to connect to. @return a set of discovered and filtered
hazelcast/src/main/java/com/hazelcast/spi/discovery/integration/DiscoveryService.java:64
↓ 9 callersMethoddisposeDeferredBlocks
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:117
↓ 9 callersMethoddoCall
(String methodName, boolean isCooperative, Runnable r)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:1004
↓ 9 callersMethoddoubleAvg
@param <I> type of the input object. @return an aggregator that calculates the average of the input values. Does NOT accept null input values. Accepts
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:173
↓ 9 callersMethoddoubleSum
@param <I> type of the input object. @return an aggregator that calculates the sum of the input values. Does NOT accept null input values. Accepts onl
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:628
↓ 9 callersMethodempty
()
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:562
↓ 9 callersMethodencodeRequest
(java.lang.String name, java.util.Collection<com.hazelcast.replicatedmap.impl.record.ReplicatedMapEntryViewHol
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapPutAllWithMetadataCodec.java:82
↓ 9 callersMethodencodeRequest
(java.lang.String name, @Nullable com.hazelcast.client.impl.protocol.codec.holder.WanConsumerConfigHolder cons
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddWanReplicationConfigCodec.java:82
↓ 9 callersMethodencodeRequest
(java.lang.String name, java.util.Collection<com.hazelcast.map.impl.SimpleEntryView<com.hazelcast.internal.ser
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapPutAllWithMetadataCodec.java:77
↓ 9 callersMethodencodeRequest
(java.lang.String name, @Nullable java.util.UUID cursorId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapEndEntryViewIterationCodec.java:74
↓ 9 callersMethodencodeRequest
(java.util.UUID uuid, byte[] token)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientTpcAuthenticationCodec.java:73
↓ 9 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddUserCodeNamespaceConfigCodec.java:95
↓ 9 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/DynamicConfigAddWanReplicationConfigCodec.java:110
↓ 9 callersMethodencodeResponse
(java.util.UUID cursorId, java.util.Collection<com.hazelcast.replicatedmap.impl.record.ReplicatedMapEntryViewH
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapFetchEntryViewsCodec.java:138
↓ 9 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MapPutAllWithMetadataCodec.java:101
↓ 9 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapEndEntryViewIterationCodec.java:96
↓ 9 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientTpcAuthenticationCodec.java:95
↓ 9 callersMethodensureNoSplitBrain
(SplitBrainProtectionOn requiredSplitBrainProtectionPermissionType)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/ReplicatedMapProxy.java:511
↓ 9 callersMethodensureNoSplitBrain
Ensures that the split brain protection with the given name is present. Throws a SplitBrainProtectionException if split brain protection not present.
hazelcast/src/main/java/com/hazelcast/splitbrainprotection/SplitBrainProtectionService.java:55
↓ 9 callersMethodentry
(Data data)
hazelcast/src/test/java/com/hazelcast/query/impl/DuplicateDetectingMultiResultTest.java:129
↓ 9 callersMethodequals
(Object o)
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/MongoSinkTest.java:288
↓ 9 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/SnapshotBarrier.java:48
↓ 9 callersMethodeventloopThread
Returns the {@link Thread} that runs the eventloop. The eventloop thread is created when the Reactor is created. <p/> This method is thread-safe. @re
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Reactor.java:187
↓ 9 callersMethodeventsWithKey
(String key)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SessionWindowPTest.java:233
↓ 9 callersMethodexecuteAndJoin
(List<MockTasklet> tasklets)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/TaskletExecutionServiceTest.java:386
↓ 9 callersMethodexecuteOnPartitions
Executes for each of the partitions, a task created by the taskFactory. For more info see the {@link com.hazelcast.spi.impl.operationexecutor.Operati
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationService.java:118
↓ 9 callersMethodexpectCardinalityEstimatorException
(ThrowingCallable toRun)
hazelcast/src/test/java/com/hazelcast/internal/config/MergePolicyValidatorCacheIntegrationTest.java:142
↓ 9 callersMethodexpectDuplicateElementError
(String elName, ThrowingCallable toRun)
hazelcast/src/test/java/com/hazelcast/config/XmlSchemaValidationTest.java:152
↓ 9 callersMethodexpectedInvalidMergePolicyException
(ThrowingCallable toRun)
hazelcast/src/test/java/com/hazelcast/internal/config/MergePolicyValidatorCacheIntegrationTest.java:149
↓ 9 callersMethodextendedRow
Creates a copy of this row with the number of fields increased by {@code extendBy}. The added fields will contain {@code null}s. If {@code extendBy ==
hazelcast/src/main/java/com/hazelcast/sql/impl/row/JetSqlRow.java:106
↓ 9 callersMethodextractMillis
(Object value)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/WindowUtils.java:157
↓ 9 callersMethodfileMapping
(String name, File file)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/file/SqlAvroTest.java:64
↓ 9 callersMethodfilesBuilder
Returns a builder object that offers a step-by-step fluent API to build a custom source to read files for the Pipeline API. The source reads lines fro
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:1206
↓ 9 callersMethodfilter
(long input)
hazelcast-spring-tests/src/test/java/com/hazelcast/spring/jet/Calculator.java:23
↓ 9 callersMethodfindDurableExecutorConfig
Finds existing Durable Executor config. @param name name of the config @return Durable Executor config or {@code null} when requested Durable Executo
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:198
↓ 9 callersMethodfindPropertyField
Return a {@link Field} object for the given {@code fieldName}. The field must be public and non-static. @param clazz The containing class @param
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ReflectionUtils.java:260
↓ 9 callersMethodfinishSnapshotRestore
Called after a job was restarted from a snapshot and the processor has consumed all the snapshot data in {@link #restoreFromSnapshot}. <p> If this met
hazelcast/src/main/java/com/hazelcast/jet/core/Processor.java:528
↓ 9 callersMethodfireEntryListenerEvent
(Data key, Data oldValue, Data value, String name, Address caller)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/ReplicatedMapEventPublishingService.java:200
↓ 9 callersMethodfirstArrangement
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:244
↓ 9 callersMethodflushAndResetMap
()
hazelcast/src/main/java/com/hazelcast/jet/impl/util/AsyncSnapshotWriter.java:28
↓ 9 callersMethodformatJobDuration
Formats a duration given im milliseconds to the form of: <ul> <li>{@code HH:MM:SS.sss}, if <24 hours <li>{@code Nd HH:MM:SS.sss} otherwise </u
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:709
↓ 9 callersMethodframe
(long ts, long value)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SlidingWindowP_stage1Test.java:191
↓ 9 callersMethodfrom
(boolean ignoreNulls, boolean distinct)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/CountSqlAggregations.java:30
↓ 9 callersMethodget
Returns the value for the given key. If this {@code HazelcastProperties} object is initialized with a "compromised" {@link Properties} object (ie one
hazelcast/src/main/java/com/hazelcast/spi/properties/HazelcastProperties.java:106
↓ 9 callersMethodget
Returns the current thread's {@link Random}. @return the current thread's {@link Random}.
hazelcast/src/main/java/com/hazelcast/internal/util/ThreadLocalRandomProvider.java:38
↓ 9 callersMethodget2
Returns the second value.
hazelcast/src/main/java/com/hazelcast/jet/accumulator/LongLongAccumulator.java:60
↓ 9 callersMethodgetAddressHolder
(String address)
hazelcast/src/main/java/com/hazelcast/internal/util/AddressUtil.java:116
↓ 9 callersMethodgetAddresses
Returns the list of candidate addresses that client will use to establish initial connection @return list of addresses
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:261
↓ 9 callersMethodgetAdvancedNetworkConfigWithSocketOption
(String socketOption, int value)
hazelcast/src/test/java/com/hazelcast/config/YamlConfigBuilderTest.java:5779
↓ 9 callersMethodgetAdvancedNetworkConfigWithSocketOption
(String socketOption, int value)
hazelcast/src/test/java/com/hazelcast/config/XMLConfigBuilderTest.java:5394
↓ 9 callersMethodgetAllEvents
Reads from the event journal a set of events. @param adapter the adapter for a specific data structure @param predicate the predicate which the
hazelcast/src/test/java/com/hazelcast/journal/AbstractEventJournalBasicTest.java:710
↓ 9 callersMethodgetAllRecordStores
()
hazelcast/src/main/java/com/hazelcast/map/impl/PartitionContainer.java:31
↓ 9 callersMethodgetAndPutAsync
Asynchronously associates the specified value with the specified key in this cache, returning an existing value if one existed. <p> In case a previous
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:366
↓ 9 callersMethodgetAndRemove
Atomically removes the entry for a key only if it is currently mapped to some value. <p> This is equivalent to: <pre><code> if (cache.containsKey(key)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheRecordStore.java:158
↓ 9 callersMethodgetAndReplace
Atomically replaces the assigned value of the given key by the specified value using a custom {@link javax.cache.expiry.ExpiryPolicy} and returns the
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:894
↓ 9 callersMethodgetAndSet
Sets the current value of the counter and returns the old value. @param newValue the new value. @return the old value of the counter.
hazelcast/src/main/java/com/hazelcast/internal/util/counters/Counter.java:48
↓ 9 callersMethodgetArray
Returns a field in a Json object as an array. Throws IllegalArgumentException if the field value is null. @param object the Json Object @param field
hazelcast/src/main/java/com/hazelcast/internal/util/JsonUtil.java:228
↓ 9 callersMethodgetAttribute
@return the attribute on which this range predicate acts.
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangePredicate.java:29
↓ 9 callersMethodgetBitsNodeId
@see #setBitsNodeId(int)
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:257
↓ 9 callersMethodgetBitsSequence
@see #setBitsSequence(int)
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:235
↓ 9 callersMethodgetById
Returns the OverflowPolicy for the given ID. @return the OverflowPolicy found or null if not found
hazelcast/src/main/java/com/hazelcast/ringbuffer/OverflowPolicy.java:83
↓ 9 callersMethodgetCache
(String name, MergePolicyConfig mergePolicyConfig)
hazelcast/src/test/java/com/hazelcast/internal/config/MergePolicyValidatorCachingProviderIntegrationTest.java:67
↓ 9 callersMethodgetCacheConfig
(String cacheNameWithPrefix)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:473
↓ 9 callersMethodgetCapacity
Returns the capacity of this device. @return device capacity.
hazelcast/src/main/java/com/hazelcast/config/LocalDeviceConfig.java:129
↓ 9 callersMethodgetCapacityPolicy
@return the policy of the capacity setting
hazelcast/src/main/java/com/hazelcast/config/ScheduledExecutorConfig.java:214
↓ 9 callersMethodgetClassCacheMode
Return the current ClassCacheMode @return current ProviderMode
hazelcast/src/main/java/com/hazelcast/config/UserCodeDeploymentConfig.java:250
↓ 9 callersMethodgetClassDefinitionList
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientUserCodeDeploymentService.java:158
↓ 9 callersMethodgetClassFilterConfig
()
hazelcast/src/main/java/com/hazelcast/config/UserCodeNamespacesConfig.java:89
↓ 9 callersMethodgetClassId
Returns the class ID. @return class ID
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinition.java:103
↓ 9 callersMethodgetClassName
@return class name of proxy factory
hazelcast/src/main/java/com/hazelcast/client/config/ProxyFactoryConfig.java:60
↓ 9 callersMethodgetClassName
Returns the name of the class of the EventListener. If no class is specified, null is returned. @return the class name of the EventListener @see #set
hazelcast/src/main/java/com/hazelcast/config/ListenerConfig.java:81
↓ 9 callersMethodgetClientIcmpPingConfig
ICMP ping is used to detect if machine that a remote hazelcast member runs on alive or not @return current configuration for client icmp ping, return
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:523
↓ 9 callersMethodgetClientPolicyConfig
()
hazelcast/src/main/java/com/hazelcast/config/SecurityConfig.java:98
↓ 9 callersMethodgetCollection
()
hazelcast/src/main/java/com/hazelcast/spi/impl/SerializableList.java:42
↓ 9 callersMethodgetConfig
()
hazelcast/src/test/java/com/hazelcast/collection/impl/queue/QueueStoreTest.java:672
↓ 9 callersMethodgetConfig
(String mapName, long maxWbqCapacity)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TransactionsWithWriteBehind_whenNoCoalescingQueueIsFullTest.java:254
↓ 9 callersMethodgetConfigurationUrl
Returns the {@link URL} to the declarative configuration, which has been parsed to create this {@link Config} instance. @return the configuration URL
hazelcast/src/main/java/com/hazelcast/config/Config.java:2860
↓ 9 callersMethodgetCreationTime
Returns the creation time of the merge data. @return the creation time of the merge data
hazelcast/src/main/java/com/hazelcast/spi/merge/MergingCreationTime.java:31
↓ 9 callersMethodgetCreationTime
()
hazelcast/src/main/java/com/hazelcast/map/impl/record/Record.java:95
↓ 9 callersMethodgetDataConnectionName
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcTable.java:91
↓ 9 callersMethodgetDataValue
Gets cache entry value as {@link Data}. @return value as {@link Data}.
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventData.java:66
↓ 9 callersMethodgetDefaultEdgeConfig
Returns the default DAG edge configuration.
hazelcast/src/main/java/com/hazelcast/jet/config/JetConfig.java:338
↓ 9 callersMethodgetDeserializedValue
Returns the merging value in deserialized form. @implNote This method invokes deserialization of the value when called - <b>be careful not to use it
hazelcast/src/main/java/com/hazelcast/spi/merge/MergingValue.java:58
↓ 9 callersMethodgetDictionaryId
Returns the dictionary id for the given word. If the word is not yet stored in the dictionary, the word gets stored and a newly assigned id is returne
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsDictionary.java:47
↓ 9 callersMethodgetDirtyEntryCount
Returns the number of entries that the member owns and are dirty (updated but not persisted yet). dirty entry count is meaningful when there is a pers
hazelcast/src/main/java/com/hazelcast/map/LocalMapStats.java:137
↓ 9 callersMethodgetDiscoveryServiceProvider
()
hazelcast/src/main/java/com/hazelcast/config/DiscoveryConfig.java:71
↓ 9 callersMethodgetDurability
Gets the durability of the executor @return the durability of the executor
hazelcast/src/main/java/com/hazelcast/config/DurableExecutorConfig.java:144
↓ 9 callersMethodgetEffectiveMemberList
<p> Gets the collection of members, or an empty list if the client changed the cluster and the new member list is not received yet. </p> <p> When {@li
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientClusterService.java:68
↓ 9 callersMethodgetEmptyQueueTtl
@return the TTL (time to live) for destroying the Queue (in seconds). <br> Once items have been removed and the Queue has been empty for a giv
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:110
↓ 9 callersMethodgetEventQueue
()
hazelcast/src/test/java/com/hazelcast/wan/impl/WanDummyPublisher.java:70
↓ 9 callersMethodgetEvictionConfigHolder
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/holder/CacheConfigHolder.java:143
↓ 9 callersMethodgetEvictionPolicy
Gets the eviction policy. @return the eviction policy
hazelcast/src/main/java/com/hazelcast/internal/eviction/EvictionConfiguration.java:39
↓ 9 callersMethodgetFactoryId
Returns the factory ID. @return factory ID
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinition.java:96
↓ 9 callersMethodgetFileFromResources
(String resourceFileName)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:652
← previousnext →7,101–7,200 of 147,315, ranked by callers