MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 3 callersMethodtxn
(HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/xa/HazelcastXATest.java:241
↓ 3 callersMethodtypeConverter
The {@link com.hazelcast.core.TypeConverter} to be used to convert the string value read from XML to the expected type automatically. @return a defin
hazelcast/src/main/java/com/hazelcast/config/properties/PropertyDefinition.java:44
↓ 3 callersMethodtypes
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/file/FileTable.java:64
↓ 3 callersMethodunblock
()
hazelcast/src/test/java/com/hazelcast/jet/job/AbstractJobInitialSnapshotTest.java:189
↓ 3 callersMethodunescapeSpecialCharacters
@param buffer the string for which the escape character '\' is removed properly @return the unescaped string
hazelcast/src/main/java/com/hazelcast/client/impl/statistics/ClientStatisticsService.java:271
↓ 3 callersMethoduniqueName
Creates a {@code Vertex} name that is unique in this DAG and starts with the given prefix.
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:333
↓ 3 callersMethodunit
Return the measurement unit for the associated metric. Meant to provide further information on the type of value measured by the user-defined metric.
hazelcast/src/main/java/com/hazelcast/jet/core/metrics/Metric.java:49
↓ 3 callersMethodunknownJobOption
(String key)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/ParserResource.java:85
↓ 3 callersMethodunlock
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:145
↓ 3 callersMethodunmodifiableArray
Returns an unmodifiable wrapper for the specified JsonArray. This method allows to provide read-only access to a JsonArray. <p> The returned JsonArray
hazelcast/src/main/java/com/hazelcast/internal/json/JsonArray.java:108
↓ 3 callersMethodunmodifiableObject
Returns an unmodifiable JsonObject for the specified one. This method allows to provide read-only access to a JsonObject. <p> The returned JsonObject
hazelcast/src/main/java/com/hazelcast/internal/json/JsonObject.java:126
↓ 3 callersMethodunprocessedNodes
(ConfigNode node)
hazelcast/src/main/java/com/hazelcast/internal/config/override/ConfigNodeStateTracker.java:27
↓ 3 callersMethodunregisterMBeanIgnoreError
(ObjectName objectName)
hazelcast/src/main/java/com/hazelcast/internal/metrics/jmx/JmxPublisher.java:139
↓ 3 callersMethodunscheduleExpirationTask
Ends scheduling of the task that clears expired entries. Calling this method multiple times has same effect.
hazelcast/src/main/java/com/hazelcast/internal/eviction/ExpirationManager.java:100
↓ 3 callersMethodunwrap
@return internal implementation specific instance of supplied clazz, otherwise returns null.
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueue.java:112
↓ 3 callersMethodunwrapPayload
(Object jetEvent)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:292
↓ 3 callersMethodunzip
(InputStream is, Path targetDir)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/IOUtil.java:103
↓ 3 callersMethodupdate
()
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithms.java:235
↓ 3 callersMethodupdateBranch
Synchronously calculates the hash for all the parent nodes of the node referenced by {@code leafOrder} up to the root node. @param leafOrder The orde
hazelcast/src/main/java/com/hazelcast/wan/impl/merkletree/ArrayMerkleTree.java:168
↓ 3 callersMethodupdateGetNextRecordsTime
(long currentTime, long minimumIncrease)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardReader.java:313
↓ 3 callersMethodupdateMemberGroupsSize
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateManager.java:86
↓ 3 callersMethodupdateRecordValue
Updates record's value. Performs an update in-place if the record can accommodate the new value (applicable for the inlined records only). Otherwise,
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/Storage.java:61
↓ 3 callersMethodupdateTcpIpMemberList
(String clusterName, String clusterPassword, String memberListText)
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:437
↓ 3 callersMethodupdatesMongo_using
(String expr)
extensions/mongodb/src/test/java/com/hazelcast/jet/sql/impl/connector/mongodb/MongoBatchSqlConnectorUpdateIT.java:380
↓ 3 callersMethoduploadJobResources
Uploads job resources and returns a unique job id generated for the job. If the upload process fails for any reason, such as being unable to access a
hazelcast/src/main/java/com/hazelcast/jet/impl/JobRepository.java:225
↓ 3 callersMethoduploadResourcesForNewJob
()
hazelcast/src/test/java/com/hazelcast/jet/impl/JobRepositoryTest.java:277
↓ 3 callersMethodurl
@return the path of the resource
hazelcast/src/main/java/com/hazelcast/internal/namespace/ResourceDefinition.java:45
↓ 3 callersMethoduser
()
hazelcast/src/test/java/com/hazelcast/test/jdbc/MSSQLDatabaseProvider.java:105
↓ 3 callersMethodvalOrNull
(final long value)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Object2LongHashMap.java:620
↓ 3 callersMethodvalidateAttribute
Validate attribute name. @param config Index config. @param attributeName Attribute name.
hazelcast/src/main/java/com/hazelcast/query/impl/IndexUtils.java:172
↓ 3 callersMethodvalidateConfiguredKeyType
Validates the key with key type. @param keyType key class. @param key key to be validated. @param <K> the type of key. @throws ClassCastExcep
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxyUtil.java:214
↓ 3 callersMethodvalidateConfiguredValueType
Validates the value with value type. @param valueType value class. @param value value to be validated. @param <V> the type of value. @throw
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxyUtil.java:231
↓ 3 callersMethodvalidateJoinMessage
Validate that the configuration received from the remote node in {@code joinMessage} is compatible with the configuration of this node. @param joinMe
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:258
↓ 3 callersMethodvalidateMembersViewMetadata
(MembersViewMetadata membersViewMetadata)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:612
↓ 3 callersMethodvalidatePartitionStamp
Verifies that the given partition stamp is still valid. It is valid iff there were no partition updates since the call to the {@link #getPartitionStam
hazelcast/src/main/java/com/hazelcast/query/impl/InternalIndex.java:117
↓ 3 callersMethodvalidateProcessor
()
hazelcast/src/test/java/com/hazelcast/jet/core/VertexTest.java:107
↓ 3 callersMethodvalidateRegion
(String region)
hazelcast/src/main/java/com/hazelcast/aws/RegionValidator.java:34
↓ 3 callersMethodvalidateRegistrationsOnMembers
(final TestHazelcastFactory factory, int expected)
hazelcast/src/test/java/com/hazelcast/client/listeners/AbstractListenersOnReconnectTest.java:299
↓ 3 callersMethodvalidateRestConfig
(Config config)
hazelcast/src/test/java/com/hazelcast/config/AbstractConfigBuilderTest.java:757
↓ 3 callersMethodvalidateSenderIsMaster
(Address sender, String messageType)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:661
↓ 3 callersMethodvalidateSuffixInSystemProperty
Validates if the config file referenced in {@code propertyKey} has an accepted suffix. If the system property is not set, the validation passes withou
hazelcast/src/main/java/com/hazelcast/internal/config/DeclarativeConfigUtil.java:99
↓ 3 callersMethodvalue
(T item)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/WriteMapP.java:117
↓ 3 callersMethodvalueFields
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/map/PartitionedMapTable.java:112
↓ 3 callersMethodvalueIterator
(Comparable value, TypeConverter converter)
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/Bitmap.java:212
↓ 3 callersMethodvalueToData
(Object value)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:344
↓ 3 callersMethodverifyClass
Verifies that the provided {@link Class} is safe to use for attribute extraction in this policy. @param clazz the class to verify @return the verifie
hazelcast/src/main/java/com/hazelcast/query/impl/getters/policy/ReflectiveAttributeLookupPolicy.java:56
↓ 3 callersMethodverifyCollectedOnce
(CapturingCollector collector, MetricDescriptor expectedDescriptor)
hazelcast/src/test/java/com/hazelcast/internal/server/tcp/TcpServerConnectionManagerMetricsTest.java:61
↓ 3 callersMethodverifyDataStructureMetricPresent
(HazelcastInstance instance, boolean shouldContain)
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/MetricsPropertiesTest.java:215
↓ 3 callersMethodverifyNotBuilt
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/nio/NioAsyncServerSocketBuilder.java:99
↓ 3 callersMethodverifyRunning
()
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/Reactor.java:242
↓ 3 callersMethodverifyScriptEngineFactory
(ScriptEngineFactory scriptEngineFactory)
hazelcast/src/test/java/com/hazelcast/osgi/impl/HazelcastOSGiScriptEngineFactoryTest.java:63
↓ 3 callersMethodverifyTreesAreSameOnCommonLevels
(MerkleTree merkleTreeShallow, MerkleTree merkleTreeDeep)
hazelcast/src/test/java/com/hazelcast/wan/impl/merkletree/ArrayMerkleTreeTest.java:300
↓ 3 callersMethodverifyValue
(long key1, long key2, long valueAddress)
hazelcast/src/test/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArray16byteKeyImplTest.java:412
↓ 3 callersMethodverifyValue
(long key, long valueAddress)
hazelcast/src/test/java/com/hazelcast/internal/util/hashslot/impl/HashSlotArray8byteKeyImplTest.java:313
↓ 3 callersMethodwaitAllForSafeStateAndDumpPartitionServiceOnFailure
(List<HazelcastInstance> instances,
hazelcast/src/test/java/com/hazelcast/partition/AbstractPartitionLostListenerTest.java:182
↓ 3 callersMethodwaitBlockingSemaphore
()
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:358
↓ 3 callersMethodwaitForFirstStatisticsCollection
(final HazelcastClientInstanceImpl client, final Clie
hazelcast/src/test/java/com/hazelcast/client/statistics/ClientStatisticsTest.java:350
↓ 3 callersMethodwaitForJobRunning
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlMetadataInJobConfigTest.java:147
↓ 3 callersMethodwaitForNearCachePersistence
(final NearCacheTestContext context, final int persistenceCount)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/AbstractNearCachePreloaderTest.java:446
↓ 3 callersMethodwaitForTopicConsumption
()
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/JmsSourceIntegrationTestBase.java:137
↓ 3 callersMethodwaitInstanceForSafeState
(final HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:757
↓ 3 callersMethodwaitPartitionReplicaSyncOnCluster
Waits until partition replicas (primaries and backups) get in sync. @param unit time unit @param supplier the {@link SafeStateCheckOperation} supplie
hazelcast/src/main/java/com/hazelcast/internal/hotrestart/InternalHotRestartService.java:153
↓ 3 callersMethodwaitUntilAllResponded
(Collection<? extends Future> futures)
hazelcast/src/main/java/com/hazelcast/internal/util/FutureUtil.java:291
↓ 3 callersMethodwaitUntilLoaded
()
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:776
↓ 3 callersMethodwanMapConsistencyCheck
(String clusterName, String clusterPassword, String wanRepName, Strin
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:334
↓ 3 callersMethodwatermarkedColumnIndex
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/FullScan.java:53
↓ 3 callersMethodwatermarkedFieldByIndex
(int watermarkedFieldIndex)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/metadata/HazelcastRelMdWatermarkedFields.java:81
↓ 3 callersMethodwhenNoProblemPacket
(int threadCount)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/InboundResponseHandlerSupplierTest.java:128
↓ 3 callersMethodwhen_maxAccumulatedRecordsCountIsExceededWhileS2SJoin_then_throws
(Object[][] rows1, Object[][] rows2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlMemoryManagementTest.java:163
↓ 3 callersMethodwhen_snapshotFails
(ProcessingGuarantee guarantee, boolean expectFailure)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/JmsSourceIntegration_NonSharedClusterTest.java:119
↓ 3 callersMethodwhen_zipSlipVulnerability_then_zipEntryIgnored
@param entryFunction maps from (targetDir, nonTargetDir) to an entry path
hazelcast/src/test/java/com/hazelcast/jet/impl/util/IOUtilTest.java:137
↓ 3 callersMethodwindowDefinition
Returns the definition of the window for the windowed aggregation operation that you are about to construct using this object.
hazelcast/src/main/java/com/hazelcast/jet/pipeline/StageWithWindow.java:57
↓ 3 callersMethodwindowPolicyProvider
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/SlidingWindowAggregatePhysicalRel.java:114
↓ 3 callersMethodwithBackupCount
(int backupCount)
hazelcast/src/test/java/com/hazelcast/map/EntryCostEstimatorTest.java:267
↓ 3 callersMethodwithBackupProcessingDelay
(int backupDelaySeconds)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:86
↓ 3 callersMethodwithCacheName
(String cacheName)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/QueryCacheRequest.java:58
↓ 3 callersMethodwithCatalog
(String schema)
hazelcast/src/main/java/com/hazelcast/dataconnection/impl/ResourceReader.java:38
↓ 3 callersMethodwithClassName
(String className)
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlStoreConfigBuilder.java:43
↓ 3 callersMethodwithCodecRegistry
(CodecRegistry codecRegistry)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/dataconnection/CloseableMongoClient.java:207
↓ 3 callersMethodwithContext
(QueryCacheContext context)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/QueryCacheRequest.java:80
↓ 3 callersMethodwithDefaults
()
hazelcast/src/test/java/com/hazelcast/jet/impl/util/JsonUtilTest.java:322
↓ 3 callersMethodwithFilter
(RexNode filter)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/HazelcastTable.java:133
↓ 3 callersMethodwithHeaders
(Map<String, String> headers)
hazelcast/src/main/java/com/hazelcast/spi/utils/RestClient.java:137
↓ 3 callersMethodwithHeartbeatIntervalMillis
Bootstrap the stats with heartbeats that corresponds to this duration in milliseconds, with a rather high standard deviation (since environment is unk
hazelcast/src/main/java/com/hazelcast/config/ProbabilisticSplitBrainProtectionConfigBuilder.java:119
↓ 3 callersMethodwithInMemoryFormat
(InMemoryFormat inMemoryFormat)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:137
↓ 3 callersMethodwithInitialMode
(MapStoreConfig.InitialLoadMode initialMode)
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlStoreConfigBuilder.java:38
↓ 3 callersMethodwithKey
(K key)
hazelcast/src/main/java/com/hazelcast/map/impl/SimpleEntryView.java:69
↓ 3 callersMethodwithMapName
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/QueryCacheEventDataBuilder.java:80
↓ 3 callersMethodwithMaxSampleSize
Number of samples to use for calculation of mean and standard deviation of inter-arrival times.
hazelcast/src/main/java/com/hazelcast/config/ProbabilisticSplitBrainProtectionConfigBuilder.java:89
↓ 3 callersMethodwithMemberSelector
Selects the members on which the job will run. <p> If there is no member matching the selector during submission, the submission will be successful, b
hazelcast/src/main/java/com/hazelcast/jet/JetService.java:341
↓ 3 callersMethodwithMinStdDeviationMillis
Minimum standard deviation (in milliseconds) to use for the normal distribution used when calculating phi. Too low standard deviation might result in
hazelcast/src/main/java/com/hazelcast/config/ProbabilisticSplitBrainProtectionConfigBuilder.java:99
↓ 3 callersMethodwithNodeCount
(int nodeCount)
hazelcast/src/test/java/com/hazelcast/map/EntryCostEstimatorTest.java:258
↓ 3 callersMethodwithPartitionId
(int partitionId)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/event/QueryCacheEventDataBuilder.java:70
↓ 3 callersMethodwithRetryStrategy
Specifies how the source should behave when reading data from the stream fails. The default behavior retries the read operation indefinitely, but afte
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/KinesisSinks.java:288
↓ 3 callersMethodwithStore
(MapXmlStoreConfigBuilder mapXmlStoreConfigBuilder)
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlConfigBuilder.java:42
↓ 3 callersMethodwithSuspicionThreshold
Threshold for suspicion (φ) level. A low threshold is prone to generate many wrong suspicions but ensures a quick detection in the event of a real cra
hazelcast/src/main/java/com/hazelcast/config/ProbabilisticSplitBrainProtectionConfigBuilder.java:81
↓ 3 callersMethodwithWriteBatchSize
(int writeBatchSize)
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlStoreConfigBuilder.java:53
↓ 3 callersMethodwithWriteBehindQueueCapacity
(int writeBehindQueueCapacity)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/TestMapUsingMapStoreBuilder.java:110
↓ 3 callersMethodwithWriteDelay
(int writeDelaySeconds)
hazelcast/src/test/java/com/hazelcast/config/test/builders/MapXmlStoreConfigBuilder.java:48
↓ 3 callersMethodword
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsDictionary.java:78
← previousnext →16,001–16,100 of 147,315, ranked by callers