MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 11 callersMethodisMemberSuspected
(MemberImpl member)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java:515
↓ 11 callersMethodisNumericIntegerType
@return {@code true} if the given type is an integer type, {@code false} otherwise. <p> Integer types are: TINYINT, SMALLINT, INTEGER and BIGINT.
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastTypeUtils.java:239
↓ 11 callersMethodisOwnerOrBackup
Checks if given address is owner of primary or backup of this partition. @param address owner address @return {@code true} if address is owner or bac
hazelcast/src/main/java/com/hazelcast/internal/partition/IPartition.java:100
↓ 11 callersMethodisPopulate
Returns {@code true} if initial population of {@code QueryCache} is enabled, otherwise returns {@code false}. <p> Default value is {@value #DEFAULT_PO
hazelcast/src/main/java/com/hazelcast/config/QueryCacheConfig.java:327
↓ 11 callersMethodisRegistered
(String cacheManagerName, String name, boolean stats)
hazelcast/src/main/java/com/hazelcast/cache/impl/MXBeanUtil.java:66
↓ 11 callersMethodisRunAllowed
Returns true if the given operation is allowed to run on the calling thread, false otherwise. If this method returns true, then the operation can be e
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationService.java:447
↓ 11 callersMethodisShared
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/dataconnection/DataConnectionCatalogEntry.java:76
↓ 11 callersMethodisWindows
@return {@code true} if the current system is a Windows one.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/util/OS.java:158
↓ 11 callersMethoditem
Returns the item.
hazelcast/src/main/java/com/hazelcast/jet/datamodel/TimestampedItem.java:49
↓ 11 callersMethoditerator
()
hazelcast/src/main/java/com/hazelcast/spi/partitiongroup/MemberGroup.java:37
↓ 11 callersMethodjobNameAndExecutionId
(String jobName, long executionId)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:368
↓ 11 callersMethodkafkaMapping
(String name)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/kafka/SqlJsonTest.java:48
↓ 11 callersMethodliteral
(C left, C right, SqlTypeName typeName)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/physical/visitor/RexToExpressionTest.java:182
↓ 11 callersMethodload
Populates Hazelcast {@link ClientFailoverConfig} object from an external configuration file. <p> It tries to load Hazelcast Failover Client configurat
hazelcast/src/main/java/com/hazelcast/client/config/ClientFailoverConfig.java:72
↓ 11 callersMethodlog
(String msg)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/writebehind/MapStoreWriteBehindTest.java:682
↓ 11 callersMethodlookupClassDefinition
(int factoryId, int classId, int version)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableContext.java:37
↓ 11 callersMethodmapPut
(String mapName, String key, String value)
hazelcast/src/test/java/com/hazelcast/internal/ascii/HTTPCommunicator.java:247
↓ 11 callersMethodmemoizeConcurrent
(Supplier<T> onceSupplier)
hazelcast/src/main/java/com/hazelcast/jet/impl/util/Util.java:161
↓ 11 callersMethodmerge
Attaches a stage that emits all the items from this stage as well as all the items from the supplied stage. The other stage's type parameter must be a
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:247
↓ 11 callersMethodmerge
Merges the given {@link MapMergeTypes} via the given {@link SplitBrainMergePolicy}. @param mergingEntry the {@link MapMergeTypes} instance to merge @
hazelcast/src/main/java/com/hazelcast/map/impl/recordstore/RecordStore.java:283
↓ 11 callersMethodmetadataQuery
(RelNode rel)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/OptUtils.java:269
↓ 11 callersMethodmetricString
Returns a textual representation of this descriptor. <p> Note: The excluded targets are not part of the textual representation of the metric returned
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricDescriptor.java:186
↓ 11 callersMethodmetricString
()
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricDescriptorImpl.java:212
↓ 11 callersMethodmetrics
Return the {@link AsyncSocketMetrics} of this AsyncSocket. <p/> This call can always be made no matter the state of the socket. @return the metrics.
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/net/AsyncSocket.java:48
↓ 11 callersMethodnewAddress
(int port)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/MemberMapTest.java:389
↓ 11 callersMethodnewBuilderWithClone
Returned {@link GenericRecordBuilder} can be used to have exact copy and also just to update a couple of fields. By default, it will copy all the fiel
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecord.java:133
↓ 11 callersMethodnewClientConfig
()
hazelcast/src/test/java/com/hazelcast/client/TcpClientConnectionTest.java:362
↓ 11 callersMethodnewConfig
(String mapName, MapStoreConfig.InitialLoadMode loadMode)
hazelcast/src/test/java/com/hazelcast/map/impl/mapstore/MapLoaderMultiNodeTest.java:152
↓ 11 callersMethodnewConfig
()
hazelcast/src/test/java/com/hazelcast/cluster/SplitMergeTest.java:186
↓ 11 callersMethodnewInvalidationEnabledNearCacheConfig
()
hazelcast/src/test/java/com/hazelcast/client/map/impl/nearcache/ClientMapNearCacheTest.java:1192
↓ 11 callersMethodnext
()
hazelcast/src/main/java/com/hazelcast/jet/impl/util/FlatMappingTraverser.java:33
↓ 11 callersMethodnextCallId
(CallIdSequence seq, boolean isUrgent)
hazelcast/src/test/java/com/hazelcast/spi/impl/sequence/CallIdSequenceWithBackpressureTest.java:145
↓ 11 callersMethodor
Performs OR for the given operands acting on the given row in the given context. <p> The method exhibits a short-circuiting behaviour: there is no gua
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/predicate/TernaryLogic.java:83
↓ 11 callersMethodpartitions
(List<Member> members)
hazelcast/src/test/java/com/hazelcast/internal/partition/impl/MigrationManagerTest.java:218
↓ 11 callersMethodpassword
Password to authenticate
hazelcast/src/test/java/com/hazelcast/test/jdbc/TestDatabaseProvider.java:65
↓ 11 callersMethodpaths
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/map/PartitionedMapTable.java:116
↓ 11 callersMethodpeekInputP
Returns a meta-supplier that wraps the provided one and adds a logging layer to each processor it creates. For each item the wrapped processor removes
hazelcast/src/main/java/com/hazelcast/jet/core/processor/DiagnosticProcessors.java:149
↓ 11 callersMethodpermission
Sets the permission required to use this sink when the security is enabled. The default value is {@code null} which means there is no restriction to u
hazelcast/src/main/java/com/hazelcast/jet/pipeline/SinkBuilder.java:182
↓ 11 callersMethodpopulate
Populate the LiveOperations @param liveOperations the LiveOperations to populate.
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/LiveOperationsTracker.java:34
↓ 11 callersMethodprepareBinding
(SqlCallBinding binding)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/operators/common/HazelcastOperandTypeCheckerAware.java:47
↓ 11 callersMethodprocessJobMultipart
Process the part message for the job upload @param parameterObject specified message from client @return JobMetaDataParameterObject if upload is comp
hazelcast/src/main/java/com/hazelcast/jet/impl/submitjob/memberside/JobUploadStore.java:92
↓ 11 callersMethodpublishAll
Publishes all messages to all subscribers of this topic. @param messages the messages to publish to all subscribers of this topic @throws TopicOverlo
hazelcast/src/main/java/com/hazelcast/topic/ITopic.java:118
↓ 11 callersMethodpublishWanUpdate
Notifies the WAN subsystem of a map update on a replica owner. @param mapName the map name @param entryView the updated entry @para
hazelcast/src/main/java/com/hazelcast/map/impl/event/MapEventPublisher.java:44
↓ 11 callersMethodputIntoMap
(Map<String, String> map, int notFilterOutItemsCount, int filterOutItemsCount)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetrics_StreamTest.java:337
↓ 11 callersMethodquote
Quotes given compound identifier using the {@link #databaseProvider}
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/connector/jdbc/JdbcSqlTestSupport.java:115
↓ 11 callersMethodrandomPartitionId
()
hazelcast/src/test/java/com/hazelcast/map/AbstractMapQueryIterableTest.java:245
↓ 11 callersMethodreadChar
(int position)
hazelcast/src/main/java/com/hazelcast/internal/nio/BufferObjectDataInput.java:47
↓ 11 callersMethodreadLongL
(byte[] buffer, int pos)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:187
↓ 11 callersMethodrecomputeWithBaseTime
(int seconds)
hazelcast/src/main/java/com/hazelcast/internal/util/TimeStripUtil.java:66
↓ 11 callersMethodregisterServer
(HazelcastInstance instance)
hazelcast/src/main/java/com/hazelcast/instance/impl/OutOfMemoryErrorDispatcher.java:71
↓ 11 callersMethodremoveAll
()
hazelcast/src/main/java/com/hazelcast/internal/adapter/DataStructureAdapter.java:126
↓ 11 callersMethodremoveDistributedObjectListener
Removes the specified Distributed Object listener. Returns silently if the specified instance listener does not exist. @param registrationId ID of li
hazelcast/src/main/java/com/hazelcast/core/HazelcastInstance.java:312
↓ 11 callersMethodremoveHash
Removes a hash from the accumulated hash of a tree node <p> Notes: <ul> <li>The hash function must be associative. For the detailed reasoning see {@li
hazelcast/src/main/java/com/hazelcast/wan/impl/merkletree/MerkleTreeUtil.java:146
↓ 11 callersMethodremoveInterceptor
Removes the given interceptor for this map, so it will not intercept operations anymore. @param id registration ID of the map interceptor @return {@c
hazelcast/src/main/java/com/hazelcast/map/IMap.java:2217
↓ 11 callersMethodreplicas
Returns the internal replica array of this partition. Callers should not modify this array.
hazelcast/src/main/java/com/hazelcast/internal/partition/AbstractInternalPartition.java:38
↓ 11 callersMethodresetClock
()
hazelcast/src/test/java/com/hazelcast/internal/util/AbstractClockTest.java:96
↓ 11 callersMethodresolveEc2Endpoint
(AwsConfig awsConfig, String region)
hazelcast/src/main/java/com/hazelcast/aws/AwsClientConfigurator.java:115
↓ 11 callersMethodresolveTypeForClass
(Class<?> clazz)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataTypeUtils.java:187
↓ 11 callersMethodrestoreSnapshotFn
Sets the function that restores the source's state from a snapshot. <p> When Jet is restarting a job after it was interrupted (failure or other reason
hazelcast/src/main/java/com/hazelcast/jet/pipeline/SourceBuilder.java:749
↓ 11 callersMethodrethrowGuardianException
(Throwable t)
hazelcast/src/test/java/com/hazelcast/test/starter/HazelcastStarterUtils.java:48
↓ 11 callersMethodretrieveCache
(HazelcastInstance instance, boolean getCache)
hazelcast/src/test/java/com/hazelcast/cache/instance/CacheThroughHazelcastInstanceTest.java:402
↓ 11 callersMethodrollingAggregate
(@Nonnull AggregateOperation1<? super T, A, ? extends R> aggrOp)
hazelcast/src/main/java/com/hazelcast/jet/pipeline/BatchStage.java:141
↓ 11 callersMethodrunOrExecute
Tries to run the {@link Operation} on the calling thread if allowed. Otherwise the operation is submitted for executing using {@link #execute(Operatio
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/OperationExecutor.java:160
↓ 11 callersMethodrunWithHazelcast
(GlobalMixin global, boolean retryClusterConnectForever, ConsumerEx<Hazelcas
hazelcast/src/main/java/com/hazelcast/client/console/HazelcastCommandLine.java:446
↓ 11 callersMethodscheduleAtFixedRate
Schedules a publisher to be executed at a fixed rate. Probably this method will be removed in the future, but we need a mechanism for complex gauges
hazelcast/src/main/java/com/hazelcast/internal/metrics/MetricsRegistry.java:290
↓ 11 callersMethodscheduleExpirationTask
Starts 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:83
↓ 11 callersMethodset
Sets the item at the given sequence. The method allows {@code null} data. @param seq the target sequence @param data the data to be set
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/Ringbuffer.java:173
↓ 11 callersMethodset
Sets the value as given.
hazelcast/src/main/java/com/hazelcast/jet/accumulator/LongAccumulator.java:51
↓ 11 callersMethodsetAge
(int age)
hazelcast/src/test/java/com/hazelcast/map/impl/querycache/utils/Employee.java:74
↓ 11 callersMethodsetComparator
Sets the instance of the configured {@link EvictionPolicyComparator} implementation. <p> Only one of the {@code comparator class name} and {@code comp
hazelcast/src/main/java/com/hazelcast/config/EvictionConfig.java:233
↓ 11 callersMethodsetCompleteError
(SupplierEx<? extends Throwable> completeError)
hazelcast/src/test/java/com/hazelcast/jet/core/TestProcessors.java:469
↓ 11 callersMethodsetConfig
Sets diagnostics config on the service. The new config will take an effect immediately. Please note that if there is diagnostics config provided over
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/Diagnostics.java:436
↓ 11 callersMethodsetConnectionCount
Sets the number of connections to TPC ports offered by a Hazelcast member. <ol> <li>If set to a negative value, an IllegalArgumentException will
hazelcast/src/main/java/com/hazelcast/client/config/ClientTpcConfig.java:108
↓ 11 callersMethodsetDataPersistenceConfig
Sets the {@code DataPersistenceConfig} for this {@code MapConfig} @param dataPersistenceConfig dataPersistenceConfig config @return this {@code MapCo
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:737
↓ 11 callersMethodsetFieldValueReflectively
(Object arg, String fieldName, Object newValue)
hazelcast/src/test/java/com/hazelcast/test/starter/ReflectionUtils.java:142
↓ 11 callersMethodsetFlag
(boolean value, int bitmask)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/Operation.java:629
↓ 11 callersMethodsetFloat32
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:266
↓ 11 callersMethodsetFloat64
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:291
↓ 11 callersMethodsetFsync
Sets whether disk write should be followed by an {@code fsync()} system call. @return this HotRestartConfig
hazelcast/src/main/java/com/hazelcast/config/HotRestartConfig.java:86
↓ 11 callersMethodsetGlobalOrderingEnabled
Enable global ordering (all nodes listening to the same topic get their messages in the same order), or disable it (nodes get the messages in the orde
hazelcast/src/main/java/com/hazelcast/config/TopicConfig.java:127
↓ 11 callersMethodsetHostHeader
(String hostHeader)
hazelcast/src/main/java/com/hazelcast/aws/AwsConfig.java:266
↓ 11 callersMethodsetHotRestartConfig
Sets the {@code HotRestartConfig} for this {@code MapConfig} @param hotRestartConfig hot restart config @return this {@code MapConfig} instance @dep
hazelcast/src/main/java/com/hazelcast/config/MapConfig.java:723
↓ 11 callersMethodsetIncludeEpochTime
Configures if the epoch time should be included in the 'top' section. This makes it easy to determine the time in epoch format and prevents needing to
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/DiagnosticsConfig.java:237
↓ 11 callersMethodsetInvocationTime
Sets the invocation time for the Operation. @param op the Operation that is updated for its invocation time. @param invocationTime the new invocation
hazelcast/src/main/java/com/hazelcast/spi/impl/operationservice/OperationAccessor.java:68
↓ 11 callersMethodsetJobName
(String jobName)
hazelcast/src/main/java/com/hazelcast/jet/impl/SubmitJobParameters.java:107
↓ 11 callersMethodsetMaxProcessorAccumulatedRecords
Sets the maximum number of records that can be accumulated by any single {@link Processor} instance. <p> Operations like grouping, sorting or joining
hazelcast/src/main/java/com/hazelcast/jet/config/JetConfig.java:261
↓ 11 callersMethodsetName
Sets the name of this {@link com.hazelcast.cache.ICache}. @param name the name to set for this {@link com.hazelcast.cache.ICache} @return the current
hazelcast/src/main/java/com/hazelcast/config/CacheConfig.java:243
↓ 11 callersMethodsetNormalPacketsRead
(Counter normalPacketsRead)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/InboundHandlerWithCounters.java:35
↓ 11 callersMethodsetNullableInt64
It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t
hazelcast/src/main/java/com/hazelcast/nio/serialization/genericrecord/GenericRecordBuilder.java:422
↓ 11 callersMethodsetOrAdd
(List tokens, int position, Predicate predicate)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/SqlPredicate.java:309
↓ 11 callersMethodsetPartitionId
(ReplicatedMap<String, String> map, int partitionId)
hazelcast/src/test/java/com/hazelcast/client/replicatedmap/DummyClientReplicatedMapTest.java:266
↓ 11 callersMethodsetPreserveOrder
Tells Jet whether or not it is allowed to reorder the events for better performance. Enabling this property adds restrictions to the internal data flo
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Pipeline.java:83
↓ 11 callersMethodsetReadBatchSize
()
hazelcast/src/test/java/com/hazelcast/config/ReliableTopicConfigTest.java:125
↓ 11 callersMethodsetSystemProperty
Sets or removes a system property. <p> When the value is {@code null}, the system property will be removed. <p> Avoids a {@link NullPointerException}
hazelcast/src/test/java/com/hazelcast/instance/impl/TestUtil.java:265
↓ 11 callersMethodsetTimeout
Sets the timeout. <p> The timeout determines the maximum lifespan of a transaction. So if a transaction is configured with a timeout of 2 minutes, the
hazelcast/src/main/java/com/hazelcast/transaction/TransactionOptions.java:107
↓ 11 callersMethodsetTypeClassName
This method is called only if typeClass is not set. If type class is not set, class will try to be loaded from class loader via given className using
hazelcast/src/main/java/com/hazelcast/config/SerializerConfig.java:148
↓ 11 callersMethodsetup
(boolean backPressureEnabled)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationservice/impl/OperationBackupHandlerTest.java:62
↓ 11 callersMethodshutdownKafkaCluster
()
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/KafkaTestSupport.java:133
↓ 11 callersMethodsignatureErorr
(SqlColumnType... columnTypes)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/RoundFunctionIntegrationTest.java:357
↓ 11 callersMethodsignatureErorr
(SqlColumnType... columnTypes)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/TruncateFunctionIntegrationTest.java:348
← previousnext →6,401–6,500 of 147,315, ranked by callers