stream.scotty.slicing.slice

Class AbstractSlice<InputType,ValueType>

java.lang.Object

slice.stream.scotty.slicing.AbstractSlice<InputType,ValueType>

All Implemented Interfaces:

Slice<InputType,ValueType>

Direct Known Subclasses:

EagerSlice

public abstract class AbstractSlice<InputType,ValueType>
extends java.lang.Object
implements Slice<InputType,ValueType>

Nested Class Summary

Nested classes/interfaces inherited from interface stream.scotty.slicing.slice.Slice

Slice.Fixed, Slice.Flexible, Slice.Type

Field Summary

Fields

Modifier and Type	Field and Description
private long	tEnd
private long	tFirst
private long	tLast
private long	tStart
private Slice.Type	type

Constructor Summary

Constructors

Constructor and Description
AbstractSlice(long startTs, long endTs, Slice.Type type)

Method Summary

Modifier and Type	Method and Description
void	addElement(InputType element, long ts) Add a element to the slice.
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
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface stream.scotty.slicing.slice.Slice

getAggState

Field Detail

tStart

private long tStart

tEnd

private long tEnd

type

private Slice.Type type

tLast

private long tLast

tFirst

private long tFirst

Constructor Detail

AbstractSlice

public AbstractSlice(long startTs,
                     long endTs,
                     Slice.Type type)

Method Detail

addElement

public void addElement(InputType element,
                       long ts)

Description copied from interface: Slice

Add a element to the slice.

Specified by:

addElement in interface Slice<InputType,ValueType>

Parameters:

element - the element which is added

ts - timestamp of the element

merge

public void merge(Slice otherSlice)

Specified by:

merge in interface Slice<InputType,ValueType>

getTLast

public long getTLast()

Description copied from interface: Slice

timestamp of the last record in the slice

Specified by:

getTLast in interface Slice<InputType,ValueType>

Returns:

long

getTFirst

public long getTFirst()

Description copied from interface: Slice

timestamp of the first record in the slice

Specified by:

getTFirst in interface Slice<InputType,ValueType>

Returns:

long

getTStart

public long getTStart()

Specified by:

getTStart in interface Slice<InputType,ValueType>

Returns:

slice start timestamp

setTStart

public void setTStart(long tStart)

Specified by:

setTStart in interface Slice<InputType,ValueType>

getTEnd

public long getTEnd()

Specified by:

getTEnd in interface Slice<InputType,ValueType>

Returns:

slice end timestamp

setTEnd

public void setTEnd(long tEnd)

Specified by:

setTEnd in interface Slice<InputType,ValueType>

getType

public Slice.Type getType()

Description copied from interface: Slice

The measure of the slice end.

Specified by:

getType in interface Slice<InputType,ValueType>

Returns:

Type

setType

public void setType(Slice.Type type)

Description copied from interface: Slice

Set the end of the slice

Specified by:

setType in interface Slice<InputType,ValueType>

Parameters:

type - of slice end

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object