Returns the image.

Close the table

Remove from the map the unwilling items. @param map to clean @return nb of deleted item

Create a {@code Grok} instance with the given patterns file and a {@code Grok} pattern. @param grokPatternPath Path to the pattern file @param grokEx

Loads configuration resources @return Configuration

Loads configuration resources @return Configuration

Returns the mode. @return the mode.

Skip Tests

Always returns the singleton instance. @return IPcapGetter singleton instance @throws IOException Signals that an I/O exception has occurre

Converts the given time to the 'hbase' data creation time unit. @param inputTime the input time @return the long

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

Compile the {@code Grok} pattern to named regex pattern. @param pattern : Grok pattern (ex: %{IP}) @throws Exception

Gets the packet header. @return the packet header

@param OutputFieldName - output name of the tuple coming out of this bolt @return - instance of this bolt

Always returns the singleton instance. @return IPcapGetter singleton instance @throws IOException Signals that an I/O exception has occurre

@return the table

Read a character.

Get the next Token.

An optional attribute value of the Token. Tokens which are not used as syntactic sugar will often contain meaningful values that will be used later on

Sort the potentially unsorted byte array according to the timestamp in the packet header @param unsortedBytes a byte array of a pcap file @return b

@param config A class for generating custom metrics into graphite @return Instance of this class

Add column family and column qualifier to be extracted from tuple @param columnFamily The column family name @param columnQualifier

Returns the config. @return the config.

Retreat.

@param filter A class for filtering/dropping incomming telemetry messages @return Instance of this class

@param parser The parser class for parsing the incoming raw message byte stream @return Instance of this class

@param config A class for generating custom metrics into graphite @return Instance of this class

Convert ipv4 ip to hex. @param ipAddress the ip address @return the string

Converts the given time to the 'hbase' data creation time unit. @param inputTime the input time @return the long

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

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

Always returns the singleton instance. @return IPcapScanner singleton instance @throws IOException Signals that an I/O exception has occurr

Gets the key. @return the key

Gets the result size unit. @return the result size unit

Gets the session key. @param srcIp the src ip @param dstIp the dst ip @param protocol the protocol @param srcPort

@param EnrichmentTag Defines what tag the enrichment will be tagged with in the telemetry message @return Instance of this class

@param MAX_CACHE_SIZE_OBJECTS_NUM Maximum size of cache before flushing @return Instance of this class

@param MAX_TIME_RETAIN_MINUTES Maximum time to retain cached entry before expiring @return Instance of this class

Method write. @param packet PcapPacket @throws IOException @see org.krakenapps.pcap.PcapOutputStream#write(PcapPacket) @see org

Convert to bytes. @param value the value @param unit the unit @return the long

Convert to bytes. @param value the value @param unit the unit @return the long

Creates the get request. @param key the key @param startTime the start time @param endTime the end time @return the gets t

Gets the column family. @return the column family

Gets the column family. @return the column family

Singleton. @return instance of Match

You can also modify the body of this method to customize your error messages. For example, cases like LOOP_DETECTED and INVALID_LEXICAL_STATE are not

Gets the response size. @return the response size

Gets the response size. @return the response size

Gets the result size unit. @return the result size unit

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

<p> Returns the sublist starting from the element after the lastRowKey to the last element in the list; if the 'lastRowKey' is not matched the complet

Int to byte array. @param number the number @return the byte[]

Match the given <tt>text</tt> with the named regex {@code Grok} will extract data from the string and get an extence of {@link Match}. @param text :

Builds the reverseKey to fetch the pcaps in the reverse traffic (destination to source). @param key indicates hbase rowKey (partial or full)

Scan pcaps. @param pcaps the pcaps @param table the table @param scan the scan @param cf the cf @param cq

Sets the mode. @param mode the mode.

Adds reverse keys to the list if the flag 'includeReverseTraffic' is set to true; removes duplicates and sorts the list by ascending order;. @param k

@param adapter Adapter for doing the enrichment @return Instance of this class

@param jsonKeys Keys in the telemetry message that are to be enriched by this bolt @return Instance of this class