MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 10 callersMethodrequired
(String property)
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/impl/PropertyRules.java:33
↓ 10 callersMethodreset
Resets the cursor to the initial state.
hazelcast/src/main/java/com/hazelcast/internal/util/collection/LongCursor.java:43
↓ 10 callersMethodrnd
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/SerializationConcurrencyTest.java:114
↓ 10 callersMethodroundRobinPart
From an imaginary set of integers {@code (0, 1, ..., objectCount-1)} returns {@code index}-th disjoint subset out of {@code count} subsets. The assign
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:356
↓ 10 callersMethodrun
( Consumer<ThrowingMapStore> setupMapStore, Consumer<IMap<Integer, String>> mapOperati
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapStoreExceptionsLoggedTest.java:211
↓ 10 callersMethodrunPipeline
(DAG dag)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/MetricsTest.java:483
↓ 10 callersMethodrunTest
( Expression<Boolean> rowProjectorCondition, Expression<?> rowProjectorProjection,
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/JoinByPrimitiveKeyProcessorTest.java:148
↓ 10 callersMethodrunnable
()
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/durableexecutor/DurableExecutorSplitBrainProtectionWriteTest.java:272
↓ 10 callersMethodsampleBigDecimals
()
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:86
↓ 10 callersMethodscheduleOnKeyOwner
Creates and executes a one-shot action that becomes enabled after the given delay on the partition owner of the given key. @param command the task to
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:223
↓ 10 callersMethodscheduleOnMembers
Creates and executes a one-shot action that becomes enabled after the given delay on all {@link Member}s given. <p> <b>Note: </b> In the event of Mem
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:368
↓ 10 callersMethodsend500
Prepares a {@link HttpURLConnection#HTTP_INTERNAL_ERROR} response.
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpCommand.java:106
↓ 10 callersMethodsendMessages
(boolean isQueue)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/JmsSourceIntegrationTestBase.java:461
↓ 10 callersMethodseqToArrayIndex
(long sequence, long mask)
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/AbstractConcurrentArrayQueue.java:227
↓ 10 callersMethodserializationService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/Contexts.java:230
↓ 10 callersMethodset
(int index, Object val)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/row/HeapRow.java:65
↓ 10 callersMethodsetBufferSize
Sets the maximum number of events which can be stored in a buffer of partition. @param bufferSize the buffer size @return this {@code QueryCacheConfi
hazelcast/src/main/java/com/hazelcast/config/QueryCacheConfig.java:242
↓ 10 callersMethodsetConfigPatternMatcher
Sets the pattern matcher which is used to match item names to configuration objects. By default, the {@link MatchingPointConfigPatternMatcher} is used
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:242
↓ 10 callersMethodsetCurrentSequence
(String name, int partitionId, long sequence)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/MetaDataGenerator.java:76
↓ 10 callersMethodsetDate
Sets a date field consisting of year, month of the year, and day of the month. <p> It is legal to set the field again only when Builder is created wit
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:612
↓ 10 callersMethodsetDepth
Sets the depth of the merkle tree. The depth must be between {@value MAX_DEPTH} and {@value MIN_DEPTH} (exclusive). @param depth the depth of the mer
hazelcast/src/main/java/com/hazelcast/config/MerkleTreeConfig.java:117
↓ 10 callersMethodsetDynamicConfig
(DiagnosticsConfig config)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/DiagnosticsAutoOffTests.java:243
↓ 10 callersMethodsetHazelcastInstance
(HazelcastInstance hazelcastInstance)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:57
↓ 10 callersMethodsetInMemoryFormat
Sets the data type used to store entries. <p> Possible values: <ul> <li>{@code BINARY}: keys and values are stored as binary data</li> <li>{@code OBJE
hazelcast/src/main/java/com/hazelcast/config/NearCacheConfig.java:176
↓ 10 callersMethodsetInt8
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:138
↓ 10 callersMethodsetLoadAllKeys
(boolean loadAllKeys)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapStoreTest.java:1263
↓ 10 callersMethodsetManagedContext
(ManagedContext managedContext)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:51
↓ 10 callersMethodsetManagerPrefix
Sets the manager prefix of the {@link com.hazelcast.cache.ICache}. @param managerPrefix the manager prefix to set for this {@link com.hazelcast.cache
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:263
↓ 10 callersMethodsetMulticastTimeoutSeconds
Specifies the time in seconds that a node should wait for a valid multicast response from another node running in the network before declaring itself
hazelcast/src/main/java/com/hazelcast/config/MulticastConfig.java:165
↓ 10 callersMethodsetName
Sets the name of the job. There can be at most one active job in the cluster with particular name, however, the name can be reused after the previous
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:121
↓ 10 callersMethodsetNullableInt32
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:396
↓ 10 callersMethodsetPacketType
Sets the packet type by updating the packet type bits in the {@code flags} bitfield. Other bits are unaffected. @param type the type to set @return {
hazelcast/src/main/java/com/hazelcast/internal/nio/Packet.java:161
↓ 10 callersMethodsetParameterConverter
(int ordinal, ParameterConverter parameterConverter)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/HazelcastSqlValidator.java:474
↓ 10 callersMethodsetPreloaderConfig
Sets the {@link NearCachePreloaderConfig} of this Near Cache. @param preloaderConfig the {@link NearCachePreloaderConfig} of this Near Cache @return
hazelcast/src/main/java/com/hazelcast/config/NearCacheConfig.java:384
↓ 10 callersMethodsetPrimaryKey
(boolean primaryKey)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/MappingField.java:111
↓ 10 callersMethodsetProperty
(SchemaFactory schemaFactory, String propertyName)
hazelcast/src/main/java/com/hazelcast/internal/util/XmlUtil.java:224
↓ 10 callersMethodsetSchema
Sets the schema name. The engine will try to resolve the non-qualified object identifiers from the statement in the given schema. If not found, the de
hazelcast/src/main/java/com/hazelcast/sql/SqlStatement.java:149
↓ 10 callersMethodsetSerializationConfig
Sets the serialization configuration for this hazelcast instance. The serialization configuration defines how objects are serialized and deserialized
hazelcast/src/main/java/com/hazelcast/config/Config.java:2620
↓ 10 callersMethodsetSessionId
(UUID sessionId)
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobMultiPartParameterObject.java:42
↓ 10 callersMethodsetTcpIpConfig
@param tcpIpConfig the tcpIpConfig join configuration to set @throws IllegalArgumentException if tcpIpConfig is null
hazelcast/src/main/java/com/hazelcast/config/JoinConfig.java:76
↓ 10 callersMethodsetTimestamp
Sets a timestamp field consisting of year, month of the year, and day of the month, hour, minute, seconds, nanos parts. <p> It is legal to set the fie
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:640
↓ 10 callersMethodsetTryPauseMillis
Sets the pause time in milliseconds. @param tryPauseMillis the pause time in milliseconds. @return the InvocationBuilder
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/InvocationBuilder.java:187
↓ 10 callersMethodsetUniqueKey
Sets unique key attribute in this index config. @param uniqueKey a unique key attribute to configure.
hazelcast/src/main/java/com/hazelcast/config/BitmapIndexOptions.java:180
↓ 10 callersMethodsetUniqueKeyTransformation
Sets unique key transformation in this index config. @param uniqueKeyTransformation a unique key transformation to configure.
hazelcast/src/main/java/com/hazelcast/config/BitmapIndexOptions.java:203
↓ 10 callersMethodsetUuid
(int partitionId, UUID uuid)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/MetaDataGenerator.java:92
↓ 10 callersMethodsetValue
Sets the value of the scalar node @param newValue The new value of the scalar node
hazelcast/src/main/java/com/hazelcast/internal/yaml/MutableYamlScalar.java:28
↓ 10 callersMethodsetVersion
(byte version)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:35
↓ 10 callersMethodshouldBackup
Checks if a backup needs to be made. <p> If a call has not made any change, e.g. an AtomicLong increment with 0, no backup needs to be made. @return
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/BackupAwareOperation.java:34
↓ 10 callersMethodshutdown
Shuts down the Reactor. <p/> This call doesn't wait for the Reactor to shut down. The {@link #awaitTermination(long, TimeUnit)} should be used for tha
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Reactor.java:274
↓ 10 callersMethodshutdown
@deprecated Use {@link HazelcastInstance#shutdown()} instead.
hazelcast/src/main/java/com/hazelcast/jet/JetInstance.java:136
↓ 10 callersMethodsignatureError
(SqlColumnType type)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/FloorCeilFunctionIntegrationTest.java:170
↓ 10 callersMethodskipWhiteSpace
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonParser.java:420
↓ 10 callersMethodsleep
(long delay, TimeUnit unit)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Eventloop.java:264
↓ 10 callersMethodstart
Start accepting incoming sockets asynchronously. <p/> This method can be called from any thread, but the actual processing will happen on the reactor-
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncServerSocket.java:141
↓ 10 callersMethodstart
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:384
↓ 10 callersMethodstartAllTcpServers
()
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerConnection_AbstractTest.java:113
↓ 10 callersMethodstoreTaskResponseToReference
(final AtomicReference<Object> ref)
hazelcast/src/test/java/com/hazelcast/executor/CompletableFutureTest.java:321
↓ 10 callersMethodstringValue1
(String first)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/ExpressionTestSupport.java:259
↓ 10 callersMethodsupplier
( QueryPath[] paths, QueryDataType[] types, QueryTargetDescriptor keyDescr
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvRowProjector.java:140
↓ 10 callersMethodsupplierFrom
Wraps the provided {@code ProcessorSupplier} with a {@code Supplier<Processor>} that returns processors obtained from it.
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:1070
↓ 10 callersMethodtagCount
Returns the number of tags in this descriptor. @return the number of tags
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:175
↓ 10 callersMethodterminateAll
(Collection<? extends Reactor> reactors)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/TpcTestSupport.java:62
↓ 10 callersMethodtestJoin
(Config config)
hazelcast/src/test/java/com/hazelcast/cluster/AbstractJoinTest.java:36
↓ 10 callersMethodthrottle
(@Nonnull SupplierEx<Processor> wrapped, long itemsPerSecond)
hazelcast/src/test/java/com/hazelcast/jet/core/TestUtil.java:85
↓ 10 callersMethodtime
(long epochMillis)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:754
↓ 10 callersMethodtoIntSize
Converts <code>long</code> map size to <code>int</code>. If <code>size</code> is greater than <code>Integer.MAX_VALUE</code> then <code>Integer.MAX_VA
hazelcast/src/main/java/com/hazelcast/internal/util/MapUtil.java:113
↓ 10 callersMethodtoOpControl
(Address address)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/CallsPerMember.java:66
↓ 10 callersMethodtoPrettyString
Returns a pretty format String representation of this capacity. @return a pretty format representation of this capacity
hazelcast/src/main/java/com/hazelcast/memory/Capacity.java:182
↓ 10 callersMethodtoString
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpiryMetadata.java:113
↓ 10 callersMethodtryOverride
(HazelcastProperty property, UnaryOperator<String> getPropertyValueFn, Con
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsConfigHelper.java:122
↓ 10 callersMethodunpark
Unparks the parked {@link BlockingOperation} operation by rescheduling it on the {@link com.hazelcast.spi.impl.operationexecutor.OperationExecutor} A
hazelcast/src/main/java/com/hazelcast/spi/impl/operationparker/OperationParker.java:60
↓ 10 callersMethoduuidOf
(Address address)
hazelcast/src/test/java/com/hazelcast/test/mocknetwork/TestNodeRegistry.java:96
↓ 10 callersMethodvalidateReceptionAtOrdinals
(Object item, int... ordinals)
hazelcast/src/test/java/com/hazelcast/jet/core/AbstractProcessorTest.java:357
↓ 10 callersMethodverifyAnd
()
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithmsTest.java:209
↓ 10 callersMethodwait
(Map<Member, IScheduledFuture<V>> futures)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/scheduledexecutor/ScheduledExecutorSplitBrainProtectionWriteTest.java:271
↓ 10 callersMethodwhenEntryIsLoaded_thenNearCacheShouldBeInvalidated
With the {@link NearCacheTestContext#dataAdapter} we have to set {@link NearCacheConfig#setInvalidateOnChange(boolean)}. With the {@link NearCacheTest
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheBasicTest.java:1029
↓ 10 callersMethodwithSerializedValue
(Data serializedValue)
hazelcast/src/main/java/com/hazelcast/cache/impl/DeferredValue.java:124
↓ 10 callersMethodwriteInt
(byte[] buffer, int pos, int v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:163
↓ 10 callersMethodwriteMemberName
(String name)
hazelcast/src/main/java/com/hazelcast/internal/json/JsonWriter.java:84
↓ 10 callersMethodwriteZeroBytes
(int count)
hazelcast/src/main/java/com/hazelcast/internal/nio/BufferObjectDataOutput.java:49
↓ 9 callersMethodaccessRecord
Callback which is called when the record is being accessed from the record or index store. <p> An implementation is not supposed to be thread safe. @
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:148
↓ 9 callersMethodadd
Adds a future to this Pipelining or blocks until there is capacity to add the future to the Pipelining. <p> This call blocks until there is space in t
hazelcast/src/main/java/com/hazelcast/core/Pipelining.java:132
↓ 9 callersMethodadd
(@Nonnull URL url, @Nullable String id, @Nonnull ResourceType resourceType)
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:1174
↓ 9 callersMethodaddAllResolvedAddresses
(Address address)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/LinkedAddresses.java:57
↓ 9 callersMethodaddChild
(String name, YamlNode node)
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlMappingImpl.java:82
↓ 9 callersMethodaddClusterMember
()
hazelcast/src/test/java/com/hazelcast/internal/util/iterator/RestartingMemberIteratorTest.java:55
↓ 9 callersMethodaddDataSerializableFactoryClass
@param factoryId factory ID of dataSerializableFactory to be registered @param dataSerializableFactoryClass name of dataSerializabl
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:195
↓ 9 callersMethodaddDateField
Adds a date field consisting of year, month of the year and day of the month to the class definition @param fieldName name of the field that will be
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinitionBuilder.java:230
↓ 9 callersMethodaddDecimalField
Adds a decimal which is arbitrary precision and scale floating-point number to the class definition @param fieldName name of the field that will be a
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinitionBuilder.java:204
↓ 9 callersMethodaddDurableExecutorConfig
Adds the durable executor configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be
hazelcast/src/main/java/com/hazelcast/config/Config.java:2085
↓ 9 callersMethodaddItemListenerConfig
Add an item listener configuration to this queue. @param listenerConfig the item listener configuration to add to this queue @return the updated queu
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:275
↓ 9 callersMethodaddPNCounterConfig
Adds the PN counter configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtai
hazelcast/src/main/java/com/hazelcast/config/Config.java:2124
↓ 9 callersMethodaddScheduledExecutorConfig
Adds the scheduled executor configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will
hazelcast/src/main/java/com/hazelcast/config/Config.java:2098
↓ 9 callersMethodaddStatefulSetInfo
Adds or updates StatefulSet information in this context. @param name the name of the StatefulSet @param info the StatefulSet information @param resour
hazelcast/src/main/java/com/hazelcast/kubernetes/RuntimeContext.java:243
↓ 9 callersMethodaddTaskAndWakeup
Adds a task to be executed by the NioThread and wakes up the selector so that it will eventually pick up the task. @param task the task to add. @thro
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioThread.java:222
↓ 9 callersMethodaddTimeField
Adds a time field consisting of hour, minute, seconds and nanos parts to the class definition @param fieldName name of the field that will be added t
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinitionBuilder.java:217
↓ 9 callersMethodaddTimestampField
Adds a timestamp field consisting of year, month of the year, day of the month, hour, minute, seconds, nanos parts to the class definition @param fie
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinitionBuilder.java:244
↓ 9 callersMethodaddTimestampWithTimezoneField
Adds a timestamp with timezone field consisting of year, month of the year, day of the month, offset seconds, hour, minute, seconds, nanos parts to th
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinitionBuilder.java:259
↓ 9 callersMethodafterOperation
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:677
↓ 9 callersMethodallTable1ExpectedOperations
(int dbSuffix)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcWhiteBlackListIntegrationTest.java:365
← previousnext →6,901–7,000 of 147,315, ranked by callers