Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PrestoClient ¶
type PrestoClient interface {
// Submits a query to Presto
ExecuteCommand(ctx context.Context, commandStr string, executeArgs PrestoExecuteArgs) (PrestoExecuteResponse, error)
// Cancels a currently running Presto query
KillCommand(ctx context.Context, commandID string) error
// Gets the status of a Presto query
GetCommandStatus(ctx context.Context, commandID string) (PrestoStatus, error)
}
Interface to interact with PrestoClient for Presto tasks
func NewNoopPrestoClient ¶
func NewNoopPrestoClient(cfg *config.Config) PrestoClient
type PrestoExecuteArgs ¶
type PrestoExecuteArgs struct {
RoutingGroup string `json:"routingGroup,omitempty"`
Catalog string `json:"catalog,omitempty"`
Schema string `json:"schema,omitempty"`
Source string `json:"source,omitempty"`
User string `json:"user,omitempty"`
}
Contains information needed to execute a Presto query
type PrestoExecuteResponse ¶
type PrestoExecuteResponse struct {
ID string `json:"id,omitempty"`
NextURI string `json:"nextUri,omitempty"`
}
Representation of a response after submitting a query to Presto
type PrestoStatus ¶
type PrestoStatus int
const ( PrestoStatusUnknown PrestoStatus = iota PrestoStatusWaiting PrestoStatusRunning PrestoStatusFinished PrestoStatusFailed PrestoStatusCancelled )
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.