public class AlterSystemPropertiesRequest extends Object implements org.apache.avro.generic.IndexedRecord
GPUdb.alterSystemProperties(AlterSystemPropertiesRequest).
The GPUdb.alterSystemProperties(AlterSystemPropertiesRequest)
endpoint is primarily used to simplify the testing of the system and is not
expected to be used during normal execution. Commands are given through the
propertyUpdatesMap whose keys are commands and values are strings
representing integer values (for example '8000') or boolean values ('true'
or 'false').
| Modifier and Type | Class and Description |
|---|---|
static class |
AlterSystemPropertiesRequest.PropertyUpdatesMap
Map containing the properties of the system to be updated.
|
| Constructor and Description |
|---|
AlterSystemPropertiesRequest()
Constructs an AlterSystemPropertiesRequest object with default
parameters.
|
AlterSystemPropertiesRequest(Map<String,String> propertyUpdatesMap,
Map<String,String> options)
Constructs an AlterSystemPropertiesRequest object with the specified
parameters.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
equals(Object obj) |
Object |
get(int index)
This method supports the Avro framework and is not intended to be called
directly by the user.
|
static org.apache.avro.Schema |
getClassSchema()
This method supports the Avro framework and is not intended to be called
directly by the user.
|
Map<String,String> |
getOptions() |
Map<String,String> |
getPropertyUpdatesMap() |
org.apache.avro.Schema |
getSchema()
This method supports the Avro framework and is not intended to be called
directly by the user.
|
int |
hashCode() |
void |
put(int index,
Object value)
This method supports the Avro framework and is not intended to be called
directly by the user.
|
AlterSystemPropertiesRequest |
setOptions(Map<String,String> options) |
AlterSystemPropertiesRequest |
setPropertyUpdatesMap(Map<String,String> propertyUpdatesMap) |
String |
toString() |
public AlterSystemPropertiesRequest()
public AlterSystemPropertiesRequest(Map<String,String> propertyUpdatesMap, Map<String,String> options)
propertyUpdatesMap - Map containing the properties of the system
to be updated. Error if empty.
SM_OMP_THREADS: Set the number of OpenMP
threads that will be used to service filter &
aggregation requests against collections to
the specified integer value.
KERNEL_OMP_THREADS: Set the number of kernel
OpenMP threads to the specified integer
value.
CONCURRENT_KERNEL_EXECUTION: Enables
concurrent kernel execution if the value is
true and disables it if the value is
false.
Supported values:
SUBTASK_CONCURRENCY_LIMIT: Sets the maximum
number of simultaneous threads allocated to a
given request, on each rank. Note that thread
allocation may also be limted by resource
group limits and/or system load.
CHUNK_SIZE: Sets the number of records per
chunk to be used for all new tables.
EVICT_COLUMNS: Attempts to evict columns
from memory to the persistent store. Value
string is a semicolon separated list of
entries, each entry being a table name
optionally followed by a comma and a comma
separated list of column names to attempt to
evict. An empty value string will attempt to
evict all tables and columns.
EXECUTION_MODE: Sets the execution_mode for
kernel executions to the specified string
value. Possible values are host, device,
default (engine decides) or an integer value
that indicates max chunk size to exec on host
EXTERNAL_FILES_DIRECTORY: Sets the root
directory path where external table data
files are accessed from. Path must exist on
the head node
FLUSH_TO_DISK: Flushes any changes to any
tables to the persistent store. These
changes include updates to the vector store,
object store, and text search store, Value
string is ignored
CLEAR_CACHE: Clears cached results. Useful
to allow repeated timing of endpoints. Value
string is the name of the table for which to
clear the cached results, or an empty string
to clear the cached results for all tables.
COMMUNICATOR_TEST: Invoke the communicator
test and report timing results. Value string
is is a semicolon separated list of
[key]=[value] expressions. Expressions are:
num_transactions=[num] where num is the
number of request reply transactions to
invoke per test; message_size=[bytes] where
bytes is the size in bytes of the messages to
send; check_values=[enabled] where if enabled
is true the value of the messages received
are verified.
SET_MESSAGE_TIMERS_ENABLED: Enables the
communicator test to collect additional
timing statistics when the value string is
true. Disables the collection when
the value string is false
Supported values:
NETWORK_SPEED: Invoke the network speed test
and report timing results. Value string is a
semicolon-separated list of [key]=[value]
expressions. Valid expressions are:
seconds=[time] where time is the time in
seconds to run the test; data_size=[bytes]
where bytes is the size in bytes of the block
to be transferred; threads=[number of
threads]; to_ranks=[space-separated list of
ranks] where the list of ranks is the ranks
that rank 0 will send data to and get data
from. If to_ranks is unspecified then all
worker ranks are used.
REQUEST_TIMEOUT: Number of minutes after
which filtering (e.g., GPUdb.filter(FilterRequest)) and
aggregating (e.g., GPUdb.aggregateGroupByRaw(AggregateGroupByRequest))
queries will timeout. The default value is
'20'.
MAX_GET_RECORDS_SIZE: The maximum number of
records the database will serve for a given
data retrieval call. The default value is
'20000'.
ENABLE_AUDIT: Enable or disable auditing.
AUDIT_HEADERS: Enable or disable auditing of
request headers.
AUDIT_BODY: Enable or disable auditing of
request bodies.
AUDIT_DATA: Enable or disable auditing of
request data.
SHADOW_AGG_SIZE: Size of the shadow
aggregate chunk cache in bytes. The default
value is '10000000'.
SHADOW_FILTER_SIZE: Size of the shdow filter
chunk cache in bytes. The default value is
'10000000'.
SYNCHRONOUS_COMPRESSION: compress vector on
set_compression (instead of waiting for
background thread). The default value is
'false'.
ENABLE_OVERLAPPED_EQUI_JOIN: Enable
overlapped-equi-join filter. The default
value is 'true'.
ENABLE_COMPOUND_EQUI_JOIN: Enable
compound-equi-join filter plan type. The
default value is 'false'.
options - Optional parameters. The default value is an empty
Map.public static org.apache.avro.Schema getClassSchema()
public Map<String,String> getPropertyUpdatesMap()
SM_OMP_THREADS: Set the number of OpenMP threads that will be
used to service filter & aggregation requests against
collections to the specified integer value.
KERNEL_OMP_THREADS: Set the number of kernel OpenMP threads to
the specified integer value.
CONCURRENT_KERNEL_EXECUTION: Enables concurrent kernel
execution if the value is true and disables it if the
value is false.
Supported values:
SUBTASK_CONCURRENCY_LIMIT: Sets the maximum number of
simultaneous threads allocated to a given request, on each rank.
Note that thread allocation may also be limted by resource group
limits and/or system load.
CHUNK_SIZE: Sets the number of records per chunk to be used for
all new tables.
EVICT_COLUMNS: Attempts to evict columns from memory to the
persistent store. Value string is a semicolon separated list of
entries, each entry being a table name optionally followed by a
comma and a comma separated list of column names to attempt to
evict. An empty value string will attempt to evict all tables
and columns.
EXECUTION_MODE: Sets the execution_mode for kernel executions
to the specified string value. Possible values are host, device,
default (engine decides) or an integer value that indicates max
chunk size to exec on host
EXTERNAL_FILES_DIRECTORY: Sets the root directory path where
external table data files are accessed from. Path must exist on
the head node
FLUSH_TO_DISK: Flushes any changes to any tables to the
persistent store. These changes include updates to the vector
store, object store, and text search store, Value string is
ignored
CLEAR_CACHE: Clears cached results. Useful to allow repeated
timing of endpoints. Value string is the name of the table for
which to clear the cached results, or an empty string to clear
the cached results for all tables.
COMMUNICATOR_TEST: Invoke the communicator test and report
timing results. Value string is is a semicolon separated list of
[key]=[value] expressions. Expressions are:
num_transactions=[num] where num is the number of request reply
transactions to invoke per test; message_size=[bytes] where
bytes is the size in bytes of the messages to send;
check_values=[enabled] where if enabled is true the value of the
messages received are verified.
SET_MESSAGE_TIMERS_ENABLED: Enables the communicator test to
collect additional timing statistics when the value string is
true. Disables the collection when the value string is
false
Supported values:
NETWORK_SPEED: Invoke the network speed test and report timing
results. Value string is a semicolon-separated list of
[key]=[value] expressions. Valid expressions are:
seconds=[time] where time is the time in seconds to run the
test; data_size=[bytes] where bytes is the size in bytes of the
block to be transferred; threads=[number of threads];
to_ranks=[space-separated list of ranks] where the list of ranks
is the ranks that rank 0 will send data to and get data from. If
to_ranks is unspecified then all worker ranks are used.
REQUEST_TIMEOUT: Number of minutes after which filtering (e.g.,
GPUdb.filter(FilterRequest)) and aggregating
(e.g., GPUdb.aggregateGroupByRaw(AggregateGroupByRequest))
queries will timeout. The default value is '20'.
MAX_GET_RECORDS_SIZE: The maximum number of records the
database will serve for a given data retrieval call. The
default value is '20000'.
ENABLE_AUDIT: Enable or disable auditing.
AUDIT_HEADERS: Enable or disable auditing of request headers.
AUDIT_BODY: Enable or disable auditing of request bodies.
AUDIT_DATA: Enable or disable auditing of request data.
SHADOW_AGG_SIZE: Size of the shadow aggregate chunk cache in
bytes. The default value is '10000000'.
SHADOW_FILTER_SIZE: Size of the shdow filter chunk cache in
bytes. The default value is '10000000'.
SYNCHRONOUS_COMPRESSION: compress vector on set_compression
(instead of waiting for background thread). The default value
is 'false'.
ENABLE_OVERLAPPED_EQUI_JOIN: Enable overlapped-equi-join
filter. The default value is 'true'.
ENABLE_COMPOUND_EQUI_JOIN: Enable compound-equi-join filter
plan type. The default value is 'false'.
public AlterSystemPropertiesRequest setPropertyUpdatesMap(Map<String,String> propertyUpdatesMap)
propertyUpdatesMap - Map containing the properties of the system
to be updated. Error if empty.
SM_OMP_THREADS: Set the number of OpenMP
threads that will be used to service filter &
aggregation requests against collections to
the specified integer value.
KERNEL_OMP_THREADS: Set the number of kernel
OpenMP threads to the specified integer
value.
CONCURRENT_KERNEL_EXECUTION: Enables
concurrent kernel execution if the value is
true and disables it if the value is
false.
Supported values:
SUBTASK_CONCURRENCY_LIMIT: Sets the maximum
number of simultaneous threads allocated to a
given request, on each rank. Note that thread
allocation may also be limted by resource
group limits and/or system load.
CHUNK_SIZE: Sets the number of records per
chunk to be used for all new tables.
EVICT_COLUMNS: Attempts to evict columns
from memory to the persistent store. Value
string is a semicolon separated list of
entries, each entry being a table name
optionally followed by a comma and a comma
separated list of column names to attempt to
evict. An empty value string will attempt to
evict all tables and columns.
EXECUTION_MODE: Sets the execution_mode for
kernel executions to the specified string
value. Possible values are host, device,
default (engine decides) or an integer value
that indicates max chunk size to exec on host
EXTERNAL_FILES_DIRECTORY: Sets the root
directory path where external table data
files are accessed from. Path must exist on
the head node
FLUSH_TO_DISK: Flushes any changes to any
tables to the persistent store. These
changes include updates to the vector store,
object store, and text search store, Value
string is ignored
CLEAR_CACHE: Clears cached results. Useful
to allow repeated timing of endpoints. Value
string is the name of the table for which to
clear the cached results, or an empty string
to clear the cached results for all tables.
COMMUNICATOR_TEST: Invoke the communicator
test and report timing results. Value string
is is a semicolon separated list of
[key]=[value] expressions. Expressions are:
num_transactions=[num] where num is the
number of request reply transactions to
invoke per test; message_size=[bytes] where
bytes is the size in bytes of the messages to
send; check_values=[enabled] where if enabled
is true the value of the messages received
are verified.
SET_MESSAGE_TIMERS_ENABLED: Enables the
communicator test to collect additional
timing statistics when the value string is
true. Disables the collection when
the value string is false
Supported values:
NETWORK_SPEED: Invoke the network speed test
and report timing results. Value string is a
semicolon-separated list of [key]=[value]
expressions. Valid expressions are:
seconds=[time] where time is the time in
seconds to run the test; data_size=[bytes]
where bytes is the size in bytes of the block
to be transferred; threads=[number of
threads]; to_ranks=[space-separated list of
ranks] where the list of ranks is the ranks
that rank 0 will send data to and get data
from. If to_ranks is unspecified then all
worker ranks are used.
REQUEST_TIMEOUT: Number of minutes after
which filtering (e.g., GPUdb.filter(FilterRequest)) and
aggregating (e.g., GPUdb.aggregateGroupByRaw(AggregateGroupByRequest))
queries will timeout. The default value is
'20'.
MAX_GET_RECORDS_SIZE: The maximum number of
records the database will serve for a given
data retrieval call. The default value is
'20000'.
ENABLE_AUDIT: Enable or disable auditing.
AUDIT_HEADERS: Enable or disable auditing of
request headers.
AUDIT_BODY: Enable or disable auditing of
request bodies.
AUDIT_DATA: Enable or disable auditing of
request data.
SHADOW_AGG_SIZE: Size of the shadow
aggregate chunk cache in bytes. The default
value is '10000000'.
SHADOW_FILTER_SIZE: Size of the shdow filter
chunk cache in bytes. The default value is
'10000000'.
SYNCHRONOUS_COMPRESSION: compress vector on
set_compression (instead of waiting for
background thread). The default value is
'false'.
ENABLE_OVERLAPPED_EQUI_JOIN: Enable
overlapped-equi-join filter. The default
value is 'true'.
ENABLE_COMPOUND_EQUI_JOIN: Enable
compound-equi-join filter plan type. The
default value is 'false'.
this to mimic the builder pattern.public Map<String,String> getOptions()
Map.public AlterSystemPropertiesRequest setOptions(Map<String,String> options)
options - Optional parameters. The default value is an empty
Map.this to mimic the builder pattern.public org.apache.avro.Schema getSchema()
getSchema in interface org.apache.avro.generic.GenericContainerpublic Object get(int index)
get in interface org.apache.avro.generic.IndexedRecordindex - the position of the field to getIndexOutOfBoundsExceptionpublic void put(int index,
Object value)
put in interface org.apache.avro.generic.IndexedRecordindex - the position of the field to setvalue - the value to setIndexOutOfBoundsExceptionCopyright © 2020. All rights reserved.