MCPcopy Create free account

hub / github.com/hazelcast/hazelcast / functions

Functions147,315 in github.com/hazelcast/hazelcast

↓ 3 callersMethodwrap
(DagBuildContext ctx, ProcessorSupplier supplier)
extensions/mongodb/src/main/java/com/hazelcast/jet/sql/impl/connector/mongodb/MongoSqlConnectorBase.java:209
↓ 3 callersMethodwrap
(ServerConnection c)
hazelcast/src/test/java/com/hazelcast/internal/server/FirewallingServer.java:291
↓ 3 callersMethodwrapInCompletionException
(Throwable t)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1346
↓ 3 callersMethodwrapOrPeel
(Throwable cause)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1945
↓ 3 callersMethodwrapThrowable
(Object value)
hazelcast/src/main/java/com/hazelcast/spi/impl/AbstractInvocationFuture.java:1352
↓ 3 callersMethodwrapToJetEvent
()
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/StreamSourceStageImpl.java:98
↓ 3 callersMethodwriteArraySeparator
()
hazelcast/src/test/java/com/hazelcast/internal/json/RandomPrint.java:66
↓ 3 callersMethodwriteBufferedP
Shortcut for {@link #writeBufferedP(FunctionEx, BiConsumerEx, ConsumerEx, ConsumerEx)} with a no-op {@code destroyFn}.
hazelcast/src/main/java/com/hazelcast/jet/core/processor/SinkProcessors.java:341
↓ 3 callersMethodwriteChar
( ByteAccessStrategy<R> strategy, R resource, long offset, char v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:73
↓ 3 callersMethodwriteChar
(byte[] buffer, int pos, char v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:99
↓ 3 callersMethodwriteDateArray
Writes an array of Date's @param fieldName name of the field @param values LocalDate array to be written @throws IOException in case of any except
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:328
↓ 3 callersMethodwriteDecimalArray
Writes an array of Decimals @param fieldName name of the field @param values BigDecimal array to be written @throws IOException in case of any exc
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:308
↓ 3 callersMethodwriteDuration
(ObjectDataOutput out, Duration duration)
hazelcast/src/main/java/com/hazelcast/cache/HazelcastExpiryPolicy.java:162
↓ 3 callersMethodwriteGenericRecord
(@Nonnull String fieldName, @Nullable GenericRecord value)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/DefaultCompactWriter.java:266
↓ 3 callersMethodwriteInt
( ByteAccessStrategy<R> strategy, R resource, long offset, int v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:151
↓ 3 callersMethodwriteInt
(FileOutputStream fos, int dataSize)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/preloader/NearCachePreloader.java:265
↓ 3 callersMethodwriteInt32
(@Nonnull String fieldName, int value)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/SchemaWriter.java:68
↓ 3 callersMethodwriteIntB
(ByteAccessStrategy<R> strategy, R resource, long offset, int v)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:160
↓ 3 callersMethodwriteInternal
(ObjectDataOutput out)
hazelcast/src/test/java/com/hazelcast/internal/util/SerialOperationInvokerTest.java:323
↓ 3 callersMethodwriteInternal
(BufferObjectDataOutput out, Portable p)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableSerializer.java:77
↓ 3 callersMethodwriteJobExecutionRecordSafe
Ensure that {@link JobExecutionRecord} is safe, that is: it is stored in IMap and all backups succeeded. @throws IndeterminateOperationStateException
hazelcast/src/main/java/com/hazelcast/jet/impl/MasterContext.java:413
↓ 3 callersMethodwriteLocalDate
(ObjectDataOutput out, LocalDate value)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:203
↓ 3 callersMethodwriteLocalTime
(ObjectDataOutput out, LocalTime value)
hazelcast/src/main/java/com/hazelcast/internal/nio/IOUtil.java:184
↓ 3 callersMethodwriteLong
(long value)
hazelcast-tpc-engine/src/main/java/com/hazelcast/internal/tpcengine/iobuffer/IOBuffer.java:206
↓ 3 callersMethodwriteLong
( ByteAccessStrategy<R> strategy, R resource, long offset, long v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:235
↓ 3 callersMethodwriteLongB
(ByteAccessStrategy<R> strategy, R resource, long offset, long v)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:244
↓ 3 callersMethodwriteLongL
(byte[] buffer, int pos, long v)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:199
↓ 3 callersMethodwriteNullPortable
To write a null portable value, user needs to provide class and factoryIds of related class. @param fieldName name of the field @param factoryId fact
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:150
↓ 3 callersMethodwriteObjectTypeMetadata
(QueryDataType type, ObjectDataOutput out)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/type/QueryDataType.java:325
↓ 3 callersMethodwritePortableGenericRecordInternal
(ObjectDataOutput out, PortableGenericRecord record)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/portable/PortableSerializer.java:184
↓ 3 callersMethodwriteShort
( ByteAccessStrategy<R> strategy, R resource, long offset, short v, boolean useBigEndian)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:110
↓ 3 callersMethodwriteShortL
(ByteAccessStrategy<R> strategy, R resource, long offset, short v)
hazelcast/src/main/java/com/hazelcast/internal/memory/impl/EndiannessUtil.java:124
↓ 3 callersMethodwriteShortL
(byte[] buffer, int pos, short v)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:135
↓ 3 callersMethodwriteString
(@Nonnull String fieldName, @Nullable String str)
hazelcast/src/main/java/com/hazelcast/internal/serialization/impl/compact/SchemaWriter.java:78
↓ 3 callersMethodwriteThroughCache
(Data key, Object value)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:1051
↓ 3 callersMethodwriteThroughEnabled
(boolean writeThroughEnabled)
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioNetworking.java:517
↓ 3 callersMethodwriteTimeArray
Writes an array of Time's @param fieldName name of the field @param values LocalTime array to be written @throws IOException in case of any except
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:318
↓ 3 callersMethodwriteTimestampArray
Writes an array of Timestamp's @param fieldName name of the field @param values LocalDateTime array to be written @throws IOException in case of a
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:338
↓ 3 callersMethodwriteTimestampWithTimezoneArray
Writes an array of TimestampWithTimezone's @param fieldName name of the field @param values OffsetDateTime array to be written @throws IOException
hazelcast/src/main/java/com/hazelcast/nio/serialization/PortableWriter.java:348
↓ 3 callersMethodwriteTo
(ByteBuffer dst, ClientMessage clientMessage)
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/ClientMessageWriter.java:32
↓ 3 callersMethodwriteUtf8Char
(byte[] buffer, int pos, int c)
hazelcast/src/main/java/com/hazelcast/internal/nio/Bits.java:203
↓ 2 callersMethodDefault
()
hazelcast/src/main/java/com/hazelcast/jet/core/Partitioner.java:125
↓ 2 callersMethodabort
()
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManagerImpl.java:1343
↓ 2 callersMethodabortTransaction
(Xid xid)
hazelcast/src/main/java/com/hazelcast/jet/impl/connector/XaSinkProcessorBase.java:180
↓ 2 callersMethodabortUnfinishedTransactions
()
hazelcast/src/main/java/com/hazelcast/jet/impl/processor/UnboundedTransactionsProcessorUtility.java:180
↓ 2 callersMethodabortUpload
()
extensions/s3/src/main/java/com/hazelcast/jet/s3/S3Sinks.java:272
↓ 2 callersMethodaccept
(Visitor visitor, IndexRegistry indexes)
hazelcast/src/main/java/com/hazelcast/query/impl/predicates/NotPredicate.java:75
↓ 2 callersMethodacceptEitherAsync
()
hazelcast/src/test/java/com/hazelcast/spi/impl/CompletableFutureAbstractTest.java:1166
↓ 2 callersMethodacceptEx
Exception-declaring version of {@link BiConsumer#accept}. @throws Exception in case of any exceptional case
hazelcast/src/main/java/com/hazelcast/function/BiConsumerEx.java:42
↓ 2 callersMethodacceptLiteral
(String literal)
hazelcast-sql/src/main/java/com/hazelcast/sql/impl/expression/datetime/Formatter.java:254
↓ 2 callersMethodacceptMultilineJson
(Configuration configuration)
extensions/hadoop/src/main/java/com/hazelcast/jet/hadoop/impl/JsonInputFormat.java:73
↓ 2 callersMethodaccess
()
hazelcast/src/main/java/com/hazelcast/internal/iteration/IteratorWithCursor.java:78
↓ 2 callersMethodaccess
()
hazelcast/src/main/java/com/hazelcast/multimap/impl/MultiMapContainer.java:195
↓ 2 callersMethodaccessRecord
(QueryCacheRecord record)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/subscriber/DefaultQueryCacheRecordStore.java:79
↓ 2 callersMethodaccessToken
()
hazelcast/src/test/java/com/hazelcast/gcp/GcpMetadataApiTest.java:96
↓ 2 callersMethodaccumulateExtracted
Accumulates a single extracted value. This method may be called multiple times per accumulated entry if the attributePath contains [any] operator. @p
hazelcast/src/main/java/com/hazelcast/aggregation/impl/AbstractAggregator.java:111
↓ 2 callersMethodaccumulateFn
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperation1Impl.java:57
↓ 2 callersMethodaccumulateFn0
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperation3Impl.java:67
↓ 2 callersMethodaccumulateFn1
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperation3Impl.java:73
↓ 2 callersMethodaccumulateFn2
()
hazelcast/src/main/java/com/hazelcast/jet/impl/aggregate/AggregateOperation3Impl.java:79
↓ 2 callersMethodaccumulateOrSendExpiredKeysToBackup
(Data key, R record)
hazelcast/src/main/java/com/hazelcast/cache/impl/AbstractCacheRecordStore.java:547
↓ 2 callersMethodaccumulateTaskHandlersAsScheduledFutures
(Map<Member, List<IScheduledFuture<V>>> accumulator,
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorServiceProxy.java:397
↓ 2 callersMethodaccumulateTaskHandlersAsUrnValues
(List<ScheduledTaskHandler> accumulator, Map<?, ?> taskHand
hazelcast/src/main/java/com/hazelcast/client/impl/protocol/task/scheduledexecutor/ScheduledExecutorGetAllScheduledMessageTask.java:120
↓ 2 callersMethodaccumulatorInfoCountOfMap
(String mapName)
hazelcast/src/main/java/com/hazelcast/map/impl/querycache/accumulator/DefaultAccumulatorInfoSupplier.java:76
↓ 2 callersMethodacquirePermit
(boolean quietly)
hazelcast/src/main/java/com/hazelcast/scheduledexecutor/impl/ScheduledExecutorContainer.java:355
↓ 2 callersMethodadapt
(final Runnable runnable)
hazelcast/src/test/java/com/hazelcast/internal/json/TestUtil.java:71
↓ 2 callersMethodadaptAggregateOperation
( @Nonnull AggregateOperation<A, ? extends R> aggrOp )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:187
↓ 2 callersMethodadaptAggregateOperation1
( @Nonnull AggregateOperation1<? super T, A, ? extends R> aggrOp )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:194
↓ 2 callersMethodadaptDeleteStatePredicate
( @Nonnull TriPredicate<? super S, ? super K, ? super T> deleteStatePredicate )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:89
↓ 2 callersMethodadaptFilterFn
(@Nonnull PredicateEx<? super T> filterFn)
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:69
↓ 2 callersMethodadaptFilterUsingServiceFn
( @Nonnull BiPredicateEx<? super S, ? super T> filterFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:124
↓ 2 callersMethodadaptFlatMapUsingServiceAsyncBatchedFn
( @Nonnull BiFunctionEx<? super S, ? super List<T>, ? extends CompletableFuture<List<Traverser<R>>
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:146
↓ 2 callersMethodadaptFlatMapUsingServiceAsyncFn
( @Nonnull BiFunctionEx<? super S, ? super T, ? extends CompletableFuture<Traverser<R>>> flatMapAs
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:138
↓ 2 callersMethodadaptFlatMapUsingServiceFn
( @Nonnull BiFunctionEx<? super S, ? super T, ? extends Traverser<R>> flatMapFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:131
↓ 2 callersMethodadaptMapUsingServiceFn
( @Nonnull BiFunctionEx<? super S, ? super T, ? extends R> mapFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:117
↓ 2 callersMethodadaptStatefulFlatMapFn
( @Nonnull TriFunction<? super S, ? super K, ? super T, ? extends Traverser<R>> flatMapFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:103
↓ 2 callersMethodadaptStatefulMapFn
( @Nonnull TriFunction<? super S, ? super K, ? super T, ? extends R> mapFn )
hazelcast/src/main/java/com/hazelcast/jet/impl/pipeline/FunctionAdapter.java:82
↓ 2 callersMethodadd
(Object value, long count)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/AvgSqlAggregations.java:74
↓ 2 callersMethodadd
(Object value, long count)
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/aggregate/AvgSqlAggregations.java:130
↓ 2 callersMethodadd
(int value)
hazelcast/src/test/java/com/hazelcast/map/EntryProcessorBouncingNodesTest.java:210
↓ 2 callersMethodadd
Adds one item to the ring buffer. Sets the expiration time if TTL is configured and also attempts to store the item in the data store if one is config
hazelcast/src/main/java/com/hazelcast/ringbuffer/impl/RingbufferContainer.java:309
↓ 2 callersMethodadd
Adds an item to the tail of the ringbuffer. If there is no space in the ringbuffer, the add will overwrite the oldest item in the ringbuffer. The meth
hazelcast/src/main/java/com/hazelcast/spi/merge/RingbufferMergeData.java:141
↓ 2 callersMethodadd
(Object task, boolean priority)
hazelcast/src/main/java/com/hazelcast/spi/impl/operationexecutor/impl/OperationQueueImpl.java:61
↓ 2 callersMethodadd
(RemoteCallHook newHook)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/CompositeRemoteCallHook.java:30
↓ 2 callersMethodaddActiveMigration
Adds the active migration if none is set for the partition and returns {@code null}, otherwise returns the currently set active migration.
hazelcast/src/main/java/com/hazelcast/internal/partition/impl/MigrationManager.java:76
↓ 2 callersMethodaddAdded
(@Nonnull Shard shard)
extensions/kinesis/src/main/java/com/hazelcast/jet/kinesis/impl/source/ShardQueue.java:30
↓ 2 callersMethodaddAddends
( RexNode expr, Integer[] positiveField, Integer[] negativeField,
hazelcast-sql/src/main/java/com/hazelcast/jet/sql/impl/opt/physical/StreamToStreamJoinPhysicalRule.java:280
↓ 2 callersMethodaddAll
(Addresses addresses)
hazelcast/src/main/java/com/hazelcast/client/impl/connection/Addresses.java:42
↓ 2 callersMethodaddAll
{@inheritDoc}
hazelcast/src/main/java/com/hazelcast/internal/util/collection/LongHashSet.java:202
↓ 2 callersMethodaddAndGet
Adds the given value to the current value. <p> The method can throw a {@link ConsistencyLostException} when the state of this CRDT is not causally rel
hazelcast/src/main/java/com/hazelcast/internal/crdt/pncounter/PNCounterImpl.java:141
↓ 2 callersMethodaddAndGet
(long delta)
hazelcast/src/main/java/com/hazelcast/internal/longregister/LongRegister.java:30
↓ 2 callersMethodaddAndGetMissedSequenceCount
(long missCount)
hazelcast/src/main/java/com/hazelcast/internal/nearcache/impl/invalidation/MetaDataContainer.java:103
↓ 2 callersMethodaddAndGetSequence
@param fullFlush {@code true} if flush cause is {@link IMap#flush()}, {@code false} for flushes caused by eviction. @return last stor
hazelcast/src/main/java/com/hazelcast/map/impl/mapstore/writebehind/WriteBehindStore.java:343
↓ 2 callersMethodaddAsync
(List<ReliableTopicMessage> messages, OverflowPolicy overflowPolicy)
hazelcast/src/main/java/com/hazelcast/client/impl/proxy/ClientReliableTopicProxy.java:313
↓ 2 callersMethodaddAsync
(List<ReliableTopicMessage> messages, OverflowPolicy overflowPolicy)
hazelcast/src/main/java/com/hazelcast/topic/impl/reliable/ReliableTopicProxy.java:362
↓ 2 callersMethodaddAsync_whenOverwrite
()
hazelcast/src/test/java/com/hazelcast/ringbuffer/impl/RingbufferAbstractTest.java:259
↓ 2 callersMethodaddAttributeInternal
(String attribute)
hazelcast/src/main/java/com/hazelcast/config/IndexConfig.java:177
↓ 2 callersMethodaddBackupListener
(UUID clientUUID, LongConsumer backupListener)
hazelcast/src/main/java/com/hazelcast/client/impl/ClientEngine.java:172
↓ 2 callersMethodaddBatchToBuffer
(SourceBuffer<? super T> buffer)
extensions/s3/src/main/java/com/hazelcast/jet/s3/S3Sources.java:307
↓ 2 callersMethodaddCacheConfig
(CacheConfig cacheConfig)
hazelcast/src/main/java/com/hazelcast/cache/impl/operation/OnJoinCacheOperation.java:54
← previousnext →16,101–16,200 of 147,315, ranked by callers