MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 8 callersMethodsetValueClassName
(String valueClassName)
hazelcast/src/main/java/com/hazelcast/config/AbstractCacheConfig.java:382
↓ 8 callersMethodsetValueType
Sets the value type for this {@link com.hazelcast.cache.ICache}. @param valueType the value type to set for this {@link com.hazelcast.cache.ICache} @
hazelcast/src/main/java/com/hazelcast/config/CacheSimpleConfig.java:227
↓ 8 callersMethodsetWhitelist
Sets the whitelist filter. @param whiteList the whitelist filter to set @return this configuration
hazelcast/src/main/java/com/hazelcast/config/JavaSerializationFilterConfig.java:96
↓ 8 callersMethodsetZeroConfigFilter
Set the filter determining class eligibility for reflective compact serialization. Setting the filter to null means all classes are eligible. @param
hazelcast/src/main/java/com/hazelcast/config/CompactSerializationConfig.java:111
↓ 8 callersMethodsharedFileSystem
Sets whether files are in a shared storage visible to all members. The default value is {@code false}. <p> If {@code sharedFileSystem} is {@code true}
extensions/avro/src/main/java/com/hazelcast/jet/avro/AvroSourceBuilder.java:80
↓ 8 callersMethodshouldWait
()
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/operations/ReadOneOperation.java:52
↓ 8 callersMethodshutdownMember_whenClusterNotActive
(boolean shutdownMaster, boolean initializePartitions, ClusterState state)
hazelcast/src/test/java/com/hazelcast/internal/partition/GracefulShutdownTest.java:401
↓ 8 callersMethodsignatureError
(Object type1, Object type2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/math/ArithmeticOperatorIntegrationTest.java:201
↓ 8 callersMethodsingleCapturedValue
()
hazelcast/src/test/java/com/hazelcast/internal/metrics/impl/CapturingCollector.java:78
↓ 8 callersMethodsliding
Returns a sliding window definition with the given parameters. In a sliding window, the incoming items are grouped by fixed-size and overlapping inter
hazelcast/src/main/java/com/hazelcast/jet/pipeline/WindowDefinition.java:97
↓ 8 callersMethodsnapshotContext
()
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:272
↓ 8 callersMethodspyTransactionManagerService
(HazelcastInstance hz)
hazelcast/src/test/java/com/hazelcast/internal/cluster/impl/AdvancedClusterStateTest.java:641
↓ 8 callersMethodsql
(String token, String operand1, String operand2)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/expression/predicate/ComparisonPredicateIntegrationTest.java:696
↓ 8 callersMethodsql
(String name, String interval)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/aggregate/SqlInsertWindowBoundsTest.java:280
↓ 8 callersMethodsqlServiceImpl
(HazelcastInstance instance)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/SqlTestSupport.java:714
↓ 8 callersMethodstart
Starts the Channel. <p> In case of a client-mode channel, the {@link #connect(InetSocketAddress, int)} should be called before start is called. <p> Wh
hazelcast/src/main/java/com/hazelcast/internal/networking/Channel.java:178
↓ 8 callersMethodstartNode
()
hazelcast/src/test/java/com/hazelcast/internal/util/AbstractClockTest.java:51
↓ 8 callersMethodstop
()
hazelcast/src/test/java/com/hazelcast/osgi/TestBundle.java:115
↓ 8 callersMethodstreamFromProcessor
Returns an unbounded (event stream) source constructed directly from the given Core API processor meta-supplier. @param sourceName user-friendly sour
hazelcast/src/main/java/com/hazelcast/jet/pipeline/Sources.java:152
↓ 8 callersMethodstreamMapP
Returns a supplier of processors for {@link Sources#mapJournal(String, JournalInitialPosition)}.
hazelcast/src/main/java/com/hazelcast/jet/core/processor/SourceProcessors.java:122
↓ 8 callersMethodstreamingTable
(Table table, long rowCount)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/OptimizerTestSupport.java:192
↓ 8 callersMethodstreamingTable
(Table table)
hazelcast-sql/src/test/java/com/hazelcast/jet/sql/impl/opt/physical/PhysicalJoinTest.java:134
↓ 8 callersMethodsubmitToKeyOwnerInternal
(@Nonnull Data task, @Nonnull Object key,
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientExecutorServiceProxy.java:427
↓ 8 callersMethodsubmitToKeys
Async version of {@link #executeOnKeys}. @param keys the keys to execute the entry processor on. Can be empty, in that case it's a local n
hazelcast/src/main/java/com/hazelcast/map/IMap.java:2887
↓ 8 callersMethodsumValueFor
(JobMetrics metrics, String vertex, String metric)
hazelcast/src/test/java/com/hazelcast/jet/core/metrics/JobMetrics_BatchTest.java:179
↓ 8 callersMethodsupports
Checks whether the given XML {@code tag} is supported.
hazelcast/src/main/java/com/hazelcast/internal/config/AliasedDiscoveryConfigUtils.java:65
↓ 8 callersMethodsuspectMember
(Member suspectedMember, String reason, boolean destroyConnection)
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java:202
↓ 8 callersMethodtakeInputBuffer
Takes an BufferObjectDataInput from the pool and initializes it with the given data. The reason that Data is passed as argument, is that for Hazelcas
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/bufferpool/BufferPool.java:55
↓ 8 callersMethodtakeReadLock
()
hazelcast/src/main/java/com/hazelcast/query/impl/BaseIndexStore.java:82
↓ 8 callersMethodtest
(HazelcastInstance instance, DistributedObject object)
hazelcast/src/test/java/com/hazelcast/core/DistributedObjectTest.java:112
↓ 8 callersMethodtest
Evaluates this predicate on the given argument. @param t the input argument @return {@code true} if the input argument matches the predicate, otherwi
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/IPredicate.java:33
↓ 8 callersMethodtestCancel_submitToMember
(boolean allMembersRouting, HazelcastInstance server, boolean waitTaskStart)
hazelcast/src/test/java/com/hazelcast/client/executor/ClientExecutorServiceCancelTest.java:172
↓ 8 callersMethodtestFullSplitInto2Cliques
(int vertexCount, int leftCliqueSize)
hazelcast/src/test/java/com/hazelcast/internal/util/graph/BronKerboschCliqueFinderTest.java:131
↓ 8 callersMethodtestTwoDisconnectedSubgraphs
(int vertexCount, int firstGroupSize, int secondGroupSize)
hazelcast/src/test/java/com/hazelcast/internal/util/graph/BronKerboschCliqueFinderTest.java:202
↓ 8 callersMethodtestTxnInvalidatesNearCache
(InvalidatorTxnOp invalidatorTxnTask)
hazelcast/src/test/java/com/hazelcast/map/impl/tx/TxnMapNearCacheInvalidationTest.java:227
↓ 8 callersMethodthrowDisabled
()
hazelcast/src/main/java/com/hazelcast/sql/impl/MissingSqlService.java:105
↓ 8 callersMethodthrowExceptionIfNull
Throws IllegalArgumentException if the Json field is not found.
hazelcast/src/main/java/com/hazelcast/internal/util/JsonUtil.java:316
↓ 8 callersMethodthrowIfLocked
()
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:640
↓ 8 callersMethodthrowReadOnly
()
hazelcast/src/main/java/com/hazelcast/internal/config/ReplicatedMapConfigReadOnly.java:73
↓ 8 callersMethodtoBsonDocument
(I item)
extensions/mongodb/src/main/java/com/hazelcast/jet/mongodb/impl/Mappers.java:87
↓ 8 callersMethodtoData
(Object obj)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:431
↓ 8 callersMethodtoDataWithSchema
Serializes an object to a {@link Data} that contains the {@link com.hazelcast.internal.serialization.impl.compact.Schema} in the binary, if the {@code
hazelcast/src/main/java/com/hazelcast/internal/serialization/SerializationService.java:64
↓ 8 callersMethodtoDotString
Returns a DOT format (graphviz) representation of the DAG.
hazelcast/src/main/java/com/hazelcast/jet/core/DAG.java:479
↓ 8 callersMethodtoGenericRecord
(Object value, Schema schema)
extensions/kafka/src/test/java/com/hazelcast/jet/kafka/impl/StreamKafkaAvroTest.java:151
↓ 8 callersMethodtoIndex
(int sequence)
hazelcast/src/main/java/com/hazelcast/durableexecutor/impl/TaskRingBuffer.java:192
↓ 8 callersMethodtoKiloBytes
(long value)
hazelcast/src/main/java/com/hazelcast/memory/MemoryUnit.java:42
↓ 8 callersMethodtoMembersView
()
hazelcast/src/main/java/com/hazelcast/internal/cluster/impl/MemberMap.java:209
↓ 8 callersMethodtoOperationDesc
(Operation op)
hazelcast/src/main/java/com/hazelcast/internal/diagnostics/OperationDescriptors.java:43
↓ 8 callersMethodtoPublicException
(@Nonnull Throwable e, @Nonnull UUID localMemberId)
hazelcast/src/main/java/com/hazelcast/sql/impl/CoreQueryUtils.java:36
↓ 8 callersMethodtoString
(String ip, Integer port, String endpointName)
hazelcast/src/test/java/com/hazelcast/kubernetes/KubernetesApiProviderTest.java:129
↓ 8 callersMethodtriggerControlTask
Clears the migration queue and triggers the control task. Called on the master node.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:128
↓ 8 callersMethodtryEmitToSnapshot
Offers one key-value pair to the snapshot bucket. <p> The type of the offered key determines which processors receive the key and value pair when it i
hazelcast/src/main/java/com/hazelcast/jet/core/AbstractProcessor.java:440
↓ 8 callersMethodtryLoadClass
(String className, ClassLoader classLoader)
hazelcast/src/main/java/com/hazelcast/internal/nio/ClassLoaderUtil.java:288
↓ 8 callersMethodtypes
()
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/schema/map/PartitionedMapTable.java:120
↓ 8 callersMethodundecorateTo
(Class<T> clazz)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/AbstractTaskDecorator.java:83
↓ 8 callersMethodunlock
Releases the lock for the specified key. <p> It never blocks and returns immediately. <p> <b>Warning:</b> This method uses {@code hashCode} and {@code
hazelcast/src/main/java/com/hazelcast/multimap/MultiMap.java:530
↓ 8 callersMethodunpark
(WaitSetTest.BlockedOperation op)
hazelcast/src/test/java/com/hazelcast/spi/impl/operationparker/impl/OperationParkerMigrationTest.java:219
↓ 8 callersMethodunwrapIfOptional
Unwraps the given potentially {@link Optional optional} value. @param value the potentially optional value to unwrap. @return an unwrapped value, if
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/PredicateUtils.java:68
↓ 8 callersMethodupdateAndGetSendSeqLimitCompressed
Calls {@link #updateAndGetSendSeqLimitCompressed(long, Connection)} with {@code System.nanoTime()} and the current acked seq for the given sender ID.
hazelcast/src/main/java/com/hazelcast/jet/impl/execution/ReceiverTasklet.java:189
↓ 8 callersMethodupdateConfig
(Method setterMethod, Object otherConfigObject, Object value)
hazelcast/src/test/java/com/hazelcast/test/starter/constructor/AbstractConfigConstructor.java:188
↓ 8 callersMethodupdateMapSupplier
Update map with an update function
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/HazelcastWriters.java:168
↓ 8 callersMethoduuidOf
If this address or its resolved IP address has been registered before, it returns the instance uuid corresponding to this address. @param address addr
hazelcast/src/main/java/com/hazelcast/internal/server/tcp/LocalAddressRegistry.java:208
↓ 8 callersMethodvalidateAndNormalize
Validate provided index config and normalize it's name and attribute names. @param mapName Name of the map @param config Index config. @return Normal
hazelcast/src/main/java/com/hazelcast/query/impl/IndexUtils.java:67
↓ 8 callersMethodvalidateTraversal
(Traverser<?> trav)
hazelcast/src/test/java/com/hazelcast/jet/TraversersTest.java:166
↓ 8 callersMethodvalidator
Returns an optional validator to validate a value before finalizing the configuration. @return the optional validator. Is allowed to be <code>null</c
hazelcast/src/main/java/com/hazelcast/config/properties/PropertyDefinition.java:60
↓ 8 callersMethodvalue
(Comparable... values)
hazelcast/src/test/java/com/hazelcast/query/impl/predicates/CompositeRangePredicateTest.java:306
↓ 8 callersMethodverify
(AscendingLongIterator actual, SortedSet<Long> expected)
hazelcast/src/test/java/com/hazelcast/query/impl/bitmap/BitmapAlgorithmsTest.java:386
↓ 8 callersMethodverifyExplicitSerializerIsUsed
(SerializationConfig serializationConfig)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:302
↓ 8 callersMethodverifyQueries
()
hazelcast/src/test/java/com/hazelcast/map/impl/query/SingleValueBitmapIndexTest.java:298
↓ 8 callersMethodverifyReflectiveSerializerIsUsed
(SerializationConfig serializationConfig)
hazelcast/src/test/java/com/hazelcast/internal/serialization/impl/compact/CompactTestUtil.java:291
↓ 8 callersMethodwait
(Map<Member, ? extends Future<?>> futures)
hazelcast/src/test/java/com/hazelcast/splitbrainprotection/executor/ExecutorSplitBrainProtectionWriteTest.java:528
↓ 8 callersMethodwaitClusterForSafeState
(final HazelcastInstance instance)
hazelcast/src/test/java/com/hazelcast/test/HazelcastTestSupport.java:761
↓ 8 callersMethodwaitForNextSnapshot
(HazelcastInstance instance, Job job)
hazelcast/src/test/java/com/hazelcast/jet/core/JetTestSupport.java:315
↓ 8 callersMethodwaitUntilExpectedEndpointCountIsReached
(Node node, int expectedEndpointCount)
hazelcast/src/test/java/com/hazelcast/internal/util/phonehome/PhoneHomeWithDifferentClientTypesTest.java:205
↓ 8 callersMethodwithClass
(Class<?> c)
hazelcast/src/test/java/com/hazelcast/config/test/builders/ConfigReplacerBuilder.java:31
↓ 8 callersMethodwithCreateContextFn
Creates a new {@code ServiceFactory} with the given function that creates the shared context object. Make sure to also call {@link #withCreateServiceF
hazelcast/src/main/java/com/hazelcast/jet/pipeline/ServiceFactory.java:158
↓ 8 callersMethodwriteArrayOfNullableInt16
Writes a nullable array of nullable 16-bit two's complement signed integers. @param fieldName name of the field. @param value to be written.
hazelcast/src/main/java/com/hazelcast/nio/serialization/compact/CompactWriter.java:342
↓ 8 callersMethodwriteClientMessage
(OutputStream os, final ClientMessage clientMessage)
hazelcast/src/test/java/com/hazelcast/client/impl/clientside/ClientTestUtil.java:61
↓ 8 callersMethodwriteDate
Writes a date field consisting of year, month of the year and day of the month @param fieldName name of the field @param value LocalDate value to
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:177
↓ 8 callersMethodwriteDecimal
Writes a decimal which is arbitrary precision and scale floating-point number @param fieldName name of the field @param value BigDecimal value to
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:159
↓ 8 callersMethodwriteInt
(final int v)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/UnsafeObjectDataOutput.java:99
↓ 8 callersMethodwriteLong
(byte[] buffer, int pos, long v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:191
↓ 8 callersMethodwriteShort
(int position, int v)
hazelcast/src/main/java/com/hazelcast/internal/nio/BufferObjectDataOutput.java:65
↓ 8 callersMethodwriteTime
Write a time field consisting of hour, minute, seconds and nanos parts @param fieldName name of the field @param value LocalTime value to be writ
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:168
↓ 8 callersMethodwriteTimestamp
Writes a timestamp field consisting of year, month of the year, day of the month, hour, minute, seconds, nanos parts @param fieldName name of the fie
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:187
↓ 8 callersMethodwriteTimestampWithTimezone
Writes a timestamp with timezone field consisting of year, month of the year, day of the month, offset seconds, hour, minute, seconds, nanos parts @p
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:197
↓ 7 callersMethodaccumulateByFrameP
Returns a supplier of processors for the first-stage vertex in a two-stage sliding window aggregation setup (see the {@link Processors class Javadoc}
hazelcast/src/main/java/com/hazelcast/jet/core/processor/Processors.java:521
↓ 7 callersMethodactionAfterTerminate
Returns the action that should be done after the job terminates.
hazelcast/src/main/java/com/hazelcast/jet/impl/TerminationMode.java:61
↓ 7 callersMethodactiveTransaction
Returns the active transaction that can be used to store an item or query the source. It's null in case when a transaction is not available now. In th
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/TwoPhaseSnapshotCommitUtility.java:137
↓ 7 callersMethodadaptAccumulateFn
( @Nonnull BiConsumerEx<? super A, ? super T> accumulateFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:493
↓ 7 callersMethodadd
(Data key, Data value)
hazelcast/src/main/java/com/hazelcast/map/impl/MapEntries.java:61
↓ 7 callersMethodadd
Add a new object in the estimation set. This is the method you want to use to feed objects into the estimator. <p> Objects are considered identical if
hazelcast/src/main/java/com/hazelcast/cardinality/CardinalityEstimator.java:63
↓ 7 callersMethodaddBatchReplicationPublisherConfig
Adds a WAN publisher configuration using the built-in batching WAN implementation to this WAN replication. @param config the WAN publisher configurat
hazelcast/src/main/java/com/hazelcast/config/WanReplicationConfig.java:159
↓ 7 callersMethodaddCallback
(InternalCompletableFuture<T> future, BiConsumer<T, Throwable>
hazelcast/src/main/java/com/hazelcast/client/cache/impl/ClientCacheProxySupportUtil.java:83
↓ 7 callersMethodaddDouble
(MetricDescriptor descriptor, double value)
hazelcast/src/main/java/com/hazelcast/internal/metrics/impl/MetricsCompressor.java:158
↓ 7 callersMethodaddEntryListener
@see IMap#addEntryListener(MapListener, boolean)
hazelcast/src/main/java/com/hazelcast/map/QueryCache.java:172
↓ 7 callersMethodaddField
(Field field)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/validate/types/HazelcastObjectType.java:130
↓ 7 callersMethodaddIntArrayField
@param fieldName name of the field that will be added to this class definition @return itself for chaining @throws HazelcastSerializationException if
hazelcast/src/main/java/com/hazelcast/nio/serialization/ClassDefinitionBuilder.java:292
↓ 7 callersMethodaddIntegerPropertyValue
(BeanDefinitionBuilder bdb, String parameterName, String textContent)
hazelcast-spring/src/main/java/com/hazelcast/spring/HazelcastConfigBeanDefinitionParser.java:1021
↓ 7 callersMethodaddLabel
Adds a label for this client {@link Client} available @param label The label to be added. @return configured {@link com.hazelcast.client.config.Clien
hazelcast/src/main/java/com/hazelcast/client/config/ClientConfig.java:895
← previousnext →8,201–8,300 of 147,315, ranked by callers