Adds the int. @param number the number

Returns false if keys is empty or null AND lastRowKey is null or empty; otherwise returns true;. @param keys input row keys @param lastRowKe

Builds start and stop row keys according to the following logic : 1. Creates tokens out of 'key' using pcap_id delimiter ('-') 2. if the input 'key' c

Gets the column qualifier. @return the column qualifier

Gets the column qualifier. @return the column qualifier

Creates HConnection instance when the first request is received and returns the same instance for all subsequent requests if the connection is still o

Gets the global header. @return the global header

Gets the global header. @return the global header

Returns the configured max row size in bytes. @return long

Gets the pcaps. @return the pcaps @throws IOException Signals that an I/O exception has occurred.

Gets the pcaps. @return the pcaps @throws IOException Signals that an I/O exception has occurred.

@return the tableName

Gets the test pcap bytes. @return the test pcap bytes @throws IOException the IO exception

Returns the testProperties. @return the testProperties.

@return token image as String

Match the given list of <tt>log</tt> with the named regex and return the list of json representation of the matched elements. @param logs : list of l

Closes pcap stream handle. @throws IOException Signals that an I/O exception has occurred. @see org.krakenapps.pcap.PcapInputStr

Creates the scan request. @param cf the cf @param cq the cq @param startKey the start key @param endKey the end k

Common method to load content of all configuration resources defined in 'config-definition.xml'. @param configDefFilePath the config def fil

Creates HConnection instance when the first request is received and returns the same instance for all subsequent requests if the connection is still o

Returns the 'hbase' data creation time unit by reading 'hbase.table.data.time.unit' property in 'hbase-config' properties file; If none is mentioned i

Returns the configured max result size in bytes. @return long

Returns the configured max row size in bytes. @return long

Get the named regex from the given id. @param id : named regex id @return String of the named regex

Reads a packet from pcap byte array. @return the packet throws IOException the stream has been closed and the contained input stream does not

Gets the row size unit. @return the row size unit

@return

Gets the status. @return the status

Gets the status. @return the status

@return the writeBufferSize

Sets the mode. @param mode the mode.

@param readSchemaFromFile

Get the map representation of the matched element in the text. @return map object from the matched element in the text

validateJsonData @param jsonSchema @param jsonData @return @throws Exception

@param BulkIndexNumber number of documents to bulk index together @return instance of bolt

@param ClusterName name of cluster to index into in ElasticSearch/Solr/etc... @return instance of bolt

@param DocumentName name of document to be indexed in ElasticSearch/Solr/etc... @return

@param adapter adapter that handles indexing of JSON strings @return instance of bolt

@param IndexIP ip of ElasticSearch/Solr/etc... @return instance of bolt

@param IndexName name of the index in ElasticSearch/Solr/etc... @return instance of bolt

@param IndexPort port of ElasticSearch/Solr/etc... @return instance of bolt

@param dateFormat timestamp to append to index names @return instance of bolt

Switch to specified lex state.

Replaces unprintable characters by their escaped (or unicode escaped) equivalents in the given string

Add custom pattern to grok in the runtime. @param name : Pattern Name @param pattern : Regular expression Or {@code Grok} pattern @throws Exception

Adds the pcaps. @param pcaps the pcaps

Adds the pcaps. @param pcaps the pcaps

Adds the to response. @param pcapsResponse the pcaps response @param scannedCells the scanned cells @param maxResultSize t

Adds the to response. @param pcapsResponse the pcaps response @param scannedCells the scanned cells @param maxResultSize t

Match to the <tt>subject</tt> the <tt>regex</tt> and save the matched element into a map.

Remove and rename the unwanted elelents in the matched map.

Closes the underlying connection to cluster; ignores if any exception is thrown.

Closes the underlying connection to cluster; ignores if any exception is thrown.

Connection available. @return true, if successful

Connection available. @return true, if successful

Convert seconds to data creation time unit. @param inputTime the input time @return the long

Creates the scan request. @param pcapsResponse the pcaps response @param keysMap the keys map @param startTime the start t

Execute scan request. @param table hbase table @param scan the scan @return the list @throws IOException Signals that an

Execute scan request. @param table hbase table @param scan the scan @return the list @throws IOException Signals that an

Method flush. @throws IOException @see org.krakenapps.pcap.PcapOutputStream#flush() @see org.krakenapps.pcap.PcapOutputStream#flush()

Returns the allAlertAdapter. @return the allAlertAdapter.

Gets the appending token digits. @return the appending token digits

Gets the appending token digits. @return the appending token digits

Returns Comparator for sorting pcaps cells based on the timestamp (dsc). @return CellTimestampComparator

Returns Comparator for sorting pcaps cells based on the timestamp (dsc). @return CellTimestampComparator

Get end column.

Get end line.