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
↓ 10 callers
Method
withEventInterceptors
Add the {@link EventInterceptor} instances that will be added to all {@link Session} instances as they are created on start-up. @param interceptors
prj/coherence-core/src/main/java/com/tangosol/net/CoherenceConfiguration.java:304
↓ 10 callers
Method
withRawTypes
Obtains a {@link TypeAssertion} that allows NamedCaches to be acquired and assigned to a raw NamedCache reference. A debug log message will be raised
prj/coherence-core/src/main/java/com/tangosol/net/cache/TypeAssertion.java:92
↓ 10 callers
Method
withSessions
Add the {@link SessionConfiguration} instances to the {@link Coherence} instance that will be used to create the corresponding {@link Session} instanc
prj/coherence-core/src/main/java/com/tangosol/net/CoherenceConfiguration.java:246
↓ 10 callers
Method
write
Request a write into the peer's memory from the specified BufferSequence. <p> Upon {@link Event.Type#RECEIPT completion} of the asynchronous operation
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/exabus/MemoryBus.java:105
↓ 10 callers
Method
writeToFile
(byte[] ba, String dataType)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/pof/data/PofStreamTest.java:234
↓ 9 callers
Method
__init
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:15842
↓ 9 callers
Method
__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/proxy/NamedCacheProxy.java:186
↓ 9 callers
Method
__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/transactionCache/Local.java:87
↓ 9 callers
Method
__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/peer/acceptor/TcpAcceptor.java:331
↓ 9 callers
Method
__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:15853
↓ 9 callers
Method
__initPrivate
()
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ProxyService.java:307
↓ 9 callers
Method
_newInstance
Create a new instance of a component with the specified fully qualified name (i.e. "Component.GUI.Color.Red"). The algorithm works out of the assump
prj/coherence-core-components/src/main/java/com/tangosol/coherence/Component.java:1052
↓ 9 callers
Method
accept
This method should be called by the client immediately after it determines that it can successfully use an address returned by the {@link #getNextAddr
prj/coherence-core/src/main/java/com/tangosol/net/SocketAddressProvider.java:46
↓ 9 callers
Method
accepted
Determines if the tracked {@link Event} was accepted for processing. @return if the {@link Event} was accepted for processing
prj/test/unit/coherence-tests/src/test/java/com/tangosol/util/fsm/misc/TrackingEvent.java:107
↓ 9 callers
Method
add
(Object o)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/memberSet/ActualMemberSet.java:146
↓ 9 callers
Method
addAll
Helper method for colThis.addAll(colThat)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/Collections.java:104
↓ 9 callers
Method
addAvailable
Add the specified node to the available set. @param node the available node @return true
prj/coherence-core/src/main/java/com/oracle/coherence/common/util/ConcurrentAssociationPile.java:203
↓ 9 callers
Method
addDeleteHandler
Add the event handler for DELETE events. @param onDelete the event handler to execute @return this MapListener
prj/coherence-core/src/main/java/com/tangosol/util/listener/SimpleMapListener.java:63
↓ 9 callers
Method
addEvent
Requests that the specified event be prepared for dispatching to the specified type of listeners. @param listenerClass the class of {@link javax.cach
prj/coherence-jcache/src/main/java/com/tangosol/coherence/jcache/common/CoherenceCacheEventEventDispatcher.java:56
↓ 9 callers
Method
addIndex
Asynchronous implementation of {@link NamedCache#addIndex}. @param extractor the ValueExtractor object that is used to extract an
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClientChannel.java:87
↓ 9 callers
Method
addReason
Add a reason to the provided list (could be null).
prj/coherence-core/src/main/java/com/tangosol/net/ConfigurableQuorumPolicy.java:899
↓ 9 callers
Method
addResourceLink
Add a resource link to the response links. @param sRel the name of link @param uri the URI of the link @return
prj/coherence-core/src/main/java/com/tangosol/internal/management/MBeanResponse.java:159
↓ 9 callers
Method
addSchemaSource
Add {@link SchemaSource} to this {@code SchemaBuilder}. @param schemaSource the {@link SchemaSource} to add @return this {@code SchemaBuilder}
prj/coherence-core/src/main/java/com/oracle/coherence/common/schema/SchemaBuilder.java:82
↓ 9 callers
Method
adjust
Adjust the offset of this BufferOutput based on a write that by-passed this BufferOutput's own super-class implementation that is responsible for main
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/OldMultiBufferWriteBuffer.java:760
↓ 9 callers
Method
aggregate
Perform an aggregating operation asynchronously against all the entries. @param <R> the type of value returned by the EntryAggregator @param
prj/coherence-core/src/main/java/com/tangosol/net/AsyncNamedMap.java:791
↓ 9 callers
Method
apply
(ManagedChannelBuilder<?> builder)
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/GrpcChannelConfigurer.java:21
↓ 9 callers
Method
assertIO
Similar to _assert(), but IOException is thrown.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/packet/MessagePacket.java:303
↓ 9 callers
Method
assertSingleEvent
(EventCollector collector, Filter filter, boolean fClear)
prj/test/functional/transformer/src/main/java/transformer/AbstractMapEventTransformerTests.java:335
↓ 9 callers
Method
assertSnapshotExists
Assert a snapshot exists. @param sSnapshotName the snapshot name @param sType the type of snapshot, archive or snapshot @return true if it
prj/test/functional/management/src/main/java/management/BaseManagementInfoResourceTests.java:4341
↓ 9 callers
Method
async
Return an asynchronous wrapper for this NamedCache. <p> By default, the order of execution of asynchronous operation invoked on the returned AsyncName
prj/coherence-core/src/main/java/com/tangosol/net/NamedCache.java:162
↓ 9 callers
Method
awaitNanos
(long nanosTimeout)
prj/coherence-core/src/main/java/com/oracle/coherence/common/util/NullLock.java:93
↓ 9 callers
Method
awaitReleased
Wait for the permit released event. @param timeout the maximum amount of time to wait @return the global order of the permit released event
prj/test/functional/concurrent/src/main/java/concurrent/AbstractClusteredRemoteSemaphoreIT.java:910
↓ 9 callers
Method
awaitReleased
Wait for the lock released event. @param timeout the maximum amount of time to wait @return the global order of the lock released event
prj/test/functional/concurrent/src/main/java/concurrent/locks/AbstractClusteredRemoteLockIT.java:688
↓ 9 callers
Method
awaitStarted
()
prj/test/functional/core/src/main/java/com/tangosol/coherence/component/util/DaemonPoolIT.java:1503
↓ 9 callers
Method
begin
Begin a new sequence of mutating operations that should be committed to the store as an atomic unit. The returned token should be passed to all mutati
prj/coherence-core/src/main/java/com/oracle/coherence/persistence/PersistentStore.java:239
↓ 9 callers
Method
beginNextObjectMetadata
This method is a kind of cheat as it allows us to start writing metadata and then still be able to call beginObject. This is mainly intended to be use
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/stream/ObjectWriter.java:264
↓ 9 callers
Method
bruteForce
Force brute force search, ignoring any available indexes. @return this instance
prj/coherence-core/src/main/java/com/oracle/coherence/ai/search/SimilaritySearch.java:128
↓ 9 callers
Method
calculateQueueHash
Calculate the hash from the queue name. <p/> This hash will be consistent across versions and JVMs, which is important as the hash is used in queue ke
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/model/QueueKey.java:209
↓ 9 callers
Method
calculateUnbalanced
Calculate the total number of unbalanced partitions. Used by the JMX and tests.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:1541
↓ 9 callers
Method
checkDate
Validate date information. @param nYear the year number @param nMonth the month number @param nDay the day number
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofHelper.java:1767
↓ 9 callers
Method
checkReadOnly
Check the read-only setting to verify that the cache is NOT read-only. @throws IllegalStateException if the {@code ContinuousQueryCache} is read-only
prj/coherence-core/src/main/java/com/tangosol/net/cache/ContinuousQueryCache.java:1608
↓ 9 callers
Method
checkResultCode
This method checks the result code coming from the native execution is correct otherwise throws an exception. @throws UnexpectedNativeException when
prj/coherence-hnsw/src/main/java/com/oracle/coherence/hnswlib/Index.java:402
↓ 9 callers
Method
checkType
Validate a type identifier. @param nType the type identifier
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofHelper.java:1598
↓ 9 callers
Method
clearEvent
Reset the MapEvent property.
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/TestMapListener.java:104
↓ 9 callers
Method
configureStore
()
prj/coherence-rag-parent/coherence-rag/src/test/java/com/oracle/coherence/rag/api/StoreIT.java:116
↓ 9 callers
Method
connect
Explicitly connect to the server, if the client is not already connected. @throws IOException on connection error
prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/net/EchoClient.java:66
↓ 9 callers
Method
containsEntry
Create a {@link ContainsEntryRequest}. @param scope the scope name to use to obtain the cache from. @param cacheName the name of the cache to c
prj/coherence-grpc/src/main/java/com/oracle/coherence/grpc/v0/Requests.java:330
↓ 9 callers
Method
containsValue
Helper method for confirm presence of the value within the cache. @param value the value to check @return a {@link CompletableFuture} returning {@cod
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClientChannel.java:177
↓ 9 callers
Method
containsValue
Returns {@code true} if this map contains a mapping for the specified value. @param request the request which contains the value whose presence
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/NamedCacheService.java:140
↓ 9 callers
Method
containsValue
Create a {@link ContainsValueRequest}. @param scope the scope name to use to obtain the cache from. @param cacheName the name of the cache to c
prj/coherence-grpc/src/main/java/com/oracle/coherence/grpc/v0/Requests.java:372
↓ 9 callers
Method
convertAssignable
Some types are considered assignable although they require conversion. @param ctx the compilation context @param dtThat the type to assign to @
prj/coherence-core/src/main/java/com/tangosol/dev/compiler/java/Expression.java:890
↓ 9 callers
Method
convertEL
Serialize the input value using ExternalizableLite then de-serialize it. @param inVal the input value @return the output value that was de-serializ
prj/test/unit/coherence-tests/src/test/java/com/tangosol/config/TestSerializableHelper.java:35
↓ 9 callers
Method
convertPof
Serialize the input value using POF then de-serialize it. @param inVal the input value @return the output value that was de-serialized
prj/test/unit/coherence-tests/src/test/java/com/tangosol/config/TestSerializableHelper.java:55
↓ 9 callers
Method
copyBytes
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/MultiBufferReadBuffer.java:219
↓ 9 callers
Method
count
A {@link Task.Collector} that counts the number of non-null results that have been made. @param <T> the type of result @return a {@link Task.Collec
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/TaskCollectors.java:94
↓ 9 callers
Method
create
Returns an immutable default {@link CoherenceConfiguration} instance. <p> This configuration will include the default system session, and any session
prj/coherence-core/src/main/java/com/tangosol/net/CoherenceConfiguration.java:52
↓ 9 callers
Method
createNestedPofWriter
Obtain a PofWriter that can be used to write a set of properties into a single property of the current user type. The returned PofWriter is only valid
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofWriter.java:1618
↓ 9 callers
Method
createPartition
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/partition/ObservableSplittingBackingCache.java:80
↓ 9 callers
Method
createPk
(int nId)
prj/test/functional/jpa/src/main/java/orm/AbstractPersistenceTests.java:264
↓ 9 callers
Method
createResizeTask
(ResizeTaskDaemonPoolStub pool, int cThreads, int cMin, int cMax)
prj/test/functional/core/src/main/java/com/tangosol/coherence/component/util/DaemonPoolIT.java:708
↓ 9 callers
Method
createResponse
Create an entity response. @param request the {@link HttpRequest} @param parentUri the parent URI which needs to be added to the response @pa
prj/coherence-core/src/main/java/com/tangosol/internal/management/resources/AbstractManagementResource.java:1297
↓ 9 callers
Method
createSubscriber
(CoherenceClusterMember member, String sId, String sTopic, Subscriber.Option... options)
prj/test/distribution/topics-compatibility/topics-14.1.1.2206.3/src/test/java/topics/TopicSubscriber.java:37
↓ 9 callers
Method
createWriter
Creates a new ObjectWriter with this Genson instance configuration and default encoding to UTF8.
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/Genson.java:645
↓ 9 callers
Method
disassemble
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/dev/assembler/StackMapTableAttribute.java:62
↓ 9 callers
Method
discoverFileIds
Discover existing journal file ids in a partition directory. @param dir partition directory @return sorted journal file ids
prj/coherence-core/src/main/java/com/tangosol/io/journal2/JournalUtils.java:93
↓ 9 callers
Method
dispatchEvent
(com.tangosol.util.MapEvent event)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/CacheHandler.java:535
↓ 9 callers
Method
distance
(BitSet v1, BitSet v2)
prj/coherence-core/src/main/java/com/oracle/coherence/ai/distance/CosineDistance.java:26
↓ 9 callers
Method
distance
(BitSet v1, BitSet v2)
prj/coherence-core/src/main/java/com/oracle/coherence/ai/distance/InnerProductDistance.java:22
↓ 9 callers
Method
distance
(BitSet v1, BitSet v2)
prj/coherence-core/src/main/java/com/oracle/coherence/ai/distance/L2SquaredDistance.java:22
↓ 9 callers
Method
dumpHeap
Collect a heap dump of live objects and write it into a dynamically named file in the temp directory, or <tt>-Dcom.oracle.coherence.common.internal.ut
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/util/HeapDump.java:105
↓ 9 callers
Method
enlist
Enlist the resource with the specified transaction. <p> This method is invoked for all resources that are "used" by the transaction immediately before
prj/coherence-core/src/main/java/com/tangosol/util/TransactionMap.java:345
↓ 9 callers
Method
ensureCache
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/net/DefaultConfigurableCacheFactory.java:307
↓ 9 callers
Method
ensureInputStream
Return the underlying InputStream. @return the underlying InputStream @throws IllegalStateException if the underlying stream has not been
prj/coherence-core/src/main/java/com/tangosol/io/WrapperInputStream.java:68
↓ 9 callers
Method
ensureInternalListener
Obtain the internal MapListener, creating one if necessary. @return an instance of MapListener; never null
prj/coherence-core/src/main/java/com/tangosol/util/WrapperObservableMap.java:811
↓ 9 callers
Method
ensureMapJsonBodyHandler
Load a {@link MapJsonBodyHandler} using the JVM's {@link ServiceLoader} mechanism. @return a {@link MapJsonBodyHandler} loaded via the {@link Service
prj/coherence-core/src/main/java/com/tangosol/net/management/MapJsonBodyHandler.java:86
↓ 9 callers
Method
ensureMessageSnapshot
Ensure that there is a relatively recent snapshot from the message duration histogram. @return a relatively recent snapshot from the message
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/GrpcProxyMetrics.java:504
↓ 9 callers
Method
ensureNotNull
Return the specified {@link com.google.protobuf.ByteString} if it is not {@code null} otherwise return {@link com.google.protobuf.ByteString#EMPTY}.
prj/coherence-grpc/src/main/java/com/oracle/coherence/grpc/v0/Requests.java:1177
↓ 9 callers
Method
ensureRequestSnapshot
Ensure that there is a relatively recent snapshot from the request duration histogram. @return a relatively recent snapshot from the request
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/GrpcProxyMetrics.java:482
↓ 9 callers
Method
ensureResponse
Return the Response for this Request. <p> If not already available, the Response must be created using the {@link Protocol.MessageFactory} associated
prj/coherence-core/src/main/java/com/tangosol/net/messaging/Request.java:67
↓ 9 callers
Method
ensureReturnEntry
Ensure that if entry has a {@link #NULL} key or value, return NullableEntry; @param e an entry @return an entry that can contain a null key or null
prj/coherence-core/src/main/java/com/tangosol/util/SafeSortedMap.java:1071
↓ 9 callers
Method
ensureSubscription
Ensure the specified subscriber is created in a subscription. @param sTopicName the name of the topic @param groupId the {@link SubscriberGr
prj/coherence-core/src/main/java/com/tangosol/net/PagedTopicService.java:42
↓ 9 callers
Method
finalizeResult
Return the final result of the aggregation. @return the final result of the aggregation
prj/coherence-core/src/main/java/com/tangosol/util/InvocableMap.java:966
↓ 9 callers
Method
find
Scan for the argument {@link Annotation} on the argument {@link AccessibleObject}. @param annotation the {@link Annotation} to scan for @param onObje
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/reflect/BeanMutatorAccessorResolver.java:412
↓ 9 callers
Method
finisher
Perform the final transformation from the intermediate accumulation type A to the final result type R. @return a function which transforms the interm
prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/Task.java:172
↓ 9 callers
Method
fromBinary
Decode a Binary into a ContentKey @param bin the binary @return the ContentKey
prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/model/ContentKey.java:159
↓ 9 callers
Method
getActionPolicyBuilder
Return the ActionPolicyBuilder which is a pluggable policy builder that defines certain aspects of a service's behavior at runtime. @return the Actio
prj/coherence-core/src/main/java/com/tangosol/internal/net/service/grid/GridDependencies.java:34
↓ 9 callers
Method
getAggregator
Returns an aggregator instance. @param asArgs aggregator configuration arguments @return an aggregator instance
prj/coherence-rest/src/main/java/com/tangosol/coherence/rest/util/aggregator/AggregatorFactory.java:29
↓ 9 callers
Method
getAll
Get all the specified keys, if they are in the cache. For each key that is in the cache, that key and its corresponding value will be placed in the ma
prj/coherence-core/src/main/java/com/tangosol/net/cache/CacheMap.java:64
↓ 9 callers
Method
getAll
Obtain a stream of mappings of keys to values for all the specified keys. @param request the {@link GetAllRequest} request containing the cache nam
prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/v0/NamedCacheService.java:190
↓ 9 callers
Method
getAll
Create a {@link GetAllRequest}. @param scope the scope name to use to obtain the cache from. @param cacheName the name of the cache to clear @p
prj/coherence-grpc/src/main/java/com/oracle/coherence/grpc/v0/Requests.java:492
↓ 9 callers
Method
getAllLocalAddresses
Return a list of all InetAddress objects bound to all the network interfaces on this machine. @return a list of InetAddress objects
prj/coherence-core/src/main/java/com/oracle/coherence/common/net/InetAddresses.java:615
↓ 9 callers
Method
getAnnotations
Reads the {@code attribute} structure processing any {@code RuntimeVisibleAnnotation} or {@code RuntimeInvisibleAnnotation} or method parameter equiva
prj/coherence-core/src/main/java/com/tangosol/dev/introspect/ClassAnnotationScanner.java:198
↓ 9 callers
Method
getArguments
Returns the arguments passed to this class for interpretation and ultimately used by the {@link PofConfigGenerator}. @return the arguments passed to
prj/coherence-core/src/main/java/com/tangosol/io/pof/generator/Executor.java:120
↓ 9 callers
Method
getAttributes
Provides a predictable {@link Iterator} over {@link AttributeMetadata} for the attributes of the type represented by this TypeMetadata. @return Itera
prj/coherence-core/src/main/java/com/tangosol/io/pof/reflect/internal/TypeMetadata.java:51
↓ 9 callers
Method
getBackupOwner
Determine the backup owner of the specified partition. It is possible that during partition re-distribution (e.g. as a result of a failover) that thi
prj/coherence-core/src/main/java/com/tangosol/net/PartitionedService.java:169
↓ 9 callers
Method
getBigDecimal
Return the <tt>BigDecimal</tt> which this PofValue represents. @return the <tt>BigDecimal</tt> value
prj/coherence-core/src/main/java/com/tangosol/io/pof/reflect/PofValue.java:282
↓ 9 callers
Method
getBinaryValue
Getter for property BinaryValue.<p> Binary value.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:13018
↓ 9 callers
Method
getBody
Returns the notification text. @return the notification text
prj/examples/guides/905-key-association/src/main/java/com/oracle/coherence/guides/notifications/model/Notification.java:51
↓ 9 callers
Method
getBodyLength
Getter for property BodyLength.<p> The length in bytes of this Packet's body.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/packet/MessagePacket.java:469
↓ 9 callers
Method
getBufferOffset
Determine the offset of the specified buffer. The offset of a buffer is the absolute offset of the first byte stored in the buffer. @param iBuffer a
prj/coherence-core/src/main/java/com/tangosol/io/MultiBufferReadBuffer.java:1083
← previous
next →
4,001–4,100 of 78,752, ranked by callers