MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 25 callersMethodexpandPrimitiveArrayScenario
Expands test cases for primitive array data types. Word "primitiveArray" is replaced by each primitive array type and the scenario is expanded to for
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderSpecTest.java:236
↓ 25 callersMethodget
(String attribute)
hazelcast/src/main/java/com/hazelcast/query/PredicateBuilder.java:41
↓ 25 callersMethodgetClientConfig
()
hazelcast/src/main/java/com/hazelcast/client/impl/clientside/HazelcastClientProxy.java:282
↓ 25 callersMethodgetClusterName
Returns the configured cluster name. The name is sent as part of client authentication message and may be verified on the member. @return the configu
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:805
↓ 25 callersMethodgetExpiryMetadata
(Data key)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpirySystem.java:69
↓ 25 callersMethodgetField
(String fieldName)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/Schema.java:165
↓ 25 callersMethodgetFirstResourceConfig
()
hazelcast/src/test/java/com/hazelcast/jet/config/ResourceConfigTest.java:142
↓ 25 callersMethodgetForUpdate
Locks the key and then gets and returns the value to which the specified key is mapped. The lock will be released at the end of the transaction (eithe
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:99
↓ 25 callersMethodgetIndexes
Returns all the indexes known to this indexes instance.
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:444
↓ 25 callersMethodgetLastCallId
Returns the last issued call ID. <strong>ONLY FOR TESTING. Must not be used for production code.</strong>
hazelcast/src/main/java/com/hazelcast/spi/impl/sequence/CallIdSequence.java:77
↓ 25 callersMethodgetLocalPort
Gets the local port of the {@link AsyncServerSocket}. <p/> If {@link #bind(SocketAddress)} has not been called, then -1 is returned. @return the loca
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncServerSocket.java:88
↓ 25 callersMethodgetLongAttribute
(String name)
hazelcast/src/test/java/com/hazelcast/internal/jmx/ReplicatedMapMBeanTest.java:185
↓ 25 callersMethodgetMinor
()
hazelcast/src/main/java/com/hazelcast/version/Version.java:75
↓ 25 callersMethodgetName
Gets the name of this {@link NearCache} instance. @return the name of this {@link NearCache} instance
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCache.java:117
↓ 25 callersMethodgetNextSequenceToReadFrom
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/ReadResultSetImpl.java:213
↓ 25 callersMethodgetQueryCacheConfigs
Returns all {@link QueryCacheConfig} instances defined on this {@code MapConfig}. @return all {@link QueryCacheConfig} instances defined on this {@co
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:647
↓ 25 callersMethodgetReadOnlyConfig
()
hazelcast/src/test/java/com/hazelcast/config/MapConfigReadOnlyTest.java:37
↓ 25 callersMethodgetService
(TestBundleContext bundleContext)
hazelcast/src/test/java/com/hazelcast/osgi/HazelcastOSGiServiceTest.java:114
↓ 25 callersMethodgetTarget
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlOrderByTest.java:199
↓ 25 callersMethodgetTtl
()
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/expiry/ExpiryMetadata.java:33
↓ 25 callersMethodgroup
(PrimitivePortable.Init init)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/portablereader/DefaultPortableReaderTestStructure.java:596
↓ 25 callersMethodhandleAsync
(BiFunction<? super V, Throwable, ? extends U> fn)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientDelegatingFuture.java:344
↓ 25 callersMethodinvalidateNearCache
(Object key)
hazelcast/src/main/java/com/hazelcast/client/cache/impl/nearcache/NearCachedClientCacheProxy.java:704
↓ 25 callersMethodinvokeOnAllPartitions
(Object request, boolean urgent)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/InvokerWrapper.java:31
↓ 25 callersMethodisAlive
Check if ClientConnectionManager is alive. ClientConnectionManager is not alive only when client is closing. @return true if alive, false otherwise.
hazelcast/src/main/java/com/hazelcast/client/impl/connection/ClientConnectionManager.java:40
↓ 25 callersMethodisFsync
Returns whether disk write should be followed by an {@code fsync()} system call. @return true if fsync is be called after disk write, false otherwise
hazelcast/src/main/java/com/hazelcast/config/HotRestartConfig.java:77
↓ 25 callersMethodisOrHasCause
Checks, if {@code t} itself or any exception in its cause chain is an instance of {@code classToFind}.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ExceptionUtil.java:199
↓ 25 callersMethodisRepublishingEnabled
Returns {@code true} if incoming WAN events to this member should be republished (forwarded) to this WAN replication reference. The default state for
hazelcast/src/main/java/com/hazelcast/config/WanReplicationRef.java:158
↓ 25 callersMethodisTrue
Detects whether this value represents the JSON literal <code>true</code>. @return <code>true</code> if this value represents the JSON literal <code>t
hazelcast/src/main/java/com/hazelcast/internal/json/JsonValue.java:121
↓ 25 callersMethodisValid
@return {@code true} if supplied record store is valid to apply forced eviction, otherwise return {@code false}
hazelcast/src/main/java/com/hazelcast/map/impl/operation/ForcedEviction.java:104
↓ 25 callersMethodisWanReplicationEnabled
Returns {@code true} if WAN replication is enabled for the cache named {@code cacheNameWithPrefix}. @param cacheNameWithPrefix the full name of the {
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:142
↓ 25 callersMethoditem
(int index)
hazelcast/src/main/java/com/hazelcast/internal/config/yaml/EmptyNodeList.java:33
↓ 25 callersMethoditemsByTag
Accepts an argument list of alternating tags and values, interprets them as a list of tag-value pairs, and returns an {@code ItemsByTag} populated wit
hazelcast/src/main/java/com/hazelcast/jet/datamodel/ItemsByTag.java:49
↓ 25 callersMethoditerator
Returns an iterator over the items in the inbox in the order they would be returned by the {@link #poll()} method. <p> The returned iterator doesn't s
hazelcast/src/main/java/com/hazelcast/jet/core/Inbox.java:69
↓ 25 callersMethodkafkaMapping
(String name)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlAvroTest.java:146
↓ 25 callersMethodload
Loads a YAML document from an {@link InputStream} and builds a {@link YamlNode} tree that is under the provided top-level {@code rootName} key. This l
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlLoader.java:50
↓ 25 callersMethodnewCompletableFuture
(long completeAfterMillis)
hazelcast/src/test/java/com/hazelcast/spi/impl/DelegatingCompletableFuture_SerializationExceptionTest.java:260
↓ 25 callersMethodnewDoubleGauge
Creates a {@link DoubleGauge} for a given metric name. @param name name of the metric @return the create DoubleGauge @throws NullPointerException if
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricsRegistry.java:108
↓ 25 callersMethodnewHazelcastClient
()
hazelcast/src/test/java/com/hazelcast/client/executor/ExecutorServiceLiteMemberTest.java:79
↓ 25 callersMethodproduce
(String topic, Object key, Object value)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:180
↓ 25 callersMethodputAllAsync
Asynchronously copies all of the mappings from the specified map to this map. This version doesn't support batching. <pre>{@code CompletionStage<V
hazelcast/src/main/java/com/hazelcast/map/IMap.java:920
↓ 25 callersMethodputEntry
Inserts a new entry into this indexes instance or updates an existing one. <p> Consider using {@link #putEntry(CachedQueryEntry, CachedQueryEntry, Que
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:324
↓ 25 callersMethodrange
Returns list of integers from begin (inclusive) to end (exclusive).
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:498
↓ 25 callersMethodresolve
(ProtocolType protocolType, String identifier)
hazelcast/src/main/java/com/hazelcast/instance/EndpointQualifier.java:149
↓ 25 callersMethodresolveMetadata
( boolean isKey, List<MappingField> resolvedFields, Map<String, String> op
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataResolver.java:54
↓ 25 callersMethodreuseOrCreate
(RelMetadataQuery mq)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/metadata/HazelcastRelMetadataQuery.java:42
↓ 25 callersMethodrunWithNamespace
Obtains a {@link NodeEngine} reference from {@link NodeEngineThreadLocalContext} and uses it to call {@link UserCodeNamespaceService#runWithNamespace(
hazelcast/src/main/java/com/hazelcast/internal/namespace/NamespaceUtil.java:95
↓ 25 callersMethodsetBackupCount
Sets the number of synchronous backups. For example, if 1 is set as the backup count, then all entries of the map will be copied to another JVM for fa
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:320
↓ 25 callersMethodsetEnabled
@param enabled Enable or disable User Code Deployment. Default: {{@code false}} @return this for chaining
hazelcast/src/main/java/com/hazelcast/client/config/ClientUserCodeDeploymentConfig.java:65
↓ 25 callersMethodsetEnabled
Sets if Jet is enabled
hazelcast/src/main/java/com/hazelcast/jet/config/JetConfig.java:287
↓ 25 callersMethodsetInt64
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:241
↓ 25 callersMethodsetName
Sets the name of the {@link IMap} @param name the name to set for this {@link IMap}
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:210
↓ 25 callersMethodsetPortAutoIncrement
Sets if a Hazelcast member is allowed to find a free port by incrementing the port number when it encounters an occupied port. <p> If you explicitly w
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:170
↓ 25 callersMethodsetPosition
(@Nonnull String fieldName, @Nonnull FieldType fieldType)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/DefaultPortableWriter.java:390
↓ 25 callersMethodsetProperty
Sets a single property. See {@link DataConnectionConfig#setProperties(Properties)} @param key the property key @param value the property value @ret
hazelcast/src/main/java/com/hazelcast/config/DataConnectionConfig.java:170
↓ 25 callersMethodsetResponse
(byte[] value)
hazelcast/src/main/java/com/hazelcast/internal/ascii/memcache/SetCommand.java:61
↓ 25 callersMethodsize
Returns the number of elements in this {@link WriteBehindQueue}. @return the number of elements in this {@link WriteBehindQueue}.
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueue.java:85
↓ 25 callersMethodsocket
@see java.nio.channels.SocketChannel#socket() This method will be removed from the interface. Only an explicit cast to NioChannel will expose the Soc
hazelcast/src/main/java/com/hazelcast/internal/networking/Channel.java:130
↓ 25 callersMethodsql
(Object field, Object source)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ExtractFunctionIntegrationTest.java:455
↓ 25 callersMethodtoEventData
(Object obj)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:465
↓ 25 callersMethodtoJson
Returns the raw JSON string that this object wraps. You can use it if parsing is failing for some reason (for example on some untested DB-connector ve
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/RecordPart.java:90
↓ 25 callersMethodtoMember
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/MemberInfo.java:132
↓ 25 callersMethodunblockCommunicationBetween
(HazelcastInstance h1, HazelcastInstance h2)
hazelcast/src/test/java/com/hazelcast/test/SplitBrainTestSupport.java:391
↓ 25 callersMethodwithMetric
(String metric)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:94
↓ 24 callersMethodaddListenerConfig
Helper method to add a new ListenerConfig @param listenerConfig ListenerConfig @return configured {@link com.hazelcast.client.config.ClientConfig} fo
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:399
↓ 24 callersMethodaddSerializer
Registers the given Compact serializer. <p> For the class returned by the serializer's {@link CompactSerializer#getCompactClass()} method, Compact ser
hazelcast/src/main/java/com/hazelcast/config/CompactSerializationConfig.java:175
↓ 24 callersMethodagainst
(String... allowed)
hazelcast/src/test/java/com/hazelcast/security/permission/PermissionTestSupport.java:54
↓ 24 callersMethodapplyState
@param state state to be applied to operation after execution of all step chain
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/engine/StepAwareOperation.java:41
↓ 24 callersMethodassertCompletions
(TestObserver observer, int completions)
hazelcast/src/test/java/com/hazelcast/jet/core/ObservableResultsTest.java:620
↓ 24 callersMethodassertError
(TestObserver observer, String error)
hazelcast/src/test/java/com/hazelcast/jet/core/ObservableResultsTest.java:609
↓ 24 callersMethodcheckClasses
(Converter converter, Class<?>... classes)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:891
↓ 24 callersMethodcheckConverterConversions
(Converter converter, QueryDataTypeFamily... expectedSupportedConversions)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:931
↓ 24 callersMethodcheckFamily
(Converter converter, QueryDataTypeFamily expectedTypeFamily)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:898
↓ 24 callersMethodcheckId
(Converter converter, int id)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:886
↓ 24 callersMethodcheckLiteral
(String literal, String function, boolean expectedResult)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/IsTrueFalsePredicateIntegrationTest.java:208
↓ 24 callersMethodcheckPartitionArgumentIndex
(String sql, Integer expectedIndex, Object... arguments)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlClientTest.java:131
↓ 24 callersMethodcol
(String name, ColumnType type)
hazelcast/src/test/java/com/hazelcast/test/jdbc/TestDatabaseRecordProvider.java:102
↓ 24 callersMethodconsumeLong
Called when the Metric contains a {@code long} value. @param descriptor metric descriptor @param value metric value
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricConsumer.java:30
↓ 24 callersMethodcontains
(Object objectToCheck)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/OAHashSet.java:168
↓ 24 callersMethodcreateEntry
(Object key)
hazelcast/src/test/java/com/hazelcast/query/impl/CachedQueryEntryTest.java:235
↓ 24 callersMethoddecode
(byte[] buffer, int position)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListCNFixedSizeCodec.java:213
↓ 24 callersMethoddecodeParamsAndAuthenticate
(HttpPostCommand cmd, int expectedParamCount)
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpCommandProcessor.java:197
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/AtomicRefSetCodec.java:99
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPSessionCloseSessionCodec.java:87
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/AtomicLongAlterCodec.java:100
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/AtomicRefGetCodec.java:85
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/FencedLockTryLockCodec.java:121
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetSubmitJobCodec.java:101
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/TransactionalMapContainsValueCodec.java:101
↓ 24 callersMethoddecodeRequest
UUID of the unreachable CP member
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCRemoveCPMemberCodec.java:76
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPGroupDestroyCPObjectCodec.java:92
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetExportSnapshotCodec.java:89
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SemaphoreChangeCodec.java:114
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SemaphoreAcquireCodec.java:124
↓ 24 callersMethoddecodeRequest
The proxy name of this data structure instance
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPGroupCreateCPGroupCodec.java:74
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/SemaphoreAvailablePermitsCodec.java:86
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/CPSessionCreateSessionCodec.java:88
↓ 24 callersMethoddecodeRequest
New state of the cluster: 0 - ACTIVE 1 - NO_MIGRATION 2 - FROZEN 3 - PASSIVE 4 - IN_TRANSITION (not allowed)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/MCChangeClusterStateCodec.java:80
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetGetJobSubmissionTimeCodec.java:91
↓ 24 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetTerminateJobCodec.java:96
← previousnext →3,501–3,600 of 147,315, ranked by callers