Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/hazelcast/hazelcast
/ functions
Functions
147,315 in github.com/hazelcast/hazelcast
⨍
Functions
147,315
◇
Types & classes
15,944
↓ 8 callers
Method
cast
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/LongConverter.java:109
↓ 8 callers
Method
cast
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/BigDecimalConverter.java:101
↓ 8 callers
Method
cast
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/IntegerConverter.java:102
↓ 8 callers
Method
cast
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/FloatConverter.java:172
↓ 8 callers
Method
changeClusterVersion
Changes the cluster version transactionally. Internally this method uses the same transaction infrastructure as {@link #changeClusterState(ClusterStat
hazelcast/src/main/java/com/hazelcast/cluster/Cluster.java:355
↓ 8 callers
Method
check2BytesAligned
(long address)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/AlignmentUtil.java:70
↓ 8 callers
Method
checkAvailable
(int pos, int k)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataInput.java:662
↓ 8 callers
Method
checkAvailable
()
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/store/AbstractNearCacheRecordStore.java:145
↓ 8 callers
Method
checkColumn
(Object value, SqlColumnType expectedType, Object expectedResult)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToEpochMillisIntegrationTest.java:126
↓ 8 callers
Method
checkColumnFailure
(Object value, int expectedErrorCode, String expectedErrorMessage)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/AbsFunctionIntegrationTest.java:121
↓ 8 callers
Method
checkColumnFailure
(Object value, int expectedErrorCode, String expectedErrorMessage)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/FloorCeilFunctionIntegrationTest.java:115
↓ 8 callers
Method
checkConverterCompatibilityNumeric
(QueryDataType columnType)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/schema/map/MapTableConverterResolutionTest.java:208
↓ 8 callers
Method
checkOrdering
(QueryDataTypeFamily orderingColumnType, String size, Object[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/aggregate/SqlHopTest.java:1493
↓ 8 callers
Method
checkOrdering
(QueryDataTypeFamily orderingColumnType, String windowSize, Object[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/aggregate/SqlTumbleTest.java:1311
↓ 8 callers
Method
checkParameter
(Object parameterValue, Object expectedValue)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToEpochMillisIntegrationTest.java:131
↓ 8 callers
Method
checkPath
(String originalPath, boolean expectedKey, String expectedPath)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/extract/QueryPathTest.java:72
↓ 8 callers
Method
checkReferenceAligned
(long address)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/AlignmentUtil.java:63
↓ 8 callers
Method
checkRequiredProperty
Tests if properties contain non-empty property value @param properties the properties tested to see if it contains non-empty property value @param ke
hazelcast/src/main/java/com/hazelcast/internal/util/Preconditions.java:386
↓ 8 callers
Method
checkUnsupportedColumnColumn
(ExpressionType<?> type, ExpressionType<?>... excludeTypes)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/ComparisonPredicateIntegrationTest.java:586
↓ 8 callers
Method
checkValidArguments
(QueryDataTypeFamily orderingColumnType, String size, Object[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/aggregate/SqlHopTest.java:106
↓ 8 callers
Method
checkValidArguments
(QueryDataTypeFamily orderingColumnType, String windowSize, Object[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/aggregate/SqlTumbleTest.java:107
↓ 8 callers
Method
clear
()
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/InternalQueryCache.java:64
↓ 8 callers
Method
clearReplicaIndex
(final int partitionId, int replicaIndexToClear)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:344
↓ 8 callers
Method
close
(String reason, Throwable cause)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnection.java:275
↓ 8 callers
Method
closeIsCooperative
Returns {@code true} if the {@link #close()} method of this processor is cooperative. If it's not, the call to the {@code close()} method is off-loade
hazelcast/src/main/java/com/hazelcast/jet/core/Processor.java:567
↓ 8 callers
Method
combineToLong
Combines two integer values into a long integer.
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:305
↓ 8 callers
Method
combineToSlidingWindowP
Returns a supplier of processors for the second-stage vertex in a two-stage sliding window aggregation setup (see the {@link Processors class Javadoc}
hazelcast/src/main/java/com/hazelcast/jet/core/processor/Processors.java:629
↓ 8 callers
Method
commitMigration
Commits the migration process for this service, on both source and destination members. This method will be called after all replication operations ar
hazelcast/src/main/java/com/hazelcast/internal/partition/MigrationAwareService.java:110
↓ 8 callers
Method
compareAndSwapInt
Compares and swaps the given int value to the expected value atomically based in the given object with given offset if and only if its current value e
hazelcast/src/main/java/com/hazelcast/internal/memory/ConcurrentMemoryAccessor.java:165
↓ 8 callers
Method
compareAndSwapLong
Compares and swaps the long value to the expected value atomically based in the given object with given offset if and only if its current value equals
hazelcast/src/main/java/com/hazelcast/internal/memory/ConcurrentMemoryAccessor.java:177
↓ 8 callers
Method
completedExceptionally
Creates a new {@code InternalCompletableFuture} that is completed exceptionally with the given {@code Throwable}. @param t the {@code Throwable}
hazelcast/src/main/java/com/hazelcast/spi/impl/InternalCompletableFuture.java:283
↓ 8 callers
Method
config
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/misc/SqlNoDeserializationTest.java:85
↓ 8 callers
Method
config
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/BaseElasticTest.java:273
↓ 8 callers
Method
consistencyCheck
Initiate WAN consistency check for a specific map. NOTE: not supported on OS, only on EE @param wanReplicationName the name of the wan replication co
hazelcast/src/main/java/com/hazelcast/wan/impl/WanReplicationService.java:182
↓ 8 callers
Method
consumer
(int localParallelism)
hazelcast/src/test/java/com/hazelcast/jet/core/RoutingPolicyTest.java:226
↓ 8 callers
Method
contains
(Object o)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberSelectingCollection.java:68
↓ 8 callers
Method
contentAsserts
(IList<Object> list, int expectedFirst, int expectedLast, int expectedSize)
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/MongoSourceTest.java:363
↓ 8 callers
Method
coordinator
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ExecutionContext.java:412
↓ 8 callers
Method
copy
Creates a copy of this instance @return Copy of this instance
hazelcast/src/main/java/com/hazelcast/sql/SqlStatement.java:353
↓ 8 callers
Method
create
(Expression<?> operand1, Expression<?> operand2, QueryDataType resultType)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/math/RemainderFunction.java:42
↓ 8 callers
Method
create
(Expression<?> operand, QueryDataType resultType)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/math/UnaryMinusFunction.java:46
↓ 8 callers
Method
createCacheConfig
(String cacheName)
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheHazelcastInstanceAwareTest.java:87
↓ 8 callers
Method
createCacheManager
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/eviction/CacheExpirationManagerTest.java:216
↓ 8 callers
Method
createClientAndServer
(String serverClusterName, String clientClusterName, boolean skipNameChecks)
hazelcast/src/test/java/com/hazelcast/client/TcpClientConnectionTest.java:336
↓ 8 callers
Method
createCompactMapping
(HazelcastInstance instance, String name, String valueCompactTypeName, St
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/CompactNestedFieldsTest.java:58
↓ 8 callers
Method
createConfig
()
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheThroughHazelcastInstanceTest.java:67
↓ 8 callers
Method
createConfig
(Boolean callSetInterface)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MulticastServiceTest.java:162
↓ 8 callers
Method
createConfigWithRestEnabled
(int port, int... otherMembersPorts)
hazelcast/src/test/java/com/hazelcast/cluster/TcpIpSplitBrainDiscoveryTest.java:109
↓ 8 callers
Method
createContext
Creates the {@link NearCacheTestContext} used by the Near Cache tests. @param <K> key type of the created {@link DataStructureAda
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:128
↓ 8 callers
Method
createEmptyResponseHandler
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationResponseHandlerFactory.java:28
↓ 8 callers
Method
createFilesWithCycleImports
(Function<String, String> fileContentWithImportResource, String... paths)
hazelcast/src/test/java/com/hazelcast/config/helpers/DeclarativeConfigFileHelper.java:204
↓ 8 callers
Method
createFunction
(ExtractField field, Object value, QueryDataType valueType)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ExtractFunctionIntegrationTest.java:446
↓ 8 callers
Method
createIndex
(IndexType indexType)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/LikePredicateTest.java:172
↓ 8 callers
Method
createInstanceAndInitializeListeners
()
hazelcast/src/test/java/com/hazelcast/map/EntryListenerConfigTest.java:132
↓ 8 callers
Method
createKafkaCluster
()
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:105
↓ 8 callers
Method
createLinkedHashMap
Utility method that creates an {@link java.util.LinkedHashMap} with its initialCapacity calculated to minimize rehash operations
hazelcast/src/main/java/com/hazelcast/internal/util/MapUtil.java:53
↓ 8 callers
Method
createListenerRunner
()
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/discovery/ViridianAddressProviderTest.java:190
↓ 8 callers
Method
createLoopBackAddressWithEphemeralPort
@return a loopback {@InetSocketAddress} with an ephemeral port
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/net/AsyncServerSocketTest.java:268
↓ 8 callers
Method
createMapping
(String tableName, String mappingName)
extensions/mapstore/src/test/java/com/hazelcast/mapstore/GenericMapLoaderTest.java:145
↓ 8 callers
Method
createMultiMapWithCollectionType
(MultiMapConfig.ValueCollectionType collectionType)
hazelcast/src/test/java/com/hazelcast/multimap/MultiMapReturnedCollectionTest.java:125
↓ 8 callers
Method
createNodeExtension
(Node node)
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeContext.java:34
↓ 8 callers
Method
createParamSet
( FunctionEx<StreamStage<Integer>, StreamStage<Integer>> cooperative_defaultLP, Functi
hazelcast/src/test/java/com/hazelcast/jet/pipeline/ProcessorTransformParallelismTest.java:195
↓ 8 callers
Method
createParser
(Object obj)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/JsonDataGetter.java:43
↓ 8 callers
Method
createParserFromString
(String jsonString)
hazelcast/src/test/java/com/hazelcast/json/internal/AbstractJsonSchemaCreateTest.java:160
↓ 8 callers
Method
createRandomTopic
(int partitionCount)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaSqlTestSupport.java:93
↓ 8 callers
Method
createSecureCallable
Creates secure callable that runs in a sandbox. @param <V> return type of callable @return result of callable
hazelcast/src/main/java/com/hazelcast/security/SecurityContext.java:121
↓ 8 callers
Method
createServerSocketConfig
(int port)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/AbstractAdvancedNetworkIntegrationTest.java:71
↓ 8 callers
Method
createSupplier
( long ttl, @Nonnull FunctionEx<? super T, ? extends K> keyFn, @Nonnull To
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/TransformStatefulPTest.java:475
↓ 8 callers
Method
createTableAndFill
(String connectionUrl, String tableName)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectJdbcIT.java:388
↓ 8 callers
Method
createTestHazelcastInstance
()
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryIndexTest.java:71
↓ 8 callers
Method
createTimedMemberState
()
hazelcast/src/main/java/com/hazelcast/internal/management/TimedMemberStateFactory.java:109
↓ 8 callers
Method
dataToValue
(Data data)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:346
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapRemoveCodec.java:92
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapGetCodec.java:92
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapCompareAndSetCodec.java:106
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ExperimentalPipelineSubmitCodec.java:99
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapSetCodec.java:98
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapDeleteCodec.java:92
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPSubsystemGetCPObjectInfosCodec.java:94
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCForceCloseCPSessionCodec.java:87
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapPutIfAbsentCodec.java:98
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapPutCodec.java:98
↓ 8 callers
Method
decodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientTpcAuthenticationCodec.java:86
↓ 8 callers
Method
decodeResponse
The result of the remove.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapRemoveCodec.java:116
↓ 8 callers
Method
decodeResponse
The result of the map lookup.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapGetCodec.java:116
↓ 8 callers
Method
decodeResponse
True if key was associated with newValue, otherwise false.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapCompareAndSetCodec.java:132
↓ 8 callers
Method
decodeResponse
This is the unique identifier for the job which is created for this pipeline
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ExperimentalPipelineSubmitCodec.java:123
↓ 8 callers
Method
decodeResponse
Always null, set does not return any previous value.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapSetCodec.java:123
↓ 8 callers
Method
decodeResponse
Always null, delete does not return any value.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapDeleteCodec.java:116
↓ 8 callers
Method
decodeResponse
List of names of CP structures that belong to the specified cp group and service.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPSubsystemGetCPObjectInfosCodec.java:117
↓ 8 callers
Method
decodeResponse
true if the session is found & closed, false otherwise.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCForceCloseCPSessionCodec.java:110
↓ 8 callers
Method
decodeResponse
Value associated with the key if already present, otherwise null.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapPutIfAbsentCodec.java:123
↓ 8 callers
Method
decodeResponse
Previous value associated with the key.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapPutCodec.java:123
↓ 8 callers
Method
decodeResponse
List of active CP group ids.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPSubsystemGetCPGroupIdsCodec.java:84
↓ 8 callers
Method
decreaseParallelism
(DAG dag, int defaultParallelism)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/CreateTopLevelDagVisitor.java:662
↓ 8 callers
Method
deregisterCompletionLatch
(Integer countDownLatchId)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheSyncListenerCompleter.java:74
↓ 8 callers
Method
deregisterListenerAsync
(String cacheNameWithPrefix, UUID registrationId)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:124
↓ 8 callers
Method
deserialize
(byte[] data, ClassFilter blockList, ClassFilter allowList)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/ReflectiveCompactSerializerTest.java:164
↓ 8 callers
Method
destroyObjectAndAssert
(DistributedObject distributedObject, String type)
hazelcast/src/test/java/com/hazelcast/internal/jmx/MBeanDestroyTest.java:123
↓ 8 callers
Method
discoverLocalMetadata
Returns a map with discovered metadata provided by the runtime environment. Those information may include, but are not limited, to location informatio
hazelcast/src/main/java/com/hazelcast/spi/discovery/DiscoveryStrategy.java:118
← previous
next →
7,601–7,700 of 147,315, ranked by callers