Uses of Class
io.druid.segment.realtime.FireHydrant

Packages that use FireHydrant

Package	Description
io.druid.segment.realtime.appenderator
io.druid.segment.realtime.plumber

Uses of FireHydrant in io.druid.segment.realtime.appenderator

Methods in io.druid.segment.realtime.appenderator with parameters of type FireHydrant

Modifier and Type	Method and Description
static String	SinkQuerySegmentWalker.makeHydrantCacheIdentifier(FireHydrant input)

Uses of FireHydrant in io.druid.segment.realtime.plumber

Methods in io.druid.segment.realtime.plumber that return FireHydrant

Modifier and Type	Method and Description
FireHydrant	Sink.getCurrHydrant()
FireHydrant	Sink.swap() If currHydrant is A, creates a new index B, sets currHydrant to B and returns A.

Methods in io.druid.segment.realtime.plumber that return types with arguments of type FireHydrant

Modifier and Type	Method and Description
Iterator<FireHydrant>	Sink.iterator()

Methods in io.druid.segment.realtime.plumber with parameters of type FireHydrant

Modifier and Type	Method and Description
protected int	RealtimePlumber.persistHydrant(FireHydrant indexToPersist, DataSchema schema, org.joda.time.Interval interval, Map<String,Object> metadataElems) Persists the given hydrant and returns the number of rows persisted

Constructor parameters in io.druid.segment.realtime.plumber with type arguments of type FireHydrant

Constructor and Description
Sink(org.joda.time.Interval interval, DataSchema schema, ShardSpec shardSpec, String version, int maxRowsInMemory, boolean reportParseExceptions, List<FireHydrant> hydrants)