MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 6 callersMethodreadDigit
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonParser.java:412
↓ 6 callersMethodreadDigit
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonReducedValueParser.java:268
↓ 6 callersMethodreadInt8
Reads an 8-bit two's complement signed integer. <p> This method can also read a nullable int8, as long as it is not {@code null}. If a {@code null} va
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:104
↓ 6 callersMethodreadList
(@Nonnull ObjectDataInput input)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ImdgUtil.java:195
↓ 6 callersMethodreadNullableInt16
Reads a nullable 16-bit two's complement signed integer. <p> This method can also read a non-nullable int16. @param fieldName name of the field. @ret
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:564
↓ 6 callersMethodreadShortL
(byte[] buffer, int pos)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:119
↓ 6 callersMethodreadValue
()
hazelcast/src/main/java/com/hazelcast/internal/json/JsonParser.java:159
↓ 6 callersMethodreadsFromMongo
(boolean includeIdInMapping, boolean useUnsupportedExpressionInProjection, bool
extensions/mongodb/src/test/java/com/hazelcast/jet/sql/impl/connector/mongodb/MongoSqlConnectorIT.java:77
↓ 6 callersMethodrecover
(XAResource xaResource)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientXACompatibilityTest.java:208
↓ 6 callersMethodregex
Creates a <b>regex</b> predicate that will pass items if the given {@code pattern} matches the value stored under the given item {@code attribute}. <p
hazelcast/src/main/java/com/hazelcast/query/Predicates.java:369
↓ 6 callersMethodregister
Registers a {@link DiagnosticsPlugin}. <p> This method is thread-safe. <p> The duplicated plugins will overwrite the previous one. <p> If the {@link D
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:316
↓ 6 callersMethodregisterCompletionLatch
(int count)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheSyncListenerCompleter.java:80
↓ 6 callersMethodregisterIndex
Tracks indexes created dynamically via {@link com.hazelcast.map.IMap#addIndex}
hazelcast/src/main/java/com/hazelcast/map/impl/MapServiceContext.java:301
↓ 6 callersMethodregisterListenerAsync
(String cacheNameWithPrefix, CacheEventListener listener)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:117
↓ 6 callersMethodregisterSchema
Registers the specified {@code schema} and returns its ID.
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:291
↓ 6 callersMethodrejectOperationsFrom
(HazelcastInstance instance, int factory, List<Integer> opTypes)
hazelcast/src/test/java/com/hazelcast/test/PacketFiltersUtil.java:92
↓ 6 callersMethodremembered
Get the remembered value. Returns {@code null} if value was never asked for
hazelcast/src/main/java/com/hazelcast/instance/impl/executejar/ResettableSingleton.java:54
↓ 6 callersMethodremoteMapWithUpdating
Returns a sink equivalent to {@link #mapWithUpdating}, but for a map in a remote Hazelcast cluster identified by the supplied {@code ClientConfig}. <p
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sinks.java:688
↓ 6 callersMethodremove
Transactional implementation of {@link IMap#remove(Object)}. <p> The object to be removed will be removed from only the current transaction context un
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:205
↓ 6 callersMethodremoveAsyncInternal
(K key, V oldValue, boolean hasOldValue, boolean isGe
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxySupport.java:306
↓ 6 callersMethodremoveBadSession
Remove the bad JobUploadStatus because of an exception or expiration @param sessionId specifies the key to be used
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobUploadStore.java:55
↓ 6 callersMethodremoveCastIfPossible
Removes CAST operator from the column expression when possible. <p> The following expression might be found: {@code CAST(a AS BIGINT) > ?}. This may h
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:1447
↓ 6 callersMethodremoveCharacter
Removes all occurrence of {@code charToRemove} from {@code str}. This method is more efficient than {@link String#replaceAll(String, String)} which co
hazelcast/src/main/java/com/hazelcast/internal/util/StringUtil.java:419
↓ 6 callersMethodremoveEntriesFromMap
(IMap<Integer, Employee> map, int startIndex, int endIndex)
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/AbstractQueryCacheTestSupport.java:51
↓ 6 callersMethodremoveLifecycleListener
Removes a lifecycle listener. @param registrationId the listener ID returned by {@link #addLifecycleListener(LifecycleListener)} @return true if the
hazelcast/src/main/java/com/hazelcast/core/LifecycleService.java:61
↓ 6 callersMethodremoveMigrationListener
Removes a MigrationListener. <p> If the same MigrationListener is registered multiple times, it needs to be removed multiple times. <p> This method ca
hazelcast/src/main/java/com/hazelcast/partition/PartitionService.java:84
↓ 6 callersMethodremoveStale
()
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrentReferenceHashMap.java:983
↓ 6 callersMethodrender
Renders the value from the gauge. @param stringBuilder the {@link StringBuilder} to write to.
hazelcast/src/main/java/com/hazelcast/internal/metrics/Gauge.java:36
↓ 6 callersMethodrender
(DiagnosticsLogWriter writer, LifecycleEvent event)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/SystemLogPlugin.java:218
↓ 6 callersMethodreplaceAsync
Asynchronously replaces the assigned value of the given key by the specified value. <p> If the cache is configured for <code>write-through</code> oper
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:497
↓ 6 callersMethodreplacePlaceholders
(Document doc, ExpressionEvalContext evalContext, JetSqlRow inputRow,
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/PlaceholderReplacer.java:33
↓ 6 callersMethodreplica
(String host, int port)
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionRuntimeStateTest.java:95
↓ 6 callersMethodreset
()
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestOutbox.java:203
↓ 6 callersMethodresetLevel
Resets the levels of all the loggers known to this logger factory back to the default preconfigured values. Basically, undoes all the changes done by
hazelcast/src/main/java/com/hazelcast/logging/impl/InternalLoggerFactory.java:42
↓ 6 callersMethodresetRemembered
()
hazelcast/src/main/java/com/hazelcast/instance/impl/HazelcastBootstrap.java:73
↓ 6 callersMethodresolveConsumerProperties
(Map<String, String> options, Object keySchema, Object valueSchema)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/kafka/PropertiesResolver.java:90
↓ 6 callersMethodresolveFields
Resolves fields based on the options passed to the connector and schema provided by user (if any). @param externalName external name of the map
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/FieldResolver.java:68
↓ 6 callersMethodresolveNodes
()
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesApiEndpointResolver.java:69
↓ 6 callersMethodresolveProducerProperties
(Map<String, String> options, Object keySchema, Object valueSchema)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/kafka/PropertiesResolver.java:99
↓ 6 callersMethodrestoreWatermark
(Long value)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/ReadMongoP.java:381
↓ 6 callersMethodresult
Returns the aggregated result.
hazelcast/src/main/java/com/hazelcast/jet/datamodel/WindowResult.java:80
↓ 6 callersMethodrethrowFromCollection
If there's any Throwable instance in the values, throw it.
hazelcast/src/main/java/com/hazelcast/internal/util/ExceptionUtil.java:357
↓ 6 callersMethodretries
Number of retries the connector will do in addition to Elastic client retries <p> Elastic client tries to connect to a node only once for each request
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/ElasticSinkBuilder.java:193
↓ 6 callersMethodring
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/ringbuffer/RingbufferSplitBrainProtectionWriteTest.java:102
↓ 6 callersMethodringbufferName
(String observableName)
hazelcast/src/main/java/com/hazelcast/jet/impl/observer/ObservableImpl.java:156
↓ 6 callersMethodrollback
Roll back the transaction. Only called for non-prepared transactions when the job execution ends. <p> Will only be called for a transaction that was {
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:327
↓ 6 callersMethodrollbackClusterState
(UUID txnId)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterStateManager.java:303
↓ 6 callersMethodrunJob
()
hazelcast/src/test/java/com/hazelcast/jet/JobStatusListenerTest.java:398
↓ 6 callersMethodsampleValues
(RandomNumberSupplier<T> randomNumberSupplier)
hazelcast/src/test/java/com/hazelcast/aggregation/TestSamples.java:182
↓ 6 callersMethodsanitizeValue
(Object input)
hazelcast/src/main/java/com/hazelcast/query/impl/BaseIndexStore.java:107
↓ 6 callersMethodschedule
(Runnable command, long delay, TimeUnit unit)
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/ExecutionService.java:158
↓ 6 callersMethodschedule
Schedules (or reschedules) the execution of given entry. Key parameter is used to check whether there is an existing scheduling for this entry, see {@
hazelcast/src/main/java/com/hazelcast/internal/util/scheduler/EntryTaskScheduler.java:37
↓ 6 callersMethodsendJoinRequest
Send join request to {@code toAddress}. @param toAddress the currently known master address. @return {@code true} if join request was sent succ
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:455
↓ 6 callersMethodsendMasterAnswer
Respond to a join request by sending the master address in a {@link MasterResponseOp}. This happens when current node receives a join request but is n
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:618
↓ 6 callersMethodsendMessage
(String destinationName, boolean isQueue)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/StreamJmsPTest.java:190
↓ 6 callersMethodsendMigrationEvent
Sends a {@link ReplicaMigrationEvent} to the registered event listeners.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionEventManager.java:68
↓ 6 callersMethodsendToListeningEndpoints
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/AbstractListenerService.java:67
↓ 6 callersMethodserializeAndDeserialize
(T object)
hazelcast/src/test/java/com/hazelcast/test/TestJavaSerializationUtils.java:31
↓ 6 callersMethodserviceLbWithoutAddr
(ServicePort... port)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesFakeUtils.java:478
↓ 6 callersMethodset
(Integer... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/IsNullPredicateIntegrationTest.java:237
↓ 6 callersMethodsetAllAsync
Asynchronously copies all of the mappings from the specified map to this map without loading non-existing elements from map store. This version doesn'
hazelcast/src/main/java/com/hazelcast/map/IMap.java:1930
↓ 6 callersMethodsetAllowUnsafe
(boolean allowUnsafe)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:63
↓ 6 callersMethodsetAmount
(int amount)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientTxnMapTest.java:143
↓ 6 callersMethodsetAndGetListenerFlags
Sets and gets flags of implemented listener interfaces of a {@link com.hazelcast.map.listener.MapListener MapListener}.
hazelcast/src/main/java/com/hazelcast/map/impl/MapListenerFlagOperator.java:38
↓ 6 callersMethodsetArrayOfFloat32
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:847
↓ 6 callersMethodsetArrayOfFloat64
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:872
↓ 6 callersMethodsetArrayOfInt32
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:797
↓ 6 callersMethodsetArrayOfInt64
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:822
↓ 6 callersMethodsetArrayOfInt8
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:719
↓ 6 callersMethodsetArrayOfNullableInt16
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:950
↓ 6 callersMethodsetArrayOfNullableInt32
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:976
↓ 6 callersMethodsetAutoStepDownWhenLeader
Enables or disables automatic leader step-down for this CP member. <p>If enabled, the member will immediately relinquish leadership whenever elected,
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:627
↓ 6 callersMethodsetBackupAckToClientEnabled
This feature reduces number of hops and increases performance for {@link RoutingMode#ALL_MEMBERS} routing clients. It is enabled by default for {@link
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:941
↓ 6 callersMethodsetBackupDir
Sets base directory for all Hot Restart stores. @param backupDir home directory @return PersistenceConfig
hazelcast/src/main/java/com/hazelcast/config/PersistenceConfig.java:156
↓ 6 callersMethodsetBackupPacketDropFilter
(HazelcastInstance instance, float blockRatio)
hazelcast/src/test/java/com/hazelcast/internal/partition/AntiEntropyCorrectnessTest.java:95
↓ 6 callersMethodsetCacheEntryEventFilterFactory
(String cacheEntryEventFilterFactory)
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleEntryListenerConfig.java:60
↓ 6 callersMethodsetCallerAddress
(Address callerAddress)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:210
↓ 6 callersMethodsetCapacity
(int capacity)
hazelcast/src/main/java/com/hazelcast/internal/config/RingbufferConfigReadOnly.java:42
↓ 6 callersMethodsetCheckClassDefErrors
When enabled, serialization system will check for class definitions error at start and throw a Serialization Exception with error definition. @param
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:407
↓ 6 callersMethodsetClassLoader
Sets the classLoader which is used by serialization and listener configuration @param classLoader the classLoader @return configured {@link com.hazel
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:679
↓ 6 callersMethodsetClassName
(@Nonnull String className)
hazelcast/src/main/java/com/hazelcast/internal/config/MapStoreConfigReadOnly.java:33
↓ 6 callersMethodsetClientXml
(String clientXml)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/MapSinkConfiguration.java:63
↓ 6 callersMethodsetClockOffset
(long offset)
hazelcast/src/test/java/com/hazelcast/internal/util/AbstractClockTest.java:86
↓ 6 callersMethodsetCluster
(String cluster)
hazelcast/src/main/java/com/hazelcast/aws/AwsConfig.java:306
↓ 6 callersMethodsetConnectionTimeout
@param connectionTimeoutInMillis Timeout value in millis for nodes to accept client connection requests. A zero value
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:218
↓ 6 callersMethodsetDataKey
(Data dataKey)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEventContext.java:68
↓ 6 callersMethodsetDisablePerEntryInvalidationEvents
Sets invalidation events disabled status for per entry. @param disablePerEntryInvalidationEvents disables invalidation event sending behaviour if it
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:514
↓ 6 callersMethodsetEnabled
Set whether the ICMP failure detector should be enabled or not. When set to true, this member will use icmp ping failure detector to detect unavailabl
hazelcast/src/main/java/com/hazelcast/config/IcmpFailureDetectorConfig.java:195
↓ 6 callersMethodsetEnabled
Enables or disables native memory allocation. @return this {@link NativeMemoryConfig} instance
hazelcast/src/main/java/com/hazelcast/config/NativeMemoryConfig.java:153
↓ 6 callersMethodsetError
(Throwable t)
hazelcast/src/main/java/com/hazelcast/spi/impl/proxyservice/impl/DistributedObjectFuture.java:147
↓ 6 callersMethodsetExpiryPolicyFactoryConfig
Sets the factory configuration for this {@link javax.cache.expiry.ExpiryPolicy}. @param expiryPolicyFactoryConfig the factory configuration to set fo
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:427
↓ 6 callersMethodsetExternalName
(String extName)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/MappingField.java:101
↓ 6 callersMethodsetFailFastOnStartup
Sets whether the member should fail-fast on startup if ICMP is not allowed by the underlying OS. Failure is usually due to OS level restrictions. @pa
hazelcast/src/main/java/com/hazelcast/config/IcmpFailureDetectorConfig.java:140
↓ 6 callersMethodsetFailOnIndeterminateOperationState
Sets the value to determine if CP Subsystem calls will fail when result of an API call becomes indeterminate. @return this config instance
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:513
↓ 6 callersMethodsetFileName
Sets the name of the file which will contain the tracking metadata. If set to {@code null}, {@link InstanceTrackingConfig#DEFAULT_FILE} is used instea
hazelcast/src/main/java/com/hazelcast/config/InstanceTrackingConfig.java:116
↓ 6 callersMethodsetInMemoryFormat
Data type that will be used to store records in this {@link com.hazelcast.cache.ICache}. Possible values: <ul> <li>BINARY (default): keys and values w
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:436
↓ 6 callersMethodsetInitialBackoffMillis
@param initialBackoffMillis how long to wait after the first failure before retrying @return updated ConnectionRetryConfig
hazelcast/src/main/java/com/hazelcast/client/config/ConnectionRetryConfig.java:75
↓ 6 callersMethodsetItemClass
(@Nonnull Class itemClass)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/ReadMongoParams.java:162
↓ 6 callersMethodsetIterationPointers
Sets the iteration state to the state defined by the {@code pointers} if the given response contains items. @param response the iteration response @p
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheIterator.java:221
↓ 6 callersMethodsetJaasAuthenticationConfig
(JaasAuthenticationConfig authenticationConfig)
hazelcast/src/main/java/com/hazelcast/config/security/RealmConfig.java:46
← previousnext →9,901–10,000 of 147,315, ranked by callers