com.twitter.summingbird.batch

MillisecondBatcher

class MillisecondBatcher extends AbstractBatcher

Batcher implementation based on a fixed-width batch of milliseconds.

Source
MillisecondBatcher.scala
Linear Supertypes
AbstractBatcher, Batcher, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. MillisecondBatcher
  2. AbstractBatcher
  3. Batcher
  4. Serializable
  5. AnyRef
  6. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MillisecondBatcher(durationMillis: Long)

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. def batchOf(t: Timestamp): BatchID

    Returns the batch into which the supplied Date is bucketed.

    Returns the batch into which the supplied Date is bucketed.

    Definition Classes
    MillisecondBatcherBatcher
  8. def batchesCoveredBy(interval: Interval[Timestamp]): Interval[BatchID]

    Definition Classes
    Batcher
  9. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  10. def cover(interval: Interval[Timestamp]): Interval[BatchID]

    What batches are needed to cover the given interval or: for all t in interval, batchOf(t) is in the result

    What batches are needed to cover the given interval or: for all t in interval, batchOf(t) is in the result

    Definition Classes
    Batcher
  11. def currentBatch: BatchID

    Returns the current BatchID.

    Returns the current BatchID.

    Definition Classes
    Batcher
  12. val durationMillis: Long

  13. def earliestTimeOf(batch: BatchID): Timestamp

    Returns the (inclusive) earliest time of the supplied batch.

    Returns the (inclusive) earliest time of the supplied batch.

    Definition Classes
    MillisecondBatcherBatcher
  14. def enclosedBy(extremities: (BatchID, BatchID), other: Batcher): Iterable[BatchID]

    Definition Classes
    Batcher
  15. def enclosedBy(batchID: BatchID, other: Batcher): Iterable[BatchID]

    Returns the sequence of BatchIDs that the supplied other batcher would need to fetch to fully enclose the supplied batchID.

    Returns the sequence of BatchIDs that the supplied other batcher would need to fetch to fully enclose the supplied batchID.

    Definition Classes
    Batcher
  16. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  17. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  18. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  19. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  20. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  21. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  22. def isLowerBatchEdge(ts: Timestamp): Boolean

    Returns true if the supplied timestamp sits at the floor of the supplied batch.

    Returns true if the supplied timestamp sits at the floor of the supplied batch.

    Definition Classes
    Batcher
  23. def latestTimeOf(batch: BatchID): Timestamp

    Returns the latest time in the given batch

    Returns the latest time in the given batch

    Definition Classes
    Batcher
  24. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  25. final def notify(): Unit

    Definition Classes
    AnyRef
  26. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  27. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  28. def toInterval(b: BatchID): Interval[Timestamp]

    Definition Classes
    Batcher
  29. def toString(): String

    Definition Classes
    AnyRef → Any
  30. def toTimestamp(b: Interval[BatchID]): Interval[Timestamp]

    Definition Classes
    Batcher
  31. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AbstractBatcher

Inherited from Batcher

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped