object
StateChangeLogMerger
extends Logging
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
asInstanceOf
[T0]
: T0
-
def
clone
(): AnyRef
-
object
dateBasedOrdering
extends Ordering[LineIterator]
-
val
dateFormat
: SimpleDateFormat
-
val
dateFormatString
: String
-
val
dateRegex
: Regex
-
def
debug
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
debug
(e: ⇒ Throwable): Any
-
def
debug
(msg: ⇒ String): Unit
-
var
endDate
: Date
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
error
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
error
(e: ⇒ Throwable): Any
-
def
error
(msg: ⇒ String): Unit
-
def
fatal
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
fatal
(e: ⇒ Throwable): Any
-
def
fatal
(msg: ⇒ String): Unit
-
var
files
: List[String]
-
def
finalize
(): Unit
-
def
getClass
(): java.lang.Class[_]
-
def
getNextLine
(itr: Iterator[String]): LineIterator
-
def
hashCode
(): Int
-
def
info
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
info
(e: ⇒ Throwable): Any
-
def
info
(msg: ⇒ String): Unit
-
def
isInstanceOf
[T0]
: Boolean
-
var
logIdent
: String
-
lazy val
logger
: Logger
-
val
loggerName
: String
-
def
main
(args: Array[String]): Unit
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
var
partitions
: List[Int]
-
var
startDate
: Date
-
def
swallow
(action: ⇒ Unit): Unit
-
def
swallowDebug
(action: ⇒ Unit): Unit
-
def
swallowError
(action: ⇒ Unit): Unit
-
def
swallowInfo
(action: ⇒ Unit): Unit
-
def
swallowTrace
(action: ⇒ Unit): Unit
-
def
swallowWarn
(action: ⇒ Unit): Unit
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
var
topic
: String
-
val
topicPartitionRegex
: Regex
-
def
trace
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
trace
(e: ⇒ Throwable): Any
-
def
trace
(msg: ⇒ String): Unit
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
-
def
warn
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
warn
(e: ⇒ Throwable): Any
-
def
warn
(msg: ⇒ String): Unit
Inherited from AnyRef
Inherited from Any
A utility that merges the state change logs (possibly obtained from different brokers and over multiple days).
This utility expects at least one of the following two arguments - 1. A list of state change log files 2. A regex to specify state change log file names.
This utility optionally also accepts the following arguments - 1. The topic whose state change logs should be merged 2. A list of partitions whose state change logs should be merged (can be specified only when the topic argument is explicitly specified) 3. Start time from when the logs should be merged 4. End time until when the logs should be merged