com.twitter.summingbird.batch

AbstractBatcher

abstract class AbstractBatcher extends Batcher

Abstract class to extend for easier java interop.

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

Instance Constructors

  1. new AbstractBatcher()

Abstract Value Members

  1. abstract 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
    Batcher
  2. abstract 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
    Batcher

Concrete 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 batchesCoveredBy(interval: Interval[Timestamp]): Interval[BatchID]

    Definition Classes
    Batcher
  8. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  9. 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
  10. def currentBatch: BatchID

    Returns the current BatchID.

    Returns the current BatchID.

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

    Definition Classes
    Batcher
  12. 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
  13. final def eq(arg0: AnyRef): Boolean

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

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

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

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

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

    Definition Classes
    Any
  19. 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
  20. def latestTimeOf(batch: BatchID): Timestamp

    Returns the latest time in the given batch

    Returns the latest time in the given batch

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

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

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

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

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

    Definition Classes
    Batcher
  26. def toString(): String

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

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

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Batcher

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped