MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 24 callersMethodgetActiveMemberNetworkConfig
(Config config)
hazelcast/src/main/java/com/hazelcast/config/ConfigAccessor.java:41
↓ 24 callersMethodgetAge
()
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/utils/Employee.java:70
↓ 24 callersMethodgetBindAddress
Returns a server socket listener address. The returned address for different {@link EndpointQualifier}s may be the same or different, depending on the
hazelcast/src/main/java/com/hazelcast/instance/AddressPicker.java:45
↓ 24 callersMethodgetBrokerConnectionString
()
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:146
↓ 24 callersMethodgetClasses
Returns unmodifiable set of class names.
hazelcast/src/main/java/com/hazelcast/config/ClassFilter.java:74
↓ 24 callersMethodgetComparatorClassName
Gets the class name of the configured {@link EvictionPolicyComparator} implementation. @return class name of the configured {@link EvictionPolicyComp
hazelcast/src/main/java/com/hazelcast/internal/eviction/EvictionConfiguration.java:46
↓ 24 callersMethodgetConfig
Returns a config for the given name, creating one if necessary and adding it to the collection of known configurations. <p> The configuration is found
hazelcast/src/main/java/com/hazelcast/internal/config/ConfigUtils.java:94
↓ 24 callersMethodgetDestName
Returns the name of the destination vertex.
hazelcast/src/main/java/com/hazelcast/jet/core/Edge.java:217
↓ 24 callersMethodgetDirectory
Returns the directory of this {@link PersistentMemoryDirectoryConfig}. @return the directory
hazelcast/src/main/java/com/hazelcast/config/PersistentMemoryDirectoryConfig.java:78
↓ 24 callersMethodgetEventType
Return the event type @return event type
hazelcast/src/main/java/com/hazelcast/cache/impl/event/ICacheEvent.java:40
↓ 24 callersMethodgetHazelcastClientInstanceImpl
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/client/impl/clientside/ClientTestUtil.java:47
↓ 24 callersMethodgetItemId
()
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueItem.java:75
↓ 24 callersMethodgetJobExecutionService
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JetServiceBackend.java:368
↓ 24 callersMethodgetLeft
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/type/RecurrentStructuresNestedFieldsTest.java:399
↓ 24 callersMethodgetLocalMapStatsImpl
(String name)
hazelcast/src/main/java/com/hazelcast/map/impl/LocalMapStatsProvider.java:110
↓ 24 callersMethodgetMajor
()
hazelcast/src/main/java/com/hazelcast/version/Version.java:71
↓ 24 callersMethodgetMemberAddressProviderConfig
(Config cfg)
hazelcast/src/test/java/com/hazelcast/config/ConfigXmlGeneratorTest.java:185
↓ 24 callersMethodgetMultiMapStats
()
hazelcast/src/test/java/com/hazelcast/multimap/LocalMultiMapStatsTest.java:68
↓ 24 callersMethodgetName
Returns the name of this data connection as specified in the {@link DataConnectionConfig} or the {@code CREATE DATA CONNECTION} command. @return the
hazelcast/src/main/java/com/hazelcast/dataconnection/DataConnection.java:92
↓ 24 callersMethodgetNewValue
Returns the event new value
hazelcast/src/test/java/com/hazelcast/journal/EventJournalEventAdapter.java:38
↓ 24 callersMethodgetOffset
@return the offset to read the primitive field from. If field is not primitive returns -1
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/FieldDescriptor.java:71
↓ 24 callersMethodgetOwnedEntryCount
@return number of Near Cache entries owned by this member
hazelcast/src/main/java/com/hazelcast/nearcache/NearCacheStats.java:36
↓ 24 callersMethodgetPartition
(int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/InternalPartitionService.java:48
↓ 24 callersMethodgetPreloaderConfig
Returns the {@link NearCachePreloaderConfig} of this Near Cache. @return the {@link NearCachePreloaderConfig} of this Near Cache
hazelcast/src/main/java/com/hazelcast/config/NearCacheConfig.java:374
↓ 24 callersMethodgetRemoveOperationCount
Returns the number of Remove operations @return number of remove operations
hazelcast/src/main/java/com/hazelcast/map/LocalMapStats.java:165
↓ 24 callersMethodgetReplicatedRecordStore
(String name, boolean create, Object key)
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/ReplicatedMapService.java:241
↓ 24 callersMethodgetSalt
Returns the salt. @return the salt
hazelcast/src/main/java/com/hazelcast/config/AbstractSymmetricEncryptionConfig.java:83
↓ 24 callersMethodgetSplitBrainMergePolicyProvider
Returns the {@link SplitBrainMergePolicyProvider} for this instance. @return the {@link SplitBrainMergePolicyProvider} @since 3.10
hazelcast/src/main/java/com/hazelcast/spi/impl/NodeEngine.java:307
↓ 24 callersMethodgetSplitBrainProtectionConfig
Returns the {@link SplitBrainProtectionConfig} for the given name, creating one if necessary and adding it to the collection of known configurations.
hazelcast/src/main/java/com/hazelcast/config/Config.java:2358
↓ 24 callersMethodgetSplitBrainProtectionName
Returns the split brain protection name for operations of the data structure. @return the split brain protection name
hazelcast/src/main/java/com/hazelcast/config/SplitBrainPolicyAwareConfig.java:33
↓ 24 callersMethodgetSubscriberContext
Returns {@link SubscriberContext} for this context. @return {@link SubscriberContext} for this context. @see SubscriberContext
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/QueryCacheContext.java:53
↓ 24 callersMethodgetTo
@return the upper/right bound of this range predicate or {@code null} if the predicate range is right-unbounded.
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/RangePredicate.java:49
↓ 24 callersMethodgetValueClass
()
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:1118
↓ 24 callersMethodgetVersion
()
hazelcast/src/main/java/com/hazelcast/map/impl/record/Record.java:49
↓ 24 callersMethodgetWatermarkedFieldsKey
(RelNode node)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/WatermarkKeysAssigner.java:88
↓ 24 callersMethodindex
Returns the index of the processor that will handle this transaction ID. Used when restoring transaction IDs to determine which processor owns which t
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:352
↓ 24 callersMethodisSerializeKeys
Checks if the Near Cache key is stored in serialized format or by-reference. @return {@code true} if the key is stored in serialized format, {@code f
hazelcast/src/main/java/com/hazelcast/internal/nearcache/NearCache.java:183
↓ 24 callersMethodisUsePublicIp
Checks whether the public or private IP should be used to connect to Hazelcast members. @return {@code true} for public IP, {@code false} for private
hazelcast/src/main/java/com/hazelcast/config/AliasedDiscoveryConfig.java:137
↓ 24 callersMethodjobContext
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:268
↓ 24 callersMethodlimb
(String name, List<String> tattoos, Finger... fingers)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/extractor/ComplexTestDataStructure.java:161
↓ 24 callersMethodloadClass
(String name)
hazelcast/src/test/java/com/hazelcast/osgi/TestBundle.java:85
↓ 24 callersMethodmapResultsToSortedList
(IMap<?, ?> map)
extensions/cdc-debezium/src/test/java/com/hazelcast/jet/cdc/AbstractCdcIntegrationTest.java:64
↓ 24 callersMethodnaturalOrder
{@code Serializable} variant of {@link Comparator#naturalOrder() java.util.Comparator#naturalOrder()}. @param <T> the {@link Comparable} type of elem
hazelcast/src/main/java/com/hazelcast/function/ComparatorEx.java:65
↓ 24 callersMethodnewNearCacheConfig
()
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/NearCacheTestSupport.java:190
↓ 24 callersMethodoffer
(String queueName, Object value)
hazelcast/src/main/java/com/hazelcast/internal/ascii/TextCommandService.java:29
↓ 24 callersMethodonEvent
Handle event. @param event type of event.
hazelcast/src/main/java/com/hazelcast/map/impl/ListenerAdapter.java:36
↓ 24 callersMethodpartition
Return the slice of the hash range for partition {@code index} out of {@code count} partitions.
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/HashRange.java:77
↓ 24 callersMethodpopulateMap
(Map<Integer, Integer> map, int mapSize)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/NearCacheTestSupport.java:235
↓ 24 callersMethodpopulateNearCache
(Map<Integer, ?> map, int mapSize)
hazelcast/src/test/java/com/hazelcast/map/impl/nearcache/NearCacheTestSupport.java:241
↓ 24 callersMethodpredicate
(String indexName, CompositeValue value, String... components)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/CompositeEqualPredicateTest.java:143
↓ 24 callersMethodpublishLong
Publish the given metric with a long value.
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricsPublisher.java:27
↓ 24 callersMethodputCheckCommute
(Object value, String operand1, String operand2, Boolean expectedResult, Object... params)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/AndOrPredicateIntegrationTest.java:242
↓ 24 callersMethodreadCharArray
@return the char array read @throws IOException if it reaches end of file before finish reading
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:62
↓ 24 callersMethodreadInt32
Reads a 32-bit two's complement signed integer. <p> This method can also read a nullable int32, as long as it is not {@code null}. If a {@code null} v
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:138
↓ 24 callersMethodreadLong
(byte[] buffer, int pos, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:179
↓ 24 callersMethodregister
(TextCommandConstants.TextCommandType type, TextCommandProcessor processor)
hazelcast/src/main/java/com/hazelcast/internal/ascii/TextCommandServiceImpl.java:148
↓ 24 callersMethodremoveMessageListener
Stops receiving messages for the given message listener. <p> If the given listener already removed, this method does nothing. @param registrationId I
hazelcast/src/main/java/com/hazelcast/topic/ITopic.java:100
↓ 24 callersMethodresults
(Object... args)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/datetime/ExtractFunctionIntegrationTest.java:487
↓ 24 callersMethodsetBaseDir
Sets the base directory where the Python files reside. When you set this, also set the name of the {@link #setHandlerModule handler module} to identif
extensions/python/src/main/java/com/hazelcast/jet/python/PythonServiceConfig.java:182
↓ 24 callersMethodsetCacheLoaderFactory
Set the {@link javax.cache.integration.CacheLoader} factory. @param factory the {@link javax.cache.integration.CacheLoader} {@link javax.cache.config
hazelcast/src/main/java/com/hazelcast/config/CacheConfiguration.java:81
↓ 24 callersMethodsetClassCacheMode
Configure caching of classes loaded from remote members. <p> Default: {@link ClassCacheMode#ETERNAL} @return this instance of UserCodeDeploymentConfi
hazelcast/src/main/java/com/hazelcast/config/UserCodeDeploymentConfig.java:240
↓ 24 callersMethodsetDataAdapter
(DataStructureAdapter<K, V> dataAdapter)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestContextBuilder.java:78
↓ 24 callersMethodsetDataInstance
(HazelcastInstance dataInstance)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/NearCacheTestContextBuilder.java:68
↓ 24 callersMethodsetDefaultsDisabled
Sets whether the default serialization filters are disabled. @param defaultsDisabled {@code true} to disable defaults, {@code false} otherwise @retur
hazelcast/src/main/java/com/hazelcast/config/JavaSerializationFilterConfig.java:116
↓ 24 callersMethodsetHandlerModule
Sets the name of the Python module that has the function that transforms Jet pipeline data.
extensions/python/src/main/java/com/hazelcast/jet/python/PythonServiceConfig.java:255
↓ 24 callersMethodsetTypes
Sets the expected type of keys and values for a {@link javax.cache.Cache} configured with this {@link javax.cache.configuration.Configuration}. Settin
hazelcast/src/main/java/com/hazelcast/config/CacheConfiguration.java:53
↓ 24 callersMethodstring
(Object value)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/misc/CastFunctionIntegrationTest.java:1227
↓ 24 callersMethodtimeInMsOrOneIfResultIsZero
Convert time to milliseconds based on the given time unit. If conversion result is 0 and {@code time} was &gt; 0, then 1 is returned. @param time
hazelcast/src/main/java/com/hazelcast/internal/util/TimeUtil.java:70
↓ 24 callersMethoduncheckCall
(@Nonnull Callable<T> callable)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:165
↓ 24 callersMethodvalueOf
(boolean isMadeProgress, boolean isDone)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ProgressState.java:41
↓ 24 callersMethodwith
(Config memberConfig)
hazelcast/src/test/java/com/hazelcast/test/bounce/BounceMemberRule.java:297
↓ 24 callersMethodwriteStringArray
@param values String array to be written @throws IOException in case of any exceptional case
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataOutput.java:102
↓ 23 callersMethodadd
(final Integer value)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/IntHashSet.java:61
↓ 23 callersMethodaddMultiMapConfig
Adds the multimap configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtaine
hazelcast/src/main/java/com/hazelcast/config/Config.java:1333
↓ 23 callersMethodassertListContent
(List<Object> list)
hazelcast/src/test/java/com/hazelcast/collection/impl/list/ListSplitBrainTest.java:268
↓ 23 callersMethodassertMapEventually
Execute a query and assert that it eventually returns the expected entries. @param mapName The IMap name @param sql The query @param expected E
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:141
↓ 23 callersMethodassertNoOptimization
(Predicate original)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/EvaluateVisitorTest.java:197
↓ 23 callersMethodassertNotContains
(String expected)
hazelcast/src/test/java/com/hazelcast/internal/diagnostics/AbstractDiagnosticsPluginTest.java:56
↓ 23 callersMethodassertQueueContent
(Queue<Object> queue)
hazelcast/src/test/java/com/hazelcast/collection/impl/queue/QueueSplitBrainTest.java:299
↓ 23 callersMethodassertRingbufferContent
(Ringbuffer<Object> ringbuffer, int expectedSize)
hazelcast/src/test/java/com/hazelcast/ringbuffer/RingbufferSplitBrainTest.java:331
↓ 23 callersMethodassertSetContent
(Set<Object> set)
hazelcast/src/test/java/com/hazelcast/collection/impl/set/SetSplitBrainTest.java:267
↓ 23 callersMethodassertSummedMetricValue
(String metricName, long expectedValue)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetricsChecker.java:62
↓ 23 callersMethodassertThrowsNPE
(ConsumerEx<HazelcastInstance> method)
hazelcast/src/test/java/com/hazelcast/instance/AbstractHazelcastInstanceNullTest.java:59
↓ 23 callersMethodbitWidthOf
@return the bit width required to represent the given value.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastIntegerType.java:187
↓ 23 callersMethodcall
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/operations/ReadManyOperation.java:64
↓ 23 callersMethodcheckConverterSelf
(Converter converter)
hazelcast-sql/src/test/java/com/hazelcast/sql/impl/type/converter/ConvertersTest.java:1103
↓ 23 callersMethodclientFn
Set the client supplier function <p> The connector uses the returned instance to access Elasticsearch. Also see {@link ElasticClients} for convenience
extensions/elasticsearch/elasticsearch-7/src/main/java/com/hazelcast/jet/elastic/ElasticSinkBuilder.java:99
↓ 23 callersMethodconstant
Creates an {@code IntervalFunction} which returns a fixed interval in milliseconds.
hazelcast/src/main/java/com/hazelcast/jet/retry/IntervalFunction.java:38
↓ 23 callersMethodcontainer
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/Contexts.java:417
↓ 23 callersMethoddefaultDatabase
()
extensions/mongodb/src/test/java/com/hazelcast/jet/mongodb/AbstractMongoTest.java:133
↓ 23 callersMethodequals
(Object o)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/schema/model/Person.java:41
↓ 23 callersMethodequals
(Object o)
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/InputRef.java:64
↓ 23 callersMethodexpectInvalid
()
hazelcast/src/test/java/com/hazelcast/config/InvalidConfigurationTest.java:332
↓ 23 callersMethodforceNext
Generates the next unique call ID. This never blocks and it should be used only for urgent operation or when retrying. @return the generated call ID
hazelcast/src/main/java/com/hazelcast/spi/impl/sequence/CallIdSequence.java:69
↓ 23 callersMethodget
(IMap map, Object key)
hazelcast/src/test/java/com/hazelcast/map/InterceptorTest.java:80
↓ 23 callersMethodget
(@Nonnull String fieldName, @Nonnull FieldKind primitiveFieldKind, @Nonnull FieldKind nu
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/DeserializedGenericRecord.java:567
↓ 23 callersMethodget
(long key)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2LongMap.java:24
↓ 23 callersMethodgetBoolean
Returns the configured boolean value of a {@link HazelcastProperty}. @param property the {@link HazelcastProperty} to get the value from @return the
hazelcast/src/main/java/com/hazelcast/spi/properties/HazelcastProperties.java:186
↓ 23 callersMethodgetByteOrder
@return ByteOrder BIG_ENDIAN or LITTLE_ENDIAN
hazelcast/src/main/java/com/hazelcast/nio/ObjectDataInput.java:143
↓ 23 callersMethodgetCatalogReader
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/logical/UpdateLogicalRel.java:86
← previousnext →3,801–3,900 of 147,315, ranked by callers