org.eligosource.eventsourced.journal

hbase

package hbase

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. hbase
  2. AnyRef
  3. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Type Members

  1. case class HBaseJournalProps(zookeeperQuorum: String, tableName: String = ..., name: Option[String] = scala.None, dispatcherName: Option[String] = scala.None, replayChunkSize: Int = 16.*(100), initTimeout: FiniteDuration = ..., snapshotPath: Path = ..., snapshotSerializer: SnapshotSerializer = ..., snapshotLoadTimeout: FiniteDuration = ..., snapshotSaveTimeout: FiniteDuration = ..., snapshotFilesystem: FileSystem = ..., readOnly: Boolean = false) extends JournalProps with HadoopFilesystemSnapshottingProps[HBaseJournalProps] with Product with Serializable

    Configuration object for a HBase backed journal.

  2. class PartitionCountNotFoundException extends Exception

Value Members

  1. val AckColumnPrefix: String

  2. val ColumnFamilyName: String

  3. val ColumnFamilyNameBytes: Array[Byte]

  4. object CreateTable extends App

    Creates an HBase event message table.

  5. val DefaultPartitionCount: Int

  6. val DefaultTableName: String

  7. object DeleteTable extends App

    Deletes an HBase event message table.

  8. object HBaseJournalProps extends Serializable

  9. val MsgColumnName: String

  10. val MsgColumnNameBytes: Array[Byte]

  11. val PartitionCountColumnName: String

  12. val PartitionCountColumnNameBytes: Array[Byte]

  13. val SequenceNrColumnName: String

  14. val SequenceNrColumnNameBytes: Array[Byte]

  15. val TimestampColumnName: String

  16. val TimestampColumnNameBytes: Array[Byte]

  17. def ackColumnBytes(channelId: Int): Array[Byte]

  18. implicit def deferredToFuture[A](d: Deferred[A]): Future[A]

Inherited from AnyRef

Inherited from Any

Ungrouped