MCPcopy Create free account

hub / github.com/oracle/coherence / functions

Functions78,752 in github.com/oracle/coherence

↓ 2 callersMethodputInternal
An actual implementation for the extended put() method. @param oKey key with which the specified value is to be associated @param oValue value
prj/coherence-core/src/main/java/com/tangosol/net/cache/ReadWriteBackingMap.java:1765
↓ 2 callersMethodputLoaderIfAbsent
Store a loader reference with the supplied value (a reference or subject reference) only if it does not already exist. @param map the map @param
prj/coherence-core/src/main/java/com/tangosol/net/internal/ScopedReferenceStore.java:480
↓ 2 callersMethodputLoaderIfAbsent
Store a loader reference with the supplied value (a cache or subject reference) only if it does not already exist. @param map the map @param load
prj/coherence-core/src/main/java/com/tangosol/net/internal/ScopedCacheReferenceStore.java:537
↓ 2 callersMethodputLoaderIfAbsent
(Map map, ClassLoader loader, Object oValue)
prj/coherence-core/src/main/java/com/tangosol/net/internal/ScopedTopicReferenceStore.java:515
↓ 2 callersMethodputLoaderIfAbsent
(Map map, ClassLoader loader, Object oValue)
prj/coherence-core/src/main/java/com/tangosol/net/internal/ScopedCollectionReferenceStore.java:438
↓ 2 callersMethodputObject
Put the value in external (Object) format directly int the backing map. @param oKey the key; could be in either internal (Binary) or external
prj/coherence-core/src/main/java/com/tangosol/net/internal/SessionLocalBackingMap.java:81
↓ 2 callersMethodputRequest
Create a {@link PutRequest}. @param key the serialized key @param value the serialized value @return a {@link PutRequest} for the specified key
prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/v1/NamedCacheClientChannel_V1.java:631
↓ 2 callersMethodputToInternalMap
Put the specified key in internal format and value in internal format into the internal backing map. If the cExpiry parameter is greater than the defa
prj/coherence-core/src/main/java/com/tangosol/net/cache/ReadWriteBackingMap.java:1138
↓ 2 callersMethodputValue
(BenchmarkState state)
prj/test/performance/benchmarks/src/main/java/com/tangosol/coherence/performance/benchmarks/daemonpool/MultiMemberPutBenchmark.java:44
↓ 2 callersMethodputValues
Put values into the {@link NamedMap}. @param map {@link NamedMap} to add data to @param start start key @param count number of entries to add
prj/examples/guides/130-near-caching/src/main/java/com/oracle/coherence/guides/nearcaching/SimpleNearCachingExample.java:148
↓ 2 callersMethodquantize
(float[] vector, byte[] dest, int start)
prj/coherence-vector-util/src/main/java/com/tangosol/internal/lucene/vectorization/DefaultVectorUtilSupport.java:312
↓ 2 callersMethodquantizeFloat
(float v, byte[] dest, int destIndex)
prj/coherence-vector-util/src/main/java/com/tangosol/internal/lucene/vectorization/DefaultVectorUtilSupport.java:335
↓ 2 callersMethodquarantineLegacyActiveDirectory
Quarantine legacy active data so journal persistence can start cleanly. @param fileActive the active directory @param sReason the quarantine rea
prj/coherence-core/src/main/java/com/tangosol/persistence/journal/JournalPersistenceEnvironment.java:420
↓ 2 callersMethodquery
(String query)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/dslquery/queryplus/TraceStatementBuilderTest.java:85
↓ 2 callersMethodquery
(InvocationService service)
prj/test/functional/extend/src/main/java/extend/ProxyServiceDynamicThreadSizingTests.java:310
↓ 2 callersMethodquery
Perform a remote query. @param filter the Filter used in the query @param fKeysOnly if true, only the keys from the result will be returned; otherw
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/RemoteNamedCache.java:2432
↓ 2 callersMethodrandomFloats
(int n)
prj/test/functional/hnsw-index/src/main/java/hnsw/HnswIndexIT.java:168
↓ 2 callersMethodrandomFloats
(int n)
prj/test/functional/ai/src/main/java/ai_tests/search/BaseSimilaritySearchIT.java:87
↓ 2 callersMethodrandomFloats
(int n)
prj/test/functional/ai/src/main/java/ai_tests/index/BinaryQuantIndexIT.java:170
↓ 2 callersMethodrandomFloats
(int n)
prj/test/functional/grpc-client-tck/src/main/java/grpc/client/AbstractGrpcClientIT.java:2401
↓ 2 callersMethodrandomHead
Return a random head entry key. @return a random head entry key
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/model/QueueKey.java:97
↓ 2 callersMethodrandomString
()
prj/test/functional/net/src/main/java/net/DeltaBackupTests.java:604
↓ 2 callersMethodrandomTail
Return a random tail entry key. @return a random tail entry key
prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/model/QueueKey.java:108
↓ 2 callersMethodread
(ReadBuffer.BufferInput in)
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/BufferTest.java:658
↓ 2 callersMethodread
(Class<?> ofClass)
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/reflect/ASMCreatorParameterNameResolver.java:68
↓ 2 callersMethodread
()
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/ext/jsr353/GensonJsonReaderFactory.java:51
↓ 2 callersMethodreadArray
Read an array of specified length from the passed DataInput object. @param in the DataInput stream to read property data from @return the data re
prj/coherence-core/src/main/java/com/tangosol/run/xml/ArrayAdapter.java:373
↓ 2 callersMethodreadAttributes
(DataInput stream, Constant[] aconst)
prj/coherence-core/src/main/java/com/tangosol/dev/disassembler/Attribute.java:21
↓ 2 callersMethodreadBigInteger
Read a BigInteger from a DataInput stream. @param in a DataInput stream to read from @return a BigInteger value @throws IOException if an I/O exc
prj/coherence-core/src/main/java/com/tangosol/util/ExternalizableHelper.java:1798
↓ 2 callersMethodreadBinary
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofBufferReader.java:1495
↓ 2 callersMethodreadBoolean
Helper for reading booleans from XML. Assumes "false" for missing data. @param xml the XmlValue to get a boolean value from @return the boolean fr
prj/coherence-core/src/main/java/com/tangosol/dev/component/Trait.java:587
↓ 2 callersMethodreadBoolean
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofBufferReader.java:80
↓ 2 callersMethodreadByte
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/io/AbstractReadBuffer.java:448
↓ 2 callersMethodreadComplexTypeHeader
@return @throws IOException
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/pof/PofBufferTest.java:85
↓ 2 callersMethodreadDoubleArray
Read an array of doubles for the specified length from a DataInput stream. @param in a DataInput stream to read from @param c length to read @ret
prj/coherence-core/src/main/java/com/tangosol/internal/util/DoubleBag.java:258
↓ 2 callersMethodreadEncrypted
Attempt to read from the network into the inbound encrypted buffer. The caller must hold the read monitor. @return the number of bytes read @throws
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/ssl/SSLSocketChannel.java:1139
↓ 2 callersMethodreadExternal
Restore the contents of this object by loading the object's state from the passed DataInput object. @param in the DataInput stream to read data from
prj/coherence-core/src/main/java/com/tangosol/io/ExternalizableLite.java:88
↓ 2 callersMethodreadExternal
Read this object from an ObjectInputStream. @param in the ObjectInputStream to read this object from @throws IOException if an exception occurs re
prj/coherence-core/src/main/java/com/tangosol/util/UUID.java:577
↓ 2 callersMethodreadExternal
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/util/aggregator/QueryRecorder.java:149
↓ 2 callersMethodreadFloatArray
Read an array of float numbers from a DataInput stream. @param in a DataInput stream to read from @return an array of floats @throws IOException
prj/coherence-core/src/main/java/com/tangosol/util/ExternalizableHelper.java:2049
↓ 2 callersMethodreadHeader
Transfer as many bytes as possible from the inbound header buffer to the supplied buffer @param aBufDst the destination buffers @param offset the
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/MultiplexedSocketProvider.java:1609
↓ 2 callersMethodreadHistgram
Read histgram from a DataInput stream. @param in a DataInput stream to read from @return an array of longs @throws IOException if an I/O exceptio
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/util/Histogram.java:399
↓ 2 callersMethodreadInt
{@inheritDoc}
prj/coherence-core/src/main/java/com/oracle/coherence/common/io/BufferSequenceInputStream.java:252
↓ 2 callersMethodreadIntArray2d
Read a 2-dimensional int-array from the stream. @param in the input stream to read from @return the 2-dimensional int-array @throws IOException if
prj/coherence-core/src/main/java/com/tangosol/util/ExternalizableHelper.java:1011
↓ 2 callersMethodreadInternal
(ISReader isReader)
prj/coherence-http-netty/src/main/java/com/tangosol/coherence/http/netty/NettyInputStream.java:83
↓ 2 callersMethodreadInternal
(com.tangosol.io.ReadBuffer.BufferInput input)
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/Message.java:1123
↓ 2 callersMethodreadLargeObjectArray
Read an array of objects with length larger than {@link #CHUNK_THRESHOLD} {@literal >>} 4. @param in a DataInput stream to read from @param cLe
prj/coherence-core/src/main/java/com/tangosol/util/ExternalizableHelper.java:6649
↓ 2 callersMethodreadLocalDate
Read a LocalDate value from a POF stream. @param in the stream containing the POF date value @return a LocalDate object @throws IOException on rea
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofHelper.java:610
↓ 2 callersMethodreadLocalModelArray
Read an array of LocalModel instances from a DataInput stream. @param in a DataInput stream to read from @return an array of LocalModel instances
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/Connector.java:4869
↓ 2 callersMethodreadLocalTime
Read a <tt>java.time.LocalTime</tt> from the POF stream. @param iProp the property index to read @return the <tt>LocalTime</tt> property value, or
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofReader.java:437
↓ 2 callersMethodreadLongArray
Read an array of long numbers using the provided DataInput stream. @param in a DataInput stream to read from @return an array of longs @throws IOE
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/management/Connector.java:5292
↓ 2 callersMethodreadMigrationStatus
Read migration status from the active directory. @param fileActive the active directory @return the migration status
prj/coherence-core/src/main/java/com/tangosol/persistence/journal/JournalPersistenceEnvironment.java:537
↓ 2 callersMethodreadNext
()
prj/coherence-core/src/main/java/com/tangosol/io/bdb/BerkeleyDBBinaryStore.java:359
↓ 2 callersMethodreadObjectArray
Read an array of the specified number of objects from a DataInput stream. @param in a DataInput stream to read from @param cLength length to r
prj/coherence-core/src/main/java/com/tangosol/util/LiteSet.java:899
↓ 2 callersMethodreadObjectArray
Read an array of objects from a DataInput stream. @param in a ObjectInputStream stream to read from @return an array of objects @throws IOExceptio
prj/coherence-core/src/main/java/com/tangosol/util/CircularArrayList.java:823
↓ 2 callersMethodreadObjectData
()
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/pof/PofReaderTest.java:419
↓ 2 callersMethodreadObjectInternal
Read an object of a known type from the specified DataInput.
prj/coherence-core/src/main/java/com/tangosol/util/ExternalizableHelper.java:3007
↓ 2 callersMethodreadOffsetDateTime
Read a <tt>java.time.OffsetDateTime</tt> from the POF stream. @param iProp the property index to read @return the <tt>OffsetDateTime</tt> property
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofReader.java:452
↓ 2 callersMethodreadOffsetTime
Read a <tt>java.time.OffsetTime</tt> from the POF stream. @param iProp the property index to read @return the <tt>OffsetTime</tt> property value, o
prj/coherence-core/src/main/java/com/tangosol/io/pof/PofReader.java:467
↓ 2 callersMethodreadOuput
()
prj/test/functional/dslquery/src/main/java/dslquery/QueryPlusRunner.java:143
↓ 2 callersMethodreadPersistedExtentIds
Read persisted extent identifiers. @return persisted extent identifiers @throws IOException on I/O failure
prj/coherence-core/src/main/java/com/tangosol/persistence/journal/JournalPersistenceManager.java:1294
↓ 2 callersMethodreadStoreEntry
Read the full STORE entry referenced by the supplied ticket. @param lTicket the STORE ticket @return the parsed STORE entry @throws IOException on
prj/coherence-core/src/main/java/com/tangosol/io/journal2/PartitionJournal.java:833
↓ 2 callersMethodreadString
(RecordedEvent event, String sName)
prj/test/performance/benchmarks/src/main/java/com/tangosol/coherence/performance/benchmarks/daemonpool/common/JfrPinnedThreadParser.java:149
↓ 2 callersMethodreadStringMap
Read a StringMap of data from XML. @param xml the XML containing a StringMap @param sMap the name of the set of key/key mappings in the XML;
prj/coherence-core/src/main/java/com/tangosol/dev/component/Trait.java:775
↓ 2 callersMethodreadTableKeys
Read a StringTable of keys from XML. @param xml the XML element that contains the table of keys @param sTable the XML element name that encloses
prj/coherence-core/src/main/java/com/tangosol/dev/component/Trait.java:707
↓ 2 callersMethodreadUnknownProperty
Called whenever a property is encountered in a JSON document that doesn't have a corresponding {@link PropertyMutator}. <p> Typically, the implementat
prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/reflect/UnknownPropertyHandler.java:54
↓ 2 callersMethodreadVersionedObjectData
()
prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/pof/PofReaderTest.java:507
↓ 2 callersMethodreadXml
Deserialize an object from XML. Note that the parent element is the one passed to this method; this method is responsible for finding all of the nece
prj/coherence-core/src/main/java/com/tangosol/run/xml/PropertyAdapter.java:564
↓ 2 callersMethodrealize
Realize a SSLSocketProviderDefaultDependencies based on configured/defaulted values for config element ssl. <p> Note: unlike typical builders, this is
prj/coherence-core/src/main/java/com/tangosol/coherence/config/builder/SSLSocketProviderDependenciesBuilder.java:350
↓ 2 callersMethodrealize
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/coherence/config/builder/PartitionedCacheQuorumPolicyBuilder.java:67
↓ 2 callersMethodrealize
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/coherence/config/builder/LocalAddressProviderBuilder.java:98
↓ 2 callersMethodrealize
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/coherence/config/builder/ProxyQuorumPolicyBuilder.java:48
↓ 2 callersMethodrealize
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/coherence/config/builder/storemanager/AsyncStoreManagerBuilder.java:42
↓ 2 callersMethodrealize
Realize (ensure) a remote NamedCache, CacheStore, CacheLoader, or BinaryEntryStore as specified by the builder. The returned cache is fully configured
prj/coherence-core/src/main/java/com/tangosol/coherence/config/scheme/CacheStoreScheme.java:65
↓ 2 callersMethodrealize
(ExecutionContext ctx, NodeTerm term, List listBindVars, ParameterResolver
prj/coherence-core/src/main/java/com/tangosol/coherence/dslquery/statement/UpdateStatementBuilder.java:43
↓ 2 callersMethodrealize
(ExecutionContext ctx, NodeTerm term, List listBindVars, ParameterResolver namedBindVars)
prj/coherence-core/src/main/java/com/tangosol/coherence/dslquery/statement/QueryRecorderStatementBuilder.java:51
↓ 2 callersMethodrealize
(ExecutionContext ctx, NodeTerm term, List listBindVars, ParameterResolver
prj/coherence-core/src/main/java/com/tangosol/coherence/dslquery/statement/DeleteStatementBuilder.java:43
↓ 2 callersMethodrealizeMap
{@inheritDoc}
prj/coherence-core/src/main/java/com/tangosol/coherence/config/scheme/LocalScheme.java:76
↓ 2 callersMethodreasonToString
Return a human-readable description for the specified REASON_ constant. @param nReason one of the REASON_ constants @return the operation descripti
prj/coherence-core/src/main/java/com/tangosol/net/security/StorageAccessAuthorizer.java:80
↓ 2 callersMethodrecalculateOffset
Recalculates the offset for {@code vector}. @param vector the vector to quantize @param oldAlpha the previous alpha value @param oldMin
prj/coherence-vector-util/src/main/java/com/tangosol/internal/lucene/util/VectorUtil.java:456
↓ 2 callersMethodreceive
Receive a message from a given {@link Subscriber} and once processed, re-subscribe. @param element {@link Element} received @param throwable {@lin
prj/examples/guides/460-topics/src/main/java/com/oracle/coherence/guides/topics/ChatApplication.java:290
↓ 2 callersMethodreceive
Called when a Message is received via this Channel. This method is called on the service thread ("Channel0" Messages) or on a daemon thread. @param m
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/extend/Channel.java:1540
↓ 2 callersMethodreceivePartition
Receive the partition, and any associated data or state, as specified by the $TransferRequest. @param iPartition the partition to recei
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:8336
↓ 2 callersMethodreconcileMailboxAfterDrain
Reconcile the keyed-mailbox map after a drainer exits. Serializing this state change through the map avoids removing a mailbox that has already been r
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/Service.java:4405
↓ 2 callersMethodrecordCheckpointMetrics
Record checkpoint metrics and optionally log the checkpoint. @param sReason checkpoint reason @param cNanosTotal total checkpoint time @param c
prj/coherence-core/src/main/java/com/tangosol/persistence/journal/JournalPersistenceManager.java:2665
↓ 2 callersMethodrecordCommand
Record a command in the history.
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/application/console/Coherence.java:6268
↓ 2 callersMethodrecordExtractor
Record all relevant index information for any index associated with the given extractor (e.g. index lookup and range scan). This method may be called
prj/coherence-core/src/main/java/com/tangosol/util/QueryRecord.java:186
↓ 2 callersMethodrecordRecoveryStatus
(PersistenceEnvironment env, String sSnapshot, boolean bRecoverySuccess, String sReason)
prj/coherence-core/src/main/java/com/tangosol/persistence/CachePersistenceHelper.java:1771
↓ 2 callersMethodrecordRequest
Update the partition statistics to record the specified request. @param cWaitMillis the time (in ms) that the task/request spent waiting @param cExe
prj/coherence-core/src/main/java/com/tangosol/net/partition/PartitionStatistics.java:86
↓ 2 callersMethodrecordRoute
Async client-streaming example. Sends {@code numPoints} randomly chosen points from {@code features} with a variable delay in between. Prints the stat
prj/test/functional/grpc-proxy-tck/src/main/java/grpc/proxy/routeguide/RouteGuideClient.java:115
↓ 2 callersMethodrecordSummary
Record a recovery summary contribution. @param cRecoveries number of recovery operations represented @param cKeys number of rec
prj/coherence-core/src/main/java/com/tangosol/persistence/PersistenceRecoveryMetrics.java:71
↓ 2 callersMethodrecordUsage
Record the current buffer usage.
prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/io/SegmentedBufferManager.java:922
↓ 2 callersMethodrecycleBlock
Release (recycle) the specified Block object. This method should not be called directly; instead, call block.close(). @param block the Block object
prj/coherence-core/src/main/java/com/tangosol/io/nio/BinaryMap.java:3486
↓ 2 callersMethodreduce
Performs a <em>reduction</em> on the elements of this stream, using the provided identity value and an <em>associative</em> accumulation function, and
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteDoubleStream.java:410
↓ 2 callersMethodreduce
Performs a <em>reduction</em> on the elements of this stream, using the provided identity value and an <em>associative</em> accumulation function, and
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteLongStream.java:408
↓ 2 callersMethodreduce
Performs a <em>reduction</em> on the elements of this stream, using the provided identity value and an <em>associative</em> accumulation function, and
prj/coherence-core/src/main/java/com/tangosol/util/stream/RemoteIntStream.java:408
↓ 2 callersMethodreevaluateQueryResults
An index query returned some keys, which is suspect to have values that where during the population phase of the query. These values need to be reeval
prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:8373
↓ 2 callersMethodrefillScanBuffer
Refill the sequential scan buffer, preserving any unread bytes. @param raf open journal file @param abBuffer scan buffer @param ofBuffer firs
prj/coherence-core/src/main/java/com/tangosol/io/journal2/JournalUtils.java:253
↓ 2 callersMethodrefreshAddressList
Refresh the cached address list using the underlying provider.
prj/coherence-core/src/main/java/com/tangosol/net/RefreshableAddressProvider.java:168
↓ 2 callersMethodrefreshIterator
Set the value of {@code m_iterator} to a new iterator from the address list, and ensure the address list is refreshed.
prj/coherence-core/src/main/java/com/tangosol/net/RefreshableAddressProvider.java:355
← previousnext →17,201–17,300 of 78,752, ranked by callers