All Classes and Interfaces
Class
Description
An action is the core logic that occurs within an activity.
An ActionDispenser is created for each Activity instance within a scenario.
Dispensers that implement this decorator interface might need to know about the other
activities that are present in a configuration.
Provides the components needed to build and run an activity a runtime.
Provide a bindings wrapper around a ScenarioController,
A runtime definition for an activity.
Decorator interface for getting notified when an activities parameters are changed at runtime.
An ActivityExecutor is an execution harness for a single activity instance.
ActivityInitErrors are those known to occur during the initiailization of an activity.
Represents an error that occurred while initializing an activity instance to run.
All the accessors of the metrics that will be used for each activity instance.
Consolidates the activity type and activity instantiation logic into one place
per scope.
Adds a value to the input.
Adds a cycle range to the input, producing an increasing sawtooth-like output.
Adds a pseudo-random value within the specified range to the input.
Uses the alias sampling method to encode and sample from discrete probabilities,
even over large sets of data.
Uses the alias sampling method to encode and sample from discrete probabilities,
even over larger sets of data.
Create an alpha-numeric string of the specified length, character-by-character.
This is a general purpose representation of an event that describes
a significant workflow detail to users running tests.
An implementation of this type is responsible for taking annotation details and
logging them in a useful place.
Singleton-scoped annotator interface for the local process.
An AsyncAction allows an activity type to implement asynchronous
operations within each thread.
TODO: This documentation is out of date as of 2.0.0
Delete an Azure AI Search index.
Lists the indexes available.
The
AzureAISearchSpace class is a context object which stores all
stateful contextual information needed to interact with the
Azure AI Search database instance.See
OpDispenser for details on how to use this type.This example of a space uses the SelfT technique to enable
the self type to be used in method signatures and return types.
User exceptions are errors for which we know how to explain the cause to the user.
Provide named doubles without resorting to Map and boxing shenanigans.
A Binder is a type that knows how to return a result object given a long value
to bind mapped values with.
Maps a template with named bind points and specifiers onto a set of data
mapping function instances.
A bindings library is simply a service point for a specific way
to map a column definition to a binding function.
Maps a set of parameters on an associated object of type T to specifiers for data mappers.
A bind point is a named injection point in a field value or
statement needed for an operation of some type.
Type type of bindpoint indicates whether is was specified as a reference or a definition.
BindPointParser parses a user-provide string template into spans.
This cycle value supplier blocks the caller, only letting it complete
for each value that is set from the controlling producer.
Easily step from one value to the next according to a modified
logarithmic sequence that makes it easy to pick useful testing
boundaries.
Introduction
This is a lightweight buffer implementation that allows for buffer
flipping and callbacks when the buffer is full.
At runtime, any instances of markdown content or other static
assets which are intended to be copied into the external doc site,
or otherwise made available under a local doc service.
If a type implements this interface, then it wants to be provided with a data source in the form of a series of byte
buffers.
Create a ByteBuffer from a long input based on a provided size function.
Convert the contents of the input ByteBuffer to a String as hexadecimal.
A simple bytebuffer marker implementation
A silly class that does nothing but allow cleaner code elsewhere,
because MetricRegistryListener, that's why.
A capture point is a named variable which should be extracted from a payload or result type
using a native driver API.
A capture point is named variable which is to be extracted from the
result of an operation, using whichever syntax and type conventions
that are appropriate to the specific op implementation.
Direct the user to additional resources
Most of the functionality of
CqlModel preparation is handled with transformers.The unit of generation is simply everything that is provided to the exporter together.
This was added to nosqlbench because the error handling logic was
starting to look a bit contrived.
Create a CharBuffer from the first function, and then sample data from
that buffer according to the size function.
Builds a shared text image in memory and samples from it
pseudo-randomly with hashing.
Checksum interface to access 128 bit in various ways.
Synopsis
Return a valid city name.
Return a city name, weighted by population density.
Return a city name, weighted by total population.
Clamp the output values to be at least the minimum value and
at most the maximum value.
Clears the per-thread map which is used by the Expr function.
Encapsulate Command parsing and structure for the NoSQLBench command line.
This is the Java-native version of findmax on the NB5.21 architecture.
If the initial trust radius is not large enough with respect to the stopping trust radius, then the search will stop
ascending the approximate manifold too early.
An argument to a command is based on a defined parameter.
A CmdParam is used to define the valid names of arguments and their types.
Take zero or more strings containing combined argv and return
a single
Cmd list containing zero or more commands.Command verbs define the names and possible parameters for valid commands.
This is a higher-order function which takes an input value,
and flips a coin.
ANSI console colors for enhanced logging
Convert a numeric value into a code according to ASCII printable
characters.
Combiner - a combinatoric toolkit for NoSQLBench
A CompletedOp can be any of
SucceededOp
FailedOp
SkippedOp
It may be necessary to downcast a completed Op in order to
get more contextual details from it.A collection of compute functions related to vector search relevancy.
This is the core implementation of the Concat style of String
binding.
This variant of Concat allows you to apply a string concatenation to a series of
string produced by the provided functions.
This is a variant of Concat which chains the hash values
from step to step so that each of the provided functions will
yield unrelated values.
This is a variant of Concat which always uses the input cycle value
as the input for all the functions provided.
This is a variant of Concat which always uses the same value
as input for the functions provided.
This is a variant of Concat which always hashes the cycle+step value
for each function provided.
This sequencer just repeats a number of elements, one element after
another.
This is a variant of Concat which uses the cycle+step sum for each
of the functions provided.
This cache implementation packs referents into an atomic array, keeping things as compact as possible,
allowing auto-resizing, size tracking, and supporting concurrent access with minimal locking.
This is only here for backwards compatibility.
Native driver state in NoSQLBench is stored in a context called a
Space, with each driver adapter
providing its own implementation.The mappings between logging levels for conditions and the advisory
levels should be consistent, so they will be described here to start.
The config loader is meant to be the way that configurations
for objects or subsystems are loaded generically.
A Config Source knows how to read a block of data and convert it
into a stream of zero or more configuration elements.
Always yields the same value.
A ScenarioController provides a way to start Activities,
modify them while running, and forceStopMotors, pause or restart them.
A generic content wrapper for anything that can be given to a NoSQLBench runtime
using a specific type of locator.
A thread-local template that describes a set of data mappers, a context object,
and a method for applying mapped values to the context object via an object array.
A thread-local template that describes a set of data mappers, a context object, and a method for applying
mapped values to the context object directly from the bindings.
A template that maps a set of specifiers, a context object, and a method for applying
mapped values to the context object.
A template that maps a set of specifiers, a context object, and a method for applying
mapped values to the context object.
A thread-local template that describes a set of data mappers, a context object, and a method for applying
mapped values to the context object via a String-Object map.
This is the default cycle output implementation for NB when
the input cycles are known to be contiguous.
An action dispenser that returns a logging action.
ActivityMotor is a Runnable which runs in one of an activity's many threads.
Produce index ActivityMotor instances with an input and action,
given the input and an action factory.
This cycle result filter implements a filter that allows for the
inclusion or exclusion of single-values or intervals.
This is here to allow the classic name 'count' to work although the
modern error handler scheme uses canonical metric type names.
Return a valid county name.
Return a county name weighted by population density.
Return a county name weighted by total population.
Return a valid country code.
Return a valid country name.
This should only be used when there is an exception thrown by some higher level logic.
This class is used to parse the raw JSON from the HDF dataset into a CQL predicate.
Map a long value into a CQL Duration object based on a set of field functions.
This model contains definition level details for schema elements which are parsed from the
Antlr4 CQL grammar.
This class provides an empty implementation of
CqlParserListener,
which can be extended to create a listener which only needs to handle a subset
of the available methods.This interface defines a complete listener for a parse tree produced by
CqlParser.Create a new CqlVector from a composed function, where the inner function
is a list generation function that must take a long (cycle) input.
A criterion is a single component factor of a value for a black-box testing samples.
Takes a CSV with sample data and generates random values based on the
relative frequencies of the values in the file.
This function is a toolkit version of the
WeightedStringsFromCSV function.Provide the millisecond epoch time as given by
Just cycle numbers in a long array.
Provide some basic error handlers
A
Output that writes cycles and results to an RLE-based file format.The
CycleOp is the core interface for any executable operation within
the NoSQLBench runtime.Yields a value within a specified range, which rolls over continuously.
A readable interface for (cycle, result) tuple types.
Implements a cycle result segment in a basic buffer
that contains the cycle and the result in long, byte format.
This is just a typed-data holder for efficient transfer of tracked data.
Implements a cycle result segment in a run-length encoded buffer
that contains the cycle interval and the result in long, long, byte format,
where the last value (the second long value) is *not* included in the
cycle inteval.
Implements a convenient target buffer for Marker data that can be used
to create nio ByteBuffers easily.
Implements a cycle result segment in a basic buffer
that contains the cycle and the result in long, byte format.
A segment of cycle numbers to iterate over.
This class implements an obtuse way of avoiding autoboxing and M:N type
mapping complexity by way of doublish dispatch.
A DataMapperLibrary is an independently loadable library of data mapping functions.
Convenient singleton for accessing all loadable DataMapper Library instances.
This interface is used to parse the raw JSON from the HDF dataset into a CQL predicate.
Takes an input as a reference point in epoch time, and converts it to a DateRange,
with the bounds set to the lower and upper timestamps which align to the
specified precision.
Uses the precision and the two functions provided to create a DateRange.
Takes an input as a reference point in epoch time, and converts it to a DateRange,
with the lower bounds set to the lower bound of the precision and millisecond
provided, and with no upper bound.
Takes an input as a reference point in epoch time, and converts it to a DateRange,
with the upper bound set to the upper bound of the precision and millisecond
provided, and with no lower bound.
Parses the DateRange format according to Date Range Formatting.
The valid formats, in joda specifier form are documented in
DateTimeFormats
yyyy-MM-dd HH:mm:ss.SSSZ, for example: 2015-02-28 23:30:15.223
yyyy-MM-dd HH:mm:ss, for example 2015-02-28 23:30:15
yyyyMMdd'T'HHmmss.SSSZ, for example: 20150228T233015.223
yyyyMMdd'T'HHmmssZ, for example: 20150228T233015
yyyy-MM-dd, for example: 2015-02-28
yyyyMMdd, for example: 20150228
yyyyMM, for example: 201502
yyyy, for example: 2015
This function will parse a String containing a formatted
date time, yielding a DateTime object.
Request Syntax
{
"AttributeDefinitions": [
{
"AttributeName": "string",
"AttributeType": "string"
}
],
"BillingMode": "string",
"GlobalSecondaryIndexes": [
{
"IndexName": "string",
"KeySchema": [
{
"AttributeName": "string",
"KeyType": "string"
}
],
"Projection": {
"NonKeyAttributes": [ "string" ],
"ProjectionType": "string"
},
"ProvisionedThroughput": {
"ReadCapacityUnits": number,
"WriteCapacityUnits": number
}
}
],
"KeySchema": [
{
"AttributeName": "string",
"KeyType": "string"
}
],
"LocalSecondaryIndexes": [
{
"IndexName": "string",
"KeySchema": [
{
"AttributeName": "string",
"KeyType": "string"
}
],
"Projection": {
"NonKeyAttributes": [ "string" ],
"ProjectionType": "string"
}
}
],
"ProvisionedThroughput": {
"ReadCapacityUnits": number,
"WriteCapacityUnits": number
},
"SSESpecification": {
"Enabled": boolean,
"KMSMasterKeyId": "string",
"SSEType": "string"
},
"StreamSpecification": {
"StreamEnabled": boolean,
"StreamViewType": "string"
},
"TableClass": "string",
"TableName": "string",
"Tags": [
{
"Key": "string",
"Value": "string"
}
]
}
Request Syntax
{
"TableName": "string"
}
{
"AttributesToGet": [ "string" ],
"ConditionalOperator": "string",
"ConsistentRead": boolean,
"ExclusiveStartKey": {
"string" : {
"B": blob,
"BOOL": boolean,
"BS": [ blob ],
"L": [
"AttributeValue"
],
"M": {
"string" : "AttributeValue"
},
"N": "string",
"NS": [ "string" ],
"NULL": boolean,
"S": "string",
"SS": [ "string" ]
}
},
"ExpressionAttributeNames": {
"string" : "string"
},
"ExpressionAttributeValues": {
"string" : {
"B": blob,
"BOOL": boolean,
"BS": [ blob ],
"L": [
"AttributeValue"
],
"M": {
"string" : "AttributeValue"
},
"N": "string",
"NS": [ "string" ],
"NULL": boolean,
"S": "string",
"SS": [ "string" ]
}
},
"FilterExpression": "string",
"IndexName": "string",
"KeyConditionExpression": "string",
"KeyConditions": {
"string" : {
"AttributeValueList": [
{
"B": blob,
"BOOL": boolean,
"BS": [ blob ],
"L": [
"AttributeValue"
],
"M": {
"string" : "AttributeValue"
},
"N": "string",
"NS": [ "string" ],
"NULL": boolean,
"S": "string",
"SS": [ "string" ]
}
],
"ComparisonOperator": "string"
}
},
"Limit": number,
"ProjectionExpression": "string",
"QueryFilter": {
"string" : {
"AttributeValueList": [
{
"B": blob,
"BOOL": boolean,
"BS": [ blob ],
"L": [
"AttributeValue"
],
"M": {
"string" : "AttributeValue"
},
"N": "string",
"NS": [ "string" ],
"NULL": boolean,
"S": "string",
"SS": [ "string" ]
}
],
"ComparisonOperator": "string"
}
},
"ReturnConsumedCapacity": "string",
"ScanIndexForward": boolean,
"Select": "string",
"TableName": "string"
}
Formats a floating point value to a string using the java.text.DecimalFormat
Takes a CSV with sample data and generates random values based on the
relative frequencies of the values in the file.
A custom wrapping of snapshotting logic on the HdrHistogram.
This marks functions as deprecated, with a reason.
The base type for building Diagnostic Op tasks, which are composed into
a diagnostic operation in order.
Cause a blocking call to delay the initialization
of this owning operation for a number of milliseconds.
A diag gauge task allows you to create a source of metrics data for testing or demonstration.
Cause a blocking call to delay the initialization
of this owning operation for a number of milliseconds.
Computes the digest of the ByteBuffer on input and stores it in the output
ByteBuffer.
Read each line in each matching file in a directory structure, providing one
line for each time this function is called.
Read each line in each matching file in a directory structure, providing one
line for each time this function is called.
This function takes a long input and ignores it.
Create a Distance generator which produces
com.datastax.driver.dse.geometry.Distance objects.
Divide the operand by a fixed value and return the result.
Integer devide the cycle, the other side of modulo.
This is equivalent to
Div(...), but returns
the result after String.valueOf(...).Compute the indices of the neighbors of a given v using DNN mapping.
Compute the indices of the neighbors of a given v using DNN mapping.
This represents an enumerated population of vectors of some dimension,
where any ordinal values which address outside of that enumeration
simply wrap with modulo.
Implementations of this type represent the ordinals of vectors as integers,
and the component values as doubles.
Provide data about a function, suitable for building a documentation site.
The Docs class is a utility class that makes it easy to enumerate docs for a component.
DocsInfo is a manifest view of a set of namespaces and included
paths.
DocScope determines which display mode a topic is meant to be displayed in.
Doc Path Info represents a readable Path which is part of a well-known
namespace.
The standard way to load and use all of the
DocsNameSpaceImpl
instances which are present in the runtime via SPI.At runtime, any instances of this service will be used to find
paths to be hosted as static content.
Precompute the interior double[] values to use as a LUT.
Precompute the interior double[] values to use as a LUT.
For comprehensive docs on how this works, please see the javadocs for
Combiner<T>.Combine multiple DoubleUnaryOperators into a single function.
A VectorSequence is a sequence of vectors which are a deterministic
map between a set of ordinal values and vector values.
Create a discrete stat reservoir as a gauge.
Convert the input double value to the closest float value.
Prefix the incoming array with an empty double[] so that it is sized up to at least the given size.
Suffix the incoming array with an empty double[] so that it is sized up to at least the given size.
Prefix the incoming array with an empty double[] of the given size.
This is a version of the NoSQLBench
Combiner
which is especially suited to constructing unique sequences of doubles.Suffix the incoming array with an empty double[] of the given size.
The DriverAdapter interface is the top level API for implementing operations of any kind in
NoSQLBench.
This type simply captures (by extension) any optional decorator
interfaces which may be implemented by a
DriverAdapter.This service allows for the dynamic instancing of
DriverAdapters as services,
using a well-defined method signature instead of (just) a no-args constructor.An interface which captures the semantics and patterns of
reading field values that are rendered functionally.
Any type implementing [
DynamicVariableCapture] will allow
a caller to extract a map of names and values from it.Op templates which are supported by the NoSQLBench DynamoDB driver are
enumerated below.
https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/HowItWorks.ReadWriteCapacityMode.html?
Provide the elapsed nano time since the process started.
A generic type-safe reader interface for parameters.
A generic type-safe reader interface for parameters.
The source data for a param reader is intended to be a collection of something, not a single value.
A simple wrapper type for "Event Probability", where the event is identified by a unique int,
and the probability is represented with double precision floating-point.
This distribution is an easy-to use and modify distribution which
is simply based on observed or expected frequencies.
////
Creates a probability density given the values and optional weights provided, in "value:weight value:weight ..." form.
Create a sampler based on enumeration of integer values an sample over them
using the EnumeratedInts distribution curve provided by Apache Commons Math.
A result reading filter which uses an Enum as a set of elements to filter.
Provide a way to configure a target object of type T, given an enumeration which describes the distinct property
types which could be configured.
Converts epoch millis to a java.time.LocalDate, which takes the place
of the previous CQL-specific LocalDate. if a zoneid of 'default' is provided,
then the time zone is set by the default for the JVM.
Converts epoch millis to a java.time.
LocalDate object,
using either the system
default timezone or the timezone provided.Converts epoch millis to a
java.time.
LocalDateTime object, using either the system
default timezone or the timezone provided.Escape all special characters which are required to be escaped when found within
JSON content according to the JSON spec
A simple wrapper type for "Event Probability", where the event is identified by a unique int,
and the probability is represented with double precision floating-point.
A simple wrapper type for "Event Probability", where the event is identified by a unique int,
and the probability is represented with single precision floating-point.
The example annotation allows for a function developer to attach illustrative
examples for any given constructor.
Formatting conventions
Example class doc.
This predicate adapter is not based on any real type of system.
Each
DriverAdapter implementation
is generic over a type ofThis is a synthetic error generated by the cql driver in NoSQLBench when
the retryreplace option is used but the number of LWT round-trips from the driver
is excessive.
Use this to provide exception metering in a uniform way.
Use this to provide exception metering during expected result verification.
Use this to provide exception histograms in a uniform way.
Use this to provide exception metering in a uniform way.
Use this to provide exception metering in a uniform way.
Provide a result type back to a caller, including the start and end times,
any exception that occurred, and any content written to stdout or stderr equivalent
IO streams.
The expected result verification error handler will create, if needed, two metric
objects for error and retry counts.
Allow for the use of arbitrary expressions according to the
MVEL expression language.
An evaluator is a scripting helper that knows what its return type will be at runtime.
A failed op is any operation which has an error, according to the semantics
of the implementing activity type.
holds all FunctionDoc instances for the same basic function name
Extracts out a set of fields from a delimited string, returning
a string with the same delimiter containing only the specified fields.
A fillable object needs to be filled with data.
These search parameters are based on the original findmax algorithm, and
should be reduced down to the minimum set needed.
These parameters are calculated by the planner based on previous simulation frame history.
Return a pseudo-randomly sampled first name from the last US census data on first names
occurring more than 100 times.
Yield a fixed value.
Yield one of the specified values, rotating through them as the input value
increases.
Prefix the incoming array with an empty float[] so that it is sized up to at least the given size.
Suffix the incoming array with an empty float[] so that it is sized up to at least the given size.
Prefix the incoming array with an empty float[] of the given size.
This is the float version of the DoubleVector function.
Suffix the incoming array with an empty double[] of the given size.
Combine functions into one.
Apply the Java String.format method to an incoming object.
A frame sample is responsible for capturing the data associated with a single criterion as a single dependent
variable.
A bundle of frame samples
FrontMatter services provided within NoSQLBench are required to return the following types.
This uses the Murmur3F (64-bit optimized) version of Murmur3,
not as a checksum, but as a simple hash.
Combines the FirstNames and LastNames functions into one that
simply concatenates them with a space between.
This enumerator receives stateful updates out of order from the annotation
processor and constructs consistent view of document models for listeners.
These Listeners handle data that has been found by the FuncEnumerator.
This documentation processor is responsible for finding all the enumerated that feed documentation
manifests.
This annotation processor is responsible for finding all annotated functions and adding
them to the manifest file for the current project.
Captures the list of function object types which may be used
to implement data mapping functions.
Reads ivec files with random access, using the input to specify the record number.
Abstract base class for GCP Spanner operations.
Abstract base class for GCP Spanner operation dispensers.
This class represents an operation to create the database DDL (Data Definition Language) in Google Cloud Spanner.
Dispenser class for creating databases of
GCPSpannerCreateDatabaseDdlOp.This class represents an operation to Drop the database DDL (Data Definition Language) in Google Cloud Spanner.
Dispenser class for creating databases of
GCPSpannerDropDatabaseDdlOp.This class represents an operation to execute a DML statement on Google Cloud Spanner.
Dispenser class for creating GCP Spanner Execute DML operations.
This class represents an operation to insert a vector into a Google Cloud Spanner database.
This class is responsible for dispensing GCP Spanner insert vector operations.
All the spanner rpc api calls are defined here, representing a
guide to the set of operations we should define if we want to implement full Spanner api support.
This class represents an operation to update the database DDL (Data Definition Language) in Google Cloud Spanner.
Dispenser class for creating instances of GCPSpannerUpdateDatabaseDdlOp.
This evaluator uses
Object.equals(Object) to compare the results of an operation with
a constructed value.This uses the Murmur3F (64-bit optimized) version of Murmur3,
not as a checksum, but as a simple hash.
Create a ByteBuffer from the first function, and then sample data from
that bytebuffer according to the size function.
Construct an arbitrarily large vector with hashes.
Allow error handlers to be registered for any exception type, with an explicit handler
that will be called if no specific other handler is matched.
Pseudo-randomly extract a section of a text file and return it according to some
minimum and maximum extract size.
Construct an arbitrarily large float vector with hashes.
Generate a string in the format key1:value1;key2:value2;... from the words
in the specified file, ranging in size between zero and the specified maximum.
Return a pseudo-randomly selected integer value from a file of numeric values.
Return a pseudo-randomly selected String value from a single line of
the specified file.
Creates a List<String> from a list of words in a file.
Return a pseudo-randomly created Set from the values in
the specified file.
Create a String-String map from the specified file, ranging in size
from 0 to the specified maximum.
Provide a text extract from the full lorem ipsum text, between the specified
minimum and maximum size.
This provides a random sample of a double in a range, without
accounting for the non-uniform distribution of IEEE double representation.
This provides a random sample of a double in a range, without
accounting for the non-uniform distribution of IEEE double representation.
Create a list of longs.
Hash a long input value into a byte buffer, at least length bytes long, but aligned on 8-byte
boundary;
Create a double value from a hashed long, over the valid range of long inputs.
Return a value within a range, pseudo-randomly, using interval semantics,
where the range of values return does not include the last value.
Return a double value within the specified range.
The various HashRange functions take an input long, hash it to a random
long value, and then use to interpolate a fractional value between the minimum
and maximum values.
Return a pseudo-random value which can only be as large as the input times
a scale factor, with a default scale factor of 1.0d
Binding function that accepts a long input value for the cycle and returns a string consisting of the
CQL predicate parsed from a single record in an HDF5 dataset
This function reads a vector dataset from an HDF5 file.
This function reads a dataset of any supported type from an HDF5 file.
This function reads a vector dataset from an HDF5 file.
This function reads a vector dataset from an HDF5 file.
This function reads a vector dataset from an HDF5 file.
This function reads a vector dataset from an HDF5 file.
This function reads a vector dataset from an HDF5 file.
This function reads a vector dataset from an HDF5 file.
Binding function that accepts a long input value for the cycle and returns a string consisting of the
CQL predicate parsed from a single record in an HDF5 dataset
Allow a DeltaHistogram to have attached metrics that also get a copy of
any input data.
The histogram error handler will create, if needed, a histogram metrics
object for the named
"errorhistos.simplename" + e.getClass().getSimpleName(),
and then add the current session time to it.HistoIntervalLogger runs a separate thread to snapshotAndWrite encoded histograms on a regular interval.
HistoIntervalLogger runs a separate thread to snapshotAndWrite encoded histograms on a regular interval.
Provides a stable hash that is seeded by all the interface
naming data on a given host.
encode HTML Entities
encode HTML Entities
ThreadLocal http clients have been removed from this version, as the built-in
HTTP client implementation is meant to be immutable.
Simply returns the input value.
A naive implementation of set filtering on integer values.
A named and indexed thread factory, making threads within a thread pool
have the same name and a unique integer index
A named and indexed thread factory, making threads within a thread pool
have the same name and a unique integer index
This annotation is used to mark the input type for a functional interface which
uses generics, like LongFunction, IntFunction, or Function.
An InputDispenser is created for each Activity instance within a scenario.
Return a value along an interpolation curve.
See
Interpolate for
details on implementation.Introduction
Combine multiple IntUnaryOperators into a single function.
Reads ivec files with random access, using the input to specify the record number.
This class is used to parse the raw JSON from the HDF dataset into a CQL predicate.
This takes any collection and concatenates the String representation
with a specified delimiter.
Combine the result of the specified functions together with the
specified delimiter and optional prefix and suffix.
Provide an observer-only view of a simulation journal
////
Return a pseudo-randomly sampled last name from the last US census data on last names
occurring more than 100 times.
Create a com.datastax.driver.dse.geometry.LineString
Deprecated.
Create a List from a long input based on a set of provided functions.
Create a List from a long input based on a set of provided functions.
Create a List from a long input based on a set of provided functions.
Create a List from a long input based on a set of provided functions.
Create a List from a long input based on a set of provided functions.
Create a List from a long input based on a set of provided functions.
Create a
List<String> based on two functions, the first to
determine the list size, and the second to populate the list with
string values.Load a named value from the per-thread state map.
Load a value from a named thread-local variable, where the variable
name is fixed or a generated variable name from a provided function.
Load a value from a map, based on the injected configuration.
Load a value from a named thread-local variable, where the variable
name is fixed or a generated variable name from a provided function.
Load a value from a named thread-local variable, where the variable
name is fixed or a generated variable name from a provided function.
Load a value from a named thread-local variable, where the variable
name is fixed or a generated variable name from a provided function.
Load a value from a named thread-local variable, where the variable
name is fixed or a generated variable name from a provided function.
This is a Log4J targeted metrics logging reporter, derived from
Slf4jReporter.Combine multiple LongUnaryOperators into a single function.
Provide a moving aggregate (min,max,avg,sum,count) of long values presented.
Convert the input long value to a byte, with negative values
masked away.
Days since Jan 1st 1970
Convert the input value from long to short.
Deprecated.
use ToString() instead
Using the 64 bit structure of a long as a heap addressed
tracker, where the leaf nodes represent marked values and
all others are used to consolidate state.
This is a version of longTreeTracker that is safe for concurrent access.
Create a
Map from a long input based on three functions,
the first to determine the map size, and the second to populate
the map with key objects, and the third to populate the map with
value objects.Create a Map from a long input based on a set of provided key and value functions.
Create a Map from a long input based on a set of provided key and value functions.
Create a Map from a long input based on a set of provided key and value functions.
Create a Map from a long input based on a set of provided key and value functions.
Create a Map from a long input based on a set of provided key and value functions.
Create a Map from a long input based on a set of provided key and value functions.
Match any input with a regular expression, and apply the associated
function to it, yielding the value.
Match any input with a regular expression, and apply the associated
regex replacement to it, yielding the value.
This is a way for NoSQLBench code and driver maintainers to communicate about the maturity of various components.
Return the maximum of either the input value or the specified max.
Handles adding a monotonic sequence number to message properties of sent messages
This Shifty Imp can provide some data for you.
Return the minimum of either the input value or the specified minimum.
Return the result of modulo division by the specified divisor.
Select a value from a CSV file line by modulo division against the number
of lines in the file.
Select a value from a text file line by modulo division against the number
of lines in the file.
Return a
BigDecimal value as the result of modulo division with the specified divisor.Return a
BigInteger value as the result of modulo division with the specified divisor.Return a boolean value as the result of modulo division with the specified divisor.
Return a byte value as the result of modulo division with the specified divisor.
Return an integer value as the result of modulo division with the specified divisor.
Return a long value as the result of modulo division with the specified divisor.
Return a boolean value as the result of modulo division with the specified divisor.
Special thanks to Justin Chu who authored the original NoSQLBench MongoDB ActivityType.
https://www.mongodb.com/docs/manual/reference/command/update/#mongodb-dbcommand-dbcmd.update
https://www.mongodb.com/docs/drivers/java/sync/current/usage-examples/updateOne/
The core threading harness within an activity.
A MotorDispenser is created for each Activity instance within a scenario.
Holds the state of a slot, allows only valid transitions, and shares the
slot state as
Return the result of multiplying the specified value with the input.
Yield a long value which is the result of hashing and modulo division
with the specified divisor.
Yield a String value which is the result of hashing and modulo division
with the specified divisor to long and then converting the value to String.
Murmur3F (MurmurHash3_x64_128)
A generator that is mostly useless, except for testing useless generators.
MVELCompilationErrors are those known to occur during the compilation of expected results expressions.
Utility class for creating pre-compiled MVEL expressions with a typed and named context variable.
The purpose of this class is to put all the logic/complexity of name condensing into one place.
This is related to
Conditions, and the terms
should be aligned.TODO: provide before and after atfile processing logs for diagnostics
TODO:ERRORHANDLER Cannot invoke "Object.getClass()" because "scopeOfInclude" is null on file full of comments only
Synopsis
This class is meant to consolidate the error handling logic for the varios types of errors
that may bubble up from the layers within NoSQLBench.
No CLI parser lib is useful for command structures, it seems.
Implement this stub service to identify
NBInvokableCommands which can be loaded in the runtime.A Component is a functional element of the NoSQLBench runtime which is:
Contract Oriented - Components are based on well-defined interfaces.
Modular - Components are wired together by configuration.
Configurable - Components have configurations which are well defined and type safe.
User Facing - Components are top level constructs which users interact with.
Hierarchic - Components fit together in a runtime hierarchy.
Since we like to use SPI/ServiceLoader, and we can't use the Provider-only interface as
suggested in
ServiceLoader, we have to indirect to the safe ctor from a parent context.This is the stateful store of metrics on a specific component in the hierarchy.
This configuration model describes what is valid to submit
for configuration for a given configurable object.
All implementation types which wish to have a type-marshalled configuration
should implement this interface.
This is the core wrapper around any resolvers for NB commands.
Safer, Easier lookup of property and environment variables, so
that commonly used env vars as seen on *n*x systems map to stable
system properties where known, but attempt to fall through to
the env variables if not.
Synopsis
A heartbeat component is one which provides evidence that it is either
in a healthy state or that it is not, via a heartbeat mechanism.
errored_at > 0 -> ERROR
started_at == 0 -> STARTING
<p>
<p>
<p>
started_at > closed_at
STARTING
closed_at > started_at
RUNNING
teardown_at > closed_at
STOPPING
teardown_at
STOPPED
stopped_at
If you provide a type of invokable element in this list, then it should
automatically be handled by NB.
NBIO is a helper utility packaged as a search builder and fluent API.
The NBLabels type represents sets of identifying label names and values for any element in the
NoSQLBench runtime which needs to be named.
Validate a set of labels to ensure conformance to a labeling standard.
This is a custom programmatic logger config handler which allows for a variety of
logging features to be controlled at runtime.
NB Params
This API provides a single service to locate and load content resource from multiple places,
at build time and runtime, using a standard fluent-like pattern.
All implementation types which wish to have a type-marshalled configuration
should implement this interface IFF they wish to support follow-on configuration
after initialization.
A session represents a single execution of NoSQLBench, whether episodic or persistent under some service layer.
This is a canonical way to get the words which are acceptable and valid
for token transformations in strings, particularly in identifiers for
external reporting or logging.
Shenanigans in the java type system, particularly those around boxing,
generics, type-erasure and primitive conversions have brought us here
in our attempt to simplify things.
A tagging only interface to indicate sources of static type conversion functions
Use this gauge type when you are setting the gauge value directly.
For examples, see embedded examples
This class is used to parse the raw JSON from the HDF dataset into a CQL predicate.
Normalize a vector in List form, calling the appropriate conversion function
depending on the component (Class) type of the incoming List values.
Normalize a vector.
Normalize a vector.
Normalize a vector in List form, calling the appropriate conversion function
depending on the component (Class) type of the incoming List values.
Returns null if the input value is within range of the specified value.
Yields a null if the input String is empty.
Yeilds a null if the input value is equal to the specified value.
Yields a null if the input value is greater tha
or equal to the specified value.
Yields a null if the input value is greater than the
specified value.
Yields a null if the input value is less than or equal to
the specified value.
Yields a null if the input value is equal to the specified value.
Yield a null value if the input String is either null or empty.
Yields a null if the input value is within the specified range,
inclusive.
Reads a long variable from the input, hashes and scales it
to the unit interval 0.0d - 1.0d, then uses the result to determine whether
to return null object or a loaded value.
Reads a long variable from the thread local variable map, hashes and scales it
to the unit interval 0.0d - 1.0d, then uses the result to determine whether
to return a null object or the input value.
Provides the spelled-out name of a number.
An object cache to memoize returned objects into a concurrent hash map by name.
This is a functional wrapper layer which will upgrade a basic
CycleOp to
one that has a validator provided by it's DriverAdapter, so long as the
adapter implements ValidatorSource and can provide one for the given name.This is a functional wrapper layer which will upgrade a basic
CycleOp to
one that has a specialized variable extractor, given
1.OpConfigErrors are
BasicErrors which are known to occur when
there is an invalid set of configuration details for an op.Synopsis
This interface represents the union of interfaces needed for all of the
behavioral facets of a useful Op implementation.
This is where operations are customized to support special
testing or analysis capabilities.
If an Op implements OpGenerator, then it will be asked for chained
operations that are secondary unless or until
OpGenerator.getNextOp()}
returns null.Provide the result size for an operation.
OpsDoc creates a logical view of a RawOpsDoc doc that includes
all inherited and overridden values for bindings, tags, and params.
An OpSequence provides fast access to a set of operations in a specific
order.
This class is responsible for loading op templates.
An OpSource provides an Op for a given long value.
The OpTemplate is a structurally normalized type which presents the user-provided op template to the NoSQLBench
loading and templating mechanisms.
The formats which are recognized as source data for the workload.
Provide a concise way to express configuration option helpers which simplify
usage of the long-form options with the latest driver.
The Op Tracker is the keeper of concurrency and op states.
This tracker keeps track of the state of operations associated with it.
A cycle output is simply a type that knows how to do something
useful with the result of a particular cycle.
This annotation is used to mark the output type for a functional interface which
uses generics, like LongFunction, IntFunction, or Function.
A configuration element describes a single configurable parameter.
A concurrently accessible parameter map which holds both keys and values as strings.
Synopsis
TODO: Make this a value type
ParsedOp API
The type of a parsed template depends on the structure of the bindings provided.
A parsed map template, which allows construction of extracted or projected functions related
to dynamic value templates.
A ParsedTemplate represents any string provided by a user which is meant to be
a prototype for value used in an operation.
Split the value range of Java longs into a number of offsets,
starting with Long.MIN_VALUE.
PathContent provides the Path-centric way of accessing
resolved content from the URIs API.
A central API for finding and accessing Paths which are either in
the classpath or in the file system, or both.
This op context carries with it a data element which a protocol-specific
implementation can use to hold the state and logic for operations.
Perf is a testing utility class that collects and analyzes
performance data from individual test runs.
This is a simple and light way to run a periodic task
A PerThreadMapper will be instantiated once for each thread,
for each scope in which it is used.
This artifact contains data files for the other modules in the accompanying reactor project.
Create a Point generator which generates com.datastax.driver.dse.geometry.Point
objects.
A view of metrics objects as an object tree.
Create a com.datastax.driver.dse.geometry.Polygon
This function will return a polygon in the form of a rectangle from the specified
grid system.
PredicateAdapters know how to read the predicate abstract syntax
representation (in the form of a
PredicateExpr and all it entails)
and render a protocol-specific form.Add the specified prefix String to the input value and return the result.
Statically defined names which need to be visible for refactoring
and safe source manipulation.
Any type that implements this interface can provide a double indicating relative progress.
Format NBMetrics according to the prometheus exposition format.
////
////
////
////
////
////
////
////
////
////
////
The
QdrantSpace class is a context object which stores all stateful contextual information needed to interact
with the Qdrant database instance.TODO: Redo this a functional with murmur3F
These search parameters are based on the original findmax algorithm, and
should be reduced down to the minimum set needed.
A MarkdownProvider simply provides all the markdown content it is aware of.
The internal
See specification for what this should do in UniformWorkloadSpecificationTest
A StmtsDef contains a list of rawStmts, as well as all of the optional
block parameters that can be assigned to
RawOpFields, which includes
a name, config values, data bindings, and filtering tags.These search parameters are based on the original findmax algorithm, and
should be reduced down to the minimum set needed.
A convenience class to make read-only Bindings easier to write.
Detects message loss, message duplication and out-of-order message delivery
based on a monotonic sequence number that each received message contains.
This will implement a result buffer that puts cycles in order when possible,
according to a sliding window.
Repeat the incoming list into a new list, filling it to the given size.
Replace all occurrences of the extant string with the replacement string.
Replace all occurrences of the regular expression with the replacement string.
A function that has been resolved by a libraryName for use in data mapping.
Resolves resources which can be found via the class loader.
A result processor can consume data from a result which is contains of a set of
ordered elements.
An accumulator for rows, sized to a page of results.
This enum indicates the state of a thread within an activity.
A value type which encodes the atomic state of a RunState tally.
Synopsis
This client cache uses the credentials provided in a URL to create
a fingerprint, and then creates a customized S3 client for each unique
instance.
This class is used to convert the configuration items in its raw
format (as provided in the property file) to the format needed by
the S4J driver
Used for async message production
Used for async message consumption
Any object can be a sandbox extension.
Save the current input value at this point in the function chain to a thread-local variable name.
Save a value to a named thread-local variable, where the variable
name is fixed or a generated variable name from a provided function.
Save a value to a named thread-local variable, where the variable
name is fixed or a generated variable name from a provided function.
Save a value to a named thread-local variable, where the variable
name is fixed or a generated variable name from a provided function.
Save a value to a named thread-local variable, where the variable
name is fixed or a generated variable name from a provided function.
Save a value to a named thread-local variable, where the variable
name is fixed or a generated variable name from a provided function.
Return the double value closest to the fraction (input) / (Long.MAX_VALUE).
If an object is ScenarioMetadata, then they will be updated with a map of
scenario metadata.
Helper class to consolidate the notions of scoping items over different
NB layers of execution.
Add cmd
ScriptEnvBuffer provides a variant of SimpleScriptContext which captures all
stdin, stdout, and stderr data into diagnostic character buffers.
Any implementation of a SandboxExtension that is found in the runtime
can be automatically loaded into the scenario scripting sandbox.
Helper class to store the vector name, vector values and sparse indices to be used for searching points.
Direct the user to additional resources
Direct the user to additional resources
SequenceOf bindings allow you to specify an order and count of a set of values which will then
be repeated in that order.
SequenceOf bindings allow you to specify an order and count of a set of values which will then
be repeated in that order.
Sequencer types are used to control the type of ordering used with a set of
operations.
A Service annotation will cause a class to be added to META-INF/services/
under the specified class name.
Statically defined names which need to be visible for refactoring
and safe source manipulation.
This annotation processor is responsible for adding services to the
A service loader filter which works with
Service to load a named service.Deprecated.
Create a Set from a long input based on a set of provided functions.
Create a Set from a long input based on a set of provided functions.
Create a Set from a long input based on a set of provided functions.
Create a Set from a long input based on a set of provided functions.
Create a Set from a long input based on a set of provided functions.
Create a Set from a long input based on a set of provided functions.
This provides common thread local instancing for sharing a thread local map across classes.
Show diagnostic values for the thread-local variable map.
This function provides a low-overhead shuffling effect without loading
elements into memory.
A simple callback handler for shutting down things gracefully.
This function provides the current NB process identifier.
This uses the Murmur3F (64-bit optimized) version of Murmur3,
not as a checksum, but as a simple hash.
Capture the control inputs as well as the samples of a sample period of a simulated workload.
This is a helper class that makes it easy to bundle up a combination of measurable
factors and get a windowed sample from them.
Aggregate usage patterns around capturing and using simulation frame data.
A frame planner is what decides what next set of parameters to try based on a history
of simulation frames, and whether to proceed with another sim frame.
An observer-only view of results.
A default implementation of an Activity, suitable for building upon.
Invariants
Rate Limiter Specifications
Rate limiters can be put into motion in different modes to suit different scenarios.
Compress the input using snappy compression
A space is simply a separate namespace associated with an instance of a
native client or driver.
This is the entry point into a specification test.
This is the generified version of an Action.
This is a typed activity which is expected to become the standard
core of all new activity types.
A symblic reference to an earlier argument in the same list, to avoid duplication and expose
uniformity in a visual way.
A StartedOp is a type that represents that an operation has been sent to some
specific type of protocol or logic.
This function sets the minimum long value to the equivalent
unix epoch time in milliseconds.
This is a relatively efficient statistics bucket which can maintain moving
aggregates over a window of samples for count, mean, variance, stddev, sum.
Return a valid state code.
Return a state code (abbreviation), weighted by population density.
Return a state code (abbreviation), weighted by population.
Return a valid state name.
Return a state name, weighted by population density.
Return a state name, weighted by total population.
Return a static String value.
Match if all the predicates match when tested pair-wise across the AST nodes, traversing
strictly across by sibling nodes, and not following beyond the current parent.
A
STNameCodeTuple is a set of metadata that describes a test target from a
test specification file, in terms of Node sequences and context.A
STNode is a set of metadata that describes a test target from a
test specification file, in terms of Node sequences and context.A
STNodeAssembly is a sequence of STNodes.Construct a sequence of {com.vladsch.flexmark.util.ast.Node} matchers using
one of a few common predicate forms, inferred from the types of the predicate
formats provided.
STNodePredicates is a convenient wrapper around STNodePredicate
evaluation so that creating a Node scanner is a one-liner.A NodeScanner extracts a sequence of
STNodeAssemblys, typically
by use of STNodePredicatesAny activity that implements StrideAware will be notified of the
exact interval that it is processing before the first cycle
is dispatched from the motor.
Allows the generation of strings from a string template and bindings template.
Uses a string template and a bindings template to create instances of
StringBindings.This implementation of a string compositor takes a logically coherent
string template and bindings set.
This function wraps an epoch time in milliseconds into a String
as specified in the format.
A DriverSpaceCache is simply a place to hold something like a
client instance and all associated objects for quick and easy access.
Combine multiple String functions together into one function.
Deprecated.
Create a
Map<String,String> from a long input
based on three functions,
the first to determine the map size, and the second to populate
the map with key objects, and the third to populate the map with
value objects.StringCompositor provides a way to build strings from a string template and provided values.
Create a
Set<String> from a long
based on two functions, the first to
determine the set size, and the second to populate the set with
String values.An op should be deemed successful if it completes with no exception.
Add the specified prefix String to the input value and return the result.
Compute the sum of a set of functions.
Load a named value from the per-thread state map.
It is possible for a DriverAdapter to create op templates using partial information.
TagFilter Synopsis
Creates a template function which will yield a string which fits the template
provided, with all occurrences of
{} substituted pair-wise with the
result of the provided functions.Auxiliary thread-local metrics for an activity which are tracked by name.
Matches a digit sequence in the current thread name and caches it in a thread local.
Matches a digit sequence in the current thread name and caches it in a thread local.
Matches a digit sequence in the current thread name and caches it in a thread local.
This uses the Murmur3F (64-bit optimized) version of Murmur3,
not as a checksum, but as a simple hash.
A ThreadSafeMapper will only be instantiated once in a scope, to be
shared among all threads in that scope.
Return a state name, weighted by population density.
Return a state name, weighted by population density.
Return a state name, weighted by population.
Takes a bytebuffer and turns it into a base64 string
Computes the Base64 representation of the byte image of the input long.
Convert values to BigDecimals at configurable scale or precision.
Convert the input value to a
BigIntegerConvert the input value to a
booleanConvert the input value to a
Byte.Convert the input value to a
ByteBufferConvert the input string to a character buffer
Convert the input double value into a CQL
CqlDuration object,
by setting months to zero, and using the fractional part as part
of a day, assuming 24-hour days.Convert the input value into a
CqlDuration
by reading the input as total nanoseconds, assuming 30-month days.Shows the compatible CQL type most associated with the incoming Java type.
Convert the input value to a
Date, by multiplying and then dividing
the input by the provided parameters.Convert the input value to a
org.joda.time.DateTimeCreate a double by converting values.
Convert an incoming double array to a List of Double
Converts a long UTC timestamp in epoch millis form into a Version 1 TimeUUID
according to RFC 4122.
Converts a count of 100ns intervals from 1582 Julian to a Type1 TimeUUID
according to RFC 4122.
Convert the input value into a float.
Create a float by converting values.
Convert an incoming float array to a List of Float
This function provides a stable hashing of the input value to
a version 4 (Random) UUID.
Converts the input ByteBuffer to a hexadecimal String.
Convert the input value to a
java.net.InetAddressConvert the input value to an int with long modulus remainder.
Convert the input epoch millisecond to a
Java Instant, by multiplying and then dividing
by the provided parameters.Convert the input value to a
org.joda.time.DateTimeConvert the input epoch millisecond to a
JodaTime Instant, by multiplying and then dividing
by the provided parameters.Convert the input object to a JSON string with Gson.
Convert the input object to a JSON string with Gson.
Convert the input object to a JSON string with Gson.
Convert the input object to a JSON string with Gson, with pretty printing enabled.
This class provides cursor-like access to a set of data from
a binary file using Java nio buffers.
Utility function used for advanced data generation experiments.
Utility function used for advanced data generation experiments.
Utility function used for advanced data generation experiments.
Utility function used for advanced data generation experiments.
Convert the input epoch millisecond to a
Java Instant, by multiplying and then dividing
by the provided parameters, then convert the result to a java LocalTime.Convert the input value to a long.
Adapts any compatible
FunctionalInterface type to a LongFunction,
for use with higher-order functions, when they require a
LongFunction as an argument.Adapts any compatible
FunctionalInterface type to a LongUnaryOperator,
for use with higher-order functions, when they require a
LongUnaryOperator as an argument.Deprecated, for removal: This API element is subject to removal in a future version.
Return the epoch milliseconds at the start of the day for the given
epoch milliseconds.
Return the epoch milliseconds at the start of the hour for the given
epoch milliseconds.
Return the epoch milliseconds at the start of the minute for the given
epoch milliseconds.
Return the epoch milliseconds at the start of the month for the given
epoch milliseconds.
Return the epoch milliseconds at the start of the most recent day
that falls on the given weekday for the given
epoch milliseconds, including the current day if valid.
Return the epoch milliseconds at the start of the day after the day for the given
epoch milliseconds.
Return the epoch milliseconds at the start of the next day
that falls on the given weekday for the given
epoch milliseconds, not including the current day.
Return the epoch milliseconds at the start of the second for the given
epoch milliseconds.
Return the epoch milliseconds at the start of the year for the given
epoch milliseconds.
Convert the input value to a short.
Convert CharBuffer to String
Converts the input to the most obvious string representation with String.valueOf(...).
Converts a long timestamp in epoch millis form into a Version 1 TimeUUID
according to RFC 4122.
Converts a long timestamp in epoch millis form into a Version 1 TimeUUID
according to RFC 4122.
map<A,B>
where:
A := (f1 text, f2 text, f3 int)
AND
B := (f1 text, f2 text)
Convert the incoming String value to the equivalent UUID with
UUID.fromString(String)This function creates a non-random UUID in the type 4 version (Random).
A tracked op is one that has been added to a tracker, and can
then be started.
Wrap 32 of the 32-position LongTreeTrackers together, allowing
for a range of 0-1023 positions.
Computes the distance between the current input value and the
beginning of the phase, according to a phase length.
Compute a value which increases monotonically with respect to the cycle value.
Trim the input value and return the result.
A tri-state filter allows for flexible configuration of
multi-phase filtering.
The filter action determines what action is taken for a given
of the filter matching.
A convenient pattern for users to specify a command is that of type and target.
Yields the class of the resulting type in String form.
This is not a core exception.
Any type implementing [
UniformVariableCapture] will allow
a caller to extract a map of names and values from it.Create a vector which consists of a number of uniform vector ranges.
Always yields the VALUE.unset value, which signals to
any consumers that the value provided should be considered
undefined for any operation.
Yield VALUE.unset if the input value is close to the
specified value by the sigma threshold.
Yield VALUE.unset if the input String is empty.
Yield UNSET.vale if the input value is equal to the
specified value.
Yield VALUE.unset if the input value is greater than
or equal to the specified value.
Yield UNSET.value if the input value is greater
than the specified value.
Yield VALUE.unset if the input value is less than
or equal to the specified value.
Yield VALUE.unset if the provided value is less than the specified value,
otherwise, pass the original value;
Yields UNSET.value if the input value is null or empty.
Yields UNSET.value if the input value is equal to the
specified value.
Yields UNSET.value if the input String is not equal to the
specified String value.
Yields UNSET.value if the input value is within the specified
range, inclusive.
Reads a long variable from the input, hashes and scales it
to the unit interval 0.0d - 1.0d, then uses the result to determine whether
to return UNSET.value or a loaded value.
Reads a long variable from the thread local variable map, hashes and scales it
to the unit interval 0.0d - 1.0d, then uses the result to determine whether
to return UNSET.value or the input value.
Because of ctor super calling order requirements, the task thread can't always be started
automatically in super(...).
This is a stateful search object for resources like Paths or URLs.
This is a URI-centric content locator for URLs and Paths.
StreamContent is meant for short-lived use as an efficient way to
find a read URL content.
URLDecode string data
URLEncode string data
A
DriverAdapter may implement this interface to provide adapter-specific
validators.A public class which holds global values.
ValuesArrayBinder provides a way to apply an array of object values to a template
object of type T to yield a new object instance of type R.
ValuesBinder provides a way to apply an map of named object values to a template
object of type T to yield a new object instance of type R.
ValuesMapBinder provides a way to apply an map of named object values to a template
object of type T to yield a new object instance of type R.
Capture preference for types, favoring more efficient types for generation over others.
Implementors of this type can have variables set on them for later use.
A VectorSequence is a sequence of vectors which are a deterministic
map between a set of ordinal values and vector values.
This class provides an empty implementation of
VirtDataListener,
which can be extended to create a listener which only needs to handle a subset
of the available methods.Synopsis
This is the top-level API supporting access to the documentation models
for all known
ThreadSafeMapper and
PerThreadMapper instances in the runtime.A VirtDataFunctionLibrary is simply a way to ask for a set
of named function objects in a generic way.
This interface defines a complete listener for a parse tree produced by
VirtDataParser.This just routes the user to the correct sub-app depending on the leading verb, stripping it off in the process.
Create objects.
Delete a Weaviate collection.
The
WeaviateSpace class is a context object which stores all stateful
contextual information needed to interact with the Weaviate database
instance.Any class which is annotated with
Allows for easy branching over multiple functions with specific
weights.
Provides a long value from a list of weighted values.
Allows for weighted elements to be used, such as
a:0.25;b:0.25;c:0.5 or a:1;b:1.0;c:2.0
The unit weights are normalized to the cumulative sum
internally, so it is not necessary for them
to add up to any particular value.Provides sampling of a given field in a CSV file according
to discrete probabilities.
Create a discrete stat reservoir as a gauge.
Return a valid zip code.
Return a zip code, weighted by population density.
Return a zip code, weighted by population.