MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 8 callersMethodcast
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/LongConverter.java:109
↓ 8 callersMethodcast
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/BigDecimalConverter.java:101
↓ 8 callersMethodcast
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/IntegerConverter.java:102
↓ 8 callersMethodcast
(Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/converter/FloatConverter.java:172
↓ 8 callersMethodchangeClusterVersion
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 callersMethodcheck2BytesAligned
(long address)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/AlignmentUtil.java:70
↓ 8 callersMethodcheckAvailable
(int pos, int k)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataInput.java:662
↓ 8 callersMethodcheckAvailable
()
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/store/AbstractNearCacheRecordStore.java:145
↓ 8 callersMethodcheckColumn
(Object value, SqlColumnType expectedType, Object expectedResult)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToEpochMillisIntegrationTest.java:126
↓ 8 callersMethodcheckColumnFailure
(Object value, int expectedErrorCode, String expectedErrorMessage)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/AbsFunctionIntegrationTest.java:121
↓ 8 callersMethodcheckColumnFailure
(Object value, int expectedErrorCode, String expectedErrorMessage)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/FloorCeilFunctionIntegrationTest.java:115
↓ 8 callersMethodcheckConverterCompatibilityNumeric
(QueryDataType columnType)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/schema/map/MapTableConverterResolutionTest.java:208
↓ 8 callersMethodcheckOrdering
(QueryDataTypeFamily orderingColumnType, String size, Object[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/aggregate/SqlHopTest.java:1493
↓ 8 callersMethodcheckOrdering
(QueryDataTypeFamily orderingColumnType, String windowSize, Object[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/aggregate/SqlTumbleTest.java:1311
↓ 8 callersMethodcheckParameter
(Object parameterValue, Object expectedValue)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToEpochMillisIntegrationTest.java:131
↓ 8 callersMethodcheckPath
(String originalPath, boolean expectedKey, String expectedPath)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/extract/QueryPathTest.java:72
↓ 8 callersMethodcheckReferenceAligned
(long address)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/AlignmentUtil.java:63
↓ 8 callersMethodcheckRequiredProperty
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 callersMethodcheckUnsupportedColumnColumn
(ExpressionType<?> type, ExpressionType<?>... excludeTypes)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/ComparisonPredicateIntegrationTest.java:586
↓ 8 callersMethodcheckValidArguments
(QueryDataTypeFamily orderingColumnType, String size, Object[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/aggregate/SqlHopTest.java:106
↓ 8 callersMethodcheckValidArguments
(QueryDataTypeFamily orderingColumnType, String windowSize, Object[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/aggregate/SqlTumbleTest.java:107
↓ 8 callersMethodclear
()
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/InternalQueryCache.java:64
↓ 8 callersMethodclearReplicaIndex
(final int partitionId, int replicaIndexToClear)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationCommitServiceTest.java:344
↓ 8 callersMethodclose
(String reason, Throwable cause)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/TcpServerConnection.java:275
↓ 8 callersMethodcloseIsCooperative
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 callersMethodcombineToLong
Combines two integer values into a long integer.
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:305
↓ 8 callersMethodcombineToSlidingWindowP
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 callersMethodcommitMigration
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 callersMethodcompareAndSwapInt
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 callersMethodcompareAndSwapLong
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 callersMethodcompletedExceptionally
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 callersMethodconfig
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/misc/SqlNoDeserializationTest.java:85
↓ 8 callersMethodconfig
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/BaseElasticTest.java:273
↓ 8 callersMethodconsistencyCheck
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 callersMethodconsumer
(int localParallelism)
hazelcast/src/test/java/com/hazelcast/jet/core/RoutingPolicyTest.java:226
↓ 8 callersMethodcontains
(Object o)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberSelectingCollection.java:68
↓ 8 callersMethodcontentAsserts
(IList<Object> list, int expectedFirst, int expectedLast, int expectedSize)
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/MongoSourceTest.java:363
↓ 8 callersMethodcoordinator
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ExecutionContext.java:412
↓ 8 callersMethodcopy
Creates a copy of this instance @return Copy of this instance
hazelcast/src/main/java/com/hazelcast/sql/SqlStatement.java:353
↓ 8 callersMethodcreate
(Expression<?> operand1, Expression<?> operand2, QueryDataType resultType)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/math/RemainderFunction.java:42
↓ 8 callersMethodcreate
(Expression<?> operand, QueryDataType resultType)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/math/UnaryMinusFunction.java:46
↓ 8 callersMethodcreateCacheConfig
(String cacheName)
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheHazelcastInstanceAwareTest.java:87
↓ 8 callersMethodcreateCacheManager
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/eviction/CacheExpirationManagerTest.java:216
↓ 8 callersMethodcreateClientAndServer
(String serverClusterName, String clientClusterName, boolean skipNameChecks)
hazelcast/src/test/java/com/hazelcast/client/TcpClientConnectionTest.java:336
↓ 8 callersMethodcreateCompactMapping
(HazelcastInstance instance, String name, String valueCompactTypeName, St
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/CompactNestedFieldsTest.java:58
↓ 8 callersMethodcreateConfig
()
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheThroughHazelcastInstanceTest.java:67
↓ 8 callersMethodcreateConfig
(Boolean callSetInterface)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MulticastServiceTest.java:162
↓ 8 callersMethodcreateConfigWithRestEnabled
(int port, int... otherMembersPorts)
hazelcast/src/test/java/com/hazelcast/cluster/TcpIpSplitBrainDiscoveryTest.java:109
↓ 8 callersMethodcreateContext
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 callersMethodcreateEmptyResponseHandler
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationResponseHandlerFactory.java:28
↓ 8 callersMethodcreateFilesWithCycleImports
(Function<String, String> fileContentWithImportResource, String... paths)
hazelcast/src/test/java/com/hazelcast/config/helpers/DeclarativeConfigFileHelper.java:204
↓ 8 callersMethodcreateFunction
(ExtractField field, Object value, QueryDataType valueType)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ExtractFunctionIntegrationTest.java:446
↓ 8 callersMethodcreateIndex
(IndexType indexType)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/LikePredicateTest.java:172
↓ 8 callersMethodcreateInstanceAndInitializeListeners
()
hazelcast/src/test/java/com/hazelcast/map/EntryListenerConfigTest.java:132
↓ 8 callersMethodcreateKafkaCluster
()
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:105
↓ 8 callersMethodcreateLinkedHashMap
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 callersMethodcreateListenerRunner
()
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/discovery/ViridianAddressProviderTest.java:190
↓ 8 callersMethodcreateLoopBackAddressWithEphemeralPort
@return a loopback {@InetSocketAddress} with an ephemeral port
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/net/AsyncServerSocketTest.java:268
↓ 8 callersMethodcreateMapping
(String tableName, String mappingName)
extensions/mapstore/src/test/java/com/hazelcast/mapstore/GenericMapLoaderTest.java:145
↓ 8 callersMethodcreateMultiMapWithCollectionType
(MultiMapConfig.ValueCollectionType collectionType)
hazelcast/src/test/java/com/hazelcast/multimap/MultiMapReturnedCollectionTest.java:125
↓ 8 callersMethodcreateNodeExtension
(Node node)
hazelcast/src/main/java/com/hazelcast/instance/impl/NodeContext.java:34
↓ 8 callersMethodcreateParamSet
( FunctionEx<StreamStage<Integer>, StreamStage<Integer>> cooperative_defaultLP, Functi
hazelcast/src/test/java/com/hazelcast/jet/pipeline/ProcessorTransformParallelismTest.java:195
↓ 8 callersMethodcreateParser
(Object obj)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/JsonDataGetter.java:43
↓ 8 callersMethodcreateParserFromString
(String jsonString)
hazelcast/src/test/java/com/hazelcast/json/internal/AbstractJsonSchemaCreateTest.java:160
↓ 8 callersMethodcreateRandomTopic
(int partitionCount)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/KafkaSqlTestSupport.java:93
↓ 8 callersMethodcreateSecureCallable
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 callersMethodcreateServerSocketConfig
(int port)
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/AbstractAdvancedNetworkIntegrationTest.java:71
↓ 8 callersMethodcreateSupplier
( long ttl, @Nonnull FunctionEx<? super T, ? extends K> keyFn, @Nonnull To
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/TransformStatefulPTest.java:475
↓ 8 callersMethodcreateTableAndFill
(String connectionUrl, String tableName)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectJdbcIT.java:388
↓ 8 callersMethodcreateTestHazelcastInstance
()
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryIndexTest.java:71
↓ 8 callersMethodcreateTimedMemberState
()
hazelcast/src/main/java/com/hazelcast/internal/management/TimedMemberStateFactory.java:109
↓ 8 callersMethoddataToValue
(Data data)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:346
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapRemoveCodec.java:92
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapGetCodec.java:92
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapCompareAndSetCodec.java:106
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ExperimentalPipelineSubmitCodec.java:99
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapSetCodec.java:98
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapDeleteCodec.java:92
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPSubsystemGetCPObjectInfosCodec.java:94
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCForceCloseCPSessionCodec.java:87
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapPutIfAbsentCodec.java:98
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapPutCodec.java:98
↓ 8 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientTpcAuthenticationCodec.java:86
↓ 8 callersMethoddecodeResponse
The result of the remove.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapRemoveCodec.java:116
↓ 8 callersMethoddecodeResponse
The result of the map lookup.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapGetCodec.java:116
↓ 8 callersMethoddecodeResponse
True if key was associated with newValue, otherwise false.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapCompareAndSetCodec.java:132
↓ 8 callersMethoddecodeResponse
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 callersMethoddecodeResponse
Always null, set does not return any previous value.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapSetCodec.java:123
↓ 8 callersMethoddecodeResponse
Always null, delete does not return any value.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapDeleteCodec.java:116
↓ 8 callersMethoddecodeResponse
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 callersMethoddecodeResponse
true if the session is found & closed, false otherwise.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCForceCloseCPSessionCodec.java:110
↓ 8 callersMethoddecodeResponse
Value associated with the key if already present, otherwise null.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapPutIfAbsentCodec.java:123
↓ 8 callersMethoddecodeResponse
Previous value associated with the key.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPMapPutCodec.java:123
↓ 8 callersMethoddecodeResponse
List of active CP group ids.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPSubsystemGetCPGroupIdsCodec.java:84
↓ 8 callersMethoddecreaseParallelism
(DAG dag, int defaultParallelism)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/CreateTopLevelDagVisitor.java:662
↓ 8 callersMethodderegisterCompletionLatch
(Integer countDownLatchId)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheSyncListenerCompleter.java:74
↓ 8 callersMethodderegisterListenerAsync
(String cacheNameWithPrefix, UUID registrationId)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:124
↓ 8 callersMethoddeserialize
(byte[] data, ClassFilter blockList, ClassFilter allowList)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/ReflectiveCompactSerializerTest.java:164
↓ 8 callersMethoddestroyObjectAndAssert
(DistributedObject distributedObject, String type)
hazelcast/src/test/java/com/hazelcast/internal/jmx/MBeanDestroyTest.java:123
↓ 8 callersMethoddiscoverLocalMetadata
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
← previousnext →7,601–7,700 of 147,315, ranked by callers