MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 5 callersMethodnameWithoutSchema
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/parse/SqlCreateMapping.java:91
↓ 5 callersMethodnegate
Create logical negation of itself. @return A predicate which is a logical negation of itself.
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/NegatablePredicate.java:32
↓ 5 callersMethodnewAddress
()
hazelcast/src/test/java/com/hazelcast/internal/util/LockGuardTest.java:117
↓ 5 callersMethodnewChainingFuture
(CountingIterator<InternalCompletableFuture<T>> iterator, ChainingFuture.ExceptionHandler handler)
hazelcast/src/test/java/com/hazelcast/internal/util/futures/ChainingFutureTest.java:192
↓ 5 callersMethodnewChunkSupplier
By default, a {@link ChunkedMigrationAwareService} behaves identical with a {@link FragmentedMigrationAwareService}. <p> In other words, a chunk equal
hazelcast/src/main/java/com/hazelcast/internal/partition/ChunkedMigrationAwareService.java:57
↓ 5 callersMethodnewClientConfig
()
hazelcast/src/test/java/com/hazelcast/client/impl/management/ClientConnectionProcessListenerTest.java:63
↓ 5 callersMethodnewCompleteCacheConfig
(String name)
hazelcast/src/test/java/com/hazelcast/config/helpers/CacheConfigHelper.java:61
↓ 5 callersMethodnewConfig
(String mergePolicy, String mapName)
hazelcast/src/test/java/com/hazelcast/map/MergePolicyTest.java:269
↓ 5 callersMethodnewConfig
(String mapName, boolean sizeLimited, MapStoreConfig.InitialLoadMode loadMode)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapStoreEvictionTest.java:213
↓ 5 callersMethodnewLog
(Diagnostics diagnostics)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:582
↓ 5 callersMethodnewOutbox
()
hazelcast/src/test/java/com/hazelcast/jet/impl/processor/SlidingWindowP_twoStageSnapshotTest.java:201
↓ 5 callersMethodnewProbabilisticSplitBrainProtectionConfigBuilder
Returns a builder for {@link SplitBrainProtectionConfig} with the given {@code name} using a probabilistic split brain protection function, for the gi
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfig.java:238
↓ 5 callersMethodnewRecentlyActiveSplitBrainProtectionConfigBuilder
Returns a builder for a {@link SplitBrainProtectionConfig} with the given {@code name} using a recently-active split brain protection function for the
hazelcast/src/main/java/com/hazelcast/config/SplitBrainProtectionConfig.java:253
↓ 5 callersMethodnewRecord
(Data key, Object value)
hazelcast/src/main/java/com/hazelcast/map/impl/record/RecordFactory.java:28
↓ 5 callersMethodnewRepairingTask
(Config config)
hazelcast/src/test/java/com/hazelcast/internal/nearcache/impl/invalidation/RepairingTaskTest.java:95
↓ 5 callersMethodnewStreamPipeline
()
hazelcast/src/test/java/com/hazelcast/jet/impl/JobSummaryTest.java:306
↓ 5 callersMethodnextAddress
()
hazelcast/src/test/java/com/hazelcast/test/TestHazelcastInstanceFactory.java:279
↓ 5 callersMethodnextId
()
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapContainer.java:102
↓ 5 callersMethodnot
(Boolean value)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/NotPredicateIntegrationTest.java:143
↓ 5 callersMethodnot
Negates the given boolean value. @param value the value to negate. @return {@code true} if the passed value was {@code false}, {@code false} if it wa
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/TernaryLogic.java:108
↓ 5 callersMethodnotifyListeners
()
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/MapStoreWriteBehindTest.java:708
↓ 5 callersMethodobjectKey
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/SinkMapPhysicalRel.java:68
↓ 5 callersMethodof
(EvictionConfig config, SerializationService serializationService)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/dynamicconfig/EvictionConfigHolder.java:83
↓ 5 callersMethodofferToEdgesAndSnapshot
(Object item)
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/OutboxImpl.java:257
↓ 5 callersMethodoffloadedOperation
Returns the Operation that created this Offload. Returned operation should not be null. <p> Currently, this is used to automatically register the oper
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Offload.java:98
↓ 5 callersMethodonConnectionClose
This will be called on each connection close. Note that is different from {@link ConnectionListener#connectionRemoved(Connection)} where `connectionRe
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientInvocationService.java:92
↓ 5 callersMethodonEntryEvent
This method is called when one of the methods of the {@link com.hazelcast.core.EntryListener} is not overridden. It can be practical if you want to bu
hazelcast/src/main/java/com/hazelcast/core/EntryAdapter.java:72
↓ 5 callersMethodonMigrationComplete
(MigrationParticipant participant, MigrationInfo migration, boolean success)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationInterceptor.java:44
↓ 5 callersMethodonPartitionChange
(PartitionIndexChangeEvent changeEvent)
hazelcast/src/main/java/com/hazelcast/internal/monitor/impl/PerIndexStats.java:170
↓ 5 callersMethodonPartitionLost
(IPartitionLostEvent event)
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/InternalPartitionServiceImpl.java:1279
↓ 5 callersMethodonPartitionLost
(IPartitionLostEvent partitionLostEvent)
hazelcast/src/main/java/com/hazelcast/map/impl/MapService.java:225
↓ 5 callersMethodonPossibleAddressesCollected
Calls {@link ClientConnectionProcessListener#possibleAddressesCollected(List)} on all listeners, after converting the given collection to a list.
hazelcast/src/main/java/com/hazelcast/client/impl/management/ClientConnectionProcessListenerRegistry.java:100
↓ 5 callersMethodonRemove
Called when an entry is removed. @param key the key @param value the old value
hazelcast/src/main/java/com/hazelcast/cache/impl/CacheRSMutationObserver.java:42
↓ 5 callersMethodonTouched
()
hazelcast/src/main/java/com/hazelcast/map/impl/operation/EntryOperator.java:421
↓ 5 callersMethodonTryToConnectNextCluster
Resets the cluster snapshot back to the initial state.
hazelcast/src/main/java/com/hazelcast/client/impl/spi/ClientClusterService.java:151
↓ 5 callersMethodongoingSnapshotId
ID for the ongoing or the next snapshot. The value is incremented each time we attempt a new snapshot.
hazelcast/src/main/java/com/hazelcast/jet/impl/JobExecutionRecord.java:231
↓ 5 callersMethodopen
(String name, Object... attributes)
hazelcast/src/main/java/com/hazelcast/config/ConfigXmlGenerator.java:1340
↓ 5 callersMethodoptional
Defines if this property is optional or not. Optional properties don't have to be set inside the configuration but if set they need to pass a possibly
hazelcast/src/main/java/com/hazelcast/config/properties/PropertyDefinition.java:70
↓ 5 callersMethodoptionsIf
(boolean condition, Object... options)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:968
↓ 5 callersMethodotherClassFilter
()
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/ReflectiveCompactSerializerTest.java:148
↓ 5 callersMethodoutputThreadCount
(int outputThreadCount)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioNetworking.java:565
↓ 5 callersMethodownerAddTaskAndWakeup
Adds a task to be executed on the {@link NioThread owner}. <p> This task is scheduled on the task queue of the owning {@link NioThread}. <p> If the pi
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioPipeline.java:184
↓ 5 callersMethodpackages
(PackageAccessRequirement... requirements)
hazelcast/src/main/java/com/hazelcast/internal/util/ModularJavaUtils.java:170
↓ 5 callersMethodparameterMetadata
()
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/SqlPlanImpl.java:1555
↓ 5 callersMethodparametrize
Parametrises queries replacing underscore to underscore_collection_type. e.g. limb_[0], may be replaced to limb_array[0] or limb_list[0]. Of course th
hazelcast/src/test/java/com/hazelcast/query/impl/extractor/AbstractExtractionSpecification.java:125
↓ 5 callersMethodparse
(Properties properties)
hazelcast/src/main/java/com/hazelcast/internal/util/JavaVm.java:37
↓ 5 callersMethodparseDelimitedString
(String value, char delimiter)
hazelcast-build-utils/src/main/java/com/hazelcast/buildutils/ElementParser.java:39
↓ 5 callersMethodparseJsonResponse
(JsonValue jsonValue, boolean tpcEnabled)
hazelcast/src/main/java/com/hazelcast/client/impl/spi/impl/discovery/HazelcastCloudDiscovery.java:115
↓ 5 callersMethodparseSqlDate
(final String value)
hazelcast/src/main/java/com/hazelcast/query/impl/DateHelper.java:55
↓ 5 callersMethodparseTimeStamp
(final String value)
hazelcast/src/main/java/com/hazelcast/query/impl/DateHelper.java:46
↓ 5 callersMethodpartitionIndexed
(int partition)
hazelcast/src/main/java/com/hazelcast/query/impl/GlobalIndexPartitionTracker.java:106
↓ 5 callersMethodpartitions
()
hazelcast/src/main/java/com/hazelcast/map/impl/query/Target.java:53
↓ 5 callersMethodpath
(String... fileNames)
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/ClassPathFormattingTest.java:30
↓ 5 callersMethodpeek
Retrieves, but does not remove, the head of this queue, or returns {@code null} if this queue is empty. @return the head of this queue, or {@code nul
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindQueue.java:53
↓ 5 callersMethodperformPrepareWithXa
(XAResource xaResource)
hazelcast/src/test/java/com/hazelcast/xa/HazelcastXACompatibilityTest.java:129
↓ 5 callersMethodpickLoopbackAddress
(String host)
hazelcast/src/main/java/com/hazelcast/instance/impl/DefaultAddressPicker.java:348
↓ 5 callersMethodpingNotifiableEventListener
Notifies the registration of a event in the listener lifecycle. The registration is checked for a {@link NotifiableEventListener} in this order : <ul>
hazelcast/src/main/java/com/hazelcast/spi/impl/eventservice/impl/EventServiceSegment.java:90
↓ 5 callersMethodpollAdded
Polls the queue and return an added shard, if the next item is an added shard. Returns null if the next item is an expired shard or if there's no next
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardQueue.java:43
↓ 5 callersMethodpollExpired
Polls the queue and return an expired shard, if the next item is an expired shard. Returns null if the next item is an added shard or if there's no ne
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardQueue.java:53
↓ 5 callersMethodpooledDataSource
(JdbcDataConnection dataConnection)
hazelcast/src/test/java/com/hazelcast/dataconnection/impl/JdbcDataConnectionTest.java:261
↓ 5 callersMethodpopulateFullyConnectedGraph
(List<String> vertices)
hazelcast/src/test/java/com/hazelcast/internal/util/graph/BronKerboschCliqueFinderTest.java:328
↓ 5 callersMethodpopulateMap
()
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/MemberPruningTest.java:167
↓ 5 callersMethodpopulateMap
(Map<Object, Object> map)
hazelcast/src/test/java/com/hazelcast/jet/impl/connector/HazelcastRemoteConnectorTest.java:313
↓ 5 callersMethodpopulateMap
(IMap<String, Double> map)
hazelcast/src/test/java/com/hazelcast/aggregation/MapAggregateTest.java:125
↓ 5 callersMethodpopulateMapWithPersons
(IMap<String, Person> map)
hazelcast/src/test/java/com/hazelcast/aggregation/MapAggregateTest.java:178
↓ 5 callersMethodpopulateMemberCache
()
hazelcast/src/test/java/com/hazelcast/client/cache/impl/nearcache/ClientCacheNearCacheInvalidationTest.java:492
↓ 5 callersMethodprepareSimpleCleanupSh
(String baseDirStr, String outcomeFilename)
extensions/python/src/test/java/com/hazelcast/jet/python/PythonInitCleanupTest.java:360
↓ 5 callersMethodprintMemberList
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:810
↓ 5 callersMethodproject
(JetSqlRow row, int[] indices)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/ObjectArrayKey.java:87
↓ 5 callersMethodproject
(Object key, Object value)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvRowProjector.java:99
↓ 5 callersMethodproject
(JetSqlRow row)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/connector/keyvalue/KvProjector.java:87
↓ 5 callersMethodproperties
()
hazelcast/src/test/java/com/hazelcast/test/jdbc/TestDatabaseProvider.java:101
↓ 5 callersMethodpropertiesByInstanceName
Create the {@link java.util.Properties} with the provided instance name. @param instanceName the instance name to configure @return the properties in
hazelcast/src/main/java/com/hazelcast/cache/HazelcastCachingProvider.java:230
↓ 5 callersMethodput
(String key, Object value)
hazelcast/src/test/java/com/hazelcast/query/PortablePredicatesTest.java:104
↓ 5 callersMethodput
(HazelcastInstance instance, Integer key, Integer value)
hazelcast/src/test/java/com/hazelcast/jet/pipeline/AbstractJournalLostEventTest.java:153
↓ 5 callersMethodput
(K key, V value)
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:52
↓ 5 callersMethodput
(final Long key, final V value)
hazelcast/src/main/java/com/hazelcast/internal/util/collection/Long2ObjectHashMap.java:200
↓ 5 callersMethodputAll
Puts all supplied transactions capacity counts into this counter. @param reservedCapacityPerTxnId reserved capacity counts per txnId
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/TxnReservedCapacityCounter.java:84
↓ 5 callersMethodputAllToList
(Collection<Map.Entry<Data, Data>> targetList)
hazelcast/src/main/java/com/hazelcast/map/impl/MapEntries.java:96
↓ 5 callersMethodputDummyData
(IMap<String, String> map, int size)
hazelcast/src/test/java/com/hazelcast/map/ListenerTest.java:235
↓ 5 callersMethodputFromLoadInternal
(Data key, Object newValue, long ttl, long maxIdle, Address callerAddre
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/DefaultRecordStore.java:1283
↓ 5 callersMethodputIfAbsent
Adds a new {@link AccumulatorInfo} for the query-cache of {@code IMap}. @param mapName map name. @param cacheId cache name.
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/AccumulatorInfoSupplier.java:42
↓ 5 callersMethodputIfAbsent
Transactional implementation of {@link IMap#putIfAbsent(Object, Object)}. <p> The object to be put will be accessible only in the current transaction
hazelcast/src/main/java/com/hazelcast/transaction/TransactionalMap.java:166
↓ 5 callersMethodputIfAbsentInternal
(Object key, Data value, long ttl, TimeUnit ttlUnit,
hazelcast/src/main/java/com/hazelcast/map/impl/proxy/MapProxySupport.java:478
↓ 5 callersMethodputInt
(byte[] name, int value)
hazelcast/src/main/java/com/hazelcast/internal/ascii/memcache/StatsCommand.java:84
↓ 5 callersMethodputInternal
(Data key, Data value, long ttl, TimeUnit timeUnit, RemoteCallHook hook)
hazelcast/src/main/java/com/hazelcast/map/impl/tx/TransactionalMapProxySupport.java:237
↓ 5 callersMethodputOrderedObject
Puts the given referenced object as ordered to the CPU write buffer based by the given owner object at the given offset. @param address address to a
hazelcast/src/main/java/com/hazelcast/internal/memory/ConcurrentMemoryAccessor.java:216
↓ 5 callersMethodqueryOurInstances
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/jmx/JmxPublisherTestHelper.java:116
↓ 5 callersMethodquote
(String text)
hazelcast/src/main/java/com/hazelcast/internal/jmx/ManagementService.java:201
↓ 5 callersMethodrandomEntryFrom
(String mapName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/map/SqlPortableTest.java:702
↓ 5 callersMethodrandomList
(int size)
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/RingbufferAbstractTest.java:127
↓ 5 callersMethodread
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/LongGaugeImpl.java:113
↓ 5 callersMethodread
(int position)
hazelcast/src/main/java/com/hazelcast/internal/nio/BufferObjectDataInput.java:29
↓ 5 callersMethodreadArrayOfBoolean
Reads an array of booleans. <p> This method can also read an array of nullable booleans, as long as it does not contain {@code null} values. If a {@co
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:308
↓ 5 callersMethodreadArrayOfInt32
Reads an array of 32-bit two's complement signed integers. <p> This method can also read an array of nullable int32s, as long as it does not contain {
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:362
↓ 5 callersMethodreadArrayOfInt64
Reads an array of 64-bit two's complement signed integers. <p> This method can also read an array of nullable int64s, as long as it does not contain {
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:380
↓ 5 callersMethodreadCompact
Reads a compact object @param fieldName name of the field. @return the value of the field. @throws HazelcastSerializationException if the field
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:290
↓ 5 callersMethodreadFloat32
Reads a 32-bit IEEE 754 floating point number. <p> This method can also read a nullable float32, as long as it is not {@code null}. If a {@code null}
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:172
↓ 5 callersMethodreadFloat64
Reads a 64-bit IEEE 754 floating point number. <p> This method can also read a nullable float64, as long as it is not {@code null}. If a {@code null}
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactReader.java:189
↓ 5 callersMethodreadGenericRecord
(BufferObjectDataInput input, Schema schema, boolean schemaIncludedInBinary)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/CompactStreamSerializer.java:302
← previousnext →11,001–11,100 of 147,315, ranked by callers