com.yahoo.bullet.pubsub.rest

Class RESTPubSubConfig

java.lang.Object

com.yahoo.bullet.common.Config

com.yahoo.bullet.common.BulletConfig

com.yahoo.bullet.pubsub.rest.RESTPubSubConfig

All Implemented Interfaces:

Serializable

public class RESTPubSubConfig
extends BulletConfig

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MAX_UNCOMMITTED_MESSAGES
static int	DEFAULT_PUBLISHER_CONNECT_TIMEOUT
static Long	DEFAULT_QUERY_MIN_WAIT
static List<String>	DEFAULT_QUERY_URLS
static String	DEFAULT_REST_PUBSUB_CONFIGURATION_NAME
static Long	DEFAULT_RESULT_MIN_WAIT
static String	DEFAULT_RESULT_URL
static int	DEFAULT_SUBSCRIBER_CONNECT_TIMEOUT
static String	MAX_UNCOMMITTED_MESSAGES
static String	PREFIX
static String	PUBLISHER_CONNECT_TIMEOUT
static String	QUERY_SUBSCRIBER_MIN_WAIT
static String	QUERY_URLS
static String	RESULT_SUBSCRIBER_MIN_WAIT
static String	RESULT_URL
static String	SUBSCRIBER_CONNECT_TIMEOUT

Fields inherited from class com.yahoo.bullet.common.BulletConfig

AGGREGATION_COMPOSITE_FIELD_SEPARATOR, AGGREGATION_DEFAULT_SIZE, AGGREGATION_MAX_SIZE, ALPHA_SKETCH_FAMILY, COUNT_DISTINCT_AGGREGATION_SKETCH_ENTRIES, COUNT_DISTINCT_AGGREGATION_SKETCH_FAMILY, COUNT_DISTINCT_AGGREGATION_SKETCH_RESIZE_FACTOR, COUNT_DISTINCT_AGGREGATION_SKETCH_SAMPLING, DEFAULT_AGGREGATION_COMPOSITE_FIELD_SEPARATOR, DEFAULT_AGGREGATION_MAX_SIZE, DEFAULT_AGGREGATION_SIZE, DEFAULT_CONFIGURATION_NAME, DEFAULT_COUNT_DISTINCT_AGGREGATION_SKETCH_ENTRIES, DEFAULT_COUNT_DISTINCT_AGGREGATION_SKETCH_FAMILY, DEFAULT_COUNT_DISTINCT_AGGREGATION_SKETCH_RESIZE_FACTOR, DEFAULT_COUNT_DISTINCT_AGGREGATION_SKETCH_SAMPLING, DEFAULT_DISTRIBUTION_AGGREGATION_GENERATED_POINTS_ROUNDING, DEFAULT_DISTRIBUTION_AGGREGATION_MAX_POINTS, DEFAULT_DISTRIBUTION_AGGREGATION_SKETCH_ENTRIES, DEFAULT_EQUALITY_PARTITIONER_DELIMITER, DEFAULT_GROUP_AGGREGATION_MAX_SIZE, DEFAULT_GROUP_AGGREGATION_SKETCH_ENTRIES, DEFAULT_GROUP_AGGREGATION_SKETCH_RESIZE_FACTOR, DEFAULT_GROUP_AGGREGATION_SKETCH_SAMPLING, DEFAULT_PUBSUB_CLASS_NAME, DEFAULT_PUBSUB_CONTEXT_NAME, DEFAULT_QUERY_DURATION, DEFAULT_QUERY_MAX_DURATION, DEFAULT_QUERY_PARTITIONER_CLASS_NAME, DEFAULT_QUERY_PARTITIONER_ENABLE, DEFAULT_RATE_LIMIT_ENABLE, DEFAULT_RATE_LIMIT_MAX_EMIT_COUNT, DEFAULT_RATE_LIMIT_TIME_INTERVAL, DEFAULT_RAW_AGGREGATION_MAX_SIZE, DEFAULT_RECORD_PROVIDER_CLASS_NAME, DEFAULT_RESULT_METADATA_ENABLE, DEFAULT_RESULT_METADATA_METRICS, DEFAULT_TOP_K_AGGREGATION_SKETCH_ENTRIES, DEFAULT_TOP_K_AGGREGATION_SKETCH_ERROR_TYPE, DEFAULT_WINDOW_DISABLE, DEFAULT_WINDOW_MIN_EMIT_EVERY, DISTRIBUTION_AGGREGATION_GENERATED_POINTS_ROUNDING, DISTRIBUTION_AGGREGATION_MAX_POINTS, DISTRIBUTION_AGGREGATION_SKETCH_ENTRIES, EQUALITY_PARTITIONER_DELIMITER, EQUALITY_PARTITIONER_FIELDS, GROUP_AGGREGATION_MAX_SIZE, GROUP_AGGREGATION_SKETCH_ENTRIES, GROUP_AGGREGATION_SKETCH_RESIZE_FACTOR, GROUP_AGGREGATION_SKETCH_SAMPLING, MAXIMUM_EQUALITY_FIELDS, METRIC_PUBLISHER_CLASS_NAME, PUBSUB_CLASS_NAME, PUBSUB_CONTEXT_NAME, QUERY_DEFAULT_DURATION, QUERY_MAX_DURATION, QUERY_PARTITIONER_CLASS_NAME, QUERY_PARTITIONER_ENABLE, QUICKSELECT_SKETCH_FAMILY, RATE_LIMIT_ENABLE, RATE_LIMIT_MAX_EMIT_COUNT, RATE_LIMIT_TIME_INTERVAL, RAW_AGGREGATION_MAX_SIZE, RECORD_PROVIDER_CLASS_NAME, RECORD_SCHEMA_FILE_NAME, RESULT_METADATA_ENABLE, RESULT_METADATA_METRICS, RESULT_METADATA_METRICS_CONCEPT_KEY, RESULT_METADATA_METRICS_NAME_KEY, STORAGE_CLASS_NAME, TOP_K_AGGREGATION_SKETCH_ENTRIES, TOP_K_AGGREGATION_SKETCH_ERROR_TYPE, WINDOW_DISABLE, WINDOW_MIN_EMIT_EVERY

Fields inherited from class com.yahoo.bullet.common.Config

DELIMITER

Constructor Summary

Constructors

Constructor and Description
RESTPubSubConfig(Config other) Constructor that loads the defaults and augments it with defaults.
RESTPubSubConfig(String file) Constructor that loads specific file augmented with defaults.

Method Summary

Modifier and Type	Method and Description
RESTPubSubConfig	validate() Validates and fixes configuration for this config.

Methods inherited from class com.yahoo.bullet.common.BulletConfig

getBulletRecordProvider, getSchema, getValidator, loadConfiguredClass, merge

Methods inherited from class com.yahoo.bullet.common.Config

clear, get, getAll, getAllBut, getAllWithPrefix, getAs, getOrDefault, getOrDefaultAs, getRequiredConfigAs, readYAML, set, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

PREFIX

public static final String PREFIX

See Also:

Constant Field Values

SUBSCRIBER_CONNECT_TIMEOUT

public static final String SUBSCRIBER_CONNECT_TIMEOUT

See Also:

Constant Field Values

PUBLISHER_CONNECT_TIMEOUT

public static final String PUBLISHER_CONNECT_TIMEOUT

See Also:

Constant Field Values

MAX_UNCOMMITTED_MESSAGES

public static final String MAX_UNCOMMITTED_MESSAGES

See Also:

Constant Field Values

QUERY_URLS

public static final String QUERY_URLS

See Also:

Constant Field Values

RESULT_URL

public static final String RESULT_URL

See Also:

Constant Field Values

RESULT_SUBSCRIBER_MIN_WAIT

public static final String RESULT_SUBSCRIBER_MIN_WAIT

See Also:

Constant Field Values

QUERY_SUBSCRIBER_MIN_WAIT

public static final String QUERY_SUBSCRIBER_MIN_WAIT

See Also:

Constant Field Values

DEFAULT_SUBSCRIBER_CONNECT_TIMEOUT

public static final int DEFAULT_SUBSCRIBER_CONNECT_TIMEOUT

See Also:

Constant Field Values

DEFAULT_PUBLISHER_CONNECT_TIMEOUT

public static final int DEFAULT_PUBLISHER_CONNECT_TIMEOUT

See Also:

Constant Field Values

DEFAULT_MAX_UNCOMMITTED_MESSAGES

public static final int DEFAULT_MAX_UNCOMMITTED_MESSAGES

See Also:

Constant Field Values

DEFAULT_QUERY_URLS

public static final List<String> DEFAULT_QUERY_URLS

DEFAULT_RESULT_URL

public static final String DEFAULT_RESULT_URL

See Also:

Constant Field Values

DEFAULT_RESULT_MIN_WAIT

public static final Long DEFAULT_RESULT_MIN_WAIT

DEFAULT_QUERY_MIN_WAIT

public static final Long DEFAULT_QUERY_MIN_WAIT

DEFAULT_REST_PUBSUB_CONFIGURATION_NAME

public static final String DEFAULT_REST_PUBSUB_CONFIGURATION_NAME

See Also:

Constant Field Values

Constructor Detail

RESTPubSubConfig

public RESTPubSubConfig(String file)

Constructor that loads specific file augmented with defaults.

Parameters:

file - YAML file to load.

RESTPubSubConfig

public RESTPubSubConfig(Config other)

Constructor that loads the defaults and augments it with defaults.

Parameters:

other - The other config to wrap.

Method Detail

validate

public RESTPubSubConfig validate()

Description copied from class: BulletConfig

Validates and fixes configuration for this config. If there are undefaulted or wrongly typed elements, you should use a Validator to define the appropriate definitions, casters and defaults to use. You should call this method before you use the config if you set additional settings to ensure that all configurations are valid.

This class defines a validator for all the fields it knows about. If you subclass it and define your own fields, you should BulletConfig.getValidator() and add entries and relationships that you need to validate. Make sure to call this method from your override if you wish validate your new definitions.

Overrides:

validate in class BulletConfig

Returns:

This config for chaining.