Package org.apache.calcite.adapter.splunk.search

Class SplunkConnectionImpl

java.lang.Object

org.apache.calcite.adapter.splunk.search.SplunkConnectionImpl

All Implemented Interfaces:

SplunkConnection

public class SplunkConnectionImpl
extends java.lang.Object
implements SplunkConnection

Implementation of SplunkConnection based on Splunk's REST API.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SplunkConnectionImpl.CountingSearchResultListener	Implementation of SearchResultListener interface that just counts the results.
static class	SplunkConnectionImpl.SplunkResultEnumerator	Implementation of Enumerator that parses results from a Splunk REST call.

Field Summary

Fields

Modifier and Type	Field	Description
private static org.slf4j.Logger	LOGGER
(package private) java.lang.String	password
(package private) java.util.Map<java.lang.String,java.lang.String>	requestHeaders
private static java.util.regex.Pattern	SESSION_KEY
(package private) java.lang.String	sessionKey
(package private) java.net.URL	url
(package private) java.lang.String	username

Constructor Summary

Constructors

Constructor	Description
SplunkConnectionImpl(java.lang.String url, java.lang.String username, java.lang.String password)
SplunkConnectionImpl(java.net.URL url, java.lang.String username, java.lang.String password)

Method Summary

Modifier and Type	Method	Description
private static void	close(java.io.Closeable c)
private void	connect()
Enumerator<java.lang.Object>	getSearchResultEnumerator(java.lang.String search, java.util.Map<java.lang.String,java.lang.String> otherArgs, java.util.List<java.lang.String> fieldList)
void	getSearchResults(java.lang.String search, java.util.Map<java.lang.String,java.lang.String> otherArgs, java.util.List<java.lang.String> fieldList, SearchResultListener srl)
private Enumerator<java.lang.Object>	getSearchResults_(java.lang.String search, java.util.Map<java.lang.String,java.lang.String> otherArgs, java.util.List<java.lang.String> wantedFields, SearchResultListener srl)
static void	main(java.lang.String[] args)
static void	parseArgs(java.lang.String[] args, java.util.Map<java.lang.String,java.lang.String> map)
private static void	parseResults(java.io.InputStream in, SearchResultListener srl)
static void	printUsage(java.lang.String errorMsg)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

SESSION_KEY

private static final java.util.regex.Pattern SESSION_KEY

url

final java.net.URL url

username

final java.lang.String username

password

final java.lang.String password

sessionKey

java.lang.String sessionKey

requestHeaders

final java.util.Map<java.lang.String,java.lang.String> requestHeaders

Constructor Detail

SplunkConnectionImpl

public SplunkConnectionImpl(java.lang.String url,
                            java.lang.String username,
                            java.lang.String password)
                     throws java.net.MalformedURLException

Throws:

java.net.MalformedURLException

SplunkConnectionImpl

public SplunkConnectionImpl(java.net.URL url,
                            java.lang.String username,
                            java.lang.String password)

Method Detail

close

private static void close(java.io.Closeable c)

connect

private void connect()

getSearchResults

public void getSearchResults(java.lang.String search,
                             java.util.Map<java.lang.String,java.lang.String> otherArgs,
                             java.util.List<java.lang.String> fieldList,
                             SearchResultListener srl)

Specified by:

getSearchResults in interface SplunkConnection

getSearchResultEnumerator

public Enumerator<java.lang.Object> getSearchResultEnumerator(java.lang.String search,
                                                              java.util.Map<java.lang.String,java.lang.String> otherArgs,
                                                              java.util.List<java.lang.String> fieldList)

Specified by:

getSearchResultEnumerator in interface SplunkConnection

getSearchResults_

private Enumerator<java.lang.Object> getSearchResults_(java.lang.String search,
                                                       java.util.Map<java.lang.String,java.lang.String> otherArgs,
                                                       java.util.List<java.lang.String> wantedFields,
                                                       SearchResultListener srl)

parseResults

private static void parseResults(java.io.InputStream in,
                                 SearchResultListener srl)

parseArgs

public static void parseArgs(java.lang.String[] args,
                             java.util.Map<java.lang.String,java.lang.String> map)

printUsage

public static void printUsage(java.lang.String errorMsg)

main

public static void main(java.lang.String[] args)
                 throws java.net.MalformedURLException

Throws:

java.net.MalformedURLException