MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 12 callersMethodsetOffload
Default value is {@value #DEFAULT_OFFLOAD}. <p> {@link MapStore} interaction can be slow compared to in-memory processing of data, to make partition t
hazelcast/src/main/java/com/hazelcast/config/MapStoreConfig.java:225
↓ 12 callersMethodsetPartData
(byte[] partData)
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobMultiPartParameterObject.java:66
↓ 12 callersMethodsetPartSize
(int partSize)
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobMultiPartParameterObject.java:74
↓ 12 callersMethodsetPopulate
Set {@code true} to enable initial population, otherwise set {@code false}. <p> Default value is {@value #DEFAULT_POPULATE}. @param populate set {@co
hazelcast/src/main/java/com/hazelcast/config/QueryCacheConfig.java:339
↓ 12 callersMethodsetPortableVersion
(int portableVersion)
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationServiceBuilder.java:37
↓ 12 callersMethodsetQueueSize
Sets the capacity of processor-to-processor concurrent queues. The value is rounded upwards to the next power of 2. <p> When data needs to travel betw
hazelcast/src/main/java/com/hazelcast/jet/config/EdgeConfig.java:73
↓ 12 callersMethodsetSSLConfig
Sets the {@link SSLConfig}. null value indicates that no SSLConfig should be used. @param sslConfig the SSLConfig @return the updated NetworkConfig @
hazelcast/src/main/java/com/hazelcast/config/NetworkConfig.java:354
↓ 12 callersMethodsetStatus
(MigrationStatus status)
hazelcast/src/main/java/com/hazelcast/internal/partition/MigrationInfo.java:148
↓ 12 callersMethodsetTime
Sets a time field consisting of hour, minute, seconds, and nanos parts. <p> It is legal to set the field again only when Builder is created with {@lin
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:584
↓ 12 callersMethodsetTotalPartNumber
(int totalPartNumber)
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobMultiPartParameterObject.java:58
↓ 12 callersMethodsetTryCount
Sets the try count; the number of times this operation can be retried. @param tryCount the try count; the number of times this operation can be retri
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/InvocationBuilder.java:145
↓ 12 callersMethodsetUsernamePasswordIdentityConfig
(UsernamePasswordIdentityConfig identityConfig)
hazelcast/src/main/java/com/hazelcast/config/security/RealmConfig.java:91
↓ 12 callersMethodsetWriteCoalescing
()
hazelcast/src/test/java/com/hazelcast/config/MapStoreConfigTest.java:207
↓ 12 callersMethodsetWriteThrough
Set if write-through caching should be used. <p> It is an invalid configuration to set this to {@code true} without specifying a {@link javax.cache.in
hazelcast/src/main/java/com/hazelcast/config/CacheConfiguration.java:120
↓ 12 callersMethodshutdown
Shutdowns the Server completely. Connections and the networking engine will not be operational anymore and cannot be restarted. <p> This method has no
hazelcast/src/main/java/com/hazelcast/internal/server/Server.java:135
↓ 12 callersMethodshutdownNodeFactory
()
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:177
↓ 12 callersMethodsinkStreamOfKeyedWinResult
()
hazelcast/src/test/java/com/hazelcast/jet/pipeline/PipelineStreamTestSupport.java:81
↓ 12 callersMethodstart
()
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/ClientUserCodeDeploymentService.java:63
↓ 12 callersMethodstartInstance
()
hazelcast/src/test/java/com/hazelcast/wan/WanRESTTest.java:181
↓ 12 callersMethodstartJob
(HazelcastInstance hz, DAG dag, JobConfig config)
hazelcast/src/test/java/com/hazelcast/jet/core/SplitBrainTest.java:431
↓ 12 callersMethodsumValueFor
(JobMetrics metrics, String vertex, String metric)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetrics_StreamTest.java:355
↓ 12 callersMethodtag
()
hazelcast/src/test/java/com/hazelcast/azure/TagTest.java:25
↓ 12 callersMethodtakeWriteLock
()
hazelcast/src/main/java/com/hazelcast/query/impl/BaseIndexStore.java:70
↓ 12 callersMethodtest
(StreamSource<ChangeRecord> source, List<String> expectedRecords, int expectedInitialOps)
extensions/cdc-mysql/src/test/java/com/hazelcast/jet/cdc/mysql/MySqlCdcWhiteBlackListIntegrationTest.java:232
↓ 12 callersMethodtest
(StreamSource<ChangeRecord> source, List<String> expectedRecords, int expectedInitialOps)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcWhiteBlackListIntegrationTest.java:233
↓ 12 callersMethodtest
(Set<Integer> keySet, boolean update, EntryProcessor entryProcessor, boolean expectShift
hazelcast/src/test/java/com/hazelcast/map/EntryProcessorExpiryTimeTest.java:162
↓ 12 callersMethodtoAdapter
(HazelcastJsonValue jsonValue)
hazelcast/src/test/java/com/hazelcast/json/internal/AbstractJsonSchemaTest.java:55
↓ 12 callersMethodtoArray
()
extensions/avro/src/main/java/com/hazelcast/jet/avro/impl/AvroSerializerHooks.java:310
↓ 12 callersMethodtoKey
(int i)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/offload/MapStoreOffloadingBouncingNodeTest.java:316
↓ 12 callersMethodtoStorageIndex
(long addr)
hazelcast/src/test/java/com/hazelcast/internal/memory/impl/HeapMemoryManager.java:157
↓ 12 callersMethodtryLock
Acquires the lock if it is available or already held by the current thread at the time of invocation &amp; the acquire limit is not exceeded, and imme
hazelcast/src/main/java/com/hazelcast/cp/lock/FencedLock.java:335
↓ 12 callersMethodtryLock
Tries to acquire the lock for the specified key. <p> If the lock is not available, then the current thread does not wait and the method returns false
hazelcast/src/main/java/com/hazelcast/multimap/MultiMap.java:462
↓ 12 callersMethodtumblingWinPolicy
Returns the definition of a tumbling window of length {@code windowSize}. The tumbling window is a special case of the sliding window with {@code slid
hazelcast/src/main/java/com/hazelcast/jet/core/SlidingWindowPolicy.java:176
↓ 12 callersMethodunit
Returns the unit of the metric denoted by this instance. @return the unit
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:112
↓ 12 callersMethodunlock
(Data key, UUID caller, long threadId, long referenceId)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:389
↓ 12 callersMethodupstream
()
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/transform/Transform.java:63
↓ 12 callersMethodusing
Applies extension to this stage in a fluent way. <pre>{@code srcStage.using(IMapExtension.iMapExtension()) // additional methods available he
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:692
↓ 12 callersMethodvalueOf
(int ordinal)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCompressor.java:478
↓ 12 callersMethodverifyNotAndThenClear
()
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithmsTest.java:255
↓ 12 callersMethodverifyOr
()
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithmsTest.java:232
↓ 12 callersMethodwaitAfterAttempt
Returns the wait time required before the specified attempt. In this context attempt no. 1 means the first attempt, so it's not an index and zero is n
hazelcast/src/main/java/com/hazelcast/jet/retry/IntervalFunction.java:69
↓ 12 callersMethodwaitForFirstSnapshot
(JobRepository jr, long jobId, int timeoutSeconds, boolean allowEmptySnapshot)
hazelcast/src/test/java/com/hazelcast/jet/core/JetTestSupport.java:301
↓ 12 callersMethodwithDatabaseName
(String databaseName)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/DbCheckingPMetaSupplierBuilder.java:44
↓ 12 callersMethodwithEndpoint
(@Nullable String endpoint)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/AwsConfig.java:52
↓ 12 callersMethodwithIdentityFinish
Returns a copy of this aggregate operation, but with the {@code finish} primitive replaced with the identity function. It will return the accumulator
hazelcast/src/main/java/com/hazelcast/jet/aggregate/AggregateOperation.java:281
↓ 12 callersMethodwithRegion
(@Nullable String region)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/AwsConfig.java:62
↓ 12 callersMethodwrapDataConnectionKey
(String dataConnectionKey)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/QueryUtils.java:70
↓ 11 callersMethodadd
Adds an task to this queue. This method is thread safe. @param task the item to add @param priority if the task has priority or not @throws java
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationQueue.java:44
↓ 11 callersMethodadd
Convenience for {@code inbox.queue().add(o)}
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestInbox.java:79
↓ 11 callersMethodaddByteField
@param fieldName name of the field that will be added to this class definition @return itself for chaining @throws HazelcastSerializationException if
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinitionBuilder.java:136
↓ 11 callersMethodaddClamped
(long a, long b)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:202
↓ 11 callersMethodaddCustomClasspath
Adds custom classpath element to a stage with the given name. <pre>{@code BatchSource<String> source = ... JobConfig config = new JobConfig(); config
hazelcast/src/main/java/com/hazelcast/jet/config/JobConfig.java:659
↓ 11 callersMethodaddDirectoryConfig
Adds the persistent memory directory configuration to be used to store memory structures allocated by native memory manager. <p/> If the specified dir
hazelcast/src/main/java/com/hazelcast/config/PersistentMemoryConfig.java:144
↓ 11 callersMethodaddFlakeIdGeneratorConfig
Adds a flake ID generator configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be
hazelcast/src/main/java/com/hazelcast/config/Config.java:2579
↓ 11 callersMethodaddJar
String jarPath is searched in following order: 1. as absolute path, 2. as URL, 3. and in classpath. @param jarPath path of the jar that will be sent
hazelcast/src/main/java/com/hazelcast/client/config/ClientUserCodeDeploymentConfig.java:138
↓ 11 callersMethodaddOrIncrementIndexInName
If the name ends with "-N", returns a new name where "-N" is replaced with "-M" where M = N + 1. If N is too large for {@code int}, negative, unparsea
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:564
↓ 11 callersMethodaddSetConfig
Adds the set configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtained in
hazelcast/src/main/java/com/hazelcast/config/Config.java:1233
↓ 11 callersMethodaddWanReplicationConfig
Adds a new {@link WanReplicationConfig} to the cluster. This method can also accept WAN configs with an existing WAN replication name. Such configs wi
hazelcast/src/main/java/com/hazelcast/wan/impl/WanReplicationService.java:229
↓ 11 callersMethodallocate
()
hazelcast/src/test/java/com/hazelcast/internal/util/collection/HsaHeapMemoryManagerTest.java:152
↓ 11 callersMethodanalyzeJobConfig
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/SqlPlanImpl.java:1229
↓ 11 callersMethodand
Performs AND for the given operands acting on the given row in the given context. <p> The method exhibits a short-circuiting behaviour: there is no gu
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/TernaryLogic.java:50
↓ 11 callersMethodapplyConfig
Applies the given config. @param configDTO configuration object
hazelcast/src/main/java/com/hazelcast/internal/management/ClientBwListConfigHandler.java:50
↓ 11 callersMethodasCompletableFuture
(Future<V> future)
hazelcast/src/main/java/com/hazelcast/spi/impl/executionservice/ExecutionService.java:170
↓ 11 callersMethodasInt
()
hazelcast/src/test/java/com/hazelcast/internal/json/JsonNumber_Test.java:74
↓ 11 callersMethodassertCommitNotCalled
()
hazelcast/src/test/java/com/hazelcast/transaction/impl/MockTransactionLogRecord.java:118
↓ 11 callersMethodassertContains
(Object state, Thread waiter, boolean contains)
hazelcast/src/test/java/com/hazelcast/spi/impl/AbstractInvocationFuture_GetWithTimeoutTest.java:213
↓ 11 callersMethodassertContainsSensor
(String parameter)
hazelcast/src/test/java/com/hazelcast/internal/metrics/metricsets/OperatingSystemMetricSetTest.java:95
↓ 11 callersMethodassertEntries
(Entry<Integer, Integer>... entries)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/ReadOptimizedLruCacheTest.java:107
↓ 11 callersMethodassertIndex
(IMap<Integer, HazelcastJsonValue> map, int targetCount, Comparable comparable, String attributeName)
hazelcast/src/test/java/com/hazelcast/json/MapIndexJsonTest.java:208
↓ 11 callersMethodassertItemsInOrder
(WeightedEvictableList<String> weightedList, T... values)
hazelcast/src/test/java/com/hazelcast/internal/util/collection/WeightedEvictableListTest.java:149
↓ 11 callersMethodassertJobFailed
( FileSourceBuilder<?> source, Class<? extends Throwable> expectedRootException,
extensions/hadoop/src/test/java/com/hazelcast/jet/hadoop/file/BaseFileFormatTest.java:96
↓ 11 callersMethodassertNearCacheStats
Asserts the {@link NearCacheStats} for expected values. @param context the {@link NearCacheTestContext} to retrieve the stats from @p
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestUtils.java:483
↓ 11 callersMethodassertNewLastUpdateTime
()
hazelcast/src/test/java/com/hazelcast/collection/impl/AbstractCollectionStatisticsTest.java:48
↓ 11 callersMethodassertResult
(List<Integer> expected, Iterator<IndexKeyEntries> actual)
hazelcast/src/test/java/com/hazelcast/query/impl/OrderedIndexStoreTest.java:180
↓ 11 callersMethodassertResultContains
(Set<Map.Entry<String, String>> result, String key, String value)
hazelcast/src/test/java/com/hazelcast/map/impl/query/MapEntrySetTest.java:198
↓ 11 callersMethodassertResultSorted
(MapFetchIndexOperationResult result, List<Person> orderedPeopleList)
hazelcast/src/test/java/com/hazelcast/map/impl/operation/MapFetchIndexOperationTest.java:553
↓ 11 callersMethodassertSuccessJson
(ConnectionResponse resp, String... attributesAndValues)
hazelcast/src/test/java/com/hazelcast/internal/ascii/RestClusterTest.java:568
↓ 11 callersMethodassertValid
()
hazelcast/src/main/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArrayBase.java:339
↓ 11 callersMethodassertWithCause
(CompletableFuture<?> future)
hazelcast/src/test/java/com/hazelcast/spi/impl/DelegatingCompletableFuture_SerializationExceptionTest.java:275
↓ 11 callersMethodassertXsdVersion
(String buildVersion, String expectedXsdVersion)
hazelcast/src/test/java/com/hazelcast/config/XmlOnlyConfigBuilderTest.java:235
↓ 11 callersMethodassignWatermarkKeys
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/WatermarkKeysAssigner.java:63
↓ 11 callersMethodassumeThatMethodIsAvailable
Assumes that the {@link DataStructureAdapter} created by the Near Cache test supports a given {@link DataStructureAdapterMethod}. @param method the {
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCacheBasicTest.java:138
↓ 11 callersMethodasyncBackups
(int requestedSyncBackups, int requestedAsyncBackups, boolean syncForced)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/OperationBackupHandler.java:126
↓ 11 callersMethodattributes
(Map<String, String> attributes)
hazelcast/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java:192
↓ 11 callersMethodbeforeRemoteCall
(Object key, Data keyData, Object value, Data valueData)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/RemoteCallHook.java:35
↓ 11 callersMethodbigDecimalAvg
@param <I> type of the input object. @return an aggregator that calculates the average of the input values. Does NOT accept null input values. Accepts
hazelcast/src/main/java/com/hazelcast/aggregation/Aggregators.java:127
↓ 11 callersMethodblockMessagesFromInstance
Blocks incoming messages to client from given instance
hazelcast/src/test/java/com/hazelcast/client/test/ClientTestSupport.java:45
↓ 11 callersMethodboundsCheck
Bounds check when copying to/from a buffer @param capacity capacity of the buffer @param index index of copying will start from/to @param length
hazelcast/src/main/java/com/hazelcast/internal/util/collection/ArrayUtils.java:152
↓ 11 callersMethodbsonToDocument
Converts given {@link Bson} to {@link Document}.
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/Mappers.java:109
↓ 11 callersMethodbuild
Builds the schema from the written fields and returns it.
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/SchemaWriter.java:52
↓ 11 callersMethodbyteBuffer
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/iobuffer/IOBuffer.java:84
↓ 11 callersMethodcalculate
(PhysicalRel rel, ExpressionEvalContext evalContext)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/WatermarkThrottlingFrameSizeCalculator.java:36
↓ 11 callersMethodcallListeners
(Consumer<ClientConnectionProcessListener> consumer)
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListenerRegistry.java:192
↓ 11 callersMethodcallsBeforeDone
(int count)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/TaskletExecutionServiceTest.java:476
↓ 11 callersMethodcheckParameter
(Object parameterValue, Object expectedValue)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ToTimestampTzIntegrationTest.java:159
↓ 11 callersMethodcheckSelectWithOrderBy
(List<String> indexAttrs, List<String> orderFields, List<Boolean> orderDirections)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlOrderByTest.java:842
↓ 11 callersMethodchildAsScalarValue
Gets a child scalar node's value by its name <p> See {@link YamlScalar} for the possible types <p> Please note that if the scalar's type is not the ex
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlMapping.java:89
↓ 11 callersMethodchildren
Returns the children nodes @return the children nodes
hazelcast/src/main/java/com/hazelcast/internal/yaml/YamlCollection.java:29
↓ 11 callersMethodcleanup
Cleans up the event journal by removing any expired items. Items are considered expired according to the configured expiration policy. @param namespa
hazelcast/src/main/java/com/hazelcast/internal/journal/EventJournal.java:157
↓ 11 callersMethodclear
Clears the multimap. Removes all key-value pairs.
hazelcast/src/main/java/com/hazelcast/multimap/MultiMap.java:288
← previousnext →6,101–6,200 of 147,315, ranked by callers