MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 21 callersMethodaddMigrationListener
Adds a MigrationListener. <p> The addMigrationListener returns a register ID. This ID is needed to remove the MigrationListener using the {@link #remo
hazelcast/src/main/java/com/hazelcast/partition/PartitionService.java:68
↓ 21 callersMethodaddVectorIndexConfig
Adds a vector index configuration to this vector collection configuration. @param vectorIndexConfig the vector index configuration to add @return thi
hazelcast/src/main/java/com/hazelcast/config/vector/VectorCollectionConfig.java:135
↓ 21 callersMethodalwaysFalse
Creates an <b>always false</b> predicate that will filter out all items. @param <K> the type of keys the predicate operates on. @param <V> the type of
hazelcast/src/main/java/com/hazelcast/query/Predicates.java:211
↓ 21 callersMethodassertQueryPlan
(String query)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/SqlEndToEndTestSupport.java:113
↓ 21 callersMethodassertTipOfStream
Execute the given `sql` and assert that the first rows it returns are those in `expectedRows`. Ignores the rest of rows. <p> This is useful for assert
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:288
↓ 21 callersMethodawaitTermination
(long timeout, @Nonnull TimeUnit unit)
hazelcast/src/test/java/com/hazelcast/jet/core/TestUtil.java:138
↓ 21 callersMethodbit
(int bit, long value)
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapTest.java:201
↓ 21 callersMethodbroadcastConfig
Registers a dynamic configurations to all cluster members. @param config configuration to register
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:65
↓ 21 callersMethodcheck
(String sql, Integer expectedResult, Object... parameters)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/string/PositionFunctionIntegrationTest.java:154
↓ 21 callersMethodcheckLiteral
(Object literal, SqlColumnType expectedType, Object expectedValue)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/AbsFunctionIntegrationTest.java:218
↓ 21 callersMethodclear
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:109
↓ 21 callersMethodconverter
(TypeConverter... converters)
hazelcast/src/test/java/com/hazelcast/query/impl/CompositeConverterTest.java:93
↓ 21 callersMethodcreateConcurrentHashMap
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:62
↓ 21 callersMethodcreateCursor
Creates a new cursor from given attribute path.
hazelcast/src/main/java/com/hazelcast/query/impl/getters/JsonPathCursor.java:59
↓ 21 callersMethodcreateEntry
(String key, String value)
hazelcast/src/test/java/com/hazelcast/query/impl/QueryEntryTest.java:242
↓ 21 callersMethodcreateManagedMap
(String configName)
hazelcast-spring/src/main/java/com/hazelcast/spring/HazelcastConfigBeanDefinitionParser.java:307
↓ 21 callersMethodcreateMapping
(String name, boolean simple)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlPrimitiveTest.java:61
↓ 21 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/TopicPublishAllCodec.java:86
↓ 21 callersMethoddecodeRequest
Query ID.
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlCloseCodec.java:74
↓ 21 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MultiMapPutAllCodec.java:89
↓ 21 callersMethodderegister
()
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:363
↓ 21 callersMethodderegisterListener
(@Nonnull UUID registrationId)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientListenerService.java:36
↓ 21 callersMethoddivisionByZeroError
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/DivideOperatorIntegrationTest.java:417
↓ 21 callersMethoddoGet
(String url)
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:479
↓ 21 callersMethodenableGroups
Enables provided REST endpoint groups. It doesn't replace already enabled groups.
hazelcast/src/main/java/com/hazelcast/config/RestApiConfig.java:66
↓ 21 callersMethodencodeRequest
(java.lang.String name, java.util.Collection<com.hazelcast.internal.serialization.Data> messages)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/TopicPublishAllCodec.java:72
↓ 21 callersMethodencodeRequest
(java.lang.String sql, java.util.Collection<com.hazelcast.internal.serialization.Data> parameters, long timeou
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlExecuteCodec.java:118
↓ 21 callersMethodencodeRequest
(java.lang.String sql, java.util.Collection<com.hazelcast.internal.serialization.Data> parameters, long timeou
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlExecute_reservedCodec.java:87
↓ 21 callersMethodencodeRequest
(java.lang.String name, java.util.Collection<java.util.Map.Entry<com.hazelcast.internal.serialization.Data, ja
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MultiMapPutAllCodec.java:75
↓ 21 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/TopicPublishAllCodec.java:96
↓ 21 callersMethodencodeResponse
(@Nullable java.util.List<com.hazelcast.sql.SqlColumnMetadata> rowMetadata, @Nullable com.hazelcast.sql.impl.c
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlExecuteCodec.java:203
↓ 21 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SqlCloseCodec.java:81
↓ 21 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MultiMapPutAllCodec.java:99
↓ 21 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/jet/impl/JetEvent.java:72
↓ 21 callersMethodfield
(String name, QueryDataType type)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataAvroResolverTest.java:220
↓ 21 callersMethodflatMap
(@Nonnull FunctionEx<? super T, ? extends Traverser<R>> flatMapFn)
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:122
↓ 21 callersMethodfrom
Returns an edge with the given source vertex and no destination vertex. The ordinal of the edge is 0. Typically followed by one of the {@code to()} me
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:144
↓ 21 callersMethodfromString
(String value)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/SelectorMode.java:43
↓ 21 callersMethodgetBean
(String name)
hazelcast-spring/src/main/java/com/hazelcast/spring/jet/JetSpringServiceFactories.java:116
↓ 21 callersMethodgetCPSubsystemConfig
Get current configuration for the CP subsystem @return CP subsystem configuration @since 3.12
hazelcast/src/main/java/com/hazelcast/config/Config.java:2991
↓ 21 callersMethodgetCacheLoaderFactory
Gets the factory for the {@link javax.cache.integration.CacheLoader}. @return the factory for the {@link javax.cache.integration.CacheLoader}
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:321
↓ 21 callersMethodgetCacheWriterFactory
Gets the factory for the {@link javax.cache.integration.CacheWriter}. @return the factory for the {@link javax.cache.integration.CacheWriter}
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:369
↓ 21 callersMethodgetComponentType
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastDynamicTableFunction.java:286
↓ 21 callersMethodgetConfig
Gets the configuration of the cache that this store belongs to. @return {@link CacheConfig}
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheRecordStore.java:393
↓ 21 callersMethodgetDataKey
Gets cache entry key as {@link Data}. @return key as {@link Data}.
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventData.java:60
↓ 21 callersMethodgetDataNewValue
()
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/QueryCacheEventData.java:37
↓ 21 callersMethodgetDirectoryConfigs
Returns the persistent memory directory configurations to be used to store memory structures allocated by native memory manager. <p> By default, there
hazelcast/src/main/java/com/hazelcast/config/PersistentMemoryConfig.java:92
↓ 21 callersMethodgetExpiryPolicyFactoryConfig
Gets the factory configuration for the {@link javax.cache.expiry.ExpiryPolicy}. @return the factory configuration for the {@link javax.cache.expiry.E
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:417
↓ 21 callersMethodgetFactoryImplementation
()
hazelcast/src/test/java/com/hazelcast/config/MapStoreConfigTest.java:156
↓ 21 callersMethodgetHazelcastInstance
Gets the underlying {@link HazelcastInstance} implementation. @return the underlying {@link HazelcastInstance} implementation
hazelcast/src/main/java/com/hazelcast/cache/HazelcastCacheManager.java:50
↓ 21 callersMethodgetInstanceName
()
hazelcast/src/main/java/com/hazelcast/internal/ascii/TextCommandService.java:100
↓ 21 callersMethodgetJobCoordinationService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JetServiceBackend.java:360
↓ 21 callersMethodgetMap
()
hazelcast/src/test/java/com/hazelcast/map/impl/tx/LocalTxnMapStatsTest.java:70
↓ 21 callersMethodgetMemoryTierConfig
Returns memory tier configuration for this index. @return memory tier configuration for this index.
hazelcast/src/main/java/com/hazelcast/config/BTreeIndexConfig.java:78
↓ 21 callersMethodgetMergePolicy
(String dataStructureName)
hazelcast/src/main/java/com/hazelcast/map/impl/MapMergeRunnable.java:78
↓ 21 callersMethodgetMultiMap
()
hazelcast/src/test/java/com/hazelcast/multimap/LocalMultiMapStatsTest.java:76
↓ 21 callersMethodgetObjectName
Gets the object name within the service. @return the object name within the service
hazelcast/src/main/java/com/hazelcast/internal/services/ObjectNamespace.java:29
↓ 21 callersMethodgetOption
Gets an option value. @param option the option @param <T> the type of the value @return null if value is null. @throws com.hazelcast.core.HazelcastEx
hazelcast/src/main/java/com/hazelcast/internal/networking/ChannelOptions.java:48
↓ 21 callersMethodgetPartitionOwner
Gets the owner of the partition if it's set. <p> If the owner of the partition is not set yet, it will trigger partition assignment. @param partition
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:53
↓ 21 callersMethodgetProtocolType
()
hazelcast/src/main/java/com/hazelcast/config/EndpointConfig.java:116
↓ 21 callersMethodgetSchemaId
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/Schema.java:173
↓ 21 callersMethodgetSsl
Gets the SSL configuration. @return the SSL configuration.
hazelcast/src/main/java/com/hazelcast/config/rest/RestConfig.java:664
↓ 21 callersMethodgetStats
Gathers statistics of related {@link WanPublisher} instance. This method will always return the same instance. NOTE: used only in Hazelcast Enterprise
hazelcast/src/main/java/com/hazelcast/wan/impl/InternalWanPublisher.java:126
↓ 21 callersMethodgetSteadyMember
@return cluster member that stays up for the duration of the test
hazelcast/src/test/java/com/hazelcast/test/bounce/BounceMemberRule.java:168
↓ 21 callersMethodgetString
Returns the configured value of a {@link HazelcastProperty} as String. @param property the {@link HazelcastProperty} to get the value from @return th
hazelcast/src/main/java/com/hazelcast/spi/properties/HazelcastProperties.java:116
↓ 21 callersMethodgetTarget
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastTable.java:148
↓ 21 callersMethodgetThisUuid
Returns UUID of the local member. @return member UUID
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:66
↓ 21 callersMethodgetTpcSocketConfig
Gets the TpcSocketConfig. @return the TpcSocketConfig @see TpcConfig @since 5.3
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:427
↓ 21 callersMethodgetType
Returns serialization type of binary form. It's defined by {@link Serializer#getTypeId()} @return serializer type ID
hazelcast/src/main/java/com/hazelcast/internal/serialization/Data.java:41
↓ 21 callersMethodgetYamlRoot
()
hazelcast/src/test/java/com/hazelcast/internal/yaml/YamlTest.java:448
↓ 21 callersMethodinit
Initializes this processor with the outbox that the <em>processing methods</em> must use to deposit their output items. This method will be called exa
hazelcast/src/main/java/com/hazelcast/jet/core/Processor.java:161
↓ 21 callersMethodisDone
()
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:518
↓ 21 callersMethodisNumaNodeSet
Returns if the NUMA node for the given persistent memory directory is set. @return {@code true} if the NUMA node is set, {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/PersistentMemoryDirectoryConfig.java:123
↓ 21 callersMethodisPersistWanReplicatedData
()
hazelcast/src/main/java/com/hazelcast/map/impl/wan/MapWanContext.java:154
↓ 21 callersMethodisSerializeKeys
Checks if the Near Cache key is stored in serialized format or by-reference. <p> <b>NOTE:</b> When the in-memory-format is {@code NATIVE}, this method
hazelcast/src/main/java/com/hazelcast/config/NearCacheConfig.java:197
↓ 21 callersMethodisUrgent
Checks if this OutboundFrame is urgent. <p> Frames that are urgent, have priority above regular frames. This is useful to implement system operations
hazelcast/src/main/java/com/hazelcast/internal/networking/OutboundFrame.java:54
↓ 21 callersMethodmapName
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlOrderByTest.java:1181
↓ 21 callersMethodmapUsingServiceAsync
( @Nonnull ServiceFactory<?, S> serviceFactory, @Nonnull BiFunctionEx<? super S, ? sup
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:152
↓ 21 callersMethodmessage
@param message event message. May be {@code null} @return this instance
hazelcast/src/main/java/com/hazelcast/auditlog/EventBuilder.java:38
↓ 21 callersMethodnewDescriptor
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/jmx/JmxPublisherTest.java:310
↓ 21 callersMethodnewId
Generates and returns a cluster-wide unique ID. <p> Operation on a member is always local, if the member has valid node ID, otherwise it's remote. On
hazelcast/src/main/java/com/hazelcast/flakeidgen/FlakeIdGenerator.java:106
↓ 21 callersMethodnewIdBaseLocal
(int batchSize)
hazelcast/src/main/java/com/hazelcast/flakeidgen/impl/FlakeIdGeneratorProxy.java:148
↓ 21 callersMethodnewMapConfig
(String mapName)
hazelcast/src/test/java/com/hazelcast/map/EvictionTest.java:1307
↓ 21 callersMethodof
Returns an instance of {@link Capacity}. @param value value of the capacity @param unit unit of the capacity @return a {@link Capacity} instance
hazelcast/src/main/java/com/hazelcast/memory/Capacity.java:108
↓ 21 callersMethodpreferLocalParallelismOne
Wraps the provided {@code ProcessorSupplier} into a meta-supplier that will always return it. The {@link #preferredLocalParallelism()} of the meta-sup
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorMetaSupplier.java:410
↓ 21 callersMethodprefix
Returns the prefix of the metric denoted by this instance. @return the prefix
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:43
↓ 21 callersMethodpublishEvent
Publish an event to the event subsystem. Note: Exceptions during publications are caught and logged. @param caller the address of the caller that
hazelcast/src/main/java/com/hazelcast/map/impl/event/MapEventPublisher.java:70
↓ 21 callersMethodputBiValue
(Object field1, Object field2, ExpressionType<?> type1, ExpressionType<?> type2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/ComparisonPredicateIntegrationTest.java:509
↓ 21 callersMethodputIfAbsent
Associates {@code key} with {@code value} only if {@code key} is not present. @param key non-null key of the entry @param value non-null value of the
hazelcast/src/main/java/com/hazelcast/cp/CPMap.java:54
↓ 21 callersMethodreadDoubleArray
@return double array read @throws IOException if it reaches end of file before finish reading
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:83
↓ 21 callersMethodreadShortArray
@return short array read @throws IOException if it reaches end of file before finish reading
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:97
↓ 21 callersMethodreadUnsignedByte
()
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:100
↓ 21 callersMethodreset
Resets the counter that prevents adding more than {@code batchSize} items until this method is called again. Note that the counter may jump to the "fu
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/OutboxInternal.java:28
↓ 21 callersMethodsetConsumerThread
Sets the consumer thread. <p> The consumer thread is needed for blocking, so that an offering known which thread to wakeup. There can only be a single
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/MPSCQueue.java:88
↓ 21 callersMethodsetCreationTime
(long creationTime)
hazelcast/src/main/java/com/hazelcast/map/impl/record/Record.java:99
↓ 21 callersMethodsetMembers
Sets the well known members. <p> If members are empty, calling this method will have the same effect as calling {@link #clear()}. <p> A member can be
hazelcast/src/main/java/com/hazelcast/config/TcpIpConfig.java:121
↓ 21 callersMethodsetStoreMetricsAfterJobCompletion
Sets whether metrics should be stored in the cluster after the job completes. If enabled, metrics can be retrieved for the configured job after it has
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1376
↓ 21 callersMethodsinkList
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineTestSupport.java:144
↓ 21 callersMethodstartNewSnapshotPhase1
This method is called when the member received {@link SnapshotPhase1Operation}.
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/SnapshotContext.java:212
↓ 21 callersMethodstorage
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/AbstractSchemaStorage.java:46
← previousnext →4,101–4,200 of 147,315, ranked by callers