MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

⨍ Functions 147,315◇ Types & classes 15,944
↓ 2 callersMethodpickMaxIdleMillis
Pick the right value for idleness expiry. @param mapConfig used to get configured maxIdleSeconds @param millisFromOperation user provided m
hazelcast/src/main/java/com/hazelcast/map/impl/ExpirationTimeSetter.java:69
↓ 2 callersMethodpickRightTimeInMillis
Have right expiry value by using mapConfig or operation provided values. @param secondsFromMapConfig expiry in seconds from map config @param millisF
hazelcast/src/main/java/com/hazelcast/map/impl/ExpirationTimeSetter.java:80
↓ 2 callersMethodpickTTLMillis
Pick the right value for TTL expiry. @param mapConfig used to get configured TTL seconds @param millisFromOperation user provided TTL durin
hazelcast/src/main/java/com/hazelcast/map/impl/ExpirationTimeSetter.java:58
↓ 2 callersMethodpingMemberIfRequired
Pings the {@code member} if ICMP is enabled and more than {@link #HEART_BEAT_INTERVAL_FACTOR} heartbeats have passed.
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterHeartbeatManager.java:577
↓ 2 callersMethodpingNotifiableEventListenerInternal
Notifies the object of an event in the lifecycle of the listener. The listener may have been registered or deregistered. The object must implement {@l
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/impl/EventServiceSegment.java:112
↓ 2 callersMethodpingSuccessfully
()
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/impl/AbstractSplitBrainProtectionFunctionTest.java:100
↓ 2 callersMethodpipeline
(StreamSource<ChangeRecord> source)
extensions/cdc-postgres/src/test/java/com/hazelcast/jet/cdc/postgres/PostgresCdcAuthAndConnectionIntegrationTest.java:82
↓ 2 callersMethodpipelineJson
(boolean asMap)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/ReadFilesPTest.java:207
↓ 2 callersMethodpk
(Column c)
hazelcast/src/test/java/com/hazelcast/test/jdbc/JdbcObjectProvider.java:86
↓ 2 callersMethodplainExternalName
Returns the external name of the field without {@code __key.} or {@code this.} prefix.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/schema/TypeUtils.java:354
↓ 2 callersMethodpnCounter
(int index)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/pncounter/PNCounterSplitBrainProtectionReadTest.java:71
↓ 2 callersMethodpodName
()
hazelcast/src/main/java/com/hazelcast/kubernetes/KubernetesApiEndpointResolver.java:169
↓ 2 callersMethodpojoType
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/inject/PojoUpsertTargetTest.java:208
↓ 2 callersMethodpoll
(long timeout, @Nonnull TimeUnit timeUnit)
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueProxyImpl.java:94
↓ 2 callersMethodpoll
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/PeekWrappedP.java:157
↓ 2 callersMethodpollBackup
Polls an item on the backup replica. The item ID is predetermined when executing the poll operation on the partition owner. Executed on the backup rep
hazelcast/src/main/java/com/hazelcast/collection/impl/queue/QueueContainer.java:598
↓ 2 callersMethodpop
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/typeinference/HazelcastReturnTypeInference.java:80
↓ 2 callersMethodpopInstreamGroup
()
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ProcessorTasklet.java:649
↓ 2 callersMethodpopulate
(LiveOperations liveOperations)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationparker/impl/OperationParkerImpl.java:88
↓ 2 callersMethodpopulate
(Collection<V> candidates, V candidate)
hazelcast/src/main/java/com/hazelcast/internal/util/graph/BronKerboschCliqueFinder.java:149
↓ 2 callersMethodpopulateAddressMap
(Map<ProtocolType, Collection<Address>> addressMap, boolean isWanHandshake)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/SendMemberHandshakeTask.java:98
↓ 2 callersMethodpopulateAndGetRecord
(Record writtenRecord, ExpiryMetadata expiryMetadata)
hazelcast/src/test/java/com/hazelcast/map/impl/record/RecordReaderWriterTest.java:85
↓ 2 callersMethodpopulateChildren
()
hazelcast/src/test/java/com/hazelcast/config/DefaultConfigValidationTest.java:137
↓ 2 callersMethodpopulateFields
(Object object, Collection<String> ignoredFields)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/init/JetInitDataSerializerHookTest.java:104
↓ 2 callersMethodpopulateIndexes
(PartitionMigrationEvent event, TargetIndexes targetIndexes, String stepName)
hazelcast/src/main/java/com/hazelcast/map/impl/MapMigrationAwareService.java:300
↓ 2 callersMethodpopulateLocalConveyorMap
(EdgeDef edge)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/init/ExecutionPlan.java:592
↓ 2 callersMethodpopulateMap
(Map<Integer, Integer> map)
hazelcast/src/test/java/com/hazelcast/replicatedmap/ReplicatedMapIterationServiceTest.java:133
↓ 2 callersMethodpopulateMap
(IMap<Integer, Integer> map, int numberOfItems)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindMapStoreWithEvictionsTest.java:287
↓ 2 callersMethodpopulateMapWithPersons
(IMap<Integer, Person> map, String postfix, int count)
hazelcast/src/test/java/com/hazelcast/aggregation/AggregatorsSpecTest.java:488
↓ 2 callersMethodpopulateReadersWriters
(Class<?> clazz)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/record/JavaRecordSerializer.java:101
↓ 2 callersMethodpopulateScheduledForHolder
(List<ScheduledTaskHandler> handlers, DistributedScheduledExecutorService service,
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/operations/AbstractGetAllScheduledOperation.java:38
↓ 2 callersMethodportableFactory
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/misc/SqlNoDeserializationTest.java:102
↓ 2 callersMethodports
(Integer... ports)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesFakeUtils.java:312
↓ 2 callersMethodposition
Returns this buffer's position.
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/ByteArrayObjectDataInput.java:646
↓ 2 callersMethodpow2
(long x)
hazelcast/src/main/java/com/hazelcast/internal/cluster/fd/PhiAccrualFailureDetector.java:230
↓ 2 callersMethodpowerOfTwo
(int x)
hazelcast/src/test/java/com/hazelcast/internal/util/QuickMathTest.java:98
↓ 2 callersMethodpreOptimizeInternal
(String sql, OptimizerContext context)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/OptimizerTestSupport.java:101
↓ 2 callersMethodprecision
()
hazelcast/src/test/java/com/hazelcast/cardinality/impl/hyperloglog/impl/HyperLogLogEncoderAbstractTest.java:45
↓ 2 callersMethodpredicate
(String indexName, CompositeValue from, boolean fromInclusive, CompositeValue to, boolean toInclusive,
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/CompositeRangePredicateTest.java:293
↓ 2 callersMethodpredicateIterator
(Predicate predicate, TypeConverter converter)
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/Bitmap.java:159
↓ 2 callersMethodpredicateIterators
(Predicate[] predicates, TypeConverter converter)
hazelcast/src/main/java/com/hazelcast/query/impl/bitmap/Bitmap.java:204
↓ 2 callersMethodpreferIPv6Addresses
()
hazelcast/src/main/java/com/hazelcast/instance/impl/DefaultAddressPicker.java:458
↓ 2 callersMethodprepare
(NodeEngine nodeEngine)
hazelcast/src/main/java/com/hazelcast/transaction/impl/TransactionLog.java:110
↓ 2 callersMethodprepareAndAppendReplicationOperation
(PartitionReplicationEvent event, Servi
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/AbstractPartitionOperation.java:355
↓ 2 callersMethodprepareAndRunQueryTasks
(boolean withIndexes)
hazelcast/src/test/java/com/hazelcast/map/QueryBounceTest.java:89
↓ 2 callersMethodprepareDefaultQueryCacheEventDataWithMapName
()
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/event/BatchEventDataTest.java:72
↓ 2 callersMethodprepareDuplicatedResult
(Object result)
hazelcast/src/test/java/com/hazelcast/jet/impl/client/protocol/task/AbstractJetMultiTargetMessageTaskTest.java:69
↓ 2 callersMethodprepareForNextCleanup
()
hazelcast/src/main/java/com/hazelcast/cache/impl/operation/CacheClearExpiredOperation.java:105
↓ 2 callersMethodprepareForNextCleanup
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/MapClearExpiredOperation.java:106
↓ 2 callersMethodprepareForReplication
Returns all task descriptors on this container, mapped by task name. @return a map of all tasks on this container
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainer.java:385
↓ 2 callersMethodprepareNotAllowedInCluster
()
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/AuthenticationBaseMessageTask.java:204
↓ 2 callersMethodprepareOperation
(Operation op)
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/MigrationOperation.java:142
↓ 2 callersMethodpreparePostJoinOp
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:897
↓ 2 callersMethodpreparePostOp
(Operation postOp)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/operations/FinalizeJoinOp.java:161
↓ 2 callersMethodpreparePreJoinOps
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterJoinManager.java:902
↓ 2 callersMethodprepareRegistration
(long jobId, JobStatusListener listener, boolean localOnly)
hazelcast/src/main/java/com/hazelcast/jet/impl/JobEventService.java:66
↓ 2 callersMethodprepareReplicationOperation
Returns a replication operation for the provided vector clocks. The vector clock map contains mappings from CRDT name to the last successfully replica
hazelcast/src/main/java/com/hazelcast/internal/crdt/CRDTReplicationAwareService.java:47
↓ 2 callersMethodprepareReplicationOperation
(PartitionReplicationEvent event, ServiceNamespace ns,
hazelcast/src/main/java/com/hazelcast/internal/partition/operation/AbstractPartitionOperation.java:342
↓ 2 callersMethodprepareServerAndGetServerMap
(String mapName, int keyInServerNearCache)
hazelcast/src/test/java/com/hazelcast/client/txn/ClientTxnMapTest.java:568
↓ 2 callersMethodprepareSingleColumnCandidate
Prepares an expression candidate for the given RexNode. <p> See method body for the details of supported expressions. @param exp expression @return c
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/index/IndexResolver.java:354
↓ 2 callersMethodprepareSingleResultMap
(Object result)
hazelcast/src/test/java/com/hazelcast/jet/impl/client/protocol/task/AbstractJetMultiTargetMessageTaskTest.java:64
↓ 2 callersMethodprepopulate
(InternalQueryCache queryCache, Collection<Map.Entry<Data, Data>> result)
hazelcast/src/main/java/com/hazelcast/client/map/impl/querycache/subscriber/ClientQueryCacheEndToEndConstructor.java:91
↓ 2 callersMethodprintAssignments
(Map<Address, List<IndexedInputSplit>> assigned)
extensions/hadoop/src/main/java/com/hazelcast/jet/hadoop/impl/ReadHdfsMetaSupplierBase.java:182
↓ 2 callersMethodprintMetadataInfo
(SqlRowMetadata metadata, int[] colWidths, Alignment[] alignments, P
hazelcast/src/main/java/com/hazelcast/client/console/SqlConsole.java:414
↓ 2 callersMethodprintRow
(SqlRow row, int[] colWidths, Alignment[] alignments, PrintWriter out)
hazelcast/src/main/java/com/hazelcast/client/console/SqlConsole.java:434
↓ 2 callersMethodprintScriptEngines
()
hazelcast/src/main/java/com/hazelcast/osgi/impl/OSGiScriptEngineManager.java:353
↓ 2 callersMethodprocess
(T t, U u)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1744
↓ 2 callersMethodprocess
(T t)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1846
↓ 2 callersMethodprocessEntryEventFilter
Evaluates filters of {@link EntryEventFilter} type. @param filter the filter which must be a {@link EntryEventFilter} @param dataKey the event entry
hazelcast/src/main/java/com/hazelcast/map/impl/event/AbstractFilteringStrategy.java:59
↓ 2 callersMethodprocessInbox
(TestInbox inbox, int inboxOrdinal, boolean isCooperative, Processor[] processor)
hazelcast/src/main/java/com/hazelcast/jet/core/test/TestSupport.java:889
↓ 2 callersMethodprocessInternal
(State state, Data key, Record record)
hazelcast/src/main/java/com/hazelcast/map/impl/operation/steps/PartitionWideEntryOpSteps.java:133
↓ 2 callersMethodprocessInternal
(List<DelayedEntry> delayedEntries)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/DefaultWriteBehindProcessor.java:73
↓ 2 callersMethodprocessItem
(@Nonnull T item)
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/AsyncTransformUsingServiceUnorderedP.java:200
↓ 2 callersMethodprocessMismatchingQueryNumber
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/jdbc/join/JoinPredicateScanRowMapper.java:173
↓ 2 callersMethodprocessPartitionState
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/operations/MembersUpdateOp.java:97
↓ 2 callersMethodprocessPid
(Process process)
extensions/python/src/main/java/com/hazelcast/jet/python/PythonServiceContext.java:246
↓ 2 callersMethodprocessSingle
(Object key, Object value, MapStore mapStore)
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/AbstractWriteBehindProcessor.java:86
↓ 2 callersMethodprocessStage2
( SlidingWindowP p, TestOutbox stage1p1Outbox, TestOutbox stage1p2Outbox, TestInbox inbox )
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SlidingWindowP_twoStageSnapshotTest.java:184
↓ 2 callersMethodprocessorCls
()
hazelcast/src/main/java/com/hazelcast/jet/impl/JobClassLoaderService.java:334
↓ 2 callersMethodprocessorMetaSupplier
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/file/Metadata.java:47
↓ 2 callersMethodproduceEventToNewPartition
()
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/StreamKafkaPTest.java:957
↓ 2 callersMethodproduceSomeStats
(HazelcastInstance hazelcastInstance, HazelcastClientInstanceImpl client)
hazelcast/src/test/java/com/hazelcast/client/statistics/ClientStatisticsTest.java:300
↓ 2 callersMethodproducer
(String key, int delayMs)
hazelcast/src/test/java/com/hazelcast/jet/impl/execution/WatermarkCoalescer_TerminalSnapshotTest.java:154
↓ 2 callersMethodprogress
Returns the current progress as a fractional number between 0 and 1. @return the progress
hazelcast/src/test/java/com/hazelcast/test/TaskProgress.java:41
↓ 2 callersMethodproject
(Object object)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/RowProjector.java:76
↓ 2 callersMethodprojection
(QueryParameterMetadata parameterMetadata)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/SelectByKeyMapPhysicalRel.java:98
↓ 2 callersMethodpromoteAndGetLocalMember
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:1072
↓ 2 callersMethodpromoteSuspended
Attempts to promote and schedule all suspended tasks on this partition. Exceptions throw during rescheduling will be rethrown and will prevent further
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorPartition.java:122
↓ 2 callersMethodpropagateDrainerFailure
(Throwable cause)
hazelcast/src/main/java/com/hazelcast/internal/util/concurrent/ConcurrentConveyor.java:407
↓ 2 callersMethodproperties
(KafkaTestSupport kafkaTestSupport)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/KafkaDataConnectionTest.java:250
↓ 2 callersMethodproperties
@return Returns an immutable set of key-value configuration entries.
hazelcast/src/main/java/com/hazelcast/internal/config/override/ConfigProvider.java:28
↓ 2 callersMethodprovideMemberChannelInitializer
(EndpointConfig endpointConfig)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/ChannelInitializerFunction.java:112
↓ 2 callersMethodprovideMetrics
(Node node, MetricsCollectionContext context)
hazelcast/src/main/java/com/hazelcast/internal/util/phonehome/CloudInfoProvider.java:52
↓ 2 callersMethodprovideMetrics
Metrics collection callback that is called in every metrics collection cycle. The collected metrics should be passed to the {@link MetricsCollectionCo
hazelcast/src/main/java/com/hazelcast/internal/util/phonehome/MetricsProvider.java:57
↓ 2 callersMethodprovideTextChannelInitializer
(EndpointConfig endpointConfig, boolean rest)
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/ChannelInitializerFunction.java:120
↓ 2 callersMethodpublishCollectedMetrics
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/PublisherMetricsCollector.java:39
↓ 2 callersMethodpublishCompletedMigrations
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:774
↓ 2 callersMethodpublishEventInternal
(EventRegistration registration, Object eventData, int orderKey)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/NodeQueryCacheEventService.java:222
↓ 2 callersMethodpublishEventInternal
(Collection<EventRegistration> registrations, Object eventData, int orderKey)
hazelcast/src/main/java/com/hazelcast/map/impl/event/MapEventPublisherImpl.java:355
↓ 2 callersMethodpublishInternal
Publishes the message and increases the local statistics for the number of published messages. @param message the message to be published
hazelcast/src/main/java/com/hazelcast/topic/impl/TopicProxySupport.java:97
← previousnext →20,201–20,300 of 147,315, ranked by callers