MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 10 callersMethodcreateKafkaDataConnection
(KafkaTestSupport kafkaTestSupport)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/KafkaDataConnectionTest.java:232
↓ 10 callersMethodcreateManagedNearCacheRecordStore
( Map<Integer, String> expectedKeyValueMappings)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestSupport.java:80
↓ 10 callersMethodcreateMapWithMaxIdleSeconds
(int maxIdleSeconds)
hazelcast/src/test/java/com/hazelcast/map/ExpirationTimeTest.java:693
↓ 10 callersMethodcreateNearCache
(String name, NearCacheConfig nearCacheConfig,
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestSupport.java:65
↓ 10 callersMethodcreateNodes
()
hazelcast/src/test/java/com/hazelcast/client/listeners/leak/ListenerLeakTest.java:96
↓ 10 callersMethodcreateOperation
(String host, int port, long callId)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/LiveOperationRegistryTest.java:104
↓ 10 callersMethodcreateOperation
(String host, int port, long callId)
hazelcast/src/test/java/com/hazelcast/jet/impl/LiveOperationRegistryTest.java:104
↓ 10 callersMethodcreateQueue
(SqsClient sqsClient)
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/KafkaConnectSQSIT.java:173
↓ 10 callersMethodcreateScheduledFutureMock
()
hazelcast/src/test/java/com/hazelcast/scheduledexecutor/impl/DelegatingScheduledFutureStripperTest.java:199
↓ 10 callersMethodcreateSerializationService
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactWithSchemaStreamSerializerTest.java:137
↓ 10 callersMethodcreateSerializationService
(int version)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/PortableTest.java:124
↓ 10 callersMethodcreateTasklet
()
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/ProcessorTaskletTest.java:267
↓ 10 callersMethodcreateTranslateProvider
()
hazelcast/src/test/java/com/hazelcast/client/impl/spi/impl/TranslateToPublicAddressProviderTest.java:216
↓ 10 callersMethodcreateType
(String name, String... fields)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/BasicNestedFieldsTest.java:98
↓ 10 callersMethodcreateWithPartitionCount
(int partitionCount, int... partitions)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/PartitionIdSetTest.java:314
↓ 10 callersMethodcreateWithSSL
(String url, String caCertificate)
hazelcast/src/main/java/com/hazelcast/spi/utils/RestClient.java:129
↓ 10 callersMethoddataConnectionService
A service to access {@link DataConnection}s in processors. @since 5.3
hazelcast/src/main/java/com/hazelcast/jet/core/ProcessorMetaSupplier.java:928
↓ 10 callersMethoddate
(long epochMillis)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:758
↓ 10 callersMethoddecode
(ClientMessage.ForwardFrameIterator iterator)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListIntegerIntegerCodec.java:51
↓ 10 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUploadJobMetaDataCodec.java:122
↓ 10 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetAddJobStatusListenerCodec.java:103
↓ 10 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUpdateJobConfigCodec.java:84
↓ 10 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetIsJobUserCancelledCodec.java:74
↓ 10 callersMethoddecodeRequest
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUploadJobMultipartCodec.java:112
↓ 10 callersMethoddecodeResponse
(ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapFetchEntryViewsCodec.java:149
↓ 10 callersMethodderegisterListener
Deregisters a listener with the given registration ID. @param serviceName service name @param topic topic name @param id registration
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/EventService.java:154
↓ 10 callersMethoddestroy
Destroys this object cluster-wide. Clears and releases all resources for this object.
hazelcast/src/main/java/com/hazelcast/core/DistributedObject.java:79
↓ 10 callersMethoddestroyDistributedObject
Destroys a distributed object. @param objectName the name of the distributed object to destroy
hazelcast/src/main/java/com/hazelcast/internal/services/RemoteService.java:49
↓ 10 callersMethoddestroyIndexes
Destroys and then removes all the indexes from this indexes instance.
hazelcast/src/main/java/com/hazelcast/query/impl/IndexRegistry.java:267
↓ 10 callersMethoddisconnect
(V v1, V v2)
hazelcast/src/main/java/com/hazelcast/internal/util/graph/Graph.java:55
↓ 10 callersMethoddiscriminator
Returns the discriminator tag's name of the metric denoted by this instance. Used to distinguish metrics that have the same {@link #prefix()} and {@li
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:83
↓ 10 callersMethoddivideExact
Divides the left-hand side operand by the right-hand side operand. <p> Unlike the regular Java division operator, throws an exception if division resu
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/math/ExpressionMath.java:46
↓ 10 callersMethoddoSomeWorkWithXa
(HazelcastXAResource xaResource)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientXACompatibilityTest.java:188
↓ 10 callersMethoddoTest
(List<Object> input, List<Object> expectedOutput)
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/InsertWatermarksPTest.java:280
↓ 10 callersMethodencode
(ClientMessage clientMessage, Collection<Map.Entry<Integer, Integer>> collection)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/EntryListIntegerIntegerCodec.java:39
↓ 10 callersMethodencodeRequest
(java.lang.String name, java.util.UUID cursorId, boolean newIteration, int partitionId, int batchSize)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ReplicatedMapFetchEntryViewsCodec.java:97
↓ 10 callersMethodencodeResponse
(@Nullable java.util.UUID response)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetAddJobStatusListenerCodec.java:113
↓ 10 callersMethodencodeResponse
(com.hazelcast.internal.serialization.Data updatedConfig)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetUpdateJobConfigCodec.java:93
↓ 10 callersMethodencodeResponse
(boolean response)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetIsJobUserCancelledCodec.java:80
↓ 10 callersMethodentryValue
Returns a function that extracts the value of a {@link Entry}. @param <V> type of entry's value
hazelcast/src/main/java/com/hazelcast/function/Functions.java:57
↓ 10 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/cache/impl/wan/WanCacheEntryView.java:159
↓ 10 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/internal/nio/Packet.java:229
↓ 10 callersMethodequals
(Object obj)
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:632
↓ 10 callersMethodexceptionally
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:809
↓ 10 callersMethodexecute
(String sql, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/SqlUpdateTest.java:317
↓ 10 callersMethodexecuteOnKeyOwner
Executes a task on the owner of the specified key. @param command a task executed on the owner of the specified key @param key the specified key
hazelcast/src/main/java/com/hazelcast/core/IExecutorService.java:62
↓ 10 callersMethodexists
()
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheEntryProcessorEntry.java:72
↓ 10 callersMethodextractPrunability
(RelNode rel, RelMetadataQuery mq)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/metadata/HazelcastRelMdPrunability.java:199
↓ 10 callersMethodfieldOperations
(FieldKind fieldKind)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/FieldOperations.java:1129
↓ 10 callersMethodfieldWithSameExternal
(String name, QueryDataType type, BsonType externalType)
extensions/mongodb/src/test/java/com/hazelcast/jet/sql/impl/connector/mongodb/FieldResolverTest.java:208
↓ 10 callersMethodfields
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/map/Metadata.java:46
↓ 10 callersMethodfindPNCounterConfig
Finds existing PN counter config. @param name name of the config @return PN counter config or {@code null} when requested PN counter configuration do
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:174
↓ 10 callersMethodfindReplicatedMapConfig
Finds existing ReplicatedMap config. @param name name of the config @return ReplicatedMap config or {@code null} when requested ReplicatedMap configu
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:238
↓ 10 callersMethodfloorFrameTs
Returns the highest frame timestamp less than or equal to the given timestamp. If there is no such {@code long} value, returns {@code Long.MIN_VALUE}.
hazelcast/src/main/java/com/hazelcast/jet/core/SlidingWindowPolicy.java:107
↓ 10 callersMethodformatPublic
(List<Endpoint> addresses)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesClientTest.java:968
↓ 10 callersMethodfreeMemory
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/metricsets/RuntimeMetricSetTest.java:63
↓ 10 callersMethodfromEpochMillis
(final Long timestamp)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToEpochMillisIntegrationTest.java:121
↓ 10 callersMethodgenerateAndUploadObjects
(String bucketName, String prefix, int objectCount, int lineCount)
extensions/s3/src/test/java/com/hazelcast/jet/s3/S3MockTest.java:257
↓ 10 callersMethodgenerateEntries
(int count)
hazelcast/src/test/java/com/hazelcast/query/impl/AndResultSetTest.java:182
↓ 10 callersMethodget
(Metric metric)
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/PhoneHomeDifferentConfigTest.java:61
↓ 10 callersMethodget
(Object name)
hazelcast/src/main/java/com/hazelcast/internal/json/JsonObject.java:871
↓ 10 callersMethodget
Returns all {@link Measurement}s associated with a given metric name. <p> For a list of job-specific metric names please see {@link MetricNames}.
hazelcast/src/main/java/com/hazelcast/jet/core/metrics/JobMetrics.java:98
↓ 10 callersMethodget1
Returns the first value.
hazelcast/src/main/java/com/hazelcast/jet/accumulator/LongLongAccumulator.java:46
↓ 10 callersMethodgetAddress
()
hazelcast/src/main/java/com/hazelcast/internal/util/AddressUtil.java:514
↓ 10 callersMethodgetAddressMatcher
Gets an AddressMatcher for a given addresses. @param address the address @return the returned AddressMatcher. The returned value will never be null.
hazelcast/src/main/java/com/hazelcast/internal/util/AddressUtil.java:307
↓ 10 callersMethodgetAge
()
hazelcast/src/test/java/com/hazelcast/map/MapListenerTest.java:180
↓ 10 callersMethodgetAllowedFutureMillis
@see #setAllowedFutureMillis(long)
hazelcast/src/main/java/com/hazelcast/config/FlakeIdGeneratorConfig.java:278
↓ 10 callersMethodgetAsyncBackupCount
Returns the asynchronous backup count for this {@link IMap}. @return the asynchronous backup count @see #setBackupCount(int)
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:296
↓ 10 callersMethodgetAsyncBackupCount
Gets the number of asynchronous backups. @return the number of asynchronous backups
hazelcast/src/main/java/com/hazelcast/config/RingbufferConfig.java:208
↓ 10 callersMethodgetAutoOffFuture
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:621
↓ 10 callersMethodgetBackupCount
Gets the number of synchronous backups. @return number of synchronous backups
hazelcast/src/main/java/com/hazelcast/config/RingbufferConfig.java:183
↓ 10 callersMethodgetBackupMap
Return the map containing queue items when this instance is a backup replica. The map contains both items that are parts of different transactions and
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueContainer.java:996
↓ 10 callersMethodgetBaseDir
Base directory for this device. Can be an absolute or relative path to the node startup directory.
hazelcast/src/main/java/com/hazelcast/config/LocalDeviceConfig.java:109
↓ 10 callersMethodgetCPMemberCount
Returns the number of CP members that will initialize CP Subsystem. CP Subsystem is disabled if it is 0. @return the number of CP members that will i
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:373
↓ 10 callersMethodgetCacheEventHandler
()
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheService.java:842
↓ 10 callersMethodgetCacheManager
(URI uri, ClassLoader classLoader, Properties properties)
hazelcast/src/main/java/com/hazelcast/client/cache/HazelcastClientCachingProvider.java:61
↓ 10 callersMethodgetCallTimeout
Gets the call timeout in milliseconds. For example, if a call should start execution within 60 seconds, or it should be aborted otherwise, then the ca
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operation.java:526
↓ 10 callersMethodgetClassName
()
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:1051
↓ 10 callersMethodgetClassName
()
hazelcast/src/main/java/com/hazelcast/config/DiscoveryStrategyConfig.java:86
↓ 10 callersMethodgetClientEventRegistrations
(HazelcastInstance client, UUID id)
hazelcast/src/test/java/com/hazelcast/client/listeners/leak/ListenerLeakTest.java:115
↓ 10 callersMethodgetClientPermissionConfigs
Returns latest client permission configuration.
hazelcast/src/main/java/com/hazelcast/security/SecurityService.java:37
↓ 10 callersMethodgetCloseCause
Gets the cause this Connection was closed. Can be null if no cause was given or if the connection is still active. It is purely meant for debugging to
hazelcast/src/main/java/com/hazelcast/internal/nio/Connection.java:203
↓ 10 callersMethodgetCloudConfig
()
hazelcast/src/main/java/com/hazelcast/client/config/ClientNetworkConfig.java:440
↓ 10 callersMethodgetClusterId
@return cluster's uuid
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientClusterService.java:111
↓ 10 callersMethodgetClusterStateManager
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:1023
↓ 10 callersMethodgetCollection
()
hazelcast/src/main/java/com/hazelcast/multimap/impl/operations/MultiMapResponse.java:57
↓ 10 callersMethodgetConfig
()
hazelcast/src/test/java/com/hazelcast/internal/partition/PartitionServiceSafetyCheckTest.java:58
↓ 10 callersMethodgetConfig
()
hazelcast/src/test/java/com/hazelcast/internal/eviction/MapExpirationManagerTest.java:58
↓ 10 callersMethodgetConfig
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:194
↓ 10 callersMethodgetConfigurationFile
Returns the {@link File} to the declarative configuration, which has been parsed to create this {@link Config} instance. @return the configuration fi
hazelcast/src/main/java/com/hazelcast/config/Config.java:2886
↓ 10 callersMethodgetConflictingSchemas
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/Table.java:105
↓ 10 callersMethodgetConnectionType
Returns the connection type. <p> See {@link com.hazelcast.internal.nio.ConnectionType} for in-house candidates. Note that a type could be provided by
hazelcast/src/main/java/com/hazelcast/internal/server/ServerConnection.java:42
↓ 10 callersMethodgetContainers
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferService.java:131
↓ 10 callersMethodgetCreatedInstancesShuffledAfterWarmedUp
()
hazelcast/src/test/java/com/hazelcast/partition/AbstractPartitionLostListenerTest.java:110
↓ 10 callersMethodgetCreationTime
Gets the cache creation time. @return the cache creation time
hazelcast/src/main/java/com/hazelcast/cache/CacheStatistics.java:47
↓ 10 callersMethodgetCursorId
()
hazelcast/src/main/java/com/hazelcast/internal/iteration/IterationResult.java:39
↓ 10 callersMethodgetDistributedTo
Note: unlike {@link Edge#getDistributedTo()}, this method always returns null if the DAG is about to be run on a single member. See {@linkplain #EdgeD
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/EdgeDef.java:119
↓ 10 callersMethodgetDriver
()
hazelcast/src/test/java/com/hazelcast/executor/AbstractExecutorNullTest.java:180
↓ 10 callersMethodgetDurability
Gets the transaction durability. @return the transaction durability. @see #setDurability(int)
hazelcast/src/main/java/com/hazelcast/transaction/TransactionOptions.java:128
↓ 10 callersMethodgetEnabled
Returns if the merkle tree is enabled. @return {@code TRUE} if the merkle tree is enabled, {@code FALSE} if disabled or {@code null} if user
hazelcast/src/main/java/com/hazelcast/config/MerkleTreeConfig.java:144
← previousnext →6,601–6,700 of 147,315, ranked by callers