Package org.spf4j.avro

Interface AvroDataSet<T extends org.apache.avro.generic.IndexedRecord>

@ParametersAreNonnullByDefault
public interface AvroDataSet<T extends org.apache.avro.generic.IndexedRecord>

Author:

Zoltan Farkas

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	AvroDataSet.Feature

Method Summary

Modifier and Type	Method	Description
org.spf4j.base.CloseableIterable<? extends org.apache.avro.generic.IndexedRecord>	getData(SqlPredicate<T> filter, List<String> selectProjections, org.spf4j.security.AbacSecurityContext secCtx, long timeout, TimeUnit timeUnit)
default org.apache.avro.Schema	getElementSchema()
default Set<AvroDataSet.Feature>	getFeatures()
default String	getName()
default long	getRowCountStatistic()

Method Detail

getElementSchema

default org.apache.avro.Schema getElementSchema()

getName

default String getName()

getFeatures

default Set<AvroDataSet.Feature> getFeatures()

getRowCountStatistic

default long getRowCountStatistic()

Returns:

-1 for unknown. or number of elements.

getData

org.spf4j.base.CloseableIterable<? extends org.apache.avro.generic.IndexedRecord> getData(@Nullable
                                                                                          SqlPredicate<T> filter,
                                                                                          @Nullable
                                                                                          List<String> selectProjections,
                                                                                          org.spf4j.security.AbacSecurityContext secCtx,
                                                                                          long timeout,
                                                                                          TimeUnit timeUnit)

Parameters:

filter - all results must comply to this filter, null means no filter.

selectProjections - list of fields that are requested. null for no projections.

Returns: