Uses of Interface
io.druid.data.input.Row

Packages that use Row

Package	Description
io.druid.data.input
io.druid.indexer.hadoop
io.druid.query.groupby
io.druid.query.groupby.epinephelinae
io.druid.query.groupby.having
io.druid.query.groupby.orderby
io.druid.query.groupby.strategy
io.druid.segment.incremental

Uses of Row in io.druid.data.input

Subinterfaces of Row in io.druid.data.input

Modifier and Type	Interface and Description
interface	InputRow An InputRow is the interface definition of an event being input into the data ingestion layer.

Classes in io.druid.data.input that implement Row

Modifier and Type	Class and Description
class	MapBasedInputRow
class	MapBasedRow

Methods in io.druid.data.input with parameters of type Row

Modifier and Type	Method and Description
int	MapBasedRow.compareTo(Row o)
static InputRow	Rows.toCaseInsensitiveInputRow(Row row, List<String> dimensions)

Uses of Row in io.druid.indexer.hadoop

Classes in io.druid.indexer.hadoop that implement Row

Modifier and Type	Class and Description
class	SegmentInputRow SegmentInputRow serves as a marker that these InputRow instances have already been combined and they contain the columns as they show up in the segment after ingestion, not what you would see in raw data.

Methods in io.druid.indexer.hadoop with parameters of type Row

Modifier and Type	Method and Description
int	SegmentInputRow.compareTo(Row row)

Uses of Row in io.druid.query.groupby

Methods in io.druid.query.groupby that return types with arguments of type Row

Modifier and Type	Method and Description
Sequence<Row>	GroupByQuery.applyLimit(Sequence<Row> results) Apply the havingSpec and limitSpec.
QueryRunner<Row>	GroupByQueryRunnerFactory.createRunner(Segment segment)
CacheStrategy<Row,Object,GroupByQuery>	GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query)
com.fasterxml.jackson.core.type.TypeReference<Row>	GroupByQueryQueryToolChest.getResultTypeReference()
com.google.common.collect.Ordering<Row>	GroupByQuery.getRowOrdering(boolean granular)
QueryToolChest<Row,GroupByQuery>	GroupByQueryRunnerFactory.getToolchest()
com.google.common.base.Function<Row,Row>	GroupByQueryQueryToolChest.makePostComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
com.google.common.base.Function<Row,Row>	GroupByQueryQueryToolChest.makePostComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
com.google.common.base.Function<Row,Row>	GroupByQueryQueryToolChest.makePreComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
com.google.common.base.Function<Row,Row>	GroupByQueryQueryToolChest.makePreComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
QueryRunner<Row>	GroupByQueryQueryToolChest.mergeResults(QueryRunner<Row> runner)
QueryRunner<Row>	GroupByQueryRunnerFactory.mergeRunners(ExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
static Sequence<Row>	GroupByQueryHelper.postAggregate(GroupByQuery query, IncrementalIndex index)
QueryRunner<Row>	GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Row> runner)
Sequence<Row>	GroupByQueryEngine.process(GroupByQuery query, StorageAdapter storageAdapter)
Query<Row>	GroupByQuery.withDataSource(DataSource dataSource)

Method parameters in io.druid.query.groupby with type arguments of type Row

Modifier and Type	Method and Description
Sequence<Row>	GroupByQuery.applyLimit(Sequence<Row> results) Apply the havingSpec and limitSpec.
static RowBasedColumnSelectorFactory	RowBasedColumnSelectorFactory.create(com.google.common.base.Supplier<? extends Row> row, Map<String,ValueType> rowSignature)
static RowBasedColumnSelectorFactory	RowBasedColumnSelectorFactory.create(ThreadLocal<? extends Row> row, Map<String,ValueType> rowSignature)
static IncrementalIndex	GroupByQueryHelper.makeIncrementalIndex(GroupByQuery query, GroupByQueryConfig config, StupidPool<ByteBuffer> bufferPool, Sequence<Row> rows, boolean combine)
QueryRunner<Row>	GroupByQueryQueryToolChest.mergeResults(QueryRunner<Row> runner)
QueryRunner<Row>	GroupByQueryRunnerFactory.mergeRunners(ExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
QueryRunner<Row>	GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Row> runner)

Uses of Row in io.druid.query.groupby.epinephelinae

Methods in io.druid.query.groupby.epinephelinae that return Row

Modifier and Type	Method and Description
Row	GroupByBinaryFnV2.apply(Row arg1, Row arg2)

Methods in io.druid.query.groupby.epinephelinae that return types with arguments of type Row

Modifier and Type	Method and Description
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Row>>	RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query, boolean isInputRaw, Map<String,ValueType> rawInputRowSignature, GroupByQueryConfig config, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, int concurrencyHint, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, AggregatorFactory[] aggregatorFactories) If isInputRaw is true, transformations such as timestamp truncation and extraction functions have not been applied to the input rows yet, for example, in a nested query, if an extraction function is being applied in the outer query to a field of the inner query.
static CloseableGrouperIterator<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey,Row>	RowBasedGrouperHelper.makeGrouperIterator(Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper, GroupByQuery query, Closeable closeable)
static Sequence<Row>	GroupByQueryEngineV2.process(GroupByQuery query, StorageAdapter storageAdapter, StupidPool<ByteBuffer> intermediateResultsBufferPool, GroupByQueryConfig config)
static Sequence<Row>	GroupByRowProcessor.process(Query queryParam, Sequence<Row> rows, Map<String,ValueType> rowSignature, GroupByQueryConfig config, GroupByQueryResource resource, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir)
Sequence<Row>	GroupByMergingQueryRunnerV2.run(Query queryParam, Map responseContext)

Methods in io.druid.query.groupby.epinephelinae with parameters of type Row

Modifier and Type	Method and Description
Row	GroupByBinaryFnV2.apply(Row arg1, Row arg2)

Method parameters in io.druid.query.groupby.epinephelinae with type arguments of type Row

Modifier and Type	Method and Description
static Sequence<Row>	GroupByRowProcessor.process(Query queryParam, Sequence<Row> rows, Map<String,ValueType> rowSignature, GroupByQueryConfig config, GroupByQueryResource resource, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir)

Constructor parameters in io.druid.query.groupby.epinephelinae with type arguments of type Row

Constructor and Description
GroupByMergingQueryRunnerV2(GroupByQueryConfig config, ExecutorService exec, QueryWatcher queryWatcher, Iterable<QueryRunner<Row>> queryables, int concurrencyHint, BlockingPool<ByteBuffer> mergeBufferPool, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir)

Uses of Row in io.druid.query.groupby.having

Methods in io.druid.query.groupby.having with parameters of type Row

Modifier and Type	Method and Description
boolean	OrHavingSpec.eval(Row row)
boolean	NotHavingSpec.eval(Row row)
boolean	NeverHavingSpec.eval(Row row)
boolean	LessThanHavingSpec.eval(Row row)
boolean	HavingSpec.eval(Row row) Evaluates if a given row satisfies the having spec.
boolean	GreaterThanHavingSpec.eval(Row row)
boolean	EqualToHavingSpec.eval(Row row)
boolean	DimensionSelectorHavingSpec.eval(Row row)
boolean	DimFilterHavingSpec.eval(Row row)
boolean	AndHavingSpec.eval(Row row)
boolean	AlwaysHavingSpec.eval(Row row)

Uses of Row in io.druid.query.groupby.orderby

Methods in io.druid.query.groupby.orderby that return types with arguments of type Row

Modifier and Type	Method and Description
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	NoopLimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	NoopLimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	LimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs) Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	LimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs) Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	DefaultLimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	DefaultLimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)

Uses of Row in io.druid.query.groupby.strategy

Methods in io.druid.query.groupby.strategy that return types with arguments of type Row

Modifier and Type	Method and Description
QueryRunner<Row>	GroupByStrategyV2.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest)
QueryRunner<Row>	GroupByStrategyV1.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest)
QueryRunner<Row>	GroupByStrategy.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest) Decorate a runner with an interval chunking decorator.
Sequence<Row>	GroupByStrategyV2.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategyV1.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategy.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
QueryRunner<Row>	GroupByStrategyV2.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
QueryRunner<Row>	GroupByStrategyV1.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
QueryRunner<Row>	GroupByStrategy.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
Sequence<Row>	GroupByStrategyV2.process(GroupByQuery query, StorageAdapter storageAdapter)
Sequence<Row>	GroupByStrategyV1.process(GroupByQuery query, StorageAdapter storageAdapter)
Sequence<Row>	GroupByStrategy.process(GroupByQuery query, StorageAdapter storageAdapter)
Sequence<Row>	GroupByStrategyV2.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResource resource, Sequence<Row> subqueryResult)
Sequence<Row>	GroupByStrategyV1.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResource resource, Sequence<Row> subqueryResult)
Sequence<Row>	GroupByStrategy.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResource resource, Sequence<Row> subqueryResult)

Method parameters in io.druid.query.groupby.strategy with type arguments of type Row

Modifier and Type	Method and Description
QueryRunner<Row>	GroupByStrategyV2.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest)
QueryRunner<Row>	GroupByStrategyV1.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest)
QueryRunner<Row>	GroupByStrategy.createIntervalChunkingRunner(IntervalChunkingQueryRunnerDecorator decorator, QueryRunner<Row> runner, GroupByQueryQueryToolChest toolChest) Decorate a runner with an interval chunking decorator.
Sequence<Row>	GroupByStrategyV2.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategyV1.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
Sequence<Row>	GroupByStrategy.mergeResults(QueryRunner<Row> baseRunner, GroupByQuery query, Map<String,Object> responseContext)
QueryRunner<Row>	GroupByStrategyV2.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
QueryRunner<Row>	GroupByStrategyV1.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
QueryRunner<Row>	GroupByStrategy.mergeRunners(com.google.common.util.concurrent.ListeningExecutorService exec, Iterable<QueryRunner<Row>> queryRunners)
Sequence<Row>	GroupByStrategyV2.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResource resource, Sequence<Row> subqueryResult)
Sequence<Row>	GroupByStrategyV1.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResource resource, Sequence<Row> subqueryResult)
Sequence<Row>	GroupByStrategy.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResource resource, Sequence<Row> subqueryResult)

Uses of Row in io.druid.segment.incremental

Methods in io.druid.segment.incremental that return types with arguments of type Row

Modifier and Type	Method and Description
Iterable<Row>	IncrementalIndex.iterableWithPostAggregations(List<PostAggregator> postAggs, boolean descending)
Iterator<Row>	IncrementalIndex.iterator()