MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 6 callersMethodgetUserCodeNamespace
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/config/RingbufferConfig.java:393
↓ 6 callersMethodgetUsernamePasswordIdentityConfig
()
hazelcast/src/main/java/com/hazelcast/config/security/RealmConfig.java:87
↓ 6 callersMethodgetUuid
Returns the UUID of this Raft endpoint @return the UUID of this Raft endpoint
hazelcast/src/main/java/com/hazelcast/cp/internal/raft/impl/RaftEndpoint.java:37
↓ 6 callersMethodgetValue
(Object object, String fieldName)
extensions/kafka/src/main/java/com/hazelcast/jet/kafka/impl/ResumeTransactionUtil.java:104
↓ 6 callersMethodgetValueClassName
()
hazelcast/src/main/java/com/hazelcast/config/AbstractCacheConfig.java:378
↓ 6 callersMethodgetValueJetMetadata
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/map/AbstractMapTable.java:108
↓ 6 callersMethodgetWanMergePolicy
()
hazelcast/src/main/java/com/hazelcast/map/impl/wan/MapWanContext.java:142
↓ 6 callersMethodgetWriteBatchSize
()
hazelcast/src/test/java/com/hazelcast/config/MapStoreConfigTest.java:108
↓ 6 callersMethodgetYear
()
hazelcast/src/test/java/com/hazelcast/map/MapIndexBackupTest.java:140
↓ 6 callersMethodgithub_11489_verifyNoFailingCastOnValue
(Function<IMap<Integer, Integer>, Object> function)
hazelcast/src/test/java/com/hazelcast/client/map/ClientMapBasicTest.java:1523
↓ 6 callersMethodgivenParkedBackupOperation
()
hazelcast/src/test/java/com/hazelcast/spi/impl/operationparker/impl/OperationParkerMigrationTest.java:205
↓ 6 callersMethodgo
()
hazelcast/src/main/java/com/hazelcast/jet/impl/TopologicalSorter.java:110
↓ 6 callersMethodhandleProcessingFailure
(Throwable throwable)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AbstractMessageTask.java:242
↓ 6 callersMethodhandleServerSocketEndpointConfig
(ServerSocketEndpointConfig endpointConfig, Node node)
hazelcast/src/main/java/com/hazelcast/internal/config/MemberDomConfigProcessor.java:1126
↓ 6 callersMethodhashCode
()
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorWaitNotifyKey.java:46
↓ 6 callersMethodid
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:374
↓ 6 callersMethodidAndName
Returns the string {@code <jobId> (name <jobName>)} without risking triggering of lazy-loading of JobConfig: if we don't have it, it will say {@code n
hazelcast/src/main/java/com/hazelcast/jet/impl/AbstractJobProxy.java:198
↓ 6 callersMethodimplementsInterfaceWithSameName
Check whether given class implements an interface with the same name. It returns true even when the implemented interface is loaded by a different cla
hazelcast/src/main/java/com/hazelcast/internal/nio/ClassLoaderUtil.java:370
↓ 6 callersMethodinboundEdges
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/VertexDef.java:75
↓ 6 callersMethodincrementEvictions
()
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/NearCacheStatsImpl.java:206
↓ 6 callersMethodincrementExpirations
()
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/NearCacheStatsImpl.java:215
↓ 6 callersMethodindexConverterToSqlTypes
(TypeConverter converter)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/map/MapTableUtils.java:157
↓ 6 callersMethodinit
()
hazelcast/src/main/java/com/hazelcast/map/impl/MapContainer.java:50
↓ 6 callersMethodinsertWatermarksP
Returns a supplier of processors for a vertex that inserts {@link com.hazelcast.jet.core.Watermark watermark items} into the stream. The value of the
hazelcast/src/main/java/com/hazelcast/jet/core/processor/Processors.java:862
↓ 6 callersMethodintersects
(LinkedAddresses other)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/LinkedAddresses.java:107
↓ 6 callersMethodinvalidateEntry
(Data key, UUID source)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:582
↓ 6 callersMethodinvoke
(Operation op, Data keyData, boolean completionOperation)
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheProxySupport.java:301
↓ 6 callersMethodinvoke
(Operation operation, Data dataKey)
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapProxySupport.java:424
↓ 6 callersMethodinvokeAsync
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/impl/Invocation.java:242
↓ 6 callersMethodinvokeOnConnection
@param invocation to be invoked @param connection to be invoked on @return true if successfully send to given connection, false otherwise
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientInvocationService.java:46
↓ 6 callersMethodinvokeOnKeyOwner
(ClientMessage request, Data keyData)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientMapProxy.java:370
↓ 6 callersMethodinvokeOnParticipants
@param completionCallback a consumer that will receive a collection of member-response pairs, one for each
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:440
↓ 6 callersMethodinvokeOnPartitionAsync
Invokes an {@link Operation} asynchronously on the specified {@code partitionId}, on behalf of the service defined by the provided {@code serviceName}
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationService.java:150
↓ 6 callersMethodinvokeOnPartitionsAsync
Invokes a set of operations on selected set of partitions in an async way. <p> If the operations have sync backups, the returned {@link CompletableFut
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationService.java:373
↓ 6 callersMethodinvokeOperationAsync
(Object key, MapOperation operation,
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:540
↓ 6 callersMethodisAuthenticated
@return true if endpoint is authenticated with valid security credentials, returns false otherwise
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEndpoint.java:97
↓ 6 callersMethodisCancelled
()
hazelcast/src/main/java/com/hazelcast/spi/impl/operationparker/impl/WaitSetEntry.java:94
↓ 6 callersMethodisCompactSerializable
Returns {@code true} if the {@code object} is compact serializable. <p> It will return {@code true} if <ul> <li>it is registered as compact serial
hazelcast/src/main/java/com/hazelcast/internal/serialization/InternalSerializationService.java:158
↓ 6 callersMethodisEmpty
Indicate whether event data have been created and are cached in this cache or not. If this method returns false, then {@code eventDataIncludingValues.
hazelcast/src/main/java/com/hazelcast/map/impl/event/EntryEventDataCache.java:61
↓ 6 callersMethodisEnabled
Check if the multicast discovery mechanism has been enabled. @return true if the multicast discovery mechanism has been enabled
hazelcast/src/main/java/com/hazelcast/config/MulticastConfig.java:79
↓ 6 callersMethodisEnabled
@return whether the ICMP detector is enabled or not.
hazelcast/src/main/java/com/hazelcast/config/IcmpFailureDetectorConfig.java:187
↓ 6 callersMethodisEnabled
Returns whether tiered-store is enabled on the related data structure. @return true if tiered-store is enabled, false otherwise.
hazelcast/src/main/java/com/hazelcast/config/TieredStoreConfig.java:58
↓ 6 callersMethodisExport
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterSnapshotContext.java:102
↓ 6 callersMethodisFailOnIndeterminateOperationState
Returns the value to determine if CP Subsystem API calls will fail when result of an API call becomes indeterminate. @return the value to determine i
hazelcast/src/main/java/com/hazelcast/config/cp/CPSubsystemConfig.java:503
↓ 6 callersMethodisFull
Checks if the CircularQueue is full. @return true if full.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/util/CircularQueue.java:58
↓ 6 callersMethodisHotRestartEnabled
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:1129
↓ 6 callersMethodisJCacheAvailable
()
hazelcast/src/test/java/com/hazelcast/cache/impl/operation/OnJoinCacheOperationTest.java:127
↓ 6 callersMethodisJetEnabled
(NodeEngine nodeEngine)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:846
↓ 6 callersMethodisKeepAlive
SO_KEEPALIVE socket option @return true if enabled
hazelcast/src/main/java/com/hazelcast/client/config/SocketOptions.java:86
↓ 6 callersMethodisKnownServiceNamespace
Returns true if namespace is known by this service, false otherwise @return true if namespace is known by this service, false otherwise
hazelcast/src/main/java/com/hazelcast/internal/partition/FragmentedMigrationAwareService.java:60
↓ 6 callersMethodisLe
(RelOptCost other)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/cost/Cost.java:107
↓ 6 callersMethodisManagementEnabled
Checks if management is enabled for this {@link com.hazelcast.cache.ICache}. @return {@code true} if cache management is enabled, {@code false} other
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:257
↓ 6 callersMethodisMigrating
(int partitionId)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/PartitionStateManager.java:116
↓ 6 callersMethodisNumericInteger
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataTypeFamily.java:108
↓ 6 callersMethodisPersistenceEnabled
Returns whether Dynamic Configuration Persistence is enabled on this member. @return true if Dynamic Configuration Persistence is enabled
hazelcast/src/main/java/com/hazelcast/config/DynamicConfigurationConfig.java:52
↓ 6 callersMethodisPopulate
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/dynamicconfig/QueryCacheConfigHolder.java:104
↓ 6 callersMethodisPostProcessingOrHasInterceptor
(RecordStore recordStore)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapOperation.java:395
↓ 6 callersMethodisPowerOfTwo
Return true if input argument is power of two. Input has to be a positive integer. <p> Result is undefined for zero or negative integers. @param x te
hazelcast/src/main/java/com/hazelcast/internal/util/QuickMath.java:41
↓ 6 callersMethodisPrimitive
(Class<?> clazz)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/FieldAccessExpression.java:109
↓ 6 callersMethodisReadThrough
Checks if this {@link com.hazelcast.cache.ICache} is read-through: a read loads the entry from the data store if it is not already in the cache. @ret
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:278
↓ 6 callersMethodisSameRM
(XAResource xaResource)
hazelcast/src/main/java/com/hazelcast/transaction/impl/xa/XAResourceImpl.java:222
↓ 6 callersMethodisStatisticsEnabled
@return {@code true} if statistics gathering is enabled on the executor task (default), {@code false} otherwise
hazelcast/src/main/java/com/hazelcast/config/DurableExecutorConfig.java:204
↓ 6 callersMethodisTargetIncluded
Returns {@code true} if this metric should be included on the given {@link MetricTarget} @param target The target to check @return {@code true} if th
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:266
↓ 6 callersMethodisTcpNoDelay
TCP_NODELAY socket option @return true if enabled
hazelcast/src/main/java/com/hazelcast/client/config/SocketOptions.java:66
↓ 6 callersMethodisToInclusive
()
hazelcast/src/main/java/com/hazelcast/internal/iteration/IndexIterationPointer.java:166
↓ 6 callersMethodisVersioned
(byte header)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/DataSerializableHeader.java:51
↓ 6 callersMethodisWithTerminalSnapshot
If true, the job should be terminated with a terminal snapshot. If false, it should be interrupted.
hazelcast/src/main/java/com/hazelcast/jet/impl/TerminationMode.java:54
↓ 6 callersMethodisWriteThrough
Checks if the {@link com.hazelcast.cache.ICache} is write-through: a write to the queue also loads the entry into the data store. @return {@code true
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:300
↓ 6 callersMethoditemsParallel
( long eventsPerSecondPerGenerator, @Nonnull List<? extends GeneratorFunction<T>> generatorFns
hazelcast/src/test/java/com/hazelcast/jet/pipeline/OrderedProcessingMergingStagesTest.java:341
↓ 6 callersMethoditerator
Iterator for the single specified partition {@link ICache} @param fetchSize batch fetching size @param partitionId partition ID of the entrie
hazelcast/src/main/java/com/hazelcast/cache/impl/ICacheInternal.java:60
↓ 6 callersMethoditerator
()
hazelcast/src/main/java/com/hazelcast/replicatedmap/impl/record/LazySet.java:52
↓ 6 callersMethoditerator
()
hazelcast/src/main/java/com/hazelcast/internal/util/collection/OAHashSet.java:273
↓ 6 callersMethodjmsQueueBuilder
Returns a builder object that offers a step-by-step fluent API to build a custom JMS {@link StreamSource} for the Pipeline API. See javadoc on {@link
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:1414
↓ 6 callersMethodjobRestartOnExceptionTest
(Exception exception)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/JobExceptionHandlerTest.java:73
↓ 6 callersMethodjoinAndExpectCancellation
(Job job)
hazelcast/src/test/java/com/hazelcast/jet/core/JobTest.java:1244
↓ 6 callersMethodjoinConfig
(boolean advancedNetworkConfig)
hazelcast/src/main/java/com/hazelcast/internal/config/MemberDomConfigProcessor.java:1543
↓ 6 callersMethodjsonMapping
(String name)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/SqlJsonTest.java:55
↓ 6 callersMethodkafkaMapping
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlAvroSchemaEvolutionTest.java:116
↓ 6 callersMethodkey
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlOption.java:50
↓ 6 callersMethodkey
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/durableexecutor/DurableExecutorSplitBrainProtectionWriteTest.java:251
↓ 6 callersMethodkey
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/scheduledexecutor/ScheduledExecutorSplitBrainProtectionWriteTest.java:263
↓ 6 callersMethodkeyEq
(Object src, Object dest)
hazelcast/src/main/java/com/hazelcast/internal/util/ConcurrentReferenceHashMap.java:591
↓ 6 callersMethodlagExpression
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/logical/WatermarkLogicalRel.java:49
↓ 6 callersMethodlast
(E[] array)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/parse/ParserNameResolutionTest.java:234
↓ 6 callersMethodlastWriteTimeMillis
Returns the clock time in milliseconds of the most recent write using this connection. @return the clock time of the most recent write.
hazelcast/src/main/java/com/hazelcast/internal/nio/Connection.java:71
↓ 6 callersMethodlistOpenShards
(Predicate<? super Shard> filter)
extensions/kinesis/src/test/java/com/hazelcast/jet/kinesis/KinesisTestHelper.java:135
↓ 6 callersMethodload
Tries to load the data for the given queue item. The method will also try to load data in batches if configured to do so. <p> If the {@link QueueStore
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueContainer.java:867
↓ 6 callersMethodload
(K key)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/MapDataStore.java:61
↓ 6 callersMethodloadClass
Load a class using the current thread's context class loader as a classLoaderHint. Exceptions are sneakily thrown.
hazelcast/src/main/java/com/hazelcast/jet/impl/util/ReflectionUtils.java:64
↓ 6 callersMethodloadConfigurationFromClasspath
(String configFileName)
hazelcast/src/main/java/com/hazelcast/internal/config/AbstractConfigLocator.java:149
↓ 6 callersMethodloadFromStream
Creates a Config from the provided stream (XML or YAML content) and uses the System.properties for variable resolution. @param source the XML or YAML
hazelcast/src/main/java/com/hazelcast/config/Config.java:474
↓ 6 callersMethodloadFromString
Creates a Config from the provided string (XML or YAML content) and uses the System.properties for variable resolution. @param source the XML or YAML
hazelcast/src/main/java/com/hazelcast/config/Config.java:444
↓ 6 callersMethodloadFromSystemPropertyOrFailOnUnacceptedSuffix
(String propertyKey, Collection<String> acceptedSuffixes)
hazelcast/src/main/java/com/hazelcast/internal/config/AbstractConfigLocator.java:227
↓ 6 callersMethodloadFromWorkingDirectory
(String configFilePath)
hazelcast/src/main/java/com/hazelcast/internal/config/AbstractConfigLocator.java:186
↓ 6 callersMethodloadValueOfKey
(Data key, long now)
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:506
↓ 6 callersMethodlocalProcessorIndex
Returns the index of the processor among all the processors created for this vertex on a single node: it's a unique node-wide index. <p> The value is
hazelcast/src/main/java/com/hazelcast/jet/core/Processor.java:592
↓ 6 callersMethodlocalSocketAddress
@return the local address. Returned value could be null
hazelcast/src/main/java/com/hazelcast/internal/networking/Channel.java:140
↓ 6 callersMethodlocateEverywhere
()
hazelcast/src/main/java/com/hazelcast/internal/config/AbstractConfigLocator.java:116
↓ 6 callersMethodlocateInWorkDirOrOnClasspath
()
hazelcast/src/main/java/com/hazelcast/internal/config/AbstractConfigLocator.java:123
↓ 6 callersMethodlog
(Throwable e, ILogger logger)
hazelcast/src/main/java/com/hazelcast/internal/partition/ReplicaErrorLogger.java:33
← previousnext →9,701–9,800 of 147,315, ranked by callers