MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 5 callersMethodreadLong
See the general contract of the {@code readLong} method of {@code DataInput}. <p> Bytes for this operation are read from the contained input stream.
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataInput.java:323
↓ 5 callersMethodreadMapStringKey
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/SerializationUtil.java:287
↓ 5 callersMethodreadNullableField
(@Nonnull String fieldName, FieldType fieldType, Reader<ObjectDataInput, T> reader)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableInternalGenericRecord.java:214
↓ 5 callersMethodreadNullableField
(@Nonnull String fieldName, FieldType fieldType, Reader<ObjectDataInput, T
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/DefaultPortableReader.java:142
↓ 5 callersMethodreadObjectArrayField
(@Nonnull String fieldName, FieldType fieldType, IntFunction<T[]> constructor,
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableInternalGenericRecord.java:416
↓ 5 callersMethodreadObjectArrayField
(@Nonnull String fieldName, FieldType fieldType, IntFunction<T[]> constructor,
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/DefaultPortableReader.java:394
↓ 5 callersMethodreadObjectFromArrayField
(@Nonnull String fieldName, FieldType fieldType, Reader<ObjectDataI
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableInternalGenericRecord.java:862
↓ 5 callersMethodreadOnly
()
hazelcast/src/main/java/com/hazelcast/internal/config/DataConnectionConfigReadOnly.java:35
↓ 5 callersMethodreadRecord
(ObjectDataInput in)
hazelcast/src/main/java/com/hazelcast/map/impl/record/Records.java:47
↓ 5 callersMethodreadResource
(String name)
hazelcast/src/test/java/com/hazelcast/jet/impl/deployment/ChildFirstClassLoaderTest.java:250
↓ 5 callersMethodreadResult
(Future<T> future)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/KinesisUtil.java:32
↓ 5 callersMethodreadStaticField
Reads a value of a static field. In case of any exceptions it returns null.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ReflectionUtils.java:139
↓ 5 callersMethodreconnectIfNecessary
@return true if there is a connection to Mongo after exiting this method
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/MongoConnection.java:80
↓ 5 callersMethodrecordIterator
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/ReplicatedRecordStore.java:87
↓ 5 callersMethodrecreate
Recreates this query cache. Recreation steps are: <ul> <li> Reset local subscribers' state, clear all cached entries </li> <li> Recreate/reset publis
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/InternalQueryCache.java:104
↓ 5 callersMethodrefreshIndex
()
extensions/elasticsearch/elasticsearch-7/src/test/java/com/hazelcast/jet/elastic/BaseElasticTest.java:225
↓ 5 callersMethodregexContains
(String str, String regex)
hazelcast/src/test/java/com/hazelcast/jet/core/DotTest.java:161
↓ 5 callersMethodregister
(String name, int defaultPoolSize, int defaultQueueCapacity, ExecutorType type)
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/impl/ExecutionServiceImpl.java:161
↓ 5 callersMethodregisterCacheEntryListener
Registers the provided listener configuration. @param cacheEntryListenerConfiguration The cache configuration to be used for registering the entry li
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheInternal.java:49
↓ 5 callersMethodregisterInvocation
(ClientInvocation clientInvocation, ClientConnection connection)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientInvocationServiceImpl.java:301
↓ 5 callersMethodregisterPublisher
Register a custom {@link MetricsPublisher} implementation with a register function that takes {@link NodeEngine} as input letting the caller to option
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsService.java:121
↓ 5 callersMethodregisterStaticProbeWithUnit
(S source, MetricDescriptor descriptor, String name, ProbeLevel level,
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsRegistryImpl.java:223
↓ 5 callersMethodrejectExecution
(String executorName)
hazelcast/src/main/java/com/hazelcast/map/impl/ExecutorStats.java:60
↓ 5 callersMethodrelease
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Promise.java:153
↓ 5 callersMethodremoteCacheJournal
Returns a source that will stream the {@link EventJournalCacheEvent} events of the Hazelcast {@code ICache} with the specified name from a remote clus
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:1052
↓ 5 callersMethodremoveAll
Removes keys from map store. It also handles {@link Data} to object conversions of keys. @param keys to be removed
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:81
↓ 5 callersMethodremoveCacheEntryListenerConfiguration
Remove a configuration for a {@link javax.cache.event.CacheEntryListener}. @param cacheEntryListenerConfiguration the {@link javax.cache.configuratio
hazelcast/src/main/java/com/hazelcast/config/CacheConfiguration.java:72
↓ 5 callersMethodremoveFirstOccurrence
Removes the first occurrence of the specified element in this queue when searching it by starting from the head of this queue. @param e element to be
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueue.java:62
↓ 5 callersMethodremoveIf
(Predicate<? super E> filter)
hazelcast/src/main/java/com/hazelcast/map/impl/query/QueryResultCollection.java:86
↓ 5 callersMethodremoveInternal
(Object key)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientMapProxy.java:297
↓ 5 callersMethodremoveInternal
(Object key)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:693
↓ 5 callersMethodremoveKey
Overloaded version of {@link Map#remove(Object)} that takes a primitive long key. Due to type erasure have to rename the method @param key for indexi
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Object2LongHashMap.java:329
↓ 5 callersMethodremoveListener
Removes listener from this event service. @param mapName underlying IMap name of query-cache @param cacheId ID of the query cache @param listen
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/QueryCacheEventService.java:98
↓ 5 callersMethodremoveLogListener
(@Nonnull LogListener logListener)
hazelcast/src/main/java/com/hazelcast/logging/LoggingService.java:26
↓ 5 callersMethodremoveModifierSuffix
Remove modifier suffix from given fullName.
hazelcast/src/main/java/com/hazelcast/query/impl/getters/SuffixModifierUtils.java:41
↓ 5 callersMethodremoveThreadLocalTestMethodName
()
hazelcast/src/test/java/com/hazelcast/test/TestLoggingUtils.java:52
↓ 5 callersMethodreplace
(K key, V newValue)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:68
↓ 5 callersMethodreplaceInternal
(Object key, Data expect, Data update)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:594
↓ 5 callersMethodreplaceVariables
Replaces variables in the given {@link Node} with the provided {@link ConfigReplacer}. @param node The node in which the variables to be replaced
hazelcast/src/main/java/com/hazelcast/internal/config/DomVariableReplacer.java:41
↓ 5 callersMethodreplicas
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionImpl.java:210
↓ 5 callersMethodreportEvent
Called to report the observation of an event with the given timestamp. The next call to {@link #getCurrentWatermark()} should reflect this. @param ti
hazelcast/src/main/java/com/hazelcast/jet/core/WatermarkPolicy.java:50
↓ 5 callersMethodrequiresJob
(RelNode rel)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:403
↓ 5 callersMethodreset
Resets the record store to it's initial state. <p> Used in replication operations. @see #putOrUpdateReplicatedRecord
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:656
↓ 5 callersMethodresolveAndValidateFields
( boolean isKey, List<MappingField> userFields, Map<String, String> option
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataResolver.java:47
↓ 5 callersMethodresolveForConverter
(Converter converter)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:426
↓ 5 callersMethodresolveNodes
()
hazelcast/src/main/java/com/hazelcast/kubernetes/DnsEndpointResolver.java:65
↓ 5 callersMethodresourceTypes
Returns the list of possible values for {@link DataConnectionResource#type()}, that will be returned when {@link #listResources()} is called. Returned
hazelcast/src/main/java/com/hazelcast/dataconnection/DataConnection.java:116
↓ 5 callersMethodrethrow
(Throwable t)
hazelcast-tpc-engine/src/test/java/com/hazelcast/internal/tpcengine/TpcTestSupport.java:213
↓ 5 callersMethodrethrowIfError
(final Throwable t)
hazelcast/src/main/java/com/hazelcast/internal/util/ExceptionUtil.java:158
↓ 5 callersMethodroutingPolicy
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/EdgeDef.java:74
↓ 5 callersMethodrowCount
()
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/WriteJdbcPTest.java:392
↓ 5 callersMethodrun
()
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/BackpressureRegulatorTest.java:264
↓ 5 callersMethodrun
(List<Operation> operationList)
hazelcast/src/main/java/com/hazelcast/collection/impl/CollectionTxnUtil.java:63
↓ 5 callersMethodrun
Runs the {@link Operation} on the calling thread. @param op the {@link Operation} to run. @throws java.lang.NullPointerException if op is null. @thro
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/OperationExecutor.java:150
↓ 5 callersMethodrunTest
(TestMode testMode)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:667
↓ 5 callersMethodrunWithOwnClassLoader
Runs the passed {@link Runnable} within the {@link ClassLoader} context of the passed {@link Object}'s own {@link ClassLoader} as defined by {@code Ob
hazelcast/src/main/java/com/hazelcast/internal/namespace/NamespaceUtil.java:196
↓ 5 callersMethodsampleObject
(T obj, byte[] serializedObject)
hazelcast/src/test/java/com/hazelcast/test/compatibility/SamplingSerializationService.java:265
↓ 5 callersMethodscheduleOnKeyOwnerAtFixedRate
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period on the partiti
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:270
↓ 5 callersMethodscheduleOnMemberAtFixedRate
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period at the given {
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:204
↓ 5 callersMethodscheduleOnMembersAtFixedRate
Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period on all {@link
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/IScheduledExecutorService.java:422
↓ 5 callersMethodscheduleWithRepetition
Executes a task periodically with the supplied {@code delaySeconds}. @param task task to execute. @param delaySeconds the time between subseq
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/QueryCacheScheduler.java:50
↓ 5 callersMethodsendInvalidationEvent
(String cacheNameWithPrefix, Data key, UUID sourceUuid)
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:135
↓ 5 callersMethodsendMemberListToOthers
Invoked on the master to send the member list (see {@link MembersUpdateOp}) to non-master nodes.
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:257
↓ 5 callersMethodsendRequestForPreparation
(Schema schema)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/schema/SchemaReplicator.java:337
↓ 5 callersMethodserialize
(Serializable entry)
hazelcast/src/test/java/com/hazelcast/test/TestJavaSerializationUtils.java:43
↓ 5 callersMethodserializeAliasedDiscoveryConfig
Serializes the provided aliased discovery config and adds the serialized contents under the tag in the JSON object if the config is not {@code null}.
hazelcast/src/main/java/com/hazelcast/internal/management/dto/WanBatchPublisherConfigDTO.java:217
↓ 5 callersMethodsetArrayOfNullableBoolean
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:898
↓ 5 callersMethodsetArrayOfNullableFloat32
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:1028
↓ 5 callersMethodsetArrayOfNullableFloat64
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:1054
↓ 5 callersMethodsetArrayOfNullableInt64
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:1002
↓ 5 callersMethodsetArrayOfNullableInt8
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:924
↓ 5 callersMethodsetAsyncBackupCount
Sets the number of asynchronous backups. 0 means no backups. @param asyncBackupCount the number of asynchronous synchronous backups to set @return th
hazelcast/src/main/java/com/hazelcast/config/RingbufferConfig.java:223
↓ 5 callersMethodsetAttribute
(TransformerFactory transformerFactory, String attributeName)
hazelcast/src/main/java/com/hazelcast/internal/util/XmlUtil.java:197
↓ 5 callersMethodsetAutoCommit
(boolean autoCommit)
hazelcast/src/main/java/com/hazelcast/dataconnection/impl/ConnectionDelegate.java:71
↓ 5 callersMethodsetAutoRemoveStaleData
Sets whether automatic removal of stale Persistence restart data is enabled. <p> When a member terminates or crashes when cluster state is {@link com.
hazelcast/src/main/java/com/hazelcast/config/PersistenceConfig.java:244
↓ 5 callersMethodsetBackupCount
(int backupCount)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:492
↓ 5 callersMethodsetBackupCount
Sets the number of synchronous backups for this queue. @param backupCount the number of synchronous backups to set @return the current QueueConfig @t
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:178
↓ 5 callersMethodsetBackupEntryCount
(long backupEntryCount)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalMapStatsImpl.java:224
↓ 5 callersMethodsetBatchSize
(int batchSize)
hazelcast/src/main/java/com/hazelcast/internal/config/QueryCacheConfigReadOnly.java:69
↓ 5 callersMethodsetByteOrder
Note that configuring use native byte order as enabled will override the byte order set by this method. @param byteOrder that serialization will use
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:443
↓ 5 callersMethodsetCPMapLimit
Sets the limit of permitted {@link com.hazelcast.cp.CPMap} instances. <p> This is a soft limit and is used exclusively by Hazelcast Management Center.
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:849
↓ 5 callersMethodsetCRDTReplicationConfig
Sets the replication configuration for {@link com.hazelcast.internal.crdt.CRDT} implementations. @param crdtReplicationConfig the replication configu
hazelcast/src/main/java/com/hazelcast/config/Config.java:2774
↓ 5 callersMethodsetCacheEntryListeners
Sets a list of {@link CacheSimpleEntryListenerConfig} for this {@link com.hazelcast.cache.ICache}. @param cacheEntryListeners list of {@link CacheSim
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:471
↓ 5 callersMethodsetCallerProvenance
(CallerProvenance callerProvenance)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:215
↓ 5 callersMethodsetChar
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:166
↓ 5 callersMethodsetCheckIfLoaded
(boolean checkIfLoaded)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:191
↓ 5 callersMethodsetClusterDataRecoveryPolicy
Sets the policy to be used when the cluster is started @param clusterDataRecoveryPolicy the policy to be used when the cluster is started @return Pe
hazelcast/src/main/java/com/hazelcast/config/PersistenceConfig.java:117
↓ 5 callersMethodsetConfigurationFile
Sets the {@link File} from which this configuration has been retrieved and created. <p> Is set by the {@link XmlConfigBuilder}, when the XML configura
hazelcast/src/main/java/com/hazelcast/config/Config.java:2899
↓ 5 callersMethodsetConnection
(Operation op, ServerConnection connection)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationAccessor.java:37
↓ 5 callersMethodsetCooperative
(boolean cooperative)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TransformP.java:59
↓ 5 callersMethodsetCurrentMapName
(String currentMapName)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/MockSnapshotContext.java:45
↓ 5 callersMethodsetDataNewValue
(Data dataNewValue)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/DefaultQueryCacheEventData.java:139
↓ 5 callersMethodsetDeny
Configures if this permission config is for a grant ({@code false}, default) permission or deny ({@code true}) @param deny value to set @return this i
hazelcast/src/main/java/com/hazelcast/config/PermissionConfig.java:339
↓ 5 callersMethodsetDeviceName
Sets the device name for this disk tier. @param deviceName device name. @return this DiskTierConfig
hazelcast/src/main/java/com/hazelcast/config/DiskTierConfig.java:86
↓ 5 callersMethodsetEnableCompression
(boolean enableCompression)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:59
↓ 5 callersMethodsetEnableSharedObject
(boolean enableSharedObject)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:61
↓ 5 callersMethodsetEnabled
Enables or disables the TPC-aware mode. <p> When enabled, the configuration option set by the {@link ClusterRoutingConfig#setRoutingMode(RoutingMode)}
hazelcast/src/main/java/com/hazelcast/client/config/ClientTpcConfig.java:73
↓ 5 callersMethodsetEntryListenerConfigs
(List<EntryListenerConfig> listenerConfigs)
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:546
↓ 5 callersMethodsetEntryOperator
(EntryOperator operator)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/State.java:379
↓ 5 callersMethodsetEpochStart
Sets the offset of timestamp component in milliseconds. By default, it's {@value DEFAULT_EPOCH_START}, that is the beginning of 2018. You can adjust t
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:197
← previousnext →11,101–11,200 of 147,315, ranked by callers