druid

Documentation

Index

• func Ingest(coordinatorURL, specJSON, datasourceName string, timeout time.Duration) error
• type NativeClient
  • func NewNativeClient(olap drivers.OLAPStore) (*NativeClient, error)
  • func (n *NativeClient) Search(ctx context.Context, dr *NativeSearchQueryRequest) (NativeSearchQueryResponse, error)
• type NativeSearchQuery
• type NativeSearchQueryRequest
  • func NewNativeSearchQueryRequest(source, search string, dims []string, virtualCols []NativeVirtualColumns, ...) NativeSearchQueryRequest
• type NativeSearchQueryResponse
• type NativeSearchSort
• type NativeVirtualColumns
• type QueryContext
• type QueryPlan

Functions

func Ingest

func Ingest(coordinatorURL, specJSON, datasourceName string, timeout time.Duration) error

Ingest uses the Druid REST API to submit an ingestion spec. It returns once Druid has finished ingesting data. This function is for test and development usage and has not been tested for production use.

Types

type NativeClient

type NativeClient struct {
	// contains filtered or unexported fields
}

func NewNativeClient

func NewNativeClient(olap drivers.OLAPStore) (*NativeClient, error)

func (*NativeClient) Search

func (n *NativeClient) Search(ctx context.Context, dr *NativeSearchQueryRequest) (NativeSearchQueryResponse, error)

type NativeSearchQuery

type NativeSearchQuery struct {
	Type          string `json:"type"`
	CaseSensitive bool   `json:"case_sensitive"`
	Value         string `json:"value"`
}

type NativeSearchQueryRequest

type NativeSearchQueryRequest struct {
	Context          QueryContext           `json:"context"`
	QueryType        string                 `json:"queryType"`
	DataSource       string                 `json:"dataSource"`
	SearchDimensions []string               `json:"searchDimensions"`
	VirtualColumns   []NativeVirtualColumns `json:"virtualColumns"`
	Limit            int                    `json:"limit"`
	Query            NativeSearchQuery      `json:"query"`
	Sort             NativeSearchSort       `json:"sort"`
	Intervals        []string               `json:"intervals"`
	Filter           map[string]interface{} `json:"filter"`
}

func NewNativeSearchQueryRequest

func NewNativeSearchQueryRequest(source, search string, dims []string, virtualCols []NativeVirtualColumns, limit int, start, end time.Time, filter map[string]interface{}) NativeSearchQueryRequest

type NativeSearchQueryResponse

type NativeSearchQueryResponse []struct {
	Timestamp time.Time `json:"timestamp"`
	Result    []struct {
		Dimension string `json:"dimension"`
		Value     string `json:"value"`
	} `json:"result"`
}

type NativeSearchSort

type NativeSearchSort struct {
	Type string `json:"type"`
}

type NativeVirtualColumns

type NativeVirtualColumns struct {
	Type       string `json:"type"`
	Name       string `json:"name"`
	Expression string `json:"expression"`
}

type QueryContext

type QueryContext struct {
	QueryID string `json:"queryId,omitempty"`
}

type QueryPlan

type QueryPlan struct {
	Query struct {
		Filter *map[string]interface{} `json:"filter"`
	} `json:"query"`
}