stream.scotty.slicing.slice

Interface Slice<InputType,ValueType>

All Known Implementing Classes:

AbstractSlice, EagerSlice

public interface Slice<InputType,ValueType>

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	Slice.Fixed
static class	Slice.Flexible
static interface	Slice.Type

Method Summary

Modifier and Type	Method and Description
void	addElement(InputType element, long ts) Add a element to the slice.
AggregationState	getAggState()
long	getTEnd()
long	getTFirst() timestamp of the first record in the slice
long	getTLast() timestamp of the last record in the slice
long	getTStart()
Slice.Type	getType() The measure of the slice end.
void	merge(Slice otherSlice)
void	setTEnd(long tEnd)
void	setTStart(long tStart)
void	setType(Slice.Type type) Set the end of the slice

Method Detail

getTStart

long getTStart()

Returns:

slice start timestamp

setTStart

void setTStart(long tStart)

getTEnd

long getTEnd()

Returns:

slice end timestamp

setTEnd

void setTEnd(long tEnd)

getTFirst

long getTFirst()

timestamp of the first record in the slice

Returns:

long

merge

void merge(Slice otherSlice)

getTLast

long getTLast()

timestamp of the last record in the slice

Returns:

long

getType

Slice.Type getType()

The measure of the slice end.

Returns:

Type

setType

void setType(Slice.Type type)

Set the end of the slice

Parameters:

type - of slice end

getAggState

AggregationState getAggState()

Returns:

addElement

void addElement(InputType element,
                long ts)

Add a element to the slice.

Parameters:

element - the element which is added

ts - timestamp of the element