Puppet Class: druid::coordinator

Defined in:
modules/druid/manifests/coordinator.pp

Overview

Class druid::coordinator

Configures and runs a Druid Coordinator. druid.io/docs/latest/design/coordinator.html

Parameters

properties

Hash of runtime.properties See: Default $properties

env

Hash of shell environment variables. Default: 

'JMX_PORT'             => 9662,
'DRUID_HEAP_OPTS'      => '-Xmx128m -Xms128m',
'DRUID_EXTRA_JVM_OPTS' => '-Dderby.stream.error.file=/var/log/druid/coordinator-derby.log',

should_subscribe

True if the service should refresh if any of its config files change. Default: false

Default $properties

The properties listed here are only the defaults. For a full list of configuration properties, see druid.io/docs/latest/configuration/coordinator.html

druid.port

Default: 8081

druid.coordinator.startDelay

The operation of the Coordinator works on the assumption that it has an up-to-date view of the state of the world when it runs. The current ZK interaction code, however, is written in a way that doesn't allow the Coordinator to know for a fact that it's done loading the current state of the world. This delay is a hack to give it enough time to believe that it has all the data. Default: PT30S

druid.coordinator.period

The run period for the coordinator. The coordinator's operates by maintaining the current state of the world in memory and periodically looking at the set of segments available and segments being served to make decisions about whether any changes need to be made to the data topology. This property sets the delay between each of these runs. Default: PT30S

Parameters:

  • properties (Any) (defaults to: {})
  • env (Any) (defaults to: {})
  • should_subscribe (Any) (defaults to: false)
  • logger_prefix (Any) (defaults to: 'io.druid') 


47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'modules/druid/manifests/coordinator.pp', line 47

class druid::coordinator(
    $properties       = {},
    $env              = {},
    $should_subscribe = false,
    $logger_prefix    = 'io.druid',
)
{
    require ::druid

    $default_properties = {
        'druid.port'                   => 8081,
        'druid.coordinator.startDelay' => 'PT30S',
        'druid.coordinator.period'     => 'PT30S',
    }

    $default_env = {
        'JAVA_HOME'            => $::druid::java_home,
        'JMX_PORT'             => 9662,
        'DRUID_HEAP_OPTS'      => '-Xmx128m -Xms128m',
        'DRUID_EXTRA_JVM_OPTS' => '-Dderby.stream.error.file=/var/log/druid/coordinator-derby.log',
    }

    # Save these in variables so the properties can be referenced
    # from outside of this class.
    $runtime_properties = merge($default_properties, $properties)
    $environment        = merge($default_env, $env)

    druid::service { 'coordinator':
        runtime_properties => $runtime_properties,
        env                => $environment,
        should_subscribe   => $should_subscribe,
        logger_prefix      => $logger_prefix,
    }
}