MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 23 callersMethodgetClientClusterService
Get cluster service
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/HazelcastClientInstance.java:50
↓ 23 callersMethodgetConfig
()
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/NearCacheTest.java:132
↓ 23 callersMethodgetConfig
Returns the Config that was used to create the HazelcastInstance. <p> The returned value will never change and will never be {@code null}. @return th
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:159
↓ 23 callersMethodgetDelegateMethod
Returns the delegate {@link Method} of the delegate class, which matches the given method name and parameter types. @param methodName the method
hazelcast/src/test/java/com/hazelcast/test/starter/answer/AbstractAnswer.java:140
↓ 23 callersMethodgetDurationAmount
()
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:1261
↓ 23 callersMethodgetDurationConfig
()
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:1134
↓ 23 callersMethodgetFieldConverterType
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/support/expressions/ExpressionType.java:40
↓ 23 callersMethodgetFieldDescriptor
(@Nonnull String fieldName)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/CompactInternalGenericRecord.java:858
↓ 23 callersMethodgetHz
@return Hazelcast instance managed by this holder
hazelcast/src/test/java/com/hazelcast/internal/jmx/MBeanDataHolder.java:87
↓ 23 callersMethodgetInputStream
()
hazelcast/src/test/java/com/hazelcast/internal/util/ServiceLoaderTest.java:700
↓ 23 callersMethodgetJobCoordinationService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/operation/AsyncOperation.java:128
↓ 23 callersMethodgetLevel
Gets the logging level. @return the logging level
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/logging/TpcLogger.java:195
↓ 23 callersMethodgetListenerConfigs
Returns the list of {@link EventListener} configurations. This includes listeners for events related to this instance/member or the cluster, such as p
hazelcast/src/main/java/com/hazelcast/config/Config.java:2483
↓ 23 callersMethodgetLocalParallelism
Returns the number of processors corresponding to this vertex that will be created on each member. A value of {@code -1} means that this property is n
hazelcast/src/main/java/com/hazelcast/jet/core/Vertex.java:172
↓ 23 callersMethodgetLogRecord
()
hazelcast/src/main/java/com/hazelcast/logging/LogEvent.java:39
↓ 23 callersMethodgetMemoryCost
Returns the memory cost of the index in bytes. <p> Currently, for on-heap indexes (OBJECT and BINARY storages), the returned value is just a best-effo
hazelcast/src/main/java/com/hazelcast/query/LocalIndexStats.java:112
↓ 23 callersMethodgetName
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:497
↓ 23 callersMethodgetName
()
hazelcast/src/main/java/com/hazelcast/internal/util/executor/ManagedExecutorService.java:32
↓ 23 callersMethodgetName
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:110
↓ 23 callersMethodgetName
Returns the name of this {@link IMap} @return the name of the {@link IMap}
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:200
↓ 23 callersMethodgetNamespaceService
Gets the NamespaceService. @return the NamespaceService
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:118
↓ 23 callersMethodgetObject
Returns the object reference at the supplied offset from the supplied object's base address. @param base the object whose base address to use for t
hazelcast/src/main/java/com/hazelcast/internal/memory/HeapMemoryAccessor.java:163
↓ 23 callersMethodgetPartitionId
Returns the partition ID. If the partition ID is smaller than 0, than it isn't specific to a partition. @return the partition ID
hazelcast/src/main/java/com/hazelcast/spi/impl/PartitionSpecificRunnable.java:30
↓ 23 callersMethodgetProperties
()
hazelcast/src/main/java/com/hazelcast/config/LoginModuleConfig.java:79
↓ 23 callersMethodgetReadOnlyConfig
()
hazelcast/src/test/java/com/hazelcast/config/CacheSimpleConfigReadOnlyTest.java:31
↓ 23 callersMethodgetReplicatedMapStats
()
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapStatsTest.java:58
↓ 23 callersMethodgetRingbufferNamespace
(String name)
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferService.java:226
↓ 23 callersMethodgetScheduledExecutorService
Creates or returns the {@link IScheduledExecutorService} scheduled executor service for the given name. ScheduledExecutor service enables you to sched
hazelcast/src/main/java/com/hazelcast/core/HazelcastInstance.java:449
↓ 23 callersMethodgetStorage
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:110
↓ 23 callersMethodgetWanReplicationConfig
Returns the WAN replication configuration with the given {@code name}. @param name the WAN replication config name @return the WAN replication config
hazelcast/src/main/java/com/hazelcast/config/Config.java:2277
↓ 23 callersMethodillegalStateException
(IOException e)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/CompactInternalGenericRecord.java:1116
↓ 23 callersMethodinitMocksWithConfiguration
(int maxResultSizeLimit)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryResultSizeLimiterTest.java:241
↓ 23 callersMethodis
(String attribute)
hazelcast/src/main/java/com/hazelcast/query/PredicateBuilder.java:45
↓ 23 callersMethodisEmpty
Returns {@code true} if the given collection is {@code null} or empty, otherwise returns {@code false}. @param collection the given collection @retur
hazelcast/src/main/java/com/hazelcast/internal/util/CollectionUtil.java:51
↓ 23 callersMethodisEvictionRequired
Checks the state to see if it has reached its maximum configured size {@link MaxSizePolicy} @return <code>true</code> if maximum size has been reache
hazelcast/src/main/java/com/hazelcast/internal/eviction/EvictionChecker.java:36
↓ 23 callersMethodisListed
Returns {@code true} if the given class name is listed in this filter. @param className class name to check @return {@code true} if the class name is
hazelcast/src/main/java/com/hazelcast/config/ClassFilter.java:199
↓ 23 callersMethodisLocal
Checks if the partition is local. <p> A partition is local if and only if the {@link #getOwnerOrNull()} returns the same address as 'this' address of
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartition.java:48
↓ 23 callersMethodisOrdered
Tells whether this index is ordered or not. <p> Ordered indexes support the fast evaluation of range queries. Unordered indexes are still capable to e
hazelcast/src/main/java/com/hazelcast/query/impl/Index.java:60
↓ 23 callersMethodisPortAutoIncrement
Checks if a Hazelcast member is allowed find a free port by incrementing the port number when it encounters an occupied port. @return the portAutoInc
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:149
↓ 23 callersMethodkey
@return the key of the current entry.
hazelcast/src/main/java/com/hazelcast/internal/util/collection/LongLongCursor.java:35
↓ 23 callersMethodlockClusterState
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/AdvancedClusterStateTest.java:178
↓ 23 callersMethodlogEvent
()
hazelcast/src/test/java/com/hazelcast/internal/management/MCEventStoreTest.java:82
↓ 23 callersMethodmapField
(String name, QueryDataType type, QueryPath queryPath)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/OptimizerTestSupport.java:206
↓ 23 callersMethodmapName
(String mapName)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:65
↓ 23 callersMethodnewAddress
()
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/ClusterStateManagerTest.java:358
↓ 23 callersMethodnewBitset
(int... cpus)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/util/ThreadAffinityTest.java:157
↓ 23 callersMethodnewBuilder
(int initialCapacity)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/InflatableSet.java:111
↓ 23 callersMethodnewHazelcastClient
()
hazelcast/src/test/java/com/hazelcast/client/listeners/leak/ListenerLeakTest.java:121
↓ 23 callersMethodnewInstances
()
hazelcast/src/test/java/com/hazelcast/internal/dynamicconfig/DynamicConfigTest.java:134
↓ 23 callersMethodnextElement
()
hazelcast/src/main/java/com/hazelcast/jet/impl/deployment/ChildFirstClassLoader.java:127
↓ 23 callersMethodnot
Creates a <b>not</b> predicate that will negate the result of the given {@code predicate}. @param predicate the predicate to negate the value of. @pa
hazelcast/src/main/java/com/hazelcast/query/Predicates.java:251
↓ 23 callersMethodnumericOverflowError
(QueryDataTypeFamily target)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/Converter.java:365
↓ 23 callersMethodonOutOfMemory
Signals the OutOfMemoryErrorDispatcher that an OutOfMemoryError happened. <p> If there are any registered instances, they are automatically unregister
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:168
↓ 23 callersMethodparse
(String sql)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/parse/HazelcastSqlParserTest.java:471
↓ 23 callersMethodproperties
()
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/StreamKafkaPTest.java:944
↓ 23 callersMethodputEntry
Saves an entry into this index. @param newEntry the new entry from which new attribute values should be read. @param ol
hazelcast/src/main/java/com/hazelcast/query/impl/Index.java:98
↓ 23 callersMethodreadChar
@param fieldName name of the field @return the char value read @throws IOException in case of any exceptional case
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableReader.java:123
↓ 23 callersMethodreadFloatArray
@return float array read @throws IOException if it reaches end of file before finish reading
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:90
↓ 23 callersMethodremainingCapacity
Returns the remaining capacity of the ringbuffer. If TTL is enabled, then the returned capacity is equal to the total capacity of the ringbuffer minus
hazelcast/src/main/java/com/hazelcast/ringbuffer/Ringbuffer.java:164
↓ 23 callersMethodscheduleWithRepetition
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period. Executions wi
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/TaskScheduler.java:97
↓ 23 callersMethodsetAutoOffDurationInMinutes
Sets the auto off time duration for the diagnostics service in minutes. <p>Auto off control is disabled by default.</p> <p><b>The auto off feature wil
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/DiagnosticsConfig.java:121
↓ 23 callersMethodsetLastUpdateTime
(long lastUpdateTime)
hazelcast/src/main/java/com/hazelcast/map/impl/record/Record.java:92
↓ 23 callersMethodsetLocalUpdatePolicy
Sets the {@link LocalUpdatePolicy} of this Near Cache. <p> This is only implemented for {@code JCache} data structures. @param localUpdatePolicy the
hazelcast/src/main/java/com/hazelcast/config/NearCacheConfig.java:364
↓ 23 callersMethodsetNearCache
(NearCache<NK, NV> nearCache)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestContextBuilder.java:83
↓ 23 callersMethodsetNearCacheAdapter
(DataStructureAdapter<K, V> nearCacheAdapter)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestContextBuilder.java:73
↓ 23 callersMethodsetNearCacheInstance
(HazelcastInstance nearCacheInstance)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestContextBuilder.java:63
↓ 23 callersMethodsetNearCacheManager
(NearCacheManager nearCacheManager)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestContextBuilder.java:88
↓ 23 callersMethodsetReadBackupData
Sets read-backup-data (reading local backup entries) for this map. @param readBackupData {@code true} to enable read-backup-data, {@code false} to di
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:509
↓ 23 callersMethodsetSerializeKeys
Sets if the Near Cache key is stored in serialized format or by-reference. <p> <b>NOTE:</b> It's not supported to disable the key serialization when t
hazelcast/src/main/java/com/hazelcast/config/NearCacheConfig.java:210
↓ 23 callersMethodsetTopicOverloadPolicy
()
hazelcast/src/test/java/com/hazelcast/config/ReliableTopicConfigTest.java:115
↓ 23 callersMethodsetTryCount
(int tryCount)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/JoinRequest.java:99
↓ 23 callersMethodsql
(Object original, Object from, Object to)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/ReplaceFunctionIntegrationTest.java:145
↓ 23 callersMethodstart
Start the AsyncSocket by scheduling it on the reactor. The Socket should be started only once. <p/> Typically, you do not want to share this AsyncSock
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncSocket.java:135
↓ 23 callersMethodtest
(T t)
hazelcast/src/main/java/com/hazelcast/function/PredicateEx.java:45
↓ 23 callersMethodthenCompose
(Function<? super V, ? extends CompletionStage<U>> fn)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientDelegatingFuture.java:309
↓ 23 callersMethodtoArray
()
hazelcast/src/main/java/com/hazelcast/internal/util/collection/OAHashSet.java:278
↓ 23 callersMethodtoMillis
(long nanos)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:1062
↓ 23 callersMethodtypeName
Return the name of the connector as seen in the {@code TYPE} clause in the {@code CREATE EXTERNAL MAPPING} command.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/SqlConnector.java:233
↓ 23 callersMethoduoe
()
hazelcast/src/test/java/com/hazelcast/jet/impl/JobBuilderTest.java:200
↓ 23 callersMethodversion
Returns the version of the partition. Partition version is incremented by one, on each replica assignment change on the partition. @return version of
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartition.java:109
↓ 23 callersMethodwithTryCatch
Utility to make sure exceptions inside {@link java.util.concurrent.CompletionStage#whenComplete(BiConsumer)} are not swallowed. Exceptions will be cau
hazelcast/src/main/java/com/hazelcast/internal/util/ExceptionUtil.java:182
↓ 23 callersMethodxmlToJavaName
(final String name)
hazelcast/src/main/java/com/hazelcast/config/AbstractXmlConfigHelper.java:153
↓ 22 callersMethodaddClasspathResource
Adds a resource that will be available on the Jet job's classpath. All the code attached to the underlying pipeline or DAG will have access to it. <p>
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:530
↓ 22 callersMethodaddConnectionListener
Registers a ConnectionListener. <p> If the same listener is registered multiple times, it will be notified multiple times. @param listener the Connec
hazelcast/src/main/java/com/hazelcast/internal/nio/ConnectionListenable.java:32
↓ 22 callersMethodaddDiscoveryStrategyConfig
Adds an enabled {@link DiscoveryStrategy} configuration. <p> All added configurations are strictly meant to be enabled, this is to remember when build
hazelcast/src/main/java/com/hazelcast/config/DiscoveryConfig.java:135
↓ 22 callersMethodadvanceAtLeastTo
Advances the given iterator to the given member; or, if the member is not present in this storage, to a member immediately following it and present in
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/SparseBitSet.java:235
↓ 22 callersMethodandDeduct
Registers the {@link AggregateOperation#deductFn() deduct} primitive. <p> The given function must be stateless and {@linkplain Processor#isCooperative
hazelcast/src/main/java/com/hazelcast/jet/aggregate/AggregateOperationBuilder.java:185
↓ 22 callersMethodappendProperties
(Properties props)
hazelcast/src/main/java/com/hazelcast/config/ConfigXmlGenerator.java:1374
↓ 22 callersMethodasVarchar
(Expression<?> expression, Row row, ExpressionEvalContext context)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/string/StringFunctionUtils.java:101
↓ 22 callersMethodassertCollectedEventually
Collects all the received items into a list and runs the {@code assertFn} every time a new item is received. An {@link AssertionError} thrown from the
hazelcast/src/main/java/com/hazelcast/jet/pipeline/test/AssertionSinks.java:172
↓ 22 callersMethodassertMessages
(Map<String, List<String>> expected, boolean checkOrder, boolean deduplicate)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisIntegrationTest.java:632
↓ 22 callersMethodassertParameters
(Node node, long activeConnectionCount, long openedConnectionCount, long clo
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/PhoneHomeClientsTest.java:349
↓ 22 callersMethodassertThrowsNPE
(ConsumerEx<ReplicatedMap<Object, Object>> method)
hazelcast/src/test/java/com/hazelcast/replicatedmap/AbstractReplicatedMapNullTest.java:73
↓ 22 callersMethodbarrier
(long snapshotId)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/ConcurrentInboundEdgeStreamTest.java:276
↓ 22 callersMethodbuild
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:81
↓ 22 callersMethodcheckColumn_1
(ExpressionValue value, SqlColumnType expectedType, Object expectedValue)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/RoundFunctionIntegrationTest.java:317
↓ 22 callersMethodcheckColumn_1
(ExpressionValue value, SqlColumnType expectedType, Object expectedValue)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/TruncateFunctionIntegrationTest.java:308
↓ 22 callersMethodcheckCommute
(String operand1, String operand2, Integer expectedResult, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/ComparisonPredicateIntegrationTest.java:666
↓ 22 callersMethodcheckCommute
(String operand1, String operand2, Boolean expectedResult, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/AndOrPredicateIntegrationTest.java:248
↓ 22 callersMethodcheckDoesNotContainPagingPredicate
This method is used for checking a predicate that it is not/does not contain a {@link com.hazelcast.query.PagingPredicate} @throws IllegalArgumentExc
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/PredicateUtils.java:89
← previousnext →3,901–4,000 of 147,315, ranked by callers