MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 13 callersMethodcreateTable
(String[]... values)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlSortTest.java:288
↓ 13 callersMethodcreateTasklet
(ProcessingGuarantee guarantee)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/ProcessorTaskletTest_Snapshots.java:399
↓ 13 callersMethodcreateThreadPoolName
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 callersMethodcurrentValue
@return current value of node-wide-used-capacity counter
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/NodeWideUsedCapacityCounter.java:99
↓ 13 callersMethoddatabase
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 callersMethoddecodePointers
(List<Entry<Integer, Integer>> pointers)
hazelcast/src/main/java/com/hazelcast/internal/iteration/IterationPointer.java:86
↓ 13 callersMethoddecodeRequest
list of schemas
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendAllSchemasCodec.java:74
↓ 13 callersMethoddecodeRequest
Id of the schema to be fetched
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientFetchSchemaCodec.java:75
↓ 13 callersMethoddecodeRequest
schema to be send to the cluster
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendSchemaCodec.java:74
↓ 13 callersMethoddecodeResponse
schema with the given schema id fetched from the cluster
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientFetchSchemaCodec.java:94
↓ 13 callersMethoddecodeResponse
UUIDs of the members that the schema is replicated
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendSchemaCodec.java:94
↓ 13 callersMethoddelete
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 callersMethoddemoteLocalDataMember
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 callersMethoddisableGroups
Disables provided REST endpoint groups.
hazelcast/src/main/java/com/hazelcast/config/RestApiConfig.java:85
↓ 13 callersMethoddistributeTo
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 callersMethoddrainAndAssert
(ProgressState expectedState, Object... expectedItems)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/ConcurrentInboundEdgeStream_OrderedDrainTest.java:133
↓ 13 callersMethoddrainQueueAndReset
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 callersMethodencode
(byte[] buffer, int position, T item)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/builtin/ListCNFixedSizeCodec.java:208
↓ 13 callersMethodencodePointers
(IterationPointer[] pointers)
hazelcast/src/main/java/com/hazelcast/internal/iteration/IterationPointer.java:95
↓ 13 callersMethodencodeRequest
(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 callersMethodencodeRequest
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetGetJobAndSqlSummaryListCodec.java:58
↓ 13 callersMethodencodeRequest
(long schemaId)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientFetchSchemaCodec.java:60
↓ 13 callersMethodencodeRequest
(com.hazelcast.internal.serialization.impl.compact.Schema schema)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendSchemaCodec.java:59
↓ 13 callersMethodencodeResponse
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendAllSchemasCodec.java:81
↓ 13 callersMethodencodeResponse
(java.util.List<com.hazelcast.jet.impl.JobAndSqlSummary> response)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/JetGetJobAndSqlSummaryListCodec.java:69
↓ 13 callersMethodencodeResponse
(@Nullable com.hazelcast.internal.serialization.impl.compact.Schema schema)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientFetchSchemaCodec.java:81
↓ 13 callersMethodencodeResponse
(java.util.Collection<java.util.UUID> replicatedMembers)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/codec/ClientSendSchemaCodec.java:81
↓ 13 callersMethodensureNoArguments
(String name, List<Object> arguments)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/SqlPlanImpl.java:1766
↓ 13 callersMethodequals
(Object o)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/portable/MainPortable.java:122
↓ 13 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientMessage.java:415
↓ 13 callersMethodequals
(Object o)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:321
↓ 13 callersMethodestimateAsync
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 callersMethodexactNumeric
(Object value)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/LiteralTypeResolutionTest.java:128
↓ 13 callersMethodexists
()
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/impl/CdcSourceP.java:526
↓ 13 callersMethodextractArgumentsFromAttributeName
(String attributeNameWithArguments)
hazelcast/src/main/java/com/hazelcast/query/impl/getters/ExtractorHelper.java:112
↓ 13 callersMethodextractFields
(List<MappingField> fields, boolean isKey)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvMetadataResolver.java:61
↓ 13 callersMethodfireLifecycleEvent
(LifecycleState lifecycleState)
hazelcast/src/main/java/com/hazelcast/instance/impl/LifecycleServiceImpl.java:65
↓ 13 callersMethodflatMapper
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 callersMethodgetAndPut
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 callersMethodgetAsBoolean
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/TranslateToPublicAddressProvider.java:182
↓ 13 callersMethodgetBackupProcessor
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 callersMethodgetBatchMaxDelayMillis
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 callersMethodgetByteOrder
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 callersMethodgetCacheEntryListeners
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 callersMethodgetCallerAddress
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operation.java:440
↓ 13 callersMethodgetClassName
()
hazelcast/src/main/java/com/hazelcast/config/LoginModuleConfig.java:75
↓ 13 callersMethodgetClientConfigForRemoteCluster
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineTestSupport.java:224
↓ 13 callersMethodgetClientEngine
()
hazelcast/src/main/java/com/hazelcast/internal/server/ServerContext.java:88
↓ 13 callersMethodgetClientJetService
()
hazelcast/src/test/java/com/hazelcast/jet/impl/submitjob/clientside/upload/JobUploadClientFailureTest.java:398
↓ 13 callersMethodgetCompiledJARName
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 callersMethodgetConfig
()
hazelcast/src/test/java/com/hazelcast/wan/WanRESTTest.java:197
↓ 13 callersMethodgetCost
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 callersMethodgetDecimal
@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 callersMethodgetDestOrdinal
Returns the ordinal of the edge at the destination vertex.
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:225
↓ 13 callersMethodgetDestinationAddress
()
hazelcast/src/main/java/com/hazelcast/internal/partition/MigrationInfo.java:111
↓ 13 callersMethodgetDestinationNewReplicaIndex
()
hazelcast/src/main/java/com/hazelcast/internal/partition/MigrationInfo.java:131
↓ 13 callersMethodgetDiscoveryPeriodSeconds
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 callersMethodgetDurableExecutorConfig
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 callersMethodgetEdgeSources
(EdgeDef edge)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/DagNodeUtil.java:173
↓ 13 callersMethodgetFileName
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 callersMethodgetFunctionClassName
()
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfig.java:165
↓ 13 callersMethodgetGlobalTransactionId
()
hazelcast/src/main/java/com/hazelcast/transaction/impl/xa/SerializableXID.java:49
↓ 13 callersMethodgetHazelcastInstance
Returns the HazelcastInstance that this {@link NodeEngine} belongs to. @return the HazelcastInstance
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:270
↓ 13 callersMethodgetInitialLoadMode
Returns the initial load mode. @return the initial load mode object
hazelcast/src/main/java/com/hazelcast/config/MapStoreConfig.java:325
↓ 13 callersMethodgetInternalService
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/SqlServiceImpl.java:149
↓ 13 callersMethodgetIterable
( IMap<K, V> map, int fetchSize, Projection<Entry<K, V>, R> projection,
hazelcast/src/test/java/com/hazelcast/map/AbstractMapQueryIterableTest.java:53
↓ 13 callersMethodgetJaasAuthenticationConfig
()
hazelcast/src/main/java/com/hazelcast/config/security/RealmConfig.java:42
↓ 13 callersMethodgetLevelOfNode
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 callersMethodgetLicenseKey
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 callersMethodgetList
()
hazelcast/src/main/java/com/hazelcast/client/console/ClientConsoleApp.java:190
↓ 13 callersMethodgetLog
()
hazelcast/src/test/java/com/hazelcast/internal/json/JsonParser_Test.java:844
↓ 13 callersMethodgetLongValue
(final String parameterName, final String value)
hazelcast/src/main/java/com/hazelcast/internal/config/DomConfigHelper.java:165
↓ 13 callersMethodgetMaxTargetEndpoints
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 callersMethodgetName
@return the name of this queue
hazelcast/src/main/java/com/hazelcast/config/QueueConfig.java:252
↓ 13 callersMethodgetNamespace
()
hazelcast/src/test/java/com/hazelcast/journal/EventJournalDataStructureAdapter.java:41
↓ 13 callersMethodgetNamespacesConfig
()
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/DynamicConfigurationAwareConfig.java:1329
↓ 13 callersMethodgetNewState
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterStateChange.java:48
↓ 13 callersMethodgetNode
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/TestUtil.java:148
↓ 13 callersMethodgetNode
()
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngineImpl.java:527
↓ 13 callersMethodgetNodeHash
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 callersMethodgetObjectNamespace
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/MapService.java:321
↓ 13 callersMethodgetOrCreateRecordStore
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 callersMethodgetPNCounterConfig
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 callersMethodgetPartition
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 callersMethodgetPatch
()
hazelcast/src/main/java/com/hazelcast/version/MemberVersion.java:92
↓ 13 callersMethodgetPeriodMillis
()
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/MetricsPlugin.java:81
↓ 13 callersMethodgetPrefixedName
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 callersMethodgetPrimaryAddress
()
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/LinkedAddresses.java:49
↓ 13 callersMethodgetProducer
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 callersMethodgetQueueConfigs
Returns all registered queue configurations. @return registered queue configurations
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:276
↓ 13 callersMethodgetReadOnlyConfig
()
hazelcast/src/test/java/com/hazelcast/config/NearCacheConfigReadOnlyTest.java:31
↓ 13 callersMethodgetRecord
(Data key)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:238
↓ 13 callersMethodgetReplicatedMapConfigs
Returns all registered replicated map configurations. @return registered replicated map configurations
hazelcast/src/main/java/com/hazelcast/internal/dynamicconfig/ConfigurationService.java:304
↓ 13 callersMethodgetResourceVersion
Returns the last resource version specified via {@link #addStatefulSetInfo}.
hazelcast/src/main/java/com/hazelcast/kubernetes/RuntimeContext.java:214
↓ 13 callersMethodgetResponseTimeoutMillis
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 callersMethodgetSchedulerName
()
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/operations/AbstractSchedulerOperation.java:45
↓ 13 callersMethodgetSerializationService
()
hazelcast/src/main/java/com/hazelcast/instance/impl/Node.java:462
↓ 13 callersMethodgetServer
()
hazelcast/src/main/java/com/hazelcast/instance/impl/Node.java:778
↓ 13 callersMethodgetServiceName
Name of the service @return name of the service
hazelcast/src/main/java/com/hazelcast/internal/services/ServiceNamespace.java:32
↓ 13 callersMethodgetSet
()
hazelcast/src/main/java/com/hazelcast/console/ConsoleApp.java:131
← previousnext →5,601–5,700 of 147,315, ranked by callers