Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/hazelcast/hazelcast
/ functions
Functions
147,315 in github.com/hazelcast/hazelcast
⨍
Functions
147,315
◇
Types & classes
15,944
↓ 13 callers
Method
createTable
(String[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlSortTest.java:288
↓ 13 callers
Method
createTasklet
(ProcessingGuarantee guarantee)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/ProcessorTaskletTest_Snapshots.java:399
↓ 13 callers
Method
createThreadPoolName
Creates the threadpool name with prefix and notation. @param hzName the name of the hazelcast instance @param poolName the name of the pool. @retur
hazelcast/src/main/java/com/hazelcast/internal/util/ThreadUtil.java:84
↓ 13 callers
Method
currentValue
@return current value of node-wide-used-capacity counter
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/NodeWideUsedCapacityCounter.java:99
↓ 13 callers
Method
database
Returns the name of the database containing the record's table. @return name of the source database for the current record
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/ChangeRecord.java:107
↓ 13 callers
Method
decodePointers
(List<Entry<Integer, Integer>> pointers)
hazelcast/src/main/java/com/hazelcast/internal/iteration/IterationPointer.java:86
↓ 13 callers
Method
decodeRequest
list of schemas
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendAllSchemasCodec.java:74
↓ 13 callers
Method
decodeRequest
Id of the schema to be fetched
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientFetchSchemaCodec.java:75
↓ 13 callers
Method
decodeRequest
schema to be send to the cluster
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendSchemaCodec.java:74
↓ 13 callers
Method
decodeResponse
schema with the given schema id fetched from the cluster
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientFetchSchemaCodec.java:94
↓ 13 callers
Method
decodeResponse
UUIDs of the members that the schema is replicated
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendSchemaCodec.java:94
↓ 13 callers
Method
delete
Ensures that the file described by the supplied parameter does not exist after the method returns. If the file didn't exist, returns silently. If the
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:526
↓ 13 callers
Method
demoteLocalDataMember
Demotes the local data member to a lite member. When this method returns, both {@link #getLocalMember()} and {@link #getMembers()} reflect the demotio
hazelcast/src/main/java/com/hazelcast/cluster/Cluster.java:128
↓ 13 callers
Method
disableGroups
Disables provided REST endpoint groups.
hazelcast/src/main/java/com/hazelcast/config/RestApiConfig.java:85
↓ 13 callers
Method
distributeTo
Declares that all items sent over this edge will be delivered to the specified member. Processors on other members will not receive any data. <p> This
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:529
↓ 13 callers
Method
drainAndAssert
(ProgressState expectedState, Object... expectedItems)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/ConcurrentInboundEdgeStream_OrderedDrainTest.java:133
↓ 13 callers
Method
drainQueueAndReset
Move all items from the queue to the {@code target} collection and make the outbox available to accept more items. Also calls {@link #reset()}. If you
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestOutbox.java:155
↓ 13 callers
Method
encode
(byte[] buffer, int position, T item)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListCNFixedSizeCodec.java:208
↓ 13 callers
Method
encodePointers
(IterationPointer[] pointers)
hazelcast/src/main/java/com/hazelcast/internal/iteration/IterationPointer.java:95
↓ 13 callers
Method
encodeRequest
(java.util.Collection<com.hazelcast.internal.serialization.impl.compact.Schema> schemas)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendAllSchemasCodec.java:59
↓ 13 callers
Method
encodeRequest
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetGetJobAndSqlSummaryListCodec.java:58
↓ 13 callers
Method
encodeRequest
(long schemaId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientFetchSchemaCodec.java:60
↓ 13 callers
Method
encodeRequest
(com.hazelcast.internal.serialization.impl.compact.Schema schema)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendSchemaCodec.java:59
↓ 13 callers
Method
encodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendAllSchemasCodec.java:81
↓ 13 callers
Method
encodeResponse
(java.util.List<com.hazelcast.jet.impl.JobAndSqlSummary> response)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetGetJobAndSqlSummaryListCodec.java:69
↓ 13 callers
Method
encodeResponse
(@Nullable com.hazelcast.internal.serialization.impl.compact.Schema schema)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientFetchSchemaCodec.java:81
↓ 13 callers
Method
encodeResponse
(java.util.Collection<java.util.UUID> replicatedMembers)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendSchemaCodec.java:81
↓ 13 callers
Method
ensureNoArguments
(String name, List<Object> arguments)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/SqlPlanImpl.java:1766
↓ 13 callers
Method
equals
(Object o)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/MainPortable.java:122
↓ 13 callers
Method
equals
(Object o)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientMessage.java:415
↓ 13 callers
Method
equals
(Object o)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:321
↓ 13 callers
Method
estimateAsync
Estimates the cardinality of the aggregation so far. If it was previously estimated and never invalidated, then a cached version is used. <p> This met
hazelcast/src/main/java/com/hazelcast/cardinality/CardinalityEstimator.java:136
↓ 13 callers
Method
exactNumeric
(Object value)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/LiteralTypeResolutionTest.java:128
↓ 13 callers
Method
exists
()
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/impl/CdcSourceP.java:526
↓ 13 callers
Method
extractArgumentsFromAttributeName
(String attributeNameWithArguments)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/ExtractorHelper.java:112
↓ 13 callers
Method
extractFields
(List<MappingField> fields, boolean isKey)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataResolver.java:61
↓ 13 callers
Method
fireLifecycleEvent
(LifecycleState lifecycleState)
hazelcast/src/main/java/com/hazelcast/instance/impl/LifecycleServiceImpl.java:65
↓ 13 callers
Method
flatMapper
Factory of {@link FlatMapper}. The {@code FlatMapper} will emit items to the given output ordinal.
hazelcast/src/main/java/com/hazelcast/jet/core/AbstractProcessor.java:488
↓ 13 callers
Method
getAndPut
Associates the specified value with the specified key in this cache using a custom {@link javax.cache.expiry.ExpiryPolicy}, returning an existing valu
hazelcast/src/main/java/com/hazelcast/cache/ICache.java:743
↓ 13 callers
Method
getAsBoolean
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/TranslateToPublicAddressProvider.java:182
↓ 13 callers
Method
getBackupProcessor
Get the entry processor to be applied to backup entries. <p> In case of a readonly execution, {@code null} can be returned to indicate that no backups
hazelcast/src/main/java/com/hazelcast/map/EntryProcessor.java:146
↓ 13 callers
Method
getBatchMaxDelayMillis
Returns the maximum amount of time in milliseconds to wait before sending a batch of events to target cluster, if {@link #getBatchSize()} of events ha
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:221
↓ 13 callers
Method
getByteOrder
Note that result of useNativeByteOrder is not reflected to return value of this method. @return configured byte order
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:433
↓ 13 callers
Method
getCacheEntryListeners
Gets a list of {@link CacheSimpleEntryListenerConfig} from this {@link com.hazelcast.cache.ICache}. @return list of {@link CacheSimpleEntryListenerCo
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:458
↓ 13 callers
Method
getCallerAddress
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operation.java:440
↓ 13 callers
Method
getClassName
()
hazelcast/src/main/java/com/hazelcast/config/LoginModuleConfig.java:75
↓ 13 callers
Method
getClientConfigForRemoteCluster
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineTestSupport.java:224
↓ 13 callers
Method
getClientEngine
()
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:88
↓ 13 callers
Method
getClientJetService
()
hazelcast/src/test/java/com/hazelcast/jet/impl/submitjob/clientside/upload/JobUploadClientFailureTest.java:398
↓ 13 callers
Method
getCompiledJARName
Not possible to name the files in a sensible way on creation - because the `maven-assembly-plugin` will always insert the name of the "main" JAR into
hazelcast/src/test/java/com/hazelcast/test/UserCodeUtil.java:52
↓ 13 callers
Method
getConfig
()
hazelcast/src/test/java/com/hazelcast/wan/WanRESTTest.java:197
↓ 13 callers
Method
getCost
Returns heap cost of this record in bytes. @return heap cost of this record in bytes.
hazelcast/src/main/java/com/hazelcast/map/impl/record/Record.java:47
↓ 13 callers
Method
getDecimal
@param fieldName the name of the field @return decimal which is arbitrary precision and scale floating-point number as {@link BigDecimal} @throws Haze
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecord.java:269
↓ 13 callers
Method
getDestOrdinal
Returns the ordinal of the edge at the destination vertex.
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:225
↓ 13 callers
Method
getDestinationAddress
()
hazelcast/src/main/java/com/hazelcast/internal/partition/MigrationInfo.java:111
↓ 13 callers
Method
getDestinationNewReplicaIndex
()
hazelcast/src/main/java/com/hazelcast/internal/partition/MigrationInfo.java:131
↓ 13 callers
Method
getDiscoveryPeriodSeconds
Returns the period in seconds in which WAN tries to discover new target endpoints and reestablish connections to failed endpoints. @return period for
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:425
↓ 13 callers
Method
getDurableExecutorConfig
Returns the DurableExecutorConfig for the given name, creating one if necessary and adding it to the collection of known configurations. <p> The confi
hazelcast/src/main/java/com/hazelcast/config/Config.java:1961
↓ 13 callers
Method
getEdgeSources
(EdgeDef edge)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/DagNodeUtil.java:173
↓ 13 callers
Method
getFileName
Returns the name of the file which will contain the tracking metadata. If {@code null}, {@link InstanceTrackingConfig#DEFAULT_FILE} is used instead. <
hazelcast/src/main/java/com/hazelcast/config/InstanceTrackingConfig.java:102
↓ 13 callers
Method
getFunctionClassName
()
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfig.java:165
↓ 13 callers
Method
getGlobalTransactionId
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/xa/SerializableXID.java:49
↓ 13 callers
Method
getHazelcastInstance
Returns the HazelcastInstance that this {@link NodeEngine} belongs to. @return the HazelcastInstance
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:270
↓ 13 callers
Method
getInitialLoadMode
Returns the initial load mode. @return the initial load mode object
hazelcast/src/main/java/com/hazelcast/config/MapStoreConfig.java:325
↓ 13 callers
Method
getInternalService
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/SqlServiceImpl.java:149
↓ 13 callers
Method
getIterable
( IMap<K, V> map, int fetchSize, Projection<Entry<K, V>, R> projection,
hazelcast/src/test/java/com/hazelcast/map/AbstractMapQueryIterableTest.java:53
↓ 13 callers
Method
getJaasAuthenticationConfig
()
hazelcast/src/main/java/com/hazelcast/config/security/RealmConfig.java:42
↓ 13 callers
Method
getLevelOfNode
Returns the level a node with the given {@code order} is on in the tree @param nodeOrder The breadth-first order of a node for which its level
hazelcast/src/main/java/com/hazelcast/wan/impl/merkletree/MerkleTreeUtil.java:173
↓ 13 callers
Method
getLicenseKey
Returns the license key for this hazelcast instance. The license key is used to enable enterprise features. @return the license key @throws SecurityE
hazelcast/src/main/java/com/hazelcast/config/Config.java:2912
↓ 13 callers
Method
getList
()
hazelcast/src/main/java/com/hazelcast/client/console/ClientConsoleApp.java:190
↓ 13 callers
Method
getLog
()
hazelcast/src/test/java/com/hazelcast/internal/json/JsonParser_Test.java:844
↓ 13 callers
Method
getLongValue
(final String parameterName, final String value)
hazelcast/src/main/java/com/hazelcast/internal/config/DomConfigHelper.java:165
↓ 13 callers
Method
getMaxTargetEndpoints
Returns the maximum number of endpoints that WAN will connect to when using a discovery mechanism to define endpoints. This property has no effect whe
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:449
↓ 13 callers
Method
getName
@return the name of this queue
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:252
↓ 13 callers
Method
getNamespace
()
hazelcast/src/test/java/com/hazelcast/journal/EventJournalDataStructureAdapter.java:41
↓ 13 callers
Method
getNamespacesConfig
()
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigurationAwareConfig.java:1329
↓ 13 callers
Method
getNewState
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterStateChange.java:48
↓ 13 callers
Method
getNode
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/TestUtil.java:148
↓ 13 callers
Method
getNode
()
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngineImpl.java:527
↓ 13 callers
Method
getNodeHash
Returns the hash for the node with the given {@code nodeOrder} @param nodeOrder The order of the node @return the hash of the node
hazelcast/src/main/java/com/hazelcast/wan/impl/merkletree/MerkleTreeView.java:29
↓ 13 callers
Method
getObjectNamespace
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/MapService.java:321
↓ 13 callers
Method
getOrCreateRecordStore
Gets or creates a cache record store with the prefixed {@code cacheNameWithPrefix} and partition ID. @param cacheNameWithPrefix the full name of the
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheService.java:65
↓ 13 callers
Method
getPNCounterConfig
Returns the {@link PNCounterConfig} for the given name, creating one if necessary and adding it to the collection of known configurations. <p> The con
hazelcast/src/main/java/com/hazelcast/config/Config.java:2060
↓ 13 callers
Method
getPartition
Returns the {@link IPartition} for a given partition ID. <p> If the owner of the partition is not set yet, it will trigger partition assignment. <p> T
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartitionService.java:76
↓ 13 callers
Method
getPatch
()
hazelcast/src/main/java/com/hazelcast/version/MemberVersion.java:92
↓ 13 callers
Method
getPeriodMillis
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/MetricsPlugin.java:81
↓ 13 callers
Method
getPrefixedName
Returns the unique prefixed name for this DistributedObject. The returned value will never be null. @return the unique prefixed name for this object.
hazelcast/src/main/java/com/hazelcast/core/PrefixedDistributedObject.java:31
↓ 13 callers
Method
getPrimaryAddress
()
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/LinkedAddresses.java:49
↓ 13 callers
Method
getProducer
Returns an instance of {@link KafkaProducer} based on the DataConnection configuration. <p> The caller is responsible for closing the producer instanc
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/KafkaDataConnection.java:146
↓ 13 callers
Method
getQueueConfigs
Returns all registered queue configurations. @return registered queue configurations
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:276
↓ 13 callers
Method
getReadOnlyConfig
()
hazelcast/src/test/java/com/hazelcast/config/NearCacheConfigReadOnlyTest.java:31
↓ 13 callers
Method
getRecord
(Data key)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:238
↓ 13 callers
Method
getReplicatedMapConfigs
Returns all registered replicated map configurations. @return registered replicated map configurations
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:304
↓ 13 callers
Method
getResourceVersion
Returns the last resource version specified via {@link #addStatefulSetInfo}.
hazelcast/src/main/java/com/hazelcast/kubernetes/RuntimeContext.java:214
↓ 13 callers
Method
getResponseTimeoutMillis
Returns the duration in milliseconds for the wait time before retrying to send the events to target cluster again in case the acknowledgement has not
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:245
↓ 13 callers
Method
getSchedulerName
()
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/operations/AbstractSchedulerOperation.java:45
↓ 13 callers
Method
getSerializationService
()
hazelcast/src/main/java/com/hazelcast/instance/impl/Node.java:462
↓ 13 callers
Method
getServer
()
hazelcast/src/main/java/com/hazelcast/instance/impl/Node.java:778
↓ 13 callers
Method
getServiceName
Name of the service @return name of the service
hazelcast/src/main/java/com/hazelcast/internal/services/ServiceNamespace.java:32
↓ 13 callers
Method
getSet
()
hazelcast/src/main/java/com/hazelcast/console/ConsoleApp.java:131
← previous
next →
5,601–5,700 of 147,315, ranked by callers