Start a builder for a particular event type.
Start a builder for a particular event type.
the event type
time extraction object for this event type
a new builder
Start a builder for a particular event type.
Start a builder for a particular event type.
the event type
time extraction function for this event type
a new builder
Start a builder for a custom type based on a particular Tranquility dataSourceConfig.
Start a builder for a custom type based on a particular Tranquility dataSourceConfig. Not all of the realtime spec in the config is used, but we do translate as much as possible into DruidBeams configurations. The builder generated by this method will already have a curatorFactory, tuning, druidTuning, location, rollup, objectWriter, timestampSpec, partitions, replicants, and druidBeamConfig set.
Tranquility dataSource config
Timestamper for this type
Serializer for this type
new builder
Start a builder for a custom type based on a particular Tranquility dataSourceConfig.
Start a builder for a custom type based on a particular Tranquility dataSourceConfig. Not all of the realtime spec in the config is used, but we do translate as much as possible into DruidBeams configurations. The builder generated by this method will already have a tuning, druidTuning, location, rollup, objectWriter, timestampSpec, partitions, replicants, and druidBeamConfig set.
Tranquility dataSource config
Timestamper for this type
Serializer for this type
new builder
Start a builder for Java Maps based on a particular Tranquility dataSourceConfig.
Start a builder for Java Maps based on a particular Tranquility dataSourceConfig. Not all of the realtime spec in the config is used, but we do translate as much as possible into DruidBeams configurations. The builder generated by this method will already have a tuning, druidTuning, location, rollup, objectWriter, timestampSpec, partitions, replicants, and druidBeamConfig set.
Tranquility dataSource config
new builder
Builds Beams or Finagle services that send events to the Druid indexing service.
Your event type (in this case,
Map[String, Any]
) must be serializable via Jackson to JSON that Druid can understand. If Jackson is not an appropriate choice, you can provide an ObjectWriter via.objectWriter(...)
.