Functions — github.com/oracle/coherence

hub / github.com/oracle/coherence / functions

Functions78,752 in github.com/oracle/coherence

⨍ Functions 78,752◇ Types & classes 10,274

prj/test/unit/coherence-tests/src/test/java/com/tangosol/util/ExternalizableHelperTest.java:914

Atomically sets the value to {@code newValue} if the current value {@code == expectedValue}. @param fExpectedValue the expected value @param fNewVal

prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/atomic/AtomicBoolean.java:66

↓ 3 callersMethodcompareByteArray

Compares two byte arrays with each other and verifies that the content is equal. @param abOne @param abTwo

prj/test/unit/coherence-tests/src/test/java/com/tangosol/io/ByteArrayReadBufferTest.java:526

↓ 3 callersMethodcompareImportance

Compare importance of the specified Member with the local Member. This method is usually called during processing of the partial packet delivery failu

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:1147

↓ 3 callersMethodcompareTimestamp

Compares the timestamps for the head and tail elements of this page with the specified timestamp. @param lTimestamp the timestamp to check @return

prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/impl/paged/model/Page.java:194

↓ 3 callersMethodcompareTo

Compares this object with the specified object for order. Returns a negative integer, zero, or a positive integer as this object is less than, equal

prj/coherence-core/src/main/java/com/tangosol/util/UUID.java:514

↓ 3 callersMethodcompareTo

{@inheritDoc}

prj/coherence-testing-support/src/main/java/com/oracle/coherence/testing/TestContact.java:147

↓ 3 callersMethodcomparingDouble

Accepts a function that extracts a {@code double} sort key from a type {@code T}, and returns a {@code Comparator<T>} that compares by that sort key.

prj/coherence-core/src/main/java/com/tangosol/util/function/Remote.java:2639

↓ 3 callersMethodcomplete

Complete as many outstanding requests as possible from the contents of the pre-fetch queue. @param queueRequest the queue of requests to complete

prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/NamedTopicSubscriber.java:1236

↓ 3 callersMethodcompleteKeyValue

Send a response containing a {@link BinaryKeyAndValue} to a {@link StreamObserver} and then complete the observer. @param binKey the binary key to

prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/BaseProxyProtocol.java:216

↓ 3 callersMethodcompleteMapStream

Send a response containing a stream of {@link BinaryKeyAndValue} to a {@link StreamObserver} and then complete the observer. @param request the {@l

prj/coherence-grpc-proxy-common/src/main/java/com/oracle/coherence/grpc/proxy/common/BaseProxyProtocol.java:248

↓ 3 callersMethodcompose

Returns a composed function that first applies the {@code before} function to its input, and then applies this function to the result. If evaluation o

prj/coherence-core/src/main/java/com/tangosol/util/function/Remote.java:438

↓ 3 callersMethodcomposeURL

Helper method to build a {@link URL} to the Metrics over HTTP service given a host and port. @param sHost the Management over HTTP listening address

prj/coherence-core/src/main/java/com/tangosol/internal/net/metrics/MetricsHttpHelper.java:56

↓ 3 callersMethodcomputeBuddies

Compute this member's buddy set.

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/ClusterService.java:21080

↓ 3 callersMethodconfigProperty

()

prj/coherence-rag-parent/coherence-rag/src/test/java/com/oracle/coherence/rag/model/AbstractModelSupplierTest.java:366

↓ 3 callersMethodconfigProperty

Returns the configuration property key for this model supplier. This method must be implemented by subclasses to specify which configuration prop

prj/coherence-rag-parent/coherence-rag/src/main/java/com/oracle/coherence/rag/model/AbstractModelSupplier.java:189

↓ 3 callersMethodconfigureCacheStore

Set up the StoreWrapper that this backing map will use. @param store the StoreWrapper that this backing map will delegate pers

prj/coherence-core/src/main/java/com/tangosol/net/cache/ReadWriteBackingMap.java:5099

↓ 3 callersMethodconfigureSocket

Configure the specified Socket @param socket the socket to configure @throws IOException on an I/O error

prj/coherence-core/src/main/java/com/oracle/coherence/common/internal/net/socketbus/AbstractSocketBus.java:971

↓ 3 callersMethodconfigureSynchronization

Set up the listeners that keep the {@code ContinuousQueryCache} up-to-date. @param fReload pass {@code true} to force a data reload

prj/coherence-core/src/main/java/com/tangosol/net/cache/ContinuousQueryCache.java:1689

↓ 3 callersMethodconnect

Ensure that the subscriber is connected.

prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/SubscriberStatistics.java:276

↓ 3 callersMethodconnectionClosed

Invoked after a Connection is closed. @param evt the {@link ConnectionEvent#CONNECTION_CLOSED} event After this event is raised, any attempt to

prj/coherence-core/src/main/java/com/tangosol/net/messaging/ConnectionListener.java:52

↓ 3 callersMethodconnectionError

Invoked when the ConnectionManager detects that the underlying communication channel has been closed by the peer, severed, or become unusable. Aft

prj/coherence-core/src/main/java/com/tangosol/net/messaging/ConnectionListener.java:64

↓ 3 callersMethodcontains

Determines if an option of the specified concrete type is in the collection. @param clzOfOption the class of option @param <O> the type of

prj/coherence-concurrent/src/main/java/com/oracle/coherence/concurrent/executor/util/OptionsByType.java:159

↓ 3 callersMethodcontainsAll

{@inheritDoc}

prj/coherence-core/src/main/java/com/tangosol/util/ConverterCollections.java:3917

↓ 3 callersMethodcontainsAll

(java.util.Collection collection)

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/MemberSet.java:946

↓ 3 callersMethodcontainsKey

(Object key)

prj/coherence-core/src/main/java/com/tangosol/persistence/journal/JournalBackingMap.java:113

↓ 3 callersMethodcontainsKey

Determine whether a mapping to the specified key exists in the cache. @param key the key to check @return a {@link CompletableFuture} returning {@cod

prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/NamedCacheClientChannel.java:169

↓ 3 callersMethodcontextWithScheme

(String sScheme, String sName, String... asRole)

prj/coherence-rag-parent/coherence-rag/src/test/java/com/oracle/coherence/rag/api/ConfigTest.java:449

↓ 3 callersMethodconvertArguments

(String[] asParam)

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/application/console/Coherence.java:1070

↓ 3 callersMethodconvertHash

Convert the provided hash to a permitted hash, avoiding the reserved value (Integer.MIN_VALUE). @param nHash the hash to be interrogated @return a

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/PartitionedService.java:2096

↓ 3 callersMethodconvertKeyToInternal

(Object oKey)

prj/coherence-core/src/main/java/com/tangosol/net/internal/SessionLocalBackingMap.java:216

↓ 3 callersMethodcopyBufferInputPortion

Read a portion of the specified BufferInput and write it to the specified offset within this buffer. @param ofDest the offset within this buffer to

prj/coherence-core/src/main/java/com/tangosol/io/AbstractWriteBuffer.java:266

↓ 3 callersMethodcopyFrom

Copy the lease data from the specified Lease. @param lease the Lease object to copy the data from

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/Lease.java:409

↓ 3 callersMethodcopyOnAdd

Create a new array from an old one by adding the specified element.

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/DaemonPool.java:768

↓ 3 callersMethodcopyPreGeneratedLibraryFiles

(Path folder, String fileName)

prj/coherence-hnsw/src/main/java/com/oracle/coherence/hnswlib/HnswlibFactory.java:78

↓ 3 callersMethodcopyStream

Store the remaining contents of the specified InputStreaming object at the specified offset within this buffer. @param ofDest the offset within thi

prj/coherence-core/src/main/java/com/tangosol/io/AbstractWriteBuffer.java:325

↓ 3 callersMethodcopyVersion

Copy the lease version from the specified Lease. @param lease the Lease object to copy the version info from

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/net/Lease.java:441

↓ 3 callersMethodcosine

Calculate the cosine similarity of two float32 vectors. @param v1 the first vector @param v2 the second vector @return the cosine similarity of th

prj/coherence-core/src/main/java/com/oracle/coherence/ai/util/Vectors.java:75

↓ 3 callersMethodcountBitsSlowly

Brute force bit counter. @param l a long @return the number of "one" bits in the long

prj/test/unit/coherence-tests/src/test/java/com/tangosol/util/BitHelperTest.java:506

↓ 3 callersMethodcreate

Creates a populated instance of a Person class to be used in tests. @return a populated instance of a Person class to be used in tests

prj/coherence-testing-data/src/main/java/data/pof/Person.java:219

↓ 3 callersMethodcreateAddressProvider

Create a new AddressProvider using the specified class loader. @param loader the optional ClassLoader with which to configure the new

prj/coherence-core/src/main/java/com/tangosol/net/AddressProviderFactory.java:26

↓ 3 callersMethodcreateAndFillArray

Create a new array of componentType of cSize. The content of the array will be initialized. @param cSize the number of items in the array @return

prj/test/functional/io/src/main/java/io/ObjectInputFilterTests.java:821

↓ 3 callersMethodcreateAndPopulate

()

prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/config/SimpleParameterListTest.java:60

↓ 3 callersMethodcreateAndPopulate

()

prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/config/builder/InstanceBuilderTest.java:188

↓ 3 callersMethodcreateAndPopulate

()

prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/config/builder/StaticFactoryInstanceBuilderTest.java:138

↓ 3 callersMethodcreateAndPopulate

()

prj/test/unit/coherence-tests/src/test/java/com/tangosol/config/expression/ChainedParameterResolverTest.java:60

↓ 3 callersMethodcreateAndPopulate

()

prj/test/unit/coherence-tests/src/test/java/com/tangosol/config/expression/ParameterTest.java:78

↓ 3 callersMethodcreateAndPopulate

()

prj/test/unit/coherence-tests/src/test/java/com/tangosol/config/expression/ScopedParameterResolverTest.java:58

↓ 3 callersMethodcreateAndPopulate

()

prj/test/unit/coherence-tests/src/test/java/com/tangosol/config/expression/LiteralExpressionTest.java:56

↓ 3 callersMethodcreateAndPopulate

()

prj/test/unit/coherence-tests/src/test/java/com/tangosol/config/expression/NullParameterResolverTest.java:54

↓ 3 callersMethodcreateBeanPropertyFactory

()

prj/coherence-json/src/main/java/com/oracle/coherence/io/json/genson/GensonBuilder.java:1164

↓ 3 callersMethodcreateBinaryResponse

()

prj/test/functional/memcached/src/main/java/memcached/ResponseQueueTest.java:111

↓ 3 callersMethodcreateBus

Create a new Bus bound to the specified local EndPoint. @param pointLocal the local EndPoint or null for an ephemeral EndPoint @return the Bus @th

prj/coherence-core/src/main/java/com/oracle/coherence/common/net/exabus/spi/Driver.java:65

↓ 3 callersMethodcreateCalculatedProperty

Create a calculated Property. A calculated Property is declared as "transient out", which means no corresponding Java field is generated. A calculate

prj/coherence-core/src/main/java/com/tangosol/dev/component/Property.java:1929

↓ 3 callersMethodcreateClassPath

()

prj/test/performance/psr/src/test/java/com/tangosol/coherence/performance/PsrPerformanceEnvironment.java:761

↓ 3 callersMethodcreateCommonSchema

(Capture<Integer> captureClusterPort, Class clsMain)

prj/test/performance/psr/src/test/java/com/tangosol/coherence/performance/PsrPerformanceEnvironment.java:976

↓ 3 callersMethodcreateConfiguration

Create a ConfigurableAddressProvider XML configuration. @param cAddresses number of addresses to include in configuration; values

prj/test/unit/coherence-tests/src/test/java/com/tangosol/net/ConfigurableAddressProviderTest.java:135

↓ 3 callersMethodcreateContainer

(HttpHandler resourceConfig)

prj/coherence-core/src/main/java/com/tangosol/coherence/http/JavaHttpServer.java:94

↓ 3 callersMethodcreateDeps

Create a DefaultClusterDependencies object. This is needed until the 3 jira's described below are fixed. This method is also used by ClusterMemberId

prj/test/unit/coherence-tests/src/test/java/com/tangosol/internal/net/cluster/DefaultClusterDependenciesTest.java:360

↓ 3 callersMethodcreateEmbedding

Creates a test embedding with the specified dimensions. @param dimensions the number of dimensions @return a new Embedding instance

prj/coherence-rag-parent/coherence-rag/src/test/java/com/oracle/coherence/rag/util/TestDataFactory.java:161

↓ 3 callersMethodcreateEntry

(String key, float[] vector)

prj/test/functional/ai/src/main/java/ai_tests/search/SimilaritySearchTest.java:225

↓ 3 callersMethodcreateEraseExtentEntry

Create an ERASE_EXTENT entry. This method is retained for unit-test and parsing scenarios. @return a {@link ByteBuffer} ready for writing to a jo

prj/coherence-core/src/main/java/com/tangosol/io/journal2/JournalEntry.java:153

↓ 3 callersMethodcreateExtractor

Create expression extractor. @param sExpr expression to create extractor for @return extractor for the specified expression

prj/coherence-rest/src/main/java/com/tangosol/coherence/rest/util/ComparatorBuilder.java:169

↓ 3 callersMethodcreateFunctionalProperty

Create a functional Property. Properties which are settable-only (declared as "in") are considered to be functional. A functional Property is implem

prj/coherence-core/src/main/java/com/tangosol/dev/component/Property.java:1979

↓ 3 callersMethodcreateHttpsClient

Create a new HTTPS client. @param provider the SSLSocketProvider used by the HTTPS client @return a new HTTPS client

prj/test/functional/security/src/main/java/security/NettyRestSecurityTests.java:102

↓ 3 callersMethodcreateJarFile

Use the {@code fileSrc} argument as the root of the jar contents. Package the entire contents using the JAR format to the specified {@code fileDest} {

prj/test/functional/io/src/main/java/io/PortableTypeMultipleIndexesTests.java:205

↓ 3 callersMethodcreateJavaConstant

Create a Java constant Property. A constant field is generated in the Java class that results from the Component Definition that declares the constan

prj/coherence-core/src/main/java/com/tangosol/dev/component/Property.java:1840

↓ 3 callersMethodcreateJoinExtractor

Create an instance of {@link JoinExtractor}. @return an instance of {@link JoinExtractor}

prj/test/unit/coherence-tests/src/test/java/com/tangosol/coherence/reporter/extractor/JoinExtractorTest.java:180

↓ 3 callersMethodcreateKey

Create a key for the marshallers map. @param clzRoot root object class @param sMediaType media type @return key for the marshallers cache

prj/coherence-rest/src/main/java/com/tangosol/coherence/rest/io/MarshallerRegistry.java:238

↓ 3 callersMethodcreateMBeanServerProxyFactory

(Supplier<MBeanServer> supplier)

prj/coherence-management/src/main/java/com/tangosol/coherence/management/RestManagement.java:233

↓ 3 callersMethodcreateMapIndex

Create MapIndex for the specified ValueExtractor and add to IndexMap.

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:2148

↓ 3 callersMethodcreateMemberProperties

(String sClusterName, File fileActive, File fileBackup, File fileSnapshot, File fileTrash)

prj/test/functional/persistence/src/main/java/persistence/JournalBackupMapTests.java:373

↓ 3 callersMethodcreateMemoryBus

Create a new MemoryBus bound to the specified local EndPoint. @param pointLocal the local EndPoint or null for an ephemeral EndPoint @return the Me

prj/coherence-core/src/main/java/com/oracle/coherence/common/net/exabus/Depot.java:44

↓ 3 callersMethodcreateMetricName

Create the name to use for a metric. @param objectName the MBean {@link ObjectName} @param attributeInfo the {@link MBeanAttributeInfo} @retu

prj/coherence-core/src/main/java/com/tangosol/internal/metrics/MetricSupport.java:816

↓ 3 callersMethodcreateMockArchivedSnapshot

Create a random archived snapshot in the given directory. @param sSnapshot the name of the snapshot to create the cluster, service then snapshot

prj/test/functional/persistence/src/main/java/persistence/BasicArchiverTests.java:216

↓ 3 callersMethodcreateMockServer

Create a mock server bound to the specified port. @param nPort the listen port @return a mock server bound to the specified port

prj/test/functional/tracing/opentelemetry/core/src/main/java/opentelemetry/core/TestingUtils.java:57

↓ 3 callersMethodcreateObjectInputFilter

Create an ObjectInputFilter from filter. @return return an ObjectInputFilter as an Object to enable working with Java version 8

prj/test/unit/coherence-tests/src/test/java/com/tangosol/util/ExternalizableHelperTest.java:1143

↓ 3 callersMethodcreateObjectName

Create an ObjectName from the MBean name. @param sMBeanName the MBean name @return an {@link ObjectName}

prj/coherence-core/src/main/java/com/tangosol/internal/metrics/MetricSupport.java:326

↓ 3 callersMethodcreatePartialClass

Create a partial class for the specified source class and property set. @param clzSource a source class to base partial the class on @param proper

prj/coherence-rest/src/main/java/com/tangosol/coherence/rest/util/PartialObject.java:200

↓ 3 callersMethodcreatePolicyBuilder

Create an action policy based on the specified XML configuration. @param xmlConfig the cluster-quorum-policy XML element @param loader the

prj/coherence-core/src/main/java/com/tangosol/internal/net/cluster/LegacyXmlConfigurableQuorumPolicy.java:56

↓ 3 callersMethodcreatePrimitives

()

prj/coherence-json/src/test/java/com/oracle/coherence/io/json/genson/convert/JsonSerializationTest.java:177

↓ 3 callersMethodcreatePublisher

Create a publisher. @param member the {@link CoherenceClusterMember} to create the publisher in @param sId an identifier for the publish

prj/test/distribution/topics-compatibility/topics-14.1.1.2206.3/src/test/java/topics/TopicPublisher.java:52

↓ 3 callersMethodcreateQueryResult

Retrieve query results. When calling this method aoResult contains the binary keys for all the entries to instantiate. When returning, it contains th

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:2307

↓ 3 callersMethodcreateQueue

(NamedMapQueue<Binary, Binary> queue)

prj/coherence-core/src/main/java/com/tangosol/internal/net/queue/ConverterNamedMapQueue.java:205

↓ 3 callersMethodcreateRecoveryProperties

(File fileActive, File fileSnapshot, File fileTrash, String sCl

prj/test/functional/persistence/src/main/java/persistence/BerkeleyDBSimplePersistenceTests.java:772

↓ 3 callersMethodcreateRequest

(final String sMethod, final String sEtag)

prj/coherence-rest/src/test/java/com/tangosol/coherence/rest/EntryResourceTest.java:247

↓ 3 callersMethodcreateSSLSettings

Return an SSLSettings initialize via {@link SSLSocketProvider.Dependencies} @param depsSSL SSL Dependencies info @return a new {@link SSLSettings} i

prj/coherence-core/src/main/java/com/tangosol/net/SocketProviderFactory.java:518

↓ 3 callersMethodcreateSchema

(File fileClass, Map<String, ?> env)

prj/coherence-core/src/main/java/com/tangosol/io/pof/generator/PortableTypeGenerator.java:845

↓ 3 callersMethodcreateSnapshotArchiver

Create a new SnapshotArchiver. @param sClusterName the name of the Cluster that is creating the archiver @param sServiceName t

prj/coherence-core/src/main/java/com/tangosol/persistence/SnapshotArchiverFactory.java:27

↓ 3 callersMethodcreateStreamer

Create a streamer of $BinaryEntry objects for a given filter and partition set.

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/util/daemon/queueProcessor/service/grid/partitionedService/partitionedCache/Storage.java:2489

↓ 3 callersMethodcreateStubWithDeadline

Create the default {@link NamedCacheServiceGrpc.NamedCacheServiceStub} to use for requests. The value of {@link PriorityTask#TIMEOUT_DEFAULT TIME

prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/v0/NamedCacheGrpcClient.java:626

↓ 3 callersMethodcreateStubWithoutDeadline

Create the default {@link ProxyServiceGrpc.ProxyServiceStub} to use for requests. @return the default {@link ProxyServiceGrpc.ProxyServiceStub}

prj/coherence-grpc-client-common/src/main/java/com/oracle/coherence/grpc/client/common/v1/GrpcConnectionV1.java:721

↓ 3 callersMethodcreateSubscriberConnector

Create a {@link SubscriberConnector}. @return a {@link SubscriberConnector}

prj/coherence-core/src/main/java/com/tangosol/internal/net/topic/SubscriberConnector.java:350

↓ 3 callersMethodcreateTables

(Connection connection)

prj/examples/guides/195-bulk-loading-caches/src/test/java/com/oracle/coherence/guides/preload/AbstractPreloadIT.java:97

↓ 3 callersMethodcreateTempDir

Create a unique temporary directory. @return a unique temporary directory

prj/test/functional/executor/src/main/java/executor/TaskExecutorServicePersistenceTests.java:356

↓ 3 callersMethodcreateTypeBasedCollector

Return a Collector that can operate against known types (integers, longs, doubles, floats, CompositeData and TabularDataSupport). @param oValue the

prj/coherence-core/src/main/java/com/tangosol/internal/net/management/MBeanCollectorFunction.java:728

↓ 3 callersMethodcreateVirtualPool

(int cTaskLimit)

prj/test/functional/core/src/main/java/com/tangosol/coherence/component/util/DaemonPoolIT.java:744

↓ 3 callersMethodcurrentTimeInSeconds

()

prj/coherence-core/src/main/java/com/tangosol/internal/net/metrics/ExponentiallyDecayingReservoir.java:142

↓ 3 callersMethoddebugOutput

Prints out the specified message according to the Application context. Derived applications should provide an appropriate implementation for this meth

prj/coherence-core-components/src/main/java/com/tangosol/coherence/component/Application.java:421

↓ 3 callersMethoddecrementAndGet

Decrement the long and return the new value. @return the new value

prj/coherence-core/src/main/java/com/oracle/coherence/common/base/MutableLong.java:76

← previous next →10,201–10,300 of 78,752, ranked by callers