Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/oracle/coherence
/ functions
Functions
78,752 in github.com/oracle/coherence
⨍
Functions
78,752
◇
Types & classes
10,274
↓ 2 callers
Method
addReplaceComplete
Handle add or replace response from the Async EntryProcessor. @param request Request @param response Response @param oReturn Object returned fro
prj/coherence-core/src/main/java/com/tangosol/coherence/memcached/DefaultRequestHandler.java:493
↓ 2 callers
Method
addSafeBundle
(GensonBuilder builder, Class<? extends GensonBundle> clz)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/JsonSerializer.java:418
↓ 2 callers
Method
addSafeListener
Ensure that the specified map has a Listeners object associated with the specified key and add the specified listener to it.
prj/coherence-core/src/main/java/com/tangosol/util/MapListenerSupport.java:1002
↓ 2 callers
Method
addSample
Add a sample to the moving average. @param iValue the sampled value
prj/coherence-core/src/main/java/com/tangosol/internal/util/MovingAverage.java:76
↓ 2 callers
Method
addSample
Add a sample value to the histogram. @param nSampleValue the sampled value.
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/util/Histogram.java:147
↓ 2 callers
Method
addSample
(List<String> listSamples, RecordedEvent event)
prj/test/performance/benchmarks/src/main/java/com/tangosol/coherence/performance/benchmarks/daemonpool/common/JfrPinnedThreadParser.java:93
↓ 2 callers
Method
addSessionInternal
(SessionConfiguration config)
prj/coherence-core/src/main/java/com/tangosol/net/Coherence.java:996
↓ 2 callers
Method
addSubscriptionListener
Add a listener that will be notified when changes are made to topic subscriptions. @param listener the listener to add
prj/coherence-core/src/main/java/com/tangosol/net/PagedTopicService.java:188
↓ 2 callers
Method
addTask
Add the provided task to the set of tasks. @param task the task to add
prj/coherence-core/src/main/java/com/tangosol/persistence/AbstractPersistenceManager.java:1066
↓ 2 callers
Method
addTestCountriesToCache
(NamedCache cache)
prj/test/functional/extractor/src/main/java/extractor/ExtractorTests.java:450
↓ 2 callers
Method
addType
Add type to this schema. @param type the type to add
prj/coherence-core/src/main/java/com/oracle/coherence/common/schema/Schema.java:242
↓ 2 callers
Method
addWarning
Adds a simple warning to the ErrorList. @param sWarning The warning text. @exception OverflowException Thrown when the error list exceeds
prj/coherence-core/src/main/java/com/tangosol/util/ErrorList.java:103
↓ 2 callers
Method
addWithKey
(@CacheKey String key, String first, String second)
prj/test/functional/cdi/src/main/java/cdi/ResponseCachingIT.java:482
↓ 2 callers
Method
addWithParams
(String first, String second)
prj/test/functional/cdi/src/main/java/cdi/ResponseCachingIT.java:475
↓ 2 callers
Method
addWriter
Add a thread to the set of concurrent writers.
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/socketbus/BufferedSocketBus.java:581
↓ 2 callers
Method
add_point_to_result
prj/coherence-hnsw/src/main/cpp/hnswlib/stop_condition.h:253
↓ 2 callers
Method
address
(Address address)
prj/coherence-testing-data/src/main/java/data/repository/Person.java:172
↓ 2 callers
Method
adjustBalance
Adjust the balance of this account. @param amount the amount to adjust the balance by
prj/examples/guides/906-partition-level-transactions/src/main/java/com/oracle/coherence/guides/partitions/bank/Account.java:94
↓ 2 callers
Method
adjustDepth
Adjust the complex data structure depth. @param cDelta either +1 or -1
prj/coherence-core/src/main/java/com/tangosol/io/pof/LoggingPofHandler.java:471
↓ 2 callers
Method
adjustDoubleBalance
Adjust the balance factor of a node and its descendants prior to a a double rotation. @param node the node which was rotated @param child the chil
prj/coherence-core/src/main/java/com/tangosol/util/AbstractSparseArray.java:717
↓ 2 callers
Method
adjustTimeout
Adjust the default timeout value using the passed context-specific timeout value. @param lDefaultValue the default timeout value (must be non-negativ
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/Service.java:365
↓ 2 callers
Method
adjustWaitingSubscriberCount
Adjust the waiting subscriber count. @param cAdjust the amount to adjust the count by @return the new count
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/model/Usage.java:197
↓ 2 callers
Method
admin
(WebTarget target)
prj/coherence-rag-parent/coherence-rag/src/test/java/com/oracle/coherence/rag/api/KbIT.java:180
↓ 2 callers
Method
advance
Advance to the next key. @return true if there is a next key
prj/coherence-core/src/main/java/com/tangosol/net/cache/SimpleOverflowMap.java:2651
↓ 2 callers
Method
advance
Advance to the next object. <p> This method must be implemented by the concrete sub-class by calling {@link #setNext} if there is a next object.
prj/coherence-core/src/main/java/com/oracle/coherence/common/collections/AbstractStableIterator.java:139
↓ 2 callers
Method
advance
Identify the distance to the next buffer which has available space. @param aBuff the array of buffers to scan @param ofBuff the starting position
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/ssl/SSLSocketChannel.java:1181
↓ 2 callers
Method
advance
Advance the internal state of the iterator to the next transfer.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:33937
↓ 2 callers
Method
advanceAfter
(char[] str)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/stream/JsonReader.java:829
↓ 2 callers
Method
advanceIpMonitor
Advance the Ip being monitored to the next address in the scan array.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/IpMonitor.java:224
↓ 2 callers
Method
advanceIterator
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:16464
↓ 2 callers
Method
advancePage
Advance to a new current page, and deactivate the oldest page is the maximum number of active pages has been reached.
prj/coherence-core/src/main/java/com/tangosol/net/cache/SerializationPagedCache.java:881
↓ 2 callers
Method
advanceWhileNumeric
(int cursor)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/stream/JsonReader.java:785
↓ 2 callers
Method
afterClassSetup
()
prj/test/functional/jcache/src/main/java/com/tangosol/coherence/jcachetesting/AbstractCoherenceCacheTests.java:114
↓ 2 callers
Method
aggregate
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/cache/WrapperNamedCache.java:429
↓ 2 callers
Method
aggregate
(Collection<? extends K> collKeys, EntryAggregator<? super K, ? super V_FRONT, R> aggregator)
prj/coherence-core/src/main/java/com/tangosol/net/cache/ContinuousQueryCache.java:1278
↓ 2 callers
Method
aggregate
Process a set of InvocableMap Entry objects using each of the underlying agregators in order to produce an array of aggregated results. @param setEnt
prj/coherence-core/src/main/java/com/tangosol/util/aggregator/CompositeAggregator.java:85
↓ 2 callers
Method
aggregate$Router
(com.tangosol.util.Filter filter, com.tangosol.util.InvocableMap.EntryAggregator agent)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/SafeNamedCache.java:319
↓ 2 callers
Method
aggregateAsync
(com.tangosol.util.Filter filter, com.tangosol.util.InvocableMap.EntryAggregator aggregator, com.tangosol.net.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/ViewMap.java:544
↓ 2 callers
Method
aggregateStatistics
aggregate over storage enabled members using <code>entryAggregator</code>. Only execute entryAggregator once per storage member. Needed context from b
prj/coherence-jcache/src/main/java/com/tangosol/coherence/jcache/partitionedcache/PartitionedJCacheStatistics.java:354
↓ 2 callers
Method
aggregateStreaming
(com.tangosol.util.Filter filter, com.tangosol.util.InvocableMap.StreamingAggregator aggregator, com.tangosol.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/ViewMap.java:666
↓ 2 callers
Method
aggregateWithFilter
Execute the filtered {@link AggregateRequest} request. @param request the {@link AggregateRequest} @return a {@link CompletionStage} that completes
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/BaseNamedCacheServiceImpl.java:161
↓ 2 callers
Method
aggregateWithKeys
Execute the key-based {@link AggregateRequest} request. @param request the {@link AggregateRequest} @return a {@link CompletionStage} that complete
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/BaseNamedCacheServiceImpl.java:203
↓ 2 callers
Method
all
Return a composite filter representing logical AND of all specified filters. @param filters an array of filters @return a composite filter represe
prj/coherence-core/src/main/java/com/tangosol/util/Filters.java:64
↓ 2 callers
Method
allMatch
Returns whether all elements of this stream match the provided predicate. May not evaluate the predicate on all elements if not necessary for determin
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteDoubleStream.java:769
↓ 2 callers
Method
allMatch
Returns whether all elements of this stream match the provided predicate. May not evaluate the predicate on all elements if not necessary for determin
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteLongStream.java:733
↓ 2 callers
Method
allMatch
Returns whether all elements of this stream match the provided predicate. May not evaluate the predicate on all elements if not necessary for determin
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteIntStream.java:737
↓ 2 callers
Method
allOrNothing
Determine if the filter will match all or none of the entries in the index. @param index the index @param mapContents the index contents @par
prj/coherence-core/src/main/java/com/tangosol/util/filter/LessFilter.java:294
↓ 2 callers
Method
allOrNothing
Determine if the filter will match all or none of the entries in the index. @param index the index @param mapContents the index contents @par
prj/coherence-core/src/main/java/com/tangosol/util/filter/GreaterFilter.java:291
↓ 2 callers
Method
allOrNothing
Determine if the filter will match all or none of the entries in the index. @param index the index @param mapContents the index contents @par
prj/coherence-core/src/main/java/com/tangosol/util/filter/BetweenFilter.java:516
↓ 2 callers
Method
allocateBlock
Allocate a free Block object of at least a certain size. Note that the returned block is both open and unlinked. @param cb the required block size
prj/coherence-core/src/main/java/com/tangosol/io/nio/BinaryMap.java:2972
↓ 2 callers
Method
allocateBuffer
Allocate a new buffer, copying old data if there is any.
prj/coherence-core/src/main/java/com/tangosol/io/nio/AbstractBufferManager.java:276
↓ 2 callers
Method
allocateSnapshotPartitions
Given a {@link Map} of member Id's and the stores each member can see for a given snapshot, allocate the stores evenly as so to allow the archival pro
prj/coherence-core/src/main/java/com/tangosol/persistence/ArchiverHelper.java:46
↓ 2 callers
Method
allowSuper
Specify that super is allowed to occur at this point in the parse tree.
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/java/SuperExpression.java:130
↓ 2 callers
Method
analyze
Analyze the distribution using the specified analysis context. @param ctx the analysis context @return the time interval before the next desired an
prj/coherence-core/src/main/java/com/tangosol/net/partition/SimpleAssignmentStrategy.java:470
↓ 2 callers
Method
analyzeDistribution
Analyze the distribution and return the desired time interval before the next distribution analysis. This method may or may not make distribution sugg
prj/coherence-core/src/main/java/com/tangosol/net/partition/PartitionAssignmentStrategy.java:80
↓ 2 callers
Method
analyzeOrphans
Analyze and suggest the assignment of orphaned partitions (partitions without an active primary or backup owner) subject to the specified constraints.
prj/coherence-core/src/main/java/com/tangosol/net/partition/PartitionAssignmentStrategy.java:57
↓ 2 callers
Method
andThen
Adds another {@link InvocableMap.EntryProcessor} to the {@link ChainedProcessor}. @param processor the {@link InvocableMap.EntryProcessor} to add @
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/ClusteredTaskManager.java:1249
↓ 2 callers
Method
announce
Initiate the handshake with other members of the Management service.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/Connector.java:409
↓ 2 callers
Method
anthropicApiKey
Returns the Anthropic API key from configuration. @return the Anthropic key for Anthropic service @throws ConfigException if the API key is not conf
prj/coherence-rag-parent/models/coherence-rag-anthropic/src/main/java/com/oracle/coherence/rag/model/anthropic/AnthropicModelProvider.java:167
↓ 2 callers
Method
anyMatch
Returns whether any elements of this stream match the provided predicate. May not evaluate the predicate on all elements if not necessary for determi
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteDoubleStream.java:734
↓ 2 callers
Method
anyMatch
Returns whether any elements of this stream match the provided predicate. May not evaluate the predicate on all elements if not necessary for determi
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteLongStream.java:697
↓ 2 callers
Method
anyMatch
Returns whether any elements of this stream match the provided predicate. May not evaluate the predicate on all elements if not necessary for determi
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteIntStream.java:702
↓ 2 callers
Method
append
Append each of the values in the aoObjects array to the {@link StringBuilder} appending the specified separator between each value. @param sb
prj/coherence-core/src/main/java/com/tangosol/coherence/dslquery/internal/AbstractCoherenceQueryWalker.java:697
↓ 2 callers
Method
append
(E e, long timeout, TimeUnit unit)
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/NamedMapBlockingQueue.java:60
↓ 2 callers
Method
append
(E e, long timeout, TimeUnit unit)
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/NamedMapBlockingDeque.java:107
↓ 2 callers
Method
appendBufferedTo
Encode a buffered journal entry into the supplied byte array. @param abEntry target byte array @param ofEntry start offset within {@code abEntr
prj/coherence-core/src/main/java/com/tangosol/io/journal2/PartitionJournal.java:587
↓ 2 callers
Method
appendBytesTo
Write this node's binary sequence to the passed BufferOutput. @param out a non-null BufferOutput to write to @throws IOException theoretically fro
prj/coherence-core/src/main/java/com/tangosol/util/BinaryRadixTree.java:1273
↓ 2 callers
Method
appendDefaultSerializerToUserTypes
Process <default-serializer> element from the specified xml configuration and append information about the serializer to each <user-type>
prj/coherence-core/src/main/java/com/tangosol/io/pof/ConfigurablePofContext.java:1648
↓ 2 callers
Method
appendHistogram
(StringBuilder s, Snapshot snapshot)
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/SimpleQueueStatistics.java:162
↓ 2 callers
Method
appendMeter
(StringBuilder s, Meter meter)
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/SimpleQueueStatistics.java:174
↓ 2 callers
Method
appendPendingReceiptMessages
Append any pending receipt bookkeeping into the current consumer-owned build batch. @param batch the current build batch, or {@code null} @return t
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/socketbus/BufferedSocketBus.java:403
↓ 2 callers
Method
appendPrepared
Append a pre-validated entry at the current file position. @param info appending file metadata @param raf append file handle positioned at {
prj/coherence-core/src/main/java/com/tangosol/io/journal2/PartitionJournal.java:477
↓ 2 callers
Method
appendPrepend
Handle Append/Prepend request. @param request Request @param response Response @param fAppend true iff the request is an APPEND operation @thro
prj/coherence-core/src/main/java/com/tangosol/coherence/memcached/DefaultRequestHandler.java:553
↓ 2 callers
Method
appendPrependComplete
Handle append or prepend response from the Async EntryProcessor. @param request Request @param response Response @param oReturn Object returned
prj/coherence-core/src/main/java/com/tangosol/coherence/memcached/DefaultRequestHandler.java:569
↓ 2 callers
Method
appendToFile
(String sFileName, String... asLines)
prj/test/performance/framework/src/main/java/com/tangosol/coherence/performance/AppendToFile.java:37
↓ 2 callers
Method
apply
Configure the specified socket. @param socket the socket to configure @throws SocketException if an I/O error occurs
prj/coherence-core/src/main/java/com/tangosol/net/SocketOptions.java:57
↓ 2 callers
Method
applyFilter
Apply the specified IndexAwareFilter to the specified keySet. Record the actual cost of execution if a query context is provided. @param filter
prj/coherence-core/src/main/java/com/tangosol/util/filter/ArrayFilter.java:378
↓ 2 callers
Method
applyFilter
(String sFilter, boolean fKeysOnly, java.util.Comparator comparator, int nPage)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/application/console/Coherence.java:709
↓ 2 callers
Method
applyForwardEvaluate
(Set<Integer> setKeys)
prj/test/performance/benchmarks/src/main/java/com/tangosol/coherence/performance/benchmarks/filter/FilterIndexStrategyBenchmark.java:209
↓ 2 callers
Method
applyInverseRetain
(Set<Integer> setKeys)
prj/test/performance/benchmarks/src/main/java/com/tangosol/coherence/performance/benchmarks/filter/FilterIndexStrategyBenchmark.java:199
↓ 2 callers
Method
applyMemberDirectories
(PropertySnapshot snapshot, MemberDirectories dirs)
prj/test/functional/persistence/src/main/java/persistence/JournalVsBdbComparisonTests.java:332
↓ 2 callers
Method
applyResolvedLauncherProperties
(Properties props)
prj/test/functional/persistence/src/main/java/persistence/JournalBackingMapRecoveryBenchmarkTests.java:279
↓ 2 callers
Method
applySSLSettings
Apply the specified settingsSSL to the dependencies @param settingsSSL the SSLSettings object to apply @return this dependencies object
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/SSLSocketProvider.java:426
↓ 2 callers
Method
archiveSnapshot
Archive a snapshot of the specified service with the specified name. @param sService the name of the service to archive @param sSnapshot the name
prj/test/functional/persistence/src/main/java/persistence/PersistenceTestHelper.java:128
↓ 2 callers
Method
arrayContains
Return a filter that tests if the extracted array contains the specified value. @param extractor the ValueExtractor to use @param value the val
prj/coherence-core/src/main/java/com/tangosol/util/Filters.java:379
↓ 2 callers
Method
arrayContainsAll
Return a filter that tests if the extracted array contains all of the specified values. @param extractor the ValueExtractor to use @param setValues
prj/coherence-core/src/main/java/com/tangosol/util/Filters.java:439
↓ 2 callers
Method
arrayContainsAny
Return a filter that tests if the extracted array contains any of the specified values. @param extractor the ValueExtractor to use @param setValues
prj/coherence-core/src/main/java/com/tangosol/util/Filters.java:519
↓ 2 callers
Method
arrayLoad
Helper to construct an op to load an element of an array. @param dt the type of the element @return the op which will load the element (assuming th
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/java/InvocationExpression.java:687
↓ 2 callers
Method
arrayToString
Format an array as a String. @param ao the array to format @return the human-readable String value of the array
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/util/BaseMapTest.java:2440
↓ 2 callers
Method
asArray
Return the additional type info as {@link PofArray}. @return the additional type info as {@code PofArray} @throws IllegalStateException if this prop
prj/coherence-core/src/main/java/com/tangosol/io/pof/schema/PofProperty.java:183
↓ 2 callers
Method
asCollection
Return the additional type info as {@link PofCollection}. @return the additional type info as {@code PofCollection} @throws IllegalStateException if
prj/coherence-core/src/main/java/com/tangosol/io/pof/schema/PofProperty.java:215
↓ 2 callers
Method
asDoubleStream
Returns a {@code DoubleStream} consisting of the elements of this stream, converted to {@code double}. <p> This is an <em>intermediate operation</em>.
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteIntStream.java:844
↓ 2 callers
Method
asUniversalExtractor
Create am {@link UniversalExtractor} with the specified method name and optionally the specified method parameters. @param sFunction the name of the
prj/coherence-core/src/main/java/com/tangosol/coherence/dslquery/internal/UpdateSetListMaker.java:571
↓ 2 callers
Method
asc
Add comparator to this builder. @param sExpr expression used to create an expression extractor @return this ComparatorBuilder
prj/coherence-rest/src/main/java/com/tangosol/coherence/rest/util/ComparatorBuilder.java:46
↓ 2 callers
Method
assemble
The assembly process assembles and writes the constant to the passed output stream. The particular constant implementation should super to this gener
prj/coherence-core/src/main/java/com/tangosol/dev/assembler/Constant.java:195
↓ 2 callers
Method
assertActive
Assert that this {@link BatchingOperationsQueue} is active. @throws com.tangosol.util.AssertionException if this {@link BatchingOperationsQueue} is n
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/BatchingOperationsQueue.java:725
↓ 2 callers
Method
assertCacheContents
(NamedCache cache, Map<Integer, String> mapExpected)
prj/test/functional/persistence/src/main/java/persistence/JournalMigrationTests.java:249
↓ 2 callers
Method
assertCanCreateKeys
Assert that openssl and Java keytool can be used to create test keys and certs. @throws org.opentest4j.TestAbortedException if the check fails
prj/examples/guides/810-custom-access-controller/src/test/java/com/oracle/coherence/guides/security/KeyTool.java:50
↓ 2 callers
Method
assertCheckpointLayout
(MemberDirectories dirs, String sEnvironment, RecoveryMode mode)
prj/test/functional/persistence/src/main/java/persistence/JournalVsBdbComparisonTests.java:495
↓ 2 callers
Method
assertCloneEquals
Assert that the two PeerDependencies are equal. @param deps1 the first PeerDependencies object @param deps2 the second PeerDependencies object
prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/service/peer/PeerDependenciesTest.java:59
← previous
next →
13,301–13,400 of 78,752, ranked by callers