MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 6 callersMethodsetJobParameters
(List<String> jobParameters)
hazelcast/src/main/java/com/hazelcast/jet/impl/SubmitJobParameters.java:125
↓ 6 callersMethodsetLicenseKey
Sets the license key for this hazelcast instance. The license key is used to enable enterprise features. @param licenseKey the license key @return th
hazelcast/src/main/java/com/hazelcast/config/Config.java:2927
↓ 6 callersMethodsetLoopbackModeEnabled
Explicitly enables or disables the loopback mode in the multicast discovery mechanism. @param enabled {@code true} to enable the loopback mode, {@cod
hazelcast/src/main/java/com/hazelcast/config/MulticastConfig.java:274
↓ 6 callersMethodsetMainClass
(String mainClass)
hazelcast/src/main/java/com/hazelcast/jet/impl/SubmitJobParameters.java:116
↓ 6 callersMethodsetMigrationInterceptor
(MigrationInterceptor interceptor)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:134
↓ 6 callersMethodsetMulticastPort
Sets the multicast port. @param multicastPort the multicastPort to set @return the updated MulticastConfig @throws IllegalArgumentException if multic
hazelcast/src/main/java/com/hazelcast/config/MulticastConfig.java:136
↓ 6 callersMethodsetName
Sets the WAN replication reference name. @param name the reference name @return this config
hazelcast/src/main/java/com/hazelcast/config/WanReplicationRef.java:81
↓ 6 callersMethodsetName
Sets the name of the configuration. @throws NullPointerException if the {@code name} is null
hazelcast/src/main/java/com/hazelcast/config/cp/CPMapConfig.java:168
↓ 6 callersMethodsetNodeFilterClass
(@Nonnull String nodeFilterClass)
hazelcast/src/main/java/com/hazelcast/config/DiscoveryConfig.java:89
↓ 6 callersMethodsetNullToValue
(List<String> list, String value)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcWhiteBlackListIntegrationTest.java:425
↓ 6 callersMethodsetNullToValue
(List<String> list, String value)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcWhiteBlackListIntegrationTest.java:428
↓ 6 callersMethodsetObjectType
(ObjectType objectType)
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/RestCallExecution.java:53
↓ 6 callersMethodsetOperationResponseHandler
(Operation op)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationRunnerImpl.java:531
↓ 6 callersMethodsetOwnedEntryMemoryCost
(long ownedEntryMemoryCost)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/LocalMapStatsImpl.java:242
↓ 6 callersMethodsetParallelMode
Set the ICMP detector to run in parallel mode, independent from the other failure detectors. If set to false (default) then the detector runs in legac
hazelcast/src/main/java/com/hazelcast/config/IcmpFailureDetectorConfig.java:215
↓ 6 callersMethodsetParallelism
Sets the number of Persistence store instances to create for one Hazelcast instance.
hazelcast/src/main/java/com/hazelcast/config/PersistenceConfig.java:171
↓ 6 callersMethodsetPort
Sets the port the Hazelcast member will try to bind on. <p> A valid port value is between 0 and 65535. A port number of 0 will let the system pick up
hazelcast/src/main/java/com/hazelcast/config/ServerSocketEndpointConfig.java:102
↓ 6 callersMethodsetPortableVersion
@param portableVersion int value for the version of portable classes @return configured {@link com.hazelcast.config.SerializerConfig} for chaining @d
hazelcast/src/main/java/com/hazelcast/config/SerializationConfig.java:160
↓ 6 callersMethodsetPropertiesInternal
Sets the used properties. Can be null if no properties should be used. <p> Properties are used to resolve ${variable} occurrences in the XML file. @p
hazelcast/src/main/java/com/hazelcast/config/AbstractXmlConfigBuilder.java:190
↓ 6 callersMethodsetPurgeEnabled
Enables time-based purging of CPMap entries. <p> When enabled, entries exceeding a given age may be removed based on logical timestamps assigned by th
hazelcast/src/main/java/com/hazelcast/config/cp/CPMapConfig.java:140
↓ 6 callersMethodsetPutVanilla
(boolean putVanilla)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/StaticParams.java:156
↓ 6 callersMethodsetReactorCount
Sets the number of reactors. @param reactorCount the number of reactors. @return this @throws IllegalArgumentException if reactorCount smaller than 1
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/TpcEngineBuilder.java:54
↓ 6 callersMethodsetReadable
Configures if this AsyncSocket is readable or not. If there is no change in the readable status, the call is ignored. <p/> When an AsyncSocket is read
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncSocket.java:112
↓ 6 callersMethodsetRequiredMember
Sets the required member. If a null value is passed, it means that there is no required member. <p> With a required member configured, the cluster wil
hazelcast/src/main/java/com/hazelcast/config/TcpIpConfig.java:188
↓ 6 callersMethodsetRoleSeparator
Allows to use a custom role separator in the configuration. It's important in case when a role name contains the default separator "," (comma). @para
hazelcast/src/main/java/com/hazelcast/config/security/SimpleAuthenticationConfig.java:80
↓ 6 callersMethodsetServerHandler
(OutOfMemoryHandler outOfMemoryHandler)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:63
↓ 6 callersMethodsetSessionId
(UUID sessionId)
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobMetaDataParameterObject.java:52
↓ 6 callersMethodsetSourceConnectorWrapper
(SourceConnectorWrapper sourceConnectorWrapper)
extensions/kafka-connect/src/main/java/com/hazelcast/jet/kafka/connect/impl/ReadKafkaConnectP.java:258
↓ 6 callersMethodsetStatementTimeoutMillis
Sets the timeout in milliseconds that is applied to statements without an explicit timeout. <p> It is possible to set a timeout through the {@link Sql
hazelcast/src/main/java/com/hazelcast/config/SqlConfig.java:65
↓ 6 callersMethodsetSyncConfig
Sets the config for the WAN sync mechanism. @param syncConfig the WAN sync config @return this config
hazelcast/src/main/java/com/hazelcast/config/WanBatchPublisherConfig.java:336
↓ 6 callersMethodsetTimeoutMilliseconds
(int timeoutMilliseconds)
hazelcast/src/main/java/com/hazelcast/client/config/ClientIcmpPingConfig.java:100
↓ 6 callersMethodsetTransactionId
(UUID transactionId)
hazelcast/src/main/java/com/hazelcast/map/impl/tx/MapTxnOperation.java:37
↓ 6 callersMethodsetTtl
(Data key, long ttl)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:136
↓ 6 callersMethodsetUsage
(LoginModuleUsage usage)
hazelcast/src/main/java/com/hazelcast/config/LoginModuleConfig.java:92
↓ 6 callersMethodsetWhitelistedPrefixes
Comma-separated list of class prefixes which will be loaded remotely. <p> Use this to limit User Code Deployment to selected classes only and disable
hazelcast/src/main/java/com/hazelcast/config/UserCodeDeploymentConfig.java:196
↓ 6 callersMethodsetup
(long scaleUpDelay)
hazelcast/src/test/java/com/hazelcast/jet/core/ScaleUpTest.java:50
↓ 6 callersMethodsetupKeyAndMockStorage
()
hazelcast/src/test/java/com/hazelcast/map/impl/recordstore/expiry/ExpirySystemTest.java:181
↓ 6 callersMethodsetupMockNode
()
hazelcast/src/test/java/com/hazelcast/instance/impl/KubernetesTopologyIntentTrackerTest.java:61
↓ 6 callersMethodshard
(String id, long startHashKey, long endHashKey)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/impl/source/ShardTrackerTest.java:105
↓ 6 callersMethodshards
Returns list of shards for given indexes Only STARTED shards are returned. @param indices indexes to return shards for (wildcard format accepted)
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/impl/ElasticCatClient.java:131
↓ 6 callersMethodshouldStopDraining
The queue-draining loop drains the queues in the order specified by this class and consults this method before going on to drain the next queue. The m
hazelcast/src/main/java/com/hazelcast/jet/impl/util/SkewReductionPolicy.java:177
↓ 6 callersMethodshouldValidateTheSchema
()
hazelcast/src/main/java/com/hazelcast/config/AbstractConfigBuilder.java:32
↓ 6 callersMethodshouldWait
@implNote There can be multiple operations waiting in a queue for given {@link WaitNotifyKey}. If this method returns {@code true}, no other {@link Bl
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/BlockingOperation.java:37
↓ 6 callersMethodshutdownAllMembers
()
hazelcast/src/test/java/com/hazelcast/client/test/TestHazelcastFactory.java:149
↓ 6 callersMethodshutdownExecutor
(String name)
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/ExecutionService.java:150
↓ 6 callersMethodshutdownIsolatedNode
()
hazelcast/src/test/java/com/hazelcast/internal/util/AbstractClockTest.java:79
↓ 6 callersMethodshutdownNow
()
hazelcast/src/test/java/com/hazelcast/internal/util/executor/CachedExecutorServiceDelegateTest.java:259
↓ 6 callersMethodsize
()
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueContainer.java:662
↓ 6 callersMethodsize
()
hazelcast/src/main/java/com/hazelcast/internal/util/collection/OAHashSet.java:268
↓ 6 callersMethodsize
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberMap.java:201
↓ 6 callersMethodsize
Returns the number of items the buffer holds.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/SourceBuilder.java:78
↓ 6 callersMethodsize
Returns the number of TransactionRecords in this TransactionLog. @return the number of TransactionRecords.
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionLog.java:85
↓ 6 callersMethodskipBytes
(int n)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ObjectDataInputStream.java:85
↓ 6 callersMethodskipFirst
Skip elements until the first element satisfying the predicate is encountered. @param iterator the iterator whose first elements should be skipped. A
hazelcast/src/main/java/com/hazelcast/internal/util/IterableUtil.java:205
↓ 6 callersMethodslideBy
Returns the size of the sliding step.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/SlidingWindowDefinition.java:65
↓ 6 callersMethodsmallInstanceWithResourceUploadConfig
()
hazelcast/src/test/java/com/hazelcast/jet/core/JetTestSupport.java:234
↓ 6 callersMethodsnapshotDataMapName
Returns map name in the form {@code "_jet.snapshot.<jobId>.<dataMapIndex>"}.
hazelcast/src/main/java/com/hazelcast/jet/impl/JobRepository.java:702
↓ 6 callersMethodsolePartition
@returns the sole partition ID, if this set has a size of 1. Otherwise, returns -1.
hazelcast/src/main/java/com/hazelcast/internal/util/collection/PartitionIdSet.java:276
↓ 6 callersMethodsortedIndexConfig
(String attribute)
hazelcast/src/test/java/com/hazelcast/json/MapIndexJsonTest.java:122
↓ 6 callersMethodsourceConnectorInstance
()
extensions/kafka-connect/src/test/java/com/hazelcast/jet/kafka/connect/impl/SourceConnectorWrapperTest.java:104
↓ 6 callersMethodstartJob
()
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/JmsSourceIntegrationTestBase.java:469
↓ 6 callersMethodstartThread
()
hazelcast/src/test/java/com/hazelcast/internal/networking/nio/NioThreadAbstractTest.java:88
↓ 6 callersMethodsteppedOperationOffloadEnabled
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/EntryOperation.java:251
↓ 6 callersMethodstopContainer
Stops a container via the `docker stop` command. Necessary because the {@code stop()} method of test containers is implemented via `docker kill` and t
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/AbstractCdcIntegrationTest.java:230
↓ 6 callersMethodstore
(String path, String content)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/file/SqlHadoopTest.java:443
↓ 6 callersMethodsubmitToMember
(@Nonnull Callable<T> task, @Nonnull Member member)
hazelcast/src/main/java/com/hazelcast/executor/impl/ExecutorServiceProxy.java:281
↓ 6 callersMethodsupplier
( QueryPath[] paths, QueryDataType[] types, UpsertTargetDescriptor keyDesc
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvProjector.java:110
↓ 6 callersMethodsupplier
Returns meta-supplier with default local parallelism of 1
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:595
↓ 6 callersMethodtagValue
Returns the value associated with the given {@code tag} or {@code null} if the given tag is not set for the descriptor. If tag is duplicated, returns
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:134
↓ 6 callersMethodterminateAll
Terminates all instances started by this factory.
hazelcast/src/test/java/com/hazelcast/test/TestHazelcastInstanceFactory.java:504
↓ 6 callersMethodtest
(int producerCount, IdleStrategy idleStrategy)
hazelcast/src/test/java/com/hazelcast/internal/util/concurrent/MPSCQueueStressTest.java:73
↓ 6 callersMethodtest
(String name, BiConsumer<Pipeline, Integer> configureFn)
hazelcast/src/test/java/com/hazelcast/jet/impl/memory/MemoryManagementTest.java:105
↓ 6 callersMethodtestIndexWithoutMapProxy
(Consumer<String> actionBeforeTest)
hazelcast/src/test/java/com/hazelcast/client/map/ClientIndexStatsTest.java:173
↓ 6 callersMethodtestIterator
(Iterator it, int size)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryBasicTest.java:294
↓ 6 callersMethodtestSplitBrain
(int firstSubClusterSize, int secondSubClusterSize, Consumer<Hazelcast
hazelcast/src/test/java/com/hazelcast/jet/core/JetSplitBrainTestSupport.java:93
↓ 6 callersMethodtimeout
(long timeout)
hazelcast/src/main/java/com/hazelcast/sql/impl/QueryException.java:93
↓ 6 callersMethodtimestamp
Specifies the moment when the change event occurred in the database. Normally this is the timestamp recorded in the database's change log, but since i
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/ChangeRecord.java:69
↓ 6 callersMethodtoArray
(Record record)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/KinesisSources.java:352
↓ 6 callersMethodtoArray
(List<Long> longs)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/CallsPerMember.java:94
↓ 6 callersMethodtoArray
(Map<UUID, Address> addressMap)
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionTableView.java:130
↓ 6 callersMethodtoHeapData
(Data data)
hazelcast/src/main/java/com/hazelcast/cache/impl/operation/CacheOperation.java:264
↓ 6 callersMethodtoJson
()
extensions/cdc-debezium/src/main/java/com/hazelcast/jet/cdc/impl/RecordPartImpl.java:78
↓ 6 callersMethodtoJson
(CPGroupId groupId)
hazelcast/src/main/java/com/hazelcast/internal/ascii/rest/HttpGetCommandProcessor.java:313
↓ 6 callersMethodtoJson
Creates a JSON string for the given object.
hazelcast/src/main/java/com/hazelcast/jet/json/JsonUtil.java:257
↓ 6 callersMethodtoObject
(Object data)
hazelcast/src/test/java/com/hazelcast/map/impl/query/QueryEngineImplTest.java:136
↓ 6 callersMethodtoObject
(Object object)
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:1394
↓ 6 callersMethodtoPercentage
(long amount, long total)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/NetworkingImbalancePlugin.java:161
↓ 6 callersMethodtoString
()
hazelcast/src/main/java/com/hazelcast/internal/partition/PartitionRuntimeState.java:208
↓ 6 callersMethodtoString
()
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfig.java:184
↓ 6 callersMethodtotalMicros
()
hazelcast/src/main/java/com/hazelcast/internal/util/LatencyDistribution.java:129
↓ 6 callersMethodtraitPlus
Add a single trait to the trait set. @param traitSet Original trait set. @param trait Trait to add. @return Resulting trait set.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:143
↓ 6 callersMethodtransactionContext
()
hazelcast-spring/src/main/java/com/hazelcast/spring/transaction/ManagedTransactionalTaskContext.java:74
↓ 6 callersMethodtransform
Transforms the input object into the output object. @param input object. @return the output object.
hazelcast/src/main/java/com/hazelcast/projection/Projection.java:54
↓ 6 callersMethodtraverseArray
Returns a traverser over the given array. Null elements in the array are skipped.
hazelcast/src/main/java/com/hazelcast/jet/Traversers.java:151
↓ 6 callersMethodtryProcess
Tries to process the supplied input item, which was received from the edge with the supplied ordinal. May choose to process only partially and return
hazelcast/src/main/java/com/hazelcast/jet/core/AbstractProcessor.java:169
↓ 6 callersMethodtryRecover
This method can be used to recover from a possible event loss situation. You can detect event loss via {@link com.hazelcast.map.listener.EventLostList
hazelcast/src/main/java/com/hazelcast/map/QueryCache.java:220
↓ 6 callersMethodtsv
(Class<?> type, Object sampleValue)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/HsaHeapMemoryManagerTest.java:160
↓ 6 callersMethodtuple5
Returns a new 5-tuple with the supplied values.
hazelcast/src/main/java/com/hazelcast/jet/datamodel/Tuple5.java:54
↓ 6 callersMethodtype
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/MappingField.java:80
↓ 6 callersMethodunblock
Removes the effect of a previous {@link #block()} call (if any).
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/OutboxInternal.java:40
← previousnext →10,001–10,100 of 147,315, ranked by callers