PipelineBuilder
where()
def where(filter) -> 'PipelineBuilder':Parameters
PropType
filterFilter
Type
FilterReturns
'PipelineBuilder'
pick()
def pick(*, by=None, n=None, per=None, reverse=None) -> 'PipelineBuilder':Parameters
PropType
by?Optional[str]
Type
Optional[str]Default
Nonen?Optional[int]
Type
Optional[int]Default
Noneper?Optional[str]
Type
Optional[str]Default
Nonereverse?Optional[bool]
Type
Optional[bool]Default
NoneReturns
'PipelineBuilder'
derive()
def derive(cols) -> 'PipelineBuilder':Parameters
PropType
colsMapping[str, Any]
Type
Mapping[str, Any]Returns
'PipelineBuilder'
summarize()
def summarize(aggs, *, by=None) -> 'PipelineBuilder':Parameters
PropType
aggsMapping[str, Any]
Type
Mapping[str, Any]by?Any
Type
AnyDefault
NoneReturns
'PipelineBuilder'
sort()
def sort(by) -> 'PipelineBuilder':Parameters
PropType
bystr
Type
strReturns
'PipelineBuilder'
take()
def take(n, offset=None) -> 'PipelineBuilder':Parameters
PropType
nint
Type
intoffset?Optional[int]
Type
Optional[int]Default
NoneReturns
'PipelineBuilder'
chart()
def chart(*, chart_type, title, x_axis, y_axis, series_by=None, description=None) -> JsonObject:Parameters
PropType
chart_typeChartType
Type
ChartTypetitlestr
Type
strx_axisPresentationField
Type
PresentationFieldy_axisPresentationField
Type
PresentationFieldseries_by?Optional[PresentationField]
Type
Optional[PresentationField]Default
Nonedescription?Optional[str]
Type
Optional[str]Default
NoneReturns
JsonObject
table()
def table(*, title, columns, description=None) -> JsonObject:Parameters
PropType
titlestr
Type
strcolumnsSequence[PresentationField]
Type
Sequence[PresentationField]description?Optional[str]
Type
Optional[str]Default
NoneReturns
JsonObject
to_json()
def to_json() -> JsonObject:Returns
JsonObject
__init__()
def __init__(_spec, _stages) -> None:Parameters
PropType
_specJsonObject
Type
JsonObject_stagestuple[JsonObject, ...]
Type
tuple[JsonObject, ...]Returns
None